MCPcopy Create free account

hub / github.com/CNYuYang/DistributedSystems / functions

Functions23 in github.com/CNYuYang/DistributedSystems

↓ 3 callersFunctionAskTask
(AskType int, Id int)
Lab1-MapReduce/实现代码/worker.go:151
↓ 2 callersFunctioncall
send an RPC request to the master, wait for the response. usually returns true. returns false if something goes wrong.
Lab1-MapReduce/实现代码/worker.go:188
↓ 2 callersFunctionmasterSock
Add your RPC definitions here. Cook up a unique-ish UNIX-domain socket name in /var/tmp, for the master. Can't use the current directory since Athena
Lab1-MapReduce/实现代码/rpc.go:62
↓ 1 callersFunctionDoingMap
(taskId int, nReduce int, fileName string, mapf func(string, string) []KeyValue)
Lab1-MapReduce/实现代码/worker.go:114
↓ 1 callersFunctionDoingReduce
(taskId int, nMap int, reducef func(string, []string) string)
Lab1-MapReduce/实现代码/worker.go:72
↓ 1 callersMethodfilshMap
(id int)
Lab1-MapReduce/实现代码/master.go:61
↓ 1 callersMethodfilshReduce
(id int)
Lab1-MapReduce/实现代码/master.go:75
↓ 1 callersMethodgetMapTask
()
Lab1-MapReduce/实现代码/master.go:88
↓ 1 callersMethodgetReduceTask
()
Lab1-MapReduce/实现代码/master.go:119
↓ 1 callersFunctionihash
use ihash(key) % NReduce to choose the reduce task number for each KeyValue emitted by Map.
Lab1-MapReduce/实现代码/worker.go:35
↓ 1 callersMethodmapTask
(task *Task)
Lab1-MapReduce/实现代码/master.go:99
↓ 1 callersMethodreduceTask
(task *Task)
Lab1-MapReduce/实现代码/master.go:130
↓ 1 callersFunctionremoveIntermediaFiles
()
Lab1-MapReduce/实现代码/master.go:188
↓ 1 callersMethodserver
start a thread that listens for RPCs from worker.go
Lab1-MapReduce/实现代码/master.go:161
FunctionCallExample
example function to show how to make an RPC call to the master. the RPC argument and reply types are defined in rpc.go.
Lab1-MapReduce/实现代码/worker.go:165
MethodDone
main/mrmaster.go calls Done() periodically to find out if the entire job has finished.
Lab1-MapReduce/实现代码/master.go:178
MethodExample
an example RPC handler. the RPC argument and reply types are defined in rpc.go.
Lab1-MapReduce/实现代码/master.go:153
MethodLen
for sorting by key.
Lab1-MapReduce/实现代码/worker.go:27
MethodLess
(i, j int)
Lab1-MapReduce/实现代码/worker.go:29
FunctionMakeMaster
create a Master. main/mrmaster.go calls this function. nReduce is the number of reduce tasks to use.
Lab1-MapReduce/实现代码/master.go:200
MethodOrderTask
Your code here -- RPC handlers for the worker to call.
Lab1-MapReduce/实现代码/master.go:37
MethodSwap
(i, j int)
Lab1-MapReduce/实现代码/worker.go:28
FunctionWorker
main/mrworker.go calls this function.
Lab1-MapReduce/实现代码/worker.go:44