You are viewing a plain text version of this content. The canonical link for it is here.
Posted to dev@tomcat.apache.org by co...@apache.org on 2002/01/26 08:21:02 UTC
cvs commit: jakarta-tomcat-connectors/jk/java/org/apache/jk/core Channel.java
costin 02/01/25 23:21:02
Modified: jk/java/org/apache/jk/core Channel.java
Log:
Abstract class, after merging with JkChannel.
Revision Changes Path
1.3 +33 -16 jakarta-tomcat-connectors/jk/java/org/apache/jk/core/Channel.java
Index: Channel.java
===================================================================
RCS file: /home/cvs/jakarta-tomcat-connectors/jk/java/org/apache/jk/core/Channel.java,v
retrieving revision 1.2
retrieving revision 1.3
diff -u -r1.2 -r1.3
--- Channel.java 16 Jan 2002 15:38:29 -0000 1.2
+++ Channel.java 26 Jan 2002 07:21:02 -0000 1.3
@@ -63,7 +63,7 @@
import java.io.InputStream;
import java.io.OutputStream;
import java.net.Socket;
-import java.util.Enumeration;
+import java.util.*;
import java.security.*;
import org.apache.tomcat.util.http.MimeHeaders;
@@ -81,23 +81,40 @@
* @author Kevin Seguin
* @author Costin Manolache
*/
-public interface Channel {
-
- public void setWorkerEnv( WorkerEnv we );
-
- public void init() throws IOException;
+public abstract class Channel {
+ protected WorkerEnv we;
+ protected Worker worker;
+
+ public void setWorkerEnv( WorkerEnv we ) {
+ this.we=we;
+ }
- public void write( Endpoint ep, byte[] b, int offset, int len)
- throws IOException;
-
- public int read( Endpoint ep, byte[] b, int offset, int len)
- throws IOException;
+ public void setWorker(Worker worker) {
+ this.worker=worker;
+ }
+
+ public void init() throws IOException {
+ }
+
+ /** This method is used to receive messages. It shouldn't
+ * be exposed, as most processing is driven by sending
+ * messages and dispatching on incoming messages. The
+ * only current use is the aberant post packet after
+ * the first request, which doesn't fit anything.
+ */
+ public abstract int receive( Msg msg, Endpoint ep )
+ throws IOException;
+
+ /**
+ * Send a packet to the web server. Works for any type of message.
+ *
+ * @param msg A packet with accumulated data to send to the server --
+ * this method will write out the length in the header.
+ */
+ public abstract int send( Msg msg, Endpoint ep )
+ throws IOException;
- public void setJkHome(String home);
- public void setWorker(Worker wo);
-
- public void setFile(String file);
+
- public void setPort(int port);
}
--
To unsubscribe, e-mail: <ma...@jakarta.apache.org>
For additional commands, e-mail: <ma...@jakarta.apache.org>