SAMStreamSession.SAMv1StreamSessionSocketReader | Javadocs [I2P+]

java.lang.Object

net.i2p.sam.SAMStreamSession.SAMStreamSessionSocketReader

net.i2p.sam.SAMStreamSession.SAMv1StreamSessionSocketReader

All Implemented Interfaces:: Runnable

Direct Known Subclasses:: SAMv2StreamSession.SAMv2StreamSessionSocketReader

Enclosing class:: SAMStreamSession

public class SAMStreamSession.SAMv1StreamSessionSocketReaderextends SAMStreamSession.SAMStreamSessionSocketReader

SAMv1StreamSessionSocketReader.

Field Summary
Fields inherited from class SAMStreamSession.SAMStreamSessionSocketReader
i2pSocket, id, runningLock, stillRunning
Modifier and Type
Field
Description
protected final I2PSocket
i2pSocket
The tunnel socket this reader drains.
protected final int
id
Stream id for this reader.
protected final Object
runningLock
Guards the run loop's state against a concurrent stop.
protected boolean
stillRunning
Guarded by runningLock; cleared on stop.
Constructor Summary
Constructors
Constructor
Description
SAMv1StreamSessionSocketReader(I2PSocket s, int id)
Create a new SAM STREAM session socket reader.
Method Summary
All Methods
Modifier and Type
Method
Description
void
run()
Reads from the socket, forwarding bytes to the client until it ends.
void
stopRunning()
Stop a SAM STREAM session socket reader thead immediately.
Methods inherited from class Object
clone, equals, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Details
- SAMv1StreamSessionSocketReader
  public SAMv1StreamSessionSocketReader(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 - if the reader for that socket cannot be created
Method Details
- stopRunning
  public void stopRunning()
  Stop a SAM STREAM session socket reader thead immediately.
  Overrides:
  stopRunning in class SAMStreamSession.SAMStreamSessionSocketReader
- run
  public void run()
  Reads from the socket, forwarding bytes to the client until it ends.
  Specified by:
  run in interface Runnable
  Overrides:
  run in class SAMStreamSession.SAMStreamSessionSocketReader