Functions — github.com/chaozh/MIT-6.824

hub / github.com/chaozh/MIT-6.824 / functions

Functions379 in github.com/chaozh/MIT-6.824

⨍ Functions 379◇ Types & classes 79

↓ 2 callersFunctionGenericTestSpeed

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

src/kvraft/test_test.go:385

↓ 2 callersMethodGetTotalCount

()

src/labrpc/labrpc.go:372

↓ 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

src/shardctrler/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 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:45

↓ 2 callersFunctionMakePersister

()

src/raft/persister.go:20

↓ 2 callersMethodMove

(shard int, gid int)

src/shardctrler/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:45

↓ 2 callersMethodShutdownServer

Shutdown a server by isolating it

src/shardctrler/config.go:228

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

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

src/kvraft/test_test.go:132

↓ 2 callersMethodcheckLogs

(i int, m ApplyMsg)

src/raft/config.go:136

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

↓ 2 callersMethodcheckTimeout

()

src/kvraft/config.go:62

↓ 2 callersMethodcheckTimeout

()

src/raft/config.go:287

↓ 2 callersFunctioncheck_same_config

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

src/shardctrler/test_test.go:56

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

↓ 2 callersMethodhash

()

src/porcupine/bitset.go:54

↓ 2 callersFunctioninternalChurn

(t *testing.T, unreliable bool)

src/raft/test_test.go:858

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

↓ 2 callersMethodrpcTotal

()

src/kvraft/config.go:392

↓ 2 callersMethodrpcTotal

()

src/raft/config.go:354

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

↓ 2 callersFunctionusage

()

src/main/diskvd.go:25

↓ 2 callersFunctionusage

()

src/main/lockc.go:11

↓ 1 callersMethodCondInstallSnapshot

A service wants to switch to snapshot. Only do so if Raft hasn't have more recent info since it communicate the snapshot on applyCh.

src/raft/raft.go:123

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

(value reflect.Value)

src/labgob/labgob.go:37

↓ 1 callersMethodLeader

()

src/kvraft/config.go:325

↓ 1 callersMethodLogSize

Maximum log size across all servers

src/raft/config.go:582

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

src/raft/raft.go:267

↓ 1 callersFunctionMakeClerk

(servers []*labrpc.ClientEnd)

src/shardctrler/client.go:24

↓ 1 callersFunctionMakeClerk

(servers []*labrpc.ClientEnd)

src/kvraft/client.go:20

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

↓ 1 callersFunctionNextValue

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

src/kvraft/test_test.go:126

↓ 1 callersMethodRaft

needed by shardkv tester

src/shardctrler/server.go:56

↓ 1 callersFunctionRegister

(value interface{})

src/labgob/labgob.go:58

↓ 1 callersMethodSaveStateAndSnapshot

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

↓ 1 callersMethodShutdownServer

Shutdown a server by isolating it

src/kvraft/config.go:255

↓ 1 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:134

↓ 1 callersMethodStartCtrlerserver

(i int)

src/shardkv/config.go:270

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

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

src/shardctrler/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:79

↓ 1 callersFunctionVisualize

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

src/porcupine/visualization.go:89

↓ 1 callersFunctioncacheContains

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

src/porcupine/checker.go:140

↓ 1 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:69

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

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

↓ 1 callersFunctioncheckSingle

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

src/porcupine/checker.go:174

↓ 1 callersMethodcheckTimeout

()

src/shardctrler/config.go:47

↓ 1 callersMethodcheckTimeout

()

src/shardkv/config.go:72

↓ 1 callersFunctioncheckType

(t reflect.Type)

src/labgob/labgob.go:72

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

(ck *Clerk)

src/kvraft/config.go:211

↓ 1 callersMethoddispatch

(req reqMsg)

src/labrpc/labrpc.go:405

↓ 1 callersMethodequals

(b2 bitset)

src/porcupine/bitset.go:62

↓ 1 callersMethodkilled

()

src/raft/raft.go:239

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

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

repartition the servers periodically

src/kvraft/test_test.go:176

↓ 1 callersMethodpopcnt

()

src/porcupine/bitset.go:46

↓ 1 callersMethodprocessReq

(req reqMsg)

src/labrpc/labrpc.go:218

↓ 1 callersFunctionrandom_handles

Randomize server handles

src/shardctrler/config.go:24

↓ 1 callersFunctionrandom_handles

Randomize server handles

src/kvraft/config.go:34

↓ 1 callersMethodreadEndnameInfo

(endname interface{})

src/labrpc/labrpc.go:192

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