3609c3609,3612
< res = nxt_unit_ctx_port_recv(ctx, ctx_impl->read_port, rbuf);
---
> do {
> res = nxt_unit_ctx_port_recv(ctx, ctx_impl->read_port, rbuf);
> } while (res == NXT_UNIT_AGAIN);
>