fixed
This commit is contained in:
@@ -2919,8 +2919,8 @@ private:
|
|||||||
#ifdef _MSC_VER
|
#ifdef _MSC_VER
|
||||||
ret = pipe(pipes, 1024 * 1024 * 20, O_BINARY); // 20 MB
|
ret = pipe(pipes, 1024 * 1024 * 20, O_BINARY); // 20 MB
|
||||||
#else
|
#else
|
||||||
fcntl(*pipes, F_SETPIPE_SZ, 1024 * 1024 * 20);
|
|
||||||
ret = pipe(pipes) == -1;
|
ret = pipe(pipes) == -1;
|
||||||
|
fcntl(*pipes, F_SETPIPE_SZ, 1024 * 1024 * 20);
|
||||||
#endif
|
#endif
|
||||||
fd_blocked = (errno == EINTR || errno == EBUSY);
|
fd_blocked = (errno == EINTR || errno == EBUSY);
|
||||||
if (fd_blocked)
|
if (fd_blocked)
|
||||||
|
|||||||
Reference in New Issue
Block a user