Functions — github.com/YXG520/MIT6.824-6.5840

hub / github.com/YXG520/MIT6.824-6.5840 / functions

Functions548 in github.com/YXG520/MIT6.824-6.5840

⨍ Functions 548◇ Types & classes 106

↓ 1 callersMethodmakeSnapshot

制作快照

src/kvraft/snapshot.go:20

↓ 1 callersMethodmakeSnapshot

制作快照

src/shardkv_with_bug/snapshot.go:20

↓ 1 callersMethodmake_partition

Partition servers into 2 groups and put current leader in minority

src/kvraft/config.go:343

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

()

src/shardctrler/client.go:24

↓ 1 callersFunctionnrand

()

src/shardkv/client.go:31

↓ 1 callersFunctionnrand

()

src/shardkv_with_bug/client.go:31

↓ 1 callersFunctionpartitioner

repartition the servers periodically

src/kvraft/test_test.go:183

↓ 1 callersMethodpastElectionTimeout

()

src/raft/leader_election.go:76

↓ 1 callersMethodpastHeartbeatTimeout

()

src/raft/log_replication.go:7

↓ 1 callersMethodpopcnt

()

src/porcupine/bitset.go:46

↓ 1 callersMethodprocessReq

(req reqMsg)

src/labrpc/labrpc.go:232

↓ 1 callersFunctionrandom_handles

Randomize server handles

src/shardctrler/config.go:24

↓ 1 callersFunctionrandom_handles

Randomize server handles

src/kvraft/config.go:37

↓ 1 callersMethodreadEndnameInfo

(endname interface{})

src/labrpc/labrpc.go:206

↓ 1 callersMethodreadPersist

restore previously persisted state.

src/raft/raft.go:171

↓ 1 callersMethodremoveShardHandler

(op Op)

src/shardkv/server.go:473

↓ 1 callersMethodremoveShardHandler

(op Op)

src/shardkv_with_bug/reshard.go:60

↓ 1 callersFunctionrenumber

(events []Event)

src/porcupine/checker.go:92

↓ 1 callersMethodresetHeartbeatTimer

()

src/raft/log_replication.go:13

↓ 1 callersMethodresetTrackedIndex

()

src/raft/tracker.go:17

↓ 1 callersFunctionrun_client

a client runs the function f and then signals it is done

src/kvraft/test_test.go:106

↓ 1 callersMethodsendMsgToTester

通知tester（作用相当于状态机）接收这个日志消息，然后供状态机使用

src/raft/raft.go:717

↓ 1 callersMethodsendRequestInstallSnapshot

(server int, args *RequestInstallSnapShotArgs, reply *RequestInstallSnapShotReply)

src/raft/snapshot.go:155

↓ 1 callersMethodsendRequestVote

example code to send a RequestVoteRPC to a server. server is the index of the target server in rf.peers[]. expects RPC arguments in args. fills in *re

src/raft/raft.go:229

↓ 1 callersMethodsendShard

(servers []*labrpc.ClientEnd, args *MoveShardsArgs, shardId int)

src/shardkv_with_bug/server.go:188

↓ 1 callersMethodserver

start a thread that listens for RPCs from worker.go

src/mr/coordinator.go:29

↓ 1 callersMethodsetlongreordering

(longrel bool)

src/raft/config.go:420

↓ 1 callersMethodshardclerk

()

src/shardkv/config.go:292

↓ 1 callersMethodshardclerk

()

src/shardkv_with_bug/config.go:292

↓ 1 callersMethodticker

()

src/raft/raft.go:790

↓ 1 callersFunctionunlift

(entry *node)

src/porcupine/checker.go:169

↓ 1 callersMethodupConfigHandler

------------------------------------------------------handler部分------------------------------------------------------ 更新最新的config的handler

src/shardkv/server.go:438

↓ 1 callersMethodupdateConfig

更新最新的config的handler

src/shardkv_with_bug/reshard.go:4

↓ 1 callersFunctionusage

()

src/main/pbc.go:25

MethodAddShard

AddShard move shards from caller to this server

src/shardkv/server.go:420

MethodAddShard

AddShards move shards from caller to this server

src/shardkv_with_bug/reshard.go:26

MethodAppend

(key string, value string)

src/kvraft/client.go:96

MethodAppendEntries2

nextIndex收敛速度优化：nextIndex跳跃算法，需搭配HandleAppendEntriesRPC2方法使用

src/raft/raft.go:561

FunctionCallExample

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

FunctionCheckEvents

(model Model, history []Event)

src/porcupine/porcupine.go:23

FunctionCheckEventsTimeout

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

src/porcupine/porcupine.go:30

FunctionCheckEventsVerbose

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

src/porcupine/porcupine.go:37

FunctionCheckOperations

(model Model, history []Operation)

src/porcupine/porcupine.go:5

FunctionCheckOperationsTimeout

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

src/porcupine/porcupine.go:12

FunctionCheckOperationsVerbose

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

src/porcupine/porcupine.go:19

MethodConnectClient

(ck *Clerk, to []int)

src/shardctrler/config.go:205

MethodDecodeWithPrint

(id int, name string, e interface{})

src/labgob/labgob.go:59

FunctionDefaultDescribeOperation

(input interface{}, output interface{})

src/porcupine/model.go:63

FunctionDefaultDescribeState

(state interface{})

src/porcupine/model.go:67

MethodDisconnectClient

(ck *Clerk, from []int)

src/shardctrler/config.go:221

MethodDisconnectClient

(ck *Clerk, from []int)

src/kvraft/config.go:252

MethodExample

Your code here -- RPC handlers for the worker to call. an example RPC handler. the RPC argument and reply types are defined in rpc.go.

src/mr/coordinator.go:21

MethodGet

(args *GetArgs, reply *GetReply)

src/kvraft/server.go:79

MethodGet

------------------------------------------------------RPC部分----------------------------------------------------------

src/shardkv/server.go:359

MethodGet

(args *GetArgs, reply *GetReply)

src/shardkv_with_bug/server.go:338

MethodGetCount

get a server's count of incoming RPCs.

src/labrpc/labrpc.go:378

MethodHandleAppendEntriesRPC

方法一：定义一个心跳兼日志同步处理器，这个方法是Candidate和Follower节点的处理 nextIndex递减算法 func (rf *Raft) HandleAppendEntriesRPC2(args *RequestAppendEntriesArgs, reply *RequestA

src/raft/log_replication.go:80

MethodHandleHeartbeatRPC

定义一个心跳兼日志同步处理器，这个方法是Candidate和Follower节点的处理

src/raft/leader_election.go:104

MethodHandler1

(args string, reply *int)

src/labrpc/test_test.go:23

MethodHandler2

(args int, reply *string)

src/labrpc/test_test.go:30

MethodHandler3

(args int, reply *int)

src/labrpc/test_test.go:37

MethodHandler4

args is a pointer

src/labrpc/test_test.go:45

MethodHandler5

args is a not pointer

src/labrpc/test_test.go:50

MethodHandler6

(args string, reply *int)

src/labrpc/test_test.go:54

MethodHandler7

(args int, reply *string)

src/labrpc/test_test.go:60

MethodJoin

(args *JoinArgs, reply *JoinReply)

src/shardctrler/server.go:129

(args *LeaveArgs, reply *LeaveReply)

src/shardctrler/server.go:185

MethodLen

for sorting by key.

src/main/mrsequential.go:21

MethodLen

()

src/porcupine/checker.go:31

MethodLess

(i, j int)

src/main/mrsequential.go:23

MethodLess

(i, j int)

src/porcupine/checker.go:39

MethodLogSize

Maximum log size across all servers

src/shardctrler/config.go:67

FunctionMakeCoordinator

create a Coordinator. main/mrcoordinator.go calls this function. nReduce is the number of reduce tasks to use.

src/mr/coordinator.go:59

FunctionMap

(filename string, contents string)

src/mrapps/jobcount.go:22

FunctionMap

The map function is called once for each file of input. The first argument is the name of the input file, and the second is the file's complete conten

src/mrapps/wc.go:19

FunctionMap

(filename string, contents string)

src/mrapps/nocrash.go:26

FunctionMap

The map function is called once for each file of input. This map function just returns 1 for each file

src/mrapps/early_exit.go:19

FunctionMap

(filename string, contents string)

src/mrapps/mtiming.go:64

FunctionMap

(filename string, contents string)

src/mrapps/rtiming.go:62

FunctionMap

The mapping function is called once for each piece of the input. In this framework, the key is the name of the file that is being processed, and the v

src/mrapps/indexer.go:20

FunctionMap

(filename string, contents string)

src/mrapps/crash.go:34

MethodMove

(args *MoveArgs, reply *MoveReply)

src/shardctrler/server.go:237

FunctionNoPartition

(history []Operation)

src/porcupine/model.go:51

FunctionNoPartitionEvent

(history []Event)

src/porcupine/model.go:55

MethodPutAppend

(args *PutAppendArgs, reply *PutAppendReply)

src/kvraft/server.go:199

MethodPutAppend

(args *PutAppendArgs, reply *PutAppendReply)

src/shardkv/server.go:396

MethodPutAppend

(args *PutAppendArgs, reply *PutAppendReply)

src/shardkv_with_bug/server.go:408

MethodQuery

(args *QueryArgs, reply *QueryReply)

src/shardctrler/server.go:289

FunctionReduce

(key string, values []string)

src/mrapps/jobcount.go:34

FunctionReduce

The reduce function is called once for each key generated by the map tasks, with a list of all the values created for that key by any map task.

src/mrapps/wc.go:37

FunctionReduce

(key string, values []string)

src/mrapps/nocrash.go:37

FunctionReduce

The reduce function is called once for each key generated by the map tasks, with a list of all the values created for that key by any map task.

src/mrapps/early_exit.go:28

FunctionReduce

(key string, values []string)

src/mrapps/mtiming.go:81

FunctionReduce

(key string, values []string)

src/mrapps/rtiming.go:78

← previous next →301–400 of 548, ranked by callers