1 2 3 4 5 6 7 8 9 10 11 12 13 14 15 16 17 18 19 20 21 22 23 24 25 26 27 28 29 30 31 32 33 34 35 36 37 38 39 40 41 42 43 44 45 46 47 48 49 50 51 52 53 54 55 56 57 58 59 60 61
|
/* signal-safe read and write (for BSD slow devices). writeall() also
allows partial writes */
#include "rc.h"
#include <errno.h>
#include "jbwrap.h"
#include "wait.h"
Jbwrap slowbuf;
volatile sig_atomic_t slow;
static char *safe_buf;
static size_t safe_remain;
extern void writeall(int fd, char *buf, size_t remain) {
int i;
safe_buf = buf;
safe_remain = remain;
for (i = 0; safe_remain > 0; buf += i, safe_remain -= i) {
if (sigsetjmp(slowbuf.j, 1) == 0) {
slow = TRUE;
if ((i = write(fd, safe_buf, safe_remain)) <= 0)
break; /* abort silently on errors in write() */
} else
break;
}
slow = FALSE;
sigchk();
}
extern int rc_read(int fd, char *buf, size_t n) {
ssize_t r;
if (sigsetjmp(slowbuf.j, 1) == 0) {
slow = TRUE;
r = read(fd, buf, n);
} else {
errno = EINTR;
r = -1;
}
slow = FALSE;
return r;
}
static int r = -1;
extern pid_t rc_wait(int *stat) {
if (sigsetjmp(slowbuf.j, 1) == 0) {
slow = TRUE;
r = wait(stat);
} else {
errno = EINTR;
r = -1;
}
slow = FALSE;
return r;
}
|