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.
36 lines
929 B
C++
36 lines
929 B
C++
#include "link.hpp"
|
|
#include <cstring>
|
|
|
|
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, struct sockaddr src, uint8_t * buff, size_t sz)
|
|
{
|
|
if(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;
|
|
}
|
|
|
|
|
|
}
|