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.c13
1 files changed, 6 insertions, 7 deletions
diff --git a/src/dht/gnunet-service-dht.c b/src/dht/gnunet-service-dht.c
index b8a45e5d1..c6ddb0ab9 100644
--- a/src/dht/gnunet-service-dht.c
+++ b/src/dht/gnunet-service-dht.c
@@ -144,7 +144,9 @@ static struct GNUNET_CORE_MessageHandler core_handlers[] = {
144 */ 144 */
145static void handle_dht_get (void *cls, struct GNUNET_DHT_GetMessage *get_msg, GNUNET_HashCode *key) 145static void handle_dht_get (void *cls, struct GNUNET_DHT_GetMessage *get_msg, GNUNET_HashCode *key)
146{ 146{
147#if DEBUG_DHT
147 GNUNET_HashCode get_key; 148 GNUNET_HashCode get_key;
149#endif
148 size_t get_type; 150 size_t get_type;
149 151
150 GNUNET_assert(ntohs(get_msg->header.size) >= sizeof(struct GNUNET_DHT_GetMessage)); 152 GNUNET_assert(ntohs(get_msg->header.size) >= sizeof(struct GNUNET_DHT_GetMessage));
@@ -164,14 +166,13 @@ static void handle_dht_get (void *cls, struct GNUNET_DHT_GetMessage *get_msg, GN
164 */ 166 */
165static void handle_dht_find_peer (void *cls, struct GNUNET_DHT_FindPeerMessage *find_msg, GNUNET_HashCode *key) 167static void handle_dht_find_peer (void *cls, struct GNUNET_DHT_FindPeerMessage *find_msg, GNUNET_HashCode *key)
166{ 168{
167
168 GNUNET_assert(ntohs(find_msg->header.size) == sizeof(struct GNUNET_DHT_FindPeerMessage));
169
170#if DEBUG_DHT 169#if DEBUG_DHT
171 GNUNET_log (GNUNET_ERROR_TYPE_DEBUG, 170 GNUNET_log (GNUNET_ERROR_TYPE_DEBUG,
172 "`%s': Received `%s' request from client, key %s\n", "DHT", "FIND PEER", GNUNET_h2s(key)); 171 "`%s': Received `%s' request from client, key %s (msg size %d, we expected %d)\n", "DHT", "FIND PEER", GNUNET_h2s(key), ntohs(find_msg->header.size), sizeof(struct GNUNET_DHT_FindPeerMessage));
173#endif 172#endif
174 173
174 GNUNET_assert(ntohs(find_msg->header.size) >= sizeof(struct GNUNET_DHT_FindPeerMessage));
175
175 /* FIXME: Implement find peer functionality here */ 176 /* FIXME: Implement find peer functionality here */
176} 177}
177 178
@@ -298,10 +299,8 @@ handle_dht_start_message(void *cls, struct GNUNET_SERVER_Client * client,
298 handle_dht_find_peer(cls, (struct GNUNET_DHT_FindPeerMessage *)enc_msg, &dht_msg->key); 299 handle_dht_find_peer(cls, (struct GNUNET_DHT_FindPeerMessage *)enc_msg, &dht_msg->key);
299 break; 300 break;
300 default: 301 default:
301#if DEBUG_DHT 302 GNUNET_log (GNUNET_ERROR_TYPE_WARNING,
302 GNUNET_log (GNUNET_ERROR_TYPE_DEBUG,
303 "`%s': Message type (%d) not handled\n", "DHT", enc_type); 303 "`%s': Message type (%d) not handled\n", "DHT", enc_type);
304#endif
305 } 304 }
306 305
307 GNUNET_SERVER_receive_done(client, GNUNET_OK); 306 GNUNET_SERVER_receive_done(client, GNUNET_OK);