Code
Hub
Workspaces
Following
Trending
Connect
MCP
copy
Create free account
hub
/
github.com/1345414527/MIT6.824-2022
/ functions
Functions
474 in github.com/1345414527/MIT6.824-2022
⨍
Functions
474
◇
Types & classes
105
Function
TestPersist22C
(t *testing.T)
raft/test_test.go:737
Function
TestPersist32C
(t *testing.T)
raft/test_test.go:783
Function
TestPersistConcurrent3A
(t *testing.T)
kvraft/test_test.go:570
Function
TestPersistConcurrentUnreliable3A
(t *testing.T)
kvraft/test_test.go:575
Function
TestPersistOneClient3A
(t *testing.T)
kvraft/test_test.go:565
Function
TestPersistPartition3A
(t *testing.T)
kvraft/test_test.go:580
Function
TestPersistPartitionUnreliable3A
(t *testing.T)
kvraft/test_test.go:585
Function
TestPersistPartitionUnreliableLinearizable3A
(t *testing.T)
kvraft/test_test.go:590
Function
TestRPCBytes2B
check, based on counting bytes of RPCs, that each command is sent to each peer just once.
raft/test_test.go:161
Function
TestReElection2A
TestReElection测试在上一个测试的基础上,检查发生leader离线情况的行为。 先等待集群产生一个leader,然后让这个leader离线,检查集群能否再产生一个leader。 若能,令原来的leader上线,检查leader不应该发生变化,因为后来的leader的term大于原来的le
raft/test_test.go:59
Function
TestRegression1
regression: an RPC that's delayed during Enabled=false should not delay subsequent RPCs (e.g. after Enabled=true).
labrpc/test_test.go:448
Function
TestRejoin2B
(t *testing.T)
raft/test_test.go:471
Function
TestReliableChurn2C
(t *testing.T)
raft/test_test.go:1108
Function
TestSnapshot
(t *testing.T)
shardkv/test_test.go:153
Function
TestSnapshotAllCrash2D
do the servers persist the snapshots, and restart using snapshot along with the tail of the log?
raft/test_test.go:1208
Function
TestSnapshotBasic2D
(t *testing.T)
raft/test_test.go:1182
Function
TestSnapshotInstall2D
(t *testing.T)
raft/test_test.go:1186
Function
TestSnapshotInstallCrash2D
(t *testing.T)
raft/test_test.go:1195
Function
TestSnapshotInstallUnCrash2D
(t *testing.T)
raft/test_test.go:1199
Function
TestSnapshotInstallUnreliable2D
(t *testing.T)
raft/test_test.go:1190
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
kvraft/test_test.go:601
Function
TestSnapshotRecover3B
(t *testing.T)
kvraft/test_test.go:696
Function
TestSnapshotRecoverManyClients3B
(t *testing.T)
kvraft/test_test.go:701
Function
TestSnapshotSize3B
are the snapshots not too huge? 500 bytes is a generous bound for the operations we're doing here.
kvraft/test_test.go:659
Function
TestSnapshotUnreliable3B
(t *testing.T)
kvraft/test_test.go:706
Function
TestSnapshotUnreliableRecover3B
(t *testing.T)
kvraft/test_test.go:711
Function
TestSnapshotUnreliableRecoverConcurrentPartition3B
(t *testing.T)
kvraft/test_test.go:716
Function
TestSnapshotUnreliableRecoverConcurrentPartitionLinearizable3B
(t *testing.T)
kvraft/test_test.go:721
Function
TestSpeed3A
(t *testing.T)
kvraft/test_test.go:431
Function
TestSpeed3B
(t *testing.T)
kvraft/test_test.go:692
Function
TestStaticShards
test static 2-way sharding, without shard movement.
shardkv/test_test.go:28
Function
TestTypes
(t *testing.T)
labrpc/test_test.go:104
Function
TestUnreliable
test unreliable
labrpc/test_test.go:333
Function
TestUnreliable1
(t *testing.T)
shardkv/test_test.go:530
Function
TestUnreliable2
(t *testing.T)
shardkv/test_test.go:572
Function
TestUnreliable3
(t *testing.T)
shardkv/test_test.go:635
Function
TestUnreliable3A
(t *testing.T)
kvraft/test_test.go:440
Function
TestUnreliableAgree2C
(t *testing.T)
raft/test_test.go:879
Function
TestUnreliableChurn2C
(t *testing.T)
raft/test_test.go:1112
Function
TestUnreliableOneKey3A
(t *testing.T)
kvraft/test_test.go:445
Function
VisualizePath
(model Model, info linearizationInfo, path string)
porcupine/visualization.go:102
Method
applier
applier reads message from apply ch and checks that they match the log contents
raft/config.go:165
Method
applierSnap
periodically snapshot raft state
raft/config.go:216
Method
connect
(i int, to []int)
shardctrler/config.go:96
Method
connect
(i int, to []int)
kvraft/config.go:123
Method
copy
()
shardkv/common.go:57
Method
copy
()
shardkv/common.go:82
Method
deleteClient
(ck *Clerk)
shardctrler/config.go:184
Method
deleteClient
(ck *Clerk)
shardkv/config.go:144
Method
disconnect
(i int, from []int)
shardctrler/config.go:124
Method
disconnect
(i int, from []int)
kvraft/config.go:151
Method
dispatch
(methname string, req reqMsg)
labrpc/labrpc.go:483
Method
get
(pos uint)
porcupine/bitset.go:41
Function
init
必须注册才能进行解码和编码
shardctrler/common.go:38
Function
init
()
shardctrler/util.go:16
Function
init
()
mr/common.go:16
Function
init
()
kvraft/util.go:16
Function
init
as each Raft peer becomes aware that successive log entries are committed, the peer should send an ApplyMsg to the service (or tester) on the same se
raft/raft.go:46
Function
init
()
raft/util.go:16
Function
init
主要是applyCh的处理中,ApplyMsg的Command是一个interface,因此要向labgob注册具体实现才能进行编解码
shardkv/common.go:27
Function
init
()
shardkv/util.go:16
Method
killed
()
kvraft/server.go:184
Function
main
()
main/viewd.go:12
Function
main
()
main/pbc.go:31
Function
main
()
main/mrcoordinator.go:17
Function
main
()
main/lockd.go:19
Function
main
()
main/diskvd.go:30
Function
main
()
main/lockc.go:16
Function
main
()
main/pbd.go:12
Function
main
()
main/mrsequential.go:25
Function
main
()
main/mrworker.go:19
Method
make_partition
Partition servers into 2 groups and put current leader in minority
shardctrler/config.go:315
Method
partition
Sets up 2 partitions with connectivity between servers in each partition.
shardctrler/config.go:147
Function
random_handles
Randomize server handles
shardkv/config.go:35
← previous
401–474 of 474, ranked by callers