if (sender_status == SENDER_OFF)
return 0;
- ret = udp_init_session(sc);
- if (ret < 0)
- goto fail;
- ret = send_queued_chunks(sc->fd, sc->cq, 0);
+ ret = send_queued_chunks(sc->fd, sc->cq);
if (ret == -ERRNO_TO_PARA_ERROR(ECONNREFUSED))
ret = 0;
if (ret < 0)
ret = cq_force_enqueue(sc->cq, buf, len);
assert(ret >= 0);
}
- ret = write_nonblock(sc->fd, buf, len, 0);
+ ret = write_nonblock(sc->fd, buf, len);
if (ret == -ERRNO_TO_PARA_ERROR(ECONNREFUSED))
ret = 0;
if (ret < 0)