net.i2p.sam
Class SAMv2StreamSession.SAMv2StreamSessionSocketReader

java.lang.Object
  extended by net.i2p.sam.SAMStreamSession.SAMStreamSessionSocketReader
      extended by net.i2p.sam.SAMStreamSession.SAMv1StreamSessionSocketReader
          extended by net.i2p.sam.SAMv2StreamSession.SAMv2StreamSessionSocketReader
All Implemented Interfaces:
java.lang.Runnable
Enclosing class:
SAMv2StreamSession

public class SAMv2StreamSession.SAMv2StreamSessionSocketReader
extends SAMStreamSession.SAMv1StreamSessionSocketReader

SAM STREAM socket reader, running in its own thread. It forwards forward data to/from an I2P socket.

Author:
human

Field Summary
protected  long limit
           
protected  boolean nolimit
           
protected  long totalReceived
           
 
Fields inherited from class net.i2p.sam.SAMStreamSession.SAMStreamSessionSocketReader
i2pSocket, id, runningLock, stillRunning
 
Constructor Summary
SAMv2StreamSession.SAMv2StreamSessionSocketReader(I2PSocket s, int id)
          Create a new SAM STREAM session socket reader
 
Method Summary
 void run()
           
 void setLimit(long limit, boolean nolimit)
           
 
Methods inherited from class net.i2p.sam.SAMStreamSession.SAMv1StreamSessionSocketReader
stopRunning
 
Methods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
 

Field Detail

nolimit

protected boolean nolimit

limit

protected long limit

totalReceived

protected long totalReceived
Constructor Detail

SAMv2StreamSession.SAMv2StreamSessionSocketReader

public SAMv2StreamSession.SAMv2StreamSessionSocketReader(I2PSocket s,
                                                         int id)
                                                  throws java.io.IOException
Create a new SAM STREAM session socket reader

Parameters:
s - Socket to be handled
id - Unique id assigned to the handler
Throws:
java.io.IOException
Method Detail

setLimit

public void setLimit(long limit,
                     boolean nolimit)

run

public void run()
Specified by:
run in interface java.lang.Runnable
Overrides:
run in class SAMStreamSession.SAMv1StreamSessionSocketReader