Functions — github.com/aQuaYi/MIT-6.824-Distributed-Systems

CodeHub MCPcopy Create free account

hub / github.com/aQuaYi/MIT-6.824-Distributed-Systems / functions

Functions473 in github.com/aQuaYi/MIT-6.824-Distributed-Systems

⨍ Functions 473◇ Types & classes 96

↓ 58 callersMethodjoin

tell the shardmaster that a group is joining.

src/shardkv/config.go:303

↓ 40 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:426

↓ 39 callersFunctiondebugPrintf

debugPrintf 根据设置打印输出

src/raft/util.go:14

↓ 36 callersMethodEnable

enable/disable a ClientEnd.

src/labrpc/labrpc.go:343

↓ 36 callersMethodconnect

attach server i to the net.

src/raft/config.go:235

↓ 35 callersFunctioncheck

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

src/shardkv/test_test.go:15

↓ 34 callersMethodcall

(event fsmEvent, args interface{})

src/raft/fsm.go:39

↓ 32 callersFunctionrandstring

src/shardkv/config.go:20

↓ 29 callersMethoddisconnect

detach server i from the net.

src/raft/config.go:258

↓ 28 callersMethodQuery

src/shardmaster/client.go:31

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

↓ 26 callersMethodleave

tell the shardmaster that a group is leaving.

src/shardkv/config.go:321

↓ 22 callersMethodConnect

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

src/labrpc/labrpc.go:335

↓ 22 callersMethodMakeEnd

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

src/labrpc/labrpc.go:300

↓ 21 callersMethodcheckOneLeader

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

src/raft/config.go:298

↓ 19 callersMethodAddService

src/labrpc/labrpc.go:381

↓ 19 callersMethodmakeClient

src/shardkv/config.go:115

↓ 17 callersMethodDecode

(e interface{})

src/labgob/labgob.go:52

↓ 17 callersMethodPut

(key string, value string)

src/shardkv/client.go:130

↓ 17 callersMethodbegin

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

src/raft/config.go:478

↓ 16 callersMethodShutdownGroup

src/shardkv/config.go:194

↓ 16 callersMethodcleanup

src/raft/config.go:224

↓ 16 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:490

↓ 16 callersFunctionmakeConfig

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

src/raft/config.go:59

↓ 15 callersMethodAddServer

(servername interface{}, rs *Server)

src/labrpc/labrpc.go:319

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

↓ 15 callersFunctionPut

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

src/kvraft/test_test.go:27

↓ 15 callersMethodStart

Start 给 server 发送命令 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 serv

src/raft/raft_method.go:122

↓ 14 callersMethodAppend

(key string, value string)

src/shardkv/client.go:133

↓ 14 callersMethodCleanup

src/labrpc/labrpc.go:156

↓ 14 callersMethodWait

Wait blocks until the currently scheduled work has completed. This happens when all tasks have scheduled and completed, the final output have been com

src/mapreduce/master.go:158

↓ 14 callersFunctioncheck

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

src/kvraft/test_test.go:37

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

↓ 13 callersMethodEncode

(e interface{})

src/labgob/labgob.go:32

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

(servers map[int][]string)

src/shardmaster/client.go:48

↓ 12 callersMethodStartGroup

src/shardkv/config.go:261

↓ 12 callersFunctiondebug

debug() will only print if debugEnabled is true

src/mapreduce/common.go:12

↓ 11 callersMethodLeave

src/shardmaster/client.go:66

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

src/labrpc/labrpc.go:130

↓ 10 callersFunctionMakeServer

src/labrpc/labrpc.go:375

↓ 10 callersFunctionMakeService

(rcvr interface{})

src/labrpc/labrpc.go:429

↓ 10 callersFunctioncheck

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

src/shardmaster/test_test.go:11

↓ 10 callersMethodget

src/linearizability/bitset.go:39

↓ 9 callersMethodStartServer

start i'th server in gi'th group

src/shardkv/config.go:201

↓ 9 callersMethodaddHandler

(state fsmState, event fsmEvent, handler fsmHandler)

src/raft/fsm.go:29

↓ 8 callersMethodCopy

src/raft/persister.go:27

↓ 8 callersMethodGetState

GetState 可以获取 raft 对象的状态 return currentTerm and whether this server believes it is the leader.

src/raft/raft_method.go:14

↓ 8 callersMethodLogSize

Maximum log size across all servers

src/kvraft/config.go:82

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

Register is an RPC method that is called by workers after they have started up to report that they are ready to receive tasks.

src/mapreduce/master.go:36

↓ 7 callersMethodReliable

src/labrpc/labrpc.go:160

↓ 7 callersMethodShutdownServer

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

src/shardkv/config.go:153

↓ 7 callersFunctionport

Cook up a unique-ish UNIX-domain socket name in /var/tmp. can't use current directory since AFS doesn't support UNIX-domain sockets.

src/mapreduce/test_test.go:122

↓ 7 callersMethodset

src/linearizability/bitset.go:27

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

↓ 6 callersMethodGetCount

src/labrpc/labrpc.go:414

↓ 6 callersFunctionRunWorker

RunWorker sets up a connection with the master, registers its address, and waits for tasks to be scheduled.

src/mapreduce/worker.go:119

↓ 6 callersFunctioncheck

Checks input file agaist output file: each input number should show up in the output file in string sorted order

src/mapreduce/test_test.go:46

↓ 6 callersFunctioncleanup

src/mapreduce/test_test.go:139

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

↓ 5 callersMethodDeleteServer

(servername interface{})

src/labrpc/labrpc.go:326

↓ 5 callersFunctioncheckValue

(value interface{})

src/labgob/labgob.go:68

↓ 5 callersFunctioncheckWorker

Workers report back how many RPCs they have processed in the Shutdown reply. Check that they processed at least 1 DoTask RPC.

src/mapreduce/test_test.go:90

↓ 5 callersMethodcrash1

shut down a Raft server but save its persistent state.

src/raft/config.go:98

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

RaftStateSize is

src/raft/persister.go:51

↓ 4 callersFunctioncall

call() sends an RPC to the rpcname handler on server srv with arguments args, waits for the reply, and leaves the reply in reply. the reply argument s

src/mapreduce/common_rpc.go:51

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

mergeName constructs the name of the output file of reduce task <reduceTask>

src/mapreduce/common.go:41

↓ 4 callersFunctionremoveFile

removeFile is a simple wrapper around os.Remove that logs errors.

src/mapreduce/master_splitmerge.go:54

↓ 4 callersMethodservername

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

src/shardkv/config.go:111

↓ 4 callersFunctionsetup

src/mapreduce/test_test.go:132

↓ 4 callersMethodwait

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

src/raft/config.go:385

↓ 3 callersFunctionAppend

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

src/kvraft/test_test.go:32

↓ 3 callersMethodFetch

Fetch returns a slice of URLs found on the page.

Lectures/LEC02/crawler/crawler.go:161

↓ 3 callersMethodKill

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

src/raft/raft_method.go:167

↓ 3 callersFunctionNewDecoder

src/labgob/labgob.go:46

↓ 3 callersFunctionNewEncoder

src/labgob/labgob.go:26

↓ 3 callersMethodReadRaftState

ReadRaftState is

src/raft/persister.go:44

↓ 3 callersFunctionbind

Lectures/LEC03/6.824 Lab 2: Raft_files/vomnibar_data/vomnibar.js:4

↓ 3 callersFunctionbitsetIndex

src/linearizability/bitset.go:23

↓ 3 callersMethodchecklogs

check that no server's log is too big.

src/shardkv/config.go:88

↓ 3 callersFunctioninsertBefore

(n *node, mark *node)

src/linearizability/linearizability.go:59

↓ 3 callersFunctionkey2shard

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

src/shardkv/client.go:22

↓ 3 callersFunctionmakeInputs

Make input file

src/mapreduce/test_test.go:99

next →1–100 of 473, ranked by callers