java/test/Ice/background/BackgroundControllerI.java

   1 // **********************************************************************
   2 //
   3 // Copyright (c) 2003-2011 ZeroC, Inc. All rights reserved.
   4 //
   5 // This copy of Ice is licensed to you under the terms described in the
   6 // ICE_LICENSE file included in this distribution.
   7 //
   8 // **********************************************************************
   9 package test.Ice.background;
  10
  11 import test.Ice.background.Test._BackgroundControllerDisp;
  12
  13 class BackgroundControllerI extends _BackgroundControllerDisp
  14 {
  15     synchronized public void
  16     pauseCall(String opName, Ice.Current current)
  17     {
  18         _pausedCalls.add(opName);
  19     }
  20
  21     synchronized public void
  22     resumeCall(String opName, Ice.Current current)
  23     {
  24         _pausedCalls.remove(opName);
  25         notifyAll();
  26     }
  27
  28     synchronized public void
  29     checkCallPause(Ice.Current current)
  30     {
  31         while(_pausedCalls.contains(current.operation))
  32         {
  33             try
  34             {
  35                 wait();
  36                 break;
  37             }
  38             catch(java.lang.InterruptedException ex)
  39             {
  40             }
  41         }
  42     }
  43
  44     public void
  45     holdAdapter(Ice.Current current)
  46     {
  47         _adapter.hold();
  48     }
  49
  50     public void
  51     resumeAdapter(Ice.Current current)
  52     {
  53         _adapter.activate();
  54     }
  55
  56     public void
  57     initializeSocketStatus(int status, Ice.Current current)
  58     {
  59         _configuration.initializeSocketStatus(status);
  60     }
  61
  62     public void
  63     initializeException(boolean enable, Ice.Current current)
  64     {
  65         _configuration.initializeException(enable ? new Ice.SocketException() : null);
  66     }
  67
  68     public void
  69     readReady(boolean enable, Ice.Current current)
  70     {
  71         _configuration.readReady(enable);
  72     }
  73
  74     public void
  75     readException(boolean enable, Ice.Current current)
  76     {
  77         _configuration.readException(enable ? new Ice.SocketException() : null);
  78     }
  79
  80     public void
  81     writeReady(boolean enable, Ice.Current current)
  82     {
  83         _configuration.writeReady(enable);
  84     }
  85
  86     public void
  87     writeException(boolean enable, Ice.Current current)
  88     {
  89         _configuration.writeException(enable ? new Ice.SocketException() : null);
  90     }
  91
  92     public
  93     BackgroundControllerI(Configuration configuration, Ice.ObjectAdapter adapter)
  94     {
  95         _adapter = adapter;
  96         _configuration = configuration;
  97     }
  98
  99     final private Ice.ObjectAdapter _adapter;
 100     final private java.util.Set<String> _pausedCalls = new java.util.HashSet<String>();
 101     final private Configuration _configuration;
 102 }