aboutsummaryrefslogtreecommitdiffstats
path: root/fnet
diff options
context:
space:
mode:
authorHenning Baldersheim <balder@yahoo-inc.com>2020-11-30 13:09:26 +0000
committerHenning Baldersheim <balder@yahoo-inc.com>2020-11-30 13:09:26 +0000
commita471ab72a468ccc51390d232275df6ef5fdf8f1b (patch)
tree9db2ed83a6fdee2bac9be130db86eff1457d4d81 /fnet
parent7481d52c6ce19da5efa9435a5e57a5b25beb232a (diff)
Rename handle_wakeup -> handle_wakeup_events and leave an empty handle_wakeup to satisfy selector callback api.
Diffstat (limited to 'fnet')
-rw-r--r--fnet/src/vespa/fnet/transport_thread.cpp7
-rw-r--r--fnet/src/vespa/fnet/transport_thread.h6
2 files changed, 7 insertions, 6 deletions
diff --git a/fnet/src/vespa/fnet/transport_thread.cpp b/fnet/src/vespa/fnet/transport_thread.cpp
index 1200d2ad6f9..d61eaffa24f 100644
--- a/fnet/src/vespa/fnet/transport_thread.cpp
+++ b/fnet/src/vespa/fnet/transport_thread.cpp
@@ -398,9 +398,8 @@ FNET_TransportThread::InitEventLoop()
return true;
}
-
void
-FNET_TransportThread::handle_wakeup()
+FNET_TransportThread::handle_wakeup_events()
{
{
std::lock_guard<std::mutex> guard(_lock);
@@ -481,11 +480,11 @@ FNET_TransportThread::EventLoopIteration()
// sample current time (performed once per event loop iteration)
_now = clock::now();
+ handle_wakeup_events();
+
// handle io-events
_selector.dispatch(*this);
- handle_wakeup();
-
// handle IOC time-outs
if (_config._iocTimeOut > 0) {
time_point oldest = (_now - std::chrono::milliseconds(_config._iocTimeOut));
diff --git a/fnet/src/vespa/fnet/transport_thread.h b/fnet/src/vespa/fnet/transport_thread.h
index 966ffb849e0..b4319d4e2bc 100644
--- a/fnet/src/vespa/fnet/transport_thread.h
+++ b/fnet/src/vespa/fnet/transport_thread.h
@@ -172,6 +172,8 @@ private:
return _shutdown.load(std::memory_order_relaxed);
}
+ void handle_wakeup_events();
+
public:
FNET_TransportThread(const FNET_TransportThread &) = delete;
FNET_TransportThread &operator=(const FNET_TransportThread &) = delete;
@@ -456,8 +458,8 @@ public:
void WaitFinished();
- // selector call-back for selector wakeup
- void handle_wakeup();
+ // Empty selector call-back for selector wakeup
+ void handle_wakeup() { }
// selector call-back for io-events
void handle_event(FNET_IOComponent &ctx, bool read, bool write);