net.i2p.sam
Class SAMStreamSession.SAMStreamSessionSocketReader

java.lang.Object
  extended by net.i2p.sam.SAMStreamSession.SAMStreamSessionSocketReader
All Implemented Interfaces:
java.lang.Runnable
Direct Known Subclasses:
SAMStreamSession.SAMv1StreamSessionSocketReader
Enclosing class:
SAMStreamSession

public class SAMStreamSession.SAMStreamSessionSocketReader
extends java.lang.Object
implements java.lang.Runnable

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

Author:
human

Field Summary
protected  I2PSocket i2pSocket
           
protected  int id
           
protected  java.lang.Object runningLock
           
protected  boolean stillRunning
           
 
Constructor Summary
SAMStreamSession.SAMStreamSessionSocketReader(I2PSocket s, int id)
          Create a new SAM STREAM session socket reader
 
Method Summary
 void run()
           
 void stopRunning()
          Stop a SAM STREAM session socket reader thread immediately.
 
Methods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
 

Field Detail

i2pSocket

protected I2PSocket i2pSocket

runningLock

protected java.lang.Object runningLock

stillRunning

protected boolean stillRunning

id

protected int id
Constructor Detail

SAMStreamSession.SAMStreamSessionSocketReader

public SAMStreamSession.SAMStreamSessionSocketReader(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

stopRunning

public void stopRunning()
Stop a SAM STREAM session socket reader thread immediately.


run

public void run()
Specified by:
run in interface java.lang.Runnable