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

Removed some test code

Browse source
This commit is contained in:
John Jones 2017-08-31 12:52:36 -05:00
parent 1eab27fa0e
commit f9d836ef6f
1 changed files with 0 additions and 20 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

20
routing/online.c
View file

@ -56,26 +56,6 @@ struct KademliaMessage* ipfs_routing_online_send_receive_message(struct SessionC
goto exit; goto exit;
} }
// remove protocol
uint8_t *pos = &results[0];
size_t pos_length = results_size;
int results_max = fmin(results_size, 30);
for (int i = 0; i < results_max; i++) {
if (results[i] == '\n') {
if (i < results_size - 1) {
// there's more left
pos = &results[i];
pos_length = results_size - i;
} else {
// we've run out of buffer. See if we have more on the network.
if (!sessionContext->default_stream->read(sessionContext, &results, &results_size, 5)) {
// we don't have more. This is a problem.
libp2p_logger_error("online", "Reading kademlia response returned nothing.\n");
}
}
}
}
// see if we can unprotobuf // see if we can unprotobuf
if (!libp2p_message_protobuf_decode(results, results_size, &return_message)) { if (!libp2p_message_protobuf_decode(results, results_size, &return_message)) {
libp2p_logger_error("online", "Received kademlia response, but cannot decode it.\n"); libp2p_logger_error("online", "Received kademlia response, but cannot decode it.\n");