|
||
---|---|---|
kvraft | ||
kvsrv | ||
labgob | ||
labrpc | ||
main | ||
models | ||
mr | ||
mrapps | ||
porcupine | ||
raft | ||
shardctrler | ||
shardkv | ||
.README.md.un~ | ||
.gitignore | ||
README.md | ||
README.md~ | ||
go.mod | ||
go.sum |
README.md
修改的文件包括/mr下的三个文件
coordinator.go
用于协调worker的工作worker.go
通过RPC向coordinator请求任务,执行Map或者Reduce任务rpc.go
定义了RPC的接口
使用方法:
运行
cd main
go run mrcoordinator.go pg-*.txt
然后在另一个窗口运行
cd main
go run mrworker.go wc.so
wc.so是用户编写生成的动态库,用于执行Map和Reduce任务
测试程序
cd main
sh test-mr.sh