Package net.i2p.i2ptunnel

Class I2PTunnelServer

    • Method Detail

      • startRunning

        public void startRunning()
        Start running the I2PTunnelServer. Warning, blocks while connecting to router and building tunnels;
        Throws:
        IllegalArgumentException - if the I2CP configuration is b0rked so badly that we cant create a socketManager

      • setReadTimeout

        public void setReadTimeout​(long ms)
        Set the read idle timeout for newly-created connections (in milliseconds). After this time expires without data being reached from the I2P network, the connection itself will be closed. Less than or equal to 0 means forever. Default -1 (forever) as of 0.9.36 for standard tunnels, but extending classes may override. Prior to that, default was 5 minutes, but did not work due to streaming bugs. Applies only to future connections; calling this does not affect existing connections.
        Parameters:
        ms - in ms

      • getReadTimeout

        public long getReadTimeout()
        Get the read idle timeout for newly-created connections (in milliseconds). Less than or equal to 0 means forever. Default -1 (forever) as of 0.9.36 for standard tunnels, but extending classes may override. Prior to that, default was 5 minutes, but did not work due to streaming bugs.
        Returns:
        The read timeout used for connections

      • close

        public boolean close​(boolean forced)
        Note that the tunnel can be reopened after this by calling startRunning(). This does not release all resources. In particular, the I2PSocketManager remains and it may have timer threads that continue running. To release all resources permanently, call destroy().
        Specified by:
        close in class I2PTunnelTask
        Returns:
        success

      • destroy

        public boolean destroy()
        Note that the tunnel cannot be reopened after this by calling startRunning(), as it will destroy the underlying socket manager. This releases all resources.
        Overrides:
        destroy in class I2PTunnelTask
        Returns:
        success
        Since:
        0.9.17

      • optionsUpdated

        public void optionsUpdated​(I2PTunnel tunnel)
        Update the I2PSocketManager. And since 0.9.15, the target host and port.
        Overrides:
        optionsUpdated in class I2PTunnelTask
        Since:
        0.9.1

      • getHandlerCount

        protected int getHandlerCount()

      • run

        public void run()
        If usePool is set, this starts the executor pool. Then, do the accept() loop, and either hands each I2P socket to the executor or runs it in-line.
        Specified by:
        run in interface Runnable

      • shouldUsePool

        public boolean shouldUsePool()

      • blockingHandle

        protected void blockingHandle​(I2PSocket socket)
        This is run in a thread from a limited-size thread pool via Handler.run(), except for a standard server (this class, no extension, as determined in getUsePool()), it is run directly in the acceptor thread (see run()). In either case, this method and any overrides must spawn a thread and return quickly. If blocking while reading the headers (as in HTTP and IRC), the thread pool may be exhausted. See PROP_USE_POOL, DEFAULT_USE_POOL, PROP_HANDLER_COUNT, DEFAULT_HANDLER_COUNT

      • getSocket

        protected Socket getSocket​(Hash from,
                           int incomingPort)
                    throws IOException
        Get a regular or SSL socket depending on config and the incoming port. To configure a specific host:port as the server for incoming port xx, set option targetForPort.xx=host:port
        Parameters:
        from - may be used to construct local address since 0.9.13
        Throws:
        IOException
        Since:
        0.9.9

      • getSocket

        protected Socket getSocket​(Hash from,
                           InetAddress remoteHost,
                           int remotePort)
                    throws IOException
        Get a regular or SSL socket depending on config. The SSL config applies to all hosts/ports.
        Parameters:
        from - may be used to construct local address since 0.9.13
        Throws:
        IOException
        Since:
        0.9.9