commit 51459409bdc2c70fe7804eb6df7a0917cb0c1259
author Eric Newberry <enewberry@cs.arizona.edu> Thu Jun 28 00:06:18 2018 -0700
committer Eric Newberry <enewberry@cs.arizona.edu> Thu Jun 28 21:01:19 2018 -0700
tree 8be8090b328b4b18dd38fea1023b8f6105c70258
parent b4ef47818a3d492d127c3a2ee8b54f8b011788dd

server: clear SIGINT/SIGTERM handler to exit cleanly

refs #4642

Change-Id: Ief62af106c5211aa4877a9196ada0299090c7287

src/ndn-traffic-server.cpp

diff --git a/src/ndn-traffic-server.cpp b/src/ndn-traffic-server.cpp
index bac43b4..83ea6db 100644
--- a/src/ndn-traffic-server.cpp
+++ b/src/ndn-traffic-server.cpp
@@ -24,7 +24,6 @@
 #include <ndn-cxx/security/key-chain.hpp>
 #include <ndn-cxx/security/signing-info.hpp>
 #include <ndn-cxx/util/backports.hpp>
-#include <ndn-cxx/util/scheduler.hpp>
 
 #include <boost/asio/io_service.hpp>
 #include <boost/asio/signal_set.hpp>
@@ -55,7 +54,7 @@
     , m_contentDelay(time::milliseconds(-1))
     , m_instanceId(to_string(std::rand()))
     , m_face(m_ioService)
-    , m_scheduler(m_ioService)
+    , m_signalSet(m_ioService, SIGINT, SIGTERM)
   {
   }
 
@@ -417,6 +416,7 @@
       for (auto registeredPrefix : m_registeredPrefixes) {
         m_face.unsetInterestFilter(registeredPrefix);
       }
+      m_signalSet.cancel();
     }
   }
 
@@ -438,8 +438,7 @@
   void
   run()
   {
-    boost::asio::signal_set signalSet(m_ioService, SIGINT, SIGTERM);
-    signalSet.async_wait(bind(&NdnTrafficServer::signalHandler, this));
+    m_signalSet.async_wait(bind(&NdnTrafficServer::signalHandler, this));
 
     m_logger.initializeLog(m_instanceId);
     initializeTrafficConfiguration();
@@ -452,6 +451,7 @@
       m_registeredPrefixes.push_back(
         m_face.setInterestFilter(m_trafficPatterns[patternId].m_name,
                                  bind(&NdnTrafficServer::onInterest, this, _1, _2, patternId),
+                                 nullptr,
                                  bind(&NdnTrafficServer::onRegisterFailed, this, _1, _2, patternId)));
     }
 
@@ -480,7 +480,7 @@
 
   boost::asio::io_service m_ioService;
   Face m_face;
-  util::scheduler::Scheduler m_scheduler;
+  boost::asio::signal_set m_signalSet;
   std::vector<DataTrafficConfiguration> m_trafficPatterns;
   std::vector<const RegisteredPrefixId*> m_registeredPrefixes;
 };