Functions — github.com/chaozh/MIT-6.824

CodeHub MCPcopy Create free account

hub / github.com/chaozh/MIT-6.824 / functions

Functions379 in github.com/chaozh/MIT-6.824

⨍ Functions 379◇ Types & classes 79

↓ 49 callersMethodjoin

tell the shardctrler that a group is joining.

src/shardkv/config.go:306

↓ 48 callersMethodone

do a complete agreement. it might choose the wrong leader initially, and have to re-submit after giving up. entirely gives up after about 10 seconds.

src/raft/config.go:500

↓ 40 callersMethodconnect

attach server i to the net.

src/raft/config.go:305

↓ 37 callersMethodEnable

enable/disable a ClientEnd.

src/labrpc/labrpc.go:356

↓ 34 callersFunctioncheck

(t *testing.T, ck *Clerk, key string, value string)

src/shardkv/test_test.go:16

↓ 33 callersMethoddisconnect

detach server i from the net.

src/raft/config.go:328

↓ 32 callersFunctionrandstring

src/shardkv/config.go:20

↓ 30 callersMethodQuery

src/shardctrler/client.go:31

↓ 28 callersMethodcheckOneLeader

check that there's exactly one leader. try a few times in case re-elections are needed.

src/raft/config.go:372

↓ 26 callersMethodleave

tell the shardctrler that a group is leaving.

src/shardkv/config.go:324

↓ 25 callersMethodCall

send an RPC, wait for the reply. the return value indicates success; false means that no reply was received from the server.

src/labrpc/labrpc.go:84

↓ 23 callersMethodConnect

connect a ClientEnd to a server. a ClientEnd can only be connected once in its lifetime.

src/labrpc/labrpc.go:348

↓ 23 callersMethodMakeEnd

create a client end-point. start the thread that listens and delivers.

src/labrpc/labrpc.go:313

↓ 20 callersMethodAddService

src/labrpc/labrpc.go:399

↓ 20 callersMethodbegin

start a Test. print the Test message. e.g. cfg.begin("Test (2B): RPC counts aren't too high")

src/raft/config.go:552

↓ 19 callersMethodcleanup

src/raft/config.go:294

↓ 19 callersMethodend

end a Test -- the fact that we got here means there was no failure. print the Passed message, and some performance numbers.

src/raft/config.go:565

↓ 19 callersMethodmakeClient

src/shardkv/config.go:118

↓ 19 callersFunctionmake_config

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

src/raft/config.go:62

↓ 17 callersFunctionGenericTest

Basic test is as follows: one or more clients submitting Append/Get operations to set of servers for some period of time. After the period is over, t

src/kvraft/test_test.go:206

↓ 17 callersMethodPut

(key string, value string)

src/shardkv/client.go:132

↓ 16 callersMethodAddServer

(servername interface{}, rs *Server)

src/labrpc/labrpc.go:332

↓ 16 callersMethodJoin

(servers map[int][]string)

src/shardctrler/client.go:48

↓ 16 callersMethodShutdownGroup

src/shardkv/config.go:197

↓ 16 callersMethodStart

the service using Raft (e.g. a k/v server) wants to start agreement on the next command to be appended to Raft's log. if this server isn't the leader

src/raft/raft.go:212

↓ 15 callersMethodCleanup

src/labrpc/labrpc.go:167

↓ 15 callersFunctionPut

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

src/kvraft/test_test.go:59

↓ 15 callersMethodstart1

start or re-start a Raft. if one already exists, "kill" it first. allocate new outgoing port file names, and a new state persister, to isolate previo

src/raft/config.go:240

↓ 14 callersMethodAppend

(key string, value string)

src/shardkv/client.go:135

↓ 14 callersFunctioncheck

(cfg *config, t *testing.T, ck *Clerk, key string, value string)

src/kvraft/test_test.go:91

↓ 13 callersMethodcleanup

src/shardkv/config.go:79

↓ 13 callersFunctionmake_config

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

src/shardkv/config.go:338

↓ 12 callersMethodStartGroup

src/shardkv/config.go:264

↓ 12 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/kvraft/config.go:191

↓ 11 callersMethodAll

src/kvraft/config.go:157

↓ 11 callersMethodLeave

src/shardctrler/client.go:66

↓ 11 callersFunctionMakeNetwork

src/labrpc/labrpc.go:140

↓ 11 callersFunctionMakeServer

src/labrpc/labrpc.go:393

↓ 11 callersFunctionMakeService

(rcvr interface{})

src/labrpc/labrpc.go:447

↓ 10 callersFunctioncheck

src/shardctrler/test_test.go:12

↓ 9 callersMethodDecode

(e interface{})

src/labgob/labgob.go:52

↓ 9 callersMethodStartServer

start i'th server in gi'th group

src/shardkv/config.go:204

↓ 8 callersMethodCopy

src/raft/persister.go:30

↓ 8 callersMethodEncode

(e interface{})

src/labgob/labgob.go:32

↓ 8 callersMethodGetState

return currentTerm and whether this server believes it is the leader.

src/raft/raft.go:71

↓ 8 callersMethodbegin

start a Test. print the Test message. e.g. cfg.begin("Test (2B): RPC counts aren't too high")

src/kvraft/config.go:399

↓ 8 callersMethodend

end a Test -- the fact that we got here means there was no failure. print the Passed message, and some performance numbers.

src/kvraft/config.go:414

↓ 7 callersMethodReliable

src/labrpc/labrpc.go:171

↓ 7 callersMethodShutdownServer

Shutdown i'th server of gi'th group, by isolating it

src/shardkv/config.go:156

↓ 7 callersMethodStartServer

If restart servers, first call ShutdownServer

src/kvraft/config.go:287

↓ 6 callersMethodAll

src/shardctrler/config.go:130

↓ 6 callersMethodGetCount

src/labrpc/labrpc.go:432

↓ 6 callersMethodcleanup

src/kvraft/config.go:69

↓ 6 callersMethodcrash1

shut down a Raft server but save its persistent state.

src/raft/config.go:105

↓ 6 callersFunctionmake_config

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

src/kvraft/config.go:360

↓ 6 callersMethodnCommitted

how many servers think a log entry is committed?

src/raft/config.go:433

↓ 5 callersMethodAppend

(op porcupine.Operation)

src/kvraft/test_test.go:26

↓ 5 callersMethodDeleteServer

(servername interface{})

src/labrpc/labrpc.go:339

↓ 5 callersFunctionGet

get/put/putappend that keep counts

src/kvraft/test_test.go:41

↓ 5 callersMethodKill

the tester doesn't halt goroutines created by Raft after each test, but it does call the Kill() method. your code can use killed() to check whether K

src/raft/raft.go:234

↓ 5 callersMethodRaftStateSize

src/raft/persister.go:51

↓ 5 callersMethodRead

src/kvraft/test_test.go:32

↓ 5 callersFunctioncheckValue

(value interface{})

src/labgob/labgob.go:68

↓ 5 callersFunctionclone

src/raft/persister.go:24

↓ 5 callersMethodctrlername

controler server name for labrpc.

src/shardkv/config.go:108

↓ 5 callersMethodpartition

Sets up 2 partitions with connectivity between servers in each partition.

src/kvraft/config.go:174

↓ 5 callersFunctionsnapcommon

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

src/raft/test_test.go:1013

↓ 4 callersMethodConnectAll

src/kvraft/config.go:165

↓ 4 callersMethodDone

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

src/mr/coordinator.go:48

↓ 4 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 can send an RPC w

src/kvraft/client.go:39

↓ 4 callersMethodbytesTotal

src/raft/config.go:362

↓ 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:107

↓ 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:131

↓ 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 callersMethodservername

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

src/shardkv/config.go:114

↓ 4 callersMethodwait

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

src/raft/config.go:459

↓ 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 modif

src/shardkv/client.go:68

↓ 3 callersMethodGetTotalBytes

src/labrpc/labrpc.go:377

↓ 3 callersMethodLeader

src/shardctrler/config.go:299

↓ 3 callersMethodLogSize

Maximum log size across all servers

src/kvraft/config.go:82

↓ 3 callersFunctionNewDecoder

src/labgob/labgob.go:46

↓ 3 callersFunctionNewEncoder

src/labgob/labgob.go:26

↓ 3 callersMethodReadSnapshot

src/raft/persister.go:66

↓ 3 callersFunctionbitsetIndex

src/porcupine/bitset.go:25

↓ 3 callersFunctioncheckEvents

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

src/porcupine/checker.go:350

↓ 3 callersFunctioncheckOperations

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

src/porcupine/checker.go:360

↓ 3 callersMethodchecklogs

check that no server's log is too big.

src/shardkv/config.go:91

↓ 3 callersFunctionfillDefault

src/porcupine/checker.go:250

↓ 3 callersFunctioninsertBefore

(n *node, mark *node)

src/porcupine/checker.go:65

↓ 3 callersFunctionkey2shard

which shard is a key in? please use this function, and please do not change it.

src/shardkv/client.go:22

↓ 3 callersMethodop

src/kvraft/config.go:406

↓ 3 callersMethodrpcCount

src/raft/config.go:350

↓ 3 callersMethodsetunreliable

src/raft/config.go:358

↓ 2 callersFunctionAppend

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

src/kvraft/test_test.go:75

↓ 2 callersMethodConnectAll

src/shardctrler/config.go:138

↓ 2 callersMethodConnectClient

(ck *Clerk, to []int)

src/kvraft/config.go:232

↓ 2 callersMethodConnectClientUnlocked

caller should hold cfg.mu

src/shardctrler/config.go:196

↓ 2 callersMethodConnectClientUnlocked

caller should hold cfg.mu

src/kvraft/config.go:223

next →1–100 of 379, ranked by callers