Code
Hub
Workspaces
Following
Trending
Connect
MCP
copy
Create free account
hub
/
github.com/CNYuYang/DistributedSystems
/ functions
Functions
23 in github.com/CNYuYang/DistributedSystems
⨍
Functions
23
◇
Types & classes
7
↓ 3 callers
Function
AskTask
(AskType int, Id int)
Lab1-MapReduce/实现代码/worker.go:151
↓ 2 callers
Function
call
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 callers
Function
masterSock
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 callers
Function
DoingMap
(taskId int, nReduce int, fileName string, mapf func(string, string) []KeyValue)
Lab1-MapReduce/实现代码/worker.go:114
↓ 1 callers
Function
DoingReduce
(taskId int, nMap int, reducef func(string, []string) string)
Lab1-MapReduce/实现代码/worker.go:72
↓ 1 callers
Method
filshMap
(id int)
Lab1-MapReduce/实现代码/master.go:61
↓ 1 callers
Method
filshReduce
(id int)
Lab1-MapReduce/实现代码/master.go:75
↓ 1 callers
Method
getMapTask
()
Lab1-MapReduce/实现代码/master.go:88
↓ 1 callers
Method
getReduceTask
()
Lab1-MapReduce/实现代码/master.go:119
↓ 1 callers
Function
ihash
use ihash(key) % NReduce to choose the reduce task number for each KeyValue emitted by Map.
Lab1-MapReduce/实现代码/worker.go:35
↓ 1 callers
Method
mapTask
(task *Task)
Lab1-MapReduce/实现代码/master.go:99
↓ 1 callers
Method
reduceTask
(task *Task)
Lab1-MapReduce/实现代码/master.go:130
↓ 1 callers
Function
removeIntermediaFiles
()
Lab1-MapReduce/实现代码/master.go:188
↓ 1 callers
Method
server
start a thread that listens for RPCs from worker.go
Lab1-MapReduce/实现代码/master.go:161
Function
CallExample
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
Method
Done
main/mrmaster.go calls Done() periodically to find out if the entire job has finished.
Lab1-MapReduce/实现代码/master.go:178
Method
Example
an example RPC handler. the RPC argument and reply types are defined in rpc.go.
Lab1-MapReduce/实现代码/master.go:153
Method
Len
for sorting by key.
Lab1-MapReduce/实现代码/worker.go:27
Method
Less
(i, j int)
Lab1-MapReduce/实现代码/worker.go:29
Function
MakeMaster
create a Master. main/mrmaster.go calls this function. nReduce is the number of reduce tasks to use.
Lab1-MapReduce/实现代码/master.go:200
Method
OrderTask
Your code here -- RPC handlers for the worker to call.
Lab1-MapReduce/实现代码/master.go:37
Method
Swap
(i, j int)
Lab1-MapReduce/实现代码/worker.go:28
Function
Worker
main/mrworker.go calls this function.
Lab1-MapReduce/实现代码/worker.go:44