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

⨍ Functions 386◇ Types & classes 90

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

()

src/kvraft/client.go:18

↓ 1 callersMethodpopcnt

()

src/porcupine/bitset.go:46

↓ 1 callersMethodprocessReq

(req reqMsg)

src/labrpc/labrpc.go:216

↓ 1 callersFunctionrandom_handles

Randomize server handles

src/shardmaster/config.go:24

↓ 1 callersFunctionrandom_handles

Randomize server handles

src/kvraft/config.go:34

↓ 1 callersMethodreadEndnameInfo

(endname interface{})

src/labrpc/labrpc.go:190

↓ 1 callersMethodreadPersist

restore previously persisted state.

src/raft/raft.go:130

↓ 1 callersFunctionrenumber

(events []Event)

src/porcupine/checker.go:87

↓ 1 callersFunctionrequestTask

()

src/mr/worker.go:200

↓ 1 callersMethodrunServer

main server loop.

src/raft/raft.go:660

↓ 1 callersFunctionrun_client

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

src/kvraft/test_test.go:47

↓ 1 callersMethodsendAppendEntries

send a AppendEntries RPC to a server.

src/raft/raft.go:453

↓ 1 callersMethodsendRequestVote

send a RequestVote RPC to a server. server is the index of the target server in rf.peers[]. expects RPC arguments in args. fills in *reply with RPC r

src/raft/raft.go:329

↓ 1 callersMethodserver

start a thread that listens for RPCs from worker.go

src/mr/master.go:160

↓ 1 callersMethodsetlongreordering

(longrel bool)

src/raft/config.go:296

↓ 1 callersMethodshardclerk

()

src/shardkv/config.go:289

↓ 1 callersFunctionunlift

(entry *node)

src/porcupine/checker.go:164

↓ 1 callersFunctionusage

()

src/main/pbc.go:25

↓ 1 callersMethodwaitForTask

(task *Task)

src/mr/master.go:140

↓ 1 callersFunctionwriteMapOutput

(kva []KeyValue, mapId int)

src/mr/worker.go:98

↓ 1 callersFunctionwriteReduceOutput

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

src/mr/worker.go:163

MethodAppendEntries

AppendEntries RPC handler.

src/raft/raft.go:384

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/shardmaster/config.go:205

FunctionDPrintf

(format string, a ...interface{})

src/kvraft/server.go:15

FunctionDPrintf

(format string, a ...interface{})

src/raft/util.go:8

FunctionDefaultDescribeOperation

(input interface{}, output interface{})

src/porcupine/model.go:63

FunctionDefaultDescribeState

(state interface{})

src/porcupine/model.go:67

MethodDisconnectClient

(ck *Clerk, from []int)

src/shardmaster/config.go:221

MethodDisconnectClient

(ck *Clerk, from []int)

src/kvraft/config.go:248

MethodGet

Get RPC handler

src/kvraft/server.go:53

MethodGet

(args *GetArgs, reply *GetReply)

src/shardkv/server.go:32

MethodGetCount

get a server's count of incoming RPCs.

src/labrpc/labrpc.go:362

MethodGetReduceCount

Your code here -- RPC handlers for the worker to call. GetReduceCount RPC handler.

src/mr/master.go:57

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/shardmaster/server.go:27

MethodLeave

(args *LeaveArgs, reply *LeaveReply)

src/shardmaster/server.go:31

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/shardmaster/config.go:67

FunctionMakeMaster

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

src/mr/master.go:190

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 conte

src/mrapps/wc.go:21

FunctionMap

(filename string, contents string)

src/mrapps/nocrash.go:26

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/shardmaster/server.go:35

FunctionNoPartition

(history []Operation)

src/porcupine/model.go:51

FunctionNoPartitionEvent

(history []Event)

src/porcupine/model.go:55

MethodPutAppend

PutAppend RPC handler

src/kvraft/server.go:75

MethodPutAppend

(args *PutAppendArgs, reply *PutAppendReply)

src/shardkv/server.go:36

MethodQuery

(args *QueryArgs, reply *QueryReply)

src/shardmaster/server.go:39

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

FunctionReduce

(key string, values []string)

src/mrapps/nocrash.go:37

FunctionReduce

(key string, values []string)

src/mrapps/mtiming.go:81

FunctionReduce

(key string, values []string)

src/mrapps/rtiming.go:78

FunctionReduce

The reduce function is called once for each key generated by Map, with a list of that key's string value (merged across all inputs). The return value

src/mrapps/indexer.go:36

FunctionReduce

(key string, values []string)

src/mrapps/crash.go:45

FunctionRegisterName

(name string, value interface{})

src/labgob/labgob.go:63

MethodReportTaskDone

RequestTask RPC handler.

src/mr/master.go:95

MethodRequestTask

RequestTask RPC handler.

src/mr/master.go:69

MethodRequestVote

RequestVote RPC handler.

src/raft/raft.go:273

MethodSaveStateAndSnapshot

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

FunctionShallowEqual

(state1, state2 interface{})

src/porcupine/model.go:59

MethodSnapshotSize

()

src/raft/persister.go:66

MethodSwap

(i, j int)

src/main/mrsequential.go:22

MethodSwap

(i, j int)

src/porcupine/checker.go:35

FunctionTestBackup2B

(t *testing.T)

src/raft/test_test.go:371

FunctionTestBasic

(t *testing.T)

src/shardmaster/test_test.go:80

FunctionTestBasic

(t *testing.T)

src/labrpc/test_test.go:69

FunctionTestBasic3A

(t *testing.T)

src/kvraft/test_test.go:448

FunctionTestBasicAgree2B

(t *testing.T)

src/raft/test_test.go:89

FunctionTestBenchmark

(t *testing.T)

src/labrpc/test_test.go:568

FunctionTestBytes

test net.GetTotalBytes()

src/labrpc/test_test.go:221

← previous next →201–300 of 386, ranked by callers