MCPcopy Create free account

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

Functions379 in github.com/chaozh/MIT-6.824

FunctionTestJoinLeave
(t *testing.T)
src/shardkv/test_test.go:97
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
FunctionTestManyElections2A
(t *testing.T)
src/raft/test_test.go:89
FunctionTestManyPartitionsManyClients3A
(t *testing.T)
src/kvraft/test_test.go:553
FunctionTestManyPartitionsOneClient3A
(t *testing.T)
src/kvraft/test_test.go:548
FunctionTestMissChange
(t *testing.T)
src/shardkv/test_test.go:218
FunctionTestMulti
(t *testing.T)
src/shardctrler/test_test.go:253
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:473
FunctionTestPersist12C
(t *testing.T)
src/raft/test_test.go:586
FunctionTestPersist22C
(t *testing.T)
src/raft/test_test.go:632
FunctionTestPersist32C
(t *testing.T)
src/raft/test_test.go:678
FunctionTestPersistConcurrent3A
(t *testing.T)
src/kvraft/test_test.go:563
FunctionTestPersistConcurrentUnreliable3A
(t *testing.T)
src/kvraft/test_test.go:568
FunctionTestPersistOneClient3A
(t *testing.T)
src/kvraft/test_test.go:558
FunctionTestPersistPartition3A
(t *testing.T)
src/kvraft/test_test.go:573
FunctionTestPersistPartitionUnreliable3A
(t *testing.T)
src/kvraft/test_test.go:578
FunctionTestPersistPartitionUnreliableLinearizable3A
(t *testing.T)
src/kvraft/test_test.go:583
FunctionTestRPCBytes2B
check, based on counting bytes of RPCs, that each command is sent to each peer just once.
src/raft/test_test.go:149
FunctionTestReElection2A
(t *testing.T)
src/raft/test_test.go:53
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:366
FunctionTestReliableChurn2C
(t *testing.T)
src/raft/test_test.go:1003
FunctionTestSnapshot
(t *testing.T)
src/shardkv/test_test.go:150
FunctionTestSnapshotBasic2D
(t *testing.T)
src/raft/test_test.go:1067
FunctionTestSnapshotInstall2D
(t *testing.T)
src/raft/test_test.go:1071
FunctionTestSnapshotInstallCrash2D
(t *testing.T)
src/raft/test_test.go:1080
FunctionTestSnapshotInstallUnCrash2D
(t *testing.T)
src/raft/test_test.go:1084
FunctionTestSnapshotInstallUnreliable2D
(t *testing.T)
src/raft/test_test.go:1075
FunctionTestSnapshotRPC3B
if one server falls behind, then rejoins, does it recover by using the InstallSnapshot RPC? also checks that majority discards committed log entries
src/kvraft/test_test.go:594
FunctionTestSnapshotRecover3B
(t *testing.T)
src/kvraft/test_test.go:688
FunctionTestSnapshotRecoverManyClients3B
(t *testing.T)
src/kvraft/test_test.go:693
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:651
FunctionTestSnapshotUnreliable3B
(t *testing.T)
src/kvraft/test_test.go:698
FunctionTestSnapshotUnreliableRecover3B
(t *testing.T)
src/kvraft/test_test.go:703
FunctionTestSnapshotUnreliableRecoverConcurrentPartition3B
(t *testing.T)
src/kvraft/test_test.go:708
FunctionTestSnapshotUnreliableRecoverConcurrentPartitionLinearizable3B
(t *testing.T)
src/kvraft/test_test.go:713
FunctionTestSpeed3A
(t *testing.T)
src/kvraft/test_test.go:424
FunctionTestSpeed3B
(t *testing.T)
src/kvraft/test_test.go:684
FunctionTestStaticShards
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
(t *testing.T)
src/shardkv/test_test.go:524
FunctionTestUnreliable2
(t *testing.T)
src/shardkv/test_test.go:566
FunctionTestUnreliable3
(t *testing.T)
src/shardkv/test_test.go:629
FunctionTestUnreliable3A
(t *testing.T)
src/kvraft/test_test.go:433
FunctionTestUnreliableAgree2C
(t *testing.T)
src/raft/test_test.go:774
FunctionTestUnreliableChurn2C
(t *testing.T)
src/raft/test_test.go:1007
FunctionTestUnreliableOneKey3A
(t *testing.T)
src/kvraft/test_test.go:438
FunctionVisualizePath
(model Model, info linearizationInfo, path string)
src/porcupine/visualization.go:102
FunctionWorker
main/mrworker.go calls this function.
src/mr/worker.go:31
Methodapplier
applier reads message from apply ch and checks that they match the log contents
src/raft/config.go:157
MethodapplierSnap
periodically snapshot raft state
src/raft/config.go:181
Methodconnect
(i int, to []int)
src/shardctrler/config.go:96
Methodconnect
(i int, to []int)
src/kvraft/config.go:123
MethoddeleteClient
(ck *Clerk)
src/shardctrler/config.go:184
MethoddeleteClient
(ck *Clerk)
src/shardkv/config.go:144
Methoddisconnect
(i int, from []int)
src/shardctrler/config.go:124
Methoddisconnect
(i int, from []int)
src/kvraft/config.go:151
Methoddispatch
(methname string, req reqMsg)
src/labrpc/labrpc.go:478
Methodget
(pos uint)
src/porcupine/bitset.go:41
Functionihash
use ihash(key) % NReduce to choose the reduce task number for each KeyValue emitted by Map.
src/mr/worker.go:21
Methodkilled
()
src/kvraft/server.go:65
Functionmain
()
src/main/viewd.go:12
Functionmain
()
src/main/pbc.go:31
Functionmain
()
src/main/mrcoordinator.go:17
Functionmain
()
src/main/lockd.go:19
Functionmain
()
src/main/diskvd.go:30
Functionmain
()
src/main/lockc.go:16
Functionmain
()
src/main/pbd.go:12
Functionmain
()
src/main/mrsequential.go:25
Functionmain
()
src/main/mrworker.go:19
Methodmake_partition
Partition servers into 2 groups and put current leader in minority
src/shardctrler/config.go:315
Functionnrand
()
src/shardctrler/client.go:17
Functionnrand
()
src/kvraft/client.go:13
Functionnrand
()
src/shardkv/client.go:31
Methodpartition
Sets up 2 partitions with connectivity between servers in each partition.
src/shardctrler/config.go:147
Methodpersist
save Raft's persistent state to stable storage, where it can later be retrieved after a crash and restart. see paper's Figure 2 for a description of
src/raft/raft.go:84
Functionrandom_handles
Randomize server handles
src/shardkv/config.go:35
MethodsendRequestVote
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:192
← previous301–379 of 379, ranked by callers