Packet.hpp 31 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213214215216217218219220221222223224225226227228229230231232233234235236237238239240241242243244245246247248249250251252253254255256257258259260261262263264265266267268269270271272273274275276277278279280281282283284285286287288289290291292293294295296297298299300301302303304305306307308309310311312313314315316317318319320321322323324325326327328329330331332333334335336337338339340341342343344345346347348349350351352353354355356357358359360361362363364365366367368369370371372373374375376377378379380381382383384385386387388389390391392393394395396397398399400401402403404405406407408409410411412413414415416417418419420421422423424425426427428429430431432433434435436437438439440441442443444445446447448449450451452453454455456457458459460461462463464465466467468469470471472473474475476477478479480481482483484485486487488489490491492493494495496497498499500501502503504505506507508509510511512513514515516517518519520521522523524525526527528529530531532533534535536537538539540541542543544545546547548549550551552553554555556557558559560561562563564565566567568569570571572573574575576577578579580581582583584585586587588589590591592593594595596597598599600601602603604605606607608609610611612613614615616617618619620621622623624625626627628629630631632633634635636637638639640641642643644645646647648649650651652653654655656657658659660661662663664665666667668669670671672673674675676677678679680681682683684685686687688689690691692693694695696697698699700701702703704705706707708709710711712713714715716717718719720721722723724725726727728729730731732733734735736737738739740741742743744745746747748749750751752753754755756757758759760761762763764765766767768769770771772773774775776777778779780781782783784785786787788789790791792793794795796797798799800801802803804805806807808809810811812813814815816817818819820821822823824825826827828829830831832833834835836837838839840841842843844845846847848849850851852853854855856857858859860861862863864865866867868869870871872873874875876877878879880881882883884885886887888889890891892893894895896897898899900901902903904905906907908909910911912913914915916917918919920921922923924925926927
  1. /*
  2. * ZeroTier One - Global Peer to Peer Ethernet
  3. * Copyright (C) 2012-2013 ZeroTier Networks LLC
  4. *
  5. * This program is free software: you can redistribute it and/or modify
  6. * it under the terms of the GNU General Public License as published by
  7. * the Free Software Foundation, either version 3 of the License, or
  8. * (at your option) any later version.
  9. *
  10. * This program is distributed in the hope that it will be useful,
  11. * but WITHOUT ANY WARRANTY; without even the implied warranty of
  12. * MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the
  13. * GNU General Public License for more details.
  14. *
  15. * You should have received a copy of the GNU General Public License
  16. * along with this program. If not, see <http://www.gnu.org/licenses/>.
  17. *
  18. * --
  19. *
  20. * ZeroTier may be used and distributed under the terms of the GPLv3, which
  21. * are available at: http://www.gnu.org/licenses/gpl-3.0.html
  22. *
  23. * If you would like to embed ZeroTier into a commercial application or
  24. * redistribute it in a modified binary form, please contact ZeroTier Networks
  25. * LLC. Start here: http://www.zerotier.com/
  26. */
  27. #ifndef _ZT_N_PACKET_HPP
  28. #define _ZT_N_PACKET_HPP
  29. #include <stdint.h>
  30. #include <string.h>
  31. #include <stdio.h>
  32. #include <string>
  33. #include <iostream>
  34. #include "Address.hpp"
  35. #include "HMAC.hpp"
  36. #include "Salsa20.hpp"
  37. #include "Utils.hpp"
  38. #include "Constants.hpp"
  39. #include "Buffer.hpp"
  40. #include "../ext/lz4/lz4.h"
  41. /**
  42. * Protocol version
  43. *
  44. * 1 - 0.2.0 ... 0.2.5
  45. * 2 - 0.3.0 ...
  46. * * Added signature and originating peer to multicast frame
  47. * * Double size of multicast frame bloom filter
  48. */
  49. #define ZT_PROTO_VERSION 2
  50. /**
  51. * Maximum hop count allowed by packet structure (3 bits, 0-7)
  52. *
  53. * This is not necessarily the maximum hop counter after which
  54. * relaying is no longer performed.
  55. */
  56. #define ZT_PROTO_MAX_HOPS 7
  57. /**
  58. * Header flag indicating that a packet is encrypted with Salsa20
  59. *
  60. * If this is not set, then the packet's payload is in the clear and the
  61. * HMAC is over this (since there is no ciphertext). Otherwise the HMAC is
  62. * of the ciphertext after encryption.
  63. */
  64. #define ZT_PROTO_FLAG_ENCRYPTED 0x80
  65. /**
  66. * Header flag indicating that a packet is fragmented
  67. *
  68. * If this flag is set, the receiver knows to expect more than one fragment.
  69. * See Packet::Fragment for details.
  70. */
  71. #define ZT_PROTO_FLAG_FRAGMENTED 0x40
  72. /**
  73. * Verb flag indicating payload is compressed with LZ4
  74. */
  75. #define ZT_PROTO_VERB_FLAG_COMPRESSED 0x80
  76. // Indices of fields in normal packet header -- do not change as this
  77. // might require both code rework and will break compatibility.
  78. #define ZT_PACKET_IDX_IV 0
  79. #define ZT_PACKET_IDX_DEST 8
  80. #define ZT_PACKET_IDX_SOURCE 13
  81. #define ZT_PACKET_IDX_FLAGS 18
  82. #define ZT_PACKET_IDX_HMAC 19
  83. #define ZT_PACKET_IDX_VERB 27
  84. #define ZT_PACKET_IDX_PAYLOAD 28
  85. /**
  86. * ZeroTier packet buffer size
  87. *
  88. * This can be changed. This provides enough room for MTU-size packet
  89. * payloads plus some overhead. The subtraction of sizeof(unsigned int)
  90. * makes it an even multiple of 1024 (see Buffer), which might reduce
  91. * memory use a little.
  92. */
  93. #define ZT_PROTO_MAX_PACKET_LENGTH (3072 - sizeof(unsigned int))
  94. /**
  95. * Minimum viable packet length (also length of header)
  96. */
  97. #define ZT_PROTO_MIN_PACKET_LENGTH ZT_PACKET_IDX_PAYLOAD
  98. // Indexes of fields in fragment header -- also can't be changed without
  99. // breaking compatibility.
  100. #define ZT_PACKET_FRAGMENT_IDX_PACKET_ID 0
  101. #define ZT_PACKET_FRAGMENT_IDX_DEST 8
  102. #define ZT_PACKET_FRAGMENT_IDX_FRAGMENT_INDICATOR 13
  103. #define ZT_PACKET_FRAGMENT_IDX_FRAGMENT_NO 14
  104. #define ZT_PACKET_FRAGMENT_IDX_HOPS 15
  105. #define ZT_PACKET_FRAGMENT_IDX_PAYLOAD 16
  106. /**
  107. * Value found at ZT_PACKET_FRAGMENT_IDX_FRAGMENT_INDICATOR in fragments
  108. */
  109. #define ZT_PACKET_FRAGMENT_INDICATOR ZT_ADDRESS_RESERVED_PREFIX
  110. /**
  111. * Minimum viable fragment length
  112. */
  113. #define ZT_PROTO_MIN_FRAGMENT_LENGTH ZT_PACKET_FRAGMENT_IDX_PAYLOAD
  114. // Size of bloom filter used in multicast propagation
  115. #define ZT_PROTO_VERB_MULTICAST_FRAME_BLOOM_FILTER_SIZE_BITS 512
  116. #define ZT_PROTO_VERB_MULTICAST_FRAME_BLOOM_FILTER_SIZE_BYTES 64
  117. // Field incides for parsing verbs
  118. #define ZT_PROTO_VERB_HELLO_IDX_PROTOCOL_VERSION (ZT_PACKET_IDX_PAYLOAD)
  119. #define ZT_PROTO_VERB_HELLO_IDX_MAJOR_VERSION (ZT_PROTO_VERB_HELLO_IDX_PROTOCOL_VERSION + 1)
  120. #define ZT_PROTO_VERB_HELLO_IDX_MINOR_VERSION (ZT_PROTO_VERB_HELLO_IDX_MAJOR_VERSION + 1)
  121. #define ZT_PROTO_VERB_HELLO_IDX_REVISION (ZT_PROTO_VERB_HELLO_IDX_MINOR_VERSION + 1)
  122. #define ZT_PROTO_VERB_HELLO_IDX_TIMESTAMP (ZT_PROTO_VERB_HELLO_IDX_REVISION + 2)
  123. #define ZT_PROTO_VERB_HELLO_IDX_IDENTITY (ZT_PROTO_VERB_HELLO_IDX_TIMESTAMP + 8)
  124. #define ZT_PROTO_VERB_ERROR_IDX_IN_RE_VERB (ZT_PACKET_IDX_PAYLOAD)
  125. #define ZT_PROTO_VERB_ERROR_IDX_IN_RE_PACKET_ID (ZT_PROTO_VERB_ERROR_IDX_IN_RE_VERB + 1)
  126. #define ZT_PROTO_VERB_ERROR_IDX_ERROR_CODE (ZT_PROTO_VERB_ERROR_IDX_IN_RE_PACKET_ID + 8)
  127. #define ZT_PROTO_VERB_ERROR_IDX_PAYLOAD (ZT_PROTO_VERB_ERROR_IDX_ERROR_CODE + 1)
  128. #define ZT_PROTO_VERB_OK_IDX_IN_RE_VERB (ZT_PACKET_IDX_PAYLOAD)
  129. #define ZT_PROTO_VERB_OK_IDX_IN_RE_PACKET_ID (ZT_PROTO_VERB_OK_IDX_IN_RE_VERB + 1)
  130. #define ZT_PROTO_VERB_OK_IDX_PAYLOAD (ZT_PROTO_VERB_OK_IDX_IN_RE_PACKET_ID + 8)
  131. #define ZT_PROTO_VERB_WHOIS_IDX_ZTADDRESS (ZT_PACKET_IDX_PAYLOAD)
  132. #define ZT_PROTO_VERB_RENDEZVOUS_IDX_ZTADDRESS (ZT_PACKET_IDX_PAYLOAD)
  133. #define ZT_PROTO_VERB_RENDEZVOUS_IDX_PORT (ZT_PROTO_VERB_RENDEZVOUS_IDX_ZTADDRESS + 5)
  134. #define ZT_PROTO_VERB_RENDEZVOUS_IDX_ADDRLEN (ZT_PROTO_VERB_RENDEZVOUS_IDX_PORT + 2)
  135. #define ZT_PROTO_VERB_RENDEZVOUS_IDX_ADDRESS (ZT_PROTO_VERB_RENDEZVOUS_IDX_ADDRLEN + 1)
  136. #define ZT_PROTO_VERB_FRAME_IDX_NETWORK_ID (ZT_PACKET_IDX_PAYLOAD)
  137. #define ZT_PROTO_VERB_FRAME_IDX_ETHERTYPE (ZT_PROTO_VERB_FRAME_IDX_NETWORK_ID + 8)
  138. #define ZT_PROTO_VERB_FRAME_IDX_PAYLOAD (ZT_PROTO_VERB_FRAME_IDX_ETHERTYPE + 2)
  139. #define ZT_PROTO_VERB_MULTICAST_FRAME_IDX_FLAGS (ZT_PACKET_IDX_PAYLOAD)
  140. #define ZT_PROTO_VERB_MULTICAST_FRAME_IDX_NETWORK_ID (ZT_PROTO_VERB_MULTICAST_FRAME_IDX_FLAGS + 1)
  141. #define ZT_PROTO_VERB_MULTICAST_FRAME_IDX_SUBMITTER_ADDRESS (ZT_PROTO_VERB_MULTICAST_FRAME_IDX_NETWORK_ID + 8)
  142. #define ZT_PROTO_VERB_MULTICAST_FRAME_IDX_SOURCE_MAC (ZT_PROTO_VERB_MULTICAST_FRAME_IDX_SUBMITTER_ADDRESS + 5)
  143. #define ZT_PROTO_VERB_MULTICAST_FRAME_IDX_DESTINATION_MAC (ZT_PROTO_VERB_MULTICAST_FRAME_IDX_SOURCE_MAC + 6)
  144. #define ZT_PROTO_VERB_MULTICAST_FRAME_IDX_ADI (ZT_PROTO_VERB_MULTICAST_FRAME_IDX_DESTINATION_MAC + 6)
  145. #define ZT_PROTO_VERB_MULTICAST_FRAME_IDX_BLOOM_FILTER (ZT_PROTO_VERB_MULTICAST_FRAME_IDX_ADI + 4)
  146. #define ZT_PROTO_VERB_MULTICAST_FRAME_IDX_HOP_COUNT (ZT_PROTO_VERB_MULTICAST_FRAME_IDX_BLOOM_FILTER + 64)
  147. #define ZT_PROTO_VERB_MULTICAST_FRAME_IDX_ETHERTYPE (ZT_PROTO_VERB_MULTICAST_FRAME_IDX_HOP_COUNT + 1)
  148. #define ZT_PROTO_VERB_MULTICAST_FRAME_IDX_PAYLOAD_LENGTH (ZT_PROTO_VERB_MULTICAST_FRAME_IDX_ETHERTYPE + 2)
  149. #define ZT_PROTO_VERB_MULTICAST_FRAME_IDX_SIGNATURE_LENGTH (ZT_PROTO_VERB_MULTICAST_FRAME_IDX_PAYLOAD_LENGTH + 2)
  150. #define ZT_PROTO_VERB_MULTICAST_FRAME_IDX_PAYLOAD (ZT_PROTO_VERB_MULTICAST_FRAME_IDX_SIGNATURE_LENGTH + 2)
  151. #define ZT_PROTO_VERB_NETWORK_CONFIG_REQUEST_IDX_NETWORK_ID (ZT_PACKET_IDX_PAYLOAD)
  152. #define ZT_PROTO_VERB_NETWORK_CONFIG_REQUEST_IDX_DICT_LEN (ZT_PROTO_VERB_NETWORK_CONFIG_REQUEST_IDX_NETWORK_ID + 8)
  153. #define ZT_PROTO_VERB_NETWORK_CONFIG_REQUEST_IDX_DICT (ZT_PROTO_VERB_NETWORK_CONFIG_REQUEST_IDX_DICT_LEN + 2)
  154. #define ZT_PROTO_VERB_NETWORK_CONFIG_REFRESH_IDX_NETWORK_ID (ZT_PACKET_IDX_PAYLOAD)
  155. // Field indices for parsing OK and ERROR payloads of replies
  156. #define ZT_PROTO_VERB_HELLO__OK__IDX_TIMESTAMP (ZT_PROTO_VERB_OK_IDX_PAYLOAD)
  157. #define ZT_PROTO_VERB_WHOIS__OK__IDX_IDENTITY (ZT_PROTO_VERB_OK_IDX_PAYLOAD)
  158. #define ZT_PROTO_VERB_WHOIS__ERROR__IDX_ZTADDRESS (ZT_PROTO_VERB_ERROR_IDX_PAYLOAD)
  159. namespace ZeroTier {
  160. /**
  161. * ZeroTier packet
  162. *
  163. * Packet format:
  164. * <[8] random initialization vector (doubles as 64-bit packet ID)>
  165. * <[5] destination ZT address>
  166. * <[5] source ZT address>
  167. * <[1] flags (LS 5 bits) and ZT hop count (MS 3 bits)>
  168. * <[8] first 8 bytes of 32-byte HMAC-SHA-256 MAC>
  169. * [... -- begin encryption envelope -- ...]
  170. * <[1] encrypted flags (MS 3 bits) and verb (LS 5 bits)>
  171. * [... verb-specific payload ...]
  172. *
  173. * Packets smaller than 28 bytes are invalid and silently discarded.
  174. *
  175. * MAC is computed on ciphertext *after* encryption. See also:
  176. *
  177. * http://tonyarcieri.com/all-the-crypto-code-youve-ever-written-is-probably-broken
  178. *
  179. * For unencrypted packets, MAC is computed on plaintext. Only HELLO is ever
  180. * sent in the clear, as it's the "here is my public key" message.
  181. */
  182. class Packet : public Buffer<ZT_PROTO_MAX_PACKET_LENGTH>
  183. {
  184. public:
  185. /**
  186. * A packet fragment
  187. *
  188. * Fragments are sent if a packet is larger than UDP MTU. The first fragment
  189. * is sent with its normal header with the fragmented flag set. Remaining
  190. * fragments are sent this way.
  191. *
  192. * The fragmented bit indicates that there is at least one fragment. Fragments
  193. * themselves contain the total, so the receiver must "learn" this from the
  194. * first fragment it receives.
  195. *
  196. * Fragments are sent with the following format:
  197. * <[8] packet ID of packet whose fragment this belongs to>
  198. * <[5] destination ZT address>
  199. * <[1] 0xff, a reserved address, signals that this isn't a normal packet>
  200. * <[1] total fragments (most significant 4 bits), fragment no (LS 4 bits)>
  201. * <[1] ZT hop count>
  202. * <[...] fragment data>
  203. *
  204. * The protocol supports a maximum of 16 fragments. If a fragment is received
  205. * before its main packet header, it should be cached for a brief period of
  206. * time to see if its parent arrives. Loss of any fragment constitutes packet
  207. * loss; there is no retransmission mechanism. The receiver must wait for full
  208. * receipt to authenticate and decrypt; there is no per-fragment MAC. (But if
  209. * fragments are corrupt, the MAC will fail for the whole assembled packet.)
  210. */
  211. class Fragment : public Buffer<ZT_PROTO_MAX_PACKET_LENGTH>
  212. {
  213. public:
  214. Fragment() :
  215. Buffer<ZT_PROTO_MAX_PACKET_LENGTH>()
  216. {
  217. }
  218. template<unsigned int C2>
  219. Fragment(const Buffer<C2> &b)
  220. throw(std::out_of_range) :
  221. Buffer<ZT_PROTO_MAX_PACKET_LENGTH>(b)
  222. {
  223. }
  224. /**
  225. * Initialize from a packet
  226. *
  227. * @param p Original assembled packet
  228. * @param fragStart Start of fragment (raw index in packet data)
  229. * @param fragLen Length of fragment in bytes
  230. * @param fragNo Which fragment (>= 1, since 0 is Packet with end chopped off)
  231. * @param fragTotal Total number of fragments (including 0)
  232. * @throws std::out_of_range Packet size would exceed buffer
  233. */
  234. Fragment(const Packet &p,unsigned int fragStart,unsigned int fragLen,unsigned int fragNo,unsigned int fragTotal)
  235. throw(std::out_of_range)
  236. {
  237. init(p,fragStart,fragLen,fragNo,fragTotal);
  238. }
  239. /**
  240. * Initialize from a packet
  241. *
  242. * @param p Original assembled packet
  243. * @param fragStart Start of fragment (raw index in packet data)
  244. * @param fragLen Length of fragment in bytes
  245. * @param fragNo Which fragment (>= 1, since 0 is Packet with end chopped off)
  246. * @param fragTotal Total number of fragments (including 0)
  247. * @throws std::out_of_range Packet size would exceed buffer
  248. */
  249. inline void init(const Packet &p,unsigned int fragStart,unsigned int fragLen,unsigned int fragNo,unsigned int fragTotal)
  250. throw(std::out_of_range)
  251. {
  252. if ((fragStart + fragLen) > p.size())
  253. throw std::out_of_range("Packet::Fragment: tried to construct fragment of packet past its length");
  254. setSize(fragLen + ZT_PROTO_MIN_FRAGMENT_LENGTH);
  255. // NOTE: this copies both the IV/packet ID and the destination address.
  256. memcpy(field(ZT_PACKET_FRAGMENT_IDX_PACKET_ID,13),p.data() + ZT_PACKET_IDX_IV,13);
  257. (*this)[ZT_PACKET_FRAGMENT_IDX_FRAGMENT_INDICATOR] = ZT_PACKET_FRAGMENT_INDICATOR;
  258. (*this)[ZT_PACKET_FRAGMENT_IDX_FRAGMENT_NO] = (char)(((fragTotal & 0xf) << 4) | (fragNo & 0xf));
  259. (*this)[ZT_PACKET_FRAGMENT_IDX_HOPS] = 0;
  260. memcpy(field(ZT_PACKET_FRAGMENT_IDX_PAYLOAD,fragLen),p.data() + fragStart,fragLen);
  261. }
  262. /**
  263. * Get this fragment's destination
  264. *
  265. * @return Destination ZT address
  266. */
  267. inline Address destination() const { return Address(field(ZT_PACKET_FRAGMENT_IDX_DEST,ZT_ADDRESS_LENGTH),ZT_ADDRESS_LENGTH); }
  268. /**
  269. * @return True if fragment is of a valid length
  270. */
  271. inline bool lengthValid() const { return (size() >= ZT_PACKET_FRAGMENT_IDX_PAYLOAD); }
  272. /**
  273. * @return ID of packet this is a fragment of
  274. */
  275. inline uint64_t packetId() const { return at<uint64_t>(ZT_PACKET_FRAGMENT_IDX_PACKET_ID); }
  276. /**
  277. * @return Total number of fragments in packet
  278. */
  279. inline unsigned int totalFragments() const { return (((unsigned int)((*this)[ZT_PACKET_FRAGMENT_IDX_FRAGMENT_NO]) >> 4) & 0xf); }
  280. /**
  281. * @return Fragment number of this fragment
  282. */
  283. inline unsigned int fragmentNumber() const { return ((unsigned int)((*this)[ZT_PACKET_FRAGMENT_IDX_FRAGMENT_NO]) & 0xf); }
  284. /**
  285. * @return Fragment ZT hop count
  286. */
  287. inline unsigned int hops() const { return (unsigned int)((*this)[ZT_PACKET_FRAGMENT_IDX_HOPS]); }
  288. /**
  289. * Increment this packet's hop count
  290. */
  291. inline void incrementHops()
  292. {
  293. (*this)[ZT_PACKET_FRAGMENT_IDX_HOPS] = (((*this)[ZT_PACKET_FRAGMENT_IDX_HOPS]) + 1) & ZT_PROTO_MAX_HOPS;
  294. }
  295. /**
  296. * @return Length of payload in bytes
  297. */
  298. inline unsigned int payloadLength() const { return ((size() > ZT_PACKET_FRAGMENT_IDX_PAYLOAD) ? (size() - ZT_PACKET_FRAGMENT_IDX_PAYLOAD) : 0); }
  299. /**
  300. * @return Raw packet payload
  301. */
  302. inline const unsigned char *payload() const
  303. {
  304. return field(ZT_PACKET_FRAGMENT_IDX_PAYLOAD,size() - ZT_PACKET_FRAGMENT_IDX_PAYLOAD);
  305. }
  306. };
  307. /**
  308. * ZeroTier protocol verbs
  309. */
  310. enum Verb /* Max value: 32 (5 bits) */
  311. {
  312. /* No operation, payload ignored, no reply */
  313. VERB_NOP = 0,
  314. /* Announcement of a node's existence:
  315. * <[1] protocol version>
  316. * <[1] software major version>
  317. * <[1] software minor version>
  318. * <[2] software revision>
  319. * <[8] timestamp (ms since epoch)>
  320. * <[...] binary serialized identity (see Identity)>
  321. *
  322. * OK payload:
  323. * <[8] timestamp (echoed from original HELLO)>
  324. *
  325. * ERROR has no payload.
  326. */
  327. VERB_HELLO = 1,
  328. /* Error response:
  329. * <[1] in-re verb>
  330. * <[8] in-re packet ID>
  331. * <[1] error code>
  332. * <[...] error-dependent payload>
  333. */
  334. VERB_ERROR = 2,
  335. /* Success response:
  336. * <[1] in-re verb>
  337. * <[8] in-re packet ID>
  338. * <[...] request-specific payload>
  339. */
  340. VERB_OK = 3,
  341. /* Query an identity by address:
  342. * <[5] address to look up>
  343. *
  344. * OK response payload:
  345. * <[...] binary serialized identity>
  346. *
  347. * Error payload will be address queried.
  348. */
  349. VERB_WHOIS = 4,
  350. /* Meet another node at a given protocol address:
  351. * <[5] ZeroTier address of peer that might be found at this address>
  352. * <[2] 16-bit protocol address port>
  353. * <[1] protocol address length (4 for IPv4, 16 for IPv6)>
  354. * <[...] protocol address (network byte order)>
  355. *
  356. * This is sent by a relaying node to initiate NAT traversal between two
  357. * peers that are communicating by way of indirect relay. The relay will
  358. * send this to both peers at the same time on a periodic basis, telling
  359. * each where it might find the other on the network.
  360. *
  361. * Upon receipt, a peer sends a message such as NOP or HELLO to the other
  362. * peer. Peers only "learn" one anothers' direct addresses when they
  363. * successfully *receive* a message and authenticate it. Optionally, peers
  364. * will usually preface these messages with one or more firewall openers
  365. * to clear the path.
  366. *
  367. * Nodes should implement rate control, limiting the rate at which they
  368. * respond to these packets to prevent their use in DDOS attacks. Nodes
  369. * may also ignore these messages if a peer is not known or is not being
  370. * actively communicated with.
  371. *
  372. * No OK or ERROR is generated.
  373. */
  374. VERB_RENDEZVOUS = 5,
  375. /* A ZT-to-ZT unicast ethernet frame:
  376. * <[8] 64-bit network ID>
  377. * <[2] 16-bit ethertype>
  378. * <[...] ethernet payload>
  379. *
  380. * MAC addresses are derived from the packet's source and destination
  381. * ZeroTier addresses. ZeroTier does not support VLANs or other extensions
  382. * beyond core Ethernet.
  383. *
  384. * No OK or ERROR is generated.
  385. */
  386. VERB_FRAME = 6,
  387. /* 7 - old VERB_MULTICAST_FRAME, might be reused once all old 0.2
  388. * clients are off the net. */
  389. /* Announce interest in multicast group(s):
  390. * <[8] 64-bit network ID>
  391. * <[6] multicast Ethernet address>
  392. * <[4] multicast additional distinguishing information (ADI)>
  393. * [... additional tuples of network/address/adi ...]
  394. *
  395. * OK is generated on successful receipt.
  396. */
  397. VERB_MULTICAST_LIKE = 8,
  398. /* A multicast frame:
  399. * <[1] flags, currently unused and must be 0>
  400. * <[8] 64-bit network ID>
  401. * <[5] ZeroTier address of original submitter of this multicast>
  402. * <[6] source MAC address>
  403. * <[6] destination multicast Ethernet address>
  404. * <[4] multicast additional distinguishing information (ADI)>
  405. * <[64] multicast propagation bloom filter>
  406. * <[1] 8-bit propagation hop count>
  407. * <[2] 16-bit ethertype>
  408. * <[2] 16-bit length of payload>
  409. * <[2] 16-bit length of signature>
  410. * <[...] ethernet payload>
  411. * <[...] ECDSA signature of SHA-256 hash (see below)>
  412. *
  413. * The signature is made using the key of the original submitter, and
  414. * can be used to authenticate the submitter for security and rate
  415. * control purposes. Fields in the signature are: network ID, source
  416. * MAC, destination MAC, multicast ADI, ethertype, and payload. All
  417. * integers are hashed in big-endian byte order. A zero byte is added
  418. * to the hash between each field.
  419. *
  420. * In the future flags could indicate additional fields appended to the
  421. * end or a different signature algorithm.
  422. *
  423. * No OK or ERROR is generated.
  424. */
  425. VERB_MULTICAST_FRAME = 9,
  426. /* Network member certificate for sending peer:
  427. * <[8] 64-bit network ID>
  428. * <[2] 16-bit length of certificate>
  429. * <[2] 16-bit length of signature>
  430. * <[...] string-serialized certificate dictionary>
  431. * <[...] ECDSA signature of certificate>
  432. *
  433. * OK is generated on acceptance. ERROR is returned on failure. In both
  434. * cases the payload is the network ID.
  435. */
  436. VERB_NETWORK_MEMBERSHIP_CERTIFICATE = 10,
  437. /* Network configuration request:
  438. * <[8] 64-bit network ID>
  439. * <[2] 16-bit length of request meta-data dictionary>
  440. * <[...] string-serialized request meta-data>
  441. *
  442. * This message requests network configuration from a node capable of
  443. * providing it. Such nodes run the netconf service, which must be
  444. * installed into the ZeroTier home directory.
  445. *
  446. * OK response payload:
  447. * <[8] 64-bit network ID>
  448. * <[2] 16-bit length of network configuration dictionary>
  449. * <[...] network configuration dictionary>
  450. *
  451. * OK returns a Dictionary (string serialized) containing the network's
  452. * configuration and IP address assignment information for the querying
  453. * node. It also contains a membership certificate that the querying
  454. * node can push to other peers to demonstrate its right to speak on
  455. * a given network.
  456. *
  457. * ERROR may be NOT_FOUND if no such network is known, or
  458. * UNSUPPORTED_OPERATION if the netconf service isn't available. The
  459. * payload will be the network ID.
  460. */
  461. VERB_NETWORK_CONFIG_REQUEST = 11,
  462. /* Network configuration refresh request:
  463. * <[8] 64-bit network ID>
  464. *
  465. * This message can be sent by the network configuration master node
  466. * to request that nodes refresh their network configuration. It can
  467. * thus be used to "push" updates.
  468. *
  469. * It does not generate an OK or ERROR message, and is treated only as
  470. * a hint to refresh now.
  471. */
  472. VERB_NETWORK_CONFIG_REFRESH = 12
  473. };
  474. /**
  475. * Error codes for VERB_ERROR
  476. */
  477. enum ErrorCode
  478. {
  479. /* No error, not actually used in transit */
  480. ERROR_NONE = 0,
  481. /* Invalid request */
  482. ERROR_INVALID_REQUEST = 1,
  483. /* Bad/unsupported protocol version */
  484. ERROR_BAD_PROTOCOL_VERSION = 2,
  485. /* Unknown object queried (e.g. with WHOIS) */
  486. ERROR_NOT_FOUND = 3,
  487. /* HELLO pushed an identity whose address is already claimed */
  488. ERROR_IDENTITY_COLLISION = 4,
  489. /* Identity was not valid */
  490. ERROR_IDENTITY_INVALID = 5,
  491. /* Verb or use case not supported/enabled by this node */
  492. ERROR_UNSUPPORTED_OPERATION = 6,
  493. /* Message to private network rejected -- no unexpired certificate on file */
  494. ERROR_NO_MEMBER_CERTIFICATE = 7
  495. };
  496. /**
  497. * @param v Verb
  498. * @return String representation (e.g. HELLO, OK)
  499. */
  500. static const char *verbString(Verb v)
  501. throw();
  502. /**
  503. * @param e Error code
  504. * @return String error name
  505. */
  506. static const char *errorString(ErrorCode e)
  507. throw();
  508. template<unsigned int C2>
  509. Packet(const Buffer<C2> &b)
  510. throw(std::out_of_range) :
  511. Buffer<ZT_PROTO_MAX_PACKET_LENGTH>(b)
  512. {
  513. }
  514. /**
  515. * Construct a new empty packet with a unique random packet ID
  516. *
  517. * Flags and hops will be zero. Other fields and data region are undefined.
  518. * Use the header access methods (setDestination() and friends) to fill out
  519. * the header. Payload should be appended; initial size is header size.
  520. */
  521. Packet() :
  522. Buffer<ZT_PROTO_MAX_PACKET_LENGTH>(ZT_PROTO_MIN_PACKET_LENGTH)
  523. {
  524. Utils::getSecureRandom(field(ZT_PACKET_IDX_IV,8),8);
  525. (*this)[ZT_PACKET_IDX_FLAGS] = 0; // zero flags and hops
  526. }
  527. /**
  528. * Construct a new empty packet with a unique random packet ID
  529. *
  530. * @param dest Destination ZT address
  531. * @param source Source ZT address
  532. * @param v Verb
  533. */
  534. Packet(const Address &dest,const Address &source,const Verb v) :
  535. Buffer<ZT_PROTO_MAX_PACKET_LENGTH>(ZT_PROTO_MIN_PACKET_LENGTH)
  536. {
  537. Utils::getSecureRandom(field(ZT_PACKET_IDX_IV,8),8);
  538. setDestination(dest);
  539. setSource(source);
  540. (*this)[ZT_PACKET_IDX_FLAGS] = 0; // zero flags and hops
  541. setVerb(v);
  542. }
  543. /**
  544. * Reset this packet structure for reuse in place
  545. *
  546. * @param dest Destination ZT address
  547. * @param source Source ZT address
  548. * @param v Verb
  549. */
  550. inline void reset(const Address &dest,const Address &source,const Verb v)
  551. {
  552. setSize(ZT_PROTO_MIN_PACKET_LENGTH);
  553. Utils::getSecureRandom(field(ZT_PACKET_IDX_IV,8),8);
  554. setDestination(dest);
  555. setSource(source);
  556. (*this)[ZT_PACKET_IDX_FLAGS] = 0; // zero flags and hops
  557. setVerb(v);
  558. }
  559. /**
  560. * Generate a new IV / packet ID in place
  561. *
  562. * This can be used to re-use a packet buffer multiple times to send
  563. * technically different but otherwise identical copies of the same
  564. * packet.
  565. */
  566. inline void newInitializationVector()
  567. {
  568. Utils::getSecureRandom(field(ZT_PACKET_IDX_IV,8),8);
  569. }
  570. /**
  571. * Set this packet's destination
  572. *
  573. * @param dest ZeroTier address of destination
  574. */
  575. inline void setDestination(const Address &dest)
  576. {
  577. unsigned char *d = field(ZT_PACKET_IDX_DEST,ZT_ADDRESS_LENGTH);
  578. for(unsigned int i=0;i<ZT_ADDRESS_LENGTH;++i)
  579. d[i] = dest[i];
  580. }
  581. /**
  582. * Set this packet's source
  583. *
  584. * @param source ZeroTier address of source
  585. */
  586. inline void setSource(const Address &source)
  587. {
  588. unsigned char *s = field(ZT_PACKET_IDX_SOURCE,ZT_ADDRESS_LENGTH);
  589. for(unsigned int i=0;i<ZT_ADDRESS_LENGTH;++i)
  590. s[i] = source[i];
  591. }
  592. /**
  593. * Get this packet's destination
  594. *
  595. * @return Destination ZT address
  596. */
  597. inline Address destination() const { return Address(field(ZT_PACKET_IDX_DEST,ZT_ADDRESS_LENGTH),ZT_ADDRESS_LENGTH); }
  598. /**
  599. * Get this packet's source
  600. *
  601. * @return Source ZT address
  602. */
  603. inline Address source() const { return Address(field(ZT_PACKET_IDX_SOURCE,ZT_ADDRESS_LENGTH),ZT_ADDRESS_LENGTH); }
  604. /**
  605. * @return True if packet is of valid length
  606. */
  607. inline bool lengthValid() const { return (size() >= ZT_PROTO_MIN_PACKET_LENGTH); }
  608. /**
  609. * @return True if packet is encrypted
  610. */
  611. inline bool encrypted() const { return (((unsigned char)(*this)[ZT_PACKET_IDX_FLAGS] & ZT_PROTO_FLAG_ENCRYPTED)); }
  612. /**
  613. * @return True if packet is fragmented (expect fragments)
  614. */
  615. inline bool fragmented() const { return (((unsigned char)(*this)[ZT_PACKET_IDX_FLAGS] & ZT_PROTO_FLAG_FRAGMENTED)); }
  616. /**
  617. * Set this packet's fragmented flag
  618. *
  619. * @param f Fragmented flag value
  620. */
  621. inline void setFragmented(bool f)
  622. {
  623. if (f)
  624. (*this)[ZT_PACKET_IDX_FLAGS] |= (char)ZT_PROTO_FLAG_FRAGMENTED;
  625. else (*this)[ZT_PACKET_IDX_FLAGS] &= (char)(~ZT_PROTO_FLAG_FRAGMENTED);
  626. }
  627. /**
  628. * @return True if compressed (result only valid if unencrypted)
  629. */
  630. inline bool compressed() const { return (((unsigned char)(*this)[ZT_PACKET_IDX_VERB] & ZT_PROTO_VERB_FLAG_COMPRESSED)); }
  631. /**
  632. * @return ZeroTier forwarding hops (0 to 7)
  633. */
  634. inline unsigned int hops() const { return ((unsigned int)(*this)[ZT_PACKET_IDX_FLAGS] & 0x07); }
  635. /**
  636. * Increment this packet's hop count
  637. */
  638. inline void incrementHops()
  639. {
  640. (*this)[ZT_PACKET_IDX_FLAGS] = (char)((unsigned char)(*this)[ZT_PACKET_IDX_FLAGS] & 0xf8) | (((unsigned char)(*this)[ZT_PACKET_IDX_FLAGS] + 1) & 0x07);
  641. }
  642. /**
  643. * Get this packet's unique ID (the IV field interpreted as uint64_t)
  644. *
  645. * @return Packet ID
  646. */
  647. inline uint64_t packetId() const { return at<uint64_t>(ZT_PACKET_IDX_IV); }
  648. /**
  649. * Set packet verb
  650. *
  651. * This also has the side-effect of clearing any verb flags, such as
  652. * compressed, and so must only be done during packet composition.
  653. *
  654. * @param v New packet verb
  655. */
  656. inline void setVerb(Verb v) { (*this)[ZT_PACKET_IDX_VERB] = (char)v; }
  657. /**
  658. * @return Packet verb (not including flag bits)
  659. */
  660. inline Verb verb() const { return (Verb)((*this)[ZT_PACKET_IDX_VERB] & 0x1f); }
  661. /**
  662. * @return Length of packet payload
  663. */
  664. inline unsigned int payloadLength() const { return ((size() < ZT_PROTO_MIN_PACKET_LENGTH) ? 0 : (size() - ZT_PROTO_MIN_PACKET_LENGTH)); }
  665. /**
  666. * @return Raw packet payload
  667. */
  668. inline const unsigned char *payload() const
  669. {
  670. return field(ZT_PACKET_IDX_PAYLOAD,size() - ZT_PACKET_IDX_PAYLOAD);
  671. }
  672. /**
  673. * Compute the HMAC of this packet's payload and set HMAC field
  674. *
  675. * For encrypted packets, this must be called after encryption.
  676. *
  677. * @param key 256-bit (32 byte) key
  678. */
  679. inline void hmacSet(const void *key)
  680. {
  681. unsigned char mac[32];
  682. unsigned char key2[32];
  683. _mangleKey((const unsigned char *)key,key2);
  684. unsigned int hmacLen = (size() >= ZT_PACKET_IDX_VERB) ? (size() - ZT_PACKET_IDX_VERB) : 0;
  685. HMAC::sha256(key2,sizeof(key2),field(ZT_PACKET_IDX_VERB,hmacLen),hmacLen,mac);
  686. memcpy(field(ZT_PACKET_IDX_HMAC,8),mac,8);
  687. }
  688. /**
  689. * Check the HMAC of this packet's payload
  690. *
  691. * For encrypted packets, this must be checked before decryption.
  692. *
  693. * @param key 256-bit (32 byte) key
  694. */
  695. inline bool hmacVerify(const void *key) const
  696. {
  697. unsigned char mac[32];
  698. unsigned char key2[32];
  699. if (size() < ZT_PACKET_IDX_VERB)
  700. return false; // incomplete packets fail
  701. _mangleKey((const unsigned char *)key,key2);
  702. unsigned int hmacLen = size() - ZT_PACKET_IDX_VERB;
  703. HMAC::sha256(key2,sizeof(key2),field(ZT_PACKET_IDX_VERB,hmacLen),hmacLen,mac);
  704. return (!memcmp(field(ZT_PACKET_IDX_HMAC,8),mac,8));
  705. }
  706. /**
  707. * Encrypt this packet
  708. *
  709. * @param key 256-bit (32 byte) key
  710. */
  711. inline void encrypt(const void *key)
  712. {
  713. (*this)[ZT_PACKET_IDX_FLAGS] |= ZT_PROTO_FLAG_ENCRYPTED;
  714. unsigned char key2[32];
  715. if (size() >= ZT_PACKET_IDX_VERB) {
  716. _mangleKey((const unsigned char *)key,key2);
  717. Salsa20 s20(key2,256,field(ZT_PACKET_IDX_IV,8));
  718. unsigned int encLen = size() - ZT_PACKET_IDX_VERB;
  719. unsigned char *const encBuf = field(ZT_PACKET_IDX_VERB,encLen);
  720. s20.encrypt(encBuf,encBuf,encLen);
  721. }
  722. }
  723. /**
  724. * Decrypt this packet
  725. *
  726. * @param key 256-bit (32 byte) key
  727. */
  728. inline void decrypt(const void *key)
  729. {
  730. unsigned char key2[32];
  731. if (size() >= ZT_PACKET_IDX_VERB) {
  732. _mangleKey((const unsigned char *)key,key2);
  733. Salsa20 s20(key2,256,field(ZT_PACKET_IDX_IV,8));
  734. unsigned int decLen = size() - ZT_PACKET_IDX_VERB;
  735. unsigned char *const decBuf = field(ZT_PACKET_IDX_VERB,decLen);
  736. s20.decrypt(decBuf,decBuf,decLen);
  737. }
  738. (*this)[ZT_PACKET_IDX_FLAGS] &= (char)(~ZT_PROTO_FLAG_ENCRYPTED);
  739. }
  740. /**
  741. * Attempt to compress payload if not already (must be unencrypted)
  742. *
  743. * This requires that the payload at least contain the verb byte already
  744. * set. The compressed flag in the verb is set if compression successfully
  745. * results in a size reduction. If no size reduction occurs, compression
  746. * is not done and the flag is left cleared.
  747. *
  748. * @return True if compression occurred
  749. */
  750. inline bool compress()
  751. {
  752. unsigned char buf[ZT_PROTO_MAX_PACKET_LENGTH * 2];
  753. if ((!compressed())&&(size() > (ZT_PACKET_IDX_PAYLOAD + 32))) {
  754. int pl = (int)(size() - ZT_PACKET_IDX_PAYLOAD);
  755. int cl = LZ4_compress((const char *)field(ZT_PACKET_IDX_PAYLOAD,(unsigned int)pl),(char *)buf,pl);
  756. if ((cl > 0)&&(cl < pl)) {
  757. (*this)[ZT_PACKET_IDX_VERB] |= (char)ZT_PROTO_VERB_FLAG_COMPRESSED;
  758. setSize((unsigned int)cl + ZT_PACKET_IDX_PAYLOAD);
  759. memcpy(field(ZT_PACKET_IDX_PAYLOAD,(unsigned int)cl),buf,cl);
  760. return true;
  761. }
  762. }
  763. (*this)[ZT_PACKET_IDX_VERB] &= (char)(~ZT_PROTO_VERB_FLAG_COMPRESSED);
  764. return false;
  765. }
  766. /**
  767. * Attempt to decompress payload if it is compressed (must be unencrypted)
  768. *
  769. * If payload is compressed, it is decompressed and the compressed verb
  770. * flag is cleared. Otherwise nothing is done and true is returned.
  771. *
  772. * @return True if data is now decompressed and valid, false on error
  773. */
  774. inline bool uncompress()
  775. {
  776. unsigned char buf[ZT_PROTO_MAX_PACKET_LENGTH];
  777. if ((compressed())&&(size() >= ZT_PROTO_MIN_PACKET_LENGTH)) {
  778. if (size() > ZT_PACKET_IDX_PAYLOAD) {
  779. unsigned int compLen = size() - ZT_PACKET_IDX_PAYLOAD;
  780. int ucl = LZ4_uncompress_unknownOutputSize((const char *)field(ZT_PACKET_IDX_PAYLOAD,compLen),(char *)buf,compLen,sizeof(buf));
  781. if ((ucl > 0)&&(ucl <= (int)(capacity() - ZT_PACKET_IDX_PAYLOAD))) {
  782. setSize((unsigned int)ucl + ZT_PACKET_IDX_PAYLOAD);
  783. memcpy(field(ZT_PACKET_IDX_PAYLOAD,(unsigned int)ucl),buf,ucl);
  784. } else return false;
  785. }
  786. (*this)[ZT_PACKET_IDX_VERB] &= ~ZT_PROTO_VERB_FLAG_COMPRESSED;
  787. }
  788. return true;
  789. }
  790. private:
  791. /**
  792. * Deterministically mangle a 256-bit crypto key based on packet characteristics
  793. *
  794. * This takes the static agreed-upon input key and mangles it using
  795. * info from the packet. This serves two purposes:
  796. *
  797. * (1) It reduces the (already minute) probability of a duplicate key /
  798. * IV combo, which is good since keys are extremely long-lived. Another
  799. * way of saying this is that it increases the effective IV size by
  800. * using other parts of the packet as IV material.
  801. * (2) It causes HMAC to fail should any of the following change: ordering
  802. * of source and dest addresses, flags, IV, or packet size. HMAC has
  803. * no explicit scheme for AAD (additional authenticated data).
  804. *
  805. * NOTE: this function will have to be changed if the order of any packet
  806. * fields or their sizes/padding changes in the spec.
  807. *
  808. * @param in Input key (32 bytes)
  809. * @param out Output buffer (32 bytes)
  810. */
  811. inline void _mangleKey(const unsigned char *in,unsigned char *out) const
  812. {
  813. // Random IV (Salsa20 also uses the IV natively, but HMAC doesn't), and
  814. // destination and source addresses. Using dest and source addresses
  815. // gives us a (likely) different key space for a->b vs b->a.
  816. for(unsigned int i=0;i<18;++i) // 8 + (ZT_ADDRESS_LENGTH * 2) == 18
  817. out[i] = in[i] ^ (unsigned char)(*this)[i];
  818. // Flags, but masking off hop count which is altered by forwarding nodes
  819. out[18] = in[18] ^ ((unsigned char)(*this)[ZT_PACKET_IDX_FLAGS] & 0xf8);
  820. // Raw packet size in bytes -- each raw packet size defines a possibly
  821. // different space of keys.
  822. out[19] = in[19] ^ (unsigned char)(size() & 0xff);
  823. out[20] = in[20] ^ (unsigned char)((size() >> 8) & 0xff); // little endian
  824. // Rest of raw key is used unchanged
  825. for(unsigned int i=21;i<32;++i)
  826. out[i] = in[i];
  827. }
  828. };
  829. } // namespace ZeroTier
  830. #endif