summaryrefslogtreecommitdiff
path: root/src/packetSource.cpp
diff options
context:
space:
mode:
authorChristian Pointner <equinox@anytun.org>2010-01-13 01:46:05 +0000
committerChristian Pointner <equinox@anytun.org>2010-01-13 01:46:05 +0000
commita983fbdad590a1905ced5ee75034b2bac9a853ad (patch)
tree669d253da4c7509d70884b508b2d0e83069969b4 /src/packetSource.cpp
parentsingle thread per socket (diff)
fixed packet length
Diffstat (limited to 'src/packetSource.cpp')
-rw-r--r--src/packetSource.cpp5
1 files changed, 1 insertions, 4 deletions
diff --git a/src/packetSource.cpp b/src/packetSource.cpp
index 9eaedc6..fa4abd0 100644
--- a/src/packetSource.cpp
+++ b/src/packetSource.cpp
@@ -94,7 +94,7 @@ void UDPPacketSource::onResolve(PacketSourceResolverIt& it)
if(sockets_.size() > 1) {
std::list<sockets_element_t>::iterator it = sockets_.begin();
for(;it != sockets_.end(); ++it) {
- it->len_ = 1600; // TODO packet size
+ it->len_ = MAX_PACKET_LENGTH;
it->buf_ = new u_int8_t[it->len_];
if(!it->buf_)
AnytunError::throwErr() << "memory error";
@@ -127,9 +127,6 @@ void UDPPacketSource::recv_thread(std::list<sockets_element_t>::iterator it)
result.it_ = it;
for(;;) {
it->sem_->down();
-
- cLog.msg(Log::PRIO_DEBUG) << "calling recv() for " << it->sock_->local_endpoint();
-
result.len_ = static_cast<u_int32_t>(it->sock_->receive_from(boost::asio::buffer(it->buf_, it->len_), result.remote_));
{
Lock lock(thread_result_mutex_);