com.grey.naf.reactor

Class Dispatcher

java.lang.Object

com.grey.naf.reactor.Dispatcher

All Implemented Interfaces:

EntityReaper, Producer.Consumer<Object>, TimerNAF.TimeProvider, Runnable

public class Dispatcher
extends Object
implements Runnable, TimerNAF.TimeProvider, EntityReaper, Producer.Consumer<Object>

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
static class	Dispatcher.STOPSTATUS

Field Summary

Fields

Modifier and Type	Field and Description
String	name
long	timeboot

Method Summary

Modifier and Type	Method and Description
byte[]	allocMemBuffer(int cap)
ByteBuffer	allocNIOBuffer(int cap)
void	cancelReaper(EntityReaper reaper)
boolean	completedOK()
static Dispatcher	create(ApplicationContextNAF appctx, DispatcherDef def, Logger log)
static Dispatcher	createConfigured(ApplicationContextNAF appctx, String dname, Logger log)
static String	dumpConfig(ApplicationContextNAF appctx)
CharSequence	dumpState(StringBuilder sb, boolean verbose)
void	entityStopped(Object entity)
NafManAgent	getAgent()
ApplicationContextNAF	getApplicationContext()
Flusher	getFlusher()
Logger	getLogger()
ResolverDNS	getResolverDNS()
long	getSystemTime()
boolean	inThread()
boolean	isActive()
boolean	isRunning()
boolean	killConnection(int id, long stime, String diag)
static List<Dispatcher>	launchConfigured(ApplicationContextNAF appctx, Logger log)
Naflet[]	listNaflets()
void	loadNaflet(Naflet app)
void	producerIndication(Producer<Object> p)
void	registerReaper(EntityReaper reaper)
void	run()
TimerNAF	setTimer(long interval, int type, TimerNAF.Handler handler)
TimerNAF	setTimer(long interval, int type, TimerNAF.Handler handler, Object attachment)
Thread	start()
boolean	stop()
String	toString()
int	transfer(ByteBuffer src, ByteBuffer dst)
void	unloadNaflet(String naflet_name)
void	waitStopped()
Dispatcher.STOPSTATUS	waitStopped(long timeout, boolean force)

Methods inherited from class java.lang.Object

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

Field Detail

timeboot

public final long timeboot

name

public final String name

Method Detail

inThread

public boolean inThread()

isRunning

public boolean isRunning()

isActive

public boolean isActive()

waitStopped

public void waitStopped()

getApplicationContext

public ApplicationContextNAF getApplicationContext()

getAgent

public NafManAgent getAgent()

getResolverDNS

public ResolverDNS getResolverDNS()

getFlusher

public Flusher getFlusher()

getLogger

public Logger getLogger()

completedOK

public boolean completedOK()

start

public Thread start()

run

public void run()

Specified by:

run in interface Runnable

stop

public boolean stop()

waitStopped

public Dispatcher.STOPSTATUS waitStopped(long timeout,
                                         boolean force)

getSystemTime

public long getSystemTime()

Specified by:

getSystemTime in interface TimerNAF.TimeProvider

setTimer

public TimerNAF setTimer(long interval,
                         int type,
                         TimerNAF.Handler handler)

setTimer

public TimerNAF setTimer(long interval,
                         int type,
                         TimerNAF.Handler handler,
                         Object attachment)

producerIndication

public void producerIndication(Producer<Object> p)
                        throws IOException

Specified by:

producerIndication in interface Producer.Consumer<Object>

Throws:

IOException

loadNaflet

public void loadNaflet(Naflet app)
                throws IOException

Throws:

IOException

unloadNaflet

public void unloadNaflet(String naflet_name)
                  throws IOException

Throws:

IOException

entityStopped

public void entityStopped(Object entity)

Specified by:

entityStopped in interface EntityReaper

registerReaper

public void registerReaper(EntityReaper reaper)

cancelReaper

public void cancelReaper(EntityReaper reaper)

dumpState

public CharSequence dumpState(StringBuilder sb,
                              boolean verbose)

killConnection

public boolean killConnection(int id,
                              long stime,
                              String diag)
                       throws IOException

Throws:

IOException

listNaflets

public Naflet[] listNaflets()

transfer

public int transfer(ByteBuffer src,
                    ByteBuffer dst)

allocNIOBuffer

public ByteBuffer allocNIOBuffer(int cap)

allocMemBuffer

public byte[] allocMemBuffer(int cap)

toString

public String toString()

Overrides:

toString in class Object

create

public static Dispatcher create(ApplicationContextNAF appctx,
                                DispatcherDef def,
                                Logger log)
                         throws IOException

Throws:

IOException

launchConfigured

public static List<Dispatcher> launchConfigured(ApplicationContextNAF appctx,
                                                Logger log)
                                         throws IOException

Throws:

IOException

createConfigured

public static Dispatcher createConfigured(ApplicationContextNAF appctx,
                                          String dname,
                                          Logger log)
                                   throws IOException

Throws:

IOException

dumpConfig

public static String dumpConfig(ApplicationContextNAF appctx)