freenet.node

Class SeedClientPeerNode

java.lang.Object

freenet.node.PeerNode

freenet.node.SeedClientPeerNode

All Implemented Interfaces:

USKRetrieverCallback, PeerContext, BasePeerNode

public class SeedClientPeerNode
extends PeerNode

Seed node's representation of a client node connecting in order to announce.

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
SeedClientPeerNode(SimpleFieldSet fs, Node node2, NodeCrypto crypto)

Method Summary

Modifier and Type	Method and Description
boolean	canAcceptAnnouncements() Can we accept announcements from this node?
boolean	disconnected(boolean dumpMessageQueue, boolean dumpTrackers) Disconnected e.g.
boolean	equals(java.lang.Object o)
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.
protected boolean	fromAnonymousInitiator()
PeerNodeStatus	getStatus(boolean noHeavy) Get a PeerNodeStatus for this node.
int	handshakeSetupType()
boolean	handshakeUnknownInitiator()
protected boolean	ignoreLastGoodVersion()
boolean	isDarknet()
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()
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	onSuccess(boolean insert, boolean ssk) Called when a request or insert succeeds.
boolean	recordStatus()
boolean	shallWeRouteAccordingToOurPeersLocation(int htl)
boolean	shouldDisconnectAndRemoveNow() Should this peer be disconnected and removed immediately?
protected boolean	shouldExportPeerAddedTime()
boolean	shouldSendHandshake()
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, dontRoute, dumpTracker, enterMandatoryBackoff, exportDiskFieldSet, exportFieldSet, exportMetadataFieldSet, exportVolatileFieldSet, failedRevocationTransfer, fatalTimeout, finishedSendingUOMJar, forceCancelDisconnecting, forceDisconnect, fullPacketQueued, getAddedReason, 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, hasFullNoderef, hashCode, hasLiveHandshake, 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, onRemove, 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, setAddedReason, setJFKBuffer, setKeyAgreementSchemeContext, setLastBackoffReason, setMainJarOfferedVersion, setPeerNodeStatus, setPeerNodeStatus, setRemoteDetectedPeer, setSendLoadStatsASAP, setTimeDelta, setUptime, shortToString, shouldAcceptAnnounce, shouldBeExcludedFromPeerList, shouldPadDataPackets, shouldRejectProbeRequest, shouldRejectSwapRequest, 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

SeedClientPeerNode

public SeedClientPeerNode(SimpleFieldSet fs,
                          Node node2,
                          NodeCrypto crypto)
                   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.

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.

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

equals

public boolean equals(java.lang.Object o)

Overrides:

equals in class PeerNode

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

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

canAcceptAnnouncements

public boolean canAcceptAnnouncements()

Description copied from class: PeerNode

Can we accept announcements from this node?

Specified by:

canAcceptAnnouncements in class PeerNode

recordStatus

public boolean recordStatus()

Specified by:

recordStatus in class PeerNode

handshakeUnknownInitiator

public boolean handshakeUnknownInitiator()

Overrides:

handshakeUnknownInitiator in class PeerNode

handshakeSetupType

public int handshakeSetupType()

Overrides:

handshakeSetupType in class PeerNode

shouldSendHandshake

public boolean shouldSendHandshake()

Overrides:

shouldSendHandshake in class PeerNode

Returns:

True, if we are disconnected and it has been a sufficient time period since we last sent a handshake attempt.

disconnected

public boolean disconnected(boolean dumpMessageQueue,
                            boolean dumpTrackers)

Description copied from class: PeerNode

Disconnected e.g. due to not receiving a packet for ages.

Overrides:

disconnected in class PeerNode

Parameters:

dumpMessageQueue - If true, clear the messages-to-send queue, and change the bootID so even if we reconnect the other side will know that a disconnect happened. If false, don't clear the messages yet. They will be cleared after an hour if the peer is disconnected at that point.

dumpTrackers - If true, dump the SessionKey's (i.e. dump the cryptographic data so we don't understand any packets they send us).
Possible arguments:

• true, true => dump everything, immediate disconnect
• true, false => dump messages but keep trackers so we can acknowledge messages on their end for a while.
• false, false => tell the rest of the node that we have disconnected but do not immediately drop messages, continue to respond to their messages.
• false, true => dump crypto but keep messages. DOES NOT MAKE SENSE!!! DO NOT USE!!!

Returns:

True if the node was connected, false if it was not.

ignoreLastGoodVersion

protected boolean ignoreLastGoodVersion()

Overrides:

ignoreLastGoodVersion in class PeerNode

shouldDisconnectAndRemoveNow

public boolean shouldDisconnectAndRemoveNow()

Description copied from class: PeerNode

Should this peer be disconnected and removed immediately?

Overrides:

shouldDisconnectAndRemoveNow 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

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

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.

writePeers

protected void writePeers()

Description copied from class: PeerNode

Write the peers list affecting this node.

Specified by:

writePeers in class PeerNode

fromAnonymousInitiator

protected boolean fromAnonymousInitiator()

Overrides:

fromAnonymousInitiator in class PeerNode

Returns:

True if the node has just connected and given us a noderef, and we did not know it beforehand. This makes it a temporary connection. At the moment this only happens on seednodes.