PacketLocal (Javadocs [I2P+ 2.13.0+]

java.lang.Object
- net.i2p.client.streaming.impl.Packet
- - net.i2p.client.streaming.impl.PacketLocal

All Implemented Interfaces:
MessageOutputStream.WriteStatus
```
class PacketLocal
extends Packet
implements MessageOutputStream.WriteStatus
```
This is the class used for outbound packets. coordinate local attributes about a packet - send time, ack time, number of retries, etc.

Field Summary
- Fields inherited from class net.i2p.client.streaming.impl.Packet
  _nacks, _offlineSignature, _optionFrom, _optionSignature, _session, _transientExpires, _transientSigningPublicKey, DEFAULT_MAX_SIZE, FLAG_CLOSE, FLAG_DELAY_REQUESTED, FLAG_ECHO, FLAG_FROM_INCLUDED, FLAG_MAX_PACKET_SIZE_INCLUDED, FLAG_NO_ACK, FLAG_PROFILE_INTERACTIVE, FLAG_RESET, FLAG_SIGNATURE_INCLUDED, FLAG_SIGNATURE_OFFLINE, FLAG_SIGNATURE_REQUESTED, FLAG_SYNCHRONIZE, MAX_DELAY_REQUEST, MAX_PAYLOAD_SIZE, MAX_STREAM_ID, MIN_DELAY_CHOKE, SEND_DELAY_CHOKE, STREAM_ID_UNKNOWN

Constructor Summary

Constructors
Constructor and Description
`PacketLocal(I2PAppContext ctx, Destination to, Connection con)` Constructor for a packet bound to a connection.
`PacketLocal(I2PAppContext ctx, Destination to, I2PSession session)` Constructor for a packet not bound to a connection.

Method Summary

All Methods Static Methods Instance Methods Concrete Methods
Modifier and Type	Method and Description
`void`	`ackReceived()` Record that this packet was ACKed
`void`	`cancelled()` Record that this packet was cancelled
`StringBuilder`	`formatAsString()` Format as a string builder for logging.
`int`	`getAckTime()` How long after packet creation was it acked?
`Connection`	`getConnection()` Bound connection.
`long`	`getCreatedOn()` Creation time.
`long`	`getLastSend()` Time of the last send.
`long`	`getLifetime()` Lifetime of this packet.
`int`	`getNACKs()` Warning: This is different than getNacks() in super
`int`	`getNumSends()` Number of times sent.
`(package private) static ByteCache`	`getPayloadCache()` Shared outbound payload cache (MAX_PAYLOAD_SIZE buffers).
`int`	`getTimeout()` Used by PacketQueue to feed an expiration to the router.
`Destination`	`getTo()` Destination this packet is being sent to.
`void`	`incrementNACKs()` Will force a fast restransmit on the 3rd call (FAST_RETRANSMIT_THRESHOLD) but only if it's the lowest unacked (see Connection.ResendPacketEvent)
`void`	`incrementSends()` Increment the number of times this packet has been sent
`boolean`	`isEnqueued()`
`void`	`logTCPDump()` Generate a pcap/tcpdump-compatible format, so we can use standard debugging tools.
`void`	`markEnqueued()`
`void`	`releasePayload()` Return the payload to the shared pool instead of letting it GC.
`void`	`setOptionalFrom()` This sets the from field in the packet to the Destination for the session provided in the constructor.
`void`	`setTimeout(int timeout)` Timeout for this packet.
`boolean`	`shouldSign()` Whether this packet should be signed.
`void`	`waitForAccept(int maxWaitMs)` Blocks until outbound window is not full.
`void`	`waitForCompletion(int maxWaitMs)` Block until the packet is acked from the far end.
`boolean`	`writeAccepted()` Whether the send was accepted.
`boolean`	`writeFailed()` Whether the send failed.
`int`	`writeSignedPacket(byte[] buffer, int offset)` Sign and write the packet to the buffer (starting at the offset) and return the number of bytes written.
`boolean`	`writeSuccessful()` Whether the send succeeded and was ACKed.

Methods inherited from class net.i2p.client.streaming.impl.Packet
acquirePayload, getAckThrough, getLocalPort, getNacks, getOptionalDelay, getOptionalFrom, getOptionalMaxSize, getOptionalSignature, getPayload, getPayloadSize, getReceiveStreamId, getRemotePort, getResendDelay, getSendStreamId, getSequenceNum, getSession, getTransientSPK, isFlagSet, logTCPDump, readPacket, setAckThrough, setFlag, setFlag, setLocalPort, setNacks, setOptionalDelay, setOptionalMaxSize, setOptionalSignature, setPayload, setReceiveStreamId, setRemotePort, setResendDelay, setSendStreamId, setSequenceNum, toId, toString, verifySignature, verifySignature, writePacket, writePacket

Methods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, wait

- Constructor Detail
  - PacketLocal
```
public PacketLocal(I2PAppContext ctx,
                   Destination to,
                   Connection con)
```
    Constructor for a packet bound to a connection.
  - PacketLocal
```
public PacketLocal(I2PAppContext ctx,
                   Destination to,
                   I2PSession session)
```
    Constructor for a packet not bound to a connection.
- Method Detail
  - ackReceived
```
public void ackReceived()
```
    Record that this packet was ACKed
  - cancelled
```
public void cancelled()
```
    Record that this packet was cancelled
  - formatAsString
```
public StringBuilder formatAsString()
```
    Format as a string builder for logging.
    Overrides:
    formatAsString in class Packet
  - getAckTime
```
public int getAckTime()
```
    How long after packet creation was it acked?
    Returns:
    how long after packet creation the packet was ACKed in ms
  - getConnection
```
public Connection getConnection()
```
    Bound connection.
    Returns:
    null if not bound
  - getCreatedOn
```
public long getCreatedOn()
```
    Creation time.
    Returns:
    the time this packet was created
  - getLastSend
```
public long getLastSend()
```
    Time of the last send.
    Returns:
    the time of the last send, or -1 if never sent
  - getLifetime
```
public long getLifetime()
```
    Lifetime of this packet.
    Returns:
    the lifetime of this packet in ms
  - getNACKs
```
public int getNACKs()
```
    Warning: This is different than getNacks() in super
    Returns:
    Number of times this packet has been nacked
  - getNumSends
```
public int getNumSends()
```
    Number of times sent.
    Returns:
    the number of times this packet has been sent
  - getPayloadCache
```
static ByteCache getPayloadCache()
```
    Shared outbound payload cache (MAX_PAYLOAD_SIZE buffers). Must match the cache in ConnectionDataReceiver._payloadCache.
  - getTimeout
```
public int getTimeout()
```
    Used by PacketQueue to feed an expiration to the router.
    Returns:
    time from now, not absolute time. May be zero if unset.
  - getTo
```
public Destination getTo()
```
    Destination this packet is being sent to.
    Returns:
    the destination this packet is being sent to
  - incrementNACKs
```
public void incrementNACKs()
```
    Will force a fast restransmit on the 3rd call (FAST_RETRANSMIT_THRESHOLD) but only if it's the lowest unacked (see Connection.ResendPacketEvent)
  - incrementSends
```
public void incrementSends()
```
    Increment the number of times this packet has been sent
  - isEnqueued
```
public boolean isEnqueued()
```
  - logTCPDump
```
public void logTCPDump()
```
    Generate a pcap/tcpdump-compatible format, so we can use standard debugging tools.
  - markEnqueued
```
public void markEnqueued()
```
  - releasePayload
```
public void releasePayload()
```
    Return the payload to the shared pool instead of letting it GC. Only returns buffers that came from the MAX_PAYLOAD_SIZE pool; zero-length or other-size payloads fall through to default no-op.
    Overrides:
    releasePayload in class Packet
  - setOptionalFrom
```
public void setOptionalFrom()
```
    This sets the from field in the packet to the Destination for the session provided in the constructor. This also sets flag FLAG_FROM_INCLUDED. Also, as of 0.9.39, sets the offline signing data if supported by the session.
  - setTimeout
```
public void setTimeout(int timeout)
```
    Timeout for this packet.
    Parameters:
    timeout - time from now, not absolute time
  - shouldSign
```
public boolean shouldSign()
```
    Whether this packet should be signed.
    Returns:
    true if this packet should be signed
  - waitForAccept
```
public void waitForAccept(int maxWaitMs)
                   throws IOException,
                          InterruptedException
```
    Blocks until outbound window is not full. See Connection.packetSendChoke().
    Specified by:
    waitForAccept in interface MessageOutputStream.WriteStatus
    Parameters:
    maxWaitMs - MessageOutputStream is the only caller, generally with -1
    Throws:
    IOException - if the connection is closed
    InterruptedException - if the thread is interrupted
  - waitForCompletion
```
public void waitForCompletion(int maxWaitMs)
                       throws IOException,
                              InterruptedException
```
    Block until the packet is acked from the far end.
    Specified by:
    waitForCompletion in interface MessageOutputStream.WriteStatus
    Parameters:
    maxWaitMs - maximum time to wait in ms
    Throws:
    IOException - if the connection is reset or cancelled
    InterruptedException - if the thread is interrupted
  - writeAccepted
```
public boolean writeAccepted()
```
    Whether the send was accepted.
    Specified by:
    writeAccepted in interface MessageOutputStream.WriteStatus
    Returns:
    true if this packet was accepted for sending
  - writeFailed
```
public boolean writeFailed()
```
    Whether the send failed.
    Specified by:
    writeFailed in interface MessageOutputStream.WriteStatus
    Returns:
    true if this packet's send failed
  - writeSignedPacket
```
public int writeSignedPacket(byte[] buffer,
                             int offset)
                      throws IllegalStateException
```
    Sign and write the packet to the buffer (starting at the offset) and return the number of bytes written.
    Parameters:
    buffer - data to be written
    offset - starting point in the buffer
    Returns:
    Count of bytes written
    Throws:
    IllegalStateException - if there is data missing or otherwise b0rked
  - writeSuccessful
```
public boolean writeSuccessful()
```
    Whether the send succeeded and was ACKed.
    Returns:
    true if this packet was successfully sent and ACKed

Class PacketLocal

Field Summary

Fields inherited from class net.i2p.client.streaming.impl.Packet

Constructor Summary

Method Summary

Methods inherited from class net.i2p.client.streaming.impl.Packet

Methods inherited from class java.lang.Object

Constructor Detail

PacketLocal

PacketLocal

Method Detail

ackReceived

cancelled

formatAsString

getAckTime

getConnection

getCreatedOn

getLastSend

getLifetime

getNACKs

getNumSends

getPayloadCache

getTimeout

getTo

incrementNACKs

incrementSends

isEnqueued

logTCPDump

markEnqueued

releasePayload

setOptionalFrom

setTimeout

shouldSign

waitForAccept

waitForCompletion

writeAccepted

writeFailed

writeSignedPacket

writeSuccessful