Package | Description |
---|---|
budrys.chord | |
budrys.social | |
budrys.transport.socket |
Modifier and Type | Field and Description |
---|---|
IfcCallback |
Chord.onNeighbourChange |
Modifier and Type | Method and Description |
---|---|
void |
Peer.closestPrecedingNode(java.lang.Long id,
IfcCallback callback) |
void |
Peer.cNotify(java.lang.Long id,
IfcCallback callback) |
void |
PeerDHT.dhtDelete(java.lang.String key,
IfcCallback callback) |
ID |
IfcDHT.dhtDelete(java.lang.String key,
IfcCallback callback) |
ID |
ChordDHT.dhtDelete(java.lang.String key,
IfcCallback finalCallback) |
void |
PeerDHT.dhtGet(java.lang.String key,
IfcCallback callback) |
ID |
IfcDHT.dhtGet(java.lang.String key,
IfcCallback callback) |
ID |
ChordDHT.dhtGet(java.lang.String key,
IfcCallback finalCallback) |
ID |
ChordDHT.dhtGet1(java.lang.String key,
IfcCallback finalCallback) |
ID |
ChordDHT.dhtGet2(java.lang.String key,
IfcCallback finalCallback) |
ID |
ChordDHT.dhtGet3(java.lang.String key,
IfcCallback finalCallback) |
void |
PeerDHT.dhtRedistribute(ID shareWith,
IfcCallback callback) |
void |
PeerDHT.dhtStore(java.lang.String key,
java.lang.String value,
IfcCallback callback) |
ID |
IfcDHT.dhtStore(java.lang.String key,
java.lang.String value,
IfcCallback callback) |
ID |
ChordDHT.dhtStore(java.lang.String key,
java.lang.String value,
IfcCallback finalCallback)
Store data having 'key' on node id=successor('key')
|
void |
Peer.findSuccessor(java.lang.Long id,
java.lang.Long callerId,
IfcCallback finalCallback)
This method should be implemented iterative here
|
void |
Peer.getId(java.lang.String address,
java.lang.Short port,
IfcCallback callback)
Async
|
void |
Peer.getPredecessor(IfcCallback callback)
Tell me your predecessor
|
void |
Chord.loopThroughPeers(IfcCallback each,
IfcCallback finish)
ASYNC
Loop through all peers
|
void |
Peer.ping(IfcCallback callback) |
void |
IfcTransportClient.request(java.lang.String remoteIp,
java.lang.Short remotePort,
java.lang.String command,
java.lang.String argument,
IfcCallback callback) |
void |
Chord.startChordAsync(IfcCallback callback)
Starting is ASYNC
|
boolean |
IfcTransportServer.startService(java.lang.Short port,
IfcCallback requestHandler) |
Constructor and Description |
---|
Peer(java.lang.String address,
java.lang.Short port,
IfcCallback callback,
IfcTransportClient tc)
This constructor connects to peer.
|
Modifier and Type | Method and Description |
---|---|
void |
RemoteProfile.getProfileData(IfcCallback callback)
Get public profile data
|
void |
RemoteProfile.getProfileData(java.lang.String publicKey,
IfcCallback callback)
Get profile data according to passed publicKey privilleges
|
void |
RemoteProfile.publishWallMessage(java.lang.String profileWallEntryJSONEncoded,
IfcCallback callback) |
Constructor and Description |
---|
ProfileService(java.lang.Short myPort,
IfcTransportServer ts,
ProfileModel nModel,
FriendsModel friends,
IfcCallback onReceivePubMsg) |
Modifier and Type | Method and Description |
---|---|
void |
TransportClient.request(java.lang.String remoteIp,
java.lang.Short remotePort,
java.lang.String command,
java.lang.String argument,
IfcCallback callback)
NON BLOCKING - ASYNCHRONOUS
TODO starting a new thread should be wrapping sync method, now it is done vice versa
|
boolean |
TransportServer.startService(java.lang.Short port,
IfcCallback requestHandler) |