hammant 2003/08/19 14:42:41
Modified: src/example/org/apache/altrmi/examples/blockpublishing
AltrmiHelloWorldServerTester.java
src/java/org/apache/altrmi/client/impl
AbstractConnectionPinger.java
Log:
connection pinger testcase works again. standalone (to be deleted?) tester
compiles again
Revision Changes Path
1.2 +2 -3
incubator-altrmi/src/example/org/apache/altrmi/examples/blockpublishing/AltrmiHelloWorldServerTester.java
Index: AltrmiHelloWorldServerTester.java
===================================================================
RCS file:
/home/cvs/incubator-altrmi/src/example/org/apache/altrmi/examples/blockpublishing/AltrmiHelloWorldServerTester.java,v
retrieving revision 1.1
retrieving revision 1.2
diff -u -r1.1 -r1.2
--- AltrmiHelloWorldServerTester.java 26 Apr 2003 13:05:25 -0000 1.1
+++ AltrmiHelloWorldServerTester.java 19 Aug 2003 21:42:41 -0000 1.2
@@ -79,9 +79,8 @@
}
private String setGreeting(String newGreeting) throws
ConnectionException {
- HostContext arhc = new SocketObjectStreamHostContext( "127.0.0.1",
8666 );
- ServerSideClassFactory af = new ServerSideClassFactory();
- af.setHostContext( arhc );
+ HostContext arhc = new
SocketObjectStreamHostContext.WithSimpleDefaults( "127.0.0.1", 8666 );
+ ServerSideClassFactory af = new ServerSideClassFactory(arhc, false);
final HelloWorldServer hws =
(HelloWorldServer)af.lookup( "helloworld" );
String greeting1 = hws.getGreeting();
1.5 +6 -4
incubator-altrmi/src/java/org/apache/altrmi/client/impl/AbstractConnectionPinger.java
Index: AbstractConnectionPinger.java
===================================================================
RCS file:
/home/cvs/incubator-altrmi/src/java/org/apache/altrmi/client/impl/AbstractConnectionPinger.java,v
retrieving revision 1.4
retrieving revision 1.5
diff -u -r1.4 -r1.5
--- AbstractConnectionPinger.java 15 Jul 2003 07:08:38 -0000 1.4
+++ AbstractConnectionPinger.java 19 Aug 2003 21:42:41 -0000 1.5
@@ -55,11 +55,10 @@
package org.apache.altrmi.client.impl;
import org.apache.altrmi.client.ClientInvocationHandler;
-import org.apache.altrmi.client.ConnectionPinger;
import org.apache.altrmi.client.ConnectionClosedException;
+import org.apache.altrmi.client.ConnectionPinger;
import org.apache.altrmi.client.InvocationException;
import org.apache.altrmi.common.ThreadContext;
-import org.apache.altrmi.common.ThreadPool;
/**
* Interface AbstractConnectionPinger
@@ -155,7 +154,10 @@
while( m_continue )
{
Thread.sleep( m_pingInterval );
- ping();
+ if (m_continue)
+ {
+ ping();
+ }
}
}
catch( InvocationException ie )
---------------------------------------------------------------------
To unsubscribe, e-mail: [EMAIL PROTECTED]
For additional commands, e-mail: [EMAIL PROTECTED]
