From 5de67539ef9343aafaf44580fa8e28740d49b0ea Mon Sep 17 00:00:00 2001 From: jmjatlanta Date: Wed, 16 Aug 2017 07:34:28 -0500 Subject: [PATCH] correctly adding request to peer_request_queue --- exchange/bitswap/engine.c | 2 +- exchange/bitswap/peer_request_queue.c | 10 +++++++--- 2 files changed, 8 insertions(+), 4 deletions(-) diff --git a/exchange/bitswap/engine.c b/exchange/bitswap/engine.c index c82268b..0fd00d1 100644 --- a/exchange/bitswap/engine.c +++ b/exchange/bitswap/engine.c @@ -85,7 +85,7 @@ void* ipfs_bitswap_engine_peer_request_processor_start(void* ctx) { if (current_peer_entry->sessionContext == NULL || current_peer_entry->sessionContext->default_stream == NULL) { current_peer_entry->connection_type = CONNECTION_TYPE_NOT_CONNECTED; } else { - libp2p_logger_debug("bitswap_engine", "We're connected to this peer. Lets see if there is a message waiting for us.\n"); + libp2p_logger_debug("bitswap_engine", "We're connected to %s. Lets see if there is a message waiting for us.\n", current_peer_entry->id); int retVal = current_peer_entry->sessionContext->default_stream->peek(current_peer_entry->sessionContext); if (retVal < 0) { libp2p_logger_debug("bitswap_engine", "We thought we were connected, but Peek reported an error.\n"); diff --git a/exchange/bitswap/peer_request_queue.c b/exchange/bitswap/peer_request_queue.c index a8882e8..1664c1d 100644 --- a/exchange/bitswap/peer_request_queue.c +++ b/exchange/bitswap/peer_request_queue.c @@ -427,10 +427,14 @@ struct PeerRequest* ipfs_peer_request_queue_find_peer(struct PeerRequestQueue* q entry->current = ipfs_bitswap_peer_request_new(); entry->current->peer = peer; // attach it to the queue - if (queue->first == NULL) + if (queue->first == NULL) { queue->first = entry; - entry->prior = queue->last; - queue->last = entry; + queue->last = entry; + } else { + queue->last->next = entry; + entry->prior = queue->last; + queue->last = entry; + } return entry->current; }