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

↓ 3 callersMethodop

src/kvraft/config.go:406

↓ 3 callersMethodpersist

save Raft's persistent state to stable storage, where it can later be retrieved after a crash and restart. see paper's Figure 2 for a description of

src/raft/raft_method.go:33

↓ 3 callersFunctionreduceName

reduceName constructs the name of the intermediate file which map task <mapTask> produces for reduce task <reduceTask>.

src/mapreduce/common.go:36

↓ 3 callersMethodrpcCount

src/raft/config.go:280

↓ 3 callersFunctionschedule

schedule() starts and waits for all tasks in the given phase (mapPhase or reducePhase). the mapFiles argument holds the names of the files that are t

src/mapreduce/schedule.go:17

↓ 3 callersFunctionsetEventProperty

(object, property)

Lectures/LEC03/6.824 Lab 2: Raft_files/inject.js:17

↓ 3 callersMethodsetunreliable

src/raft/config.go:288

↓ 3 callersFunctionspawn_clients_and_wait

spawn ncli clients and wait until they are all done

src/kvraft/test_test.go:55

↓ 2 callersMethodConnectAll

src/shardmaster/config.go:138

↓ 2 callersMethodConnectClient

(ck *Clerk, to []int)

src/kvraft/config.go:232

↓ 2 callersMethodConnectClientUnlocked

caller should hold cfg.mu

src/shardmaster/config.go:196

↓ 2 callersMethodConnectClientUnlocked

caller should hold cfg.mu

src/kvraft/config.go:223

↓ 2 callersFunctionGenericTestLinearizability

similar to GenericTest, but with clients doing random operations (and using a linearizability checker)

src/kvraft/test_test.go:285

↓ 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 can send an RPC w

src/kvraft/client.go:39

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

↓ 2 callersMethodIsServerDead

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

src/labrpc/labrpc.go:197

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

↓ 2 callersMethodKill

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

src/kvraft/server.go:51

↓ 2 callersFunctionMakePersister

MakePersister is

src/raft/persister.go:22

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

↓ 2 callersMethodReadSnapshot

ReadSnapshot 读取快照

src/raft/persister.go:67

↓ 2 callersMethodSaveRaftState

SaveRaftState is

src/raft/persister.go:37

↓ 2 callersFunctionSequential

Sequential runs map and reduce tasks sequentially, waiting for each task to complete before running the next.

src/mapreduce/master.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 callersFunctioncheckSingle

(model Model, subhistory *node, kill *int32)

src/linearizability/linearizability.go:167

↓ 2 callersMethodcheckTerms

check that everyone agrees on the term.

src/raft/config.go:331

↓ 2 callersMethodcheckTimeout

src/kvraft/config.go:62

↓ 2 callersMethodcheckTimeout

src/raft/config.go:217

↓ 2 callersMethodcleanup

src/shardmaster/config.go:54

↓ 2 callersFunctionconnect

Client 客户端连接上服务器，返回一个 *rpc.Client

Lectures/LEC02/kv/kv.go:146

↓ 2 callersFunctiondoMap

( jobName string, // the name of the MapReduce job mapTask int, // which map task this is inFile string, n

src/mapreduce/common_map.go:11

↓ 2 callersFunctiondoReduce

( jobName string, // the name of the whole MapReduce job reduceTask int, // which reduce task this is outFi

src/mapreduce/common_reduce.go:11

↓ 2 callersFunctionfillDefault

src/linearizability/linearizability.go:216

↓ 2 callersFunctionget

从服务器获取 key 对应的值

Lectures/LEC02/kv/kv.go:155

↓ 2 callersFunctionhackInlineEvent

(el, eventProperty)

Lectures/LEC03/6.824 Lab 2: Raft_files/inject.js:49

↓ 2 callersMethodhash

src/linearizability/bitset.go:56

↓ 2 callersFunctioninternalChurn

(t *testing.T, unreliable bool)

src/raft/test_test.go:781

↓ 2 callersMethodjoinm

src/shardkv/config.go:307

↓ 2 callersMethodleavem

src/shardkv/config.go:325

↓ 2 callersFunctionmakeLinkedEntries

(entries []entry)

src/linearizability/linearizability.go:109

↓ 2 callersFunctionmake_config

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

src/shardmaster/config.go:332

↓ 2 callersFunctionmax

src/raft/util.go:20

↓ 2 callersFunctionmaxMajorityIndex

返回 matchIndex 中超过半数的 Index 例如 matchIndex == {8,7,6,5,4} temp == {4,5,6,7,8} i = (5-1)/2 = 2 超过半数的 server 拥有 {4,5,6} 其中 temp[i] == 6 是最大值

src/raft/applyMsg.go:92

↓ 2 callersFunctionmin

src/raft/util.go:27

↓ 2 callersFunctionnewMaster

newMaster initializes a new Map/Reduce Master

src/mapreduce/master.go:49

↓ 2 callersFunctionpartitioner

repartition the servers periodically

src/kvraft/test_test.go:122

↓ 2 callersFunctionrandstring

src/shardmaster/config.go:16

↓ 2 callersFunctionrandstring

src/kvraft/config.go:19

↓ 2 callersMethodreadPersist

restore previously persisted state. func (*Deocder) Decode(e interface{}) error Decode reads the next value from the input stream and stores it in th

src/raft/raft_method.go:66

↓ 2 callersMethodrpcTotal

src/kvraft/config.go:392

↓ 2 callersMethodrpcTotal

src/raft/config.go:284

↓ 2 callersMethodrun

run executes a mapreduce job on the given number of mappers and reducers. First, it divides up the input file among the given number of mappers, and

src/mapreduce/master.go:135

↓ 2 callersFunctiontruncateLog

TODO: 注释 truncateLog

src/raft/logEntry.go:11

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

timeout = 0 means no timeout if this operation times out, then a false positive is possible

src/linearizability/linearizability.go:278

↓ 1 callersFunctionCheckOperationsTimeout

timeout = 0 means no timeout if this operation times out, then a false positive is possible

src/linearizability/linearizability.go:235

↓ 1 callersMethodCleanupFiles

CleanupFiles removes all intermediate files produced by running mapreduce.

src/mapreduce/master_splitmerge.go:62

↓ 1 callersFunctionConcurrentChannel

ConcurrentChannel 启动 master

Lectures/LEC02/crawler/crawler.go:131

↓ 1 callersFunctionConcurrentMutex

ConcurrentMutex 并行互斥地抓取

Lectures/LEC02/crawler/crawler.go:51

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

Distributed schedules map and reduce tasks on workers that register with the master over RPC.

src/mapreduce/master.go:108

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

↓ 1 callersMethodLeader

src/shardmaster/config.go:299

↓ 1 callersMethodLeader

src/kvraft/config.go:325

↓ 1 callersMethodLongDelays

src/labrpc/labrpc.go:174

↓ 1 callersMethodLongReordering

src/labrpc/labrpc.go:167

↓ 1 callersFunctionMake

Make is 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

src/raft/raft_main.go:42

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

↓ 1 callersMethodProcessReq

src/labrpc/labrpc.go:207

↓ 1 callersMethodRaft

needed by shardkv tester

src/shardmaster/server.go:51

↓ 1 callersMethodReadEndnameInfo

(endname interface{})

src/labrpc/labrpc.go:181

↓ 1 callersFunctionRegister

(value interface{})

src/labgob/labgob.go:58

↓ 1 callersFunctionSerial

Several solutions to the crawler exercise from the Go tutorial https://tour.golang.org/concurrency/10 Serial crawler Serial 是按照顺序抓取

Lectures/LEC02/crawler/crawler.go:18

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

↓ 1 callersMethodStartMasterServer

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

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

↓ 1 callersMethodString

src/raft/fsm.go:16

↓ 1 callersMethodaddHandlers

添加 rf 转换状态时的处理函数

src/raft/fsm.go:72

↓ 1 callersFunctionautofill_email

Lectures/LEC16/6.824 Spring 2018 Paper Questions_files/common.js:1

↓ 1 callersFunctionautofill_email

Lectures/LEC15/6.824 Spring 2018 Paper Questions_files/common.js:1

↓ 1 callersFunctionautofill_email

Lectures/LEC14/6.824 Spring 2018 Paper Questions_files/common.js:1

↓ 1 callersFunctionautofill_email

Lectures/LEC21/6.824 Spring 2018 Paper Questions_files/common.js:1

↓ 1 callersFunctionautofill_email

Lectures/LEC02/6.824 Spring 2018 Paper Questions_files/common.js:1

↓ 1 callersFunctionautofill_email

Lectures/6.824 Schedule_ Spring 2018_files/common.js:1

↓ 1 callersFunctionautofill_email

Lectures/LEC13/6.824 Spring 2018 Paper Questions_files/common.js:1

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