blob: c17f1bd85b81ca39548ee87d99c7e08cce125d73 [file] [log] [blame]
Eric Newberry261dbc22015-07-22 23:18:18 -07001/* -*- Mode:C++; c-file-style:"gnu"; indent-tabs-mode:nil; -*- */
2/**
Eric Newberry8422f572017-02-04 21:53:58 -07003 * Copyright (c) 2013-2017 Regents of the University of California.
Eric Newberry261dbc22015-07-22 23:18:18 -07004 *
5 * This file is part of ndn-cxx library (NDN C++ library with eXperimental eXtensions).
6 *
7 * ndn-cxx library is free software: you can redistribute it and/or modify it under the
8 * terms of the GNU Lesser General Public License as published by the Free Software
9 * Foundation, either version 3 of the License, or (at your option) any later version.
10 *
11 * ndn-cxx library is distributed in the hope that it will be useful, but WITHOUT ANY
12 * WARRANTY; without even the implied warranty of MERCHANTABILITY or FITNESS FOR A
13 * PARTICULAR PURPOSE. See the GNU Lesser General Public License for more details.
14 *
15 * You should have received copies of the GNU General Public License and GNU Lesser
16 * General Public License along with ndn-cxx, e.g., in COPYING.md file. If not, see
17 * <http://www.gnu.org/licenses/>.
18 *
19 * See AUTHORS.md for complete list of ndn-cxx authors and contributors.
20 */
21
22#include "packet.hpp"
23#include "detail/field-info.hpp"
24
25#include <boost/range/adaptor/reversed.hpp>
26
27namespace ndn {
28namespace lp {
29
30Packet::Packet()
31 : m_wire(Block(tlv::LpPacket))
32{
33}
34
35Packet::Packet(const Block& wire)
36{
37 wireDecode(wire);
38}
39
40template<encoding::Tag TAG>
41size_t
42Packet::wireEncode(EncodingImpl<TAG>& encoder) const
43{
44 if (m_wire.hasWire()) {
45 return m_wire.size();
46 }
47
48 size_t length = 0;
49
50 for (const Block& element : boost::adaptors::reverse(m_wire.elements())) {
51 length += encoder.prependBlock(element);
52 }
53
54 length += encoder.prependVarNumber(length);
55 length += encoder.prependVarNumber(tlv::LpPacket);
56
57 return length;
58}
59
60template size_t
61Packet::wireEncode<encoding::EncoderTag>(EncodingImpl<encoding::EncoderTag>& encoder) const;
62
63template size_t
64Packet::wireEncode<encoding::EstimatorTag>(EncodingImpl<encoding::EstimatorTag>& encoder) const;
65
Eric Newberry82838be2015-11-07 13:00:35 -070066Block
Eric Newberry261dbc22015-07-22 23:18:18 -070067Packet::wireEncode() const
68{
69 if (m_wire.hasWire()) {
70 return m_wire;
71 }
72
Eric Newberry83872fd2015-08-06 17:01:24 -070073 // If no header or trailer, return bare network packet
74 Block::element_container elements = m_wire.elements();
75 if (elements.size() == 1 && elements.front().type() == FragmentField::TlvType::value) {
76 elements.front().parse();
77 elements.front().elements().front().parse();
78 return elements.front().elements().front();
79 }
80
Eric Newberry261dbc22015-07-22 23:18:18 -070081 EncodingEstimator estimator;
82 size_t estimatedSize = wireEncode(estimator);
83
84 EncodingBuffer buffer(estimatedSize, 0);
85 wireEncode(buffer);
86
87 m_wire = buffer.block();
88 return m_wire;
89}
90
91void
92Packet::wireDecode(const Block& wire)
93{
94 if (wire.type() == ndn::tlv::Interest || wire.type() == ndn::tlv::Data) {
95 m_wire = Block(tlv::LpPacket);
96 add<FragmentField>(make_pair(wire.begin(), wire.end()));
97 return;
98 }
99
Eric Newberry43bf6bb2015-10-09 16:12:09 -0700100 if (wire.type() != tlv::LpPacket) {
101 BOOST_THROW_EXCEPTION(Error("unrecognized TLV-TYPE " + to_string(wire.type())));
102 }
103
Eric Newberry261dbc22015-07-22 23:18:18 -0700104 wire.parse();
105
106 bool isFirst = true;
107 detail::FieldInfo prev;
108 for (const Block& element : wire.elements()) {
109 detail::FieldInfo info(element.type());
110
111 if (!info.isRecognized && !info.canIgnore) {
Eric Newberry3ed62472016-12-11 22:11:38 -0700112 BOOST_THROW_EXCEPTION(Error("unrecognized field " + to_string(element.type()) + " cannot be ignored"));
Eric Newberry261dbc22015-07-22 23:18:18 -0700113 }
114
115 if (!isFirst) {
116 if (info.tlvType == prev.tlvType && !info.isRepeatable) {
Eric Newberry3ed62472016-12-11 22:11:38 -0700117 BOOST_THROW_EXCEPTION(Error("non-repeatable field " + to_string(element.type()) + " cannot be repeated"));
Eric Newberry261dbc22015-07-22 23:18:18 -0700118 }
119
120 else if (info.tlvType != prev.tlvType && !detail::compareFieldSortOrder(prev, info)) {
Spyridon Mastorakis0d2ed2e2015-07-27 19:09:12 -0700121 BOOST_THROW_EXCEPTION(Error("fields are not in correct sort order"));
Eric Newberry261dbc22015-07-22 23:18:18 -0700122 }
123 }
124
125 isFirst = false;
126 prev = info;
127 }
128
129 m_wire = wire;
130}
131
132bool
Eric Newberry8422f572017-02-04 21:53:58 -0700133Packet::comparePos(uint64_t first, const Block& second)
Eric Newberry261dbc22015-07-22 23:18:18 -0700134{
Eric Newberry8422f572017-02-04 21:53:58 -0700135 detail::FieldInfo firstInfo(first);
136 detail::FieldInfo secondInfo(second.type());
Eric Newberry261dbc22015-07-22 23:18:18 -0700137 return detail::compareFieldSortOrder(firstInfo, secondInfo);
138}
139
140} // namespace lp
Spyridon Mastorakis0d2ed2e2015-07-27 19:09:12 -0700141} // namespace ndn