Package net.i2p.sam

Class SAMStreamSession.SAMStreamSessionSocketReader

java.lang.Object

net.i2p.sam.SAMStreamSession.SAMStreamSessionSocketReader

All Implemented Interfaces:

Runnable

Direct Known Subclasses:

SAMStreamSession.SAMv1StreamSessionSocketReader

Enclosing class:

SAMStreamSession

public class SAMStreamSession.SAMStreamSessionSocketReader
extends Object
implements Runnable

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

Author:

human

Field Summary

Fields

Modifier and Type	Field	Description
protected final I2PSocket	i2pSocket
protected final int	id
protected final Object	runningLock
protected boolean	stillRunning

Constructor Summary

Constructors

Constructor	Description
SAMStreamSessionSocketReader(I2PSocket s, int id)	Create a new SAM STREAM session socket reader

Method Summary

Modifier and Type	Method	Description
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 Details

i2pSocket

protected final I2PSocket i2pSocket

runningLock

protected final Object runningLock

stillRunning

protected volatile boolean stillRunning

id

protected final int id

Constructor Details

SAMStreamSessionSocketReader

public SAMStreamSessionSocketReader(I2PSocket s,
 int id)
                             throws IOException

Create a new SAM STREAM session socket reader

Parameters:

s - Socket to be handled

id - Unique id assigned to the handler

Throws:

IOException

Method Details

stopRunning

public void stopRunning()

Stop a SAM STREAM session socket reader thread immediately.

run

public void run()

Specified by:

run in interface Runnable