ostore.dispatch
Class Test.Sink

java.lang.Object
  |
  +--seda.sandStorm.core.SimpleSink
        |
        +--ostore.dispatch.Test.Sink

All Implemented Interfaces:

ProfilableIF, SinkIF

Direct Known Subclasses:

Test.DeadSink

Enclosing class:

Test

public static class Test.Sink

extends SimpleSink

Field Summary

protected int

tag

Constructor Summary

Test.Sink(int tag)

Method Summary

void	enqueue_commit(Object key)
boolean	enqueue_lossy(QueueElementIF element)
Object	enqueue_prepare(QueueElementIF[] elements)
void	enqueue(QueueElementIF element)

Methods inherited from class seda.sandStorm.core.SimpleSink

enqueue_abort, enqueue_many, getEnqueuePredicate, profileSize, setEnqueuePredicate, size

Methods inherited from class java.lang.Object

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

Field Detail

tag

protected int tag

Constructor Detail

Test.Sink

public Test.Sink(int tag)

Method Detail

enqueue_prepare

public Object enqueue_prepare(QueueElementIF[] elements)
                       throws SinkFullException

Specified by:

enqueue_prepare in interface SinkIF

Overrides:

enqueue_prepare in class SimpleSink

SinkFullException

enqueue_commit

public void enqueue_commit(Object key)

Specified by:

enqueue_commit in interface SinkIF

Overrides:

enqueue_commit in class SimpleSink

enqueue

public void enqueue(QueueElementIF element)

Specified by:

enqueue in interface SinkIF

Specified by:

enqueue in class SimpleSink

enqueue_lossy

public boolean enqueue_lossy(QueueElementIF element)

Specified by:

enqueue_lossy in interface SinkIF

Overrides:

enqueue_lossy in class SimpleSink