sin/samba-mirror
1
0
Fork 0
mirror of https://github.com/samba-team/samba.git synced 2025-02-03 13:47:25 +03:00
Code

Handle EINTR in async_sock.c

Browse Source
This commit is contained in:
Volker Lendecke 2009-05-30 09:49:17 +02:00
parent df167ee771
commit 625851a50f
1 changed files with 16 additions and 0 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

16
lib/async_req/async_sock.c
View File

@ -81,6 +81,10 @@ static void async_send_handler(struct tevent_context *ev,
tevent_req_data(req, struct async_send_state); tevent_req_data(req, struct async_send_state);
state->sent = send(state->fd, state->buf, state->len, state->flags); state->sent = send(state->fd, state->buf, state->len, state->flags);
if ((state->sent == -1) && (errno == EINTR)) {
/* retry */
return;
}
if (state->sent == -1) { if (state->sent == -1) {
tevent_req_error(req, errno); tevent_req_error(req, errno);
return; return;
@ -148,6 +152,10 @@ static void async_recv_handler(struct tevent_context *ev,
state->received = recv(state->fd, state->buf, state->len, state->received = recv(state->fd, state->buf, state->len,
state->flags); state->flags);
if ((state->received == -1) && (errno == EINTR)) {
/* retry */
return;
}
if (state->received == -1) { if (state->received == -1) {
tevent_req_error(req, errno); tevent_req_error(req, errno);
return; return;
@ -427,6 +435,10 @@ static void writev_handler(struct tevent_context *ev, struct tevent_fd *fde,
} }
written = writev(state->fd, state->iov, state->count); written = writev(state->fd, state->iov, state->count);
if ((written == -1) && (errno = EINTR)) {
/* retry */
return;
}
if (written == -1) { if (written == -1) {
tevent_req_error(req, errno); tevent_req_error(req, errno);
return; return;
@ -534,6 +546,10 @@ static void read_packet_handler(struct tevent_context *ev,
nread = recv(state->fd, state->buf+state->nread, total-state->nread, nread = recv(state->fd, state->buf+state->nread, total-state->nread,
0); 0);
if ((nread == -1) && (errno == EINTR)) {
/* retry */
return;
}
if (nread == -1) { if (nread == -1) {
tevent_req_error(req, errno); tevent_req_error(req, errno);
return; return;