github/ZeroTierOne
1
0
Fork 0
mirror of https://github.com/ZeroTier/ZeroTierOne synced 2025-07-10 07:13:09 -07:00
Code Issues Projects Releases Packages Wiki Activity Actions 2

Some work on simulated net...

Browse source
This commit is contained in:
Adam Ierymenko 2014-10-22 09:52:29 -07:00
parent ae228ade8c
commit 0a195e7bc0
5 changed files with 291 additions and 28 deletions
Download patch file Download diff file Expand all files Collapse all files

61
testnet/SimNetSocketManager.cpp
View file

@ -27,9 +27,32 @@
#include "SimNetSocketManager.hpp"
#include "../node/Constants.hpp"
#include "../node/Socket.hpp"
namespace ZeroTier {
SimNetSocketManager::SimNetSocketManager()
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))
{
}
@ -37,24 +60,40 @@ SimNetSocketManager::~SimNetSocketManager()
{
}
bool SimNetSocketManager::send(
const InetAddress &to,
bool tcp,
bool autoConnectTcp,
const void *msg,
unsigned int msglen)
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<Socket> &,void *,const InetAddress &,Buffer<ZT_SOCKET_MAX_MESSAGE_LEN> &),
void *arg)
void SimNetSocketManager::poll(unsigned long timeout,void (*handler)(const SharedPtr<Socket> &,void *,const InetAddress &,Buffer<ZT_SOCKET_MAX_MESSAGE_LEN> &),void *arg)
{
{
Mutex::Lock _l(_lock);
while (!_queue.empty()) {
handler(_mySocket,arg,_queue.front().first,_queue.front().second);
_queue.pop();
}
}
if (timeout)
_waitCond.wait(timeout);
else _waitCond.wait();
{
Mutex::Lock _l(_lock);
while (!_queue.empty()) {
handler(_mySocket,arg,_queue.front().first,_queue.front().second);
_queue.pop();
}
}
}
void SimNetSocketManager::whack()
{
_waitCond.signal();
}
void SimNetSocketManager::closeTcpSockets()