Class NetworkConnectionImpl

    • Field Detail

      • is_incoming

        private final boolean is_incoming
      • connect_with_crypto

        private boolean connect_with_crypto
      • allow_fallback

        private boolean allow_fallback
      • shared_secrets

        private byte[][] shared_secrets
      • is_connected

        boolean is_connected
      • is_lan_local

        private byte is_lan_local
      • enhanced_partition_id

        private int enhanced_partition_id
      • started

        private boolean started
      • closed

        private volatile boolean closed
      • user_data

        private java.util.Map<java.lang.Object,​java.lang.Object> user_data
    • Constructor Detail

      • NetworkConnectionImpl

        public NetworkConnectionImpl​(ConnectionEndpoint _target,
                                     MessageStreamEncoder encoder,
                                     MessageStreamDecoder decoder,
                                     boolean _connect_with_crypto,
                                     boolean _allow_fallback,
                                     byte[][] _shared_secrets)
        Constructor for new OUTbound connection. The connection is not yet established upon instantiation; use connect() to do so.
        Parameters:
        _remote_address - to connect to
        encoder - default message stream encoder to use for the outgoing queue
        decoder - default message stream decoder to use for the incoming queue
      • NetworkConnectionImpl

        public NetworkConnectionImpl​(Transport _transport,
                                     MessageStreamEncoder encoder,
                                     MessageStreamDecoder decoder)
        Constructor for new INbound connection. The connection is assumed to be already established, by the given already-connected channel.
        Parameters:
        _remote_channel - connected by
        data_already_read - bytestream already read during routing
        encoder - default message stream encoder to use for the outgoing queue
        decoder - default message stream decoder to use for the incoming queue