From cb1c34aef0199b58000cc525d9017da244c00cf8 Mon Sep 17 00:00:00 2001 From: tqchen Date: Sat, 22 Nov 2014 17:15:05 -0800 Subject: [PATCH] add nonblocking mode --- src/sync/sync_tcp.cpp | 2 ++ 1 file changed, 2 insertions(+) diff --git a/src/sync/sync_tcp.cpp b/src/sync/sync_tcp.cpp index cfd0d57cd..dd851d05a 100644 --- a/src/sync/sync_tcp.cpp +++ b/src/sync/sync_tcp.cpp @@ -101,6 +101,8 @@ class SyncManager { // setup selecter selecter.Clear(); for (size_t i = 0; i < links.size(); ++i) { + // set the socket to non-blocking mode + links[i].sock.SetNonBlock(); selecter.WatchRead(links[i].sock); selecter.WatchWrite(links[i].sock); }