Functions — github.com/PKUFlyingPig/MIT6.824

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

Functions373 in github.com/PKUFlyingPig/MIT6.824

⨍ Functions 373◇ Types & classes 84

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

↓ 1 callersFunctionrenumber

(events []Event)

src/porcupine/checker.go:87

↓ 1 callersFunctionrun_client

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

src/kvraft/test_test.go:47

↓ 1 callersMethodsendAppendEntries

(server int, args *AppendEntriesArgs, reply *AppendEntriesReply)

src/raft/raft.go:252

↓ 1 callersMethodsendRequestVote

example code to 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 *

src/raft/raft.go:328

↓ 1 callersMethodserver

start a thread that listens for RPCs from worker.go

src/mr/master.go:125

↓ 1 callersMethodsetlongreordering

(longrel bool)

src/raft/config.go:296

↓ 1 callersMethodshardclerk

()

src/shardkv/config.go:289

↓ 1 callersMethodstartElection

candidate starts an election

src/raft/raft.go:567

↓ 1 callersFunctionunlift

(entry *node)

src/porcupine/checker.go:164

↓ 1 callersFunctionusage

()

src/main/pbc.go:25

MethodAllocateTask

(args *WorkerArgs, reply *WorkerReply)

src/mr/master.go:42

MethodAppendEntries

AppendEntries RPC handler

src/raft/raft.go:184

FunctionCallExample

example function to show how to make an RPC call to the master. the RPC argument and reply types are defined in rpc.go.

src/mr/worker.go:183

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

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

MethodExample

an example RPC handler. the RPC argument and reply types are defined in rpc.go.

src/mr/master.go:117

MethodGet

(args *GetArgs, reply *GetReply)

src/kvraft/server.go:41

MethodGet

(args *GetArgs, reply *GetReply)

src/shardkv/server.go:32

MethodGetCount

get a server's count of incoming RPCs.

src/labrpc/labrpc.go:362

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

src/porcupine/checker.go:31

MethodLess

(i, j int)

src/main/mrsequential.go:23

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

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

(args *PutAppendArgs, reply *PutAppendReply)

src/kvraft/server.go:45

MethodPutAppend

(args *PutAppendArgs, reply *PutAppendReply)

src/shardkv/server.go:36

MethodQuery

(args *QueryArgs, reply *QueryReply)

src/shardmaster/server.go:39

MethodReceiveFinishedMap

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

src/mr/master.go:26

MethodReceiveFinishedReduce

(args *WorkerArgs, reply *WorkerReply)

src/mr/master.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: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

MethodRequestVote

example RequestVote RPC handler.

src/raft/raft.go:260

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

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

FunctionTestCapital

make sure we check capitalization labgob prints one warning during this test.

src/labgob/test_test.go:119

FunctionTestChallenge1Concurrent

(t *testing.T)

src/shardkv/test_test.go:744

FunctionTestChallenge1Delete

optional test to see whether servers are deleting shards for which they are no longer responsible.

src/shardkv/test_test.go:663

FunctionTestChallenge2Partial

optional test to see whether servers can handle operations on shards that have been received as a part of a config migration when the entire migratio

src/shardkv/test_test.go:887

FunctionTestChallenge2Unaffected

optional test to see whether servers can handle shards that are not affected by a config change while the config change is underway

src/shardkv/test_test.go:817

FunctionTestConcurrent1

(t *testing.T)

src/shardkv/test_test.go:297

FunctionTestConcurrent2

this tests the various sources from which a re-starting group might need to fetch shard contents.

src/shardkv/test_test.go:378

FunctionTestConcurrent3A

(t *testing.T)

src/kvraft/test_test.go:453

FunctionTestConcurrentMany

test RPCs from concurrent ClientEnds

src/labrpc/test_test.go:275

FunctionTestConcurrentOne

test concurrent RPCs from a single ClientEnd

src/labrpc/test_test.go:386

FunctionTestConcurrentStarts2B

(t *testing.T)

src/raft/test_test.go:232

FunctionTestCount2B

(t *testing.T)

src/raft/test_test.go:443

FunctionTestCounts

test net.GetCount()

src/labrpc/test_test.go:185

FunctionTestDefault

check that we warn when someone sends a default value over RPC but the target into which we're decoding holds a non-default value, which GOB seems no

src/labgob/test_test.go:146

FunctionTestDisconnect

does net.Enable(endname, false) really disconnect a client?

src/labrpc/test_test.go:146

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