diff options
author | Alberto Compagno <acompagn+fdio@cisco.com> | 2019-11-14 09:30:23 +0000 |
---|---|---|
committer | Gerrit Code Review <gerrit@fd.io> | 2019-11-14 09:30:23 +0000 |
commit | 34d819b0cf58fa3a96b5cae84b825b5a8a633cd4 (patch) | |
tree | f07a5ca4bc0133e85036daa017ef4d2e684b3749 /libtransport/src/hicn/transport/interfaces/socket_producer.h | |
parent | cd09afb42f41f8bb6cc9db3d13b3f353fa69d94f (diff) | |
parent | f2b7325ae6114b6b5b9e4d32c0a7cdc07576f224 (diff) |
Merge "[HICN-392] Assign independent suffixes for manifests/contents"
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 |