diff options
author | Christian Grothoff <christian@grothoff.org> | 2016-07-08 16:34:31 +0000 |
---|---|---|
committer | Christian Grothoff <christian@grothoff.org> | 2016-07-08 16:34:31 +0000 |
commit | 6e3599bab213760c66f13f6103ebf650bbe5b7e9 (patch) | |
tree | f56a0bbe3ce64c818c87bae6171ba800ab05b701 /src/core | |
parent | 2c0a286c8c29e135c68556658b6ac6cef48a874a (diff) | |
download | gnunet-6e3599bab213760c66f13f6103ebf650bbe5b7e9.tar.gz gnunet-6e3599bab213760c66f13f6103ebf650bbe5b7e9.zip |
migrate transport_core API to MQ
Diffstat (limited to 'src/core')
-rw-r--r-- | src/core/test_core_api.c | 6 | ||||
-rw-r--r-- | src/core/test_core_api_reliability.c | 10 | ||||
-rw-r--r-- | src/core/test_core_quota_compliance.c | 10 |
3 files changed, 13 insertions, 13 deletions
diff --git a/src/core/test_core_api.c b/src/core/test_core_api.c index 92ee038da..43f4c421e 100644 --- a/src/core/test_core_api.c +++ b/src/core/test_core_api.c | |||
@@ -65,9 +65,9 @@ process_hello (void *cls, | |||
65 | "Received (my) `%s' from transport service\n", "HELLO"); | 65 | "Received (my) `%s' from transport service\n", "HELLO"); |
66 | GNUNET_assert (message != NULL); | 66 | GNUNET_assert (message != NULL); |
67 | if ((p == &p1) && (p2.th != NULL)) | 67 | if ((p == &p1) && (p2.th != NULL)) |
68 | GNUNET_TRANSPORT_offer_hello (p2.th, message, NULL, NULL); | 68 | GNUNET_TRANSPORT_offer_hello (p2.cfg, message, NULL, NULL); |
69 | if ((p == &p2) && (p1.th != NULL)) | 69 | if ((p == &p2) && (p1.th != NULL)) |
70 | GNUNET_TRANSPORT_offer_hello (p1.th, message, NULL, NULL); | 70 | GNUNET_TRANSPORT_offer_hello (p1.cfg, message, NULL, NULL); |
71 | } | 71 | } |
72 | 72 | ||
73 | 73 | ||
@@ -280,7 +280,7 @@ setup_peer (struct PeerContext *p, | |||
280 | GNUNET_assert (NULL != p->th); | 280 | GNUNET_assert (NULL != p->th); |
281 | p->ats = GNUNET_ATS_connectivity_init (p->cfg); | 281 | p->ats = GNUNET_ATS_connectivity_init (p->cfg); |
282 | GNUNET_assert (NULL != p->ats); | 282 | GNUNET_assert (NULL != p->ats); |
283 | p->ghh = GNUNET_TRANSPORT_get_hello (p->th, &process_hello, p); | 283 | p->ghh = GNUNET_TRANSPORT_get_hello (p->cfg, &process_hello, p); |
284 | GNUNET_free (binary); | 284 | GNUNET_free (binary); |
285 | } | 285 | } |
286 | 286 | ||
diff --git a/src/core/test_core_api_reliability.c b/src/core/test_core_api_reliability.c index c7672afdb..94c223b74 100644 --- a/src/core/test_core_api_reliability.c +++ b/src/core/test_core_api_reliability.c | |||
@@ -412,14 +412,14 @@ process_hello (void *cls, | |||
412 | GNUNET_assert (message != NULL); | 412 | GNUNET_assert (message != NULL); |
413 | p->hello = GNUNET_copy_message (message); | 413 | p->hello = GNUNET_copy_message (message); |
414 | if ((p == &p1) && (p2.th != NULL)) | 414 | if ((p == &p1) && (p2.th != NULL)) |
415 | GNUNET_TRANSPORT_offer_hello (p2.th, message, NULL, NULL); | 415 | GNUNET_TRANSPORT_offer_hello (p2.cfg, message, NULL, NULL); |
416 | if ((p == &p2) && (p1.th != NULL)) | 416 | if ((p == &p2) && (p1.th != NULL)) |
417 | GNUNET_TRANSPORT_offer_hello (p1.th, message, NULL, NULL); | 417 | GNUNET_TRANSPORT_offer_hello (p1.cfg, message, NULL, NULL); |
418 | 418 | ||
419 | if ((p == &p1) && (p2.hello != NULL)) | 419 | if ((p == &p1) && (p2.hello != NULL)) |
420 | GNUNET_TRANSPORT_offer_hello (p1.th, p2.hello, NULL, NULL); | 420 | GNUNET_TRANSPORT_offer_hello (p1.cfg, p2.hello, NULL, NULL); |
421 | if ((p == &p2) && (p1.hello != NULL)) | 421 | if ((p == &p2) && (p1.hello != NULL)) |
422 | GNUNET_TRANSPORT_offer_hello (p2.th, p1.hello, NULL, NULL); | 422 | GNUNET_TRANSPORT_offer_hello (p2.cfg, p1.hello, NULL, NULL); |
423 | } | 423 | } |
424 | 424 | ||
425 | 425 | ||
@@ -442,7 +442,7 @@ setup_peer (struct PeerContext *p, | |||
442 | GNUNET_assert (p->th != NULL); | 442 | GNUNET_assert (p->th != NULL); |
443 | p->ats = GNUNET_ATS_connectivity_init (p->cfg); | 443 | p->ats = GNUNET_ATS_connectivity_init (p->cfg); |
444 | GNUNET_assert (NULL != p->ats); | 444 | GNUNET_assert (NULL != p->ats); |
445 | p->ghh = GNUNET_TRANSPORT_get_hello (p->th, &process_hello, p); | 445 | p->ghh = GNUNET_TRANSPORT_get_hello (p->cfg, &process_hello, p); |
446 | GNUNET_free (binary); | 446 | GNUNET_free (binary); |
447 | } | 447 | } |
448 | 448 | ||
diff --git a/src/core/test_core_quota_compliance.c b/src/core/test_core_quota_compliance.c index 05b1ae3d9..28d836e2e 100644 --- a/src/core/test_core_quota_compliance.c +++ b/src/core/test_core_quota_compliance.c | |||
@@ -547,14 +547,14 @@ process_hello (void *cls, const struct GNUNET_MessageHeader *message) | |||
547 | p->hello = GNUNET_malloc (ntohs (message->size)); | 547 | p->hello = GNUNET_malloc (ntohs (message->size)); |
548 | memcpy (p->hello, message, ntohs (message->size)); | 548 | memcpy (p->hello, message, ntohs (message->size)); |
549 | if ((p == &p1) && (p2.th != NULL)) | 549 | if ((p == &p1) && (p2.th != NULL)) |
550 | GNUNET_TRANSPORT_offer_hello (p2.th, message, NULL, NULL); | 550 | GNUNET_TRANSPORT_offer_hello (p2.cfg, message, NULL, NULL); |
551 | if ((p == &p2) && (p1.th != NULL)) | 551 | if ((p == &p2) && (p1.th != NULL)) |
552 | GNUNET_TRANSPORT_offer_hello (p1.th, message, NULL, NULL); | 552 | GNUNET_TRANSPORT_offer_hello (p1.cfg, message, NULL, NULL); |
553 | 553 | ||
554 | if ((p == &p1) && (p2.hello != NULL)) | 554 | if ((p == &p1) && (p2.hello != NULL)) |
555 | GNUNET_TRANSPORT_offer_hello (p1.th, p2.hello, NULL, NULL); | 555 | GNUNET_TRANSPORT_offer_hello (p1.cfg, p2.hello, NULL, NULL); |
556 | if ((p == &p2) && (p1.hello != NULL)) | 556 | if ((p == &p2) && (p1.hello != NULL)) |
557 | GNUNET_TRANSPORT_offer_hello (p2.th, p1.hello, NULL, NULL); | 557 | GNUNET_TRANSPORT_offer_hello (p2.cfg, p1.hello, NULL, NULL); |
558 | } | 558 | } |
559 | 559 | ||
560 | 560 | ||
@@ -579,7 +579,7 @@ setup_peer (struct PeerContext *p, const char *cfgname) | |||
579 | GNUNET_assert (p->th != NULL); | 579 | GNUNET_assert (p->th != NULL); |
580 | p->ats = GNUNET_ATS_connectivity_init (p->cfg); | 580 | p->ats = GNUNET_ATS_connectivity_init (p->cfg); |
581 | GNUNET_assert (NULL != p->ats); | 581 | GNUNET_assert (NULL != p->ats); |
582 | p->ghh = GNUNET_TRANSPORT_get_hello (p->th, &process_hello, p); | 582 | p->ghh = GNUNET_TRANSPORT_get_hello (p->cfg, &process_hello, p); |
583 | GNUNET_free (binary); | 583 | GNUNET_free (binary); |
584 | } | 584 | } |
585 | 585 | ||