sharpetronics/strongswan
1
0
Fork 0
mirror of https://github.com/strongswan/strongswan.git synced 2025-11-22 00:01:45 -05:00
Code Issues Projects Releases Wiki Activity

Indicate message retransmissions while initiating load-test batches

Browse Source
This commit is contained in:
Martin Willi 2012-10-19 11:36:31 +02:00
parent 3c79b7b7db
commit cf85f6b296
1 changed files with 26 additions and 0 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

26
src/libcharon/plugins/load_tester/load_tester_control.c
View File

@ -142,6 +142,31 @@ static bool equals(uintptr_t a, uintptr_t b)
return a == b; return a == b;
} }
METHOD(listener_t, alert, bool,
init_listener_t *this, ike_sa_t *ike_sa, alert_t alert, va_list args)
{
if (alert == ALERT_RETRANSMIT_SEND)
{
uintptr_t id;
bool match = FALSE;
id = ike_sa->get_unique_id(ike_sa);
this->mutex->lock(this->mutex);
if (this->initiated->get(this->initiated, (void*)id))
{
match = TRUE;
}
this->mutex->unlock(this->mutex);
if (match)
{
fprintf(this->stream, "*");
fflush(this->stream);
}
}
return TRUE;
}
METHOD(listener_t, ike_state_change, bool, METHOD(listener_t, ike_state_change, bool,
init_listener_t *this, ike_sa_t *ike_sa, ike_sa_state_t state) init_listener_t *this, ike_sa_t *ike_sa, ike_sa_state_t state)
{ {
@ -214,6 +239,7 @@ static job_requeue_t initiate(FILE *stream)
INIT(listener, INIT(listener,
.listener = { .listener = {
.ike_state_change = _ike_state_change, .ike_state_change = _ike_state_change,
.alert = _alert,
}, },
.stream = stream, .stream = stream,
.initiated = hashtable_create((void*)hash, (void*)equals, count), .initiated = hashtable_create((void*)hash, (void*)equals, count),