denozord/strongswan-ext
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

Added simple conditional packet receive delay

Browse Source
This commit is contained in:
Martin Willi
2010-05-18 12:21:05 +02:00
parent 45def2147b
commit d235274486
1 changed files with 38 additions and 9 deletions
Download Patch File Download Diff File Expand all files Collapse all files
src/libcharon/network/receiver.c
+38 -9
View File
@@ -103,7 +103,22 @@ struct private_receiver_t {
/** /**
* Delay for receiving incoming packets, to simulate larger RTT * Delay for receiving incoming packets, to simulate larger RTT
*/ */
u_int receive_delay; int receive_delay;
/**
* Specific message type to delay, 0 for any
*/
int receive_delay_type;
/**
* Delay request messages?
*/
bool receive_delay_request;
/**
* Delay response messages?
*/
bool receive_delay_response;
}; };
/** /**
@@ -259,7 +274,6 @@ static job_requeue_t receive_packets(private_receiver_t *this)
{ {
packet_t *packet; packet_t *packet;
message_t *message; message_t *message;
job_t *job;
/* read in a packet */ /* read in a packet */
if (charon->socket->receive(charon->socket, &packet) != SUCCESS) if (charon->socket->receive(charon->socket, &packet) != SUCCESS)
@@ -329,16 +343,25 @@ static job_requeue_t receive_packets(private_receiver_t *this)
return JOB_REQUEUE_DIRECT; return JOB_REQUEUE_DIRECT;
} }
} }
job = (job_t*)process_message_job_create(message);
if (this->receive_delay) if (this->receive_delay)
{ {
charon->scheduler->schedule_job_ms(charon->scheduler, if (this->receive_delay_type == 0 ||
job, this->receive_delay); this->receive_delay_type == message->get_exchange_type(message))
} {
else if ((message->get_request(message) && this->receive_delay_request) ||
{ (!message->get_request(message) && this->receive_delay_response))
charon->processor->queue_job(charon->processor, job); {
DBG1(DBG_NET, "using receive delay: %dms",
this->receive_delay);
charon->scheduler->schedule_job_ms(charon->scheduler,
(job_t*)process_message_job_create(message),
this->receive_delay);
return JOB_REQUEUE_DIRECT;
}
}
} }
charon->processor->queue_job(charon->processor,
(job_t*)process_message_job_create(message));
return JOB_REQUEUE_DIRECT; return JOB_REQUEUE_DIRECT;
} }
@@ -374,6 +397,12 @@ receiver_t *receiver_create()
} }
this->receive_delay = lib->settings->get_int(lib->settings, this->receive_delay = lib->settings->get_int(lib->settings,
"charon.receive_delay", 0); "charon.receive_delay", 0);
this->receive_delay_type = lib->settings->get_int(lib->settings,
"charon.receive_delay_type", 0),
this->receive_delay_request = lib->settings->get_bool(lib->settings,
"charon.receive_delay_request", TRUE),
this->receive_delay_response = lib->settings->get_int(lib->settings,
"charon.receive_delay_response", TRUE),
this->hasher = lib->crypto->create_hasher(lib->crypto, HASH_PREFERRED); this->hasher = lib->crypto->create_hasher(lib->crypto, HASH_PREFERRED);
if (this->hasher == NULL) if (this->hasher == NULL)