aboutsummaryrefslogtreecommitdiff
path: root/src/dht
diff options
context:
space:
mode:
authorChristian Grothoff <christian@grothoff.org>2022-01-18 21:18:30 +0100
committerChristian Grothoff <christian@grothoff.org>2022-02-19 12:41:01 +0100
commit0bd15d392c8c1c4dab56c794ec88fdbd7245cc51 (patch)
tree6370f222cdb735efdbae3022b1c94fc4c7207dc4 /src/dht
parente5f00fda52a45ebd22716debf0d9af36fb6fce0a (diff)
downloadgnunet-0bd15d392c8c1c4dab56c794ec88fdbd7245cc51.tar.gz
gnunet-0bd15d392c8c1c4dab56c794ec88fdbd7245cc51.zip
-adding logging, minor dthu bugfixes
Diffstat (limited to 'src/dht')
-rw-r--r--src/dht/gnunet-service-dht.c6
-rw-r--r--src/dht/gnunet-service-dht_clients.c8
-rw-r--r--src/dht/gnunet-service-dht_neighbours.c15
3 files changed, 29 insertions, 0 deletions
diff --git a/src/dht/gnunet-service-dht.c b/src/dht/gnunet-service-dht.c
index 4b0a290b9..39433791d 100644
--- a/src/dht/gnunet-service-dht.c
+++ b/src/dht/gnunet-service-dht.c
@@ -265,6 +265,9 @@ u_address_add (void *cls,
265 struct GDS_Underlay *u = cls; 265 struct GDS_Underlay *u = cls;
266 struct MyAddress *a; 266 struct MyAddress *a;
267 267
268 GNUNET_log (GNUNET_ERROR_TYPE_INFO,
269 "Underlay adds address %s for this peer\n",
270 address);
268 a = GNUNET_new (struct MyAddress); 271 a = GNUNET_new (struct MyAddress);
269 a->source = source; 272 a->source = source;
270 a->url = GNUNET_strdup (address); 273 a->url = GNUNET_strdup (address);
@@ -292,6 +295,9 @@ u_address_del (void *ctx)
292{ 295{
293 struct MyAddress *a = ctx; 296 struct MyAddress *a = ctx;
294 297
298 GNUNET_log (GNUNET_ERROR_TYPE_INFO,
299 "Underlay deletes address %s for this peer\n",
300 a->url);
295 GNUNET_HELLO_builder_del_address (GDS_my_hello, 301 GNUNET_HELLO_builder_del_address (GDS_my_hello,
296 a->url); 302 a->url);
297 GNUNET_CONTAINER_DLL_remove (a_head, 303 GNUNET_CONTAINER_DLL_remove (a_head,
diff --git a/src/dht/gnunet-service-dht_clients.c b/src/dht/gnunet-service-dht_clients.c
index e5819b193..dc451ed15 100644
--- a/src/dht/gnunet-service-dht_clients.c
+++ b/src/dht/gnunet-service-dht_clients.c
@@ -562,6 +562,9 @@ handle_local_result (void *cls,
562 const struct GDS_DATACACHE_BlockData *bd) 562 const struct GDS_DATACACHE_BlockData *bd)
563{ 563{
564 /* FIXME: use 'cls' instead of looking up the client? */ 564 /* FIXME: use 'cls' instead of looking up the client? */
565 GNUNET_log (GNUNET_ERROR_TYPE_INFO,
566 "Datacache provided result for query key %s\n",
567 GNUNET_h2s (&bd->key));
565 GDS_CLIENTS_handle_reply (bd, 568 GDS_CLIENTS_handle_reply (bd,
566 &bd->key, 569 &bd->key,
567 0, NULL /* get_path */); 570 0, NULL /* get_path */);
@@ -1081,6 +1084,8 @@ handle_dht_local_hello_get (void *cls,
1081 struct GNUNET_MessageHeader *hdr; 1084 struct GNUNET_MessageHeader *hdr;
1082 struct GNUNET_MQ_Envelope *env; 1085 struct GNUNET_MQ_Envelope *env;
1083 1086
1087 GNUNET_log (GNUNET_ERROR_TYPE_DEBUG,
1088 "Handling request from local client for my HELLO\n");
1084 env = GNUNET_MQ_msg_extra (hdr, 1089 env = GNUNET_MQ_msg_extra (hdr,
1085 slen, 1090 slen,
1086 GNUNET_MESSAGE_TYPE_DHT_CLIENT_HELLO_URL); 1091 GNUNET_MESSAGE_TYPE_DHT_CLIENT_HELLO_URL);
@@ -1134,6 +1139,9 @@ handle_dht_local_hello_offer (void *cls,
1134 struct GNUNET_HELLO_Builder *b; 1139 struct GNUNET_HELLO_Builder *b;
1135 struct GNUNET_PeerIdentity pid; 1140 struct GNUNET_PeerIdentity pid;
1136 1141
1142 GNUNET_log (GNUNET_ERROR_TYPE_DEBUG,
1143 "Local client provided HELLO URL %s\n",
1144 url);
1137 b = GNUNET_HELLO_builder_from_url (url); 1145 b = GNUNET_HELLO_builder_from_url (url);
1138 if (NULL == b) 1146 if (NULL == b)
1139 { 1147 {
diff --git a/src/dht/gnunet-service-dht_neighbours.c b/src/dht/gnunet-service-dht_neighbours.c
index 63307dea2..c4d6b7428 100644
--- a/src/dht/gnunet-service-dht_neighbours.c
+++ b/src/dht/gnunet-service-dht_neighbours.c
@@ -2260,7 +2260,11 @@ GDS_try_connect (void *cls,
2260 2260
2261 if (0 == GNUNET_memcmp (&GDS_my_identity, 2261 if (0 == GNUNET_memcmp (&GDS_my_identity,
2262 pid)) 2262 pid))
2263 {
2264 GNUNET_log (GNUNET_ERROR_TYPE_DEBUG,
2265 "Got a HELLO for my own PID, ignoring it\n");
2263 return; /* that's us! */ 2266 return; /* that's us! */
2267 }
2264 GNUNET_CRYPTO_hash (pid, 2268 GNUNET_CRYPTO_hash (pid,
2265 sizeof(*pid), 2269 sizeof(*pid),
2266 &phash); 2270 &phash);
@@ -2282,6 +2286,13 @@ GDS_try_connect (void *cls,
2282 alternative address??? */ 2286 alternative address??? */
2283 return; 2287 return;
2284 } 2288 }
2289 GNUNET_log (GNUNET_ERROR_TYPE_INFO,
2290 "Discovered peer %s at %s suitable for bucket %d (%u/%u), trying to connect\n",
2291 GNUNET_i2s (pid),
2292 uri,
2293 peer_bucket,
2294 bucket->peers_size,
2295 bucket_size);
2285 /* new peer that we like! */ 2296 /* new peer that we like! */
2286 GDS_u_try_connect (pid, 2297 GDS_u_try_connect (pid,
2287 uri); 2298 uri);
@@ -2492,6 +2503,10 @@ GDS_u_receive (void *cls,
2492 GNUNET_break_op (0); 2503 GNUNET_break_op (0);
2493 return; 2504 return;
2494 } 2505 }
2506 GNUNET_log (GNUNET_ERROR_TYPE_INFO,
2507 "Handling message of type %u from peer %s\n",
2508 ntohs (mh->type),
2509 GNUNET_i2s (&pi->id));
2495 if (GNUNET_OK != 2510 if (GNUNET_OK !=
2496 GNUNET_MQ_handle_message (core_handlers, 2511 GNUNET_MQ_handle_message (core_handlers,
2497 mh)) 2512 mh))