org.apache.jk.common

Class ChannelUn

Implemented Interfaces:
JkChannel, MBeanRegistration, NotificationListener

public class ChannelUn
extends JniHandler
implements JkChannel

Pass messages using unix domain sockets.

Author:
Costin Manolache

Field Summary

Fields inherited from class org.apache.jk.common.JniHandler

C2B_NOTE, JK_HANDLE_JNI_DISPATCH, JK_HANDLE_SHM_DISPATCH, MB_NOTE, MSG_NOTE, apr, jkHome, nativeJkHandlerP

Fields inherited from class org.apache.jk.core.JkHandler

ERROR, HANDLE_FLUSH, HANDLE_RECEIVE_PACKET, HANDLE_SEND_PACKET, HANDLE_THREAD_END, LAST, OK, domain, id, mserver, name, next, nextName, oname, properties, wEnv

Method Summary

void
close(MsgContext ep)
void
destroy()
Clean up and stop the handler
int
flush(Msg msg, MsgContext ep)
String
getChannelName()
String
getFile()
ThreadPool
getThreadPool()
void
init()
You must call initNative() inside the component init()
int
invoke(Msg msg, MsgContext ep)
Base implementation for invoke.
boolean
isSameAddress(MsgContext ep)
int
open(MsgContext ep)
Open a connection - since we're listening that will block in accept
int
receive(Msg msg, MsgContext ep)
void
registerRequest(Request req, MsgContext ep, int count)
int
send(Msg msg, MsgContext ep)
void
setFile(String f)
void
start()

Methods inherited from class org.apache.jk.common.JniHandler

appendString, createMsgContext, destroyJkComponent, getJkHome, init, initJkComponent, initNative, invoke, nativeDispatch, pause, recycleNative, resume, setJkHome, setNativeAttribute, setNativeEndpoint

Methods inherited from class org.apache.jk.core.JkHandler

addHandlerCallback, createMsgContext, destroy, getDomain, getId, getName, getNext, getObjectName, getProperty, handleNotification, init, invoke, pause, postDeregister, postRegister, preDeregister, preRegister, resume, setId, setName, setNext, setNext, setProperty, setWorkerEnv

Method Details

close

public void close(MsgContext ep)
            throws IOException


destroy

public void destroy()
            throws IOException
Clean up and stop the handler
Overrides:
destroy in interface JkHandler


flush

public int flush(Msg msg,
                 MsgContext ep)
            throws IOException
Specified by:
flush in interface JkChannel


getChannelName

public String getChannelName()
Specified by:
getChannelName in interface JkChannel


getFile

public String getFile()


getThreadPool

public ThreadPool getThreadPool()


init

public void init()
            throws IOException
You must call initNative() inside the component init()
Overrides:
init in interface JniHandler


invoke

public int invoke(Msg msg,
                  MsgContext ep)
            throws IOException
Base implementation for invoke. Dispatch the action to the native code, where invoke() is called on the wrapped jk_bean.
Specified by:
invoke in interface JkChannel
Overrides:
invoke in interface JniHandler


isSameAddress

public boolean isSameAddress(MsgContext ep)
Specified by:
isSameAddress in interface JkChannel


open

public int open(MsgContext ep)
            throws IOException
Open a connection - since we're listening that will block in accept


receive

public int receive(Msg msg,
                   MsgContext ep)
            throws IOException
Specified by:
receive in interface JkChannel


registerRequest

public void registerRequest(Request req,
                            MsgContext ep,
                            int count)
Specified by:
registerRequest in interface JkChannel


send

public int send(Msg msg,
                MsgContext ep)
            throws IOException
Specified by:
send in interface JkChannel


setFile

public void setFile(String f)


start

public void start()
            throws IOException


Copyright B) 2000-2003 Apache Software Foundation. All Rights Reserved.