Functions — github.com/aQuaYi/MIT-6.824-Distributed-Systems

hub / github.com/aQuaYi/MIT-6.824-Distributed-Systems / functions

Functions473 in github.com/aQuaYi/MIT-6.824-Distributed-Systems

⨍ Functions 473◇ Types & classes 96

↓ 1 callersFunctionusage

()

src/main/pbc.go:25

↓ 1 callersFunctionworker

Concurrent crawler with channels 使用通道来完成并行爬虫 worker 爬取 url 页面后，把结果发送到 ch 如果爬取失败，就发送一个空切片到 ch

Lectures/LEC02/crawler/crawler.go:102

MethodAppendEntries

AppendEntries is

src/raft/rpc_appendEntries.go:53

FunctionAsyncDataFetcher

(fetch)

Lectures/LEC03/6.824 Lab 2: Raft_files/vomnibar_data/utils.js:410

FunctionBackgroundCompleter

(name1)

Lectures/LEC03/6.824 Lab 2: Raft_files/vomnibar_data/vomnibar.js:338

FunctionCheckEvents

(model Model, history []Event)

src/linearizability/linearizability.go:272

FunctionCheckOperations

(model Model, history []Operation)

src/linearizability/linearizability.go:229

MethodConnectClient

(ck *Clerk, to []int)

src/shardmaster/config.go:205

FunctionDPrintf

(format string, a ...interface{})

src/kvraft/server.go:13

MethodDisconnectClient

(ck *Clerk, from []int)

src/shardmaster/config.go:221

MethodDisconnectClient

(ck *Clerk, from []int)

src/kvraft/config.go:248

MethodDoTask

DoTask is called by the master when a new task is being scheduled on this worker.

src/mapreduce/worker.go:40

MethodFetch

(url string)

Lectures/LEC02/crawler/crawler.go:172

MethodGet

(args *GetArgs, reply *GetReply)

src/kvraft/server.go:37

MethodGet

(args *GetArgs, reply *GetReply)

src/shardkv/server.go:28

MethodGet

Get 是 *KV 为 rpc 提供的获取 key 对应的值的方法

Lectures/LEC02/kv/kv.go:100

MethodGetCount

get a server's count of incoming RPCs.

src/labrpc/labrpc.go:351

MethodHandler1

(args string, reply *int)

src/labrpc/test_test.go:23

MethodHandler2

(args int, reply *string)

src/labrpc/test_test.go:30

MethodHandler3

(args int, reply *int)

src/labrpc/test_test.go:37

MethodHandler4

args is a pointer

src/labrpc/test_test.go:45

MethodHandler5

args is a not pointer

src/labrpc/test_test.go:50

FunctionHandlerStack

()

Lectures/LEC03/6.824 Lab 2: Raft_files/vomnibar_data/handler_stack.js:8

MethodInstallSnapshot

InstallSnapshot is

src/raft/rpc_snapshot.go:23

FunctionJobRunner

(jobs)

Lectures/LEC03/6.824 Lab 2: Raft_files/vomnibar_data/utils.js:442

MethodJoin

(args *JoinArgs, reply *JoinReply)

src/shardmaster/server.go:23

FunctionKvModel

()

src/linearizability/models.go:15

MethodLeave

(args *LeaveArgs, reply *LeaveReply)

src/shardmaster/server.go:27

MethodLen

()

src/linearizability/linearizability.go:25

MethodLess

(i, j int)

src/linearizability/linearizability.go:33

MethodLogSize

Maximum log size across all servers

src/shardmaster/config.go:67

FunctionMapFunc

Create input file with N numbers Check if we have N numbers in output file Split in words

src/mapreduce/test_test.go:26

MethodMove

(args *MoveArgs, reply *MoveReply)

src/shardmaster/server.go:31

FunctionNoPartition

(history []Operation)

src/linearizability/model.go:41

FunctionNoPartitionEvent

(history []Event)

src/linearizability/model.go:45

MethodPut

Put 是 *KV 为 rpc 提供的放入 (args.key, args.val) 的方法

Lectures/LEC02/kv/kv.go:129

MethodPutAppend

(args *PutAppendArgs, reply *PutAppendReply)

src/kvraft/server.go:41

MethodPutAppend

(args *PutAppendArgs, reply *PutAppendReply)

src/shardkv/server.go:32

MethodQuery

(args *QueryArgs, reply *QueryReply)

src/shardmaster/server.go:35

FunctionReduceFunc

Just return key

src/mapreduce/test_test.go:37

FunctionRegisterName

(name string, value interface{})

src/labgob/labgob.go:63

MethodRequestVote

RequestVote 投票工作 example RequestVote RPC handler. func (rf *Raft) RequestVote(args *RequestVoteArgs, reply *RequestVoteReply) { // Your code here (2

src/raft/rpc_requestVote.go:94

MethodSaveStateAndSnapshot

SaveStateAndSnapshot save both Raft state and K/V snapshot as a single atomic action, to help avoid them getting out of sync.

src/raft/persister.go:59

FunctionShallowEqual

(state1, state2 interface{})

src/linearizability/model.go:49

MethodShutdown

Shutdown is an RPC method that shuts down the Master's RPC server.

src/mapreduce/master_rpc.go:12

MethodShutdown

Shutdown is called by the master when all work has been completed. We should respond with the number of tasks we have processed.

src/mapreduce/worker.go:98

FunctionSimpleCache

(expiry, entries)

Lectures/LEC03/6.824 Lab 2: Raft_files/vomnibar_data/utils.js:345

MethodSnapshotSize

SnapshotSize 快照尺寸

src/raft/persister.go:74

MethodString

()

src/raft/rpc_appendEntries.go:19

MethodString

()

src/raft/rpc_appendEntries.go:31

MethodString

()

src/raft/applyMsg.go:25

MethodString

()

src/raft/rpc_requestVote.go:20

MethodString

()

src/raft/rpc_requestVote.go:35

MethodString

()

src/raft/raft_new.go:72

MethodSwap

(i, j int)

src/linearizability/linearizability.go:29

FunctionTestBackup2B

(t *testing.T)

src/raft/test_test.go:327

FunctionTestBasic

(t *testing.T)

src/shardmaster/test_test.go:80

FunctionTestBasic

(t *testing.T)

src/labrpc/test_test.go:54

FunctionTestBasic3A

(t *testing.T)

src/kvraft/test_test.go:426

FunctionTestBasicAgree2B

(t *testing.T)

src/raft/test_test.go:83

FunctionTestBenchmark

(t *testing.T)

src/labrpc/test_test.go:499

FunctionTestCapital

make sure we check capitalization labgob prints one warning during this test.

src/labgob/test_test.go:119

FunctionTestChallenge1Concurrent

(t *testing.T)

src/shardkv/test_test.go:728

FunctionTestChallenge1Delete

optional test to see whether servers are deleting shards for which they are no longer responsible.

src/shardkv/test_test.go:647

FunctionTestChallenge2Partial

optional test to see whether servers can handle operations on shards that have been received as a part of a config migration when the entire migratio

src/shardkv/test_test.go:871

FunctionTestChallenge2Unaffected

optional test to see whether servers can handle shards that are not affected by a config change while the config change is underway

src/shardkv/test_test.go:801

FunctionTestConcurrent1

(t *testing.T)

src/shardkv/test_test.go:296

FunctionTestConcurrent2

this tests the various sources from which a re-starting group might need to fetch shard contents.

src/shardkv/test_test.go:377

FunctionTestConcurrent3A

(t *testing.T)

src/kvraft/test_test.go:431

FunctionTestConcurrentMany

test RPCs from concurrent ClientEnds

src/labrpc/test_test.go:206

FunctionTestConcurrentOne

test concurrent RPCs from a single ClientEnd

src/labrpc/test_test.go:317

FunctionTestConcurrentStarts2B

(t *testing.T)

src/raft/test_test.go:188

FunctionTestCount2B

(t *testing.T)

src/raft/test_test.go:399

FunctionTestCounts

test net.GetCount()

src/labrpc/test_test.go:170

FunctionTestDefault

check that we warn when someone sends a default value over RPC but the target into which we're decoding holds a non-default value, which GOB seems no

src/labgob/test_test.go:146

FunctionTestDisconnect

does net.Enable(endname, false) really disconnect a client?

src/labrpc/test_test.go:131

FunctionTestFailAgree2B

(t *testing.T)

src/raft/test_test.go:106

FunctionTestFailNoAgree2B

(t *testing.T)

src/raft/test_test.go:137

FunctionTestFigure82C

Test the scenarios described in Figure 8 of the extended Raft paper. Each iteration asks a leader, if there is one, to insert a command in the Raft l

src/raft/test_test.go:641

FunctionTestFigure8Unreliable2C

(t *testing.T)

src/raft/test_test.go:726

FunctionTestGOB

test that we didn't break GOB.

src/labgob/test_test.go:27

FunctionTestInitialElection2A

(t *testing.T)

src/raft/test_test.go:22

FunctionTestJoinLeave

(t *testing.T)

src/shardkv/test_test.go:89

FunctionTestKilled

if an RPC is stuck in a server, and the server is killed with DeleteServer(), does the RPC get un-stuck?

src/labrpc/test_test.go:454

FunctionTestManyFailures

(t *testing.T)

src/mapreduce/test_test.go:207

FunctionTestManyPartitionsManyClients3A

(t *testing.T)

src/kvraft/test_test.go:556

FunctionTestManyPartitionsOneClient3A

(t *testing.T)

src/kvraft/test_test.go:551

FunctionTestMissChange

(t *testing.T)

src/shardkv/test_test.go:210

FunctionTestMulti

(t *testing.T)

src/shardmaster/test_test.go:252

FunctionTestOneFailure

(t *testing.T)

src/mapreduce/test_test.go:194

FunctionTestOnePartition3A

Submit a request in the minority partition and check that the requests doesn't go through until the partition heals. The leader in the original netwo

src/kvraft/test_test.go:476

FunctionTestParallelBasic

(t *testing.T)

src/mapreduce/test_test.go:162

FunctionTestParallelCheck

(t *testing.T)

src/mapreduce/test_test.go:174

FunctionTestPersist12C

(t *testing.T)

src/raft/test_test.go:509

FunctionTestPersist22C

(t *testing.T)

src/raft/test_test.go:555

FunctionTestPersist32C

(t *testing.T)

src/raft/test_test.go:601

FunctionTestPersistConcurrent3A

(t *testing.T)

src/kvraft/test_test.go:566

FunctionTestPersistConcurrentUnreliable3A

(t *testing.T)

src/kvraft/test_test.go:571

FunctionTestPersistOneClient3A

(t *testing.T)

src/kvraft/test_test.go:561

FunctionTestPersistPartition3A

(t *testing.T)

src/kvraft/test_test.go:576

← previous next →301–400 of 473, ranked by callers