aboutsummaryrefslogtreecommitdiff
path: root/src/dht/gnunet-service-dht.c
diff options
context:
space:
mode:
Diffstat (limited to 'src/dht/gnunet-service-dht.c')
-rw-r--r--src/dht/gnunet-service-dht.c118
1 files changed, 59 insertions, 59 deletions
diff --git a/src/dht/gnunet-service-dht.c b/src/dht/gnunet-service-dht.c
index c1e4c03b0..380002deb 100644
--- a/src/dht/gnunet-service-dht.c
+++ b/src/dht/gnunet-service-dht.c
@@ -66,14 +66,14 @@ struct GNUNET_TIME_Relative hello_expiration;
66 * @param message HELLO message of peer 66 * @param message HELLO message of peer
67 */ 67 */
68static void 68static void
69process_hello(void *cls, 69process_hello (void *cls,
70 const struct GNUNET_MessageHeader *message) 70 const struct GNUNET_MessageHeader *message)
71{ 71{
72 GNUNET_free_non_null(GDS_my_hello); 72 GNUNET_free_non_null (GDS_my_hello);
73 GDS_my_hello = GNUNET_malloc(ntohs(message->size)); 73 GDS_my_hello = GNUNET_malloc (ntohs (message->size));
74 GNUNET_memcpy(GDS_my_hello, 74 GNUNET_memcpy (GDS_my_hello,
75 message, 75 message,
76 ntohs(message->size)); 76 ntohs (message->size));
77} 77}
78 78
79 79
@@ -83,32 +83,32 @@ process_hello(void *cls,
83 * @param cls unused 83 * @param cls unused
84 */ 84 */
85static void 85static void
86shutdown_task(void *cls) 86shutdown_task (void *cls)
87{ 87{
88 if (NULL != ghh) 88 if (NULL != ghh)
89 { 89 {
90 GNUNET_TRANSPORT_hello_get_cancel(ghh); 90 GNUNET_TRANSPORT_hello_get_cancel (ghh);
91 ghh = NULL; 91 ghh = NULL;
92 } 92 }
93 GDS_NEIGHBOURS_done(); 93 GDS_NEIGHBOURS_done ();
94 GDS_DATACACHE_done(); 94 GDS_DATACACHE_done ();
95 GDS_ROUTING_done(); 95 GDS_ROUTING_done ();
96 GDS_HELLO_done(); 96 GDS_HELLO_done ();
97 GDS_NSE_done(); 97 GDS_NSE_done ();
98 if (NULL != GDS_block_context) 98 if (NULL != GDS_block_context)
99 { 99 {
100 GNUNET_BLOCK_context_destroy(GDS_block_context); 100 GNUNET_BLOCK_context_destroy (GDS_block_context);
101 GDS_block_context = NULL; 101 GDS_block_context = NULL;
102 } 102 }
103 if (NULL != GDS_stats) 103 if (NULL != GDS_stats)
104 { 104 {
105 GNUNET_STATISTICS_destroy(GDS_stats, 105 GNUNET_STATISTICS_destroy (GDS_stats,
106 GNUNET_YES); 106 GNUNET_YES);
107 GDS_stats = NULL; 107 GDS_stats = NULL;
108 } 108 }
109 GNUNET_free_non_null(GDS_my_hello); 109 GNUNET_free_non_null (GDS_my_hello);
110 GDS_my_hello = NULL; 110 GDS_my_hello = NULL;
111 GDS_CLIENTS_stop(); 111 GDS_CLIENTS_stop ();
112} 112}
113 113
114 114
@@ -120,45 +120,45 @@ shutdown_task(void *cls)
120 * @param service the initialized service 120 * @param service the initialized service
121 */ 121 */
122static void 122static void
123run(void *cls, 123run (void *cls,
124 const struct GNUNET_CONFIGURATION_Handle *c, 124 const struct GNUNET_CONFIGURATION_Handle *c,
125 struct GNUNET_SERVICE_Handle *service) 125 struct GNUNET_SERVICE_Handle *service)
126{ 126{
127 GDS_cfg = c; 127 GDS_cfg = c;
128 GDS_service = service; 128 GDS_service = service;
129 if (GNUNET_OK != 129 if (GNUNET_OK !=
130 GNUNET_CONFIGURATION_get_value_time(c, 130 GNUNET_CONFIGURATION_get_value_time (c,
131 "transport", 131 "transport",
132 "HELLO_EXPIRATION", 132 "HELLO_EXPIRATION",
133 &hello_expiration)) 133 &hello_expiration))
134 { 134 {
135 hello_expiration = GNUNET_CONSTANTS_HELLO_ADDRESS_EXPIRATION; 135 hello_expiration = GNUNET_CONSTANTS_HELLO_ADDRESS_EXPIRATION;
136 } 136 }
137 GDS_block_context = GNUNET_BLOCK_context_create(GDS_cfg); 137 GDS_block_context = GNUNET_BLOCK_context_create (GDS_cfg);
138 GDS_stats = GNUNET_STATISTICS_create("dht", 138 GDS_stats = GNUNET_STATISTICS_create ("dht",
139 GDS_cfg); 139 GDS_cfg);
140 GNUNET_SERVICE_suspend(GDS_service); 140 GNUNET_SERVICE_suspend (GDS_service);
141 GDS_CLIENTS_init(); 141 GDS_CLIENTS_init ();
142 GDS_ROUTING_init(); 142 GDS_ROUTING_init ();
143 GDS_NSE_init(); 143 GDS_NSE_init ();
144 GDS_DATACACHE_init(); 144 GDS_DATACACHE_init ();
145 GDS_HELLO_init(); 145 GDS_HELLO_init ();
146 if (GNUNET_OK != GDS_NEIGHBOURS_init()) 146 if (GNUNET_OK != GDS_NEIGHBOURS_init ())
147 { 147 {
148 shutdown_task(NULL); 148 shutdown_task (NULL);
149 return; 149 return;
150 } 150 }
151 GNUNET_SCHEDULER_add_shutdown(&shutdown_task, 151 GNUNET_SCHEDULER_add_shutdown (&shutdown_task,
152 NULL); 152 NULL);
153 ghh = GNUNET_TRANSPORT_hello_get(GDS_cfg, 153 ghh = GNUNET_TRANSPORT_hello_get (GDS_cfg,
154 GNUNET_TRANSPORT_AC_GLOBAL, 154 GNUNET_TRANSPORT_AC_GLOBAL,
155 &process_hello, 155 &process_hello,
156 NULL); 156 NULL);
157} 157}
158 158
159 159
160/* Finally, define the main method */ 160/* Finally, define the main method */
161GDS_DHT_SERVICE_INIT("dht", &run); 161GDS_DHT_SERVICE_INIT ("dht", &run);
162 162
163 163
164 164