timeout = 0 means no timeout if this operation times out, then a false positive is possible

timeout = 0 means no timeout if this operation times out, then a false positive is possible

timeout = 0 means no timeout if this operation times out, then a false positive is possible

请求清除shard

* RPC，针对output shard */ 请求获取shard

处理Get rpc

* Get和PutAppend RPC的处理 */

get a server's count of incoming RPCs.

Your code here -- RPC handlers for the worker to call. 处理Rpc请求：获取任务

args is a pointer

args is a not pointer

* rpc */

for sorting by key.

Maximum log size across all servers

The map function is called once for each file of input. The first argument is the name of the input file, and the second is the file's complete conte

The map function is called once for each file of input. This map function just returns 1 for each file

The mapping function is called once for each piece of the input. In this framework, the key is the name of the file that is being processed, and the v

处理Put rpc

The reduce function is called once for each key generated by the map tasks, with a list of all the values created for that key by any map task.

The reduce function is called once for each key generated by the map tasks, with a list of all the values created for that key by any map task.

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

处理Rpc请求：注册worker

处理Rpc请求：worker响应task完成情况

example RequestVote RPC handler.

test net.GetTotalBytes()

make sure we check capitalization labgob prints one warning during this test.

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

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

optional test to see whether servers can handle shards that are not affected by a config change while the config change is underway

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

test RPCs from concurrent ClientEnds

test concurrent RPCs from a single ClientEnd

test net.GetCount()

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

does net.Enable(endname, false) really disconnect a client?

test that a follower participates after disconnect and re-connect.

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

test just failure of followers.

test just failure of leaders.

test that we didn't break GOB.

TestInitialElection测试启动后Raft集群是否能够选出一个leader， 并检查在网络稳定的情况，也就是不应该发生心跳信号等待超时的情况下， 是否能保持原来的leader和term状态不变。

if an RPC is stuck in a server, and the server is killed with DeleteServer(), does the RPC get un-stuck?

TestManyElections测试是上一个测试的现实版本。每次随机令2个服务器离线，检查集群状态是否符合要求。如此重复10次。

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