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

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

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

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 w

src/kvraft/client.go:47

↓ 2 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 modif

src/shardkv/client.go:68

↓ 2 callersMethodGetTotalCount

()

src/labrpc/labrpc.go:370

↓ 2 callersMethodKill

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

src/shardmaster/server.go:50

↓ 2 callersMethodKill

the tester calls Kill() when a KVServer instance won't be needed again. for your convenience, we supply code to set rf.dead (without needing a lock),

src/kvraft/server.go:189

↓ 2 callersFunctionMakePersister

()

src/raft/persister.go:20

↓ 2 callersMethodMove

(shard int, gid int)

src/shardmaster/client.go:84

↓ 2 callersMethodPut

(key string, value string)

src/kvraft/client.go:113

↓ 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

src/kvraft/client.go:87

↓ 2 callersMethodPutAppend

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

src/shardkv/client.go:102

↓ 2 callersMethodReadRaftState

()

src/raft/persister.go:39

↓ 2 callersMethodReadSnapshot

()

src/raft/persister.go:60

↓ 2 callersMethodSaveRaftState

(state []byte)

src/raft/persister.go:33

↓ 2 callersMethodShutdownServer

Shutdown a server by isolating it

src/kvraft/config.go:255

↓ 2 callersMethodSnapshotSize

Maximum snapshot size across all servers

src/kvraft/config.go:94

↓ 2 callersMethodStartServer

If restart servers, first call ShutdownServer

src/shardmaster/config.go:260

↓ 2 callersMethodapplyLogs

apply the committed logs.

src/raft/raft.go:256

↓ 2 callersMethodapplyToStateMachine

applied the command to the state machine lock must be held before calling this

src/kvraft/server.go:168

↓ 2 callersMethodbroadcastAppendEntries

broadcast AppendEntries RPCs to all peers in parallel. lock must be held before calling this.

src/raft/raft.go:525

↓ 2 callersFunctioncheckParallel

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

src/porcupine/checker.go:269

↓ 2 callersMethodcheckTerms

check that everyone agrees on the term.

src/raft/config.go:335

↓ 2 callersMethodcheckTimeout

()

src/kvraft/config.go:62

↓ 2 callersMethodcheckTimeout

()

src/raft/config.go:217

↓ 2 callersMethodcleanup

()

src/shardmaster/config.go:54

↓ 2 callersMethodconvertToCandidate

convert the raft state to candidate.

src/raft/raft.go:626

↓ 2 callersMethodgetElectionTimeout

get the randomized election timeout.

src/raft/raft.go:209

↓ 2 callersMethodgetLastTerm

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

src/raft/raft.go:202

↓ 2 callersMethodhash

()

src/porcupine/bitset.go:54

↓ 2 callersFunctioninternalChurn

(t *testing.T, unreliable bool)

src/raft/test_test.go:825

↓ 2 callersMethodisServerDead

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

src/labrpc/labrpc.go:206

↓ 2 callersMethodjoinm

(gis []int)

src/shardkv/config.go:307

↓ 2 callersMethodleavem

(gis []int)

src/shardkv/config.go:325

↓ 2 callersFunctionmake_config

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

src/shardmaster/config.go:332

↓ 2 callersFunctionmasterSock

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

src/mr/rpc.go:49

↓ 2 callersFunctionmaybeCrash

()

src/mrapps/nocrash.go:17

↓ 2 callersFunctionmaybeCrash

()

src/mrapps/crash.go:20

↓ 2 callersFunctionpartitioner

repartition the servers periodically

src/kvraft/test_test.go:124

↓ 2 callersFunctionrandstring

(n int)

src/shardmaster/config.go:16

↓ 2 callersFunctionrandstring

(n int)

src/kvraft/config.go:19

↓ 2 callersFunctionrandstring

(n int)

src/raft/config.go:23

↓ 2 callersFunctionreportTaskDone

(taskType TaskType, taskId int)

src/mr/worker.go:208

↓ 2 callersMethodresetChannels

reset the channels, needed when converting server state. lock must be held before calling this.

src/raft/raft.go:650

↓ 2 callersMethodrpcTotal

()

src/kvraft/config.go:392

↓ 2 callersMethodrpcTotal

()

src/raft/config.go:284

↓ 2 callersMethodselectTask

(taskList []Task, workerId int)

src/mr/master.go:125

↓ 2 callersMethodset

(pos uint)

src/porcupine/bitset.go:29

↓ 2 callersFunctionusage

()

src/main/diskvd.go:25

↓ 2 callersFunctionusage

()

src/main/lockc.go:11

↓ 2 callersMethodwaitForApplied

send the op log to Raft library and wait for it to be applied

src/kvraft/server.go:97

↓ 1 callersMethodAppend

(key string, value string)

src/kvraft/client.go:116

↓ 1 callersMethodDisconnectClientUnlocked

caller should hold cfg.mu

src/shardmaster/config.go:212

↓ 1 callersMethodDisconnectClientUnlocked

caller should hold cfg.mu

src/kvraft/config.go:239

↓ 1 callersMethodEncodeValue

(value reflect.Value)

src/labgob/labgob.go:37

↓ 1 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 (

src/shardkv/server.go:46

↓ 1 callersMethodLeader

()

src/shardmaster/config.go:299

↓ 1 callersMethodLeader

()

src/kvraft/config.go:325

↓ 1 callersMethodLongDelays

(yes bool)

src/labrpc/labrpc.go:183

↓ 1 callersMethodLongReordering

(yes bool)

src/labrpc/labrpc.go:176

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

src/raft/raft.go:706

↓ 1 callersFunctionMakeClerk

(servers []*labrpc.ClientEnd)

src/shardmaster/client.go:24

↓ 1 callersFunctionMakeClerk

(servers []*labrpc.ClientEnd)

src/kvraft/client.go:25

↓ 1 callersFunctionMakeClerk

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

src/shardkv/client.go:54

↓ 1 callersFunctionNextValue

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

src/kvraft/test_test.go:74

↓ 1 callersMethodRaft

needed by shardkv tester

src/shardmaster/server.go:56

↓ 1 callersFunctionRegister

(value interface{})

src/labgob/labgob.go:58

↓ 1 callersMethodShutdownServer

Shutdown a server by isolating it

src/shardmaster/config.go:228

↓ 1 callersFunctionStartKVServer

servers[] contains the ports of the set of servers that will cooperate via Raft to form the fault-tolerant key/value service. me is the index of the

src/kvraft/server.go:214

↓ 1 callersMethodStartMasterServer

(i int)

src/shardkv/config.go:267

↓ 1 callersFunctionStartServer

servers[] contains the ports of the set of servers that will cooperate via Paxos to form the fault-tolerant shardmaster service. me is the index of t

src/shardmaster/server.go:66

↓ 1 callersFunctionStartServer

servers[] contains the ports of the servers in this group. me is the index of the current server in servers[]. the k/v server should store snapshot

src/shardkv/server.go:80

↓ 1 callersFunctionVisualize

(model Model, info linearizationInfo, output io.Writer)

src/porcupine/visualization.go:89

↓ 1 callersMethodapplyOpsLoop

background loop to receive the logs committed by the Raft library and apply them to the kv server state machine

src/kvraft/server.go:132

↓ 1 callersMethodbroadcastRequestVote

broadcast RequestVote RPCs to all peers in parallel. lock must be held before calling this.

src/raft/raft.go:362

↓ 1 callersFunctioncacheContains

(model Model, cache map[uint64][]cacheEntry, entry cacheEntry)

src/porcupine/checker.go:140

↓ 1 callersFunctioncheckClntAppends

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

src/kvraft/test_test.go:80

↓ 1 callersFunctioncheckConcurrentAppends

check that all known appends are present in a value, and are in order for each concurrent client.

src/kvraft/test_test.go:101

↓ 1 callersFunctioncheckDefault

warn if the value contains non-default values, as it would if one sent an RPC but the reply struct was already modified. if the RPC reply contains de

src/labgob/labgob.go:122

↓ 1 callersFunctioncheckDefault1

(value reflect.Value, depth int, name string)

src/labgob/labgob.go:129

↓ 1 callersMethodcheckNoLeader

check that there's no leader

src/raft/config.go:351

↓ 1 callersFunctioncheckSingle

(model Model, history []entry, computePartial bool, kill *int32)

src/porcupine/checker.go:174

↓ 1 callersMethodcheckTimeout

()

src/shardmaster/config.go:47

↓ 1 callersMethodcheckTimeout

()

src/shardkv/config.go:72

↓ 1 callersFunctioncheckType

(t reflect.Type)

src/labgob/labgob.go:72

↓ 1 callersFunctioncheck_same_config

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

src/shardmaster/test_test.go:55

↓ 1 callersMethodclear

(pos uint)

src/porcupine/bitset.go:35

↓ 1 callersMethodclone

()

src/porcupine/bitset.go:19

↓ 1 callersFunctioncomputeVisualizationData

(model Model, info linearizationInfo)

src/porcupine/visualization.go:33

↓ 1 callersFunctionconvertEntries

(events []Event)

src/porcupine/checker.go:103

↓ 1 callersMethodconvertToLeader

convert the raft state to leader.

src/raft/raft.go:601

↓ 1 callersMethoddeleteClient

(ck *Clerk)

src/kvraft/config.go:211

↓ 1 callersMethoddispatch

(req reqMsg)

src/labrpc/labrpc.go:403

↓ 1 callersFunctiondoMap

(mapf func(string, string) []KeyValue, filePath string, mapId int)

src/mr/worker.go:86

↓ 1 callersFunctiondoReduce

(reducef func(string, []string) string, reduceId int)

src/mr/worker.go:139

↓ 1 callersMethodequals

(b2 bitset)

src/porcupine/bitset.go:62

↓ 1 callersFunctiongetReduceCount

()

src/mr/worker.go:192

↓ 1 callersFunctionihash

use ihash(key) % NReduce to choose the reduce task number for each KeyValue emitted by Map.

src/mr/worker.go:33

↓ 1 callersMethodisLogUpToDate

check if the candidate's log is at least as up-to-date as ours lock must be held before calling this.

src/raft/raft.go:243

↓ 1 callersMethodisSameOp

check if the issued command is the same as the applied command

src/kvraft/server.go:123

↓ 1 callersMethodkilled

()

src/raft/raft.go:593

↓ 1 callersFunctionlength

(n *node)

src/porcupine/checker.go:78

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