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

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

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

⨍ Functions 443◇ Types & classes 93

↓ 3 callersFunctioncheckEvents

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

src/porcupine/checker.go:355

↓ 3 callersFunctioncheckOperations

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

src/porcupine/checker.go:365

↓ 3 callersMethodchecklogs

check that no server's log is too big.

src/shardkv/config.go:91

↓ 3 callersFunctiondeep_copy_map

(oldConfig *Config, newConfig *Config)

src/shardctrler/util.go:32

↓ 3 callersFunctionfillDefault

(model Model)

src/porcupine/checker.go:255

↓ 3 callersFunctioninsertBefore

(n *node, mark *node)

src/porcupine/checker.go:70

↓ 3 callersFunctionkey2shard

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

src/shardkv/client.go:20

↓ 3 callersMethodkilled

src/kvraft/config.go:406

↓ 3 callersMethodrpcCount

(server int)

src/raft/config.go:406

↓ 3 callersMethodsetunreliable

(unrel bool)

src/raft/config.go:414

↓ 2 callersFunctionAppend

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

src/kvraft/test_test.go:81

↓ 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

↓ 2 callersFunctionGenericTestSpeed

Check that ops are committed fast enough, better than 1 per heartbeat interval

src/kvraft/test_test.go:391

↓ 2 callersMethodGetSeq

()

src/kvraft/client.go:29

↓ 2 callersMethodGetTotalCount

()

src/labrpc/labrpc.go:372

↓ 2 callersMethodHandleOp

(opArgs *Op)

src/kvraft/server.go:162

↓ 2 callersMethodKill

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

src/shardctrler/server.go:188

↓ 2 callersMethodKill

()

src/kvraft/server.go:241

↓ 2 callersMethodKill

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

src/shardkv/server.go:43

↓ 2 callersMethodLoadSnapShot

(snapShot []byte)

src/kvraft/server.go:343

↓ 2 callersFunctionMakePersister

()

src/raft/persister.go:20

↓ 2 callersMethodMove

(shard int, gid int)

src/shardctrler/client.go:104

↓ 2 callersMethodPut

(key string, value string)

src/kvraft/client.go:137

↓ 2 callersMethodPutAppend

shared by Put and Append. you can send an RPC with code like this: ok := ck.servers[i].Call("KVServer.PutAppend", &args, &reply) the types of args a

src/kvraft/client.go:100

↓ 2 callersMethodPutAppend

shared by Put and Append. You will have to modify this function.

src/shardkv/client.go:94

↓ 2 callersMethodReadRaftState

()

src/raft/persister.go:39

↓ 2 callersMethodResetHeartTimer

(timeStamp int)

src/raft/raft.go:117

↓ 2 callersMethodSave

Save both Raft state and K/V snapshot as a single atomic action, to help avoid them getting out of sync.

src/raft/persister.go:53

↓ 2 callersMethodShutdownServer

Shutdown a server by isolating it

src/shardctrler/config.go:228

↓ 2 callersMethodSnapshot

the service says it has created a snapshot that has all info up to and including index. this means the service no longer needs the log through (and in

src/raft/raft.go:219

↓ 2 callersMethodSnapshotSize

Maximum snapshot size across all servers

src/kvraft/config.go:94

↓ 2 callersMethodStartServer

If restart servers, first call ShutdownServer

src/shardctrler/config.go:260

↓ 2 callersFunctioncall

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

src/mr/worker.go:221

↓ 2 callersFunctioncheckClntAppends

check that for a specific client all known appends are present in a value, and in order

src/kvraft/test_test.go:138

↓ 2 callersMethodcheckFinished

()

src/raft/config.go:344

↓ 2 callersMethodcheckLogs

(i int, m ApplyMsg)

src/raft/config.go:144

↓ 2 callersFunctioncheckParallel

(model Model, history [][]entry, computeInfo bool, timeout time.Duration)

src/porcupine/checker.go:274

↓ 2 callersMethodcheckTerms

check that everyone agrees on the term.

src/raft/config.go:467

↓ 2 callersMethodcheckTimeout

()

src/kvraft/config.go:62

↓ 2 callersMethodcheckTimeout

()

src/raft/config.go:337

↓ 2 callersMethodcheck_nil_map

()

src/shardctrler/common.go:37

↓ 2 callersFunctioncheck_same_config

(t *testing.T, c1 Config, c2 Config)

src/shardctrler/test_test.go:57

↓ 2 callersMethodcleanup

()

src/shardctrler/config.go:54

↓ 2 callersFunctioncoordinatorSock

Add your RPC definitions here. Cook up a unique-ish UNIX-domain socket name in /var/tmp, for the coordinator. Can't use the current directory since At

src/mr/rpc.go:52

↓ 2 callersFunctionget_max_map_len_count

(newConfig *Config)

src/shardctrler/util.go:45

↓ 2 callersFunctionget_min_arr

(newConfig *Config)

src/shardctrler/util.go:66

↓ 2 callersMethodhash

()

src/porcupine/bitset.go:54

↓ 2 callersMethodingestSnap

returns "" or error string

src/raft/config.go:188

↓ 2 callersFunctioninternalChurn

(t *testing.T, unreliable bool)

src/raft/test_test.go:947

↓ 2 callersMethodisServerDead

(endname interface{}, servername interface{}, server *Server)

src/labrpc/labrpc.go:208

↓ 2 callersMethodjoinm

(gis []int)

src/shardkv/config.go:310

↓ 2 callersMethodleavem

(gis []int)

src/shardkv/config.go:328

↓ 2 callersFunctionmake_config

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

src/shardctrler/config.go:334

↓ 2 callersFunctionmaybeCrash

()

src/mrapps/nocrash.go:17

↓ 2 callersFunctionmaybeCrash

()

src/mrapps/crash.go:20

↓ 2 callersFunctionrandstring

(n int)

src/shardctrler/config.go:16

↓ 2 callersFunctionrandstring

(n int)

src/kvraft/config.go:19

↓ 2 callersFunctionrandstring

(n int)

src/raft/config.go:30

↓ 2 callersMethodrpcTotal

()

src/kvraft/config.go:392

↓ 2 callersMethodrpcTotal

()

src/raft/config.go:410

↓ 2 callersMethodset

(pos uint)

src/porcupine/bitset.go:29

↓ 2 callersFunctionspawn_clients_and_wait

spawn ncli clients and wait until they are all done

src/kvraft/test_test.go:115

↓ 2 callersFunctionusage

()

src/main/diskvd.go:25

↓ 2 callersFunctionusage

()

src/main/lockc.go:11

↓ 1 callersMethodApplyHandler

()

src/shardctrler/server.go:205

↓ 1 callersMethodApplyHandler

()

src/kvraft/server.go:252

↓ 1 callersFunctionCallForTask

example function to show how to make an RPC call to the coordinator. the RPC argument and reply types are defined in rpc.go.

src/mr/worker.go:197

↓ 1 callersMethodCommitChecker

()

src/raft/raft.go:298

↓ 1 callersMethodConfigExecute

(op *Op)

src/shardctrler/server.go:64

↓ 1 callersFunctionCreateNewConfig

(me int, configs []Config, newGroups map[int][]string)

src/shardctrler/util.go:102

↓ 1 callersMethodDBExecute

(op *Op)

src/kvraft/server.go:127

↓ 1 callersFunctionDPrintf

超时为2s

src/shardctrler/util.go:15

↓ 1 callersFunctionDelFileByMapId

(targetNumber int, path string)

src/mr/utils.go:11

↓ 1 callersFunctionDelFileByReduceId

(targetNumber int, path string)

src/mr/utils.go:43

↓ 1 callersMethodDisconnectClientUnlocked

caller should hold cfg.mu

src/shardctrler/config.go:212

↓ 1 callersMethodDisconnectClientUnlocked

caller should hold cfg.mu

src/kvraft/config.go:239

↓ 1 callersMethodElect

()

src/raft/raft.go:1023

↓ 1 callersMethodEncodeValue

(value reflect.Value)

src/labgob/labgob.go:37

↓ 1 callersMethodGenSnapShot

()

src/kvraft/server.go:331

↓ 1 callersFunctionGetRandomElectTimeOut

(rd *rand.Rand)

src/raft/util.go:18

↓ 1 callersMethodGetVoteAnswer

(server int, args *RequestVoteArgs)

src/raft/raft.go:953

↓ 1 callersFunctionHandleMapTask

(reply *MessageReply, mapf func(string, string) []KeyValue)

src/mr/worker.go:74

↓ 1 callersFunctionHandleReduceTask

(reply *MessageReply, reducef func(string, []string) string)

src/mr/worker.go:123

↓ 1 callersMethodLeader

()

src/kvraft/config.go:325

↓ 1 callersMethodLogSize

Maximum log size across all servers

src/raft/config.go:647

↓ 1 callersMethodLongDelays

(yes bool)

src/labrpc/labrpc.go:185

↓ 1 callersMethodLongReordering

(yes bool)

src/labrpc/labrpc.go:178

↓ 1 callersFunctionMake

the service or tester wants to create a Raft server. the ports of all the Raft servers (including this one) are in peers[]. this server's port is peer

src/raft/raft.go:1087

↓ 1 callersFunctionMakeClerk

(servers []*labrpc.ClientEnd)

src/shardctrler/client.go:39

↓ 1 callersFunctionMakeClerk

(servers []*labrpc.ClientEnd)

src/kvraft/client.go:35

↓ 1 callersFunctionMakeClerk

the tester calls MakeClerk. ctrlers[] is needed to call shardctrler.MakeClerk(). make_end(servername) turns a server name from a Config.Groups[gid][

src/shardkv/client.go:50

↓ 1 callersFunctionMoveShard2Gid

(me int, configs []Config, n_shard int, n_gid int)

src/shardctrler/util.go:269

↓ 1 callersFunctionNextValue

predict effect of Append(k, val) if old value is prev.

src/kvraft/test_test.go:132

↓ 1 callersMethodPrint

()

src/raft/raft.go:108

↓ 1 callersFunctionQueryConfig

(me int, configs []Config, num int)

src/shardctrler/util.go:320

↓ 1 callersMethodRaft

needed by shardkv tester

src/shardctrler/server.go:201

← previous next →101–200 of 443, ranked by callers