Functions — github.com/YXG520/MIT6.824-6.5840

hub / github.com/YXG520/MIT6.824-6.5840 / functions

Functions548 in github.com/YXG520/MIT6.824-6.5840

⨍ Functions 548◇ Types & classes 106

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

MethodRequestInstallSnapshot

(args *RequestInstallSnapShotArgs, reply *RequestInstallSnapShotReply)

src/raft/snapshot.go:56

MethodRequestVote

example RequestVoteRPC handler.

src/raft/leader_election.go:132

FunctionShallowEqual

(state1, state2 interface{})

src/porcupine/model.go:59

MethodSnapshotSize

()

src/raft/persister.go:72

src/main/mrsequential.go:22

MethodSwap

(i, j int)

src/porcupine/checker.go:35

FunctionTestBackup2B

(t *testing.T)

src/raft/test_test.go:500

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

FunctionTestBasicAgree2B

(t *testing.T)

src/raft/test_test.go:127

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

FunctionTestChallenge1Delete

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

src/shardkv_with_bug/test_test.go:756

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

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_with_bug/test_test.go:908

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

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_with_bug/test_test.go:840

FunctionTestConcurrent1

(t *testing.T)

src/shardkv/test_test.go:388

FunctionTestConcurrent1

(t *testing.T)

src/shardkv_with_bug/test_test.go:326

FunctionTestConcurrent2

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

src/shardkv/test_test.go:468

FunctionTestConcurrent2

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

src/shardkv_with_bug/test_test.go:405

FunctionTestConcurrent3

(t *testing.T)

src/shardkv_with_bug/test_test.go:476

FunctionTestConcurrent3A

(t *testing.T)

src/kvraft/test_test.go:442

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

FunctionTestCount2B

(t *testing.T)

src/raft/test_test.go:582

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

FunctionTestFailNoAgree2B

(t *testing.T)

src/raft/test_test.go:310

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

FunctionTestFigure8Unreliable2C

(t *testing.T)

src/raft/test_test.go:910

FunctionTestFollowerFailure2B

test just failure of followers.

src/raft/test_test.go:190

FunctionTestGOB

test that we didn't break GOB.

src/labgob/test_test.go:25

FunctionTestInitialElection2A

(t *testing.T)

src/raft/test_test.go:22

FunctionTestJoinLeave

(t *testing.T)

src/shardkv/test_test.go:181

FunctionTestJoinLeave

(t *testing.T)

src/shardkv_with_bug/test_test.go:110

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

FunctionTestManyElections2A

(t *testing.T)

src/raft/test_test.go:94

FunctionTestManyPartitionsManyClients3A

(t *testing.T)

src/kvraft/test_test.go:567

FunctionTestManyPartitionsOneClient3A

(t *testing.T)

src/kvraft/test_test.go:562

FunctionTestMissChange

(t *testing.T)

src/shardkv/test_test.go:302

FunctionTestMissChange

(t *testing.T)

src/shardkv_with_bug/test_test.go:240

FunctionTestMulti

(t *testing.T)

src/shardctrler/test_test.go:260

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

FunctionTestPersist12C

(t *testing.T)

src/raft/test_test.go:692

FunctionTestPersist22C

(t *testing.T)

src/raft/test_test.go:741

FunctionTestPersist32C

(t *testing.T)

src/raft/test_test.go:787

FunctionTestPersistConcurrent3A

(t *testing.T)

src/kvraft/test_test.go:577

FunctionTestPersistConcurrentUnreliable3A

(t *testing.T)

src/kvraft/test_test.go:582

FunctionTestPersistOneClient3A

(t *testing.T)

src/kvraft/test_test.go:572

FunctionTestPersistPartition3A

(t *testing.T)

src/kvraft/test_test.go:587

FunctionTestPersistPartitionUnreliable3A

(t *testing.T)

src/kvraft/test_test.go:592

FunctionTestPersistPartitionUnreliableLinearizable3A

(t *testing.T)

src/kvraft/test_test.go:597

FunctionTestRPCBytes2B

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

src/raft/test_test.go:158

FunctionTestReElection2A

(t *testing.T)

src/raft/test_test.go:54

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

FunctionTestReliableChurn2C

(t *testing.T)

src/raft/test_test.go:1111

FunctionTestSnapshot

(t *testing.T)

src/shardkv/test_test.go:234

FunctionTestSnapshot

(t *testing.T)

src/shardkv_with_bug/test_test.go:172

FunctionTestSnapshotAllCrash2D

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

src/raft/test_test.go:1221

FunctionTestSnapshotBasic2D

(t *testing.T)

src/raft/test_test.go:1197

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

FunctionTestSnapshotInstall2D

(t *testing.T)

src/raft/test_test.go:1201

FunctionTestSnapshotInstallCrash2D

(t *testing.T)

src/raft/test_test.go:1210

FunctionTestSnapshotInstallUnCrash2D

(t *testing.T)

src/raft/test_test.go:1214

FunctionTestSnapshotInstallUnreliable2D

(t *testing.T)

src/raft/test_test.go:1205

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

FunctionTestSnapshotRecover3B

(t *testing.T)

src/kvraft/test_test.go:702

FunctionTestSnapshotRecoverManyClients3B

(t *testing.T)

src/kvraft/test_test.go:707

FunctionTestSnapshotSize3B

are the snapshots not too huge? 500 bytes is a generous bound for the operations we're doing here.

src/kvraft/test_test.go:665

FunctionTestSnapshotUnreliable3B

(t *testing.T)

src/kvraft/test_test.go:712

FunctionTestSnapshotUnreliableRecover3B

(t *testing.T)

src/kvraft/test_test.go:717

FunctionTestSnapshotUnreliableRecoverConcurrentPartition3B

(t *testing.T)

src/kvraft/test_test.go:722

FunctionTestSnapshotUnreliableRecoverConcurrentPartitionLinearizable3B

(t *testing.T)

src/kvraft/test_test.go:727

FunctionTestSpeed3A

(t *testing.T)

src/kvraft/test_test.go:438

FunctionTestSpeed3B

(t *testing.T)

src/kvraft/test_test.go:698

FunctionTestStaticShards

test static 2-way sharding, without shard movement.

src/shardkv/test_test.go:110

FunctionTestStaticShards

test static 2-way sharding, without shard movement.

src/shardkv_with_bug/test_test.go:27

FunctionTestStaticShards2

test static 2-way sharding, without shard movement.

src/shardkv/test_test.go:26

FunctionTestTypes

(t *testing.T)

src/labrpc/test_test.go:104

FunctionTestUnreliable

test unreliable

src/labrpc/test_test.go:333

FunctionTestUnreliable1

func TestConcurrent3(t *testing.T) { fmt.Printf("Test: concurrent configuration change and restart...\n") cfg := make_config(t, 3, false, 300) def

src/shardkv/test_test.go:607

FunctionTestUnreliable1

(t *testing.T)

src/shardkv_with_bug/test_test.go:544

FunctionTestUnreliable2

(t *testing.T)

src/shardkv/test_test.go:649

FunctionTestUnreliable2

(t *testing.T)

src/shardkv_with_bug/test_test.go:586

FunctionTestUnreliable3

(t *testing.T)

src/shardkv/test_test.go:712

FunctionTestUnreliable3

(t *testing.T)

src/shardkv_with_bug/test_test.go:649

FunctionTestUnreliable3A

(t *testing.T)

src/kvraft/test_test.go:447

← previous next →401–500 of 548, ranked by callers