From ffad0b27809f8ec0cca11a5dabd9624340857f57 Mon Sep 17 00:00:00 2001 From: Adam Ierymenko Date: Thu, 11 Jul 2013 16:19:06 -0400 Subject: Factoring out packet decoder from Switch to put that object on a little bit of a diet. Work in progress, wont build yet. --- node/PacketDecoder.hpp | 94 ++++++++++++++++++++++++++++++++++++++++++++++++++ 1 file changed, 94 insertions(+) create mode 100644 node/PacketDecoder.hpp (limited to 'node/PacketDecoder.hpp') diff --git a/node/PacketDecoder.hpp b/node/PacketDecoder.hpp new file mode 100644 index 00000000..09f6e1c4 --- /dev/null +++ b/node/PacketDecoder.hpp @@ -0,0 +1,94 @@ +/* + * ZeroTier One - Global Peer to Peer Ethernet + * Copyright (C) 2012-2013 ZeroTier Networks LLC + * + * This program is free software: you can redistribute it and/or modify + * it under the terms of the GNU General Public License as published by + * the Free Software Foundation, either version 3 of the License, or + * (at your option) any later version. + * + * This program is distributed in the hope that it will be useful, + * but WITHOUT ANY WARRANTY; without even the implied warranty of + * MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the + * GNU General Public License for more details. + * + * You should have received a copy of the GNU General Public License + * along with this program. If not, see . + * + * -- + * + * ZeroTier may be used and distributed under the terms of the GPLv3, which + * are available at: http://www.gnu.org/licenses/gpl-3.0.html + * + * If you would like to embed ZeroTier into a commercial application or + * redistribute it in a modified binary form, please contact ZeroTier Networks + * LLC. Start here: http://www.zerotier.com/ + */ + +#ifndef _ZT_PACKETDECODER_HPP +#define _ZT_PACKETDECODER_HPP + +#include + +#include "Packet.hpp" +#include "Demarc.hpp" +#include "InetAddress.hpp" +#include "Utils.hpp" +#include "SharedPtr.hpp" +#include "AtomicCounter.hpp" + +namespace ZeroTier { + +class RuntimeEnvironment; + +/** + * Subclass of packet that handles the decoding of it + */ +class PacketDecoder : public Packet +{ + friend class SharedPtr; + +public: + template + PacketDecoder(const Buffer &b,Demarc::Port localPort,const InetAddress &remoteAddress) + throw(std::out_of_range) : + Packet(b) : + _receiveTime(Utils::now()), + _localPort(localPort), + _remoteAddress(remoteAddress), + _step(DECODE_STEP_START), + __refCount() + { + } + + /** + * Attempt to decode this packet + * + * @param _r Runtime environment + * @return True if decoding and processing is complete, false on failure (try again) + */ + bool tryDecode(const RuntimeEnvironment *_r) + throw(std::out_of_range,std::runtime_error); + + /** + * @return Time of packet receipt + */ + inline uint64_t receiveTime() const throw() { return _receiveTime; } + +private: + uint64_t _receiveTime; + Demarc::Port _localPort; + InetAddress _remoteAddress; + + enum { + DECODE_STEP_START, + DECODE_STEP_WAITING_FOR_SENDER_LOOKUP, // on initial receipt, we need peer's identity + DECODE_STEP_WAITING_FOR_ORIGINAL_SUBMITTER_LOOKUP // this only applies to MULTICAST_FRAME + } _step; + + AtomicCounter __refCount; +}; + +} // namespace ZeroTier + +#endif -- cgit v1.2.3