tube_read_msg
while(tube_read_msg(ctx->rr_pipe, &msg, &len, 0)) {
r = tube_read_msg(ctx->rr_pipe, &msg, &len, 1);
r = tube_read_msg(ctx->rr_pipe, &msg, &len, 1);
if(tube_read_msg(tube, &buf, &len, 1)) {
int tube_read_msg(struct tube* tube, uint8_t** buf, uint32_t* len,
if(!tube_read_msg(worker->cmd, &msg, &len, 0)) {
if(!tube_read_msg(worker->cmd, &reply, &len, 0))
if(!tube_read_msg(worker->cmd, &buf, &len, 0)) {
while(tube_read_msg(ctx->rr_pipe, &msg, &len, 0)) {
r = tube_read_msg(ctx->rr_pipe, &msg, &len, 1);
r = tube_read_msg(ctx->rr_pipe, &msg, &len, 1);
if(tube_read_msg(tube, &buf, &len, 1)) {
int tube_read_msg(struct tube* tube, uint8_t** buf, uint32_t* len,