diff options
| author | Michi Henning <michi@zeroc.com> | 2004-01-29 03:05:56 +0000 |
|---|---|---|
| committer | Michi Henning <michi@zeroc.com> | 2004-01-29 03:05:56 +0000 |
| commit | 7161952dadb673138229cf61e684fe73cd5a9bca (patch) | |
| tree | a1566729f1b807814b65c662e621127d8f44b896 /cs/src/Ice/ObjectAdapterFactory.cs | |
| parent | fix (diff) | |
| download | ice-7161952dadb673138229cf61e684fe73cd5a9bca.tar.bz2 ice-7161952dadb673138229cf61e684fe73cd5a9bca.tar.xz ice-7161952dadb673138229cf61e684fe73cd5a9bca.zip | |
*** empty log message ***
Diffstat (limited to 'cs/src/Ice/ObjectAdapterFactory.cs')
| -rwxr-xr-x | cs/src/Ice/ObjectAdapterFactory.cs | 203 |
1 files changed, 203 insertions, 0 deletions
diff --git a/cs/src/Ice/ObjectAdapterFactory.cs b/cs/src/Ice/ObjectAdapterFactory.cs new file mode 100755 index 00000000000..f4475ec57b2 --- /dev/null +++ b/cs/src/Ice/ObjectAdapterFactory.cs @@ -0,0 +1,203 @@ +// **********************************************************************
+//
+// Copyright (c) 2003
+// ZeroC, Inc.
+// Billerica, MA, USA
+//
+// All Rights Reserved.
+//
+// Ice is free software; you can redistribute it and/or modify it under
+// the terms of the GNU General Public License version 2 as published by
+// the Free Software Foundation.
+//
+// **********************************************************************
+namespace IceInternal
+{
+
+using System.Collections;
+using System.Diagnostics;
+using IceUtil;
+
+public sealed class ObjectAdapterFactory
+{
+ public void
+ shutdown()
+ {
+ lock(this)
+ {
+ //
+ // Ignore shutdown requests if the object adapter factory has
+ // already been shut down.
+ //
+ if(_instance == null)
+ {
+ return;
+ }
+
+ foreach(Ice.ObjectAdapter adapter in _adapters.Values)
+ {
+ adapter.deactivate();
+ }
+
+ _instance = null;
+ _communicator = null;
+
+ System.Threading.Monitor.PulseAll(this);
+ }
+ }
+
+ public void
+ waitForShutdown()
+ {
+ lock(this)
+ {
+ //
+ // First we wait for the shutdown of the factory itself.
+ //
+ while(_instance != null)
+ {
+ try
+ {
+ System.Threading.Monitor.Wait(this);
+ }
+ catch(System.Threading.ThreadInterruptedException)
+ {
+ }
+ }
+
+ //
+ // If some other thread is currently shutting down, we wait
+ // until this thread is finished.
+ //
+ while(_waitForShutdown)
+ {
+ try
+ {
+ System.Threading.Monitor.Wait(this);
+ }
+ catch(System.Threading.ThreadInterruptedException)
+ {
+ }
+ }
+ _waitForShutdown = true;
+ }
+
+ //
+ // Now we wait for deactivation of each object adapter.
+ //
+ foreach(Ice.ObjectAdapter adapter in _adapters.Values)
+ {
+ adapter.waitForDeactivate();
+ }
+
+ //
+ // We're done, now we can throw away the object adapters.
+ //
+ _adapters.Clear();
+
+ lock(this)
+ {
+ //
+ // Signal that waiting is complete.
+ //
+ _waitForShutdown = false;
+ System.Threading.Monitor.PulseAll(this);
+ }
+ }
+
+ public Ice.ObjectAdapter
+ createObjectAdapter(string name)
+ {
+ lock(this)
+ {
+ if(_instance == null)
+ {
+ throw new Ice.ObjectAdapterDeactivatedException();
+ }
+
+ Ice.ObjectAdapter adapter = (Ice.ObjectAdapter)_adapters[name];
+ if(adapter != null)
+ {
+ return adapter;
+ }
+
+ adapter = new Ice.ObjectAdapterI(_instance, _communicator, name);
+ _adapters[name] = adapter;
+ return adapter;
+ }
+ }
+
+ public Ice.ObjectAdapter
+ findObjectAdapter(Ice.ObjectPrx proxy)
+ {
+ lock(this)
+ {
+ if(_instance == null)
+ {
+ return null;
+ }
+
+ IEnumerator i = _adapters.Values.GetEnumerator();
+ while(i.MoveNext())
+ {
+ Ice.ObjectAdapterI adapter = (Ice.ObjectAdapterI)i.Current;
+ try
+ {
+ if(adapter.isLocal(proxy))
+ {
+ return adapter;
+ }
+ }
+ catch(Ice.ObjectAdapterDeactivatedException)
+ {
+ // Ignore.
+ }
+ }
+
+ return null;
+ }
+ }
+
+ public void
+ flushBatchRequests()
+ {
+ LinkedList a = new LinkedList();
+ lock(this)
+ {
+ foreach(Ice.ObjectAdapterI adapter in _adapters.Values)
+ {
+ a.Add(adapter);
+ }
+ }
+ foreach(Ice.ObjectAdapterI adapter in a)
+ {
+ adapter.flushBatchRequests();
+ }
+ }
+
+ //
+ // Only for use by Instance.
+ //
+ internal ObjectAdapterFactory(Instance instance, Ice.Communicator communicator)
+ {
+ _instance = instance;
+ _communicator = communicator;
+ _adapters = new Hashtable();
+ _waitForShutdown = false;
+ }
+
+ ~ObjectAdapterFactory()
+ {
+ Debug.Assert(_instance == null);
+ Debug.Assert(_communicator == null);
+ Debug.Assert(_adapters.Count == 0);
+ Debug.Assert(!_waitForShutdown);
+ }
+
+ private Instance _instance;
+ private Ice.Communicator _communicator;
+ private Hashtable _adapters;
+ private bool _waitForShutdown;
+}
+
+}
|