common/src/main/java/HTTPClient/StreamDemultiplexor.java
/**
     * Initializes the demultiplexor with a new socket.
     *
     * @param stream   the stream to demultiplex
     */
Initializes the demultiplexor with a new socket.
@param stream   the stream to demultiplex
Initializes the demultiplexor with a new socket . @param stream the stream to demultiplex
private void init(Socket sock)  throws IOException
    {
	Log.write(Log.DEMUX, "Demux: Initializing Stream Demultiplexor (" +
			     this.hashCode() + ")");
	this.Sock       = sock;
	this.Stream     = new BufferedInputStream(sock.getInputStream());
	MarkedForClose  = null;
	chunk_len       = -1;
	Timer = TimerThread.setTimeout(this);
	Timer.hyber();
    }
private void init ( Socket sock ) throws IOException { Log . write ( Log . DEMUX , "Demux: Initializing Stream Demultiplexor (" + this . hashCode ( ) + ")" ) ; this . Sock = sock ; this . Stream = new BufferedInputStream ( sock . getInputStream ( ) ) ; MarkedForClose = null ; chunk_len = - 1 ; Timer = TimerThread . setTimeout ( this ) ; Timer . hyber ( ) ; }
Initializes the demultiplexor with a new socket.
Initializes the demultiplexor with a new socket .
// create a timer to close the socket after 60 seconds, but don't // start it yet