(nReduce int, inRAM bool)
| 32 | } |
| 33 | |
| 34 | func 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 |
no test coverage detected