task-manager: Add retransmit cleared alert
This commit is contained in:
@@ -105,6 +105,9 @@ enum alert_t {
|
|||||||
* of the retransmit, if the message got fragmented only the first fragment
|
* of the retransmit, if the message got fragmented only the first fragment
|
||||||
* is passed */
|
* is passed */
|
||||||
ALERT_RETRANSMIT_SEND,
|
ALERT_RETRANSMIT_SEND,
|
||||||
|
/** received response for retransmitted request, argument is packet_t, if
|
||||||
|
* the message got fragmented only the first fragment is passed */
|
||||||
|
ALERT_RETRANSMIT_SEND_CLEARED,
|
||||||
/** sending retransmits timed out, argument is packet_t, if available and if
|
/** sending retransmits timed out, argument is packet_t, if available and if
|
||||||
* the message got fragmented only the first fragment is passed */
|
* the message got fragmented only the first fragment is passed */
|
||||||
ALERT_RETRANSMIT_SEND_TIMEOUT,
|
ALERT_RETRANSMIT_SEND_TIMEOUT,
|
||||||
|
|||||||
@@ -1181,6 +1181,12 @@ static status_t process_response(private_task_manager_t *this,
|
|||||||
}
|
}
|
||||||
enumerator->destroy(enumerator);
|
enumerator->destroy(enumerator);
|
||||||
|
|
||||||
|
if (this->initiating.retransmitted)
|
||||||
|
{
|
||||||
|
packet_t *packet = NULL;
|
||||||
|
array_get(this->initiating.packets, 0, &packet);
|
||||||
|
charon->bus->alert(charon->bus, ALERT_RETRANSMIT_SEND_CLEARED, packet);
|
||||||
|
}
|
||||||
this->initiating.type = EXCHANGE_TYPE_UNDEFINED;
|
this->initiating.type = EXCHANGE_TYPE_UNDEFINED;
|
||||||
clear_packets(this->initiating.packets);
|
clear_packets(this->initiating.packets);
|
||||||
|
|
||||||
|
|||||||
@@ -695,6 +695,13 @@ static status_t process_response(private_task_manager_t *this,
|
|||||||
}
|
}
|
||||||
enumerator->destroy(enumerator);
|
enumerator->destroy(enumerator);
|
||||||
|
|
||||||
|
if (this->initiating.retransmitted)
|
||||||
|
{
|
||||||
|
packet_t *packet = NULL;
|
||||||
|
array_get(this->initiating.packets, 0, &packet);
|
||||||
|
charon->bus->alert(charon->bus, ALERT_RETRANSMIT_SEND_CLEARED, packet);
|
||||||
|
}
|
||||||
|
|
||||||
/* catch if we get resetted while processing */
|
/* catch if we get resetted while processing */
|
||||||
this->reset = FALSE;
|
this->reset = FALSE;
|
||||||
enumerator = array_create_enumerator(this->active_tasks);
|
enumerator = array_create_enumerator(this->active_tasks);
|
||||||
|
|||||||
Reference in New Issue
Block a user