From 81fb39606b069fbece973995572fa7f90ea1950a Mon Sep 17 00:00:00 2001
From: Mauro Sardara <msardara@cisco.com>
Date: Thu, 14 May 2020 20:21:02 +0200
Subject: [HICN-613] Add io_service to ConsumerSocket constructor.

Change-Id: Ic1952388e1d2b1e7457c71ae8a959d97aa0cd2d6
Signed-off-by: Mauro Sardara <msardara@cisco.com>
---
 libtransport/src/protocols/rtc.cc | 24 ++++++++++++------------
 1 file changed, 12 insertions(+), 12 deletions(-)

(limited to 'libtransport/src/protocols/rtc.cc')

diff --git a/libtransport/src/protocols/rtc.cc b/libtransport/src/protocols/rtc.cc
index 72abb599a..4fb352623 100644
--- a/libtransport/src/protocols/rtc.cc
+++ b/libtransport/src/protocols/rtc.cc
@@ -13,12 +13,11 @@
  * limitations under the License.
  */
 
-#include <protocols/rtc.h>
-
 #include <hicn/transport/interfaces/socket_consumer.h>
 #include <implementation/socket_consumer.h>
-
 #include <math.h>
+#include <protocols/rtc.h>
+
 #include <random>
 
 namespace transport {
@@ -42,11 +41,7 @@ RTCTransportProtocol::RTCTransportProtocol(
   reset();
 }
 
-RTCTransportProtocol::~RTCTransportProtocol() {
-  if (is_running_) {
-    stop();
-  }
-}
+RTCTransportProtocol::~RTCTransportProtocol() {}
 
 int RTCTransportProtocol::start() {
   if (is_running_) return -1;
@@ -61,17 +56,22 @@ int RTCTransportProtocol::start() {
 
   is_first_ = false;
   is_running_ = true;
-  portal_->runEventsLoop();
-  is_running_ = false;
+
+  if (is_async_) {
+    portal_->runEventsLoop();
+    is_running_ = false;
+  }
 
   return 0;
 }
 
 void RTCTransportProtocol::stop() {
   if (!is_running_) return;
-
   is_running_ = false;
-  portal_->stopEventsLoop();
+
+  if (is_async_) {
+    portal_->stopEventsLoop();
+  }
 }
 
 void RTCTransportProtocol::resume() {
-- 
cgit 1.2.3-korg