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

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
              org.globus.cog.karajan.workflow.service.channels.GSSSocketChannel

All Implemented Interfaces:

Runnable, KarajanChannel

public class GSSSocketChannel
extends AbstractSocketChannel
implements Runnable

Field Summary

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

ERROR_FLAG, FINAL_FLAG, REPLY_FLAG

Constructor Summary

GSSSocketChannel(GssSocket socket, RequestManager requestManager, ChannelContext sc, boolean client)

GSSSocketChannel(GssSocket socket, RequestManager requestManager, ChannelContext sc, boolean client, String endpoint)

Method Summary

String	getPeerId()
UserContext	getUserContext()
protected void	initializeConnection()
void	sendTaggedReply(int tag, byte[] data, boolean fin, boolean err)
void	shutdown()
String	toString()

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

close, isClient, isOffline, isStarted, run, 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, setChannelContext, setLocalShutdown, unregisterCommand, unregisterHandler

Methods inherited from class java.lang.Object

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

Methods inherited from interface java.lang.Runnable

run

Constructor Detail

GSSSocketChannel

public GSSSocketChannel(GssSocket socket,
                        RequestManager requestManager,
                        ChannelContext sc,
                        boolean client)

GSSSocketChannel

public GSSSocketChannel(GssSocket socket,
                        RequestManager requestManager,
                        ChannelContext sc,
                        boolean client,
                        String endpoint)

Method Detail

sendTaggedReply

public void sendTaggedReply(int tag,
                            byte[] data,
                            boolean fin,
                            boolean err)

Specified by:

sendTaggedReply in interface KarajanChannel

Overrides:

sendTaggedReply in class AbstractKarajanChannel

initializeConnection

protected void initializeConnection()

Overrides:

initializeConnection in class AbstractSocketChannel

shutdown

public void shutdown()

Specified by:

shutdown in interface KarajanChannel

Overrides:

shutdown in class AbstractKarajanChannel

getPeerId

public String getPeerId()

getUserContext

public UserContext getUserContext()

Specified by:

getUserContext in interface KarajanChannel

toString

public String toString()

Overrides:

toString in class Object