diff options
Diffstat (limited to 'src/dht/gnunet-service-dht.c')
-rw-r--r-- | src/dht/gnunet-service-dht.c | 118 |
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 | */ |
68 | static void | 68 | static void |
69 | process_hello(void *cls, | 69 | process_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 | */ |
85 | static void | 85 | static void |
86 | shutdown_task(void *cls) | 86 | shutdown_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 | */ |
122 | static void | 122 | static void |
123 | run(void *cls, | 123 | run (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 */ |
161 | GDS_DHT_SERVICE_INIT("dht", &run); | 161 | GDS_DHT_SERVICE_INIT ("dht", &run); |
162 | 162 | ||
163 | 163 | ||
164 | 164 | ||