Functions — github.com/YXG520/MIT6.824-6.5840

hub / github.com/YXG520/MIT6.824-6.5840 / functions

Functions548 in github.com/YXG520/MIT6.824-6.5840

⨍ Functions 548◇ Types & classes 106

↓ 5 callersFunctionsnapcommon

(t *testing.T, name string, disconnect bool, reliable bool, crash bool)

src/raft/test_test.go:1121

↓ 5 callersMethodstartCommand

(command Op, timeoutPeriod time.Duration)

src/shardkv/server.go:583

↓ 4 callersMethodConnectAll

()

src/kvraft/config.go:168

↓ 4 callersMethodDone

main/mrcoordinator.go calls Done() periodically to find out if the entire job has finished.

src/mr/coordinator.go:46

↓ 4 callersMethodGet

(key string)

src/kvraft/client.go:28

↓ 4 callersMethodGet

Get GetType fetch the current value for a key. returns "" if the key does not exist. keeps trying forever in the face of all other errors. You will ha

src/shardkv/client.go:71

↓ 4 callersMethodKilled

()

src/shardkv_with_bug/server.go:490

↓ 4 callersMethodSnapshot

the service says it has created a snapshot that has all info up to and including index. this means the service no longer needs the log through (and in

src/raft/snapshot.go:9

↓ 4 callersMethodbytesTotal

()

src/raft/config.go:416

↓ 4 callersMethodchecklogs

check that no server's log is too big.

src/shardkv/config.go:91

↓ 4 callersMethodconnectUnlocked

attach server i to servers listed in to caller must hold cfg.mu

src/shardctrler/config.go:80

↓ 4 callersMethodconnectUnlocked

attach server i to servers listed in to caller must hold cfg.mu

src/kvraft/config.go:110

↓ 4 callersMethoddisconnectUnlocked

detach server i from the servers listed in from caller must hold cfg.mu

src/shardctrler/config.go:104

↓ 4 callersMethoddisconnectUnlocked

detach server i from the servers listed in from caller must hold cfg.mu

src/kvraft/config.go:134

↓ 4 callersMethodempty

()

src/raft/log.go:50

↓ 4 callersMethodgetWaitCh

(index int)

src/shardkv_with_bug/server.go:321

↓ 4 callersMethodmakeClient

Create a clerk with clerk specific server names. Give it connections to all of the servers, but for now enable only connections to servers in to[].

src/shardctrler/config.go:164

↓ 4 callersMethodsendRequestAppendEntries

(isHeartbeat bool, server int, args *RequestAppendEntriesArgs, reply *RequestAppendEntriesReply)

src/raft/raft.go:234

↓ 4 callersMethodservername

shard server name for labrpc. i'th server of group gid.

src/shardkv/config.go:114

↓ 4 callersMethodservername

shard server name for labrpc. i'th server of group gid.

src/shardkv_with_bug/config.go:114

↓ 4 callersMethodwait

wait for at least n servers to commit. but don't wait forever.

src/raft/config.go:529

↓ 3 callersMethodGet

fetch the current value for a key. returns "" if the key does not exist. keeps trying forever in the face of all other errors. You will have to modify

src/shardkv_with_bug/client.go:73

↓ 3 callersMethodGetTotalBytes

()

src/labrpc/labrpc.go:391

↓ 3 callersMethodLeader

()

src/shardctrler/config.go:299

↓ 3 callersMethodLogSize

Maximum log size across all servers

src/kvraft/config.go:85

↓ 3 callersFunctionNewDecoder

(r io.Reader)

src/labgob/labgob.go:48

↓ 3 callersFunctionNewEncoder

(w io.Writer)

src/labgob/labgob.go:28

↓ 3 callersMethodReadRaftState

()

src/raft/persister.go:39

↓ 3 callersMethodStartAppendEntries

(heart bool)

src/raft/raft.go:324

↓ 3 callersMethodappendL

(newEntries ...Entry)

src/raft/log.go:33

↓ 3 callersFunctionbitsetIndex

(pos uint)

src/porcupine/bitset.go:25

↓ 3 callersFunctioncheckEvents

(model Model, history []Event, verbose bool, timeout time.Duration)

src/porcupine/checker.go:355

↓ 3 callersFunctioncheckOperations

(model Model, history []Operation, verbose bool, timeout time.Duration)

src/porcupine/checker.go:365

↓ 3 callersMethodchecklogs

check that no server's log is too big.

src/shardkv_with_bug/config.go:91

↓ 3 callersFunctionfillDefault

(model Model)

src/porcupine/checker.go:255

↓ 3 callersMethodgetAppendEntries

这是按照相对FirstLogIndex的偏移量来取日志的

src/raft/log.go:40

↓ 3 callersMethodgetWaitCh

(index int)

src/kvraft/server.go:127

↓ 3 callersFunctionifCond

(cond bool, a, b interface{})

src/raft/util.go:33

↓ 3 callersFunctioninsertBefore

(n *node, mark *node)

src/porcupine/checker.go:70

↓ 3 callersMethodkilled

()

src/kvraft/server.go:265

↓ 3 callersFunctionmax

src/kvraft/config.go:410

↓ 3 callersMethodprintOp

(op Op)

src/shardctrler/server.go:124

↓ 3 callersMethodrpcCount

(server int)

src/raft/config.go:404

↓ 3 callersMethodsetunreliable

(unrel bool)

src/raft/config.go:412

↓ 3 callersMethodstartCommand

(command Op, timeoutPeriod time.Duration)

src/shardkv_with_bug/server.go:505

↓ 3 callersMethodtryCommitL

主节点对日志进行提交，其条件是多余一半的从节点的commitIndex>=leader节点当前提交的commitIndex

src/raft/log_replication.go:181

↓ 3 callersMethodunregisterTask

(index int)

src/shardkv_with_bug/server.go:332

↓ 2 callersFunctionAppend

(cfg *config, ck *Clerk, key string, value string, log *OpLog, cli int)

src/kvraft/test_test.go:79

↓ 2 callersMethodConnectAll

()

src/shardctrler/config.go:138

↓ 2 callersMethodConnectClient

(ck *Clerk, to []int)

src/kvraft/config.go:236

↓ 2 callersMethodConnectClientUnlocked

caller should hold cfg.mu

src/shardctrler/config.go:196

↓ 2 callersMethodConnectClientUnlocked

caller should hold cfg.mu

src/kvraft/config.go:227

↓ 2 callersMethodDecodeSnapShot

DecodeSnapShot install a given snapshot

src/shardkv/server.go:500

↓ 2 callersFunctionGenericTestSpeed

Check that ops are committed fast enough, better than 1 per heartbeat interval

src/kvraft/test_test.go:397

↓ 2 callersMethodGetLastIncludeIndex

()

src/raft/raft.go:840

↓ 2 callersMethodGetTotalCount

()

src/labrpc/labrpc.go:386

↓ 2 callersMethodKill

the tester calls Kill() when a ShardCtrler instance won't be needed again. you are not required to do anything in Kill(), but it might be convenient t

src/shardctrler/server.go:347

↓ 2 callersMethodKill

the tester calls Kill() when a KVServer instance won't be needed again. for your convenience, we supply code to set rf.dead (without needing a lock),

src/kvraft/server.go:258

↓ 2 callersMethodKill

------------------------------------------------------utils封装部分---------------------------------------------------- Kill the tester calls Kill() when

src/shardkv/server.go:531

↓ 2 callersMethodKill

the tester calls Kill() when a ShardKV instance won't be needed again. you are not required to do anything in Kill(), but it might be convenient to (f

src/shardkv_with_bug/server.go:483

↓ 2 callersFunctionMakePersister

()

src/raft/persister.go:20

↓ 2 callersMethodMove

(shard int, gid int)

src/shardctrler/client.go:125

↓ 2 callersMethodPut

(key string, value string)

src/kvraft/client.go:92

↓ 2 callersMethodPutAppend

(key string, value string, op string)

src/kvraft/client.go:59

↓ 2 callersMethodPutAppend

PutAppend shared by Put and Append. You will have to modify this function.

src/shardkv/client.go:116

↓ 2 callersMethodPutAppend

shared by Put and Append. You will have to modify this function.

src/shardkv_with_bug/client.go:116

↓ 2 callersMethodRaft

needed by shardkv_old tester

src/shardctrler/server.go:359

↓ 2 callersMethodShutdownServer

Shutdown a server by isolating it

src/shardctrler/config.go:228

↓ 2 callersMethodSnapshotSize

Maximum snapshot size across all servers

src/kvraft/config.go:97

↓ 2 callersMethodStartServer

If restart servers, first call ShutdownServer

src/shardctrler/config.go:260

↓ 2 callersFunctioncheckClntAppends

check that for a specific client all known appends are present in a value, and in order

src/kvraft/test_test.go:139

↓ 2 callersMethodcheckFinished

()

src/raft/config.go:339

↓ 2 callersMethodcheckLogs

(i int, m ApplyMsg)

src/raft/config.go:140

↓ 2 callersFunctioncheckParallel

(model Model, history [][]entry, computeInfo bool, timeout time.Duration)

src/porcupine/checker.go:274

↓ 2 callersMethodcheckTerms

check that everyone agrees on the term.

src/raft/config.go:462

↓ 2 callersMethodcheckTimeout

()

src/kvraft/config.go:65

↓ 2 callersMethodcheckTimeout

()

src/raft/config.go:332

↓ 2 callersFunctioncheck_same_config

(t *testing.T, c1 Config, c2 Config)

src/shardctrler/test_test.go:56

↓ 2 callersMethodcleanup

()

src/shardctrler/config.go:54

↓ 2 callersMethodcloneShard

判断当前节点是否处于迁移期

src/shardkv/server.go:616

↓ 2 callersMethodcloneShard

判断当前节点是否处于迁移期

src/shardkv_with_bug/server.go:543

↓ 2 callersFunctioncoordinatorSock

Add your RPC definitions here. Cook up a unique-ish UNIX-domain socket name in /var/tmp, for the coordinator. Can't use the current directory since At

src/mr/rpc.go:31

↓ 2 callersMethoddecodeSnapshot

解码快照

src/kvraft/snapshot.go:46

↓ 2 callersMethoddecodeSnapshot

解码快照

src/shardkv_with_bug/snapshot.go:46

↓ 2 callersMethodgetWaitCh

(index int)

src/shardkv/server.go:552

↓ 2 callersMethodhash

()

src/porcupine/bitset.go:54

↓ 2 callersMethodingestSnap

returns "" or error string

src/raft/config.go:183

↓ 2 callersFunctioninternalChurn

(t *testing.T, unreliable bool)

src/raft/test_test.go:966

↓ 2 callersMethodisServerDead

(endname interface{}, servername interface{}, server *Server)

src/labrpc/labrpc.go:222

↓ 2 callersMethodjoinm

(gis []int)

src/shardkv/config.go:310

↓ 2 callersMethodjoinm

(gis []int)

src/shardkv_with_bug/config.go:310

↓ 2 callersMethodkilled

()

src/raft/raft.go:308

↓ 2 callersMethodkilled

()

src/shardkv/server.go:537

↓ 2 callersMethodleavem

(gis []int)

src/shardkv/config.go:328

↓ 2 callersMethodleavem

(gis []int)

src/shardkv_with_bug/config.go:328

↓ 2 callersFunctionmake_config

(t *testing.T, n int, unreliable bool)

src/shardctrler/config.go:334

↓ 2 callersFunctionmaybeCrash

()

src/mrapps/nocrash.go:17

↓ 2 callersFunctionmaybeCrash

()

src/mrapps/crash.go:20

↓ 2 callersFunctionmin

(a, b int)

src/raft/util.go:26

← previous next →101–200 of 548, ranked by callers