Functions — github.com/PKUFlyingPig/MIT6.824

hub / github.com/PKUFlyingPig/MIT6.824 / functions

Functions373 in github.com/PKUFlyingPig/MIT6.824

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

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

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

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

send AppendEntries RPC call to a specific server return true if success return false otherwise

src/raft/raft.go:390

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

()

src/porcupine/bitset.go:54

↓ 2 callersFunctionihash

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

src/mr/worker.go:36

↓ 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

Cook up a unique-ish UNIX-domain socket name in /var/tmp, for the master. Can't use the current directory since Athena AFS doesn't support UNIX-domain

src/mr/rpc.go:48

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

()

src/kvraft/config.go:392

↓ 2 callersMethodrpcTotal

()

src/raft/config.go:284

↓ 2 callersMethodset

(pos uint)

src/porcupine/bitset.go:29

↓ 2 callersFunctionusage

()

src/main/diskvd.go:25

↓ 2 callersFunctionusage

()

src/main/lockc.go:11

↓ 1 callersMethodAppend

(key string, value string)

src/kvraft/client.go:62

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

↓ 1 callersFunctionMakeClerk

(servers []*labrpc.ClientEnd)

src/shardmaster/client.go:24

↓ 1 callersFunctionMakeClerk

(servers []*labrpc.ClientEnd)

src/kvraft/client.go:20

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

(state []byte)

src/raft/persister.go:33

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

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

allocate len(rf.peers) go routine to check for sending appendEntries (leader only)

src/raft/raft.go:522

↓ 1 callersMethodappendChecker

periodically check if last log index >= nextIndex[server], if so, send AppendEntries (leader only)

src/raft/raft.go:479

↓ 1 callersMethodapplyCommited

periodically apply log[lastApplied] to state machine

src/raft/raft.go:636

↓ 1 callersFunctioncacheContains

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

src/porcupine/checker.go:140

↓ 1 callersMethodcallRequestVote

send RequestVote RPC call to a specific server return true if receive vote-granted = true return false if not

src/raft/raft.go:534

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

periodically check if there exists a log entry which is commited

src/raft/raft.go:452

↓ 1 callersFunctioncomputeVisualizationData

(model Model, info linearizationInfo)

src/porcupine/visualization.go:33

↓ 1 callersFunctionconvertEntries

(events []Event)

src/porcupine/checker.go:103

↓ 1 callersMethoddeleteClient

(ck *Clerk)

src/kvraft/config.go:211

↓ 1 callersMethoddispatch

(req reqMsg)

src/labrpc/labrpc.go:403

↓ 1 callersMethodelectionChecker

periodically check if it is needed to start an election

src/raft/raft.go:614

↓ 1 callersMethodequals

(b2 bitset)

src/porcupine/bitset.go:62

↓ 1 callersMethodleaderHeartBeat

send heartbeat to all other servers (leader only)

src/raft/raft.go:425

↓ 1 callersFunctionlength

(n *node)

src/porcupine/checker.go:78

↓ 1 callersFunctionlift

(entry *node)

src/porcupine/checker.go:154

↓ 1 callersFunctionloadPlugin

load the application Map and Reduce functions from a plugin file, e.g. ../mrapps/wc.so

src/main/mrsequential.go:93

↓ 1 callersFunctionloadPlugin

load the application Map and Reduce functions from a plugin file, e.g. ../mrapps/wc.so

src/main/mrworker.go:34

↓ 1 callersFunctionmakeEntries

(history []Operation)

src/porcupine/checker.go:43

↓ 1 callersFunctionmakeLinkedEntries

(entries []entry)

src/porcupine/checker.go:116

↓ 1 callersFunctionmakeSeed

()

src/kvraft/config.go:26

↓ 1 callersFunctionmakeSeed

()

src/raft/config.go:30

↓ 1 callersFunctionmakeSeed

()

src/shardkv/config.go:27

↓ 1 callersMethodmake_partition

Partition servers into 2 groups and put current leader in minority

src/kvraft/config.go:339

↓ 1 callersFunctionnewBitset

data layout: bits 0-63 are in data[0], the next are in data[1], etc.

src/porcupine/bitset.go:10

↓ 1 callersFunctionnparallel

(phase string)

src/mrapps/mtiming.go:19

↓ 1 callersFunctionnparallel

(phase string)

src/mrapps/rtiming.go:17

↓ 1 callersMethodpopcnt

()

src/porcupine/bitset.go:46

↓ 1 callersMethodprocessReq

(req reqMsg)

src/labrpc/labrpc.go:216

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