helper function that sends information about all existing and newly registered workers to channel ch. schedule() reads ch to learn about workers.

killWorkers cleans up all workers by sending each one a Shutdown RPC. It also collects and returns the number of tasks each worker has performed.

Partition servers into 2 groups and put current leader in minority

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

merge combines the results of the many reduce jobs into a single output file XXX use merge sort

data layout: bits 0-63 are in data[0], the next are in data[1], etc.

Randomize server handles

Randomize server handles

restore previously persisted state.

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.

Tell the master we exist and ready to work

a client runs the function f and then signals it is done

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 *

startRPCServer starts the Master's RPC server. It continues accepting RPC calls (Register in particular) for as long as the worker is alive.

stopRPCServer stops the master RPC server. This must be done through an RPC to avoid race conditions between the RPC server thread and the current thr

DoTask is called by the master when a new task is being scheduled on this worker.

get a server's count of incoming RPCs.

args is a pointer

args is a not pointer

Maximum log size across all servers

Create input file with N numbers Check if we have N numbers in output file Split in words

Just return key

example RequestVote RPC handler.

Shutdown is an RPC method that shuts down the Master's RPC server.

Shutdown is called by the master when all work has been completed. We should respond with the number of tasks we have processed.

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