mirror of https://github.com/oxen-io/lokinet
You cannot select more than 25 topics
Topics must start with a letter or number, can include dashes ('-') and can be up to 35 characters long.
50 lines
1.3 KiB
C++
50 lines
1.3 KiB
C++
#include "link.hpp"
|
|
#include <cstring>
|
|
#include <sarp/time.h>
|
|
|
|
bool operator < (const sockaddr_in6 addr0, const sockaddr_in6 addr1)
|
|
{
|
|
return memcmp(addr0.sin6_addr.s6_addr, addr1.sin6_addr.s6_addr, sizeof(addr0.sin6_addr)) && addr0.sin6_port < addr1.sin6_port;
|
|
}
|
|
|
|
namespace sarp
|
|
{
|
|
|
|
static void link_recv_from(struct sarp_udp_listener * l, const struct sockaddr * src, char * buff, ssize_t sz)
|
|
{
|
|
if(src && src->sa_family == AF_INET6)
|
|
{
|
|
Link * link = static_cast<Link*>(l->user);
|
|
struct sockaddr_in6 remote;
|
|
memcpy(&remote, src, sizeof(sockaddr_in6));
|
|
auto itr = link->sessions.find(remote);
|
|
if(itr == link->sessions.end())
|
|
{
|
|
link->sessions[remote] = std::make_unique<PeerSession>(link->_crypto, remote);
|
|
}
|
|
link->sessions[remote]->RecvFrom(buff, sz);
|
|
}
|
|
}
|
|
|
|
Link::Link(sarp_crypto * crypto) : _crypto(crypto)
|
|
{
|
|
listener.user = this;
|
|
listener.recvfrom = link_recv_from;
|
|
}
|
|
|
|
PeerSession::PeerSession(sarp_crypto * crypto, sockaddr_in6 remote) :
|
|
lastRX(0),
|
|
remoteAddr(remote),
|
|
_crypto(crypto),
|
|
state(eHandshakeInboundInit)
|
|
{
|
|
memset(remotePubkey, 0, sizeof(remotePubkey));
|
|
memset(sessionKey, 0, sizeof(sessionKey));
|
|
}
|
|
|
|
void PeerSession::RecvFrom(const char * buff, ssize_t sz)
|
|
{
|
|
lastRX = sarp_time_now_ms();
|
|
}
|
|
}
|