edu.berkeley.psi.seda.generic
Class genericUdpService

java.lang.Object
  edu.berkeley.psi.seda.generic.genericUdpService

All Implemented Interfaces:

genericConst, EventHandlerIF

public class genericUdpService
extends java.lang.Object
implements EventHandlerIF, genericConst

A genericUdpService is an EventHandlerIF for a SandStorm stage which accepts incoming AUdpInPackets. The server has a client sink associated with it, onto which genericConnection and genericRequest events are pushed. When a connection is closed, a SinkClosedEvent is pushed, with the sink pointer set to the genericConnection that closed.

See Also:

genericConnection, genericRequest

Field Summary

private static boolean	DEBUG
protected int	listenPort
protected ManagerIF	mgr
protected SinkIF	mySink
protected AUdpSocket	sock
protected StageIF	stage

Fields inherited from interface edu.berkeley.psi.seda.generic.genericConst

CRLF, DEFAULT_PORT, WRITE_CLOG_THRESHOLD

Constructor Summary

genericUdpService()
Create a generic server listening for incoming packets on the default port.

Method Summary

void	destroy() Called when an event handler is destroyed.
AUdpSocket	getServerSocket() Return the server socket being used by this genericServer.
(package private) SinkIF	getSink()
void	handleEvent(QueueElementIF qel) The main event handler.
void	handleEvents(QueueElementIF[] qelarr) Handle the events corresponding to the given QueueElementIF array.
void	init(ConfigDataIF config) The Sandstorm stage initialization method.
java.lang.String	toString()

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, wait

Field Detail

DEBUG

private static final boolean DEBUG

See Also:

Constant Field Values

listenPort

protected int listenPort

sock

protected AUdpSocket sock

mgr

protected ManagerIF mgr

stage

protected StageIF stage

mySink

protected SinkIF mySink

Constructor Detail

genericUdpService

public genericUdpService()

Create a generic server listening for incoming packets on the default port.

Method Detail

init

public void init(ConfigDataIF config)
          throws java.lang.Exception

The Sandstorm stage initialization method.

Specified by:

init in interface EventHandlerIF

Parameters:

config - The set of configuration parameters for the stage.

Throws:

java.lang.Exception - The EventHandler can indicate an error to the runtime during initialization by throwing an Exception.

destroy

public void destroy()

Description copied from interface: EventHandlerIF

Called when an event handler is destroyed. This method should perform any cleanup or shutdown operations as required by the application before the event handler is removed from the system.

Specified by:

destroy in interface EventHandlerIF

handleEvent

public void handleEvent(QueueElementIF qel)

The main event handler.

Specified by:

handleEvent in interface EventHandlerIF

handleEvents

public void handleEvents(QueueElementIF[] qelarr)

Description copied from interface: EventHandlerIF

Handle the events corresponding to the given QueueElementIF array. This method is invoked when multiple events are pending for the event handler. The application may reorder, filter, or drop these events if it wishes to do so.

Specified by:

handleEvents in interface EventHandlerIF

toString

public java.lang.String toString()

Overrides:

toString in class java.lang.Object

getSink

SinkIF getSink()

getServerSocket

public AUdpSocket getServerSocket()

Return the server socket being used by this genericServer.