Code
Hub
Workspaces
Following
Trending
Connect
MCP
copy
Create free account
hub
/
github.com/chaozh/MIT-6.824
/ functions
Functions
379 in github.com/chaozh/MIT-6.824
⨍
Functions
379
◇
Types & classes
79
Function
TestJoinLeave
(t *testing.T)
src/shardkv/test_test.go:97
Function
TestKilled
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
Function
TestManyElections2A
(t *testing.T)
src/raft/test_test.go:89
Function
TestManyPartitionsManyClients3A
(t *testing.T)
src/kvraft/test_test.go:553
Function
TestManyPartitionsOneClient3A
(t *testing.T)
src/kvraft/test_test.go:548
Function
TestMissChange
(t *testing.T)
src/shardkv/test_test.go:218
Function
TestMulti
(t *testing.T)
src/shardctrler/test_test.go:253
Function
TestOnePartition3A
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
Function
TestPersist12C
(t *testing.T)
src/raft/test_test.go:586
Function
TestPersist22C
(t *testing.T)
src/raft/test_test.go:632
Function
TestPersist32C
(t *testing.T)
src/raft/test_test.go:678
Function
TestPersistConcurrent3A
(t *testing.T)
src/kvraft/test_test.go:563
Function
TestPersistConcurrentUnreliable3A
(t *testing.T)
src/kvraft/test_test.go:568
Function
TestPersistOneClient3A
(t *testing.T)
src/kvraft/test_test.go:558
Function
TestPersistPartition3A
(t *testing.T)
src/kvraft/test_test.go:573
Function
TestPersistPartitionUnreliable3A
(t *testing.T)
src/kvraft/test_test.go:578
Function
TestPersistPartitionUnreliableLinearizable3A
(t *testing.T)
src/kvraft/test_test.go:583
Function
TestRPCBytes2B
check, based on counting bytes of RPCs, that each command is sent to each peer just once.
src/raft/test_test.go:149
Function
TestReElection2A
(t *testing.T)
src/raft/test_test.go:53
Function
TestRegression1
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
Function
TestRejoin2B
(t *testing.T)
src/raft/test_test.go:366
Function
TestReliableChurn2C
(t *testing.T)
src/raft/test_test.go:1003
Function
TestSnapshot
(t *testing.T)
src/shardkv/test_test.go:150
Function
TestSnapshotBasic2D
(t *testing.T)
src/raft/test_test.go:1067
Function
TestSnapshotInstall2D
(t *testing.T)
src/raft/test_test.go:1071
Function
TestSnapshotInstallCrash2D
(t *testing.T)
src/raft/test_test.go:1080
Function
TestSnapshotInstallUnCrash2D
(t *testing.T)
src/raft/test_test.go:1084
Function
TestSnapshotInstallUnreliable2D
(t *testing.T)
src/raft/test_test.go:1075
Function
TestSnapshotRPC3B
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
Function
TestSnapshotRecover3B
(t *testing.T)
src/kvraft/test_test.go:688
Function
TestSnapshotRecoverManyClients3B
(t *testing.T)
src/kvraft/test_test.go:693
Function
TestSnapshotSize3B
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
Function
TestSnapshotUnreliable3B
(t *testing.T)
src/kvraft/test_test.go:698
Function
TestSnapshotUnreliableRecover3B
(t *testing.T)
src/kvraft/test_test.go:703
Function
TestSnapshotUnreliableRecoverConcurrentPartition3B
(t *testing.T)
src/kvraft/test_test.go:708
Function
TestSnapshotUnreliableRecoverConcurrentPartitionLinearizable3B
(t *testing.T)
src/kvraft/test_test.go:713
Function
TestSpeed3A
(t *testing.T)
src/kvraft/test_test.go:424
Function
TestSpeed3B
(t *testing.T)
src/kvraft/test_test.go:684
Function
TestStaticShards
test static 2-way sharding, without shard movement.
src/shardkv/test_test.go:26
Function
TestTypes
(t *testing.T)
src/labrpc/test_test.go:104
Function
TestUnreliable
test unreliable
src/labrpc/test_test.go:333
Function
TestUnreliable1
(t *testing.T)
src/shardkv/test_test.go:524
Function
TestUnreliable2
(t *testing.T)
src/shardkv/test_test.go:566
Function
TestUnreliable3
(t *testing.T)
src/shardkv/test_test.go:629
Function
TestUnreliable3A
(t *testing.T)
src/kvraft/test_test.go:433
Function
TestUnreliableAgree2C
(t *testing.T)
src/raft/test_test.go:774
Function
TestUnreliableChurn2C
(t *testing.T)
src/raft/test_test.go:1007
Function
TestUnreliableOneKey3A
(t *testing.T)
src/kvraft/test_test.go:438
Function
VisualizePath
(model Model, info linearizationInfo, path string)
src/porcupine/visualization.go:102
Function
Worker
main/mrworker.go calls this function.
src/mr/worker.go:31
Method
applier
applier reads message from apply ch and checks that they match the log contents
src/raft/config.go:157
Method
applierSnap
periodically snapshot raft state
src/raft/config.go:181
Method
connect
(i int, to []int)
src/shardctrler/config.go:96
Method
connect
(i int, to []int)
src/kvraft/config.go:123
Method
deleteClient
(ck *Clerk)
src/shardctrler/config.go:184
Method
deleteClient
(ck *Clerk)
src/shardkv/config.go:144
Method
disconnect
(i int, from []int)
src/shardctrler/config.go:124
Method
disconnect
(i int, from []int)
src/kvraft/config.go:151
Method
dispatch
(methname string, req reqMsg)
src/labrpc/labrpc.go:478
Method
get
(pos uint)
src/porcupine/bitset.go:41
Function
ihash
use ihash(key) % NReduce to choose the reduce task number for each KeyValue emitted by Map.
src/mr/worker.go:21
Method
killed
()
src/kvraft/server.go:65
Function
main
()
src/main/viewd.go:12
Function
main
()
src/main/pbc.go:31
Function
main
()
src/main/mrcoordinator.go:17
Function
main
()
src/main/lockd.go:19
Function
main
()
src/main/diskvd.go:30
Function
main
()
src/main/lockc.go:16
Function
main
()
src/main/pbd.go:12
Function
main
()
src/main/mrsequential.go:25
Function
main
()
src/main/mrworker.go:19
Method
make_partition
Partition servers into 2 groups and put current leader in minority
src/shardctrler/config.go:315
Function
nrand
()
src/shardctrler/client.go:17
Function
nrand
()
src/kvraft/client.go:13
Function
nrand
()
src/shardkv/client.go:31
Method
partition
Sets up 2 partitions with connectivity between servers in each partition.
src/shardctrler/config.go:147
Method
persist
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
Function
random_handles
Randomize server handles
src/shardkv/config.go:35
Method
sendRequestVote
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
← previous
301–379 of 379, ranked by callers