Functions — github.com/Vanilla-Beauty/MIT6.5840

hub / github.com/Vanilla-Beauty/MIT6.5840 / functions

Functions443 in github.com/Vanilla-Beauty/MIT6.5840

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:563

↓ 49 callersMethodjoin

tell the shardctrler that a group is joining.

src/shardkv/config.go:306

↓ 43 callersMethodconnect

attach server i to the net.

src/raft/config.go:361

↓ 40 callersFunctionDPrintf

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

src/raft/util.go:11

↓ 38 callersMethoddisconnect

detach server i from the net.

src/raft/config.go:384

↓ 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

↓ 32 callersMethodcheckOneLeader

check that one of the connected servers thinks it is the leader, and that no other connected server thinks otherwise. try a few times in case re-elec

src/raft/config.go:431

↓ 32 callersFunctionrandstring

(n int)

src/shardkv/config.go:20

↓ 30 callersMethodQuery

(num int)

src/shardctrler/client.go:47

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

↓ 27 callersFunctionSDPrintf

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

src/shardctrler/util.go:21

↓ 26 callersMethodleave

tell the shardctrler that a group is leaving.

src/shardkv/config.go:324

↓ 24 callersMethodbegin

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

src/raft/config.go:617

↓ 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

↓ 23 callersMethodcleanup

()

src/raft/config.go:349

↓ 23 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:630

↓ 23 callersFunctionmake_config

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

src/raft/config.go:69

↓ 20 callersMethodAddService

(svc *Service)

src/labrpc/labrpc.go:397

↓ 20 callersFunctionServerLog

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

src/kvraft/server.go:28

↓ 20 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:276

↓ 19 callersMethodJoin

(servers map[int][]string)

src/shardctrler/client.go:66

↓ 19 callersMethodmakeClient

()

src/shardkv/config.go:118

↓ 18 callersMethodDecode

(e interface{})

src/labgob/labgob.go:52

↓ 18 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 previou

src/raft/config.go:278

↓ 17 callersMethodEncode

(e interface{})

src/labgob/labgob.go:32

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

↓ 17 callersMethodPut

(key string, value string)

src/shardkv/client.go:124

↓ 16 callersMethodAddServer

(servername interface{}, rs *Server)

src/labrpc/labrpc.go:332

↓ 16 callersMethodRealLogIdx

(vIdx int)

src/raft/raft.go:121

↓ 16 callersMethodShutdownGroup

(gi int)

src/shardkv/config.go:197

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

↓ 14 callersMethodAppend

(key string, value string)

src/shardkv/client.go:127

↓ 14 callersFunctioncheck

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

src/kvraft/test_test.go:97

↓ 13 callersMethodVirtualLogIdx

(rIdx int)

src/raft/raft.go:126

↓ 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

(gi int)

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

(gids []int)

src/shardctrler/client.go:85

↓ 11 callersFunctionMakeNetwork

()

src/labrpc/labrpc.go:140

↓ 11 callersFunctionMakeServer

()

src/labrpc/labrpc.go:391

↓ 11 callersFunctionMakeService

(rcvr interface{})

src/labrpc/labrpc.go:445

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

src/raft/raft.go:152

↓ 10 callersFunctionDPrintf

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

src/kvraft/server.go:21

↓ 10 callersFunctioncheck

import "time"

src/shardctrler/test_test.go:13

↓ 9 callersMethodStartServer

start i'th server in gi'th group

src/shardkv/config.go:204

↓ 9 callersMethodcrash1

shut down a Raft server but save its persistent state.

src/raft/config.go:113

↓ 8 callersMethodCopy

()

src/raft/persister.go:30

↓ 8 callersMethodGetState

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

src/raft/raft.go:133

↓ 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

↓ 8 callersMethodnCommitted

how many servers think a log entry is committed?

src/raft/config.go:496

↓ 7 callersFunctionControlerLog

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

src/shardctrler/util.go:28

↓ 7 callersMethodReliable

(yes bool)

src/labrpc/labrpc.go:171

↓ 7 callersMethodResetVoteTimer

()

src/raft/raft.go:112

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

↓ 6 callersMethodRaftStateSize

()

src/raft/persister.go:45

↓ 6 callersMethodReadSnapshot

()

src/raft/persister.go:60

↓ 6 callersMethodcleanup

()

src/kvraft/config.go:69

↓ 6 callersFunctionmake_config

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

src/kvraft/config.go:360

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

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

src/raft/raft.go:254

↓ 5 callersMethodLogInfoDBExecute

(opArgs *Op, err Err, res string)

src/kvraft/server.go:103

↓ 5 callersMethodRead

()

src/kvraft/test_test.go:32

↓ 5 callersFunctioncheckValue

(value interface{})

src/labgob/labgob.go:68

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

↓ 4 callersFunctionCallForReportStatus

(succesType MsgType, taskID int)

src/mr/worker.go:174

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

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

src/kvraft/client.go:53

↓ 4 callersMethodGetSeq

()

src/shardctrler/client.go:33

↓ 4 callersMethodHandleOp

(opArgs *Op)

src/shardctrler/server.go:88

↓ 4 callersMethodbytesTotal

()

src/raft/config.go:418

↓ 4 callersFunctionclone

(orig []byte)

src/raft/persister.go:24

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

↓ 3 callersMethodCheckAppendConfig

(newConfig Config)

src/shardctrler/server.go:58

↓ 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/client.go:62

↓ 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

(r io.Reader)

src/labgob/labgob.go:46

↓ 3 callersFunctionNewEncoder

(w io.Writer)

src/labgob/labgob.go:26

↓ 3 callersFunctionbitsetIndex

(pos uint)

src/porcupine/bitset.go:25

next →1–100 of 443, ranked by callers