Class CompletionWorker

java.lang.Object
  CompletionWorker

All Implemented Interfaces:

EventHandlerIF

public class CompletionWorker
extends java.lang.Object
implements EventHandlerIF

This handler accepts BufferElement and sends an ack of ACK_SIZE to the TCP connection previously established by a TaskRecvWorker.

Field Summary

private byte[]	ack
private static int	ACK_SIZE
private byte[]	ack_tagged
private BufferElement	buf
private BufferElement	buf_tagged
private static boolean	DEBUG
private int	num_received
private ATcpConnection	outgoingConnection

Constructor Summary

CompletionWorker()

Method Summary

void	destroy() Called when an event handler is destroyed.
void	handleEvent(QueueElementIF item) Handle the event corresponding to the given QueueElementIF.
void	handleEvents(QueueElementIF[] items) Handle the events corresponding to the given QueueElementIF array.
void	init(ConfigDataIF config) Called when an event handler is initialized.

Methods inherited from class java.lang.Object

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

Field Detail

DEBUG

private static final boolean DEBUG

See Also:

Constant Field Values

outgoingConnection

private ATcpConnection outgoingConnection

ACK_SIZE

private static final int ACK_SIZE

See Also:

Constant Field Values

num_received

private int num_received

ack

private byte[] ack

ack_tagged

private byte[] ack_tagged

buf

private BufferElement buf

buf_tagged

private BufferElement buf_tagged

Constructor Detail

CompletionWorker

public CompletionWorker()

Method Detail

init

public void init(ConfigDataIF config)

Description copied from interface: EventHandlerIF

Called when an event handler is initialized. This method should perform any initialization operations as required by the application.

Specified by:

init in interface EventHandlerIF

Parameters:

config - The set of configuration parameters for the stage.

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 item)

Description copied from interface: EventHandlerIF

Handle the event corresponding to the given QueueElementIF. This method is invoked by the system when a single event is pending for the event handler.

Specified by:

handleEvent in interface EventHandlerIF

handleEvents

public void handleEvents(QueueElementIF[] items)

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