Functions — github.com/chaozh/MIT-6.824

hub / github.com/chaozh/MIT-6.824 / functions

Functions379 in github.com/chaozh/MIT-6.824

⨍ Functions 379◇ Types & classes 79

↓ 1 callersMethodreadPersist

restore previously persisted state.

src/raft/raft.go:99

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

↓ 1 callersMethodserver

start a thread that listens for RPCs from worker.go

src/mr/coordinator.go:31

↓ 1 callersMethodsetlongreordering

(longrel bool)

src/raft/config.go:366

↓ 1 callersMethodshardclerk

()

src/shardkv/config.go:292

↓ 1 callersMethodticker

The ticker go routine starts a new election if this peer hasn't received heartsbeats recently.

src/raft/raft.go:246

↓ 1 callersFunctionunlift

(entry *node)

src/porcupine/checker.go:164

↓ 1 callersFunctionusage

()

src/main/pbc.go:25

MethodAppend

(key string, value string)

src/kvraft/client.go:62

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

MethodGet

(args *GetArgs, reply *GetReply)

src/kvraft/server.go:41

MethodGet

(args *GetArgs, reply *GetReply)

src/shardkv/server.go:31

MethodGetCount

get a server's count of incoming RPCs.

src/labrpc/labrpc.go:364

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

MethodLeave

(args *LeaveArgs, reply *LeaveReply)

src/shardctrler/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/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:62

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 conte

src/mrapps/wc.go:21

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

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

MethodQuery

(args *QueryArgs, reply *QueryReply)

src/shardctrler/server.go:39

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

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

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

MethodSaveRaftState

(state []byte)

src/raft/persister.go:39

FunctionShallowEqual

(state1, state2 interface{})

src/porcupine/model.go:59

MethodSnapshotSize

()

src/raft/persister.go:72

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

FunctionTestBasic

(t *testing.T)

src/shardctrler/test_test.go:81

FunctionTestBasic

(t *testing.T)

src/labrpc/test_test.go:69

FunctionTestBasic3A

(t *testing.T)

src/kvraft/test_test.go:419

FunctionTestBasicAgree2B

(t *testing.T)

src/raft/test_test.go:122

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

FunctionTestChallenge1Delete

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

src/shardkv/test_test.go:738

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

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

FunctionTestConcurrent1

(t *testing.T)

src/shardkv/test_test.go:304

FunctionTestConcurrent2

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

src/shardkv/test_test.go:385

FunctionTestConcurrent3

(t *testing.T)

src/shardkv/test_test.go:456

FunctionTestConcurrent3A

(t *testing.T)

src/kvraft/test_test.go:428

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

FunctionTestCount2B

(t *testing.T)

src/raft/test_test.go:476

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

FunctionTestFailNoAgree2B

(t *testing.T)

src/raft/test_test.go:214

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

FunctionTestFigure8Unreliable2C

(t *testing.T)

src/raft/test_test.go:803

FunctionTestGOB

test that we didn't break GOB.

src/labgob/test_test.go:27

FunctionTestInitialElection2A

(t *testing.T)

src/raft/test_test.go:22

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