costin 02/04/17 15:32:45
Modified: jk/java/org/apache/jk/core MsgContext.java
Log:
Few changes to MsgContext to allow it to be used in a more
flexible way.
Most of the methods can become generic 'notes' ( but we need
to support 'long' notes, I wouldn't like to convert to Long ).
MsgContext now has a 'type' ( from o.a.t.u.handler ) - that'll
eventually replace the Action and be commont to all coyote components.
We also store the 'source' - the handler that originally
initiated the callback ( to be used to send messages to the other
side ) and 'next' - the next handler in the chain.
All the changes are cleanups for jni and getting the code
closer to the target.
Revision Changes Path
1.3 +86 -5
jakarta-tomcat-connectors/jk/java/org/apache/jk/core/MsgContext.java
Index: MsgContext.java
===================================================================
RCS file:
/home/cvs/jakarta-tomcat-connectors/jk/java/org/apache/jk/core/MsgContext.java,v
retrieving revision 1.2
retrieving revision 1.3
diff -u -r1.2 -r1.3
--- MsgContext.java 3 Apr 2002 23:56:08 -0000 1.2
+++ MsgContext.java 17 Apr 2002 22:32:45 -0000 1.3
@@ -81,11 +81,18 @@
* @author Costin Manolache
*/
public class MsgContext {
+ private int type;
private Object notes[]=new Object[32];
- private Channel ch;
+ private JkHandler next;
+ private JkHandler source;
private Object req;
private WorkerEnv wEnv;
+ private Msg msgs[]=new Msg[10];
+ // The context can be used by JNI components as well
+ private long jkEndpointP;
+ private long xEnvP;
+
public final Object getNote( int id ) {
return notes[id];
}
@@ -94,6 +101,14 @@
notes[id]=o;
}
+ /** The id of the chain */
+ public final int getType() {
+ return type;
+ }
+
+ public final void setType(int i) {
+ type=i;
+ }
// Common attributes ( XXX should be notes for flexibility ? )
@@ -105,12 +120,20 @@
this.wEnv=we;
}
- public final Channel getChannel() {
- return ch;
+ public final JkHandler getSource() {
+ return source;
+ }
+
+ public final void setSource(JkHandler ch) {
+ this.source=ch;
+ }
+
+ public final JkHandler getNext() {
+ return next;
}
- public final void setChannel(Channel ch) {
- this.ch=ch;
+ public final void setNext(JkHandler ch) {
+ this.next=ch;
}
/** The high level request object associated with this context
@@ -122,5 +145,63 @@
public final Object getRequest() {
return req;
}
+
+ /** The context may store a number of messages ( buffers + marshalling )
+ */
+ public final Msg getMsg(int i) {
+ return msgs[i];
+ }
+
+ public final void setMsg(int i, Msg msg) {
+ this.msgs[i]=msg;
+ }
+ /** Each context contains a number of byte[] buffers used for communication.
+ * The C side will contain a char * equivalent - both buffers are long-lived
+ * and recycled.
+ *
+ * This will be called at init time. A long-lived global reference to the
byte[]
+ * will be stored in the C context.
+ */
+ public byte[] getBuffer( int id ) {
+ // We use a single buffer right now.
+ if( msgs[id]==null ) {
+ return null;
+ }
+ return msgs[id].getBuffer();
+ }
+
+ /** Invoke a java hook. The xEnv is the representation of the current execution
+ * environment ( the jni_env_t * )
+ */
+ public int execute() throws IOException {
+ int status=next.invoke(msgs[0], this);
+ return status;
+ }
+
+ // -------------------- Jni support --------------------
+
+ /** Store native execution context data when this handler is called
+ * from JNI. This will change on each call, represent temproary
+ * call data.
+ */
+ public void setJniEnv( long xEnvP ) {
+ this.xEnvP=xEnvP;
+ }
+
+ public long getJniEnv() {
+ return xEnvP;
+ }
+
+ /** The long-lived JNI context associated with this java context.
+ * The 2 share pointers to buffers and cache data to avoid expensive
+ * jni calls.
+ */
+ public void setJniContext( long cContext ) {
+ this.jkEndpointP=cContext;
+ }
+
+ public long getJniContext() {
+ return jkEndpointP;
+ }
}
--
To unsubscribe, e-mail: <mailto:[EMAIL PROTECTED]>
For additional commands, e-mail: <mailto:[EMAIL PROTECTED]>
