public class DMT
extends java.lang.Object
Modifier and Type | Field and Description |
---|---|
static MessageType |
allReceived |
static MessageType |
allSent |
static java.lang.String |
ANY_TIMED_OUT |
static java.lang.String |
AVERAGE_TRANSFERS_OUT_PER_INSERT |
static java.lang.String |
BEST_LOCATION |
static java.lang.String |
BEST_LOCATIONS_NOT_VISITED |
static java.lang.String |
BLOCK_HEADERS |
static java.lang.String |
BUILD |
static java.lang.String |
BWLIMIT_DELAY_TIME |
static java.lang.String |
CACHED |
static java.lang.String |
CAPACITY_USAGE |
static java.lang.String |
CHK_HEADER |
static java.lang.String |
CHUNK_NO |
static java.lang.String |
COUNTER |
static java.lang.String |
DATA |
static java.lang.String |
DATA_INSERT_REJECTED_REASON |
static short |
DATA_INSERT_REJECTED_RECEIVE_FAILED |
static short |
DATA_INSERT_REJECTED_SSK_ERROR |
static short |
DATA_INSERT_REJECTED_TIMEOUT_WAITING_FOR_ACCEPTED |
static short |
DATA_INSERT_REJECTED_VERIFY_FAILED |
static java.lang.String |
DATA_SOURCE |
static java.lang.String |
DAWN_HTL |
static java.lang.String |
DESCRIPTION |
static java.lang.String |
ENABLE_INSERT_FORK_WHEN_CACHEABLE |
static java.lang.String |
EXPECTED_HASH |
static java.lang.String |
EXTERNAL_ADDRESS |
static java.lang.String |
EXTRA_JAR_FILE_LENGTH |
static java.lang.String |
EXTRA_JAR_KEY |
static java.lang.String |
EXTRA_JAR_VERSION |
static java.lang.String |
FILE_LENGTH |
static java.lang.String |
FIRST_GOOD_BUILD |
static java.lang.String |
FNP_SOURCE_PEERNODE |
static MessageType |
FNPAccepted |
static MessageType |
FNPBestRoutesNotTaken |
static MessageType |
FNPBulkPacketSend |
static MessageType |
FNPBulkReceiveAborted |
static MessageType |
FNPBulkReceivedAll |
static MessageType |
FNPBulkSendAborted |
static MessageType |
FNPCheckStillRunning |
static MessageType |
FNPCHKDataFound |
static MessageType |
FNPCHKDataRequest |
static MessageType |
FNPDataInsert |
static MessageType |
FNPDataInsertRejected |
static MessageType |
FNPDataNotFound |
static MessageType |
FNPDetectedIPAddress |
static MessageType |
FNPDisconnect |
static MessageType |
FNPGetOfferedKey |
static MessageType |
FNPGetOfferedKeyInvalid |
static MessageType |
FNPGetYourFullNoderef |
static MessageType |
FNPInsertReply |
static MessageType |
FNPInsertRequest |
static MessageType |
FNPInsertTransfersCompleted |
static MessageType |
FNPIsStillRunning |
static MessageType |
FNPLocChangeNotificationNew |
static MessageType |
FNPMyFullNoderef |
static MessageType |
FNPOfferKey |
static MessageType |
FNPOpennetAnnounceCompleted |
static MessageType |
FNPOpennetAnnounceNodeNotWanted |
static MessageType |
FNPOpennetAnnounceReply
Announcement reply.
|
static MessageType |
FNPOpennetAnnounceRequest
Announcement request.
|
static MessageType |
FNPOpennetCompletedAck
Sent when a request to an opennet node is completed, but the data source does not want to
path fold.
|
static MessageType |
FNPOpennetCompletedTimeout
Sent when we wait for an FNP transfer or a completion from upstream and it never comes.
|
static MessageType |
FNPOpennetConnectDestinationNew
Sent when a request completes and the data source wants to path fold.
|
static MessageType |
FNPOpennetConnectReplyNew
Path folding response.
|
static MessageType |
FNPOpennetDisabled |
static MessageType |
FNPOpennetNoderefRejected |
static MessageType |
FNPPeerLoadStatusByte |
static MessageType |
FNPPeerLoadStatusInt |
static MessageType |
FNPPeerLoadStatusShort |
static MessageType |
FNPPing |
static MessageType |
FNPPong |
static MessageType |
FNPRealTimeFlag |
static MessageType |
FNPRecentlyFailed |
static MessageType |
FNPRejectedLoop |
static MessageType |
FNPRejectedOverload |
static MessageType |
FNPRejectedTimeout |
static MessageType |
FNPRejectIsSoft |
static MessageType |
FNPRHProbeReply |
static MessageType |
FNPRoutedPing |
static MessageType |
FNPRoutedPong |
static MessageType |
FNPRoutedRejected |
static MessageType |
FNPRouteNotFound |
static MessageType |
FNPRoutingStatus |
static MessageType |
FNPSentPackets |
static MessageType |
FNPSSKAccepted |
static MessageType |
FNPSSKDataFoundData |
static MessageType |
FNPSSKDataFoundHeaders |
static MessageType |
FNPSSKDataRequest |
static MessageType |
FNPSSKInsertRequest |
static MessageType |
FNPSSKInsertRequestData |
static MessageType |
FNPSSKInsertRequestHeaders |
static MessageType |
FNPSSKInsertRequestNew |
static MessageType |
FNPSSKPubKey |
static MessageType |
FNPSSKPubKeyAccepted |
static MessageType |
FNPSubInsertForkControl |
static MessageType |
FNPSubInsertIgnoreLowBackoff |
static MessageType |
FNPSubInsertPreferInsert |
static MessageType |
FNPSwapCommit |
static MessageType |
FNPSwapComplete |
static MessageType |
FNPSwapNodeUIDs |
static MessageType |
FNPSwapRejected |
static MessageType |
FNPSwapReply |
static MessageType |
FNPSwapRequest |
static MessageType |
FNPTime |
static MessageType |
FNPUptime |
static MessageType |
FNPVisibility |
static MessageType |
FNPVoid |
static java.lang.String |
FORK_COUNT |
static java.lang.String |
FORWARDERS |
static java.lang.String |
FREENET_ROUTING_KEY |
static java.lang.String |
FREENET_URI |
static java.lang.String |
FRIEND_VISIBILITY |
static short |
GET_OFFERED_KEY_REJECTED_BAD_AUTHENTICATOR |
static short |
GET_OFFERED_KEY_REJECTED_NO_KEY |
static java.lang.String |
HASH |
static java.lang.String |
HASHES |
static java.lang.String |
HAVE_REVOCATION_KEY |
static java.lang.String |
HTL |
static java.lang.String |
IGNORE_LOW_BACKOFF |
static java.lang.String |
INPUT_BANDWIDTH_LOWER_LIMIT |
static java.lang.String |
INPUT_BANDWIDTH_PEER_LIMIT |
static java.lang.String |
INPUT_BANDWIDTH_UPPER_LIMIT |
static java.lang.String |
IS_HASH |
static java.lang.String |
IS_LOCAL |
static java.lang.String |
JOINER |
static java.lang.String |
KEY |
static java.lang.String |
LAST_MODIFIED |
static java.lang.String |
LINEAR_COUNTER |
static java.lang.String |
LINK_LENGTHS |
static java.lang.String |
LIST_OF_UIDS |
static java.lang.String |
LOCATION |
static java.lang.String |
MAIN_JAR_FILE_LENGTH |
static java.lang.String |
MAIN_JAR_KEY |
static java.lang.String |
MAIN_JAR_VERSION |
static java.lang.String |
MAX_TRANSFERS_OUT
Maximum transfers out, hard limit based on congestion control; we will be rejected if our usage
is over this.
|
static java.lang.String |
MAX_TRANSFERS_OUT_LOWER_LIMIT
Maximum transfers out, lower limit.
|
static java.lang.String |
MAX_TRANSFERS_OUT_PEER_LIMIT
Maximum transfers out, peer limit.
|
static java.lang.String |
MAX_TRANSFERS_OUT_UPPER_LIMIT
Maximum transfers out, upper limit.
|
static java.lang.String |
MISSING |
static java.lang.String |
MY_UID |
static java.lang.String |
NEAREST_LOCATION |
static java.lang.String |
NEED_PUB_KEY |
static java.lang.String |
NODE_IDENTITY |
static java.lang.String |
NODE_TO_NODE_MESSAGE_DATA |
static java.lang.String |
NODE_TO_NODE_MESSAGE_TEXT |
static java.lang.String |
NODE_TO_NODE_MESSAGE_TYPE |
static java.lang.String |
NODE_UIDS |
static java.lang.String |
NODEREF_LENGTH |
static int |
NODEREF_REJECTED_INVALID |
static int |
NODEREF_REJECTED_REAL_BIGGER_THAN_PADDED |
static int |
NODEREF_REJECTED_TOO_BIG |
static int |
NODEREF_REJECTED_TRANSFER_FAILED |
static MessageType |
nodeToNodeMessage |
static short |
NUM_PRIORITIES |
static java.lang.String |
OFFER_AUTHENTICATOR |
static java.lang.String |
OPENNET_NODEREF |
static java.lang.String |
OTHER_TRANSFERS_IN_CHK |
static java.lang.String |
OTHER_TRANSFERS_IN_SSK |
static java.lang.String |
OTHER_TRANSFERS_OUT_CHK |
static java.lang.String |
OTHER_TRANSFERS_OUT_SSK |
static java.lang.String |
OUTPUT_BANDWIDTH_CLASS |
static java.lang.String |
OUTPUT_BANDWIDTH_LOWER_LIMIT |
static java.lang.String |
OUTPUT_BANDWIDTH_PEER_LIMIT |
static java.lang.String |
OUTPUT_BANDWIDTH_UPPER_LIMIT |
static java.lang.String |
PACKET_NO |
static MessageType |
packetTransmit |
static java.lang.String |
PADDED_LENGTH |
static java.lang.String |
PAYLOAD |
static java.lang.String |
PEER_LOCATIONS |
static java.lang.String |
PEER_UIDS |
static java.lang.String |
PEERS |
static java.lang.String |
PING_SEQNO |
static java.lang.String |
PING_TIME |
static java.lang.String |
PREFER_INSERT |
static java.lang.String |
PREV_UID |
static short |
PRIORITY_BULK_DATA
Bulk data transfer, bottom of the heap, high level limiting must ensure there is time to send it by
not accepting an infeasible number of requests; starvation will cause bwlimitDelayTime to go high and
requests to be rejected.
|
static short |
PRIORITY_HIGH
Short timeout, or urgent for other reasons - Accepted, RejectedLoop etc.
|
static short |
PRIORITY_LOW
Stuff that starts a request.
|
static short |
PRIORITY_NOW
Very urgent
|
static short |
PRIORITY_REALTIME_DATA
Bulk data transfer for realtime requests.
|
static short |
PRIORITY_UNSPECIFIED
Stuff that completes a request, and miscellaneous stuff.
|
static java.lang.String |
PROBE_IDENTIFIER |
static MessageType |
ProbeBandwidth |
static MessageType |
ProbeBuild |
static MessageType |
ProbeError |
static MessageType |
ProbeIdentifier |
static MessageType |
ProbeLinkLengths |
static MessageType |
ProbeLocation |
static MessageType |
ProbeOverallBulkOutputCapacityUsage |
static MessageType |
ProbeRefused |
static MessageType |
ProbeRejectStats |
static MessageType |
ProbeRequest |
static MessageType |
ProbeStoreSize |
static MessageType |
ProbeUptime |
static java.lang.String |
PUBKEY_AS_BYTES |
static java.lang.String |
PUBKEY_HASH |
static java.lang.String |
PURGE |
static java.lang.String |
REAL_TIME_FLAG |
static java.lang.String |
REASON |
static java.lang.String |
REJECT_CODE |
static java.lang.String |
REJECT_STATS |
static java.lang.String |
REMOVE |
static java.lang.String |
RETURN_LOCATION |
static java.lang.String |
REVOCATION_KEY |
static java.lang.String |
REVOCATION_KEY_DNF_COUNT |
static java.lang.String |
REVOCATION_KEY_FILE_LENGTH |
static java.lang.String |
REVOCATION_KEY_TIME_LAST_TRIED |
static java.lang.String |
ROUTING_ENABLED |
static java.lang.String |
SECRET |
static java.lang.String |
SEND_TIME |
static MessageType |
sendAborted |
static java.lang.String |
SENT |
static java.lang.String |
SOURCE_NODENAME |
static java.lang.String |
STORE_SIZE |
static java.lang.String |
STREAM_SEQNO |
static java.lang.String |
SUCCESS |
static java.lang.String |
TARGET_LOCATION |
static java.lang.String |
TARGET_NODENAME |
static java.lang.String |
TEST_CHK_HEADERS |
static MessageType |
testDataNotFound |
static MessageType |
testDataNotFoundAck |
static MessageType |
testDataReply |
static MessageType |
testDataReplyAck |
static MessageType |
testReceiveCompleted |
static MessageType |
testRequest |
static MessageType |
testSendCHK |
static MessageType |
testSendCHKAck |
static MessageType |
testSendCompleted |
static MessageType |
testTransferSend |
static MessageType |
testTransferSendAck |
static java.lang.String |
TIME |
static java.lang.String |
TIME_DELTAS |
static java.lang.String |
TIME_LEFT |
static java.lang.String |
TRANSFER_UID |
static java.lang.String |
TTL |
static java.lang.String |
TYPE |
static java.lang.String |
UID |
static java.lang.String |
UID_STILL_RUNNING_FLAGS |
static java.lang.String |
UNIQUE_COUNTER |
static MessageType |
UOMAnnouncement |
static MessageType |
UOMFetchDependency
Used to fetch a file required for deploying an update.
|
static MessageType |
UOMRequestMainJar |
static MessageType |
UOMRequestRevocation |
static MessageType |
UOMSendingMainJar |
static MessageType |
UOMSendingRevocation |
static java.lang.String |
UPTIME_PERCENT |
static java.lang.String |
UPTIME_PERCENT_48H |
static java.lang.String |
URL |
Constructor and Description |
---|
DMT() |
Modifier and Type | Method and Description |
---|---|
static byte |
bandwidthClassForCapacityUsage(int bandwidthLimit) |
static int |
bulkPacketTransmitSize(int size) |
static Message |
createAllReceived(long uid) |
static Message |
createAllSent(long uid,
boolean realTime) |
static Message |
createFNPAccepted(long id) |
static Message |
createFNPBestRoutesNotTaken(byte[] locs) |
static Message |
createFNPBestRoutesNotTaken(double[] locs) |
static Message |
createFNPBestRoutesNotTaken(java.lang.Double[] doubles) |
static Message |
createFNPBulkPacketSend(long uid,
int packetNo,
byte[] data,
boolean realTime) |
static Message |
createFNPBulkPacketSend(long uid,
int packetNo,
ShortBuffer data,
boolean realTime) |
static Message |
createFNPBulkReceiveAborted(long uid) |
static Message |
createFNPBulkReceivedAll(long uid) |
static Message |
createFNPBulkSendAborted(long uid) |
static Message |
createFNPCHKDataFound(long id,
byte[] buf) |
static Message |
createFNPCHKDataRequest(long id,
short htl,
NodeCHK key) |
static Message |
createFNPDataInsert(long uid,
byte[] headers) |
static Message |
createFNPDataInsertRejected(long uid,
short reason) |
static Message |
createFNPDataNotFound(long id) |
static Message |
createFNPDetectedIPAddress(Peer peer) |
static Message |
createFNPDisconnect(boolean remove,
boolean purge,
int messageType,
ShortBuffer messageData) |
static Message |
createFNPGetOfferedKey(Key key,
byte[] authenticator,
boolean needPubkey,
long uid) |
static Message |
createFNPGetOfferedKeyInvalid(long uid,
short reason) |
static Message |
createFNPGetYourFullNoderef() |
static Message |
createFNPInsertReply(long id) |
static Message |
createFNPInsertRequest(long id,
short htl,
Key key) |
static Message |
createFNPInsertTransfersCompleted(long uid,
boolean anyTimedOut) |
static Message |
createFNPLocChangeNotificationNew(double myLocation,
double[] locations) |
static Message |
createFNPMyFullNoderef(long uid,
int length) |
static Message |
createFNPOfferKey(Key key,
byte[] authenticator) |
static Message |
createFNPOpennetAnnounceCompleted(long uid) |
static Message |
createFNPOpennetAnnounceNodeNotWanted(long uid) |
static Message |
createFNPOpennetAnnounceReply(long uid,
long transferUID,
int noderefLength,
int paddedLength) |
static Message |
createFNPOpennetAnnounceRequest(long uid,
long transferUID,
int noderefLength,
int paddedLength,
double target,
short htl) |
static Message |
createFNPOpennetCompletedAck(long uid) |
static Message |
createFNPOpennetCompletedTimeout(long uid) |
static Message |
createFNPOpennetConnectDestinationNew(long uid,
long transferUID,
int noderefLength,
int paddedLength) |
static Message |
createFNPOpennetConnectReplyNew(long uid,
long transferUID,
int noderefLength,
int paddedLength) |
static Message |
createFNPOpennetDisabled(long uid) |
static Message |
createFNPOpennetNoderefRejected(long uid,
int rejectCode) |
static Message |
createFNPPeerLoadStatus(NodeStats.PeerLoadStats stats) |
static Message |
createFNPPing(int seqNo) |
static Message |
createFNPPong(int seqNo) |
static Message |
createFNPRealTimeFlag(boolean isBulk) |
static Message |
createFNPRecentlyFailed(long id,
int timeLeft) |
static Message |
createFNPRejectedLoop(long id) |
static Message |
createFNPRejectedOverload(long id,
boolean isLocal,
boolean needsLoad,
boolean realTimeFlag) |
static Message |
createFNPRejectedTimeout(long uid) |
static Message |
createFNPRejectIsSoft() |
static Message |
createFNPRHProbeReply(long uid,
double nearest,
double best,
short counter,
short uniqueCounter,
short linearCounter) |
static Message |
createFNPRoutedPing(long uid,
double targetLocation,
short htl,
int counter,
byte[] nodeIdentity) |
static Message |
createFNPRoutedPong(long uid,
int counter) |
static Message |
createFNPRoutedRejected(long uid,
short htl) |
static Message |
createFNPRouteNotFound(long id,
short htl) |
static Message |
createFNPSSKAccepted(long uid,
boolean needPubKey) |
static Message |
createFNPSSKDataFoundData(long uid,
byte[] data,
boolean realTime) |
static Message |
createFNPSSKDataFoundHeaders(long uid,
byte[] headers,
boolean realTime) |
static Message |
createFNPSSKDataRequest(long id,
short htl,
NodeSSK key,
boolean needPubKey) |
static Message |
createFNPSSKInsertRequest(long uid,
short htl,
NodeSSK myKey,
byte[] headers,
byte[] data,
byte[] pubKeyHash,
boolean realTime) |
static Message |
createFNPSSKInsertRequestData(long uid,
byte[] data,
boolean realTime) |
static Message |
createFNPSSKInsertRequestHeaders(long uid,
byte[] headers,
boolean realTime) |
static Message |
createFNPSSKInsertRequestNew(long uid,
short htl,
NodeSSK myKey) |
static Message |
createFNPSSKPubKey(long uid,
DSAPublicKey pubkey,
boolean realTime) |
static Message |
createFNPSSKPubKeyAccepted(long uid) |
static Message |
createFNPSubInsertForkControl(boolean enableInsertForkWhenCacheable) |
static Message |
createFNPSubInsertIgnoreLowBackoff(boolean ignoreLowBackoff) |
static Message |
createFNPSubInsertPreferInsert(boolean preferInsert) |
static Message |
createFNPSwapCommit(long uid,
byte[] buf) |
static Message |
createFNPSwapComplete(long uid,
byte[] buf) |
static Message |
createFNPSwapLocations(long[] uids) |
static Message |
createFNPSwapRejected(long uid) |
static Message |
createFNPSwapReply(long uid,
byte[] buf) |
static Message |
createFNPSwapRequest(long uid,
byte[] buf,
int htl) |
static Message |
createFNPTime(long time) |
static Message |
createFNPUptime(byte uptimePercent) |
static Message |
createFNPVisibility(short visibility) |
static Message |
createFNPVoid() |
static Message |
createNodeToNodeMessage(int type,
byte[] data) |
static Message |
createPacketTransmit(long uid,
int packetNo,
BitArray sent,
Buffer data,
boolean realTime) |
static Message |
createProbeBandwidth(long uid,
float limit)
Creates a probe response to a query for bandwidth limits.
|
static Message |
createProbeBuild(long uid,
int build)
Creates a probe response to a query for build.
|
static Message |
createProbeError(long uid,
Error error)
Creates a probe response which indicates there was an error.
|
static Message |
createProbeIdentifier(long uid,
long probeIdentifier,
byte uptimePercentage)
Creates a probe response to a query for identifier.
|
static Message |
createProbeLinkLengths(long uid,
float[] linkLengths)
Creates a probe response to a query for link lengths.
|
static Message |
createProbeLocation(long uid,
float location)
Creates a probe response to a query for location.
|
static Message |
createProbeOverallBulkOutputCapacityUsage(long uid,
byte outputBandwidthClass,
float capacityUsage) |
static Message |
createProbeRefused(long uid)
Creates a probe response which indicates that the endpoint opted not to respond with the requested result.
|
static Message |
createProbeRejectStats(long uid,
byte[] rejectStats) |
static Message |
createProbeRequest(byte htl,
long uid,
Type type)
Constructs a a probe request.
|
static Message |
createProbeStoreSize(long uid,
float storeSize)
Creates a probe response to a query for store size.
|
static Message |
createProbeUptime(long uid,
float uptimePercent)
Creates a probe response to a query for uptime.
|
static Message |
createRoutingStatus(boolean routeRequests) |
static Message |
createSendAborted(long uid,
int reason,
java.lang.String description) |
static Message |
createTestDataNotFound(long uid) |
static Message |
createTestDataNotFoundAck(long id) |
static Message |
createTestDataReply(long uid,
byte[] headers) |
static Message |
createTestDataReplyAck(long id) |
static Message |
createTestReceiveCompleted(long id,
boolean success,
java.lang.String reason) |
static Message |
createTestRequest(Key Key,
long id,
int htl) |
static Message |
createTestSendCHK(long uid,
java.lang.String uri,
Buffer header) |
static Message |
createTestSendCHKAck(long uid,
java.lang.String key) |
static Message |
createTestSendCompleted(long id,
boolean success,
java.lang.String reason) |
static Message |
createTestTransferSend(long uid) |
static Message |
createTestTransferSendAck(long uid) |
static Message |
createUOMAnnouncement(java.lang.String mainKey,
java.lang.String revocationKey,
boolean haveRevocation,
long mainJarVersion,
long timeLastTriedRevocationFetch,
int revocationDNFCount,
long revocationKeyLength,
long mainJarLength,
int pingTime,
int bwlimitDelayTime) |
static Message |
createUOMFetchDependency(long uid,
byte[] hash,
long length) |
static Message |
createUOMRequestMainJar(long uid) |
static Message |
createUOMRequestRevocation(long uid) |
static Message |
createUOMSendingMainJar(long uid,
long length,
java.lang.String key,
int version) |
static Message |
createUOMSendingRevocation(long uid,
long length,
java.lang.String key) |
static java.lang.String |
getDataInsertRejectedReason(short reason) |
static java.lang.String |
getOpennetRejectedCode(int x) |
static boolean |
getRealTimeFlag(Message m) |
static boolean |
isLoadLimitedRequest(Message m) |
static boolean |
isPeerLoadStatusMessage(Message m) |
static int |
packetTransmitSize(int size,
int _packets) |
public static final java.lang.String UID
public static final java.lang.String SEND_TIME
public static final java.lang.String EXTERNAL_ADDRESS
public static final java.lang.String BUILD
public static final java.lang.String FIRST_GOOD_BUILD
public static final java.lang.String JOINER
public static final java.lang.String REASON
public static final java.lang.String DESCRIPTION
public static final java.lang.String TTL
public static final java.lang.String PEERS
public static final java.lang.String URL
public static final java.lang.String FORWARDERS
public static final java.lang.String FILE_LENGTH
public static final java.lang.String LAST_MODIFIED
public static final java.lang.String CHUNK_NO
public static final java.lang.String DATA_SOURCE
public static final java.lang.String CACHED
public static final java.lang.String PACKET_NO
public static final java.lang.String DATA
public static final java.lang.String IS_HASH
public static final java.lang.String HASH
public static final java.lang.String SENT
public static final java.lang.String MISSING
public static final java.lang.String KEY
public static final java.lang.String CHK_HEADER
public static final java.lang.String FREENET_URI
public static final java.lang.String FREENET_ROUTING_KEY
public static final java.lang.String TEST_CHK_HEADERS
public static final java.lang.String HTL
public static final java.lang.String SUCCESS
public static final java.lang.String FNP_SOURCE_PEERNODE
public static final java.lang.String PING_SEQNO
public static final java.lang.String LOCATION
public static final java.lang.String NEAREST_LOCATION
public static final java.lang.String BEST_LOCATION
public static final java.lang.String TARGET_LOCATION
public static final java.lang.String TYPE
public static final java.lang.String PAYLOAD
public static final java.lang.String COUNTER
public static final java.lang.String UNIQUE_COUNTER
public static final java.lang.String LINEAR_COUNTER
public static final java.lang.String RETURN_LOCATION
public static final java.lang.String BLOCK_HEADERS
public static final java.lang.String DATA_INSERT_REJECTED_REASON
public static final java.lang.String STREAM_SEQNO
public static final java.lang.String IS_LOCAL
public static final java.lang.String ANY_TIMED_OUT
public static final java.lang.String PUBKEY_HASH
public static final java.lang.String NEED_PUB_KEY
public static final java.lang.String PUBKEY_AS_BYTES
public static final java.lang.String SOURCE_NODENAME
public static final java.lang.String TARGET_NODENAME
public static final java.lang.String NODE_TO_NODE_MESSAGE_TYPE
public static final java.lang.String NODE_TO_NODE_MESSAGE_TEXT
public static final java.lang.String NODE_TO_NODE_MESSAGE_DATA
public static final java.lang.String NODE_UIDS
public static final java.lang.String MY_UID
public static final java.lang.String PEER_LOCATIONS
public static final java.lang.String PEER_UIDS
public static final java.lang.String BEST_LOCATIONS_NOT_VISITED
public static final java.lang.String MAIN_JAR_KEY
public static final java.lang.String EXTRA_JAR_KEY
public static final java.lang.String REVOCATION_KEY
public static final java.lang.String HAVE_REVOCATION_KEY
public static final java.lang.String MAIN_JAR_VERSION
public static final java.lang.String EXTRA_JAR_VERSION
public static final java.lang.String REVOCATION_KEY_TIME_LAST_TRIED
public static final java.lang.String REVOCATION_KEY_DNF_COUNT
public static final java.lang.String REVOCATION_KEY_FILE_LENGTH
public static final java.lang.String MAIN_JAR_FILE_LENGTH
public static final java.lang.String EXTRA_JAR_FILE_LENGTH
public static final java.lang.String PING_TIME
public static final java.lang.String BWLIMIT_DELAY_TIME
public static final java.lang.String TIME
public static final java.lang.String FORK_COUNT
public static final java.lang.String TIME_LEFT
public static final java.lang.String PREV_UID
public static final java.lang.String OPENNET_NODEREF
public static final java.lang.String REMOVE
public static final java.lang.String PURGE
public static final java.lang.String TRANSFER_UID
public static final java.lang.String NODEREF_LENGTH
public static final java.lang.String PADDED_LENGTH
public static final java.lang.String TIME_DELTAS
public static final java.lang.String HASHES
public static final java.lang.String REJECT_CODE
public static final java.lang.String ROUTING_ENABLED
public static final java.lang.String OFFER_AUTHENTICATOR
public static final java.lang.String DAWN_HTL
public static final java.lang.String SECRET
public static final java.lang.String NODE_IDENTITY
public static final java.lang.String UPTIME_PERCENT_48H
public static final java.lang.String FRIEND_VISIBILITY
public static final java.lang.String ENABLE_INSERT_FORK_WHEN_CACHEABLE
public static final java.lang.String PREFER_INSERT
public static final java.lang.String IGNORE_LOW_BACKOFF
public static final java.lang.String LIST_OF_UIDS
public static final java.lang.String UID_STILL_RUNNING_FLAGS
public static final java.lang.String PROBE_IDENTIFIER
public static final java.lang.String STORE_SIZE
public static final java.lang.String LINK_LENGTHS
public static final java.lang.String UPTIME_PERCENT
public static final java.lang.String EXPECTED_HASH
public static final java.lang.String REJECT_STATS
public static final java.lang.String OUTPUT_BANDWIDTH_CLASS
public static final java.lang.String CAPACITY_USAGE
public static final short PRIORITY_NOW
public static final short PRIORITY_HIGH
public static final short PRIORITY_UNSPECIFIED
public static final short PRIORITY_LOW
public static final short PRIORITY_REALTIME_DATA
public static final short PRIORITY_BULK_DATA
public static final short NUM_PRIORITIES
public static final MessageType packetTransmit
public static final MessageType allSent
public static final MessageType allReceived
public static final MessageType sendAborted
public static final MessageType FNPBulkPacketSend
public static final MessageType FNPBulkSendAborted
public static final MessageType FNPBulkReceiveAborted
public static final MessageType FNPBulkReceivedAll
public static final MessageType testTransferSend
public static final MessageType testTransferSendAck
public static final MessageType testSendCHK
public static final MessageType testRequest
public static final MessageType testDataNotFound
public static final MessageType testDataReply
public static final MessageType testSendCHKAck
public static final MessageType testDataReplyAck
public static final MessageType testDataNotFoundAck
public static final MessageType testReceiveCompleted
public static final MessageType testSendCompleted
public static final MessageType nodeToNodeMessage
public static final MessageType FNPCHKDataRequest
public static final MessageType FNPSSKDataRequest
public static final MessageType FNPRejectedLoop
public static final MessageType FNPRejectedOverload
public static final MessageType FNPAccepted
public static final MessageType FNPDataNotFound
public static final MessageType FNPRecentlyFailed
public static final MessageType FNPCHKDataFound
public static final MessageType FNPRouteNotFound
public static final MessageType FNPInsertRequest
public static final MessageType FNPInsertReply
public static final MessageType FNPDataInsert
public static final MessageType FNPInsertTransfersCompleted
public static final MessageType FNPRejectedTimeout
public static final MessageType FNPDataInsertRejected
public static final short DATA_INSERT_REJECTED_VERIFY_FAILED
public static final short DATA_INSERT_REJECTED_RECEIVE_FAILED
public static final short DATA_INSERT_REJECTED_SSK_ERROR
public static final short DATA_INSERT_REJECTED_TIMEOUT_WAITING_FOR_ACCEPTED
public static final MessageType FNPSSKInsertRequest
public static final MessageType FNPSSKInsertRequestNew
public static final MessageType FNPSSKInsertRequestHeaders
public static final MessageType FNPSSKInsertRequestData
public static final MessageType FNPSSKDataFoundHeaders
public static final MessageType FNPSSKDataFoundData
public static final MessageType FNPSSKAccepted
public static final MessageType FNPSSKPubKey
public static final MessageType FNPSSKPubKeyAccepted
public static final MessageType FNPOpennetCompletedAck
public static final MessageType FNPOpennetCompletedTimeout
public static final MessageType FNPOpennetConnectDestinationNew
public static final MessageType FNPOpennetConnectReplyNew
public static final MessageType FNPOpennetAnnounceRequest
public static final MessageType FNPOpennetAnnounceReply
public static final MessageType FNPOpennetAnnounceCompleted
public static final MessageType FNPOpennetDisabled
public static final MessageType FNPOpennetNoderefRejected
public static final int NODEREF_REJECTED_TOO_BIG
public static final int NODEREF_REJECTED_REAL_BIGGER_THAN_PADDED
public static final int NODEREF_REJECTED_TRANSFER_FAILED
public static final int NODEREF_REJECTED_INVALID
public static final MessageType FNPOpennetAnnounceNodeNotWanted
public static final MessageType FNPOfferKey
public static final MessageType FNPGetOfferedKey
public static final MessageType FNPGetOfferedKeyInvalid
public static final short GET_OFFERED_KEY_REJECTED_BAD_AUTHENTICATOR
public static final short GET_OFFERED_KEY_REJECTED_NO_KEY
public static final MessageType FNPPing
public static final MessageType FNPPong
public static final MessageType FNPRHProbeReply
public static final MessageType ProbeRequest
public static final MessageType ProbeError
public static final MessageType ProbeRefused
public static final MessageType ProbeBandwidth
public static final MessageType ProbeBuild
public static final MessageType ProbeIdentifier
public static final MessageType ProbeLinkLengths
public static final MessageType ProbeLocation
public static final MessageType ProbeStoreSize
public static final MessageType ProbeUptime
public static final MessageType ProbeRejectStats
public static final MessageType ProbeOverallBulkOutputCapacityUsage
public static final MessageType FNPSwapRequest
public static final MessageType FNPSwapRejected
public static final MessageType FNPSwapReply
public static final MessageType FNPSwapCommit
public static final MessageType FNPSwapComplete
public static final MessageType FNPLocChangeNotificationNew
public static final MessageType FNPRoutedPing
public static final MessageType FNPRoutedPong
public static final MessageType FNPRoutedRejected
public static final MessageType FNPDetectedIPAddress
public static final MessageType FNPTime
public static final MessageType FNPUptime
public static final MessageType FNPVisibility
public static final MessageType FNPSentPackets
public static final MessageType FNPVoid
public static final MessageType FNPDisconnect
public static final MessageType UOMAnnouncement
public static final MessageType UOMRequestRevocation
public static final MessageType UOMRequestMainJar
public static final MessageType UOMSendingRevocation
public static final MessageType UOMSendingMainJar
public static final MessageType UOMFetchDependency
public static final MessageType FNPSwapNodeUIDs
public static final MessageType FNPBestRoutesNotTaken
public static final MessageType FNPRoutingStatus
public static final MessageType FNPSubInsertForkControl
public static final MessageType FNPSubInsertPreferInsert
public static final MessageType FNPSubInsertIgnoreLowBackoff
public static final MessageType FNPRejectIsSoft
public static final MessageType FNPPeerLoadStatusByte
public static final MessageType FNPPeerLoadStatusShort
public static final MessageType FNPPeerLoadStatusInt
public static final java.lang.String AVERAGE_TRANSFERS_OUT_PER_INSERT
public static final java.lang.String OTHER_TRANSFERS_OUT_CHK
public static final java.lang.String OTHER_TRANSFERS_IN_CHK
public static final java.lang.String OTHER_TRANSFERS_OUT_SSK
public static final java.lang.String OTHER_TRANSFERS_IN_SSK
public static final java.lang.String MAX_TRANSFERS_OUT
public static final java.lang.String MAX_TRANSFERS_OUT_PEER_LIMIT
public static final java.lang.String MAX_TRANSFERS_OUT_LOWER_LIMIT
public static final java.lang.String MAX_TRANSFERS_OUT_UPPER_LIMIT
public static final java.lang.String OUTPUT_BANDWIDTH_LOWER_LIMIT
public static final java.lang.String OUTPUT_BANDWIDTH_UPPER_LIMIT
public static final java.lang.String OUTPUT_BANDWIDTH_PEER_LIMIT
public static final java.lang.String INPUT_BANDWIDTH_LOWER_LIMIT
public static final java.lang.String INPUT_BANDWIDTH_UPPER_LIMIT
public static final java.lang.String INPUT_BANDWIDTH_PEER_LIMIT
public static final java.lang.String REAL_TIME_FLAG
public static final MessageType FNPRealTimeFlag
public static final MessageType FNPCheckStillRunning
public static final MessageType FNPIsStillRunning
public static final MessageType FNPGetYourFullNoderef
public static final MessageType FNPMyFullNoderef
public static Message createPacketTransmit(long uid, int packetNo, BitArray sent, Buffer data, boolean realTime)
public static int packetTransmitSize(int size, int _packets)
public static int bulkPacketTransmitSize(int size)
public static Message createAllSent(long uid, boolean realTime)
public static Message createAllReceived(long uid)
public static Message createSendAborted(long uid, int reason, java.lang.String description)
public static Message createFNPBulkPacketSend(long uid, int packetNo, ShortBuffer data, boolean realTime)
public static Message createFNPBulkPacketSend(long uid, int packetNo, byte[] data, boolean realTime)
public static Message createFNPBulkSendAborted(long uid)
public static Message createFNPBulkReceiveAborted(long uid)
public static Message createFNPBulkReceivedAll(long uid)
public static Message createTestTransferSend(long uid)
public static Message createTestTransferSendAck(long uid)
public static Message createTestSendCHK(long uid, java.lang.String uri, Buffer header)
public static Message createTestDataNotFound(long uid)
public static Message createTestDataReply(long uid, byte[] headers)
public static Message createTestSendCHKAck(long uid, java.lang.String key)
public static Message createTestDataReplyAck(long id)
public static Message createTestDataNotFoundAck(long id)
public static Message createTestReceiveCompleted(long id, boolean success, java.lang.String reason)
public static Message createTestSendCompleted(long id, boolean success, java.lang.String reason)
public static Message createNodeToNodeMessage(int type, byte[] data)
public static Message createFNPCHKDataRequest(long id, short htl, NodeCHK key)
public static Message createFNPSSKDataRequest(long id, short htl, NodeSSK key, boolean needPubKey)
public static Message createFNPRejectedLoop(long id)
public static Message createFNPRejectedOverload(long id, boolean isLocal, boolean needsLoad, boolean realTimeFlag)
public static Message createFNPAccepted(long id)
public static Message createFNPDataNotFound(long id)
public static Message createFNPRecentlyFailed(long id, int timeLeft)
public static Message createFNPCHKDataFound(long id, byte[] buf)
public static Message createFNPRouteNotFound(long id, short htl)
public static Message createFNPInsertReply(long id)
public static Message createFNPDataInsert(long uid, byte[] headers)
public static Message createFNPInsertTransfersCompleted(long uid, boolean anyTimedOut)
public static Message createFNPRejectedTimeout(long uid)
public static Message createFNPDataInsertRejected(long uid, short reason)
public static java.lang.String getDataInsertRejectedReason(short reason)
public static Message createFNPSSKInsertRequest(long uid, short htl, NodeSSK myKey, byte[] headers, byte[] data, byte[] pubKeyHash, boolean realTime)
public static Message createFNPSSKInsertRequestNew(long uid, short htl, NodeSSK myKey)
public static Message createFNPSSKInsertRequestHeaders(long uid, byte[] headers, boolean realTime)
public static Message createFNPSSKInsertRequestData(long uid, byte[] data, boolean realTime)
public static Message createFNPSSKDataFoundHeaders(long uid, byte[] headers, boolean realTime)
public static Message createFNPSSKDataFoundData(long uid, byte[] data, boolean realTime)
public static Message createFNPSSKAccepted(long uid, boolean needPubKey)
public static Message createFNPSSKPubKey(long uid, DSAPublicKey pubkey, boolean realTime)
public static Message createFNPSSKPubKeyAccepted(long uid)
public static Message createFNPOpennetCompletedAck(long uid)
public static Message createFNPOpennetCompletedTimeout(long uid)
public static Message createFNPOpennetConnectDestinationNew(long uid, long transferUID, int noderefLength, int paddedLength)
public static Message createFNPOpennetConnectReplyNew(long uid, long transferUID, int noderefLength, int paddedLength)
public static Message createFNPOpennetAnnounceRequest(long uid, long transferUID, int noderefLength, int paddedLength, double target, short htl)
public static Message createFNPOpennetAnnounceReply(long uid, long transferUID, int noderefLength, int paddedLength)
public static Message createFNPOpennetAnnounceCompleted(long uid)
public static Message createFNPOpennetDisabled(long uid)
public static Message createFNPOpennetNoderefRejected(long uid, int rejectCode)
public static java.lang.String getOpennetRejectedCode(int x)
public static Message createFNPOpennetAnnounceNodeNotWanted(long uid)
public static Message createFNPGetOfferedKey(Key key, byte[] authenticator, boolean needPubkey, long uid)
public static Message createFNPGetOfferedKeyInvalid(long uid, short reason)
public static Message createFNPPing(int seqNo)
public static Message createFNPPong(int seqNo)
public static Message createFNPRHProbeReply(long uid, double nearest, double best, short counter, short uniqueCounter, short linearCounter)
public static Message createProbeRequest(byte htl, long uid, Type type)
htl
- hopsToLive: hops until result is requested.uid
- Probe identifier: should be unique.public static Message createProbeError(long uid, Error error)
uid
- Probe identifier.error
- The type of error that occurred. Can be one of Probe.ProbeError.public static Message createProbeRefused(long uid)
uid
- Probe identifier.public static Message createProbeBandwidth(long uid, float limit)
uid
- Probe identifier.limit
- Endpoint output bandwidth limit in KiB per second.public static Message createProbeBuild(long uid, int build)
uid
- Probe identifier.build
- Endpoint build of Freenet.public static Message createProbeIdentifier(long uid, long probeIdentifier, byte uptimePercentage)
uid
- Probe UID.probeIdentifier
- Endpoint identifier.uptimePercentage
- 7-day uptime percentage.public static Message createProbeLinkLengths(long uid, float[] linkLengths)
uid
- Probe identifier.linkLengths
- Endpoint link lengths.public static Message createProbeLocation(long uid, float location)
uid
- Probe identifier.location
- Endpoint location.public static Message createProbeStoreSize(long uid, float storeSize)
uid
- Probe identifier.storeSize
- Endpoint store size in GiB multiplied by Gaussian noise.public static Message createProbeUptime(long uid, float uptimePercent)
uid
- Probe identifier.uptimePercent
- Percent of the requested period (48 hours or 7 days) which the endpoint was online.public static Message createProbeRejectStats(long uid, byte[] rejectStats)
public static final byte bandwidthClassForCapacityUsage(int bandwidthLimit)
public static final Message createProbeOverallBulkOutputCapacityUsage(long uid, byte outputBandwidthClass, float capacityUsage)
public static Message createFNPSwapRequest(long uid, byte[] buf, int htl)
public static Message createFNPSwapRejected(long uid)
public static Message createFNPSwapReply(long uid, byte[] buf)
public static Message createFNPSwapCommit(long uid, byte[] buf)
public static Message createFNPSwapComplete(long uid, byte[] buf)
public static Message createFNPLocChangeNotificationNew(double myLocation, double[] locations)
public static Message createFNPRoutedPing(long uid, double targetLocation, short htl, int counter, byte[] nodeIdentity)
public static Message createFNPRoutedPong(long uid, int counter)
public static Message createFNPRoutedRejected(long uid, short htl)
public static Message createFNPTime(long time)
public static Message createFNPUptime(byte uptimePercent)
public static Message createFNPVisibility(short visibility)
public static Message createFNPVoid()
public static Message createFNPDisconnect(boolean remove, boolean purge, int messageType, ShortBuffer messageData)
public static Message createUOMAnnouncement(java.lang.String mainKey, java.lang.String revocationKey, boolean haveRevocation, long mainJarVersion, long timeLastTriedRevocationFetch, int revocationDNFCount, long revocationKeyLength, long mainJarLength, int pingTime, int bwlimitDelayTime)
public static Message createUOMRequestRevocation(long uid)
public static Message createUOMRequestMainJar(long uid)
public static Message createUOMSendingRevocation(long uid, long length, java.lang.String key)
public static Message createUOMSendingMainJar(long uid, long length, java.lang.String key, int version)
public static Message createUOMFetchDependency(long uid, byte[] hash, long length)
public static Message createFNPSwapLocations(long[] uids)
public static Message createFNPBestRoutesNotTaken(byte[] locs)
public static Message createFNPBestRoutesNotTaken(double[] locs)
public static Message createFNPBestRoutesNotTaken(java.lang.Double[] doubles)
public static Message createRoutingStatus(boolean routeRequests)
public static Message createFNPSubInsertForkControl(boolean enableInsertForkWhenCacheable)
public static Message createFNPSubInsertPreferInsert(boolean preferInsert)
public static Message createFNPSubInsertIgnoreLowBackoff(boolean ignoreLowBackoff)
public static Message createFNPRejectIsSoft()
public static Message createFNPPeerLoadStatus(NodeStats.PeerLoadStats stats)
public static Message createFNPRealTimeFlag(boolean isBulk)
public static boolean getRealTimeFlag(Message m)
public static boolean isPeerLoadStatusMessage(Message m)
public static boolean isLoadLimitedRequest(Message m)
public static Message createFNPGetYourFullNoderef()
public static Message createFNPMyFullNoderef(long uid, int length)