agorise/c-libp2p
1
0
Fork 0
Code Issues Pull requests Projects Releases Packages Wiki Activity

bug fix in add_provider

Browse source
This commit is contained in:
John Jones 2017-04-03 17:41:13 -05:00
parent 1489e4fbf8
commit 5643c553df
1 changed files with 2 additions and 5 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

7
routing/dht_protocol.c
View file

@ -132,11 +132,6 @@ int libp2p_routing_dht_handle_add_provider(struct SessionContext* session, struc
if (!libp2p_peerstore_add_peer(peerstore, peer)) if (!libp2p_peerstore_add_peer(peerstore, peer))
goto exit; goto exit;
libp2p_peer_free(peer);
if (retVal == 0)
goto exit;
*result_buffer_size = libp2p_message_protobuf_encode_size(message); *result_buffer_size = libp2p_message_protobuf_encode_size(message);
*result_buffer = (unsigned char*)malloc(*result_buffer_size); *result_buffer = (unsigned char*)malloc(*result_buffer_size);
if (*result_buffer == NULL) if (*result_buffer == NULL)
@ -257,6 +252,8 @@ int libp2p_routing_dht_handle_message(struct SessionContext* session, struct Pee
libp2p_logger_debug("dht_protocol", "Sending message back to caller\n"); libp2p_logger_debug("dht_protocol", "Sending message back to caller\n");
if (!session->default_stream->write(session, result_buffer, result_buffer_size)) if (!session->default_stream->write(session, result_buffer, result_buffer_size))
goto exit; goto exit;
} else {
libp2p_logger_debug("dht_protocol", "Nothing to send back. Kademlia call has been handled\n");
} }
retVal = 1; retVal = 1;
exit: exit: