MCPcopy Create free account
hub / github.com/BWbwchen/MapReduce / newWorker

Function newWorker

worker/worker.go:34–43  ·  view source on GitHub ↗
(nReduce int, inRAM bool)

Source from the content-addressed store, hash-verified

32}
33
34func newWorker(nReduce int, inRAM bool) rpc.WorkerServer {
35 return &Worker{
36 UUID: uuid.New().String(),
37 nReduce: nReduce,
38 Chan: newMrContext(),
39 EndChan: make(chan bool),
40 storeInRAM: inRAM,
41 State: rpc.WorkerState_IDLE,
42 }
43}
44
45// gRPC functions
46

Callers 1

StartWorkerFunction · 0.70

Calls 2

newMrContextFunction · 0.85
StringMethod · 0.45

Tested by

no test coverage detected