+ ssize_t ret;
+
+ while(1) {
+ ret = read(d->fd, buf, len);
+ if((ret < 0) && (errno == EAGAIN)) {
+ ev = block(d->fd, EV_READ, d->timeout);
+ if(ev < 0) {
+ /* If we just go on, we should get the real error. */
+ continue;
+ } else if(ev == 0) {
+ errno = ETIMEDOUT;
+ return(-1);
+ } else {
+ continue;
+ }
+ } else {
+ return(ret);
+ }
+ }
+}
+
+static ssize_t mtwrite(void *cookie, const void *buf, size_t len)
+{
+ struct stdiofd *d = cookie;
+ int ev;
+ ssize_t ret;
+
+ while(1) {
+ if(d->sock)
+ ret = send(d->fd, buf, len, MSG_DONTWAIT | MSG_NOSIGNAL);
+ else
+ ret = write(d->fd, buf, len);
+ if((ret < 0) && (errno == EAGAIN)) {
+ ev = block(d->fd, EV_WRITE, d->timeout);
+ if(ev < 0) {
+ /* If we just go on, we should get the real error. */
+ continue;
+ } else if(ev == 0) {
+ errno = ETIMEDOUT;
+ return(-1);
+ }
+ } else {
+ return(ret);
+ }
+ }
+}