cs/test/Ice/ami/TestI.cs

   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
  10 using Test;
  11 using System.Threading;
  12
  13 public class TestI : TestIntfDisp_
  14 {
  15     public TestI()
  16     {
  17     }
  18
  19     override public void
  20     op(Ice.Current current)
  21     {
  22     }
  23
  24     override public int
  25     opWithResult(Ice.Current current)
  26     {
  27         return 15;
  28     }
  29
  30     override public void
  31     opWithUE(Ice.Current current)
  32     {
  33         throw new TestIntfException();
  34     }
  35
  36     override public void
  37     opWithPayload(byte[] seq, Ice.Current current)
  38     {
  39     }
  40
  41     override public void
  42     opBatch(Ice.Current current)
  43     {
  44         _m.Lock();
  45         try
  46         {
  47             ++_batchCount;
  48             _m.Notify();
  49         }
  50         finally
  51         {
  52             _m.Unlock();
  53         }
  54     }
  55
  56     override public int
  57     opBatchCount(Ice.Current current)
  58     {
  59         _m.Lock();
  60         try
  61         {
  62             return _batchCount;
  63         }
  64         finally
  65         {
  66             _m.Unlock();
  67         }
  68     }
  69
  70     override public bool
  71     waitForBatch(int count, Ice.Current current)
  72     {
  73         _m.Lock();
  74         try
  75         {
  76             while(_batchCount < count)
  77             {
  78                 _m.TimedWait(5000);
  79             }
  80             bool result = count == _batchCount;
  81             _batchCount = 0;
  82             return result;
  83         }
  84         finally
  85         {
  86             _m.Unlock();
  87         }
  88     }
  89
  90     override public void
  91     shutdown(Ice.Current current)
  92     {
  93         current.adapter.getCommunicator().shutdown();
  94     }
  95
  96     private int _batchCount;
  97     private readonly IceUtilInternal.Monitor _m = new IceUtilInternal.Monitor();
  98 }
  99
 100 public class TestControllerI : TestIntfControllerDisp_
 101 {
 102     override public void
 103     holdAdapter(Ice.Current current)
 104     {
 105         _adapter.hold();
 106     }
 107
 108     override public void
 109     resumeAdapter(Ice.Current current)
 110     {
 111         _adapter.activate();
 112     }
 113
 114     public
 115     TestControllerI(Ice.ObjectAdapter adapter)
 116     {
 117         _adapter = adapter;
 118     }
 119
 120     private Ice.ObjectAdapter _adapter;
 121 }