|
@@ -3439,7 +3439,7 @@ inline ssize_t SocketStream::read(char *ptr, size_t size) {
|
|
|
}
|
|
}
|
|
|
return recv(sock_, ptr, static_cast<int>(size), 0);
|
|
return recv(sock_, ptr, static_cast<int>(size), 0);
|
|
|
#else
|
|
#else
|
|
|
- return HANDLE_EINTR(recv, sock_, ptr, size, 0);
|
|
|
|
|
|
|
+ return handle_EINTR([&]() { return recv(sock_, ptr, size, 0); });
|
|
|
#endif
|
|
#endif
|
|
|
}
|
|
}
|
|
|
|
|
|
|
@@ -3452,7 +3452,7 @@ inline ssize_t SocketStream::write(const char *ptr, size_t size) {
|
|
|
}
|
|
}
|
|
|
return send(sock_, ptr, static_cast<int>(size), 0);
|
|
return send(sock_, ptr, static_cast<int>(size), 0);
|
|
|
#else
|
|
#else
|
|
|
- return HANDLE_EINTR(send, sock_, ptr, size, 0);
|
|
|
|
|
|
|
+ return handle_EINTR([&]() { return send(sock_, ptr, size, 0); });
|
|
|
#endif
|
|
#endif
|
|
|
}
|
|
}
|
|
|
|
|
|