summaryrefslogtreecommitdiff
path: root/cpp/src/Ice/Selector.cpp
diff options
context:
space:
mode:
authorBenoit Foucher <benoit@zeroc.com>2014-10-22 16:33:13 +0200
committerBenoit Foucher <benoit@zeroc.com>2014-10-22 16:33:13 +0200
commitd8da15a2d803da81b76568d0c8f620f8ed26d0fa (patch)
treef193067905624d61e0e8a3e6cd7d2498b9bf1873 /cpp/src/Ice/Selector.cpp
parentFixed demo dist to allow gradle build of java demos (diff)
downloadice-d8da15a2d803da81b76568d0c8f620f8ed26d0fa.tar.bz2
ice-d8da15a2d803da81b76568d0c8f620f8ed26d0fa.tar.xz
ice-d8da15a2d803da81b76568d0c8f620f8ed26d0fa.zip
Fixed ICE-3490: guarantee invocation serialization for proxies which are equal
Diffstat (limited to 'cpp/src/Ice/Selector.cpp')
-rw-r--r--cpp/src/Ice/Selector.cpp22
1 files changed, 11 insertions, 11 deletions
diff --git a/cpp/src/Ice/Selector.cpp b/cpp/src/Ice/Selector.cpp
index 12f0c508496..1073d245804 100644
--- a/cpp/src/Ice/Selector.cpp
+++ b/cpp/src/Ice/Selector.cpp
@@ -420,18 +420,18 @@ Selector::finish(EventHandler* handler, bool closeNow)
if(handler->_registered)
{
update(handler, handler->_registered, SocketOperationNone);
+ }
#if defined(ICE_USE_KQUEUE)
- if(closeNow && !_changes.empty())
- {
- //
- // Update selector now to remove the FD from the kqueue if
- // we're going to close it now. This isn't necessary for
- // epoll since we always update the epoll FD immediately.
- //
- updateSelector();
- }
-#endif
+ if(closeNow && !_changes.empty())
+ {
+ //
+ // Update selector now to remove the FD from the kqueue if
+ // we're going to close it now. This isn't necessary for
+ // epoll since we always update the epoll FD immediately.
+ //
+ updateSelector();
}
+#endif
return closeNow;
}
@@ -509,7 +509,7 @@ Selector::select(vector<pair<EventHandler*, SocketOperation> >& handlers, int ti
if(ev.flags & EV_ERROR)
{
Ice::Error out(_instance->initializationData().logger);
- out << "error while updating selector:\n" << IceUtilInternal::errorToString(ev.data);
+ out << "selector returned error:\n" << IceUtilInternal::errorToString(ev.data);
continue;
}
p.first = reinterpret_cast<EventHandler*>(ev.udata);