Repository : ssh://git@open-mesh.org/alfred
On branch : master
---------------------------------------------------------------
commit 8167c3cc7acbb67f999bb6aadc22a06ded710fa7
Author: Sven Eckelmann <sven(a)narfation.org>
Date: Sat Nov 12 10:25:21 2016 +0100
alfred: Don't force cleanup of transaction on TXEND
A committed transaction has always to be cleaned up/removed when the TXEND
was received. But TXEND packets which are out-of-order may still be waiting
for PUSH_DATA packets which will be receive later. Thus TXEND packets which
don't trigger a commit of the PUSH_DATA should not automatically drop the
transaction.
A transaction which doesn't get all PUSH_DATA packets will be timeout
automatically and no extra handling is necessary.
Signed-off-by: Sven Eckelmann <sven(a)narfation.org>
Signed-off-by: Simon Wunderlich <sw(a)simonwunderlich.de>
---------------------------------------------------------------
8167c3cc7acbb67f999bb6aadc22a06ded710fa7
alfred.h | 2 +-
recv.c | 13 +++++--------
2 files changed, 6 insertions(+), 9 deletions(-)
diff --git a/alfred.h b/alfred.h
index 7e7811b..9d0f6a6 100644
--- a/alfred.h
+++ b/alfred.h
@@ -71,7 +71,7 @@ struct transaction_head {
struct ether_addr server_addr;
uint16_t id;
uint8_t requested_type;
- int finished;
+ uint16_t finished;
int num_packet;
int client_socket;
struct timespec last_rx_time;
diff --git a/recv.c b/recv.c
index 21ea539..dd0b021 100644
--- a/recv.c
+++ b/recv.c
@@ -167,17 +167,14 @@ static int finish_alfred_transaction(struct globals *globals,
{
struct transaction_packet *transaction_packet, *safe;
- /* missing packets -> cleanup everything */
- if (head->num_packet == num_packets)
- head->finished = -1;
- else
- head->finished = 1;
+ /* finish when all packets received */
+ if (head->num_packet != num_packets)
+ return 0;
+ head->finished = 1;
list_for_each_entry_safe(transaction_packet, safe, &head->packet_list,
list) {
- if (head->finished == 1)
- finish_alfred_push_data(globals, mac,
- transaction_packet->push);
+ finish_alfred_push_data(globals, mac, transaction_packet->push);
list_del(&transaction_packet->list);
free(transaction_packet->push);