blob: 586f9901c647488159312080a996f02483088674 [file] [log] [blame]
Jeff Thompson25b4e612013-10-10 16:03:24 -07001/* -*- Mode:C++; c-file-style:"gnu"; indent-tabs-mode:nil -*- */
Jeff Thompsonbf50a1a2013-08-20 18:01:01 -07002/**
Jeff Thompson7687dc02013-09-13 11:54:07 -07003 * Copyright (C) 2013 Regents of the University of California.
4 * @author: Jeff Thompson <jefft0@remap.ucla.edu>
Jeff Thompsonbf50a1a2013-08-20 18:01:01 -07005 * See COPYING for copyright and distribution information.
6 */
7
Jeff Thompsonea141d72013-09-19 14:40:10 -07008#include <stdexcept>
Jeff Thompson25b4e612013-10-10 16:03:24 -07009#include "c/name.h"
10#include "c/interest.h"
Jeff Thompsonea141d72013-09-19 14:40:10 -070011#include "c/util/crypto.h"
Jeff Thompson9ae4d782013-10-17 10:25:54 -070012#include "c/util/time.h"
Jeff Thompsonbf50a1a2013-08-20 18:01:01 -070013#include "c/encoding/binary-xml.h"
Jeff Thompson25b4e612013-10-10 16:03:24 -070014#include "encoding/binary-xml-decoder.hpp"
15#include <ndn-cpp/forwarding-entry.hpp>
16#include <ndn-cpp/security/key-chain.hpp>
17#include <ndn-cpp/sha256-with-rsa-signature.hpp>
18#include <ndn-cpp/node.hpp>
Jeff Thompsonbf50a1a2013-08-20 18:01:01 -070019
20using namespace std;
21using namespace ndn::ptr_lib;
22
23namespace ndn {
24
Jeff Thompson10ad12a2013-09-24 16:19:11 -070025static uint8_t SELFREG_PUBLIC_KEY_DER[] = {
Jeff Thompsonea141d72013-09-19 14:40:10 -0700260x30, 0x81, 0x9F, 0x30, 0x0D, 0x06, 0x09, 0x2A, 0x86, 0x48, 0x86, 0xF7, 0x0D, 0x01, 0x01, 0x01, 0x05, 0x00, 0x03, 0x81,
270x8D, 0x00, 0x30, 0x81, 0x89, 0x02, 0x81, 0x81, 0x00, 0xE1, 0x7D, 0x30, 0xA7, 0xD8, 0x28, 0xAB, 0x1B, 0x84, 0x0B, 0x17,
280x54, 0x2D, 0xCA, 0xF6, 0x20, 0x7A, 0xFD, 0x22, 0x1E, 0x08, 0x6B, 0x2A, 0x60, 0xD1, 0x6C, 0xB7, 0xF5, 0x44, 0x48, 0xBA,
290x9F, 0x3F, 0x08, 0xBC, 0xD0, 0x99, 0xDB, 0x21, 0xDD, 0x16, 0x2A, 0x77, 0x9E, 0x61, 0xAA, 0x89, 0xEE, 0xE5, 0x54, 0xD3,
300xA4, 0x7D, 0xE2, 0x30, 0xBC, 0x7A, 0xC5, 0x90, 0xD5, 0x24, 0x06, 0x7C, 0x38, 0x98, 0xBB, 0xA6, 0xF5, 0xDC, 0x43, 0x60,
310xB8, 0x45, 0xED, 0xA4, 0x8C, 0xBD, 0x9C, 0xF1, 0x26, 0xA7, 0x23, 0x44, 0x5F, 0x0E, 0x19, 0x52, 0xD7, 0x32, 0x5A, 0x75,
320xFA, 0xF5, 0x56, 0x14, 0x4F, 0x9A, 0x98, 0xAF, 0x71, 0x86, 0xB0, 0x27, 0x86, 0x85, 0xB8, 0xE2, 0xC0, 0x8B, 0xEA, 0x87,
330x17, 0x1B, 0x4D, 0xEE, 0x58, 0x5C, 0x18, 0x28, 0x29, 0x5B, 0x53, 0x95, 0xEB, 0x4A, 0x17, 0x77, 0x9F, 0x02, 0x03, 0x01,
340x00, 01
35};
36
Jeff Thompson10ad12a2013-09-24 16:19:11 -070037static uint8_t SELFREG_PRIVATE_KEY_DER[] = {
Jeff Thompsonea141d72013-09-19 14:40:10 -0700380x30, 0x82, 0x02, 0x5d, 0x02, 0x01, 0x00, 0x02, 0x81, 0x81, 0x00, 0xe1, 0x7d, 0x30, 0xa7, 0xd8, 0x28, 0xab, 0x1b, 0x84,
390x0b, 0x17, 0x54, 0x2d, 0xca, 0xf6, 0x20, 0x7a, 0xfd, 0x22, 0x1e, 0x08, 0x6b, 0x2a, 0x60, 0xd1, 0x6c, 0xb7, 0xf5, 0x44,
400x48, 0xba, 0x9f, 0x3f, 0x08, 0xbc, 0xd0, 0x99, 0xdb, 0x21, 0xdd, 0x16, 0x2a, 0x77, 0x9e, 0x61, 0xaa, 0x89, 0xee, 0xe5,
410x54, 0xd3, 0xa4, 0x7d, 0xe2, 0x30, 0xbc, 0x7a, 0xc5, 0x90, 0xd5, 0x24, 0x06, 0x7c, 0x38, 0x98, 0xbb, 0xa6, 0xf5, 0xdc,
420x43, 0x60, 0xb8, 0x45, 0xed, 0xa4, 0x8c, 0xbd, 0x9c, 0xf1, 0x26, 0xa7, 0x23, 0x44, 0x5f, 0x0e, 0x19, 0x52, 0xd7, 0x32,
430x5a, 0x75, 0xfa, 0xf5, 0x56, 0x14, 0x4f, 0x9a, 0x98, 0xaf, 0x71, 0x86, 0xb0, 0x27, 0x86, 0x85, 0xb8, 0xe2, 0xc0, 0x8b,
440xea, 0x87, 0x17, 0x1b, 0x4d, 0xee, 0x58, 0x5c, 0x18, 0x28, 0x29, 0x5b, 0x53, 0x95, 0xeb, 0x4a, 0x17, 0x77, 0x9f, 0x02,
450x03, 0x01, 0x00, 0x01, 0x02, 0x81, 0x80, 0x1a, 0x4b, 0xfa, 0x4f, 0xa8, 0xc2, 0xdd, 0x69, 0xa1, 0x15, 0x96, 0x0b, 0xe8,
460x27, 0x42, 0x5a, 0xf9, 0x5c, 0xea, 0x0c, 0xac, 0x98, 0xaa, 0xe1, 0x8d, 0xaa, 0xeb, 0x2d, 0x3c, 0x60, 0x6a, 0xfb, 0x45,
470x63, 0xa4, 0x79, 0x83, 0x67, 0xed, 0xe4, 0x15, 0xc0, 0xb0, 0x20, 0x95, 0x6d, 0x49, 0x16, 0xc6, 0x42, 0x05, 0x48, 0xaa,
480xb1, 0xa5, 0x53, 0x65, 0xd2, 0x02, 0x99, 0x08, 0xd1, 0x84, 0xcc, 0xf0, 0xcd, 0xea, 0x61, 0xc9, 0x39, 0x02, 0x3f, 0x87,
490x4a, 0xe5, 0xc4, 0xd2, 0x07, 0x02, 0xe1, 0x9f, 0xa0, 0x06, 0xc2, 0xcc, 0x02, 0xe7, 0xaa, 0x6c, 0x99, 0x8a, 0xf8, 0x49,
500x00, 0xf1, 0xa2, 0x8c, 0x0c, 0x8a, 0xb9, 0x4f, 0x6d, 0x73, 0x3b, 0x2c, 0xb7, 0x9f, 0x8a, 0xa6, 0x7f, 0x9b, 0x9f, 0xb7,
510xa1, 0xcc, 0x74, 0x2e, 0x8f, 0xb8, 0xb0, 0x26, 0x89, 0xd2, 0xe5, 0x66, 0xe8, 0x8e, 0xa1, 0x02, 0x41, 0x00, 0xfc, 0xe7,
520x52, 0xbc, 0x4e, 0x95, 0xb6, 0x1a, 0xb4, 0x62, 0xcc, 0xd8, 0x06, 0xe1, 0xdc, 0x7a, 0xa2, 0xb6, 0x71, 0x01, 0xaa, 0x27,
530xfc, 0x99, 0xe5, 0xf2, 0x54, 0xbb, 0xb2, 0x85, 0xe1, 0x96, 0x54, 0x2d, 0xcb, 0xba, 0x86, 0xfa, 0x80, 0xdf, 0xcf, 0x39,
540xe6, 0x74, 0xcb, 0x22, 0xce, 0x70, 0xaa, 0x10, 0x00, 0x73, 0x1d, 0x45, 0x0a, 0x39, 0x51, 0x84, 0xf5, 0x15, 0x8f, 0x37,
550x76, 0x91, 0x02, 0x41, 0x00, 0xe4, 0x3f, 0xf0, 0xf4, 0xde, 0x79, 0x77, 0x48, 0x9b, 0x9c, 0x28, 0x45, 0x26, 0x57, 0x3c,
560x71, 0x40, 0x28, 0x6a, 0xa1, 0xfe, 0xc3, 0xe5, 0x37, 0xa1, 0x03, 0xf6, 0x2d, 0xbe, 0x80, 0x64, 0x72, 0x69, 0x2e, 0x9b,
570x4d, 0xe3, 0x2e, 0x1b, 0xfe, 0xe7, 0xf9, 0x77, 0x8c, 0x18, 0x53, 0x9f, 0xe2, 0xfe, 0x00, 0xbb, 0x49, 0x20, 0x47, 0xdf,
580x01, 0x61, 0x87, 0xd6, 0xe3, 0x44, 0xb5, 0x03, 0x2f, 0x02, 0x40, 0x54, 0xec, 0x7c, 0xbc, 0xdd, 0x0a, 0xaa, 0xde, 0xe6,
590xc9, 0xf2, 0x8d, 0x6c, 0x2a, 0x35, 0xf6, 0x3c, 0x63, 0x55, 0x29, 0x40, 0xf1, 0x32, 0x82, 0x9f, 0x53, 0xb3, 0x9e, 0x5f,
600xc1, 0x53, 0x52, 0x3e, 0xac, 0x2e, 0x28, 0x51, 0xa1, 0x16, 0xdb, 0x90, 0xe3, 0x99, 0x7e, 0x88, 0xa4, 0x04, 0x7c, 0x92,
610xae, 0xd2, 0xe7, 0xd4, 0xe1, 0x55, 0x20, 0x90, 0x3e, 0x3c, 0x6a, 0x63, 0xf0, 0x34, 0xf1, 0x02, 0x41, 0x00, 0x84, 0x5a,
620x17, 0x6c, 0xc6, 0x3c, 0x84, 0xd0, 0x93, 0x7a, 0xff, 0x56, 0xe9, 0x9e, 0x98, 0x2b, 0xcb, 0x5a, 0x24, 0x4a, 0xff, 0x21,
630xb4, 0x9e, 0x87, 0x3d, 0x76, 0xd8, 0x9b, 0xa8, 0x73, 0x96, 0x6c, 0x2b, 0x5c, 0x5e, 0xd3, 0xa6, 0xff, 0x10, 0xd6, 0x8e,
640xaf, 0xa5, 0x8a, 0xcd, 0xa2, 0xde, 0xcb, 0x0e, 0xbd, 0x8a, 0xef, 0xae, 0xfd, 0x3f, 0x1d, 0xc0, 0xd8, 0xf8, 0x3b, 0xf5,
650x02, 0x7d, 0x02, 0x41, 0x00, 0x8b, 0x26, 0xd3, 0x2c, 0x7d, 0x28, 0x38, 0x92, 0xf1, 0xbf, 0x15, 0x16, 0x39, 0x50, 0xc8,
660x6d, 0x32, 0xec, 0x28, 0xf2, 0x8b, 0xd8, 0x70, 0xc5, 0xed, 0xe1, 0x7b, 0xff, 0x2d, 0x66, 0x8c, 0x86, 0x77, 0x43, 0xeb,
670xb6, 0xf6, 0x50, 0x66, 0xb0, 0x40, 0x24, 0x6a, 0xaf, 0x98, 0x21, 0x45, 0x30, 0x01, 0x59, 0xd0, 0xc3, 0xfc, 0x7b, 0xae,
680x30, 0x18, 0xeb, 0x90, 0xfb, 0x17, 0xd3, 0xce, 0xb5
69};
70
Jeff Thompson62992e42013-10-07 18:50:51 -070071uint64_t Node::PendingInterest::lastPendingInterestId_ = 0;
72uint64_t Node::RegisteredPrefix::lastRegisteredPrefixId_ = 0;
Jeff Thompson11095142013-10-01 16:20:28 -070073
Jeff Thompsonea141d72013-09-19 14:40:10 -070074/**
75 * Set the KeyLocator using the full SELFREG_PUBLIC_KEY_DER, sign the data packet using SELFREG_PRIVATE_KEY_DER
76 * and set the signature.
77 * This is a temporary function, because we expect in the future that registerPrefix will not require a signature on the packet.
78 * @param data The Data packet to sign.
79 * @param wireFormat The WireFormat for encoding the Data packet.
80 */
81static void
82selfregSign(Data& data, WireFormat& wireFormat)
83{
84 data.setSignature(Sha256WithRsaSignature());
85 Sha256WithRsaSignature *signature = dynamic_cast<Sha256WithRsaSignature*>(data.getSignature());
86
87 // Set the public key.
Jeff Thompson10ad12a2013-09-24 16:19:11 -070088 uint8_t publicKeyDigest[SHA256_DIGEST_LENGTH];
Jeff Thompsonea141d72013-09-19 14:40:10 -070089 ndn_digestSha256(SELFREG_PUBLIC_KEY_DER, sizeof(SELFREG_PUBLIC_KEY_DER), publicKeyDigest);
Jeff Thompson43fb8222013-11-18 18:17:34 -080090 signature->getPublisherPublicKeyDigest().setPublisherPublicKeyDigest(Blob(publicKeyDigest, sizeof(publicKeyDigest)));
Jeff Thompsonea141d72013-09-19 14:40:10 -070091 signature->getKeyLocator().setType(ndn_KeyLocatorType_KEY);
Jeff Thompson43fb8222013-11-18 18:17:34 -080092 signature->getKeyLocator().setKeyData(Blob(SELFREG_PUBLIC_KEY_DER, sizeof(SELFREG_PUBLIC_KEY_DER)));
Jeff Thompsonea141d72013-09-19 14:40:10 -070093
94 // Sign the fields.
95 SignedBlob encoding = data.wireEncode(wireFormat);
Jeff Thompson10ad12a2013-09-24 16:19:11 -070096 uint8_t signedPortionDigest[SHA256_DIGEST_LENGTH];
Jeff Thompsonea141d72013-09-19 14:40:10 -070097 ndn_digestSha256(encoding.signedBuf(), encoding.signedSize(), signedPortionDigest);
Jeff Thompson10ad12a2013-09-24 16:19:11 -070098 uint8_t signatureBits[1000];
Jeff Thompsonea141d72013-09-19 14:40:10 -070099 unsigned int signatureBitsLength;
100 // Use a temporary pointer since d2i updates it.
Jeff Thompson10ad12a2013-09-24 16:19:11 -0700101 const uint8_t *derPointer = SELFREG_PRIVATE_KEY_DER;
Jeff Thompsonea141d72013-09-19 14:40:10 -0700102 RSA *privateKey = d2i_RSAPrivateKey(NULL, &derPointer, sizeof(SELFREG_PRIVATE_KEY_DER));
103 if (!privateKey)
Jeff Thompson4affbf52013-10-18 14:36:46 -0700104 throw runtime_error("Error decoding private key in d2i_RSAPrivateKey");
Jeff Thompsonea141d72013-09-19 14:40:10 -0700105 int success = RSA_sign(NID_sha256, signedPortionDigest, sizeof(signedPortionDigest), signatureBits, &signatureBitsLength, privateKey);
106 // Free the private key before checking for success.
107 RSA_free(privateKey);
108 if (!success)
Jeff Thompson4affbf52013-10-18 14:36:46 -0700109 throw runtime_error("Error in RSA_sign");
Jeff Thompsonea141d72013-09-19 14:40:10 -0700110
Jeff Thompsonfff4a372013-11-19 11:47:22 -0800111 signature->setSignature(Blob(signatureBits, (size_t)signatureBitsLength));
Jeff Thompsonea141d72013-09-19 14:40:10 -0700112}
113
Jeff Thompson590ec232013-09-18 15:55:56 -0700114Node::Node(const shared_ptr<Transport>& transport, const shared_ptr<const Transport::ConnectionInfo>& connectionInfo)
Jeff Thompsonfb29cda2013-08-24 10:26:54 -0700115: transport_(transport), connectionInfo_(connectionInfo),
116 ndndIdFetcherInterest_(Name("/%C1.M.S.localhost/%C1.M.SRV/ndnd/KEY"), 4000.0)
Jeff Thompson557b81e2013-08-21 15:13:51 -0700117{
Jeff Thompson557b81e2013-08-21 15:13:51 -0700118}
119
Jeff Thompson62992e42013-10-07 18:50:51 -0700120uint64_t
Jeff Thompson978c1522013-11-12 23:03:10 -0800121Node::expressInterest(const Interest& interest, const OnData& onData, const OnTimeout& onTimeout, WireFormat& wireFormat)
Jeff Thompsonbf50a1a2013-08-20 18:01:01 -0700122{
Jeff Thompson86507bc2013-08-23 20:51:38 -0700123 // TODO: Properly check if we are already connected to the expected host.
124 if (!transport_->getIsConnected())
125 transport_->connect(*connectionInfo_, *this);
126
Jeff Thompson62992e42013-10-07 18:50:51 -0700127 uint64_t pendingInterestId = PendingInterest::getNextPendingInterestId();
Jeff Thompson11095142013-10-01 16:20:28 -0700128 pendingInterestTable_.push_back(shared_ptr<PendingInterest>(new PendingInterest
129 (pendingInterestId, shared_ptr<const Interest>(new Interest(interest)), onData, onTimeout)));
Jeff Thompson557b81e2013-08-21 15:13:51 -0700130
Jeff Thompson978c1522013-11-12 23:03:10 -0800131 Blob encoding = interest.wireEncode(wireFormat);
Jeff Thompsonbf50a1a2013-08-20 18:01:01 -0700132 transport_->send(*encoding);
Jeff Thompson11095142013-10-01 16:20:28 -0700133
134 return pendingInterestId;
Jeff Thompsonbf50a1a2013-08-20 18:01:01 -0700135}
136
Jeff Thompson11095142013-10-01 16:20:28 -0700137void
Jeff Thompson62992e42013-10-07 18:50:51 -0700138Node::removePendingInterest(uint64_t pendingInterestId)
Jeff Thompson11095142013-10-01 16:20:28 -0700139{
140 // Go backwards through the list so we can erase entries.
141 // Remove all entries even though pendingInterestId should be unique.
142 for (int i = (int)pendingInterestTable_.size() - 1; i >= 0; --i) {
143 if (pendingInterestTable_[i]->getPendingInterestId() == pendingInterestId)
144 pendingInterestTable_.erase(pendingInterestTable_.begin() + i);
145 }
146}
147
Jeff Thompson62992e42013-10-07 18:50:51 -0700148uint64_t
Jeff Thompson590ec232013-09-18 15:55:56 -0700149Node::registerPrefix
Jeff Thompson1f8a31a2013-09-30 16:18:47 -0700150 (const Name& prefix, const OnInterest& onInterest, const OnRegisterFailed& onRegisterFailed, const ForwardingFlags& flags, WireFormat& wireFormat)
Jeff Thompson86507bc2013-08-23 20:51:38 -0700151{
Jeff Thompson11095142013-10-01 16:20:28 -0700152 // Get the registeredPrefixId now so we can return it to the caller.
Jeff Thompson62992e42013-10-07 18:50:51 -0700153 uint64_t registeredPrefixId = RegisteredPrefix::getNextRegisteredPrefixId();
Jeff Thompson11095142013-10-01 16:20:28 -0700154
Jeff Thompson86507bc2013-08-23 20:51:38 -0700155 if (ndndId_.size() == 0) {
156 // First fetch the ndndId of the connected hub.
Jeff Thompson590ec232013-09-18 15:55:56 -0700157 NdndIdFetcher fetcher
158 (shared_ptr<NdndIdFetcher::Info>(new NdndIdFetcher::Info
Jeff Thompson11095142013-10-01 16:20:28 -0700159 (this, registeredPrefixId, prefix, onInterest, onRegisterFailed, flags, wireFormat)));
Jeff Thompson86507bc2013-08-23 20:51:38 -0700160 // It is OK for func_lib::function make a copy of the function object because the Info is in a shared_ptr.
Jeff Thompson978c1522013-11-12 23:03:10 -0800161 expressInterest(ndndIdFetcherInterest_, fetcher, fetcher, wireFormat);
Jeff Thompson86507bc2013-08-23 20:51:38 -0700162 }
163 else
Jeff Thompson11095142013-10-01 16:20:28 -0700164 registerPrefixHelper(registeredPrefixId, make_shared<const Name>(prefix), onInterest, onRegisterFailed, flags, wireFormat);
165
166 return registeredPrefixId;
167}
168
169void
Jeff Thompson62992e42013-10-07 18:50:51 -0700170Node::removeRegisteredPrefix(uint64_t registeredPrefixId)
Jeff Thompson11095142013-10-01 16:20:28 -0700171{
172 // Go backwards through the list so we can erase entries.
173 // Remove all entries even though pendingInterestId should be unique.
174 for (int i = (int)registeredPrefixTable_.size() - 1; i >= 0; --i) {
175 if (registeredPrefixTable_[i]->getRegisteredPrefixId() == registeredPrefixId)
176 registeredPrefixTable_.erase(registeredPrefixTable_.begin() + i);
177 }
Jeff Thompson86507bc2013-08-23 20:51:38 -0700178}
179
Jeff Thompson0050abe2013-09-17 12:50:25 -0700180void
Jeff Thompson590ec232013-09-18 15:55:56 -0700181Node::NdndIdFetcher::operator()(const shared_ptr<const Interest>& interest, const shared_ptr<Data>& ndndIdData)
Jeff Thompson86507bc2013-08-23 20:51:38 -0700182{
Jeff Thompson03c423b2013-12-11 15:55:32 -0800183 const Sha256WithRsaSignature *signature = dynamic_cast<const Sha256WithRsaSignature*>(ndndIdData->getSignature());
Jeff Thompson20af0732013-09-12 17:01:45 -0700184 if (signature && signature->getPublisherPublicKeyDigest().getPublisherPublicKeyDigest().size() > 0) {
Jeff Thompson86507bc2013-08-23 20:51:38 -0700185 // Set the ndndId_ and continue.
Jeff Thompson7a67cb62013-08-26 11:43:18 -0700186 // TODO: If there are multiple connected hubs, the NDN ID is really stored per connected hub.
Jeff Thompson20af0732013-09-12 17:01:45 -0700187 info_->node_.ndndId_ = signature->getPublisherPublicKeyDigest().getPublisherPublicKeyDigest();
Jeff Thompson590ec232013-09-18 15:55:56 -0700188 info_->node_.registerPrefixHelper
Jeff Thompson11095142013-10-01 16:20:28 -0700189 (info_->registeredPrefixId_, info_->prefix_, info_->onInterest_, info_->onRegisterFailed_, info_->flags_, info_->wireFormat_);
Jeff Thompson86507bc2013-08-23 20:51:38 -0700190 }
Jeff Thompson590ec232013-09-18 15:55:56 -0700191 else
192 info_->onRegisterFailed_(info_->prefix_);
Jeff Thompson86507bc2013-08-23 20:51:38 -0700193}
194
Jeff Thompson0050abe2013-09-17 12:50:25 -0700195void
Jeff Thompson590ec232013-09-18 15:55:56 -0700196Node::NdndIdFetcher::operator()(const shared_ptr<const Interest>& timedOutInterest)
Jeff Thompson86507bc2013-08-23 20:51:38 -0700197{
Jeff Thompson590ec232013-09-18 15:55:56 -0700198 info_->onRegisterFailed_(info_->prefix_);
Jeff Thompson86507bc2013-08-23 20:51:38 -0700199}
200
Jeff Thompson0050abe2013-09-17 12:50:25 -0700201void
Jeff Thompson590ec232013-09-18 15:55:56 -0700202Node::registerPrefixHelper
Jeff Thompson62992e42013-10-07 18:50:51 -0700203 (uint64_t registeredPrefixId, const shared_ptr<const Name>& prefix, const OnInterest& onInterest, const OnRegisterFailed& onRegisterFailed,
Jeff Thompson1f8a31a2013-09-30 16:18:47 -0700204 const ForwardingFlags& flags, WireFormat& wireFormat)
Jeff Thompson86507bc2013-08-23 20:51:38 -0700205{
Jeff Thompson9cc4be42013-08-27 18:12:41 -0700206 // Create a ForwardingEntry.
Jeff Thompsondba5c4d2013-09-27 09:42:54 -0700207 ForwardingEntry forwardingEntry("selfreg", *prefix, PublisherPublicKeyDigest(), -1, flags, 2147483647);
Jeff Thompsonc2b7b142013-09-12 15:29:04 -0700208 Blob content = forwardingEntry.wireEncode();
Jeff Thompson9cc4be42013-08-27 18:12:41 -0700209
210 // Set the ForwardingEntry as the content of a Data packet and sign.
211 Data data;
Jeff Thompsonc2b7b142013-09-12 15:29:04 -0700212 data.setContent(content);
Jeff Thompsonfec716d2013-09-11 13:54:36 -0700213 data.getMetaInfo().setTimestampMilliseconds(time(NULL) * 1000.0);
Jeff Thompsonea141d72013-09-19 14:40:10 -0700214 // For now, self sign with an arbirary key. In the future, we may not require a signature to register.
215 selfregSign(data, wireFormat);
Jeff Thompsonc2b7b142013-09-12 15:29:04 -0700216 Blob encodedData = data.wireEncode();
Jeff Thompson9cc4be42013-08-27 18:12:41 -0700217
218 // Create an interest where the name has the encoded Data packet.
219 Name interestName;
Jeff Thompson10ad12a2013-09-24 16:19:11 -0700220 const uint8_t component0[] = "ndnx";
221 const uint8_t component2[] = "selfreg";
Jeff Thompson3a715632013-10-31 11:36:35 -0700222 interestName.append(component0, sizeof(component0) - 1);
223 interestName.append(ndndId_);
224 interestName.append(component2, sizeof(component2) - 1);
225 interestName.append(encodedData);
Jeff Thompson9cc4be42013-08-27 18:12:41 -0700226
227 Interest interest(interestName);
228 interest.setScope(1);
Jeff Thompsonc2b7b142013-09-12 15:29:04 -0700229 Blob encodedInterest = interest.wireEncode();
Jeff Thompson9cc4be42013-08-27 18:12:41 -0700230
231 // Save the onInterest callback and send the registration interest.
Jeff Thompson11095142013-10-01 16:20:28 -0700232 registeredPrefixTable_.push_back(shared_ptr<RegisteredPrefix>(new RegisteredPrefix(registeredPrefixId, prefix, onInterest)));
Jeff Thompson9cc4be42013-08-27 18:12:41 -0700233
234 transport_->send(*encodedInterest);
Jeff Thompson86507bc2013-08-23 20:51:38 -0700235}
236
Jeff Thompson0050abe2013-09-17 12:50:25 -0700237void
238Node::processEvents()
Jeff Thompsonbf50a1a2013-08-20 18:01:01 -0700239{
240 transport_->processEvents();
Jeff Thompson48917f02013-08-21 17:12:45 -0700241
242 // Check for PIT entry timeouts. Go backwards through the list so we can erase entries.
Jeff Thompson9a8e82f2013-10-17 14:13:43 -0700243 MillisecondsSince1970 nowMilliseconds = ndn_getNowMilliseconds();
Jeff Thompson11095142013-10-01 16:20:28 -0700244 for (int i = (int)pendingInterestTable_.size() - 1; i >= 0; --i) {
Jeff Thompson3b0ed532013-11-05 13:43:40 -0800245 if (pendingInterestTable_[i]->isTimedOut(nowMilliseconds)) {
246 // Save the PendingInterest and remove it from the PIT. Then call the callback.
247 shared_ptr<PendingInterest> pendingInterest = pendingInterestTable_[i];
Jeff Thompson11095142013-10-01 16:20:28 -0700248 pendingInterestTable_.erase(pendingInterestTable_.begin() + i);
Jeff Thompson3b0ed532013-11-05 13:43:40 -0800249 pendingInterest->callTimeout();
Jeff Thompson48917f02013-08-21 17:12:45 -0700250
251 // Refresh now since the timeout callback might have delayed.
Jeff Thompson9ae4d782013-10-17 10:25:54 -0700252 nowMilliseconds = ndn_getNowMilliseconds();
Jeff Thompson48917f02013-08-21 17:12:45 -0700253 }
254 }
Jeff Thompsonbf50a1a2013-08-20 18:01:01 -0700255}
256
Jeff Thompson0050abe2013-09-17 12:50:25 -0700257void
Jeff Thompson97223af2013-09-24 17:01:27 -0700258Node::onReceivedElement(const uint8_t *element, size_t elementLength)
Jeff Thompsonbf50a1a2013-08-20 18:01:01 -0700259{
260 BinaryXmlDecoder decoder(element, elementLength);
261
Jeff Thompson9cc4be42013-08-27 18:12:41 -0700262 if (decoder.peekDTag(ndn_BinaryXml_DTag_Interest)) {
263 shared_ptr<Interest> interest(new Interest());
264 interest->wireDecode(element, elementLength);
265
Jeff Thompson11095142013-10-01 16:20:28 -0700266 RegisteredPrefix *entry = getEntryForRegisteredPrefix(interest->getName());
Jeff Thompson9cc4be42013-08-27 18:12:41 -0700267 if (entry)
Jeff Thompsonb510e3e2013-10-07 18:53:20 -0700268 entry->getOnInterest()(entry->getPrefix(), interest, *transport_, entry->getRegisteredPrefixId());
Jeff Thompson9cc4be42013-08-27 18:12:41 -0700269 }
270 else if (decoder.peekDTag(ndn_BinaryXml_DTag_ContentObject)) {
Jeff Thompsonbf50a1a2013-08-20 18:01:01 -0700271 shared_ptr<Data> data(new Data());
272 data->wireDecode(element, elementLength);
273
Jeff Thompson557b81e2013-08-21 15:13:51 -0700274 int iPitEntry = getEntryIndexForExpressedInterest(data->getName());
275 if (iPitEntry >= 0) {
Jeff Thompson7aec0252013-08-22 17:29:57 -0700276 // Copy pointers to the needed objects and remove the PIT entry before the calling the callback.
Jeff Thompson11095142013-10-01 16:20:28 -0700277 const OnData onData = pendingInterestTable_[iPitEntry]->getOnData();
278 const shared_ptr<const Interest> interest = pendingInterestTable_[iPitEntry]->getInterest();
279 pendingInterestTable_.erase(pendingInterestTable_.begin() + iPitEntry);
Jeff Thompson7aec0252013-08-22 17:29:57 -0700280 onData(interest, data);
Jeff Thompson557b81e2013-08-21 15:13:51 -0700281 }
Jeff Thompsonbf50a1a2013-08-20 18:01:01 -0700282 }
283}
284
Jeff Thompson0050abe2013-09-17 12:50:25 -0700285void
286Node::shutdown()
Jeff Thompsonbf50a1a2013-08-20 18:01:01 -0700287{
288 transport_->close();
289}
290
Jeff Thompson0050abe2013-09-17 12:50:25 -0700291int
292Node::getEntryIndexForExpressedInterest(const Name& name)
Jeff Thompson557b81e2013-08-21 15:13:51 -0700293{
294 // TODO: Doesn't this belong in the Name class?
295 vector<struct ndn_NameComponent> nameComponents;
296 nameComponents.reserve(name.getComponentCount());
297 struct ndn_Name nameStruct;
Jeff Thompsond1427fb2013-08-29 17:20:32 -0700298 ndn_Name_initialize(&nameStruct, &nameComponents[0], nameComponents.capacity());
Jeff Thompson557b81e2013-08-21 15:13:51 -0700299 name.get(nameStruct);
300
301 int iResult = -1;
302
Jeff Thompsone589c3f2013-10-12 17:30:50 -0700303 for (size_t i = 0; i < pendingInterestTable_.size(); ++i) {
304 if (ndn_Interest_matchesName((struct ndn_Interest *)&pendingInterestTable_[i]->getInterestStruct(), &nameStruct)) {
Jeff Thompson557b81e2013-08-21 15:13:51 -0700305 if (iResult < 0 ||
Jeff Thompson11095142013-10-01 16:20:28 -0700306 pendingInterestTable_[i]->getInterestStruct().name.nComponents >
307 pendingInterestTable_[iResult]->getInterestStruct().name.nComponents)
Jeff Thompson48917f02013-08-21 17:12:45 -0700308 // Update to the longer match.
Jeff Thompson557b81e2013-08-21 15:13:51 -0700309 iResult = i;
310 }
Jeff Thompsone589c3f2013-10-12 17:30:50 -0700311 }
Jeff Thompson557b81e2013-08-21 15:13:51 -0700312
Jeff Thompsone589c3f2013-10-12 17:30:50 -0700313 return iResult;
Jeff Thompson557b81e2013-08-21 15:13:51 -0700314}
Jeff Thompson86507bc2013-08-23 20:51:38 -0700315
Jeff Thompson11095142013-10-01 16:20:28 -0700316Node::RegisteredPrefix*
Jeff Thompson0050abe2013-09-17 12:50:25 -0700317Node::getEntryForRegisteredPrefix(const Name& name)
Jeff Thompson9cc4be42013-08-27 18:12:41 -0700318{
319 int iResult = -1;
320
Jeff Thompsone589c3f2013-10-12 17:30:50 -0700321 for (size_t i = 0; i < registeredPrefixTable_.size(); ++i) {
322 if (registeredPrefixTable_[i]->getPrefix()->match(name)) {
Jeff Thompson9cc4be42013-08-27 18:12:41 -0700323 if (iResult < 0 ||
324 registeredPrefixTable_[i]->getPrefix()->getComponentCount() > registeredPrefixTable_[iResult]->getPrefix()->getComponentCount())
325 // Update to the longer match.
326 iResult = i;
327 }
Jeff Thompsone589c3f2013-10-12 17:30:50 -0700328 }
Jeff Thompson9cc4be42013-08-27 18:12:41 -0700329
330 if (iResult >= 0)
Jeff Thompsone589c3f2013-10-12 17:30:50 -0700331 return registeredPrefixTable_[iResult].get();
Jeff Thompson9cc4be42013-08-27 18:12:41 -0700332 else
333 return 0;
334}
335
Jeff Thompson11095142013-10-01 16:20:28 -0700336Node::PendingInterest::PendingInterest
Jeff Thompson62992e42013-10-07 18:50:51 -0700337 (uint64_t pendingInterestId, const shared_ptr<const Interest>& interest, const OnData& onData, const OnTimeout& onTimeout)
Jeff Thompson25b4e612013-10-10 16:03:24 -0700338: pendingInterestId_(pendingInterestId), interest_(interest), onData_(onData), onTimeout_(onTimeout),
339 interestStruct_(new struct ndn_Interest)
Jeff Thompson86507bc2013-08-23 20:51:38 -0700340{
341 // Set up timeoutTime_.
342 if (interest_->getInterestLifetimeMilliseconds() >= 0.0)
Jeff Thompson9ae4d782013-10-17 10:25:54 -0700343 timeoutTimeMilliseconds_ = ndn_getNowMilliseconds() + interest_->getInterestLifetimeMilliseconds();
Jeff Thompson86507bc2013-08-23 20:51:38 -0700344 else
345 // No timeout.
346 timeoutTimeMilliseconds_ = -1.0;
347
348 // Set up interestStruct_.
349 // TODO: Doesn't this belong in the Interest class?
350 nameComponents_.reserve(interest_->getName().getComponentCount());
Jeff Thompsonf62f9f22013-11-26 17:22:54 -0800351 excludeEntries_.reserve(interest_->getExclude().size());
Jeff Thompsond1427fb2013-08-29 17:20:32 -0700352 ndn_Interest_initialize
Jeff Thompson25b4e612013-10-10 16:03:24 -0700353 (interestStruct_.get(), &nameComponents_[0], nameComponents_.capacity(), &excludeEntries_[0], excludeEntries_.capacity());
354 interest_->get(*interestStruct_);
Jeff Thompson86507bc2013-08-23 20:51:38 -0700355}
356
Jeff Thompson3b0ed532013-11-05 13:43:40 -0800357void
358Node::PendingInterest::callTimeout()
Jeff Thompson86507bc2013-08-23 20:51:38 -0700359{
Jeff Thompson3b0ed532013-11-05 13:43:40 -0800360 if (onTimeout_) {
361 // Ignore all exceptions.
362 try {
363 onTimeout_(interest_);
Jeff Thompson86507bc2013-08-23 20:51:38 -0700364 }
Jeff Thompson3b0ed532013-11-05 13:43:40 -0800365 catch (...) { }
Jeff Thompson86507bc2013-08-23 20:51:38 -0700366 }
Jeff Thompson86507bc2013-08-23 20:51:38 -0700367}
Jeff Thompson557b81e2013-08-21 15:13:51 -0700368
Jeff Thompsonbf50a1a2013-08-20 18:01:01 -0700369}