mirror of
https://github.com/ChronosX88/KademliaDHT.git
synced 2024-11-22 10:12:19 +00:00
Finished a few of the Todos
- Populate all of the K-Buckets on bootstrap
This commit is contained in:
parent
21b6667eb8
commit
7c24ed7cff
@ -43,10 +43,6 @@ import kademlia.util.serializer.JsonSerializer;
|
|||||||
* @todo When we receive a store message - if we have a newer version of the content, re-send this newer version to that node so as to update their version
|
* @todo When we receive a store message - if we have a newer version of the content, re-send this newer version to that node so as to update their version
|
||||||
* @todo Handle IPv6 Addresses
|
* @todo Handle IPv6 Addresses
|
||||||
* @todo Handle compressing data
|
* @todo Handle compressing data
|
||||||
* @todo Allow optional storing of content locally using the put method
|
|
||||||
* @todo Instead of using a StoreContentMessage to send a store RPC and a ContentMessage to receive a FIND rpc, make them 1 message with different operation type
|
|
||||||
* @todo If we're trying to send a message to this node, just cancel the sending process and handle the message right here
|
|
||||||
* @todo Keep this node in it's own routing table - it helps for ContentRefresh operation - easy to check whether this node is one of the k-nodes for a content
|
|
||||||
* @todo Implement Kademlia.ping() operation.
|
* @todo Implement Kademlia.ping() operation.
|
||||||
*
|
*
|
||||||
*/
|
*/
|
||||||
|
@ -65,8 +65,6 @@ class StoredContentManager
|
|||||||
/**
|
/**
|
||||||
* Checks if our DHT has a Content for the given criteria
|
* Checks if our DHT has a Content for the given criteria
|
||||||
*
|
*
|
||||||
* @todo Add searching for content by type and ownerID
|
|
||||||
*
|
|
||||||
* @param param The parameters used to search for a content
|
* @param param The parameters used to search for a content
|
||||||
*
|
*
|
||||||
* @return boolean
|
* @return boolean
|
||||||
@ -113,8 +111,6 @@ class StoredContentManager
|
|||||||
*
|
*
|
||||||
* @param param The parameters used to search for a content
|
* @param param The parameters used to search for a content
|
||||||
*
|
*
|
||||||
* @todo Add finding for content by type and ownerID
|
|
||||||
*
|
|
||||||
* @return List of content for the specific search parameters
|
* @return List of content for the specific search parameters
|
||||||
*/
|
*/
|
||||||
public StorageEntryMetadata get(GetParameter param) throws NoSuchElementException
|
public StorageEntryMetadata get(GetParameter param) throws NoSuchElementException
|
||||||
|
@ -81,10 +81,11 @@ public class ConnectOperation implements Operation, Receiver
|
|||||||
lookup.execute();
|
lookup.execute();
|
||||||
|
|
||||||
/**
|
/**
|
||||||
* @todo Refresh buckets to get a good routing table
|
* Refresh buckets to get a good routing table
|
||||||
* I think after the above lookup operation, K buckets will be filled
|
* After the above lookup operation, K nodes will be in our routing table,
|
||||||
* Not sure if this operation is needed here
|
* Now we try to populate all of our buckets.
|
||||||
*/
|
*/
|
||||||
|
new BucketRefreshOperation(this.server, this.localNode, this.config).execute();
|
||||||
}
|
}
|
||||||
catch (IOException | InterruptedException e)
|
catch (IOException | InterruptedException e)
|
||||||
{
|
{
|
||||||
|
Loading…
Reference in New Issue
Block a user