aboutsummaryrefslogtreecommitdiffstats
path: root/libtransport/src/implementation/socket_consumer.h
diff options
context:
space:
mode:
authorMichele Papalini <micpapal@cisco.com>2020-10-20 09:05:56 +0000
committerGerrit Code Review <gerrit@fd.io>2020-10-20 09:05:56 +0000
commitdd89047e434afe4c79e6771f0a50b5ae1e08798e (patch)
tree46fa885ddf39e43edb5119e4ee3415bc027fc401 /libtransport/src/implementation/socket_consumer.h
parent56125366e9d8e526f64b43f661c6c5c3b2fb6f8a (diff)
parente8b709a3c4537c7e71c71575e4835fa761c08d46 (diff)
Merge "[HICN-648] Optionally reset RAAQM window in a per-session basis"
Diffstat (limited to 'libtransport/src/implementation/socket_consumer.h')
-rw-r--r--libtransport/src/implementation/socket_consumer.h11
1 files changed, 11 insertions, 0 deletions
diff --git a/libtransport/src/implementation/socket_consumer.h b/libtransport/src/implementation/socket_consumer.h
index 5e5073956..87965923e 100644
--- a/libtransport/src/implementation/socket_consumer.h
+++ b/libtransport/src/implementation/socket_consumer.h
@@ -58,6 +58,7 @@ class ConsumerSocket : public Socket<BasePortal> {
verifier_(std::make_shared<utils::Verifier>()),
verify_signature_(false),
key_content_(false),
+ reset_window_(false),
on_interest_output_(VOID_HANDLER),
on_interest_timeout_(VOID_HANDLER),
on_interest_satisfied_(VOID_HANDLER),
@@ -343,6 +344,11 @@ class ConsumerSocket : public Socket<BasePortal> {
result = SOCKET_OPTION_SET;
break;
+ case RaaqmTransportOptions::PER_SESSION_CWINDOW_RESET:
+ reset_window_ = socket_option_value;
+ result = SOCKET_OPTION_SET;
+ break;
+
default:
return result;
}
@@ -648,6 +654,10 @@ class ConsumerSocket : public Socket<BasePortal> {
socket_option_value = is_async_;
break;
+ case RaaqmTransportOptions::PER_SESSION_CWINDOW_RESET:
+ socket_option_value = reset_window_;
+ break;
+
default:
return SOCKET_OPTION_NOT_GET;
}
@@ -923,6 +933,7 @@ class ConsumerSocket : public Socket<BasePortal> {
PARCKeyId *key_id_;
std::atomic_bool verify_signature_;
bool key_content_;
+ bool reset_window_;
ConsumerInterestCallback on_interest_retransmission_;
ConsumerInterestCallback on_interest_output_;