summaryrefslogtreecommitdiff
path: root/src
diff options
context:
space:
mode:
Diffstat (limited to 'src')
-rw-r--r--src/anytun.cpp75
-rw-r--r--src/connectionList.cpp3
-rw-r--r--src/packetSource.h4
3 files changed, 44 insertions, 38 deletions
diff --git a/src/anytun.cpp b/src/anytun.cpp
index 6f13723..e762e0b 100644
--- a/src/anytun.cpp
+++ b/src/anytun.cpp
@@ -80,19 +80,15 @@
#define SESSION_KEYLEN_ENCR 16 // TODO: hardcoded size
#define SESSION_KEYLEN_SALT 14 // TODO: hardcoded size
-void createConnection(const std::string & remote_host, const std::string & remote_port, ConnectionList & cl, u_int16_t seqSize, SyncQueue & queue, mux_t mux)
+void createConnection(const PacketSourceEndpoint & remote_end, ConnectionList & cl, u_int16_t seqSize, SyncQueue & queue, mux_t mux)
{
SeqWindow * seq= new SeqWindow(seqSize);
seq_nr_t seq_nr_=0;
KeyDerivation * kd = KeyDerivationFactory::create(gOpt.getKdPrf());
kd->init(gOpt.getKey(), gOpt.getSalt());
- cLog.msg(Log::PRIO_NOTICE) << "added connection remote host " << remote_host << ":" << remote_port;
- boost::asio::io_service io_service;
- boost::asio::ip::udp::resolver resolver(io_service);
- boost::asio::ip::udp::resolver::query query(remote_host, remote_port);
- boost::asio::ip::udp::endpoint endpoint = *resolver.resolve(query);
+ cLog.msg(Log::PRIO_NOTICE) << "added connection remote host " << remote_end;
- ConnectionParam connparam ( (*kd), (*seq), seq_nr_, endpoint);
+ ConnectionParam connparam ( (*kd), (*seq), seq_nr_, remote_end);
cl.addConnection(connparam,mux);
NetworkAddress addr(ipv4,gOpt.getIfconfigParamRemoteNetmask().c_str());
NetworkPrefix prefix(addr,32);
@@ -108,7 +104,7 @@ bool checkPacketSeqNr(EncryptedPacket& pack,ConnectionParam& conn)
// compare sender_id and seq with window
if(conn.seq_window_.hasSeqNr(pack.getSenderId(), pack.getSeqNr()))
{
- cLog.msg(Log::PRIO_NOTICE) << "Replay attack from " << conn.remote_host_<<":"<< conn.remote_port_
+ cLog.msg(Log::PRIO_NOTICE) << "Replay attack from " << conn.remote_end_
<< " seq:"<<pack.getSeqNr() << " sid: "<<pack.getSenderId();
return false;
}
@@ -162,8 +158,10 @@ void sender(void* p)
continue;
ConnectionParam & conn = cit->second;
- if(conn.remote_host_==""||!conn.remote_port_)
+// TODO test if endpoint is not valid
+ if(conn.remote_end_.address().to_string()==""||!conn.remote_end_.port())
continue;
+
// generate packet-key TODO: do this only when needed
conn.kd_.generate(LABEL_SATP_ENCRYPTION, conn.seq_nr_, session_key);
conn.kd_.generate(LABEL_SATP_SALT, conn.seq_nr_, session_salt);
@@ -186,7 +184,7 @@ void sender(void* p)
}
try
{
- param->src.send(encrypted_packet.getBuf(), encrypted_packet.getLength(), conn.remote_host_, conn.remote_port_);
+ param->src.send(encrypted_packet.getBuf(), encrypted_packet.getLength(), conn.remote_end_);
}
catch (std::exception& e)
{
@@ -263,23 +261,22 @@ void receiver(void* p)
while(1)
{
- std::string remote_host;
- u_int16_t remote_port;
-
+ PacketSourceEndpoint remote_end;
+
plain_packet.setLength(MAX_PACKET_LENGTH);
encrypted_packet.withAuthTag(false);
encrypted_packet.setLength(MAX_PACKET_LENGTH);
// read packet from socket
- u_int32_t len = param->src.recv(encrypted_packet.getBuf(), encrypted_packet.getLength(), remote_host, remote_port);
+ u_int32_t len = param->src.recv(encrypted_packet.getBuf(), encrypted_packet.getLength(), remote_end);
encrypted_packet.setLength(len);
mux_t mux = encrypted_packet.getMux();
// autodetect peer
- if(gOpt.getRemoteAddr() == "" && param->cl.empty())
+ if( param->cl.empty() && gOpt.getRemoteAddr() == "")
{
- cLog.msg(Log::PRIO_NOTICE) << "autodetected remote host " << remote_host << ":" << remote_port;
- createConnection(remote_host, remote_port, param->cl, gOpt.getSeqWindowSize(),param->queue,mux);
+ cLog.msg(Log::PRIO_NOTICE) << "autodetected remote host " << remote_end;
+ createConnection(remote_end, param->cl, gOpt.getSeqWindowSize(),param->queue,mux);
}
ConnectionMap::iterator cit = param->cl.getConnection(mux);
@@ -301,12 +298,10 @@ void receiver(void* p)
//Allow dynamic IP changes
//TODO: add command line option to turn this off
- if (remote_host != conn.remote_host_ || remote_port != conn.remote_port_)
+ if (remote_end != conn.remote_end_)
{
- cLog.msg(Log::PRIO_NOTICE) << "connection "<< mux << " autodetected remote host ip changed "
- << remote_host << ":" << remote_port;
- conn.remote_host_=remote_host;
- conn.remote_port_=remote_port;
+ cLog.msg(Log::PRIO_NOTICE) << "connection "<< mux << " autodetected remote host ip changed " << remote_end;
+ conn.remote_end_=remote_end;
SyncCommand sc (param->cl,mux);
param->queue.push(sc);
}
@@ -523,6 +518,25 @@ int main(int argc, char* argv[])
cLog.msg(Log::PRIO_NOTICE) << "post up script '" << gOpt.getPostUpScript() << "' returned " << postup_ret;
}
+ PacketSource* src;
+ if(gOpt.getLocalAddr() == "")
+ src = new UDPPacketSource(gOpt.getLocalPort());
+ else
+ src = new UDPPacketSource(gOpt.getLocalAddr(), gOpt.getLocalPort());
+
+ ConnectionList & cl (gConnectionList);
+ ConnectToList connect_to = gOpt.getConnectTo();
+ SyncQueue queue;
+
+ if(gOpt.getRemoteAddr() != "")
+ {
+ boost::asio::io_service io_service;
+ boost::asio::ip::udp::resolver resolver(io_service);
+ boost::asio::ip::udp::resolver::query query(gOpt.getRemoteAddr(), gOpt.getRemotePort());
+ boost::asio::ip::udp::endpoint endpoint = *resolver.resolve(query);
+ createConnection(endpoint,cl,gOpt.getSeqWindowSize(), queue, gOpt.getMux());
+ }
+
if(gOpt.getChroot())
chrootAndDrop(gOpt.getChrootDir(), gOpt.getUsername());
if(gOpt.getDaemonize())
@@ -540,21 +554,8 @@ int main(int argc, char* argv[])
SignalController sig;
sig.init();
- PacketSource* src;
- if(gOpt.getLocalAddr() == "")
- src = new UDPPacketSource(gOpt.getLocalPort());
- else
- src = new UDPPacketSource(gOpt.getLocalAddr(), gOpt.getLocalPort());
-
- ConnectionList & cl (gConnectionList);
- ConnectToList connect_to = gOpt.getConnectTo();
- SyncQueue queue;
-
- if(gOpt.getRemoteAddr() != "")
- createConnection(gOpt.getRemoteAddr(),gOpt.getRemotePort(),cl,gOpt.getSeqWindowSize(), queue, gOpt.getMux());
-
ThreadParam p(dev, *src, cl, queue,*(new OptionConnectTo()));
-
+
// this must be called before any other libgcrypt call
if(!initLibGCrypt())
return -1;
@@ -563,7 +564,7 @@ int main(int argc, char* argv[])
boost::thread receiverThread(boost::bind(receiver,&p));
#ifndef ANYTUN_NOSYNC
boost::thread * syncListenerThread;
- if ( gOpt.getLocalSyncPort())
+ if(gOpt.getLocalSyncPort() != "")
syncListenerThread = new boost::thread(boost::bind(syncListener,&queue));
std::list<boost::thread *> connectThreads;
diff --git a/src/connectionList.cpp b/src/connectionList.cpp
index e72fd20..5292529 100644
--- a/src/connectionList.cpp
+++ b/src/connectionList.cpp
@@ -33,6 +33,7 @@
#include "datatypes.h"
#include "keyDerivationFactory.h"
#include "options.h"
+#include "packetSource.h"
#include "connectionList.h"
@@ -121,7 +122,7 @@ ConnectionParam & ConnectionList::getOrNewConnectionUnlocked(u_int16_t mux)
seq_nr_t seq_nr_=0;
KeyDerivation * kd = KeyDerivationFactory::create(gOpt.getKdPrf());
kd->init(Buffer(key, sizeof(key)), Buffer(salt, sizeof(salt)));
- ConnectionParam conn ( (*kd), (*seq), seq_nr_, "", 0);
+ ConnectionParam conn ( (*kd), (*seq), seq_nr_, PacketSourceEndpoint());
connections_.insert(ConnectionMap::value_type(mux, conn));
it = connections_.find(mux);
return it->second;
diff --git a/src/packetSource.h b/src/packetSource.h
index d8914b9..f5cbd5d 100644
--- a/src/packetSource.h
+++ b/src/packetSource.h
@@ -29,6 +29,9 @@
* along with anytun. If not, see <http://www.gnu.org/licenses/>.
*/
+#ifndef _PACKET_SOURCE_H_
+#define _PACKET_SOURCE_H_
+
#include <boost/asio.hpp>
#include "datatypes.h"
@@ -59,3 +62,4 @@ private:
boost::asio::ip::udp::socket sock_;
};
+#endif
generated by cgit v1.2.3 (git 2.39.1) at 2024-11-06 09:48:56 +0000