aboutsummaryrefslogtreecommitdiffstats
path: root/apps/hiperf/src/server.cc
diff options
context:
space:
mode:
Diffstat (limited to 'apps/hiperf/src/server.cc')
-rw-r--r--apps/hiperf/src/server.cc46
1 files changed, 29 insertions, 17 deletions
diff --git a/apps/hiperf/src/server.cc b/apps/hiperf/src/server.cc
index b338c69df..3f6c335f9 100644
--- a/apps/hiperf/src/server.cc
+++ b/apps/hiperf/src/server.cc
@@ -17,18 +17,25 @@
namespace hiperf {
+using transport::core::ContentObject;
+using transport::core::Interest;
+using transport::core::Name;
+using transport::interface::GeneralTransportOptions;
+using transport::interface::ProducerCallbacksOptions;
+using transport::interface::ProducerInterestCallback;
+using transport::interface::ProducerSocket;
+using transport::interface::ProductionProtocolAlgorithms;
+
/**
* Hiperf server class: configure and setup an hicn producer following the
* ServerConfiguration.
*/
class HIperfServer::Impl {
- static inline constexpr std::size_t klog2_content_object_buffer_size() {
- return 8;
- }
- static inline constexpr std::size_t kcontent_object_buffer_size() {
+ static constexpr std::size_t klog2_content_object_buffer_size() { return 8; }
+ static constexpr std::size_t kcontent_object_buffer_size() {
return (1 << klog2_content_object_buffer_size());
}
- static inline constexpr std::size_t kmask() {
+ static constexpr std::size_t kmask() {
return (kcontent_object_buffer_size() - 1);
}
@@ -58,7 +65,8 @@ class HIperfServer::Impl {
content_objects_.emplace_back(std::make_shared<ContentObject>(
configuration_.name_.makeName(), configuration_.packet_format_,
0, (const uint8_t *)buffer.data(), buffer.size()));
- element->setLifetime(default_values::content_object_expiry_time);
+ element->setLifetime(
+ transport::interface::default_values::content_object_expiry_time);
}
}
@@ -92,7 +100,8 @@ class HIperfServer::Impl {
int setup() {
int ret;
int production_protocol;
- std::shared_ptr<Signer> signer = std::make_shared<VoidSigner>();
+ std::shared_ptr<transport::auth::Signer> signer =
+ std::make_shared<transport::auth::VoidSigner>();
if (!configuration_.rtc_) {
production_protocol = ProductionProtocolAlgorithms::BYTE_STREAM;
@@ -121,7 +130,7 @@ class HIperfServer::Impl {
return ERROR_SETUP;
}
- if (producer_socket_->setSocketOption(PACKET_FORMAT,
+ if (producer_socket_->setSocketOption(transport::interface::PACKET_FORMAT,
configuration_.packet_format_) ==
SOCKET_OPTION_NOT_SET) {
getOutputStream() << "ERROR -- Impossible to set the packet format."
@@ -130,12 +139,13 @@ class HIperfServer::Impl {
}
if (!configuration_.passphrase_.empty()) {
- signer = std::make_shared<SymmetricSigner>(CryptoSuite::HMAC_SHA256,
- configuration_.passphrase_);
+ signer = std::make_shared<transport::auth::SymmetricSigner>(
+ transport::auth::CryptoSuite::HMAC_SHA256,
+ configuration_.passphrase_);
}
if (!configuration_.keystore_name_.empty()) {
- signer = std::make_shared<AsymmetricSigner>(
+ signer = std::make_shared<transport::auth::AsymmetricSigner>(
configuration_.keystore_name_, configuration_.keystore_password_);
}
@@ -161,9 +171,10 @@ class HIperfServer::Impl {
}
// Verifier for aggregated interests
- std::shared_ptr<Verifier> verifier = std::make_shared<VoidVerifier>();
+ std::shared_ptr<transport::auth::Verifier> verifier =
+ std::make_shared<transport::auth::VoidVerifier>();
if (!configuration_.aggr_interest_passphrase_.empty()) {
- verifier = std::make_unique<SymmetricVerifier>(
+ verifier = std::make_unique<transport::auth::SymmetricVerifier>(
configuration_.aggr_interest_passphrase_);
}
ret = producer_socket_->setSocketOption(GeneralTransportOptions::VERIFIER,
@@ -172,7 +183,7 @@ class HIperfServer::Impl {
if (configuration_.rtc_) {
ret = producer_socket_->setSocketOption(
- RtcTransportOptions::AGGREGATED_DATA,
+ transport::interface::RtcTransportOptions::AGGREGATED_DATA,
configuration_.aggregated_data_);
if (ret == SOCKET_OPTION_NOT_SET) {
@@ -249,7 +260,7 @@ class HIperfServer::Impl {
ret = producer_socket_->setSocketOption(
ProducerCallbacksOptions::CONTENT_PRODUCED,
- (ProducerContentCallback)bind(
+ (transport::interface::ProducerContentCallback)bind(
&ProducerContext::onContentProduced, this, std::placeholders::_1,
std::placeholders::_2, std::placeholders::_3));
if (ret == SOCKET_OPTION_NOT_SET) {
@@ -308,8 +319,9 @@ class HIperfServer::Impl {
* @brief Synchronously produce content upon reception of one interest
*/
void processInterest(ProducerSocket &p, const Interest &interest) const {
- p.setSocketOption(ProducerCallbacksOptions::CACHE_MISS,
- (ProducerInterestCallback)VOID_HANDLER);
+ p.setSocketOption(
+ ProducerCallbacksOptions::CACHE_MISS,
+ (ProducerInterestCallback)transport::interface::VOID_HANDLER);
p.setSocketOption(GeneralTransportOptions::CONTENT_OBJECT_EXPIRY_TIME,
configuration_.content_lifetime_);