freenet.node

Class OpennetPeerNode

java.lang.Object

freenet.node.PeerNode

freenet.node.OpennetPeerNode

All Implemented Interfaces:

USKRetrieverCallback, PeerContext, BasePeerNode

public class OpennetPeerNode
extends PeerNode

Nested Class Summary

Nested classes/interfaces inherited from class freenet.node.PeerNode

PeerNode.IncomingLoadSummaryStats, PeerNode.SlotWaiter

Field Summary

Fields inherited from class freenet.node.PeerNode

backedOffPercent, backedOffPercentBulk, backedOffPercentRT, BLACK_MAGIC_BACKOFF_PRUNING_PERCENTAGE, BLACK_MAGIC_BACKOFF_PRUNING_TIME, crypto, disableRouting, disableRoutingHasBeenSetLocally, disableRoutingHasBeenSetRemotely, fullFieldSet, hmacKey, incommingKey, ivKey, ivNonce, jfkContextLifetime, jfkKa, jfkKe, jfkMyRef, jfkNoncesSent, neverConnected, nominalPeer, ourInitialMsgID, ourInitialSeqNum, outgoingKey, peerAddedTime, peerECDSAPubKey, peerECDSAPubKeyHash, peerNodeStatus, resendByteCounter, SELECTION_MAX_SAMPLES, SELECTION_MIN_PEERS, SELECTION_PERCENTAGE_WARNING, SELECTION_SAMPLING_PERIOD, sendHandshakeTime, sendingUOMLegacyExtJar, sendingUOMMainJar, testnetEnabled, theirInitialMsgID, theirInitialSeqNum, unroutableNewerVersion, unroutableOlderVersion

Constructor Summary

Constructors

Constructor and Description
OpennetPeerNode(SimpleFieldSet fs, Node node2, NodeCrypto crypto, OpennetManager opennet, boolean fromLocal)

Method Summary

Modifier and Type	Method and Description
boolean	canAcceptAnnouncements() Can we accept announcements from this node?
boolean	equals(java.lang.Object o)
SimpleFieldSet	exportMetadataFieldSet(long now) Export metadata about the node as a SimpleFieldSet
void	fatalTimeout() After a fatal timeout - that is, a timeout that we reasonably believe originated on the node rather than downstream - we do not know whether or not the node thinks the request is still running.
OpennetManager.ConnectionType	getAddedReason()
PeerNodeStatus	getStatus(boolean noHeavy) Get a PeerNodeStatus for this node.
boolean	isDarknet()
boolean	isDroppable(boolean ignoreDisconnect)
freenet.node.OpennetPeerNode.NOT_DROP_REASON	isDroppableWithReason(boolean ignoreDisconnect) Is the peer droppable? SIDE EFFECT: If we are now outside the grace period, we reset peerAddedTime and opennetPeerAddedReason.
boolean	isOpennet()
boolean	isOpennetForNoderef()
boolean	isRealConnection() Does this peernode want to be returned by for example PeerManager.getByPeer() ? False = seednode etc, never going to be routable.
boolean	isRoutingCompatible() Returns true if (apart from actually knowing the peer's location), it is presumed that this peer could route requests.
boolean	isSeed()
freenet.node.OpennetManager.LinkLengthClass	linkLengthClass()
protected void	maybeClearPeerAddedTimeOnConnect()
protected void	maybeClearPeerAddedTimeOnRestart(long now)
protected void	onConnect() A method to be called once at the beginning of every time isConnected() is true
void	onRemove() Called when the peer is removed from the PeerManager
void	onSuccess(boolean insert, boolean ssk) Called when a request or insert succeeds.
boolean	recordStatus()
void	setAddedReason(OpennetManager.ConnectionType connectionType)
boolean	shallWeRouteAccordingToOurPeersLocation(int htl)
boolean	shouldDisconnectAndRemoveNow() Should this peer be disconnected and removed immediately?
protected boolean	shouldExportPeerAddedTime()
long	timeLastSuccess()
static boolean	validateRef(SimpleFieldSet ref) Is the SimpleFieldSet a valid noderef?
protected void	writePeers() Write the peers list affecting this node.

Methods inherited from class freenet.node.PeerNode

acceptedAny, addToLocalNodeReceivedMessagesFromStatistic, addToLocalNodeSentMessagesToStatistic, allowLocalAddresses, averagePingTime, averagePingTimeCorrected, backoffOnResend, calcNextHandshake, calculateMaxTransfersOut, changedIP, checkForLostPackets, checkRoutableConnectionStatus, completedAnnounce, completedHandshake, couldNotSendHandshake, countFailedRevocationTransfers, create, decrementHTL, decrementUOMSends, disconnected, dontRoute, dumpTracker, enterMandatoryBackoff, exportDiskFieldSet, exportFieldSet, exportVolatileFieldSet, failedRevocationTransfer, fatalTimeout, finishedSendingUOMJar, forceCancelDisconnecting, forceDisconnect, fromAnonymousInitiator, fullPacketQueued, getBootID, getClockDelta, getClosestPeerLocation, getCurrentKeyTracker, getDegree, getFullNoderef, getHandshakeCount, getHandshakeIP, getHandshakeIPs, getIdentityHash, getIdentityString, getIncomingLoadStats, getJFKBuffer, getKeyAgreementSchemeContext, getLastBackoffReason, getLocalNodeReceivedMessagesFromStatistic, getLocalNoderef, getLocalNodeSentMessagesToStatistic, getLocation, getLocSetTime, getMainJarOfferedVersion, getMaxPacketSize, getMessageQueue, getMessageQueueLengthBytes, getNextUrgentTime, getOutgoingBootID, getOutgoingMangler, getPeer, getPeerAddedTime, getPeerNodeStatus, getPeerNodeStatus, getPeerNodeStatusCSSClassName, getPeerNodeStatusCSSClassName, getPeerNodeStatusString, getPeerNodeStatusString, getPercentTimeRoutableConnection, getPollingPriorityNormal, getPollingPriorityProgress, getPRejected, getPreviousBackoffReason, getPreviousKeyTracker, getProbableSendQueueTime, getPubKeyHash, getRemoteDetectedPeer, getResendBytesSent, getReusableTrackerID, getRoutingBackedOffUntil, getRoutingBackedOffUntilBulk, getRoutingBackedOffUntilMax, getRoutingBackedOffUntilRT, getRoutingBackoffLength, getSimpleVersion, getSocketHandler, getThrottle, getThrottleWindowSize, getTMCIPeerInfo, getTotalInputBytes, getTotalInputSinceStartup, getTotalOutputBytes, getTotalOutputSinceStartup, getUnverifiedKeyTracker, getUptime, getVersion, getVersionNumber, getWeakRef, gotARK, grabQueuedMessageItems, grabSendLoadStatsASAP, handleMessage, handleReceivedPacket, handshakeSetupType, handshakeUnknownInitiator, hasFullNoderef, hashCode, hasLiveHandshake, ignoreLastGoodVersion, incrementNumberOfSelections, incrementUOMSends, innerCalcNextHandshake, innerProcessNewNoderef, isBurstOnly, isConnected, isDisabled, isDisconnecting, isFetchingARK, isIgnoreSource, isLowCapacity, isLowUptime, isRoutable, isRoutingBackedOff, isRoutingBackedOff, isRoutingBackedOffEither, isSignatureVerificationSuccessfull, isUnroutableNewerVersion, isUnroutableOlderVersion, lastReceivedAckTime, lastReceivedDataPacketTime, lastReceivedPacketTime, lastSentPacketTime, loadSender, localRejectedOverload, makeLoadStats, matchesIP, matchesPeerAndPort, maxTimeBetweenReceivedAcks, maxTimeBetweenReceivedPackets, maybeOnConnect, maybeRekey, maybeSendPacket, maybeUpdateHandshakeIPs, neverConnected, noContactDetails, noLongerRoutable, noLongerRoutingTo, notifyDisconnecting, offer, onFound, onNotificationOnlyPacketSent, onSetMaxOutputTransfers, onSetMaxOutputTransfersPeerLimit, onSetPeerAllocation, outputLoadTracker, paddingGen, ping, postUnlock, processDiffNoderef, processNewNoderef, publicInvalidVersion, publicReverseInvalidVersion, queueN2NM, receivedAck, receivedPacket, registerPeerNodeStatusChangeListener, rejectedGuaranteed, reportIncomingBytes, reportLoadStatus, reportOutgoingBytes, reportPing, reportRoutedTo, reportThrottledPacketSendTime, resentBytes, resetMandatoryBackoff, selectionRate, selectNegType, sendAsync, sendConnectedDiffNoderef, sendEncryptedPacket, sendingUOMJar, sendInitialMessages, sendNodeToNodeMessage, sendSync, sentHandshake, sentPacket, sentThrottledBytes, setJFKBuffer, setKeyAgreementSchemeContext, setLastBackoffReason, setMainJarOfferedVersion, setPeerNodeStatus, setPeerNodeStatus, setRemoteDetectedPeer, setSendLoadStatsASAP, setTimeDelta, setUptime, shortToString, shouldAcceptAnnounce, shouldBeExcludedFromPeerList, shouldPadDataPackets, shouldRejectProbeRequest, shouldRejectSwapRequest, shouldSendHandshake, shouldThrottle, shouldThrottle, startProcessingDecryptedMessages, startRekeying, stopARKFetcher, successNotOverload, throttleRekey, timeCheckForLostPackets, timeLastConnected, timeLastConnectionCompleted, timeLastDisconnect, timeLastRoutable, timeSendAcks, timeSendHandshake, timeSinceAddedOrRestarted, timeSinceSentUOM, toString, transferFailed, transferSuccess, unqueueMessage, updateLocation, userToString, verified, wakeUpSender, write

Methods inherited from class java.lang.Object

clone, finalize, getClass, notify, notifyAll, wait, wait, wait

Constructor Detail

OpennetPeerNode

public OpennetPeerNode(SimpleFieldSet fs,
                       Node node2,
                       NodeCrypto crypto,
                       OpennetManager opennet,
                       boolean fromLocal)
                throws FSParseException,
                       PeerParseException,
                       ReferenceSignatureVerificationException,
                       PeerTooOldException

Throws:

FSParseException

PeerParseException

ReferenceSignatureVerificationException

PeerTooOldException

Method Detail

getStatus

public PeerNodeStatus getStatus(boolean noHeavy)

Description copied from class: PeerNode

Get a PeerNodeStatus for this node.

Specified by:

getStatus in class PeerNode

Parameters:

noHeavy - If true, avoid any expensive operations e.g. the message count hashtables.

isRoutingCompatible

public boolean isRoutingCompatible()

Description copied from class: PeerNode

Returns true if (apart from actually knowing the peer's location), it is presumed that this peer could route requests. True if this peer's build number is not 'too-old' or 'too-new', actively connected, and not marked as explicity disabled. Does not reflect any 'backoff' logic.

Overrides:

isRoutingCompatible in class PeerNode

isDarknet

public boolean isDarknet()

Specified by:

isDarknet in class PeerNode

Returns:

True if the node is a full darknet peer ("Friend"), which should usually be in the darknet routing table.

isOpennet

public boolean isOpennet()

Specified by:

isOpennet in class PeerNode

Returns:

True if the node is a full opennet peer ("Stranger"), which should usually be in the OpennetManager and opennet routing table.

isSeed

public boolean isSeed()

Specified by:

isSeed in class PeerNode

Returns:

True if the node is a seed client or seed server. These are never in the routing table, but their noderefs should still say opennet=true.

isDroppable

public boolean isDroppable(boolean ignoreDisconnect)

isDroppableWithReason

public freenet.node.OpennetPeerNode.NOT_DROP_REASON isDroppableWithReason(boolean ignoreDisconnect)

Is the peer droppable? SIDE EFFECT: If we are now outside the grace period, we reset peerAddedTime and opennetPeerAddedReason. Note that the caller must check separately whether the node is TOO OLD and connected.

onSuccess

public void onSuccess(boolean insert,
                      boolean ssk)

Description copied from class: PeerNode

Called when a request or insert succeeds. Used by opennet.

Specified by:

onSuccess in class PeerNode

onRemove

public void onRemove()

Description copied from class: PeerNode

Called when the peer is removed from the PeerManager

Overrides:

onRemove in class PeerNode

exportMetadataFieldSet

public SimpleFieldSet exportMetadataFieldSet(long now)

Description copied from class: PeerNode

Export metadata about the node as a SimpleFieldSet

Overrides:

exportMetadataFieldSet in class PeerNode

timeLastSuccess

public final long timeLastSuccess()

validateRef

public static boolean validateRef(SimpleFieldSet ref)

Is the SimpleFieldSet a valid noderef?

isRealConnection

public boolean isRealConnection()

Description copied from class: PeerNode

Does this peernode want to be returned by for example PeerManager.getByPeer() ? False = seednode etc, never going to be routable.

Specified by:

isRealConnection in class PeerNode

recordStatus

public boolean recordStatus()

Specified by:

recordStatus in class PeerNode

equals

public boolean equals(java.lang.Object o)

Overrides:

equals in class PeerNode

shouldDisconnectAndRemoveNow

public final boolean shouldDisconnectAndRemoveNow()

Description copied from class: PeerNode

Should this peer be disconnected and removed immediately?

Overrides:

shouldDisconnectAndRemoveNow in class PeerNode

onConnect

protected void onConnect()

Description copied from class: PeerNode

A method to be called once at the beginning of every time isConnected() is true

Overrides:

onConnect in class PeerNode

setAddedReason

public void setAddedReason(OpennetManager.ConnectionType connectionType)

Overrides:

setAddedReason in class PeerNode

getAddedReason

public OpennetManager.ConnectionType getAddedReason()

Overrides:

getAddedReason in class PeerNode

maybeClearPeerAddedTimeOnConnect

protected void maybeClearPeerAddedTimeOnConnect()

Specified by:

maybeClearPeerAddedTimeOnConnect in class PeerNode

shouldExportPeerAddedTime

protected boolean shouldExportPeerAddedTime()

Specified by:

shouldExportPeerAddedTime in class PeerNode

maybeClearPeerAddedTimeOnRestart

protected void maybeClearPeerAddedTimeOnRestart(long now)

Specified by:

maybeClearPeerAddedTimeOnRestart in class PeerNode

fatalTimeout

public void fatalTimeout()

Description copied from class: PeerNode

After a fatal timeout - that is, a timeout that we reasonably believe originated on the node rather than downstream - we do not know whether or not the node thinks the request is still running. Hence load management will get really confused and likely start to send requests over and over, which are repeatedly rejected. So we have some alternatives: 1) Lock the slot forever (or at least until the node reconnects). So every time a node times out, it loses a slot, and gradually it becomes completely catatonic. 2) Wait forever for an acknowledgement of the timeout. This may be worth investigating. One problem with this is that the slot would still count towards our overall load management, which is surely a bad thing, although we could make it only count towards this node. Also, if it doesn't arrive in a reasonable time maybe there has been a severe problem e.g. out of memory, bug etc; in that case, waiting forever may not be sensible. 3) Disconnect the node. This makes perfect sense for opennet. For darknet it's a bit more problematic. 4) Turn off routing to the node, possibly for a limited period. This would need to include the effects of disconnection. It might open up some cheapish local DoS's. For all nodes, at present, we disconnect. For darknet nodes, we log an error, and allow them to reconnect.

Specified by:

fatalTimeout in class PeerNode

shallWeRouteAccordingToOurPeersLocation

public boolean shallWeRouteAccordingToOurPeersLocation(int htl)

Specified by:

shallWeRouteAccordingToOurPeersLocation in class PeerNode

linkLengthClass

public freenet.node.OpennetManager.LinkLengthClass linkLengthClass()

isOpennetForNoderef

public boolean isOpennetForNoderef()

Specified by:

isOpennetForNoderef in class PeerNode

Returns:

Expected value of "opennet=" in the noderef. This returns true if the node is an actual opennet peer, but also if the node is a seed client or seed server, even though they are never part of the routing table. This also determines whether we use the opennet or darknet NodeCrypto.

canAcceptAnnouncements

public boolean canAcceptAnnouncements()

Description copied from class: PeerNode

Can we accept announcements from this node?

Specified by:

canAcceptAnnouncements in class PeerNode

writePeers

protected void writePeers()

Description copied from class: PeerNode

Write the peers list affecting this node.

Specified by:

writePeers in class PeerNode