org.globus.cog.karajan.workflow.service.channels
Class AbstractSocketChannel

java.lang.Object
  org.globus.cog.karajan.workflow.service.channels.AbstractKarajanChannel
      org.globus.cog.karajan.workflow.service.channels.AbstractStreamKarajanChannel
          org.globus.cog.karajan.workflow.service.channels.AbstractSocketChannel

All Implemented Interfaces:

Runnable, KarajanChannel

Direct Known Subclasses:

GSSSocketChannel, PlainSocketChannel

public abstract class AbstractSocketChannel
extends AbstractStreamKarajanChannel
implements Runnable

Field Summary

Fields inherited from class org.globus.cog.karajan.workflow.service.channels.AbstractStreamKarajanChannel

logger

Fields inherited from interface org.globus.cog.karajan.workflow.service.channels.KarajanChannel

ERROR_FLAG, FINAL_FLAG, REPLY_FLAG

Constructor Summary

AbstractSocketChannel(RequestManager requestManager, ChannelContext channelContext, Socket socket, boolean client)

Method Summary

void	close()
protected void	initializeConnection()
boolean	isClient()
boolean	isOffline()
boolean	isStarted()
void	run()
void	start()

Methods inherited from class org.globus.cog.karajan.workflow.service.channels.AbstractStreamKarajanChannel

getEndpoint, getInputStream, getOutputStream, mainLoop, sendTaggedData, setEndpoint, setInputStream, setOutputStream

Methods inherited from class org.globus.cog.karajan.workflow.service.channels.AbstractKarajanChannel

decLongTermUsageCount, decUsageCount, getChannelContext, getLongTermUsageCount, getRequestManager, incLongTermUsageCount, incUsageCount, isClosed, isLocalShutdown, ppByteBuf, readFromStream, readFromStream, registerCommand, registerHandler, sendTaggedData, sendTaggedReply, sendTaggedReply, setChannelContext, setLocalShutdown, shutdown, unregisterCommand, unregisterHandler

Methods inherited from class java.lang.Object

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

Methods inherited from interface org.globus.cog.karajan.workflow.service.channels.KarajanChannel

getUserContext

Constructor Detail

AbstractSocketChannel

public AbstractSocketChannel(RequestManager requestManager,
                             ChannelContext channelContext,
                             Socket socket,
                             boolean client)

Method Detail

start

public void start()
           throws Exception

Throws:

Exception

run

public void run()

Specified by:

run in interface Runnable

initializeConnection

protected void initializeConnection()

close

public void close()

Specified by:

close in interface KarajanChannel

Overrides:

close in class AbstractKarajanChannel

isClient

public boolean isClient()

Specified by:

isClient in interface KarajanChannel

Overrides:

isClient in class AbstractKarajanChannel

isStarted

public boolean isStarted()

isOffline

public boolean isOffline()

Specified by:

isOffline in interface KarajanChannel