|
Lines 463-468
_client_write(eio_obj_t *obj, List objs)
Link Here
|
| 463 |
buf = client->out_msg->data + |
463 |
buf = client->out_msg->data + |
| 464 |
(client->out_msg->length - client->out_remaining); |
464 |
(client->out_msg->length - client->out_remaining); |
| 465 |
again: |
465 |
again: |
|
|
466 |
usleep(10000); |
| 466 |
if ((n = write(obj->fd, buf, client->out_remaining)) < 0) { |
467 |
if ((n = write(obj->fd, buf, client->out_remaining)) < 0) { |
| 467 |
if (errno == EINTR) { |
468 |
if (errno == EINTR) { |
| 468 |
goto again; |
469 |
goto again; |
|
Lines 557-563
_local_file_write(eio_obj_t *obj, List objs)
Link Here
|
| 557 |
/* Write the message to the file. */ |
558 |
/* Write the message to the file. */ |
| 558 |
buf = client->out_msg->data + |
559 |
buf = client->out_msg->data + |
| 559 |
(client->out_msg->length - client->out_remaining); |
560 |
(client->out_msg->length - client->out_remaining); |
| 560 |
|
561 |
usleep(10000); |
| 561 |
n = write_labelled_message(obj->fd, buf, client->out_remaining, |
562 |
n = write_labelled_message(obj->fd, buf, client->out_remaining, |
| 562 |
header.gtaskid, client->labelio, |
563 |
header.gtaskid, client->labelio, |
| 563 |
client->label_width); |
564 |
client->label_width); |
|
Lines 671-676
_task_write(eio_obj_t *obj, List objs)
Link Here
|
| 671 |
*/ |
672 |
*/ |
| 672 |
buf = in->msg->data + (in->msg->length - in->remaining); |
673 |
buf = in->msg->data + (in->msg->length - in->remaining); |
| 673 |
again: |
674 |
again: |
|
|
675 |
usleep(10000); |
| 674 |
if ((n = write(obj->fd, buf, in->remaining)) < 0) { |
676 |
if ((n = write(obj->fd, buf, in->remaining)) < 0) { |
| 675 |
if (errno == EINTR) |
677 |
if (errno == EINTR) |
| 676 |
goto again; |
678 |
goto again; |
