cmake_minimum_required(VERSION 3.2)
set(CONSUMER_SOURCE_FILES icnet_consumer_test.cc)
+set(CONSUMER__HELLO_WORLD_SOURCE_FILES icnet_consumer_hello_world.cc)
add_executable(consumer-test ${CONSUMER_SOURCE_FILES})
target_link_libraries(consumer-test icnet ${CMAKE_THREAD_LIBS_INIT} ${Boost_LIBRARIES})
install(TARGETS consumer-test DESTINATION ${CMAKE_INSTALL_PREFIX}/bin COMPONENT library)
+
+add_executable(consumer-hello-world ${CONSUMER__HELLO_WORLD_SOURCE_FILES})
+
+target_link_libraries(consumer-hello-world icnet ${CMAKE_THREAD_LIBS_INIT} ${Boost_LIBRARIES})
+install(TARGETS consumer-hello-world DESTINATION ${CMAKE_INSTALL_PREFIX}/bin COMPONENT library)
--- /dev/null
+/*
+ * Copyright (c) 2017 Cisco and/or its affiliates.
+ * Licensed under the Apache License, Version 2.0 (the "License");
+ * you may not use this file except in compliance with the License.
+ * You may obtain a copy of the License at:
+ *
+ * http://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing, software
+ * distributed under the License is distributed on an "AS IS" BASIS,
+ * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+ * See the License for the specific language governing permissions and
+ * limitations under the License.
+ */
+
+#include "icnet_transport_socket_consumer.h"
+#include "icnet_utils_daemonizator.h"
+
+namespace icnet {
+
+namespace transport {
+
+class IcnetConsumerHelloWorld {
+ public:
+ IcnetConsumerHelloWorld()
+ : c_(Name(), TransportProtocolAlgorithms::RAAQM) {
+ c_.setSocketOption(GeneralTransportOptions::INTEREST_LIFETIME, 1001);
+
+ c_.setSocketOption(GeneralTransportOptions::MAX_INTEREST_RETX, 25);
+
+ c_.setSocketOption(ConsumerCallbacksOptions::CONTENT_OBJECT_TO_VERIFY,
+ (ConsumerContentObjectVerificationCallback) std::bind(&IcnetConsumerHelloWorld::verifyPacket,
+ this,
+ std::placeholders::_1,
+ std::placeholders::_2));
+
+ c_.setSocketOption(ConsumerCallbacksOptions::CONTENT_RETRIEVED,
+ (ConsumerContentCallback) std::bind(&IcnetConsumerHelloWorld::processContent,
+ this,
+ std::placeholders::_1,
+ std::placeholders::_2));
+
+ c_.setSocketOption(ConsumerCallbacksOptions::INTEREST_OUTPUT,
+ (ConsumerInterestCallback) std::bind(&IcnetConsumerHelloWorld::processLeavingInterest,
+ this,
+ std::placeholders::_1,
+ std::placeholders::_2));
+ }
+
+ void run(Name name) {
+ c_.consume(name);
+ }
+
+ void stop() {
+ c_.stop();
+ }
+
+ private:
+ bool verifyPacket(ConsumerSocket &c, const ContentObject &contentObject) {
+ return true;
+ }
+
+ void processContent(ConsumerSocket &c, std::vector<uint8_t> &&payload) {
+ std::cout << "Content retrieved!! Size: " << payload.size() << std::endl;
+
+ // Save content to a file
+ std::ofstream file("consumer_hello_world_file", std::ofstream::binary);
+ file.write(reinterpret_cast<char*>(payload.data()), payload.size());
+ file.close();
+ }
+
+ void processLeavingInterest(ConsumerSocket &c, const Interest &interest) {
+ std::cout << "Sending interest with name " << interest.getName() << std::endl;
+ }
+ private:
+ ConsumerSocket c_;
+};
+
+int main(int argc, char *argv[]) {
+ bool daemon = false;
+
+ int opt;
+ while ((opt = getopt(argc, argv, "D")) != -1) {
+ switch (opt) {
+ case 'D':
+ daemon = true;
+ break;
+ default:
+ exit(EXIT_FAILURE);
+ }
+ }
+
+ std::string name = "ccnx:/helloworld";
+
+ if (argv[optind] == 0) {
+ std::cerr << "Using default name ccnx:/helloworld" << std::endl;
+ } else {
+ name = argv[optind];
+ }
+
+ if (daemon) {
+ utils::Daemonizator::daemonize();
+ }
+
+ IcnetConsumerHelloWorld consumer;
+ consumer.run(Name(name.c_str()));
+ consumer.stop();
+
+ return 0;
+
+}
+
+} // end namespace icnet
+
+} // end namespace transport
+
+int main(int argc, char *argv[]) {
+ return icnet::transport::main(argc, argv);
+}
+/*
/*
* Copyright (c) 2017 Cisco and/or its affiliates.
* Licensed under the Apache License, Version 2.0 (the "License");
set(PRODUCER_SOURCE_FILES
icnet_producer_test.cc)
+set(PRODUCER_HELLO_WORLD_SOURCE_FILES
+ icnet_producer_hello_world.cc)
+
add_executable(producer-test ${PRODUCER_SOURCE_FILES})
+add_executable(producer-hello-world ${PRODUCER_HELLO_WORLD_SOURCE_FILES})
+
target_link_libraries(producer-test icnet ${CMAKE_THREAD_LIBS_INIT} ${Boost_LIBRARIES})
+target_link_libraries(producer-hello-world icnet ${CMAKE_THREAD_LIBS_INIT} ${Boost_LIBRARIES})
+
install(TARGETS producer-test DESTINATION ${CMAKE_INSTALL_PREFIX}/bin COMPONENT library)
+install(TARGETS producer-hello-world DESTINATION ${CMAKE_INSTALL_PREFIX}/bin COMPONENT library)
--- /dev/null
+/*
+ * Copyright (c) 2017 Cisco and/or its affiliates.
+ * Licensed under the Apache License, Version 2.0 (the "License");
+ * you may not use this file except in compliance with the License.
+ * You may obtain a copy of the License at:
+ *
+ * http://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing, software
+ * distributed under the License is distributed on an "AS IS" BASIS,
+ * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+ * See the License for the specific language governing permissions and
+ * limitations under the License.
+ */
+
+#include "icnet_transport_socket_producer.h"
+#include "icnet_utils_daemonizator.h"
+
+#define IDENTITY_NAME "cisco"
+
+namespace icnet {
+
+namespace transport {
+
+class IcnetProducerHelloWorld {
+
+public:
+ IcnetProducerHelloWorld(Name& prefix)
+ : prefix_(prefix),
+ p_(prefix_) {
+
+ p_.setSocketOption(ProducerCallbacksOptions::INTEREST_INPUT,
+ (ProducerInterestCallback) bind(&IcnetProducerHelloWorld::processIncomingInterest,
+ this,
+ std::placeholders::_1,
+ std::placeholders::_2));
+
+ p_.setSocketOption(ProducerCallbacksOptions::CACHE_MISS,
+ (ProducerInterestCallback) bind(&IcnetProducerHelloWorld::processInterest,
+ this,
+ std::placeholders::_1,
+ std::placeholders::_2));
+
+ }
+
+ void publish_content(Name name, uint8_t *buffer, std::size_t size) {
+ p_.produce(name, buffer, size);
+ }
+
+ void run() {
+ p_.attach();
+ p_.serveForever();
+ }
+
+private:
+ void processIncomingInterest(ProducerSocket &p, const Interest &interest) {
+ // A new interest has been received!
+ std::cout << "Received interest with name " << interest.getName() << std::endl;
+ }
+
+ void processInterest(ProducerSocket &p, const Interest &interest) {
+ // The received interest did not hit any content object in the cache!
+ std::cout << "The interest with name " << interest.getName() << " cannot be satisfied!" << std::endl;
+ }
+
+private:
+ Name prefix_;
+ ProducerSocket p_;
+};
+
+int main(int argc, char **argv) {
+ std::string name = "ccnx:/helloworld";
+ unsigned long download_size = 0;
+ bool daemon = false;
+
+ int opt;
+ while ((opt = getopt(argc, argv, "Ds:")) != -1) {
+
+ switch (opt) {
+ case 'D':
+ daemon = true;
+ break;
+ case 's':
+ download_size = std::stoul(optarg);
+ break;
+ default:
+ exit(EXIT_FAILURE);
+ }
+ }
+
+ if (argv[optind] == 0) {
+ std::cerr << "Using default name ccnx:/helloworld" << std::endl;
+ } else {
+ name = argv[optind];
+ }
+
+ if (daemon) {
+ utils::Daemonizator::daemonize();
+ }
+
+ Name n(name.c_str());
+ std::string content(10000, 'A');
+
+ IcnetProducerHelloWorld producer(n);
+ producer.publish_content(n, (uint8_t *)content.data(), content.size());
+ producer.run();
+
+ return 0;
+}
+
+} // end namespace transport
+
+} // end namespace icnet
+
+int main(int argc, char **argv) {
+ return icnet::transport::main(argc, argv);
+}
+
HTTPServerPublisher &HTTPServerPublisher::setTimeout(uint32_t timeout) {
std::shared_ptr<transport::Portal> portal;
producer_->getSocketOption(transport::GeneralTransportOptions::PORTAL, portal);
- timer_ = std::unique_ptr<boost::asio::deadline_timer>(new boost::asio::deadline_timer(portal->getIoService(),
- boost::posix_time::seconds(
- timeout)));
+ timer_ = std::unique_ptr<boost::asio::deadline_timer>(new boost::asio::deadline_timer(portal->getIoService(), boost::posix_time::seconds(timeout)));
wait_callback_ = [this](const boost::system::error_code e) {
if (!e) {
seq_number_map_[name.toString()][response_id] = current_segment;
}
+
if (making_manifest_) {
std::shared_ptr<ContentObject> content_object_segment;
void dispatch();
- void produce(Name name, const uint8_t *buffer, size_t buffer_size, const int request_id = 0, bool is_last = false);
+ void produce(Name name, const uint8_t *buffer, size_t buffer_size, const int request_id = 0, bool is_last = true);
void produce(ContentObject &content_object);
Code Review / cicn.git / commitdiff