diff options
Diffstat (limited to 'libtransport/src/hicn/transport/interfaces/socket_producer.h')
| -rw-r--r-- | libtransport/src/hicn/transport/interfaces/socket_producer.h | 9 |
1 files changed, 6 insertions, 3 deletions
diff --git a/libtransport/src/hicn/transport/interfaces/socket_producer.h b/libtransport/src/hicn/transport/interfaces/socket_producer.h index 709a2582b..952587b70 100644 --- a/libtransport/src/hicn/transport/interfaces/socket_producer.h +++ b/libtransport/src/hicn/transport/interfaces/socket_producer.h @@ -18,6 +18,7 @@ #include <hicn/transport/interfaces/socket.h> #include <hicn/transport/utils/content_store.h> #include <hicn/transport/utils/event_thread.h> +#include <hicn/transport/utils/suffix_strategy.h> #include <atomic> #include <cmath> @@ -190,6 +191,8 @@ class ProducerSocket : public Socket<BasePortal>, std::atomic<utils::CryptoSuite> crypto_suite_; utils::SpinLock identity_lock_; std::shared_ptr<utils::Identity> identity_; + utils::SuffixManifest suffix_manifest_; + utils::SuffixContent suffix_content_; // callbacks ProducerInterestCallback on_interest_input_; @@ -220,8 +223,8 @@ class ProducerSocket : public Socket<BasePortal>, /* Condition variable for the wait */ std::condition_variable cv; bool done = false; - io_service_.dispatch([&socket_option_key, &socket_option_value, - &mtx, &cv, &result, &done, &func]() { + io_service_.dispatch([&socket_option_key, &socket_option_value, &mtx, &cv, + &result, &done, &func]() { std::unique_lock<std::mutex> lck(mtx); done = true; result = func(socket_option_key, socket_option_value); @@ -247,4 +250,4 @@ class ProducerSocket : public Socket<BasePortal>, } // namespace interface -} // namespace transport
\ No newline at end of file +} // namespace transport |