Functions — github.com/WenbinZhu/mit-6.824-labs

CodeHub MCPcopy Create free account

hub / github.com/WenbinZhu/mit-6.824-labs / functions

Functions386 in github.com/WenbinZhu/mit-6.824-labs

⨍ Functions 386◇ Types & classes 90

↓ 49 callersMethodjoin

tell the shardmaster that a group is joining.

src/shardkv/config.go:303

↓ 42 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:430

↓ 37 callersMethodEnable

enable/disable a ClientEnd.

src/labrpc/labrpc.go:354

↓ 35 callersFunctioncheck

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

src/shardkv/test_test.go:16

↓ 35 callersMethodconnect

attach server i to the net.

src/raft/config.go:235

↓ 32 callersFunctionrandstring

src/shardkv/config.go:20

↓ 29 callersMethoddisconnect

detach server i from the net.

src/raft/config.go:258

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

↓ 28 callersMethodQuery

src/shardmaster/client.go:31

↓ 26 callersMethodleave

tell the shardmaster that a group is leaving.

src/shardkv/config.go:321

↓ 23 callersMethodConnect

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

src/labrpc/labrpc.go:346

↓ 23 callersMethodMakeEnd

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

src/labrpc/labrpc.go:311

↓ 22 callersMethodcheckOneLeader

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

src/raft/config.go:302

↓ 20 callersMethodAddService

src/labrpc/labrpc.go:397

↓ 19 callersMethodmakeClient

src/shardkv/config.go:115

↓ 18 callersMethodbegin

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

src/raft/config.go:482

↓ 17 callersMethodPut

(key string, value string)

src/shardkv/client.go:132

↓ 17 callersMethodcleanup

src/raft/config.go:224

↓ 17 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:495

↓ 17 callersFunctionmake_config

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

src/raft/config.go:60

↓ 16 callersMethodAddServer

(servername interface{}, rs *Server)

src/labrpc/labrpc.go:330

↓ 16 callersMethodJoin

(servers map[int][]string)

src/shardmaster/client.go:48

↓ 16 callersMethodShutdownGroup

src/shardkv/config.go:194

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

↓ 15 callersMethodCleanup

src/labrpc/labrpc.go:165

↓ 15 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:154

↓ 15 callersFunctionPut

(cfg *config, ck *Clerk, key string, value string)

src/kvraft/test_test.go:29

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

↓ 14 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:136

↓ 13 callersMethodcleanup

src/shardkv/config.go:79

↓ 13 callersFunctionmake_config

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

src/shardkv/config.go:335

↓ 12 callersMethodDecode

(e interface{})

src/labgob/labgob.go:52

↓ 12 callersMethodStartGroup

src/shardkv/config.go:261

↓ 12 callersFunctioncheckError

(err error, format string, v ...interface{})

src/mr/worker.go:216

↓ 11 callersMethodEncode

(e interface{})

src/labgob/labgob.go:32

↓ 11 callersMethodLeave

src/shardmaster/client.go:66

↓ 11 callersFunctionMakeNetwork

src/labrpc/labrpc.go:138

↓ 11 callersFunctionMakeServer

src/labrpc/labrpc.go:391

↓ 11 callersFunctionMakeService

(rcvr interface{})

src/labrpc/labrpc.go:445

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

↓ 10 callersMethodAll

src/kvraft/config.go:157

↓ 10 callersFunctioncheck

(t *testing.T, groups []int, ck *Clerk)

src/shardmaster/test_test.go:11

↓ 9 callersMethodStartServer

start i'th server in gi'th group

src/shardkv/config.go:201

↓ 9 callersMethodgetLastIndex

get the index of the last log entry. lock must be held before calling this.

src/raft/raft.go:194

↓ 8 callersMethodCopy

src/raft/persister.go:24

↓ 8 callersMethodGetState

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

src/raft/raft.go:101

↓ 8 callersMethodStartServer

If restart servers, first call ShutdownServer

src/kvraft/config.go:287

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

↓ 7 callersMethodShutdownServer

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

src/shardkv/config.go:153

↓ 6 callersMethodAll

src/shardmaster/config.go:130

↓ 6 callersMethodConnectAll

src/kvraft/config.go:165

↓ 6 callersFunctionGet

get/put/putappend that keep counts

src/kvraft/test_test.go:23

↓ 6 callersMethodGetCount

src/labrpc/labrpc.go:430

↓ 6 callersMethodcleanup

src/kvraft/config.go:69

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

↓ 6 callersMethodpersist

save Raft's persistent state to stable storage, where it can later be retrieved after a crash and restart. see paper's Figure 2 for a description of

src/raft/raft.go:115

↓ 5 callersMethodDeleteServer

(servername interface{})

src/labrpc/labrpc.go:337

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

↓ 5 callersFunctioncheckValue

(value interface{})

src/labgob/labgob.go:68

↓ 5 callersMethodcrash1

shut down a Raft server but save its persistent state.

src/raft/config.go:99

↓ 5 callersMethodmastername

master server name for labrpc.

src/shardkv/config.go:105

↓ 5 callersMethodpartition

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

src/kvraft/config.go:174

↓ 4 callersMethodDone

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

src/mr/master.go:177

↓ 4 callersMethodLogSize

Maximum log size across all servers

src/kvraft/config.go:82

↓ 4 callersMethodRaftStateSize

src/raft/persister.go:45

↓ 4 callersMethodbytesTotal

src/raft/config.go:292

↓ 4 callersMethodconnectUnlocked

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

src/shardmaster/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/shardmaster/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/shardmaster/config.go:164

↓ 4 callersMethodsendToChannel

send value to an un-buffered channel without blocking

src/raft/raft.go:216

↓ 4 callersMethodservername

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

src/shardkv/config.go:111

↓ 4 callersMethodstepDownToFollower

step down to follower when getting higher term, lock must be held before calling this.

src/raft/raft.go:227

↓ 4 callersMethodwait

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

src/raft/config.go:389

↓ 3 callersFunctionAppend

(cfg *config, ck *Clerk, key string, value string)

src/kvraft/test_test.go:34

↓ 3 callersMethodGetTotalBytes

src/labrpc/labrpc.go:375

↓ 3 callersFunctionNewDecoder

src/labgob/labgob.go:46

↓ 3 callersFunctionNewEncoder

src/labgob/labgob.go:26

↓ 3 callersFunctionbitsetIndex

src/porcupine/bitset.go:25

↓ 3 callersFunctioncall

send an RPC request to the master, wait for the response. usually returns true. returns false if something goes wrong.

src/mr/worker.go:227

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

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

↓ 3 callersMethodsetunreliable

src/raft/config.go:288

↓ 3 callersFunctionspawn_clients_and_wait

spawn ncli clients and wait until they are all done

src/kvraft/test_test.go:57

↓ 2 callersMethodConnectAll

src/shardmaster/config.go:138

↓ 2 callersMethodConnectClient

(ck *Clerk, to []int)

src/kvraft/config.go:232

↓ 2 callersMethodConnectClientUnlocked

caller should hold cfg.mu

src/shardmaster/config.go:196

↓ 2 callersMethodConnectClientUnlocked

caller should hold cfg.mu

src/kvraft/config.go:223

↓ 2 callersFunctionGenericTestLinearizability

similar to GenericTest, but with clients doing random operations (and using a linearizability checker)

src/kvraft/test_test.go:296

next →1–100 of 386, ranked by callers