diff options
author | Christian Grothoff <christian@grothoff.org> | 2022-01-18 21:18:30 +0100 |
---|---|---|
committer | Christian Grothoff <christian@grothoff.org> | 2022-02-19 12:41:01 +0100 |
commit | 0bd15d392c8c1c4dab56c794ec88fdbd7245cc51 (patch) | |
tree | 6370f222cdb735efdbae3022b1c94fc4c7207dc4 /src/dht | |
parent | e5f00fda52a45ebd22716debf0d9af36fb6fce0a (diff) | |
download | gnunet-0bd15d392c8c1c4dab56c794ec88fdbd7245cc51.tar.gz gnunet-0bd15d392c8c1c4dab56c794ec88fdbd7245cc51.zip |
-adding logging, minor dthu bugfixes
Diffstat (limited to 'src/dht')
-rw-r--r-- | src/dht/gnunet-service-dht.c | 6 | ||||
-rw-r--r-- | src/dht/gnunet-service-dht_clients.c | 8 | ||||
-rw-r--r-- | src/dht/gnunet-service-dht_neighbours.c | 15 |
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)) |