MDS/openide
1
0
Fork 0
mirror of https://gitflic.ru/project/openide/openide.git synced 2026-09-27 10:03:11 +07:00
Code Issues Packages Projects Releases Wiki Activity

PING_TIMEOUT

Browse Source
This commit is contained in:
Gregory.Shrago
2016-04-27 03:09:04 +03:00
parent 563b5b1e59
commit 6d7d268c32
2 changed files with 8 additions and 7 deletions
Download Patch File Download Diff File Expand all files Collapse all files
platform/util-rt/src/com/intellij/execution/rmi/RemoteDeadHand.java
+7 -6
View File
@@ -20,6 +20,7 @@ import java.rmi.RemoteException;
import java.rmi.registry.LocateRegistry;
import java.rmi.registry.Registry;
import java.rmi.server.UnicastRemoteObject;
import java.util.concurrent.atomic.AtomicLong;
/**
* @author gregsh
@@ -27,6 +28,7 @@ import java.rmi.server.UnicastRemoteObject;
public interface RemoteDeadHand extends Remote {
String BINDING_NAME = "_DEAD_HAND_";
long PING_TIMEOUT = 20 * 1000L;
/**
* @return time in milliseconds to wait till the next ping.
@@ -38,7 +40,7 @@ public interface RemoteDeadHand extends Remote {
private static final TwoMinutesTurkish ourCook = new TwoMinutesTurkish();
private static final Remote ourHand;
private static long ourAskedThatManyTimes;
private static final AtomicLong ourAskedThatManyTimes = new AtomicLong();
static {
Remote remote;
@@ -52,14 +54,13 @@ public interface RemoteDeadHand extends Remote {
}
public long ping(String id) throws RemoteException {
//noinspection AssignmentToStaticFieldFromInstanceMethod
ourAskedThatManyTimes ++;
return 2 * 60 * 1000L;
ourAskedThatManyTimes.incrementAndGet();
return PING_TIMEOUT;
}
public static void startCooking(String host, int port) throws Exception {
final Registry registry = LocateRegistry.getRegistry(host, port);
registry.bind(RemoteDeadHand.BINDING_NAME, ourHand);
Registry registry = LocateRegistry.getRegistry(host, port);
registry.bind(BINDING_NAME, ourHand);
}
}
}
platform/util-rt/src/com/intellij/execution/rmi/RemoteServer.java
+1 -1
View File
@@ -77,7 +77,7 @@ public class RemoteServer {
String id = port + "/" + name;
System.out.println("Port/ID: " + id);
long waitTime = 2 * 60 * 1000L;
long waitTime = RemoteDeadHand.PING_TIMEOUT;
Object lock = new Object();
//noinspection InfiniteLoopStatement
while (true) {