diff --git a/src/coio.cc b/src/coio.cc index c5bdf4b2541bd4c40f672994081ff3c1fb1a285c..245376285ebbc7d79b4d2894f26956da8577c03f 100644 --- a/src/coio.cc +++ b/src/coio.cc @@ -525,6 +525,8 @@ coio_sendto_timeout(struct ev_io *coio, const void *buf, size_t sz, int flags, flags, dest_addr, addrlen); if (nwr > 0) return nwr; + if (nwr < 0 && ! sio_wouldblock(errno)) + diag_raise(); if (! ev_is_active(coio)) { ev_io_set(coio, coio->fd, EV_WRITE); ev_io_start(loop(), coio); @@ -568,7 +570,8 @@ coio_recvfrom_timeout(struct ev_io *coio, void *buf, size_t sz, int flags, src_addr, &addrlen); if (nrd >= 0) return nrd; - + if (! sio_wouldblock(errno)) + diag_raise(); if (! ev_is_active(coio)) { ev_io_set(coio, coio->fd, EV_READ); ev_io_start(loop(), coio); diff --git a/src/sio.cc b/src/sio.cc index 0c874404ec4bc73919268029afa22deee8d198a2..e1ad1c12988fb4d4826ba740ca5986e9a7f71267 100644 --- a/src/sio.cc +++ b/src/sio.cc @@ -265,7 +265,7 @@ sio_sendto(int fd, const void *buf, size_t len, int flags, ssize_t n = sendto(fd, buf, len, flags, (struct sockaddr*)dest_addr, addrlen); if (n < 0 && !sio_wouldblock(errno)) - tnt_raise(SocketError, sio_socketname(fd), "sendto(%zd)", len); + diag_set(SocketError, sio_socketname(fd), "sendto(%zd)", len); return n; } @@ -276,7 +276,7 @@ sio_recvfrom(int fd, void *buf, size_t len, int flags, ssize_t n = recvfrom(fd, buf, len, flags, (struct sockaddr*)src_addr, addrlen); if (n < 0 && !sio_wouldblock(errno)) - tnt_raise(SocketError, sio_socketname(fd), "recvfrom(%zd)", len); + diag_set(SocketError, sio_socketname(fd), "recvfrom(%zd)", len); return n; }