diff options
Diffstat (limited to 'cs/src/Ice/Direct.cs')
| -rwxr-xr-x | cs/src/Ice/Direct.cs | 196 |
1 files changed, 98 insertions, 98 deletions
diff --git a/cs/src/Ice/Direct.cs b/cs/src/Ice/Direct.cs index f3a50b338b0..6e14126da1c 100755 --- a/cs/src/Ice/Direct.cs +++ b/cs/src/Ice/Direct.cs @@ -14,104 +14,104 @@ namespace IceInternal public sealed class Direct { - public Direct(Ice.Current current) - { - _current = current; - - Ice.ObjectAdapterI adapter = (Ice.ObjectAdapterI)_current.adapter; - Debug.Assert(adapter != null); - - // - // Must call incDirectCount() first, because it checks for - // adapter deactivation, and prevents deactivation completion - // until decDirectCount() is called. This is important, - // because getServantManager() may not be called afer - // deactivation completion. - // - adapter.incDirectCount(); - - ServantManager servantManager = adapter.getServantManager(); - Debug.Assert(servantManager != null); - - try - { - _servant = servantManager.findServant(_current.id, current.facet); - if(_servant == null) - { - _locator = servantManager.findServantLocator(_current.id.category); - if(_locator == null && _current.id.category.Length > 0) - { - _locator = servantManager.findServantLocator(""); - } - if(_locator != null) - { - _servant = _locator.locate(_current, out _cookie); - } - } - if(_servant == null) - { - if(servantManager != null && servantManager.hasServant(_current.id)) - { - Ice.FacetNotExistException ex = new Ice.FacetNotExistException(); - ex.id = _current.id; - ex.facet = _current.facet; - ex.operation = _current.operation; - throw ex; - } - else - { - Ice.ObjectNotExistException ex = new Ice.ObjectNotExistException(); - ex.id = _current.id; - ex.facet = _current.facet; - ex.operation = _current.operation; - throw ex; - } - } - } - catch(System.Exception) - { - try - { - if(_locator != null && _servant != null) - { - _locator.finished(_current, _servant, _cookie); - } - throw; - } - finally - { - adapter.decDirectCount(); - } - } - } - - public void destroy() - { - Ice.ObjectAdapterI adapter = (Ice.ObjectAdapterI)_current.adapter; - Debug.Assert(adapter != null); - - try - { - if(_locator != null && _servant != null) - { - _locator.finished(_current, _servant, _cookie); - } - } - finally - { - adapter.decDirectCount(); - } - } - - public Ice.Object servant() - { - return _servant; - } - - private Ice.Current _current; - private Ice.Object _servant; - private Ice.ServantLocator _locator; - private Ice.LocalObject _cookie; + public Direct(Ice.Current current) + { + _current = current; + + Ice.ObjectAdapterI adapter = (Ice.ObjectAdapterI)_current.adapter; + Debug.Assert(adapter != null); + + // + // Must call incDirectCount() first, because it checks for + // adapter deactivation, and prevents deactivation completion + // until decDirectCount() is called. This is important, + // because getServantManager() may not be called afer + // deactivation completion. + // + adapter.incDirectCount(); + + ServantManager servantManager = adapter.getServantManager(); + Debug.Assert(servantManager != null); + + try + { + _servant = servantManager.findServant(_current.id, current.facet); + if(_servant == null) + { + _locator = servantManager.findServantLocator(_current.id.category); + if(_locator == null && _current.id.category.Length > 0) + { + _locator = servantManager.findServantLocator(""); + } + if(_locator != null) + { + _servant = _locator.locate(_current, out _cookie); + } + } + if(_servant == null) + { + if(servantManager != null && servantManager.hasServant(_current.id)) + { + Ice.FacetNotExistException ex = new Ice.FacetNotExistException(); + ex.id = _current.id; + ex.facet = _current.facet; + ex.operation = _current.operation; + throw ex; + } + else + { + Ice.ObjectNotExistException ex = new Ice.ObjectNotExistException(); + ex.id = _current.id; + ex.facet = _current.facet; + ex.operation = _current.operation; + throw ex; + } + } + } + catch(System.Exception) + { + try + { + if(_locator != null && _servant != null) + { + _locator.finished(_current, _servant, _cookie); + } + throw; + } + finally + { + adapter.decDirectCount(); + } + } + } + + public void destroy() + { + Ice.ObjectAdapterI adapter = (Ice.ObjectAdapterI)_current.adapter; + Debug.Assert(adapter != null); + + try + { + if(_locator != null && _servant != null) + { + _locator.finished(_current, _servant, _cookie); + } + } + finally + { + adapter.decDirectCount(); + } + } + + public Ice.Object servant() + { + return _servant; + } + + private Ice.Current _current; + private Ice.Object _servant; + private Ice.ServantLocator _locator; + private Ice.LocalObject _cookie; } } |