From c294250cd9faccf514316f92636a1a78a35b514f Mon Sep 17 00:00:00 2001 From: michele papalini Date: Fri, 6 Dec 2019 11:13:11 +0100 Subject: [HICN-437] concurrency problem in rtc producer socket Signed-off-by: michele papalini Change-Id: I629914f48e00814796f16b201e03549e9c7941bd --- libtransport/src/hicn/transport/interfaces/rtc_socket_producer.cc | 2 +- libtransport/src/hicn/transport/protocols/rtc.h | 4 ++-- 2 files changed, 3 insertions(+), 3 deletions(-) (limited to 'libtransport/src/hicn') diff --git a/libtransport/src/hicn/transport/interfaces/rtc_socket_producer.cc b/libtransport/src/hicn/transport/interfaces/rtc_socket_producer.cc index f1057aa57..bb93e0535 100644 --- a/libtransport/src/hicn/transport/interfaces/rtc_socket_producer.cc +++ b/libtransport/src/hicn/transport/interfaces/rtc_socket_producer.cc @@ -183,8 +183,8 @@ void RTCProducerSocket::produce(std::unique_ptr &&buffer) { // remove interests from the interest cache if it exists // this generates nacks that will tell to the consumer // that a new data packet was produced + utils::SpinLock::Acquire locked(interests_cache_lock_); if (!seqs_map_.empty()) { - utils::SpinLock::Acquire locked(interests_cache_lock_); for (auto it = seqs_map_.begin(); it != seqs_map_.end(); it++) { if (it->first != old_curr) sendNack(it->first); } diff --git a/libtransport/src/hicn/transport/protocols/rtc.h b/libtransport/src/hicn/transport/protocols/rtc.h index 697459bb7..2b9ed10a6 100644 --- a/libtransport/src/hicn/transport/protocols/rtc.h +++ b/libtransport/src/hicn/transport/protocols/rtc.h @@ -55,8 +55,8 @@ #define HICN_INITIAL_CWIN 1 // packets #define HICN_INITIAL_CWIN_MAX 100000 // packets #define HICN_MIN_CWIN 10 // packets -#define HICN_WIN_INCREASE_FACTOR 1.1 -#define HICN_WIN_DECREASE_FACTOR 0.8 +#define HICN_WIN_INCREASE_FACTOR 1.5 +#define HICN_WIN_DECREASE_FACTOR 0.9 // statistics constants #define HICN_BANDWIDTH_SLACK_FACTOR 1.8 -- cgit 1.2.3-korg