From 7576911951781baf8730ee3e166cb6efc73322bf Mon Sep 17 00:00:00 2001 From: Adam Ierymenko Date: Fri, 10 Apr 2015 11:42:02 -0700 Subject: Temporarily shelve testnet/ -- will resurrect self-contained testnet later perhaps, but probably will not by the time next version ships. Was mostly for debugging multicast anyway and that is now quite stable. --- attic/testnet/SimNetSocketManager.cpp | 90 +++++++++++++++++++++++++++++++++++ 1 file changed, 90 insertions(+) create mode 100644 attic/testnet/SimNetSocketManager.cpp (limited to 'attic/testnet/SimNetSocketManager.cpp') diff --git a/attic/testnet/SimNetSocketManager.cpp b/attic/testnet/SimNetSocketManager.cpp new file mode 100644 index 00000000..5b8b97a0 --- /dev/null +++ b/attic/testnet/SimNetSocketManager.cpp @@ -0,0 +1,90 @@ +/* + * ZeroTier One - Network Virtualization Everywhere + * Copyright (C) 2011-2015 ZeroTier, Inc. + * + * 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/ + */ + +#include "SimNetSocketManager.hpp" +#include "SimNet.hpp" + +#include "../node/Constants.hpp" +#include "../node/Socket.hpp" + +namespace ZeroTier { + +class SimNetSocket : public Socket +{ +public: + SimNetSocket(SimNetSocketManager *sm) : + Socket(ZT_SOCKET_TYPE_UDP_V4), + _parent(sm) {} + + virtual bool send(const InetAddress &to,const void *msg,unsigned int msglen) + { + SimNetSocketManager *dest = _parent->net()->get(to); + if (dest) + dest->enqueue(_parent->address(),msg,msglen); + return true; // we emulate UDP, which has no delivery guarantee semantics + } + + SimNetSocketManager *_parent; +}; + +SimNetSocketManager::SimNetSocketManager() : + _sn((SimNet *)0), // initialized by SimNet + _mySocket(new SimNetSocket(this)) +{ +} + +SimNetSocketManager::~SimNetSocketManager() +{ +} + +bool SimNetSocketManager::send(const InetAddress &to,bool tcp,bool autoConnectTcp,const void *msg,unsigned int msglen) +{ + if (tcp) + return false; // we emulate UDP + SimNetSocketManager *dest = _sn->get(to); + if (dest) + dest->enqueue(_address,msg,msglen); + return true; // we emulate UDP, which has no delivery guarantee semantics +} + +void SimNetSocketManager::poll(unsigned long timeout,void (*handler)(const SharedPtr &,void *,const InetAddress &,Buffer &),void *arg) +{ + std::pair< InetAddress,Buffer > msg; + if ((_inbox.pop(msg,timeout))&&(msg.second.size())) + handler(_mySocket,arg,msg.first,msg.second); +} + +void SimNetSocketManager::whack() +{ + _inbox.push(std::pair< InetAddress,Buffer >()); +} + +void SimNetSocketManager::closeTcpSockets() +{ +} + +} // namespace ZeroTier -- cgit v1.2.3