|
|
@ -8996,17 +8996,17 @@ mdb_env_copythr(void *arg) |
|
|
|
#define DO_WRITE(rc, fd, ptr, w2, len) rc = WriteFile(fd, ptr, w2, &len, NULL) |
|
|
|
#define DO_WRITE(rc, fd, ptr, w2, len) rc = WriteFile(fd, ptr, w2, &len, NULL) |
|
|
|
#else |
|
|
|
#else |
|
|
|
int len; |
|
|
|
int len; |
|
|
|
sigset_t set; |
|
|
|
|
|
|
|
#define DO_WRITE(rc, fd, ptr, w2, len) len = write(fd, ptr, w2); rc = (len >= 0) |
|
|
|
#define DO_WRITE(rc, fd, ptr, w2, len) len = write(fd, ptr, w2); rc = (len >= 0) |
|
|
|
|
|
|
|
#ifdef SIGPIPE |
|
|
|
|
|
|
|
sigset_t set; |
|
|
|
sigemptyset(&set); |
|
|
|
sigemptyset(&set); |
|
|
|
sigaddset(&set, SIGPIPE); |
|
|
|
sigaddset(&set, SIGPIPE); |
|
|
|
|
|
|
|
if ((rc = pthread_sigmask(SIG_BLOCK, &set, NULL)) != 0) |
|
|
|
|
|
|
|
my->mc_error = rc; |
|
|
|
|
|
|
|
#endif |
|
|
|
#endif |
|
|
|
#endif |
|
|
|
|
|
|
|
|
|
|
|
pthread_mutex_lock(&my->mc_mutex); |
|
|
|
pthread_mutex_lock(&my->mc_mutex); |
|
|
|
#ifndef _WIN32 |
|
|
|
|
|
|
|
my->mc_error = pthread_sigmask(SIG_BLOCK, &set, NULL); |
|
|
|
|
|
|
|
#endif |
|
|
|
|
|
|
|
for(;;) { |
|
|
|
for(;;) { |
|
|
|
while (!my->mc_new) |
|
|
|
while (!my->mc_new) |
|
|
|
pthread_cond_wait(&my->mc_cond, &my->mc_mutex); |
|
|
|
pthread_cond_wait(&my->mc_cond, &my->mc_mutex); |
|
|
@ -9020,8 +9020,11 @@ again: |
|
|
|
DO_WRITE(rc, my->mc_fd, ptr, wsize, len); |
|
|
|
DO_WRITE(rc, my->mc_fd, ptr, wsize, len); |
|
|
|
if (!rc) { |
|
|
|
if (!rc) { |
|
|
|
rc = ErrCode(); |
|
|
|
rc = ErrCode(); |
|
|
|
#ifndef _WIN32 |
|
|
|
#if defined(SIGPIPE) && !defined(_WIN32) |
|
|
|
if (rc == EPIPE) { |
|
|
|
if (rc == EPIPE) { |
|
|
|
|
|
|
|
/* Collect the pending SIGPIPE, otherwise at least OS X
|
|
|
|
|
|
|
|
* gives it to the process on thread-exit (ITS#8504). |
|
|
|
|
|
|
|
*/ |
|
|
|
int tmp; |
|
|
|
int tmp; |
|
|
|
sigwait(&set, &tmp); |
|
|
|
sigwait(&set, &tmp); |
|
|
|
} |
|
|
|
} |
|
|
|