From 9e5f41ed6ebe64a789916794626485460078c420 Mon Sep 17 00:00:00 2001 From: Mauro Sardara Date: Sat, 19 Jan 2019 01:29:33 +0100 Subject: - Code style fix - Improved vpp binary api interface - Correction in object pool destructor - Fix error in Memif Connector Change-Id: Id1dd9219fc1ac0b3717ae019ebff17373bebc635 Signed-off-by: Mauro Sardara --- libtransport/src/hicn/transport/interfaces/full_duplex_socket.cc | 7 ++++--- libtransport/src/hicn/transport/interfaces/rtc_socket_producer.cc | 2 +- libtransport/src/hicn/transport/interfaces/socket_consumer.cc | 6 +++--- 3 files changed, 8 insertions(+), 7 deletions(-) mode change 100755 => 100644 libtransport/src/hicn/transport/interfaces/full_duplex_socket.cc mode change 100755 => 100644 libtransport/src/hicn/transport/interfaces/rtc_socket_producer.cc mode change 100755 => 100644 libtransport/src/hicn/transport/interfaces/socket_consumer.cc (limited to 'libtransport/src/hicn/transport/interfaces') diff --git a/libtransport/src/hicn/transport/interfaces/full_duplex_socket.cc b/libtransport/src/hicn/transport/interfaces/full_duplex_socket.cc old mode 100755 new mode 100644 index 7b6342262..37e1d7b3e --- a/libtransport/src/hicn/transport/interfaces/full_duplex_socket.cc +++ b/libtransport/src/hicn/transport/interfaces/full_duplex_socket.cc @@ -68,9 +68,10 @@ AsyncFullDuplexSocket::AsyncFullDuplexSocket(const Prefix &locator, ConsumerSocket & s, const ContentObject &c) ->bool { return true; }); - consumer_->setSocketOption( - ConsumerCallbacksOptions::CONTENT_RETRIEVED, - std::bind(&AsyncFullDuplexSocket::onContentRetrieved, this, _1, _2, _3)); + ConsumerContentCallback callback = + std::bind(&AsyncFullDuplexSocket::onContentRetrieved, this, _1, _2, _3); + consumer_->setSocketOption(ConsumerCallbacksOptions::CONTENT_RETRIEVED, + callback); consumer_->setSocketOption(GeneralTransportOptions::MAX_INTEREST_RETX, uint32_t{4}); diff --git a/libtransport/src/hicn/transport/interfaces/rtc_socket_producer.cc b/libtransport/src/hicn/transport/interfaces/rtc_socket_producer.cc old mode 100755 new mode 100644 index d8a9d53b9..ec8c4c69e --- a/libtransport/src/hicn/transport/interfaces/rtc_socket_producer.cc +++ b/libtransport/src/hicn/transport/interfaces/rtc_socket_producer.cc @@ -13,9 +13,9 @@ * limitations under the License. */ +#include #include #include -#include #define NACK_HEADER_SIZE 8 // bytes #define TIMESTAMP_LEN 8 // bytes diff --git a/libtransport/src/hicn/transport/interfaces/socket_consumer.cc b/libtransport/src/hicn/transport/interfaces/socket_consumer.cc old mode 100755 new mode 100644 index 8109d0e99..27ed4e65f --- a/libtransport/src/hicn/transport/interfaces/socket_consumer.cc +++ b/libtransport/src/hicn/transport/interfaces/socket_consumer.cc @@ -137,11 +137,11 @@ void ConsumerSocket::stop() { transport_protocol_->stop(); } - //is_running_ = false; + // is_running_ = false; } void ConsumerSocket::resume() { - if(!transport_protocol_->isRunning()){ + if (!transport_protocol_->isRunning()) { transport_protocol_->resume(); } } @@ -548,7 +548,7 @@ int ConsumerSocket::getSocketOption(int socket_option_key, case GeneralTransportOptions::RUNNING: socket_option_value = transport_protocol_->isRunning(); - return SOCKET_OPTION_GET; + return SOCKET_OPTION_GET; case OtherOptions::VIRTUAL_DOWNLOAD: socket_option_value = virtual_download_; -- cgit 1.2.3-korg