mirror of
https://github.com/ChronosX88/KademliaDHT.git
synced 2024-11-22 10:12:19 +00:00
Moved the receiver interface to the message/receiver package
This commit is contained in:
parent
6503c79681
commit
6978a8023b
@ -16,7 +16,7 @@ import java.util.TimerTask;
|
|||||||
import kademlia.message.Message;
|
import kademlia.message.Message;
|
||||||
import kademlia.message.MessageFactory;
|
import kademlia.message.MessageFactory;
|
||||||
import kademlia.node.Node;
|
import kademlia.node.Node;
|
||||||
import kademlia.operation.Receiver;
|
import kademlia.message.Receiver;
|
||||||
|
|
||||||
/**
|
/**
|
||||||
* The server that handles sending and receiving messages between nodes on the Kad Network
|
* The server that handles sending and receiving messages between nodes on the Kad Network
|
||||||
|
@ -3,7 +3,6 @@ package kademlia.message;
|
|||||||
import java.io.IOException;
|
import java.io.IOException;
|
||||||
import kademlia.core.KadServer;
|
import kademlia.core.KadServer;
|
||||||
import kademlia.node.Node;
|
import kademlia.node.Node;
|
||||||
import kademlia.operation.Receiver;
|
|
||||||
|
|
||||||
/**
|
/**
|
||||||
* Receives a ConnectMessage and sends an AcknowledgeMessage as reply.
|
* Receives a ConnectMessage and sends an AcknowledgeMessage as reply.
|
||||||
|
@ -5,7 +5,6 @@ import kademlia.core.KadConfiguration;
|
|||||||
import kademlia.core.KadServer;
|
import kademlia.core.KadServer;
|
||||||
import kademlia.dht.DHT;
|
import kademlia.dht.DHT;
|
||||||
import kademlia.node.Node;
|
import kademlia.node.Node;
|
||||||
import kademlia.operation.Receiver;
|
|
||||||
|
|
||||||
/**
|
/**
|
||||||
* Responds to a ContentLookupMessage by sending a ContentMessage containing the requested content;
|
* Responds to a ContentLookupMessage by sending a ContentMessage containing the requested content;
|
||||||
|
@ -6,7 +6,6 @@ import kademlia.core.KadConfiguration;
|
|||||||
import kademlia.core.KadServer;
|
import kademlia.core.KadServer;
|
||||||
import kademlia.dht.DHT;
|
import kademlia.dht.DHT;
|
||||||
import kademlia.node.Node;
|
import kademlia.node.Node;
|
||||||
import kademlia.operation.Receiver;
|
|
||||||
|
|
||||||
/**
|
/**
|
||||||
* Handles creating messages and receivers
|
* Handles creating messages and receivers
|
||||||
|
@ -5,7 +5,6 @@ import java.util.List;
|
|||||||
import kademlia.core.KadConfiguration;
|
import kademlia.core.KadConfiguration;
|
||||||
import kademlia.core.KadServer;
|
import kademlia.core.KadServer;
|
||||||
import kademlia.node.Node;
|
import kademlia.node.Node;
|
||||||
import kademlia.operation.Receiver;
|
|
||||||
|
|
||||||
/**
|
/**
|
||||||
* Receives a NodeLookupMessage and sends a NodeReplyMessage as reply with the K-Closest nodes to the ID sent.
|
* Receives a NodeLookupMessage and sends a NodeReplyMessage as reply with the K-Closest nodes to the ID sent.
|
||||||
|
@ -1,7 +1,6 @@
|
|||||||
package kademlia.operation;
|
package kademlia.message;
|
||||||
|
|
||||||
import java.io.IOException;
|
import java.io.IOException;
|
||||||
import kademlia.message.Message;
|
|
||||||
|
|
||||||
/**
|
/**
|
||||||
* A receiver waits for incoming messages and perform some action when the message is received
|
* A receiver waits for incoming messages and perform some action when the message is received
|
@ -1,7 +1,6 @@
|
|||||||
package kademlia.message;
|
package kademlia.message;
|
||||||
|
|
||||||
import java.io.IOException;
|
import java.io.IOException;
|
||||||
import kademlia.operation.Receiver;
|
|
||||||
|
|
||||||
/**
|
/**
|
||||||
* Default receiver if none other is called
|
* Default receiver if none other is called
|
||||||
|
@ -4,7 +4,6 @@ import java.io.IOException;
|
|||||||
import kademlia.core.KadServer;
|
import kademlia.core.KadServer;
|
||||||
import kademlia.dht.DHT;
|
import kademlia.dht.DHT;
|
||||||
import kademlia.node.Node;
|
import kademlia.node.Node;
|
||||||
import kademlia.operation.Receiver;
|
|
||||||
|
|
||||||
/**
|
/**
|
||||||
* Receiver for incoming StoreContentMessage
|
* Receiver for incoming StoreContentMessage
|
||||||
|
@ -5,6 +5,7 @@
|
|||||||
*/
|
*/
|
||||||
package kademlia.operation;
|
package kademlia.operation;
|
||||||
|
|
||||||
|
import kademlia.message.Receiver;
|
||||||
import java.io.IOException;
|
import java.io.IOException;
|
||||||
import kademlia.core.KadConfiguration;
|
import kademlia.core.KadConfiguration;
|
||||||
import kademlia.core.KadServer;
|
import kademlia.core.KadServer;
|
||||||
|
@ -1,5 +1,6 @@
|
|||||||
package kademlia.operation;
|
package kademlia.operation;
|
||||||
|
|
||||||
|
import kademlia.message.Receiver;
|
||||||
import java.io.IOException;
|
import java.io.IOException;
|
||||||
import java.util.ArrayList;
|
import java.util.ArrayList;
|
||||||
import java.util.Collections;
|
import java.util.Collections;
|
||||||
|
@ -1,5 +1,6 @@
|
|||||||
package kademlia.operation;
|
package kademlia.operation;
|
||||||
|
|
||||||
|
import kademlia.message.Receiver;
|
||||||
import java.io.IOException;
|
import java.io.IOException;
|
||||||
import java.util.ArrayList;
|
import java.util.ArrayList;
|
||||||
import java.util.Comparator;
|
import java.util.Comparator;
|
||||||
|
Loading…
Reference in New Issue
Block a user