aboutsummaryrefslogtreecommitdiffstats
path: root/libtransport/src/protocols/rtc.cc
diff options
context:
space:
mode:
authorMauro Sardara <msardara@cisco.com>2020-05-14 20:21:02 +0200
committerMauro Sardara <msardara@cisco.com>2020-05-20 10:45:53 +0200
commit81fb39606b069fbece973995572fa7f90ea1950a (patch)
tree10c1534707c725eb654741e5b4d280a17ef0c0dc /libtransport/src/protocols/rtc.cc
parent67b86555b33c641de14d3c1d0864e571370a71e6 (diff)
[HICN-613] Add io_service to ConsumerSocket constructor.
Change-Id: Ic1952388e1d2b1e7457c71ae8a959d97aa0cd2d6 Signed-off-by: Mauro Sardara <msardara@cisco.com>
Diffstat (limited to 'libtransport/src/protocols/rtc.cc')
-rw-r--r--libtransport/src/protocols/rtc.cc24
1 files changed, 12 insertions, 12 deletions
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() {