diff options
| -rw-r--r-- | PROTOCOL | 15 |
1 files changed, 13 insertions, 2 deletions
@@ -49,11 +49,22 @@ The coordinators also send all known workers to the master as a list: Coordinator operations: ----------------------- +The master can start and stop workers: + { "op": "start", "rule": "master", "worker": "worker1" } { "op": "stop", "rule": "master", "worker": "worker1" } -{ "op": "kill", "rule": "master", "worker": "worker1" } The master sends this as survey call to all coordinators, the coordinator who feels responsible for this working with start/stop/kill the worker -with the given name. +with the given name. Then it sends back an ack message to the master: + +{ "op": "stopped", "role": "coordinator", "host": "eeepc", "worker": "worker1", "found": true } + +Worker messages: +---------------- + +Workers send their output and states to the master via a data channel +(PIPELINE): + +{ "op": "output", "role": "worker", "worker": "worker1", "msg": "Msg 30\n", "stdout": false } |