aboutsummaryrefslogtreecommitdiffstats
path: root/libtransport/src
diff options
context:
space:
mode:
authormichele papalini <micpapal@cisco.com>2019-12-06 11:13:11 +0100
committermichele papalini <micpapal@cisco.com>2019-12-06 11:13:11 +0100
commitc294250cd9faccf514316f92636a1a78a35b514f (patch)
treea95b24ee86a75791d8db5a30173cf24447b31ed6 /libtransport/src
parente8eda2c819b36555d9d6b080eaf8b4b1109d7646 (diff)
[HICN-437] concurrency problem in rtc producer socket
Signed-off-by: michele papalini <micpapal@cisco.com> Change-Id: I629914f48e00814796f16b201e03549e9c7941bd
Diffstat (limited to 'libtransport/src')
-rw-r--r--libtransport/src/hicn/transport/interfaces/rtc_socket_producer.cc2
-rw-r--r--libtransport/src/hicn/transport/protocols/rtc.h4
2 files changed, 3 insertions, 3 deletions
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<utils::MemBuf> &&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