|dc_buffered_stream_receive (distributed_control *dc)|
|void||incoming_data (procid_t src, const char *buf, size_t len)|
|void||function_call_completed (unsigned char packettype)|
Receiver processor for the dc class. The job of the receiver is to take as input a byte stream (as received from the socket) and cut it up into meaningful chunks. This can be thought of as a receiving end of a multiplexor. This receiver performs buffered receives. That is, the incoming data is placed in a buffer, which is then processed by a parsing thread, before passing off to the actual function call handlers.
This implements a buffered receiver and can be enabled by passing "buffered_recv=yes" in the distributed control initstring.
|void graphlab::dc_impl::dc_buffered_stream_receive::function_call_completed||(||unsigned char||packettype||)||
called by the controller when a function call is completed
|const char *||buf,|
Called by the controller when there is data coming from the source