Merge remote-tracking branch 'esc/master'

Author: jzemlo

src/escd/network/peerclient.cpp

@@ -76,7 +76,13 @@ std::size_t PeerClient::writeSync(void* data , uint32_t len,  int timeout)
     boost::asio::async_write(m_socket, boost::asio::buffer(data, len), boost::bind(&PeerClient::operationDone, this, boost::asio::placeholders::error, boost::asio::placeholders::bytes_transferred));
 
     do{
-        m_socket.get_io_service().run_one();
+        auto& ioService = m_socket.get_io_service();
+        if (ioService.stopped()) {
+            ELOG("Stopping writeSync task because io_service is stopped\n");
+            m_ec = boost::asio::error::timed_out;
+            break;
+        }
+        ioService.run_one();
     }
     while (m_ec == boost::asio::error::would_block);
 
@@ -103,7 +109,13 @@ std::size_t PeerClient::readSync(void* data , uint32_t len,  int timeout)
     boost::asio::async_read(m_socket, boost::asio::buffer(data, len), boost::bind(&PeerClient::operationDone, this, boost::asio::placeholders::error, boost::asio::placeholders::bytes_transferred));
 
     do{
-        m_socket.get_io_service().run_one();
+        auto& ioService = m_socket.get_io_service();
+        if (ioService.stopped()) {
+            ELOG("Stopping readSync task because io_service is stopped\n");
+            m_ec = boost::asio::error::timed_out;
+            break;
+        }
+        ioService.run_one();
     }
     while (m_ec == boost::asio::error::would_block);
 

src/escd/network/peerclientmanager.cpp

@@ -124,8 +124,6 @@ void PeerConnectManager::addActivePeer(uint16_t svid, boost::shared_ptr<peer> pe
 
 void PeerConnectManager::addActivePeerImpl(uint16_t svid, boost::shared_ptr<peer> peer)
 {
-    DLOG("ENTERED addActivePeerImpl, peer svid:%u\n", svid);
-
     try{
         boost::upgrade_lock< boost::shared_mutex > lock(m_peerMx);
         DLOG("Add active peer svid: %ud\n", svid);
@@ -139,8 +137,6 @@ void PeerConnectManager::addActivePeerImpl(uint16_t svid, boost::shared_ptr<peer
     {
         ELOG("ERROR: Leave peer exception%s", e.what());
     }
-
-    DLOG("LEFT addActivePeerImpl\n");
 }
 
 void PeerConnectManager::leevePeer(uint16_t svid, std::string address, unsigned short port)
@@ -431,7 +427,6 @@ void PeerConnectManager::deliver(message_ptr msg, uint16_t svid)
 
 void PeerConnectManager::deliverImpl(message_ptr msg, uint16_t svid)
 {
-    DLOG("ENTERED deliverImpl, peer svid:%u\n", svid);
     if (msg->data != nullptr) {
         DLOG("msg type:%u\n", msg->data[0]);
     }
@@ -446,7 +441,6 @@ void PeerConnectManager::deliverImpl(message_ptr msg, uint16_t svid)
     }
 
     msg->sent_erase(svid);
-    DLOG("LEFT deliverImpl 2\n");
 }
 
 void PeerConnectManager::deliverToAll(message_ptr msg)
@@ -456,7 +450,6 @@ void PeerConnectManager::deliverToAll(message_ptr msg)
 
 void PeerConnectManager::deliverToAllImpl(message_ptr msg)
 {
-    DLOG("ENTERED deliverToAllImpl\n");
     if (msg->data != nullptr) {
         DLOG("msg type:%u\n", msg->data[0]);
     }
@@ -465,8 +458,6 @@ void PeerConnectManager::deliverToAllImpl(message_ptr msg)
     for(auto& peer: m_activePeers){
         peer.second->deliver(msg);
     }
-
-    DLOG("LEFT deliverToAllImpl\n");
 }
 
 void PeerConnectManager::update(message_ptr msg, uint16_t svid)
@@ -476,7 +467,6 @@ void PeerConnectManager::update(message_ptr msg, uint16_t svid)
 
 void PeerConnectManager::updateImpl(message_ptr msg, uint16_t svid)
 {
-    DLOG("ENTERED updateImpl, peer svid:%u\n", svid);
     if (msg->data != nullptr) {
         DLOG("msg type:%u\n", msg->data[0]);
     }
@@ -486,8 +476,6 @@ void PeerConnectManager::updateImpl(message_ptr msg, uint16_t svid)
     if(svidPeer != m_activePeers.end()){
         svidPeer->second->update(msg);
     }
-
-    DLOG("LEFT updateImpl\n");
 }
 
 void PeerConnectManager::updateAll(message_ptr msg)
@@ -497,18 +485,14 @@ void PeerConnectManager::updateAll(message_ptr msg)
 
 void PeerConnectManager::updateAllImpl(message_ptr msg)
 {
-    DLOG("ENTERED updateAllImpl\n");
     if (msg->data != nullptr) {
         DLOG("msg type:%u\n", msg->data[0]);
     }
     boost::shared_lock< boost::shared_mutex > lock(m_peerMx);
 
-    for(auto& peer: m_activePeers)
-    {
+    for(auto& peer: m_activePeers) {
         peer.second->update(msg);
     }
-
-    DLOG("LEFT updateAllImpl\n");
 }
 
 void PeerConnectManager::getReadyPeers(std::set<uint16_t>& ready)