You are viewing a plain text version of this content. The canonical link for it is here.
Posted to dev@commons.apache.org by ha...@apache.org on 2002/01/18 10:58:13 UTC
cvs commit: jakarta-commons-sandbox/altrmi/src/java/org/apache/commons/altrmi/server/impl ServerCustomStreamReadWriter.java
hammant 02/01/18 01:58:13
Modified: altrmi PROPOSAL
altrmi/src/java/org/apache/commons/altrmi/client/impl
ClientCustomStreamReadWriter.java
altrmi/src/java/org/apache/commons/altrmi/server/impl
ServerCustomStreamReadWriter.java
Log:
speed improvements using buffer
Revision Changes Path
1.5 +4 -2 jakarta-commons-sandbox/altrmi/PROPOSAL
Index: PROPOSAL
===================================================================
RCS file: /home/cvs/jakarta-commons-sandbox/altrmi/PROPOSAL,v
retrieving revision 1.4
retrieving revision 1.5
diff -u -r1.4 -r1.5
--- PROPOSAL 18 Jan 2002 01:08:59 -0000 1.4
+++ PROPOSAL 18 Jan 2002 09:58:13 -0000 1.5
@@ -41,8 +41,8 @@
*AltRMI types*
a) ObjectStream over sockets #2 1472 1.00
- b) CustomStream over sockets 3198 2.17
c) Over RMI 3338 2.30
+ b) CustomStream over sockets 4717 3.20
d) ObjectStream over Pipe #2 8243 5.59
e) ObjectStream over sockets #1 8865 6.02
f) ObjectStream over Pipe #1 64789 44.01
@@ -127,7 +127,7 @@
- For Facades, if you call Person p = getPerson("Fred") twice you will get
the same instance on the client side is it is the same instance on the
- server side.
+ server side.
Limitations:
@@ -156,6 +156,8 @@
3) Client and Server code for secure conversations.
+
+4) Keep alive / ping concept.
Initial committers:
1.4 +3 -2 jakarta-commons-sandbox/altrmi/src/java/org/apache/commons/altrmi/client/impl/ClientCustomStreamReadWriter.java
Index: ClientCustomStreamReadWriter.java
===================================================================
RCS file: /home/cvs/jakarta-commons-sandbox/altrmi/src/java/org/apache/commons/altrmi/client/impl/ClientCustomStreamReadWriter.java,v
retrieving revision 1.3
retrieving revision 1.4
diff -u -r1.3 -r1.4
--- ClientCustomStreamReadWriter.java 17 Jan 2002 17:48:45 -0000 1.3
+++ ClientCustomStreamReadWriter.java 18 Jan 2002 09:58:13 -0000 1.4
@@ -22,6 +22,7 @@
import java.io.DataInputStream;
import java.io.DataOutputStream;
import java.io.IOException;
+import java.io.BufferedOutputStream;
/**
@@ -29,7 +30,7 @@
*
*
* @author Paul Hammant <a href="mailto:Paul_Hammant@yahoo.com">Paul_Hammant@yahoo.com</a>
- * @version $Revision: 1.3 $
+ * @version $Revision: 1.4 $
*/
public class ClientCustomStreamReadWriter extends ClientStreamReadWriter {
@@ -48,7 +49,7 @@
*/
public ClientCustomStreamReadWriter(InputStream inputStream, OutputStream outputStream)
throws IOException {
- mDataOutputStream = new DataOutputStream(outputStream);
+ mDataOutputStream = new DataOutputStream(new BufferedOutputStream(outputStream));
mDataInputStream = new DataInputStream(inputStream);
}
1.4 +3 -2 jakarta-commons-sandbox/altrmi/src/java/org/apache/commons/altrmi/server/impl/ServerCustomStreamReadWriter.java
Index: ServerCustomStreamReadWriter.java
===================================================================
RCS file: /home/cvs/jakarta-commons-sandbox/altrmi/src/java/org/apache/commons/altrmi/server/impl/ServerCustomStreamReadWriter.java,v
retrieving revision 1.3
retrieving revision 1.4
diff -u -r1.3 -r1.4
--- ServerCustomStreamReadWriter.java 17 Jan 2002 17:48:46 -0000 1.3
+++ ServerCustomStreamReadWriter.java 18 Jan 2002 09:58:13 -0000 1.4
@@ -22,6 +22,7 @@
import java.io.DataInputStream;
import java.io.DataOutputStream;
import java.io.IOException;
+import java.io.BufferedOutputStream;
/**
@@ -29,7 +30,7 @@
*
*
* @author Paul Hammant <a href="mailto:Paul_Hammant@yahoo.com">Paul_Hammant@yahoo.com</a>
- * @version $Revision: 1.3 $
+ * @version $Revision: 1.4 $
*/
public class ServerCustomStreamReadWriter extends ServerStreamReadWriter {
@@ -38,7 +39,7 @@
protected void initialize() throws IOException {
mDataInputStream = new DataInputStream(mInputStream);
- mDataOutputStream = new DataOutputStream(mOutputStream);
+ mDataOutputStream = new DataOutputStream(new BufferedOutputStream(mOutputStream));
}
protected synchronized AltrmiRequest writeReplyAndGetRequest(AltrmiReply altrmiReply)
--
To unsubscribe, e-mail: <ma...@jakarta.apache.org>
For additional commands, e-mail: <ma...@jakarta.apache.org>