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

Fixed duplicate result in kademlia search.

Browse source
This commit is contained in:
Jose Marcial Vieira Bisneto 2017-03-16 09:54:36 -03:00
parent 17dfadb6fd
commit 52f8ce2b3d
2 changed files with 6 additions and 3 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

5
routing/Makefile
View file

@ -16,6 +16,9 @@ $(DHT_DIR)/dht.h:
dht.c: $(DEPS) dht.c: $(DEPS)
ln -s $(DHT_DIR)/dht.c . ln -s $(DHT_DIR)/dht.c .
kademlia_test: $(OBJS)
$(CC) -o kademlia_test kademlia_test.c kademlia.o dht.o $(CFLAGS) -pthread ../libp2p.a ../../c-multiaddr/libmultiaddr.a -lm
clean: clean:
rm -f $(OBJS) dht.c rm -f kademlia_test $(OBJS) dht.c
rm -rf $(DHT_DIR) rm -rf $(DHT_DIR)

4
routing/kademlia.c
View file

@ -104,7 +104,7 @@ callback(void *closure,
memcpy(&ipv4.port, data+4, 2); memcpy(&ipv4.port, data+4, 2);
ipv4.port = ntohs(ipv4.port); ipv4.port = ntohs(ipv4.port);
for (i = 0 ; i < rp->ipv4_count ; i++) { for (i = 0 ; i < rp->ipv4_count ; i++) {
if (memcmp(&rp->ipv4[i], &ipv4, sizeof ipv4)) { if (memcmp(&rp->ipv4[i], &ipv4, sizeof ipv4) == 0) {
return; // Alread in the list. return; // Alread in the list.
} }
} }
@ -120,7 +120,7 @@ callback(void *closure,
memcpy(&ipv6.ip, data, 16); memcpy(&ipv6.ip, data, 16);
memcpy(&ipv6.port, data+16, 2); memcpy(&ipv6.port, data+16, 2);
for (i = 0 ; i < rp->ipv6_count ; i++) { for (i = 0 ; i < rp->ipv6_count ; i++) {
if (memcmp(&rp->ipv6[i], &ipv6, sizeof ipv6)) { if (memcmp(&rp->ipv6[i], &ipv6, sizeof ipv6) == 0) {
return; // Alread in the list. return; // Alread in the list.
} }
} }