Skip to content

HTTPS clone URL

Subversion checkout URL

You can clone with
or
.
Download ZIP
Browse files

removed promise (not needed anymore)

  • Loading branch information...
commit 8f92cb132f644b4fcf0e6a2a851f0b560149591b 1 parent b19b00e
@belaban authored
Showing with 1 addition and 7 deletions.
  1. +1 −7 tests/other/org/jgroups/tests/LargeState.java
View
8 tests/other/org/jgroups/tests/LargeState.java
@@ -38,7 +38,6 @@
boolean provider=true;
int size=100000;
int total_received=0;
- final Promise state_promise=new Promise();
public void start(boolean provider, int size, String props,boolean jmx) throws Exception {
@@ -62,11 +61,8 @@ public void start(boolean provider, int size, String props,boolean jmx) throws E
else {
System.out.println("Getting state");
start=System.currentTimeMillis();
- state_promise.reset();
rc=channel.getState(null, 0);
System.out.println("getState(), rc=" + rc);
- if(rc)
- state_promise.getResult(10000);
}
if(!provider) {
channel.close();
@@ -107,7 +103,6 @@ public void setState(byte[] state) {
this.state=state;
System.out.println("<-- Received byte[] state, size=" + state.length + " (took " + (stop-start) + "ms)");
}
- state_promise.setResult(Boolean.TRUE);
}
public void setState(InputStream istream) {
@@ -130,8 +125,7 @@ public void setState(InputStream istream) {
}
stop=System.currentTimeMillis();
- System.out.println("<-- Received input stream state, size=" + total_received + " (took " + (stop-start) + "ms)");
- state_promise.setResult(Boolean.TRUE);
+ System.out.println("<-- Received stream state, size=" + total_received + " (took " + (stop-start) + "ms)");
}
finally {
Util.close(istream);
Please sign in to comment.
Something went wrong with that request. Please try again.