diff options
author | Christian Grothoff <christian@grothoff.org> | 2017-01-30 12:27:11 +0100 |
---|---|---|
committer | Christian Grothoff <christian@grothoff.org> | 2017-01-30 12:27:11 +0100 |
commit | 48332ff7d4631f9be2a059c2fe150e3be5fb37f6 (patch) | |
tree | ec9da85c16ca25f37ffc4bb4d835360ffb6f134a /src/cadet/gnunet-service-cadet-new_channel.c | |
parent | c4d0522fd416da83f77475e2bb8351a7b5b72cc3 (diff) | |
download | gnunet-48332ff7d4631f9be2a059c2fe150e3be5fb37f6.tar.gz gnunet-48332ff7d4631f9be2a059c2fe150e3be5fb37f6.zip |
have tunnel tell channel which connection it used for transmission, so we can track connection performance by observing ACKs on the channel-level
Diffstat (limited to 'src/cadet/gnunet-service-cadet-new_channel.c')
-rw-r--r-- | src/cadet/gnunet-service-cadet-new_channel.c | 20 |
1 files changed, 16 insertions, 4 deletions
diff --git a/src/cadet/gnunet-service-cadet-new_channel.c b/src/cadet/gnunet-service-cadet-new_channel.c index 8633e7f74..7929d3c4b 100644 --- a/src/cadet/gnunet-service-cadet-new_channel.c +++ b/src/cadet/gnunet-service-cadet-new_channel.c | |||
@@ -501,9 +501,12 @@ send_channel_open (void *cls); | |||
501 | * create message. Delays for a bit until we retry. | 501 | * create message. Delays for a bit until we retry. |
502 | * | 502 | * |
503 | * @param cls our `struct CadetChannel`. | 503 | * @param cls our `struct CadetChannel`. |
504 | * @param cid identifier of the connection within the tunnel, NULL | ||
505 | * if transmission failed | ||
504 | */ | 506 | */ |
505 | static void | 507 | static void |
506 | channel_open_sent_cb (void *cls) | 508 | channel_open_sent_cb (void *cls, |
509 | const struct GNUNET_CADET_ConnectionTunnelIdentifier *cid) | ||
507 | { | 510 | { |
508 | struct CadetChannel *ch = cls; | 511 | struct CadetChannel *ch = cls; |
509 | 512 | ||
@@ -755,9 +758,12 @@ GCCH_channel_incoming_new (struct CadetTunnel *t, | |||
755 | * ACKs for ACKs ;-). | 758 | * ACKs for ACKs ;-). |
756 | * | 759 | * |
757 | * @param cls our `struct CadetChannel`. | 760 | * @param cls our `struct CadetChannel`. |
761 | * @param cid identifier of the connection within the tunnel, NULL | ||
762 | * if transmission failed | ||
758 | */ | 763 | */ |
759 | static void | 764 | static void |
760 | send_ack_cb (void *cls) | 765 | send_ack_cb (void *cls, |
766 | const struct GNUNET_CADET_ConnectionTunnelIdentifier *cid) | ||
761 | { | 767 | { |
762 | struct CadetChannel *ch = cls; | 768 | struct CadetChannel *ch = cls; |
763 | 769 | ||
@@ -1322,9 +1328,12 @@ GCCH_handle_channel_plaintext_data (struct CadetChannel *ch, | |||
1322 | * wait for ACK (or retransmit). | 1328 | * wait for ACK (or retransmit). |
1323 | * | 1329 | * |
1324 | * @param cls the `struct CadetReliableMessage` that was sent | 1330 | * @param cls the `struct CadetReliableMessage` that was sent |
1331 | * @param cid identifier of the connection within the tunnel, NULL | ||
1332 | * if transmission failed | ||
1325 | */ | 1333 | */ |
1326 | static void | 1334 | static void |
1327 | data_sent_cb (void *cls); | 1335 | data_sent_cb (void *cls, |
1336 | const struct GNUNET_CADET_ConnectionTunnelIdentifier *cid); | ||
1328 | 1337 | ||
1329 | 1338 | ||
1330 | /** | 1339 | /** |
@@ -1549,9 +1558,12 @@ cmp_crm_by_next_retry (void *cls, | |||
1549 | * wait for ACK (or retransmit). | 1558 | * wait for ACK (or retransmit). |
1550 | * | 1559 | * |
1551 | * @param cls the `struct CadetReliableMessage` that was sent | 1560 | * @param cls the `struct CadetReliableMessage` that was sent |
1561 | * @param cid identifier of the connection within the tunnel, NULL | ||
1562 | * if transmission failed | ||
1552 | */ | 1563 | */ |
1553 | static void | 1564 | static void |
1554 | data_sent_cb (void *cls) | 1565 | data_sent_cb (void *cls, |
1566 | const struct GNUNET_CADET_ConnectionTunnelIdentifier *cid) | ||
1555 | { | 1567 | { |
1556 | struct CadetReliableMessage *crm = cls; | 1568 | struct CadetReliableMessage *crm = cls; |
1557 | struct CadetChannel *ch = crm->ch; | 1569 | struct CadetChannel *ch = crm->ch; |