You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@mesos.apache.org by mp...@apache.org on 2016/04/10 01:55:44 UTC
mesos git commit: Windows: Fixed non-blocking connect.
Repository: mesos
Updated Branches:
refs/heads/master 8d9eb5fb9 -> 9a0829f4f
Windows: Fixed non-blocking connect.
Review: https://reviews.apache.org/r/45861/
Project: http://git-wip-us.apache.org/repos/asf/mesos/repo
Commit: http://git-wip-us.apache.org/repos/asf/mesos/commit/9a0829f4
Tree: http://git-wip-us.apache.org/repos/asf/mesos/tree/9a0829f4
Diff: http://git-wip-us.apache.org/repos/asf/mesos/diff/9a0829f4
Branch: refs/heads/master
Commit: 9a0829f4f37f9d5c1b27beffb2d1f2c7878cd0e8
Parents: 8d9eb5f
Author: Daniel Pravat <dp...@outlook.com>
Authored: Sat Apr 9 16:51:10 2016 -0700
Committer: Michael Park <mp...@apache.org>
Committed: Sat Apr 9 16:51:10 2016 -0700
----------------------------------------------------------------------
3rdparty/libprocess/src/poll_socket.cpp | 2 +-
1 file changed, 1 insertion(+), 1 deletion(-)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/mesos/blob/9a0829f4/3rdparty/libprocess/src/poll_socket.cpp
----------------------------------------------------------------------
diff --git a/3rdparty/libprocess/src/poll_socket.cpp b/3rdparty/libprocess/src/poll_socket.cpp
index 42ab965..f6abc73 100644
--- a/3rdparty/libprocess/src/poll_socket.cpp
+++ b/3rdparty/libprocess/src/poll_socket.cpp
@@ -142,7 +142,7 @@ Future<Nothing> PollSocketImpl::connect(const Address& address)
{
Try<int, SocketError> connect = network::connect(get(), address);
if (connect.isError()) {
- if (connect.error().code == EINPROGRESS) {
+ if (net::is_inprogress_error(connect.error().code)) {
return io::poll(get(), io::WRITE)
.then(lambda::bind(&internal::connect, socket()));
}