Hendrik/xgboost
1
0
Fork 0
Code Issues Pull Requests Packages Projects Releases Wiki Activity

add nonblocking mode

Browse Source
This commit is contained in:
tqchen 2014-11-22 17:15:05 -08:00
parent 67c5d8a2e6
commit cb1c34aef0
1 changed files with 2 additions and 0 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

2
src/sync/sync_tcp.cpp
View File

@ -101,6 +101,8 @@ class SyncManager {
// setup selecter // setup selecter
selecter.Clear(); selecter.Clear();
for (size_t i = 0; i < links.size(); ++i) { 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.WatchRead(links[i].sock);
selecter.WatchWrite(links[i].sock); selecter.WatchWrite(links[i].sock);
} }