home *** CD-ROM | disk | FTP | other *** search
- package sun.rmi.server;
-
- import sun.rmi.server.Activation.GroupEntry;
-
- class Activation$GroupEntry$RestartThread implements Runnable {
- Process groupProcess;
- long groupIncarnation;
- boolean canInterrupt;
- boolean shouldQuit;
- Thread thread;
- // $FF: synthetic field
- private final Activation.GroupEntry this$1;
-
- Activation$GroupEntry$RestartThread(Activation.GroupEntry var1, Process var2, long var3) {
- this.this$1 = var1;
- this.canInterrupt = true;
- this.shouldQuit = false;
- this.groupProcess = var2;
- this.groupIncarnation = var3;
- }
-
- void setThread(Thread var1) {
- this.thread = var1;
- }
-
- public void run() {
- if (!this.shouldQuit) {
- try {
- this.groupProcess.waitFor();
- if (this.shouldQuit) {
- return;
- }
-
- this.canInterrupt = false;
- Activation.GroupEntry var1 = this.this$1;
- synchronized(var1) {
- if (this.groupIncarnation == this.this$1.incarnation) {
- GroupEntry.access$1800(this.this$1);
- }
- }
- } catch (InterruptedException var4) {
- return;
- }
-
- this.this$1.restartServices();
- }
- }
-
- void dispose() {
- this.shouldQuit = true;
- if (this.canInterrupt) {
- this.thread.interrupt();
- }
-
- }
- }
-