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

↓ 90 callersFunctionDPrintf

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

src/raft/util.go:12

↓ 65 callersFunctionDPrintf

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

src/shardkv_with_bug/util.go:8

↓ 63 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:570

↓ 52 callersMethodSayMeL

()

src/raft/raft.go:709

↓ 49 callersMethodjoin

tell the shardctrler that a group is joining.

src/shardkv_with_bug/config.go:306

↓ 48 callersMethodjoin

tell the shardctrler that a group is joining.

src/shardkv/config.go:306

↓ 46 callersMethodEnable

enable/disable a ClientEnd.

src/labrpc/labrpc.go:370

↓ 43 callersMethodconnect

attach server i to the net.

src/raft/config.go:357

↓ 40 callersMethodQuery

(num int)

src/shardctrler/client.go:41

↓ 38 callersMethoddisconnect

detach server i from the net.

src/raft/config.go:382

↓ 35 callersFunctioncheck

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

src/shardkv/test_test.go:18

↓ 34 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:86

↓ 34 callersFunctioncheck

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

src/shardkv_with_bug/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:429

↓ 32 callersFunctionrandstring

(n int)

src/shardkv_with_bug/config.go:20

↓ 31 callersFunctionrandstring

(n int)

src/shardkv/config.go:20

↓ 31 callersMethodsayBasicInfo

func (kv *ShardKV) printOp(op Op) string { return fmt.Sprintf("[op.Index:%v, op.ClientId:%v,op.SeqId:%v,op.Num:%v,op.Shard:%v,op.GID:%v,op.GIDs:%v,op

src/shardkv_with_bug/server.go:500

↓ 30 callersMethodConnect

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

src/labrpc/labrpc.go:362

↓ 30 callersMethodMakeEnd

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

src/labrpc/labrpc.go:327

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

↓ 26 callersMethodleave

tell the shardctrler that a group is leaving.

src/shardkv_with_bug/config.go:324

↓ 25 callersMethodDecode

(e interface{})

src/labgob/labgob.go:54

↓ 24 callersMethodAddService

(svc *Service)

src/labrpc/labrpc.go:411

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

↓ 24 callersMethodleave

tell the shardctrler that a group is leaving.

src/shardkv/config.go:324

↓ 23 callersFunctionDPrintf

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

src/kvraft/util.go:8

↓ 23 callersMethodEncode

(e interface{})

src/labgob/labgob.go:34

↓ 23 callersMethodGetState

这个是只给tester调的 return currentTerm and whether this server believes it is the leader.

src/raft/raft.go:131

↓ 23 callersMethodcleanup

()

src/raft/config.go:344

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

↓ 23 callersFunctionmake_config

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

src/raft/config.go:65

↓ 19 callersMethodmakeClient

()

src/shardkv/config.go:118

↓ 19 callersMethodmakeClient

()

src/shardkv_with_bug/config.go:118

↓ 18 callersMethodAddServer

(servername interface{}, rs *Server)

src/labrpc/labrpc.go:346

↓ 18 callersFunctionDPrintf

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

src/shardctrler/util.go:8

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

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

↓ 17 callersMethodJoin

The Join RPC is used by an administrator to add new replica groups. Its argument is a set of mappings from unique, non-zero replica group identifiers

src/shardctrler/client.go:72

↓ 17 callersMethodPut

(key string, value string)

src/shardkv/client.go:156

↓ 17 callersMethodPut

(key string, value string)

src/shardkv_with_bug/client.go:162

↓ 16 callersMethodCleanup

()

src/labrpc/labrpc.go:181

↓ 16 callersMethodShutdownGroup

(gi int)

src/shardkv_with_bug/config.go:197

↓ 15 callersFunctionPut

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

src/kvraft/test_test.go:62

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

↓ 14 callersMethodAppend

(key string, value string)

src/shardkv_with_bug/client.go:165

↓ 14 callersMethodShutdownGroup

(gi int)

src/shardkv/config.go:197

↓ 14 callersFunctioncheck

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

src/kvraft/test_test.go:96

↓ 13 callersMethodAppend

(key string, value string)

src/shardkv/client.go:159

↓ 13 callersFunctionDPrintf

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

src/shardkv/util.go:8

↓ 13 callersMethodcleanup

()

src/shardkv/config.go:79

↓ 13 callersMethodcleanup

()

src/shardkv_with_bug/config.go:79

↓ 13 callersMethodgetEntryTerm

(index int)

src/raft/log.go:56

↓ 13 callersFunctionmake_config

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

src/shardkv/config.go:338

↓ 13 callersFunctionmake_config

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

src/shardkv_with_bug/config.go:338

↓ 12 callersMethodLeave

(gids []int)

src/shardctrler/client.go:99

↓ 12 callersMethodStartGroup

(gi int)

src/shardkv_with_bug/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:195

↓ 11 callersMethodAll

()

src/kvraft/config.go:160

↓ 11 callersFunctionMakeNetwork

()

src/labrpc/labrpc.go:154

↓ 11 callersFunctionMakeServer

()

src/labrpc/labrpc.go:405

↓ 11 callersFunctionMakeService

(rcvr interface{})

src/labrpc/labrpc.go:459

↓ 10 callersMethodCopy

()

src/raft/persister.go:30

↓ 10 callersMethodInstallSnapshot

(serverId int)

src/raft/snapshot.go:107

↓ 10 callersMethodRaftStateSize

()

src/raft/persister.go:45

↓ 10 callersMethodReadSnapshot

()

src/raft/persister.go:66

↓ 10 callersMethodReliable

(yes bool)

src/labrpc/labrpc.go:185

↓ 10 callersMethodStartGroup

(gi int)

src/shardkv/config.go:264

↓ 10 callersFunctioncheck

import "time"

src/shardctrler/test_test.go:12

↓ 9 callersMethodStartServer

start i'th server in gi'th group

src/shardkv/config.go:204

↓ 9 callersMethodStartServer

start i'th server in gi'th group

src/shardkv_with_bug/config.go:204

↓ 9 callersMethodcrash1

shut down a Raft server but save its persistent state.

src/raft/config.go:108

↓ 9 callersFunctionkey2shard

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

src/shardkv_with_bug/client.go:22

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

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

↓ 8 callersMethodgetLastEntryTerm

()

src/raft/raft.go:831

↓ 8 callersMethodnCommitted

how many servers think a log entry is committed? 输入为提交项的索引，从1开始

src/raft/config.go:492

↓ 7 callersMethodShutdownServer

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

src/shardkv/config.go:156

↓ 7 callersMethodShutdownServer

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

src/shardkv_with_bug/config.go:156

↓ 7 callersMethodStartServer

If restart servers, first call ShutdownServer

src/kvraft/config.go:291

↓ 7 callersFunctionclone

(orig []byte)

src/raft/persister.go:24

↓ 7 callersMethodgetOneEntry

(index int)

src/raft/log.go:28

↓ 7 callersFunctionkey2shard

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

src/shardkv/client.go:22

↓ 7 callersMethodresetElectionTimer

()

src/raft/leader_election.go:82

↓ 6 callersMethodAll

()

src/shardctrler/config.go:130

↓ 6 callersMethodDeleteServer

(servername interface{})

src/labrpc/labrpc.go:353

↓ 6 callersMethodGetCount

()

src/labrpc/labrpc.go:444

↓ 6 callersMethodRead

()

src/kvraft/test_test.go:35

↓ 6 callersMethodcleanup

()

src/kvraft/config.go:72

↓ 6 callersFunctionmake_config

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

src/kvraft/config.go:364

↓ 5 callersMethodAppend

(op porcupine.Operation)

src/kvraft/test_test.go:29

↓ 5 callersFunctionGet

get/put/putappend that keep counts

src/kvraft/test_test.go:44

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

↓ 5 callersMethodKilled

()

src/shardctrler/server.go:353

↓ 5 callersFunctioncheckValue

(value interface{})

src/labgob/labgob.go:75

↓ 5 callersMethodctrlername

controler server name for labrpc.

src/shardkv/config.go:108

↓ 5 callersMethodctrlername

controler server name for labrpc.

src/shardkv_with_bug/config.go:108

↓ 5 callersMethodgetRealIndex

(index int)

src/raft/log.go:25

↓ 5 callersMethodgetWaitCh

(index int)

src/shardctrler/server.go:113

↓ 5 callersMethodpartition

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

src/kvraft/config.go:177

↓ 5 callersMethodsayBasicInfo

()

src/shardkv/server.go:240

next →1–100 of 548, ranked by callers