diff options
author | Christian Grothoff <grothoff@gnunet.org> | 2022-01-03 15:35:49 +0100 |
---|---|---|
committer | Christian Grothoff <grothoff@gnunet.org> | 2022-01-03 15:35:49 +0100 |
commit | 44efce8316b644f15b5e87852f5b7df7d58cfa97 (patch) | |
tree | 8c65a552e11b56ab86748eafdac4a87958cf5d1e /src/dht/gnunet-service-dht_routing.c | |
parent | f72a57c08e2f3d4c55fd0a700b48138fdfe8df5d (diff) | |
download | gnunet-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.c | 29 |
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, |