Functions — github.com/Vanilla-Beauty/MIT6.5840

hub / github.com/Vanilla-Beauty/MIT6.5840 / functions

Functions443 in github.com/Vanilla-Beauty/MIT6.5840

⨍ Functions 443◇ Types & classes 93

MethodLen

()

src/porcupine/checker.go:31

MethodLess

(i, j int)

src/main/mrsequential.go:23

src/porcupine/checker.go:39

MethodLogInfoReceive

(opArgs *Op, logType int)

src/kvraft/server.go:74

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

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

FunctionNoPartition

(history []Operation)

src/porcupine/model.go:51

FunctionNoPartitionEvent

(history []Event)

src/porcupine/model.go:55

MethodNoticeResult

更新任务状态

src/mr/coordinator.go:176

MethodPutAppend

(args *PutAppendArgs, reply *PutAppendReply)

src/kvraft/server.go:229

MethodPutAppend

(args *PutAppendArgs, reply *PutAppendReply)

src/shardkv/server.go:35

MethodQuery

(args *QueryArgs, reply *QueryReply)

src/shardctrler/server.go:174

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

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

RequestVote RPC handler.

src/raft/raft.go:893

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

FunctionTestBasic

(t *testing.T)

src/shardctrler/test_test.go:83

FunctionTestBasic

(t *testing.T)

src/labrpc/test_test.go:69

FunctionTestBasic3A

(t *testing.T)

src/kvraft/test_test.go:425

FunctionTestBasicAgree2B

(t *testing.T)

src/raft/test_test.go:128

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

FunctionTestChallenge1Delete

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

src/shardkv/test_test.go:732

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 migration

src/shardkv/test_test.go:884

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

FunctionTestClearFile

(t *testing.T)

src/mr/utils_test.go:9

FunctionTestConcurrent1

(t *testing.T)

src/shardkv/test_test.go:302

FunctionTestConcurrent2

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

src/shardkv/test_test.go:381

FunctionTestConcurrent3

(t *testing.T)

src/shardkv/test_test.go:452

FunctionTestConcurrent3A

(t *testing.T)

src/kvraft/test_test.go:434

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

FunctionTestCount2B

(t *testing.T)

src/raft/test_test.go:567

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 not

src/labgob/test_test.go:140

FunctionTestDisconnect

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

src/labrpc/test_test.go:146

FunctionTestFailAgree2B

test that a follower participates after disconnect and re-connect.

src/raft/test_test.go:271

FunctionTestFailNoAgree2B

(t *testing.T)

src/raft/test_test.go:305

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 lo

src/raft/test_test.go:807

FunctionTestFigure8Unreliable2C

(t *testing.T)

src/raft/test_test.go:892

FunctionTestFollowerFailure2B

test just failure of followers.

src/raft/test_test.go:185

FunctionTestGOB

test that we didn't break GOB.

src/labgob/test_test.go:25

FunctionTestInitialElection2A

(t *testing.T)

src/raft/test_test.go:24

FunctionTestJoinLeave

(t *testing.T)

src/shardkv/test_test.go:95

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

FunctionTestLeaderFailure2B

test just failure of leaders.

src/raft/test_test.go:230

FunctionTestManyElections2A

(t *testing.T)

src/raft/test_test.go:95

FunctionTestManyPartitionsManyClients3A

(t *testing.T)

src/kvraft/test_test.go:559

FunctionTestManyPartitionsOneClient3A

(t *testing.T)

src/kvraft/test_test.go:554

FunctionTestMissChange

(t *testing.T)

src/shardkv/test_test.go:216

FunctionTestMulti

(t *testing.T)

src/shardctrler/test_test.go:255

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

FunctionTestPersist12C

(t *testing.T)

src/raft/test_test.go:677

FunctionTestPersist22C

(t *testing.T)

src/raft/test_test.go:723

FunctionTestPersist32C

(t *testing.T)

src/raft/test_test.go:769

FunctionTestPersistConcurrent3A

(t *testing.T)

src/kvraft/test_test.go:569

FunctionTestPersistConcurrentUnreliable3A

(t *testing.T)

src/kvraft/test_test.go:574

FunctionTestPersistOneClient3A

(t *testing.T)

src/kvraft/test_test.go:564

FunctionTestPersistPartition3A

(t *testing.T)

src/kvraft/test_test.go:579

FunctionTestPersistPartitionUnreliable3A

(t *testing.T)

src/kvraft/test_test.go:584

FunctionTestPersistPartitionUnreliableLinearizable3A

(t *testing.T)

src/kvraft/test_test.go:589

FunctionTestRPCBytes2B

check, based on counting bytes of RPCs, that each command is sent to each peer just once.

src/raft/test_test.go:153

FunctionTestReElection2A

(t *testing.T)

src/raft/test_test.go:55

FunctionTestRegression1

regression: an RPC that's delayed during Enabled=false should not delay subsequent RPCs (e.g. after Enabled=true).

src/labrpc/test_test.go:448

FunctionTestRejoin2B

(t *testing.T)

src/raft/test_test.go:457

FunctionTestReliableChurn2C

(t *testing.T)

src/raft/test_test.go:1092

FunctionTestSnapshot

(t *testing.T)

src/shardkv/test_test.go:148

FunctionTestSnapshotAllCrash2D

do the servers persist the snapshots, and restart using snapshot along with the tail of the log?

src/raft/test_test.go:1190

FunctionTestSnapshotBasic2D

(t *testing.T)

src/raft/test_test.go:1166

FunctionTestSnapshotInit2D

do servers correctly initialize their in-memory copy of the snapshot, making sure that future writes to persistent state don't lose state?

src/raft/test_test.go:1230

FunctionTestSnapshotInstall2D

(t *testing.T)

src/raft/test_test.go:1170

FunctionTestSnapshotInstallCrash2D

(t *testing.T)

src/raft/test_test.go:1179

FunctionTestSnapshotInstallUnCrash2D

(t *testing.T)

src/raft/test_test.go:1183

FunctionTestSnapshotInstallUnreliable2D

(t *testing.T)

src/raft/test_test.go:1174

FunctionTestSnapshotRPC3B

if one server falls behind, then rejoins, does it recover by using the InstallSnapshot RPC? also checks that majority discards committed log entries e

src/kvraft/test_test.go:598

FunctionTestSnapshotRecover3B

(t *testing.T)

src/kvraft/test_test.go:692

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