freenet.node

Class RequestTracker

java.lang.Object

freenet.node.RequestTracker

public class RequestTracker
extends java.lang.Object

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
static class	RequestTracker.CountedRequests
class	RequestTracker.WaitingForSlots

Method Summary

Modifier and Type	Method and Description
void	addRunningUIDs(java.util.List<java.lang.Long> list)
void	addTransferringSender(NodeCHK key, RequestSender sender) Add a transferring RequestSender to our HashMap.
void	countAllRequestsByIncomingPeer(boolean requestsToNode, boolean local, boolean ssk, boolean insert, boolean offer, boolean realTimeFlag, int transfersPerInsert, boolean ignoreLocalVsRemote, java.util.Map<PeerNode,RequestTracker.CountedRequests> counterMap) Count all requests, by the peer which originated the request.
void	countRequests(boolean local, boolean ssk, boolean insert, boolean offer, boolean realTimeFlag, int transfersPerInsert, boolean ignoreLocalVsRemote, RequestTracker.CountedRequests counter, RequestTracker.CountedRequests counterSourceRestarted) Count all requests running globally which match particular parameters.
void	countRequests(PeerNode source, boolean requestsToNode, boolean local, boolean ssk, boolean insert, boolean offer, boolean realTimeFlag, int transfersPerInsert, boolean ignoreLocalVsRemote, RequestTracker.CountedRequests counter, RequestTracker.CountedRequests counterSR) Count requests routed to a peer, or accepted from a peer, that match the specified criteria.
RequestTracker.WaitingForSlots	countRequestsWaitingForSlots()
int	getNumCHKInserts()
int	getNumCHKOfferReplies()
int	getNumCHKOfferReplies(boolean realTimeFlag)
int	getNumCHKRequests()
int	getNumLocalCHKInserts()
int	getNumLocalCHKRequests()
int	getNumLocalSSKInserts()
int	getNumLocalSSKRequests()
int	getNumRemoteCHKInserts()
int	getNumRemoteCHKRequests()
int	getNumRemoteSSKInserts()
int	getNumRemoteSSKRequests()
int	getNumSSKInserts()
int	getNumSSKOfferReplies()
int	getNumSSKOfferReplies(boolean realTimeFlag)
int	getNumSSKRequests()
int	getNumTransferringRequestHandlers()
int	getNumTransferringRequestSenders()
int	getTotalRunningUIDsAlt()
RequestSender	getTransferringRequestSenderByKey(NodeCHK key, boolean realTimeFlag)
boolean	lockUID(long uid, boolean ssk, boolean insert, boolean offerReply, boolean local, boolean realTimeFlag, UIDTag tag)
boolean	lockUID(UIDTag tag)
void	onRestartOrDisconnect(PeerNode pn)
void	removeTransferringSender(NodeCHK key, RequestSender sender) Remove a sender from the set of currently transferring senders.
protected void	unlockUID(long uid, boolean ssk, boolean insert, boolean canFail, boolean offerReply, boolean local, boolean realTimeFlag, UIDTag tag, boolean noRecord)

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Method Detail

lockUID

public boolean lockUID(UIDTag tag)

lockUID

public boolean lockUID(long uid,
                       boolean ssk,
                       boolean insert,
                       boolean offerReply,
                       boolean local,
                       boolean realTimeFlag,
                       UIDTag tag)

unlockUID

protected void unlockUID(long uid,
                         boolean ssk,
                         boolean insert,
                         boolean canFail,
                         boolean offerReply,
                         boolean local,
                         boolean realTimeFlag,
                         UIDTag tag,
                         boolean noRecord)

countRequests

public void countRequests(boolean local,
                          boolean ssk,
                          boolean insert,
                          boolean offer,
                          boolean realTimeFlag,
                          int transfersPerInsert,
                          boolean ignoreLocalVsRemote,
                          RequestTracker.CountedRequests counter,
                          RequestTracker.CountedRequests counterSourceRestarted)

Count all requests running globally which match particular parameters.

Parameters:

local - If true, only include requests which originated locally.

ssk - If true, count SSK requests, if false, count CHK requests.

insert - If true, count inserts, otherwise count requests.

offer - If true, count offer replies (takes precedence over insert).

realTimeFlag - If true, count real-time requests, if false, count bulk requests.

transfersPerInsert - Assume that any insert will cause this many outgoing transfers. This is not predictable, so we use an average.

ignoreLocalVsRemote - If true, pretend that the request is remote even if it's local (that is, count imaginary onward transfers etc depending on the request type).

counter - Transfer counts for all requests will be added to this counter object.

counterSourceRestarted - Transfer counts for requests whose source restarted (and so are counted as local) will be added to this counter object.

countRequests

public void countRequests(PeerNode source,
                          boolean requestsToNode,
                          boolean local,
                          boolean ssk,
                          boolean insert,
                          boolean offer,
                          boolean realTimeFlag,
                          int transfersPerInsert,
                          boolean ignoreLocalVsRemote,
                          RequestTracker.CountedRequests counter,
                          RequestTracker.CountedRequests counterSR)

Count requests routed to a peer, or accepted from a peer, that match the specified criteria. PERFORMANCE: There is a map for all requests of a given type (local, ssk, etc). However this is not divided up by node. FIXME ideally we would countRequests for all PeerNode's simultaneously when we need data on more than one. FIXME it would be even better if we could just store the status on the PeerNode's, but the memory usage might be an issue and synchronization would likely be problematic.

Parameters:

source - The peer the requests were accepted from or routed to.

requestsToNode - If true, count requests sent to the node and currently running. If false, count requests originated by the node.

local - If true, only include requests which originated locally.

ssk - If true, count SSK requests, if false, count CHK requests.

insert - If true, count inserts, otherwise count requests.

offer - If true, count offer replies (takes precedence over insert).

realTimeFlag - If true, count real-time requests, if false, count bulk requests.

transfersPerInsert - Assume that any insert will cause this many outgoing transfers. This is not predictable, so we use an average.

ignoreLocalVsRemote - If true, pretend that the request is remote even if it's local (that is, count imaginary onward transfers etc depending on the request type).

counter - Transfer counts for all requests will be added to this counter object.

counterSR - Transfer counts for requests whose source restarted (and so are counted as local) will be added to this counter object.

countAllRequestsByIncomingPeer

public void countAllRequestsByIncomingPeer(boolean requestsToNode,
                                           boolean local,
                                           boolean ssk,
                                           boolean insert,
                                           boolean offer,
                                           boolean realTimeFlag,
                                           int transfersPerInsert,
                                           boolean ignoreLocalVsRemote,
                                           java.util.Map<PeerNode,RequestTracker.CountedRequests> counterMap)

Count all requests, by the peer which originated the request.

Parameters:

source - The peer the requests were accepted from or routed to.

local - If true, only include requests which originated locally.

ssk - If true, count SSK requests, if false, count CHK requests.

insert - If true, count inserts, otherwise count requests.

offer - If true, count offer replies (takes precedence over insert).

realTimeFlag - If true, count real-time requests, if false, count bulk requests.

transfersPerInsert - Assume that any insert will cause this many outgoing transfers. This is not predictable, so we use an average.

ignoreLocalVsRemote - If true, pretend that the request is remote even if it's local (that is, count imaginary onward transfers etc depending on the request type).

counterMap - Map from PeerNode to CountedRequests counters. We will use "null" for various cases: local requests, requested that have been adopted because their originator restarted, requests where the originator PeerNode has been removed from the routing table etc.

countRequestsWaitingForSlots

public RequestTracker.WaitingForSlots countRequestsWaitingForSlots()

Returns:

[0] is the number of local requests waiting for slots, [1] is the number of remote requests waiting for slots.

onRestartOrDisconnect

public void onRestartOrDisconnect(PeerNode pn)

getNumSSKRequests

public int getNumSSKRequests()

getNumCHKRequests

public int getNumCHKRequests()

getNumSSKInserts

public int getNumSSKInserts()

getNumCHKInserts

public int getNumCHKInserts()

getNumLocalSSKRequests

public int getNumLocalSSKRequests()

getNumLocalCHKRequests

public int getNumLocalCHKRequests()

getNumRemoteCHKRequests

public int getNumRemoteCHKRequests()

getNumRemoteSSKRequests

public int getNumRemoteSSKRequests()

getNumLocalCHKInserts

public int getNumLocalCHKInserts()

getNumLocalSSKInserts

public int getNumLocalSSKInserts()

getNumRemoteCHKInserts

public int getNumRemoteCHKInserts()

getNumRemoteSSKInserts

public int getNumRemoteSSKInserts()

getNumSSKOfferReplies

public int getNumSSKOfferReplies()

getNumCHKOfferReplies

public int getNumCHKOfferReplies()

getNumSSKOfferReplies

public int getNumSSKOfferReplies(boolean realTimeFlag)

getNumCHKOfferReplies

public int getNumCHKOfferReplies(boolean realTimeFlag)

addRunningUIDs

public void addRunningUIDs(java.util.List<java.lang.Long> list)

getTotalRunningUIDsAlt

public int getTotalRunningUIDsAlt()

getTransferringRequestSenderByKey

public RequestSender getTransferringRequestSenderByKey(NodeCHK key,
                                                       boolean realTimeFlag)

addTransferringSender

public void addTransferringSender(NodeCHK key,
                                  RequestSender sender)

Add a transferring RequestSender to our HashMap. Should only be called by UIDTag.

removeTransferringSender

public void removeTransferringSender(NodeCHK key,
                                     RequestSender sender)

Remove a sender from the set of currently transferring senders.

getNumTransferringRequestSenders

public int getNumTransferringRequestSenders()

getNumTransferringRequestHandlers

public int getNumTransferringRequestHandlers()