|
||||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | |||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |
java.lang.Objectnet.i2p.router.client.ClientManager
public class ClientManager
Coordinate connections and various tasks
Constructor Summary | |
---|---|
ClientManager(RouterContext context,
int port)
|
Method Summary | |
---|---|
void |
destinationEstablished(ClientConnectionRunner runner)
Add to the clients list. |
(package private) void |
distributeMessage(Destination fromDest,
Destination toDest,
Payload payload,
MessageId msgId,
long expiration)
|
SessionConfig |
getClientSessionConfig(Destination dest)
Return the client's current config, or null if not connected |
SessionKeyManager |
getClientSessionKeyManager(Hash dest)
Return the client's SessionKeyManager Use this instead of the RouterContext.sessionKeyManager() to prevent correlation attacks across destinations |
(package private) ClientConnectionRunner |
getRunner(Destination dest)
|
(package private) java.util.Set<Destination> |
getRunnerDestinations()
|
boolean |
isAlive()
|
boolean |
isLocal(Destination dest)
|
boolean |
isLocal(Hash destHash)
|
java.util.Set<Destination> |
listClients()
|
void |
messageDeliveryStatusUpdate(Destination fromDest,
MessageId id,
boolean delivered)
|
void |
messageReceived(ClientMessage msg)
|
void |
registerConnection(ClientConnectionRunner runner)
|
void |
renderStatusHTML(java.io.Writer out)
|
void |
reportAbuse(Destination dest,
java.lang.String reason,
int severity)
|
void |
requestLeaseSet(Destination dest,
LeaseSet set,
long timeout,
Job onCreateJob,
Job onFailedJob)
Request that a particular client authorize the Leases contained in the LeaseSet, after which the onCreateJob is queued up. |
void |
requestLeaseSet(Hash dest,
LeaseSet ls)
|
void |
restart()
|
boolean |
shouldPublishLeaseSet(Hash destHash)
|
void |
shutdown()
|
void |
unregisterConnection(ClientConnectionRunner runner)
|
Methods inherited from class java.lang.Object |
---|
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait |
Constructor Detail |
---|
public ClientManager(RouterContext context, int port)
Method Detail |
---|
public void restart()
public void shutdown()
public boolean isAlive()
public void registerConnection(ClientConnectionRunner runner)
public void unregisterConnection(ClientConnectionRunner runner)
public void destinationEstablished(ClientConnectionRunner runner)
void distributeMessage(Destination fromDest, Destination toDest, Payload payload, MessageId msgId, long expiration)
public void requestLeaseSet(Destination dest, LeaseSet set, long timeout, Job onCreateJob, Job onFailedJob)
dest
- Destination from which the LeaseSet's authorization should be requestedset
- LeaseSet with requested leases - this object must be updated to contain the
signed version (as well as any changed/added/removed Leases)timeout
- ms to wait before failingonCreateJob
- Job to run after the LeaseSet is authorizedonFailedJob
- Job to run after the timeout passes without receiving authorizationpublic void requestLeaseSet(Hash dest, LeaseSet ls)
public boolean isLocal(Destination dest)
public boolean isLocal(Hash destHash)
public boolean shouldPublishLeaseSet(Hash destHash)
public java.util.Set<Destination> listClients()
ClientConnectionRunner getRunner(Destination dest)
public SessionConfig getClientSessionConfig(Destination dest)
public SessionKeyManager getClientSessionKeyManager(Hash dest)
public void messageDeliveryStatusUpdate(Destination fromDest, MessageId id, boolean delivered)
java.util.Set<Destination> getRunnerDestinations()
public void reportAbuse(Destination dest, java.lang.String reason, int severity)
public void renderStatusHTML(java.io.Writer out) throws java.io.IOException
java.io.IOException
public void messageReceived(ClientMessage msg)
|
||||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | |||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |