aboutsummaryrefslogtreecommitdiff
path: root/src/dht
diff options
context:
space:
mode:
authorChristian Grothoff <christian@grothoff.org>2016-07-08 16:34:31 +0000
committerChristian Grothoff <christian@grothoff.org>2016-07-08 16:34:31 +0000
commit6e3599bab213760c66f13f6103ebf650bbe5b7e9 (patch)
treef56a0bbe3ce64c818c87bae6171ba800ab05b701 /src/dht
parent2c0a286c8c29e135c68556658b6ac6cef48a874a (diff)
downloadgnunet-6e3599bab213760c66f13f6103ebf650bbe5b7e9.tar.gz
gnunet-6e3599bab213760c66f13f6103ebf650bbe5b7e9.zip
migrate transport_core API to MQ
Diffstat (limited to 'src/dht')
-rw-r--r--src/dht/gnunet-service-dht.c22
-rw-r--r--src/dht/gnunet-service-dht.h4
-rw-r--r--src/dht/gnunet-service-dht_neighbours.c8
3 files changed, 6 insertions, 28 deletions
diff --git a/src/dht/gnunet-service-dht.c b/src/dht/gnunet-service-dht.c
index abdd77548..e3b9d59a4 100644
--- a/src/dht/gnunet-service-dht.c
+++ b/src/dht/gnunet-service-dht.c
@@ -67,11 +67,6 @@ struct GNUNET_SERVER_Handle *GDS_server;
67struct GNUNET_MessageHeader *GDS_my_hello; 67struct GNUNET_MessageHeader *GDS_my_hello;
68 68
69/** 69/**
70 * Handle to the transport service, for getting our hello
71 */
72struct GNUNET_TRANSPORT_Handle *GDS_transport_handle;
73
74/**
75 * Handle to get our current HELLO. 70 * Handle to get our current HELLO.
76 */ 71 */
77static struct GNUNET_TRANSPORT_GetHelloHandle *ghh; 72static struct GNUNET_TRANSPORT_GetHelloHandle *ghh;
@@ -112,11 +107,6 @@ shutdown_task (void *cls)
112 GNUNET_TRANSPORT_get_hello_cancel (ghh); 107 GNUNET_TRANSPORT_get_hello_cancel (ghh);
113 ghh = NULL; 108 ghh = NULL;
114 } 109 }
115 if (GDS_transport_handle != NULL)
116 {
117 GNUNET_TRANSPORT_disconnect (GDS_transport_handle);
118 GDS_transport_handle = NULL;
119 }
120 GDS_NEIGHBOURS_done (); 110 GDS_NEIGHBOURS_done ();
121 GDS_DATACACHE_done (); 111 GDS_DATACACHE_done ();
122 GDS_ROUTING_done (); 112 GDS_ROUTING_done ();
@@ -170,15 +160,9 @@ run (void *cls,
170 } 160 }
171 GNUNET_SCHEDULER_add_shutdown (&shutdown_task, 161 GNUNET_SCHEDULER_add_shutdown (&shutdown_task,
172 NULL); 162 NULL);
173 GDS_transport_handle = 163 ghh = GNUNET_TRANSPORT_get_hello (GDS_cfg,
174 GNUNET_TRANSPORT_connect (GDS_cfg, NULL, NULL, NULL, NULL, NULL); 164 &process_hello,
175 if (GDS_transport_handle == NULL) 165 NULL);
176 {
177 GNUNET_log (GNUNET_ERROR_TYPE_WARNING,
178 _("Failed to connect to transport service!\n"));
179 return;
180 }
181 ghh = GNUNET_TRANSPORT_get_hello (GDS_transport_handle, &process_hello, NULL);
182} 166}
183 167
184 168
diff --git a/src/dht/gnunet-service-dht.h b/src/dht/gnunet-service-dht.h
index 6f641cb96..4684c2324 100644
--- a/src/dht/gnunet-service-dht.h
+++ b/src/dht/gnunet-service-dht.h
@@ -57,9 +57,5 @@ extern struct GNUNET_SERVER_Handle *GDS_server;
57 */ 57 */
58extern struct GNUNET_MessageHeader *GDS_my_hello; 58extern struct GNUNET_MessageHeader *GDS_my_hello;
59 59
60/**
61 * Handle to the transport service, for getting our hello
62 */
63extern struct GNUNET_TRANSPORT_Handle *GDS_transport_handle;
64 60
65#endif 61#endif
diff --git a/src/dht/gnunet-service-dht_neighbours.c b/src/dht/gnunet-service-dht_neighbours.c
index 4add3c4ae..b24a95ab2 100644
--- a/src/dht/gnunet-service-dht_neighbours.c
+++ b/src/dht/gnunet-service-dht_neighbours.c
@@ -592,13 +592,11 @@ try_connect (const struct GNUNET_PeerIdentity *pid,
592 ci, 592 ci,
593 GNUNET_CONTAINER_MULTIHASHMAPOPTION_UNIQUE_ONLY)); 593 GNUNET_CONTAINER_MULTIHASHMAPOPTION_UNIQUE_ONLY));
594 } 594 }
595 if ( (NULL != GDS_transport_handle) && 595 if ( (NULL != ci->oh) &&
596 (NULL != ci->oh) &&
597 (NULL != h) ) 596 (NULL != h) )
598 GNUNET_TRANSPORT_offer_hello_cancel (ci->oh); 597 GNUNET_TRANSPORT_offer_hello_cancel (ci->oh);
599 if ( (NULL != GDS_transport_handle) && 598 if (NULL != h)
600 (NULL != h) ) 599 ci->oh = GNUNET_TRANSPORT_offer_hello (GDS_cfg,
601 ci->oh = GNUNET_TRANSPORT_offer_hello (GDS_transport_handle,
602 h, 600 h,
603 &offer_hello_done, 601 &offer_hello_done,
604 ci); 602 ci);