Functions — github.com/Ray-Eldath/MIT6.824

hub / github.com/Ray-Eldath/MIT6.824 / functions

Functions356 in github.com/Ray-Eldath/MIT6.824

⨍ Functions 356◇ Types & classes 78

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

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

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

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/master.go:22

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

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

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

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

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

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

FunctionTestFailAgree2B

(t *testing.T)

src/raft/test_test.go:147

FunctionTestFailNoAgree2B

(t *testing.T)

src/raft/test_test.go:181

FunctionTestFigure82C

Test the scenarios described in Figure 8 of the extended Raft paper. Each iteration asks a leader, if there is one, to insert a command in the Raft l

src/raft/test_test.go:685

FunctionTestFigure8Unreliable2C

(t *testing.T)

src/raft/test_test.go:770

FunctionTestGOB

test that we didn't break GOB.

src/labgob/test_test.go:27

FunctionTestInitialElection2A

(t *testing.T)

src/raft/test_test.go:22

FunctionTestJoinLeave

(t *testing.T)

src/shardkv/test_test.go:90

FunctionTestKilled

if an RPC is stuck in a server, and the server is killed with DeleteServer(), does the RPC get un-stuck?

src/labrpc/test_test.go:523

FunctionTestManyPartitionsManyClients3A

(t *testing.T)

src/kvraft/test_test.go:578

FunctionTestManyPartitionsOneClient3A

(t *testing.T)

src/kvraft/test_test.go:573

FunctionTestMissChange

(t *testing.T)

src/shardkv/test_test.go:211

FunctionTestMulti

(t *testing.T)

src/shardmaster/test_test.go:252

FunctionTestOnePartition3A

Submit a request in the minority partition and check that the requests doesn't go through until the partition heals. The leader in the original netwo

src/kvraft/test_test.go:498

FunctionTestPersist12C

(t *testing.T)

src/raft/test_test.go:553

FunctionTestPersist22C

(t *testing.T)

src/raft/test_test.go:599

FunctionTestPersist32C

(t *testing.T)

src/raft/test_test.go:645

FunctionTestPersistConcurrent3A

(t *testing.T)

src/kvraft/test_test.go:588

FunctionTestPersistConcurrentUnreliable3A

(t *testing.T)

src/kvraft/test_test.go:593

FunctionTestPersistOneClient3A

(t *testing.T)

src/kvraft/test_test.go:583

FunctionTestPersistPartition3A

(t *testing.T)

src/kvraft/test_test.go:598

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