Code
Hub
Workspaces
Following
Trending
Connect
MCP
copy
Create free account
hub
/
github.com/WenbinZhu/mit-6.824-labs
/ functions
Functions
386 in github.com/WenbinZhu/mit-6.824-labs
⨍
Functions
386
◇
Types & classes
90
Function
TestCapital
make sure we check capitalization labgob prints one warning during this test.
src/labgob/test_test.go:119
Function
TestChallenge1Concurrent
(t *testing.T)
src/shardkv/test_test.go:744
Function
TestChallenge1Delete
optional test to see whether servers are deleting shards for which they are no longer responsible.
src/shardkv/test_test.go:663
Function
TestChallenge2Partial
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:887
Function
TestChallenge2Unaffected
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:817
Function
TestConcurrent1
(t *testing.T)
src/shardkv/test_test.go:297
Function
TestConcurrent2
this tests the various sources from which a re-starting group might need to fetch shard contents.
src/shardkv/test_test.go:378
Function
TestConcurrent3A
(t *testing.T)
src/kvraft/test_test.go:453
Function
TestConcurrentMany
test RPCs from concurrent ClientEnds
src/labrpc/test_test.go:275
Function
TestConcurrentOne
test concurrent RPCs from a single ClientEnd
src/labrpc/test_test.go:386
Function
TestConcurrentStarts2B
(t *testing.T)
src/raft/test_test.go:232
Function
TestCount2B
(t *testing.T)
src/raft/test_test.go:443
Function
TestCounts
test net.GetCount()
src/labrpc/test_test.go:185
Function
TestDefault
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
Function
TestDisconnect
does net.Enable(endname, false) really disconnect a client?
src/labrpc/test_test.go:146
Function
TestFailAgree2B
(t *testing.T)
src/raft/test_test.go:147
Function
TestFailNoAgree2B
(t *testing.T)
src/raft/test_test.go:181
Function
TestFigure82C
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:685
Function
TestFigure8Unreliable2C
(t *testing.T)
src/raft/test_test.go:770
Function
TestGOB
test that we didn't break GOB.
src/labgob/test_test.go:27
Function
TestInitialElection2A
(t *testing.T)
src/raft/test_test.go:22
Function
TestJoinLeave
(t *testing.T)
src/shardkv/test_test.go:90
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
TestManyPartitionsManyClients3A
(t *testing.T)
src/kvraft/test_test.go:578
Function
TestManyPartitionsOneClient3A
(t *testing.T)
src/kvraft/test_test.go:573
Function
TestMissChange
(t *testing.T)
src/shardkv/test_test.go:211
Function
TestMulti
(t *testing.T)
src/shardmaster/test_test.go:252
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:498
Function
TestPersist12C
(t *testing.T)
src/raft/test_test.go:553
Function
TestPersist22C
(t *testing.T)
src/raft/test_test.go:599
Function
TestPersist32C
(t *testing.T)
src/raft/test_test.go:645
Function
TestPersistConcurrent3A
(t *testing.T)
src/kvraft/test_test.go:588
Function
TestPersistConcurrentUnreliable3A
(t *testing.T)
src/kvraft/test_test.go:593
Function
TestPersistOneClient3A
(t *testing.T)
src/kvraft/test_test.go:583
Function
TestPersistPartition3A
(t *testing.T)
src/kvraft/test_test.go:598
Function
TestPersistPartitionUnreliable3A
(t *testing.T)
src/kvraft/test_test.go:603
Function
TestPersistPartitionUnreliableLinearizable3A
(t *testing.T)
src/kvraft/test_test.go:608
Function
TestRPCBytes2B
check, based on counting bytes of RPCs, that each command is sent to each peer just once.
src/raft/test_test.go:116
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:333
Function
TestReliableChurn2C
(t *testing.T)
src/raft/test_test.go:970
Function
TestSnapshot
(t *testing.T)
src/shardkv/test_test.go:143
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:619
Function
TestSnapshotRecover3B
(t *testing.T)
src/kvraft/test_test.go:709
Function
TestSnapshotRecoverManyClients3B
(t *testing.T)
src/kvraft/test_test.go:714
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:676
Function
TestSnapshotUnreliable3B
(t *testing.T)
src/kvraft/test_test.go:719
Function
TestSnapshotUnreliableRecover3B
(t *testing.T)
src/kvraft/test_test.go:724
Function
TestSnapshotUnreliableRecoverConcurrentPartition3B
(t *testing.T)
src/kvraft/test_test.go:729
Function
TestSnapshotUnreliableRecoverConcurrentPartitionLinearizable3B
(t *testing.T)
src/kvraft/test_test.go:734
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:449
Function
TestUnreliable2
(t *testing.T)
src/shardkv/test_test.go:491
Function
TestUnreliable3
(t *testing.T)
src/shardkv/test_test.go:554
Function
TestUnreliable3A
(t *testing.T)
src/kvraft/test_test.go:458
Function
TestUnreliableAgree2C
(t *testing.T)
src/raft/test_test.go:741
Function
TestUnreliableChurn2C
(t *testing.T)
src/raft/test_test.go:974
Function
TestUnreliableOneKey3A
(t *testing.T)
src/kvraft/test_test.go:463
Function
VisualizePath
(model Model, info linearizationInfo, path string)
src/porcupine/visualization.go:96
Function
Worker
main/mrworker.go calls this function.
src/mr/worker.go:42
Method
connect
(i int, to []int)
src/shardmaster/config.go:96
Method
connect
(i int, to []int)
src/kvraft/config.go:123
Method
deleteClient
(ck *Clerk)
src/shardmaster/config.go:184
Method
deleteClient
(ck *Clerk)
src/shardkv/config.go:141
Method
disconnect
(i int, from []int)
src/shardmaster/config.go:124
Method
disconnect
(i int, from []int)
src/kvraft/config.go:151
Method
dispatch
(methname string, req reqMsg)
src/labrpc/labrpc.go:476
Method
get
(pos uint)
src/porcupine/bitset.go:41
Method
killed
()
src/kvraft/server.go:195
Function
main
()
src/main/viewd.go:12
Function
main
()
src/main/pbc.go:31
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/mrmaster.go:17
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/shardmaster/config.go:313
Function
nrand
()
src/shardmaster/client.go:17
Function
nrand
()
src/shardkv/client.go:31
Method
partition
Sets up 2 partitions with connectivity between servers in each partition.
src/shardmaster/config.go:147
Function
random_handles
Randomize server handles
src/shardkv/config.go:35
← previous
301–386 of 386, ranked by callers