aboutsummaryrefslogtreecommitdiff
path: root/src/dht/gnunet-service-dht_routing.c
diff options
context:
space:
mode:
authorChristian Grothoff <grothoff@gnunet.org>2022-01-03 15:35:49 +0100
committerChristian Grothoff <grothoff@gnunet.org>2022-01-03 15:35:49 +0100
commit44efce8316b644f15b5e87852f5b7df7d58cfa97 (patch)
tree8c65a552e11b56ab86748eafdac4a87958cf5d1e /src/dht/gnunet-service-dht_routing.c
parentf72a57c08e2f3d4c55fd0a700b48138fdfe8df5d (diff)
downloadgnunet-44efce8316b644f15b5e87852f5b7df7d58cfa97.tar.gz
gnunet-44efce8316b644f15b5e87852f5b7df7d58cfa97.zip
-more DHT code cleanup (no substantial changes)
Diffstat (limited to 'src/dht/gnunet-service-dht_routing.c')
-rw-r--r--src/dht/gnunet-service-dht_routing.c29
1 files changed, 21 insertions, 8 deletions
diff --git a/src/dht/gnunet-service-dht_routing.c b/src/dht/gnunet-service-dht_routing.c
index 8ba0c70ad..ec36eae75 100644
--- a/src/dht/gnunet-service-dht_routing.c
+++ b/src/dht/gnunet-service-dht_routing.c
@@ -179,14 +179,27 @@ process (void *cls,
179 case GNUNET_BLOCK_REPLY_OK_MORE: 179 case GNUNET_BLOCK_REPLY_OK_MORE:
180 case GNUNET_BLOCK_REPLY_OK_LAST: 180 case GNUNET_BLOCK_REPLY_OK_LAST:
181 case GNUNET_BLOCK_REPLY_TYPE_NOT_SUPPORTED: 181 case GNUNET_BLOCK_REPLY_TYPE_NOT_SUPPORTED:
182 GNUNET_STATISTICS_update (GDS_stats, 182 {
183 "# Good REPLIES matched against routing table", 183 struct PeerInfo *pi;
184 1, 184
185 GNUNET_NO); 185 GNUNET_STATISTICS_update (GDS_stats,
186 GDS_NEIGHBOURS_handle_reply (&rr->peer, 186 "# Good REPLIES matched against routing table",
187 &bdx, 187 1,
188 query_hash, 188 GNUNET_NO);
189 get_path_length, pc->get_path); 189 pi = GDS_NEIGHBOURS_lookup_peer (&rr->peer);
190 if (NULL == pi)
191 {
192 /* peer disconnected in the meantime, drop reply */
193 GNUNET_log (GNUNET_ERROR_TYPE_DEBUG,
194 "No matching peer for reply for key %s\n",
195 GNUNET_h2s (query_hash));
196 return GNUNET_OK;
197 }
198 GDS_NEIGHBOURS_handle_reply (pi,
199 &bdx,
200 query_hash,
201 get_path_length, pc->get_path);
202 }
190 break; 203 break;
191 case GNUNET_BLOCK_REPLY_OK_DUPLICATE: 204 case GNUNET_BLOCK_REPLY_OK_DUPLICATE:
192 GNUNET_STATISTICS_update (GDS_stats, 205 GNUNET_STATISTICS_update (GDS_stats,