ISAR/libmdbx
3
0
Fork 0
mirror of https://github.com/isar/libmdbx.git synced 2025-01-02 00:34:13 +08:00
Code Issues Packages Projects Releases Wiki Activity

mdbx: drop EPIPE/SIGPIPE handling (since pipes are disallowed).

Browse Source 
Change-Id: I56d4539333edea93cc1a2c3606cf959c82b98b19
This commit is contained in:
Leonid Yuriev 2019-06-29 15:24:01 +03:00
parent 38110579ba
commit 2e60256978
1 changed files with 0 additions and 25 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

25
src/mdbx.c
View File

@ -11283,23 +11283,6 @@ static THREAD_RESULT __cold THREAD_CALL mdbx_env_copythr(void *arg) {
int rc;
size_t offset = pgno2bytes(my->mc_env, NUM_METAS);
#if defined(F_SETNOSIGPIPE)
/* OS X delivers SIGPIPE to the whole process, not the thread that caused it.
* Disable SIGPIPE using platform specific fcntl. */
int enabled = 1;
if (fcntl(my->mc_fd, F_SETNOSIGPIPE, &enabled))
my->mc_error = errno;
#endif
#if defined(SIGPIPE) && !defined(_WIN32) && !defined(_WIN64)
sigset_t set;
sigemptyset(&set);
sigaddset(&set, SIGPIPE);
rc = pthread_sigmask(SIG_BLOCK, &set, NULL);
if (rc != 0)
my->mc_error = rc;
#endif
mdbx_condmutex_lock(&my->mc_condmutex);
while (!my->mc_error) {
while (!my->mc_new)
@ -11312,14 +11295,6 @@ static THREAD_RESULT __cold THREAD_CALL mdbx_env_copythr(void *arg) {
if (wsize > 0 && !my->mc_error) {
rc = mdbx_pwrite(my->mc_fd, ptr, wsize, offset);
if (rc != MDBX_SUCCESS) {
#if defined(SIGPIPE) && !defined(_WIN32) && !defined(_WIN64)
if (rc == EPIPE) {
/* Collect the pending SIGPIPE, otherwise (at least OS X)
* gives it to the process on thread-exit (ITS#8504). */
int tmp;
sigwait(&set, &tmp);
}
#endif
my->mc_error = rc;
break;
}