Changeset [96ce48f3eb3287f97e02ea29d8ef5c82124da11c] by Shayan Pooya
May 28th, 2014 @ 07:32 AM
disco_worker: use the update function instead of directly sending inputs to the worker.
When the worker_runtime decides that it should not respond to an
input message
immediately, the disco_worker can avoid consuming that INPUT
message from the
worker and keep it pending.
That means, when the input is ready, disco_worker can just call
the update
functio. The INPUT message is going to be consumed but this time,
there are
some inputs available which will bee sent to the worker.
https://github.com/discoproject/disco/commit/96ce48f3eb3287f97e02ea...
Committed by Shayan Pooya
- M master/src/disco_worker.erl
Create new ticket
Create your profile
Help contribute to this project by taking a few moments to create your personal profile. Create your profile ยป
Disco is an open-source implementation of the Map-Reduce framework for distributed computing. As the original framework, Disco supports parallel computations over large data sets on unreliable cluster of computers.