aboutsummaryrefslogtreecommitdiff
path: root/src/cadet/gnunet-service-cadet-new_channel.c
diff options
context:
space:
mode:
authorChristian Grothoff <christian@grothoff.org>2017-01-30 12:27:11 +0100
committerChristian Grothoff <christian@grothoff.org>2017-01-30 12:27:11 +0100
commit48332ff7d4631f9be2a059c2fe150e3be5fb37f6 (patch)
treeec9da85c16ca25f37ffc4bb4d835360ffb6f134a /src/cadet/gnunet-service-cadet-new_channel.c
parentc4d0522fd416da83f77475e2bb8351a7b5b72cc3 (diff)
downloadgnunet-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.c20
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 */
505static void 507static void
506channel_open_sent_cb (void *cls) 508channel_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 */
759static void 764static void
760send_ack_cb (void *cls) 765send_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 */
1326static void 1334static void
1327data_sent_cb (void *cls); 1335data_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 */
1553static void 1564static void
1554data_sent_cb (void *cls) 1565data_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;