check return values and try to re-write again if necessary.
it was already done in other functions in the code.
Signed-off-by: Doron Shoham <dorons@xxxxxxxxxxxx>
---
usr/bs.c | 18 ++++++++++++++++--
1 files changed, 16 insertions(+), 2 deletions(-)
diff --git a/usr/bs.c b/usr/bs.c
index f100e2c..71b7767 100644
--- a/usr/bs.c
+++ b/usr/bs.c
@@ -125,7 +125,15 @@ static void bs_thread_request_done(int fd, int events, void *data)
cmd->scsi_cmd_done(cmd, scsi_get_result(cmd));
}
- write(info->command_fd[1], &nr_events, sizeof(nr_events));
+rewrite:
+ ret = write(info->command_fd[1], &nr_events, sizeof(nr_events));
+ if (ret < 0) {
+ eprintf("can't write done, %m\n");
+ if (errno == EAGAIN || errno == EINTR)
+ goto rewrite;
+
+ return;
+ }
}
static void *bs_thread_worker_fn(void *arg)
@@ -202,7 +210,13 @@ int bs_thread_open(struct bs_thread_info *info, request_func_t *rfn)
bs_thread_worker_fn, info);
}
- write(info->command_fd[1], &ret, sizeof(ret));
+rewrite:
+ ret = write(info->command_fd[1], &ret, sizeof(ret));
+ if (ret < 0) {
+ eprintf("can't write done, %m\n");
+ if (errno == EAGAIN || errno == EINTR)
+ goto rewrite;
+ }
return 0;
event_del:
--
1.5.3.8
--
To unsubscribe from this list: send the line "unsubscribe stgt" in
the body of a message to majordomo@xxxxxxxxxxxxxxx
More majordomo info at http://vger.kernel.org/majordomo-info.html
