StreamrProducer

net.i2p.i2ptunnel.streamr.StreamrProducer

All Implemented Interfaces:: Sink, Source, EventDispatcher

public class StreamrProducerextends I2PTunnelUDPServerBase

Streamr producer that acts as an I2P server and UDP client, receiving UDP data on a configured port and forwarding it through I2P.

Field Summary
Fields
Modifier and Type
Field
Description
private final MultiSource
multi
Hands the incoming feed to this tunnel's listeners.
private final UDPSource
server
The UDP socket the feed arrives on.
Fields inherited from class I2PTunnelUDPServerBase
l, readTimeout, slock
Modifier and Type
Field
Description
protected Logging
l
The logging facility the owning tunnel reports through.
protected long
readTimeout
Default timeout to 3 minutes - override if desired.
protected Object
slock
Held while a read or write is in flight on the client's socket.
Fields inherited from class I2PTunnelTask
open, tunnel
Modifier and Type
Field
Description
protected boolean
open
True while the tunnel is running and accepting connections.
I2PTunnel
tunnel
The I2PTunnel this task runs inside.
Constructor Summary
Constructors
Constructor
Description
StreamrProducer(int port, File privkey, String privkeyname, Logging l, EventDispatcher notifyThis, I2PTunnel tunnel)
Creates a Streamr producer that receives UDP data and forwards it through I2P.
Method Summary
All Methods
Modifier and Type
Method
Description
boolean
close(boolean forced)
Stops the server and releases resources.
final void
startRunning()
Starts the UDP server and begins forwarding data.
Methods inherited from class I2PTunnelUDPServerBase
getReadTimeout, send, setReadTimeout, setSink, start
Modifier and Type
Method
Description
long
getReadTimeout()
Read idle timeout for newly-created connections (in milliseconds).
void
send(Destination to, int fromPort, int toPort, byte[] data)
Sends data through the I2P sink.
void
setReadTimeout(long ms)
Sets the read idle timeout for newly-created connections (in milliseconds).
void
setSink(Sink s)
Sets the receiver of the UDP datagrams from I2P.
void
start()
Starts the I2P source to begin receiving datagrams.
Methods inherited from class I2PTunnelTask
connected, destroy, disconnected, errorOccurred, getBooleanOption, getId, getSocketManager, getTunnel, isOpen, optionsUpdated, reportAbuse, routerDisconnected, setId, setName, setTunnel, toString
Modifier and Type
Method
Description
void
connected(I2PSession session)
For tasks that don't call I2PTunnel.addSession(I2PSession) directly.
boolean
destroy()
Note that the tunnel cannot be reopened after this by calling startRunning(), as it may destroy the underlying socket manager, depending on implementation.
void
disconnected(I2PSession session)
Called when a session is disconnected.
void
errorOccurred(I2PSession session, String message, Throwable error)
Does nothing here.
protected boolean
getBooleanOption(String opt, boolean dflt)
Read a boolean client option from the tunnel's properties.
int
getId()
The id of the client list entry for this task.
I2PSocketManager
getSocketManager()
Returns the I2PSocketManager for this task, or null if not applicable.
I2PTunnel
getTunnel()
The I2PTunnel this task runs inside.
boolean
isOpen()
Whether the tunnel is running and accepting connections.
void
optionsUpdated(I2PTunnel tunnel)
Notify the task that I2PTunnel's options have been updated.
void
reportAbuse(I2PSession session, int severity)
Does nothing here.
protected void
routerDisconnected()
Tell the tunnel that the router connection has dropped.
void
setId(int id)
Record the client list entry id for this task.
protected void
setName(String name)
Record the display name for this task.
void
setTunnel(I2PTunnel pTunnel)
Rebind this task to a different tunnel.
String
toString()
The display name given to this task when it was constructed.
Methods inherited from class EventDispatcherImpl
attachEventDispatcher, detachEventDispatcher, getEventDispatcher, getEvents, getEventValue, ignoreEvents, notifyEvent, unIgnoreEvents, waitEventValue
Modifier and Type
Method
Description
void
attachEventDispatcher(EventDispatcher ev)
Attach an EventDispatcher object to the events dispatching chain.
void
detachEventDispatcher(EventDispatcher ev)
Detach the specified EventDispatcher object from the events dispatching chain.
EventDispatcher
getEventDispatcher()
Object to be used to deliver events (usually this, but YMMV).
Set<String>
getEvents()
Retrieve the names of all the events that have been received.
Object
getEventValue(String name)
Retrieve the value currently associated with the specified event value.
void
ignoreEvents()
Ignore further event notifications.
void
notifyEvent(String eventName, Object args)
Deliver an event.
void
unIgnoreEvents()
Almost like the method above :-).
Object
waitEventValue(String name)
Wait until the given event has received a value.
Methods inherited from class Object
clone, equals, getClass, hashCode, notify, notifyAll, wait, wait, wait

Field Details
- multi
  private final MultiSource multi
  Hands the incoming feed to this tunnel's listeners.
- server
  private final UDPSource server
  The UDP socket the feed arrives on.
Constructor Details
- StreamrProducer
  public StreamrProducer(int port, File privkey, String privkeyname, Logging l, EventDispatcher notifyThis, I2PTunnel tunnel)
  Creates a Streamr producer that receives UDP data and forwards it through I2P.
  Parameters:
  port - local UDP port to listen on
  privkey - I2P private key file for the destination
  privkeyname - name of the private key
  l - the logging facility passed on to the superclass
  notifyThis - event dispatcher for notifications
  tunnel - the owning I2PTunnel, which supplies the client options and context
Method Details
- startRunning
  public final void startRunning()
  Starts the UDP server and begins forwarding data.
  Overrides:
  startRunning in class I2PTunnelUDPServerBase
- close
  public boolean close(boolean forced)
  Stops the server and releases resources.
  Overrides:
  close in class I2PTunnelUDPServerBase
  Parameters:
  forced - if true, forces immediate close
  Returns:
  true if closed successfully

Field Summary

Fields inherited from class I2PTunnelUDPServerBase

Fields inherited from class I2PTunnelTask

Constructor Summary

Method Summary

Methods inherited from class I2PTunnelUDPServerBase

Methods inherited from class I2PTunnelTask

Methods inherited from class EventDispatcherImpl

Methods inherited from class Object

Field Details

multi

server

Constructor Details

Method Details

startRunning

close