java/test/Ice/servantLocator/ServantLocatorI.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
  10 package test.Ice.servantLocator;
  11
  12 import test.Ice.servantLocator.Test.Cookie;
  13 import test.Ice.servantLocator.Test.TestImpossibleException;
  14 import test.Ice.servantLocator.Test.TestIntfUserException;
  15 import Ice.ObjectNotExistException;
  16 import Ice.SocketException;
  17 import Ice.UnknownException;
  18 import Ice.UnknownLocalException;
  19 import Ice.UnknownUserException;
  20
  21 public final class ServantLocatorI implements Ice.ServantLocator
  22 {
  23     public
  24     ServantLocatorI(String category)
  25     {
  26         _category = category;
  27         _deactivated = false;
  28         _requestId = -1;
  29     }
  30
  31     protected synchronized void
  32     finalize()
  33         throws Throwable
  34     {
  35         test(_deactivated);
  36     }
  37
  38     private static void
  39     test(boolean b)
  40     {
  41         if(!b)
  42         {
  43             throw new RuntimeException();
  44         }
  45     }
  46
  47     public Ice.Object
  48     locate(Ice.Current current, Ice.LocalObjectHolder cookie) throws Ice.UserException
  49     {
  50         synchronized(this)
  51         {
  52             test(!_deactivated);
  53         }
  54
  55         test(current.id.category.equals(_category) || _category.length() == 0);
  56
  57         if(current.id.name.equals("unknown"))
  58         {
  59             return null;
  60         }
  61
  62         test(current.id.name.equals("locate") || current.id.name.equals("finished"));
  63         if(current.id.name.equals("locate"))
  64         {
  65             exception(current);
  66         }
  67
  68         //
  69         // Ensure locate() is only called once per request.
  70         //
  71         test(_requestId == -1);
  72         _requestId = current.requestId;
  73
  74         cookie.value = new CookieI();
  75
  76         return new TestI();
  77     }
  78
  79     public void
  80     finished(Ice.Current current, Ice.Object servant, java.lang.Object cookie) throws Ice.UserException
  81     {
  82         synchronized(this)
  83         {
  84             test(!_deactivated);
  85         }
  86
  87         //
  88         // Ensure finished() is only called once per request.
  89         //
  90         test(_requestId == current.requestId);
  91         _requestId = -1;
  92
  93         test(current.id.category.equals(_category)  || _category.length() == 0);
  94         test(current.id.name.equals("locate") || current.id.name.equals("finished"));
  95
  96         if(current.id.name.equals("finished"))
  97         {
  98             exception(current);
  99         }
 100
 101         Cookie co = (Cookie)cookie;
 102         test(co.message().equals("blahblah"));
 103     }
 104
 105     public synchronized void
 106     deactivate(String category)
 107     {
 108         synchronized(this)
 109         {
 110             test(!_deactivated);
 111
 112             _deactivated = true;
 113         }
 114     }
 115
 116     private void
 117     exception(Ice.Current current) throws Ice.UserException
 118     {
 119         if(current.operation.equals("ice_ids"))
 120         {
 121             throw new TestIntfUserException();
 122         }
 123         else if(current.operation.equals("requestFailedException"))
 124         {
 125             throw new ObjectNotExistException();
 126         }
 127         else if(current.operation.equals("unknownUserException"))
 128         {
 129             throw new UnknownUserException("reason");
 130         }
 131         else if(current.operation.equals("unknownLocalException"))
 132         {
 133             throw new UnknownLocalException("reason");
 134         }
 135         else if(current.operation.equals("unknownException"))
 136         {
 137             throw new UnknownException("reason");
 138         }
 139         //
 140         // User exceptions are checked exceptions in Java, so it's not
 141         // possible to throw it from the servant locator.
 142         //
 143 //      else if(current.operation.equals("userException"))
 144 //      {
 145 //          throw new TestIntfUserException();
 146 //      }
 147         else if(current.operation.equals("localException"))
 148         {
 149             throw new SocketException(0);
 150         }
 151         else if(current.operation.equals("javaException"))
 152         {
 153             throw new java.lang.RuntimeException("message");
 154         }
 155         else if(current.operation.equals("impossibleException"))
 156         {
 157             throw new TestIntfUserException(); // Yes, it really is meant to be TestIntfUserException.
 158         }
 159         else if(current.operation.equals("intfUserException"))
 160         {
 161             throw new TestImpossibleException(); // Yes, it really is meant to be TestImpossibleException.
 162         }
 163         else if(current.operation.equals("asyncResponse"))
 164         {
 165             throw new TestImpossibleException();
 166         }
 167         else if(current.operation.equals("asyncException"))
 168         {
 169             throw new TestImpossibleException();
 170         }
 171     }
 172
 173     private boolean _deactivated;
 174     private final String _category;
 175     private int _requestId;
 176 }