Packages that use I2CPMessageException
Package
Description
net.i2p.data.i2cp
The Invisible Internet Client Protocol (I2CP) allows applications simplified access to I2P network without requiring them to deal with the issues involved with the Invisible Internet Network Protocol (I2NP).
net.i2p.router.client
Router-side implementation of the Invisible Internet Client Protocol (I2CP): client sessions over plain or TLS sockets, message delivery, and lease and tunnel management on behalf of clients.

  • Uses of I2CPMessageException in net.i2p.data.i2cp

    Methods in net.i2p.data.i2cp that throw I2CPMessageException
    Modifier and Type
    Method
    Description
    private static I2CPMessage
    I2CPMessageHandler.createMessage(int type)
    Yes, this is fairly ugly, but its the only place it ever happens.
    protected void
    BandwidthLimitsMessage.doReadMessage(InputStream in, int size)
     
    protected void
    BlindingInfoMessage.doReadMessage(InputStream in, int size)
     
    protected void
    CreateLeaseSet2Message.doReadMessage(InputStream in, int size)
    Read the message body from the input stream.
    protected void
    CreateLeaseSetMessage.doReadMessage(InputStream in, int size)
    Read the message body from the input stream.
    protected void
    CreateSessionMessage.doReadMessage(InputStream in, int size)
    Read the message body from the input stream.
    protected void
    DestLookupMessage.doReadMessage(InputStream in, int size)
    Read the message body from the input stream.
    protected void
    DestReplyMessage.doReadMessage(InputStream in, int size)
    Read the message body from the input stream.
    protected void
    DestroySessionMessage.doReadMessage(InputStream in, int size)
    Read the message body from the input stream.
    protected void
    DisconnectMessage.doReadMessage(InputStream in, int size)
    Read the message body from the input stream.
    protected void
    GetBandwidthLimitsMessage.doReadMessage(InputStream in, int size)
    Read the message from the stream.
    protected void
    GetDateMessage.doReadMessage(InputStream in, int size)
    Read the message body from the input stream.
    protected void
    HostLookupMessage.doReadMessage(InputStream in, int size)
    Read the message body from the input stream.
    protected void
    HostReplyMessage.doReadMessage(InputStream in, int size)
    Read the message body from the input stream.
    protected abstract void
    I2CPMessageImpl.doReadMessage(InputStream buf, int size)
    Read in the payload part of the message (after the initial 4 byte size and 1 byte type).
    protected void
    MessagePayloadMessage.doReadMessage(InputStream in, int size)
    Read in the payload part of the message (after the initial 4 byte size and 1 byte type).
    protected void
    MessageStatusMessage.doReadMessage(InputStream in, int size)
    Read the message body from the input stream.
    protected void
    ReceiveMessageBeginMessage.doReadMessage(InputStream in, int size)
    Read the message body from the input stream.
    protected void
    ReceiveMessageEndMessage.doReadMessage(InputStream in, int size)
     
    protected void
    ReconfigureSessionMessage.doReadMessage(InputStream in, int size)
    Read the message body from the input stream.
    protected void
    ReportAbuseMessage.doReadMessage(InputStream in, int size)
    Read the message body from the input stream.
    protected void
    RequestLeaseSetMessage.doReadMessage(InputStream in, int size)
    Read the message body from the input stream.
    protected void
    RequestVariableLeaseSetMessage.doReadMessage(InputStream in, int size)
    Read the message body from the input stream.
    protected void
    SendMessageMessage.doReadMessage(InputStream in, int size)
    Read in the payload part of the message (after the initial 4 byte size and 1 byte type).
    protected void
    SessionStatusMessage.doReadMessage(InputStream in, int size)
    Read the message body from the input stream.
    protected void
    SetDateMessage.doReadMessage(InputStream in, int size)
    Read the message body from the input stream.
    protected byte[]
    BandwidthLimitsMessage.doWriteMessage()
     
    protected byte[]
    BlindingInfoMessage.doWriteMessage()
     
    protected byte[]
    CreateLeaseSet2Message.doWriteMessage()
    Write the message body to the output stream.
    protected byte[]
    CreateLeaseSetMessage.doWriteMessage()
    Write the message body to the output stream.
    protected byte[]
    CreateSessionMessage.doWriteMessage()
    Write the message body to the output stream.
    protected byte[]
    DestLookupMessage.doWriteMessage()
    Write the message body to the output stream.
    protected byte[]
    DestReplyMessage.doWriteMessage()
    Write the message body to the output stream.
    protected byte[]
    DestroySessionMessage.doWriteMessage()
    Write the message body to the output stream.
    protected byte[]
    DisconnectMessage.doWriteMessage()
    Write the message body to the output stream.
    protected byte[]
    GetBandwidthLimitsMessage.doWriteMessage()
    Write the message body to the output stream.
    protected byte[]
    GetDateMessage.doWriteMessage()
    Write the message body to the output stream.
    protected byte[]
    HostLookupMessage.doWriteMessage()
    Write the message body to the output stream.
    protected byte[]
    HostReplyMessage.doWriteMessage()
    Write the message body to the output stream.
    protected abstract byte[]
    I2CPMessageImpl.doWriteMessage()
    Write out the payload part of the message (not including the 4 byte size and 1 byte type).
    protected byte[]
    MessagePayloadMessage.doWriteMessage()
    Write the message body to the output stream.
    protected byte[]
    MessageStatusMessage.doWriteMessage()
    Write the message body to the output stream.
    protected byte[]
    ReceiveMessageBeginMessage.doWriteMessage()
    Write the message body to the output stream.
    protected byte[]
    ReceiveMessageEndMessage.doWriteMessage()
     
    protected byte[]
    ReconfigureSessionMessage.doWriteMessage()
    Write the message body to the output stream.
    protected byte[]
    ReportAbuseMessage.doWriteMessage()
    Write the message body to the output stream.
    protected byte[]
    RequestLeaseSetMessage.doWriteMessage()
    Write the message body to the output stream.
    protected byte[]
    RequestVariableLeaseSetMessage.doWriteMessage()
    Write the message body to the output stream.
    protected byte[]
    SendMessageMessage.doWriteMessage()
    Serialization is not supported for this message.
    protected byte[]
    SessionStatusMessage.doWriteMessage()
    Write the message body to the output stream.
    protected byte[]
    SetDateMessage.doWriteMessage()
    Write the message body to the output stream.
    void
    I2CPMessage.readMessage(InputStream in)
    Read the contents from the input stream into the current class's format.
    void
    I2CPMessage.readMessage(InputStream in, int size, int type)
    Read the contents from the input stream into the current class's format.
    static I2CPMessage
    I2CPMessageHandler.readMessage(InputStream in)
    Read an I2CPMessage from the stream and return the fully populated object.
    void
    I2CPMessageImpl.readMessage(InputStream in)
    Validate the type and size of the message, and then read the message into the data structures.
    void
    I2CPMessageImpl.readMessage(InputStream in, int length, int type)
    Read the body into the data structures.
    void
    SendMessageExpiresMessage.readMessage(InputStream in, int length, int type)
    Read the body into the data structures.
    void
    SendMessageMessage.readMessage(InputStream in, int length, int type)
    Read the body into the data structures.
    void
    I2CPMessage.writeMessage(OutputStream out)
    Write the current message to the output stream as a full message following the specification from the I2CP definition.
    void
    I2CPMessageImpl.writeMessage(OutputStream out)
    Write out the full message to the stream, including the 4 byte size and 1 byte type header.
    void
    MessagePayloadMessage.writeMessage(OutputStream out)
    Write out the full message to the stream, including the 4 byte size and 1 byte type header.
    void
    MessageStatusMessage.writeMessage(OutputStream out)
    Override to reduce mem churn.
    void
    ReceiveMessageBeginMessage.writeMessage(OutputStream out)
    Override to reduce mem churn.
    void
    SendMessageExpiresMessage.writeMessage(OutputStream out)
    Write out the full message to the stream, including the 4 byte size and 1 byte type header.
    void
    SendMessageMessage.writeMessage(OutputStream out)
    Write out the full message to the stream, including the 4 byte size and 1 byte type header.

  • Uses of I2CPMessageException in net.i2p.router.client

    Methods in net.i2p.router.client that return I2CPMessageException
    Modifier and Type
    Method
    Description
    private I2CPMessageException
    QueuedClientConnectionRunner.queueFull()
    The error for a client that is not draining its I2CP queue.
    Methods in net.i2p.router.client that throw I2CPMessageException
    Modifier and Type
    Method
    Description
    void
    ClientWriterRunner.addMessage(I2CPMessage msg)
    Add this message to the writer's queue
    (package private) void
    ClientConnectionRunner.doSend(I2CPMessage msg)
    Actually send the I2CPMessage to the peer through the socket.
    (package private) void
    QueuedClientConnectionRunner.doSend(I2CPMessage msg)
    Actually send the I2CPMessage to the client.
    (package private) void
    ClientConnectionRunner.doSendWait(I2CPMessage msg, long timeoutMs)
    Send a message, allowing the transport up to timeoutMs to accept it.
    (package private) void
    QueuedClientConnectionRunner.doSendWait(I2CPMessage msg, long timeoutMs)
    Send the I2CPMessage, giving the client's queue up to timeoutMs to make room.
    private void
    MessageReceivedJob.messageAvailable(MessageId id, long size)
    Deliver notification to the client that the given message is available.
    private void
    MessageReceivedJob.sendMessage(long id)
    Deliver the message directly, skip notification.