Code:
/ FXUpdate3074 / FXUpdate3074 / 1.1 / untmp / whidbey / QFE / ndp / clr / src / BCL / System / Runtime / Remoting / RedirectionProxy.cs / 1 / RedirectionProxy.cs
// ==++== // // Copyright (c) Microsoft Corporation. All rights reserved. // // ==--== // File: RedirectionProxy.cs using System; using System.Runtime.InteropServices; using System.Runtime.Remoting.Messaging; using System.Runtime.Remoting.Proxies; namespace System.Runtime.Remoting { internal class RedirectionProxy : MarshalByRefObject, IMessageSink { private MarshalByRefObject _proxy; private RealProxy _realProxy; private Type _serverType; private WellKnownObjectMode _objectMode; internal RedirectionProxy(MarshalByRefObject proxy, Type serverType) { _proxy = proxy; _realProxy = RemotingServices.GetRealProxy(_proxy); _serverType = serverType; _objectMode = WellKnownObjectMode.Singleton; } // RedirectionProxy public WellKnownObjectMode ObjectMode { set { _objectMode = value; } } // ObjectMode public virtual IMessage SyncProcessMessage(IMessage msg) { IMessage replyMsg = null; try { msg.Properties["__Uri"] = _realProxy.IdentityObject.URI; if (_objectMode == WellKnownObjectMode.Singleton) { replyMsg = _realProxy.Invoke(msg); } else { // This is a single call object, so we need to create // a new instance. MarshalByRefObject obj = (MarshalByRefObject)Activator.CreateInstance(_serverType, true); BCLDebug.Assert(RemotingServices.IsTransparentProxy(obj), "expecting a proxy"); RealProxy rp = RemotingServices.GetRealProxy(obj); replyMsg = rp.Invoke(msg); } } catch (Exception e) { replyMsg = new ReturnMessage(e, msg as IMethodCallMessage); } return replyMsg; } // SyncProcessMessage public virtual IMessageCtrl AsyncProcessMessage(IMessage msg, IMessageSink replySink) { // < IMessage replyMsg = null; replyMsg = SyncProcessMessage(msg); if (replySink != null) replySink.SyncProcessMessage(replyMsg); return null; } // AsyncProcessMessage public IMessageSink NextSink { get { return null; } } } // class RedirectionProxy // This is only to be used for wellknown Singleton COM objects. internal class ComRedirectionProxy : MarshalByRefObject, IMessageSink { private MarshalByRefObject _comObject; private Type _serverType; internal ComRedirectionProxy(MarshalByRefObject comObject, Type serverType) { BCLDebug.Assert(serverType.IsCOMObject, "This must be a COM object type."); _comObject = comObject; _serverType = serverType; } // ComRedirectionProxy public virtual IMessage SyncProcessMessage(IMessage msg) { IMethodCallMessage mcmReqMsg = (IMethodCallMessage)msg; IMethodReturnMessage replyMsg = null; replyMsg = RemotingServices.ExecuteMessage(_comObject, mcmReqMsg); if (replyMsg != null) { // If an "RPC server not available" (HRESULT=0x800706BA) COM // exception is thrown, we will try to recreate the object once. const int RPC_S_SERVER_UNAVAILABLE = unchecked((int)0x800706BA); const int RPC_S_CALL_FAILED_DNE = unchecked((int)0x800706BF); COMException comException = replyMsg.Exception as COMException; if ((comException != null) && ((comException._HResult == RPC_S_SERVER_UNAVAILABLE) || (comException._HResult == RPC_S_CALL_FAILED_DNE))) { _comObject = (MarshalByRefObject)Activator.CreateInstance(_serverType, true); replyMsg = RemotingServices.ExecuteMessage(_comObject, mcmReqMsg); } } return replyMsg; } // SyncProcessMessage public virtual IMessageCtrl AsyncProcessMessage(IMessage msg, IMessageSink replySink) { // < IMessage replyMsg = null; replyMsg = SyncProcessMessage(msg); if (replySink != null) replySink.SyncProcessMessage(replyMsg); return null; } // AsyncProcessMessage public IMessageSink NextSink { get { return null; } } } // class ComRedirectionProxy } // namespace System.Runtime.Remoting // File provided for Reference Use Only by Microsoft Corporation (c) 2007. // Copyright (c) Microsoft Corporation. All rights reserved.
Link Menu
This book is available now!
Buy at Amazon US or
Buy at Amazon UK
- RootAction.cs
- EnumUnknown.cs
- SelectionList.cs
- xdrvalidator.cs
- TextTreeInsertUndoUnit.cs
- IItemContainerGenerator.cs
- SettingsPropertyWrongTypeException.cs
- GenericUriParser.cs
- NetworkStream.cs
- DataRecordObjectView.cs
- HttpBufferlessInputStream.cs
- FixedHyperLink.cs
- SendSecurityHeaderElementContainer.cs
- ToolStripItem.cs
- Int64KeyFrameCollection.cs
- DataPagerFieldCollection.cs
- FtpCachePolicyElement.cs
- ScopeCollection.cs
- Polyline.cs
- Inflater.cs
- ArrayList.cs
- ProfileInfo.cs
- ColorDialog.cs
- _AuthenticationState.cs
- ExpressionHelper.cs
- TdsParserStaticMethods.cs
- ResourceSet.cs
- TemplatedWizardStep.cs
- TableLayoutCellPaintEventArgs.cs
- InfiniteIntConverter.cs
- DependencyPropertyChangedEventArgs.cs
- DependencyObjectCodeDomSerializer.cs
- NullReferenceException.cs
- DataGridViewCheckBoxCell.cs
- EncoderBestFitFallback.cs
- ObjRef.cs
- MessageSecurityProtocolFactory.cs
- TypeDelegator.cs
- NativeMethods.cs
- WindowsScrollBar.cs
- RawUIStateInputReport.cs
- ConditionCollection.cs
- PasswordBoxAutomationPeer.cs
- DataSourceUtil.cs
- PartialArray.cs
- ViewManager.cs
- ToolStripProgressBar.cs
- LockCookie.cs
- SortedList.cs
- FileChangesMonitor.cs
- ResourceSetExpression.cs
- CallbackValidatorAttribute.cs
- NativeMethods.cs
- LocationFactory.cs
- XslVisitor.cs
- CompiledQueryCacheEntry.cs
- CodeDefaultValueExpression.cs
- Identity.cs
- CompleteWizardStep.cs
- QueryOperationResponseOfT.cs
- ListViewHitTestInfo.cs
- PropertyGridView.cs
- DigitShape.cs
- HtmlEmptyTagControlBuilder.cs
- OutputCacheSection.cs
- relpropertyhelper.cs
- PagesSection.cs
- WindowsGraphicsWrapper.cs
- AnnotationStore.cs
- Rotation3D.cs
- SizeConverter.cs
- ModuleConfigurationInfo.cs
- IssuanceLicense.cs
- DragDropHelper.cs
- Brushes.cs
- TypeConverterHelper.cs
- HostingEnvironmentException.cs
- ScalarRestriction.cs
- ContextMenuService.cs
- DesignerForm.cs
- TransformProviderWrapper.cs
- CompatibleComparer.cs
- SystemEvents.cs
- HttpModuleCollection.cs
- ValidatorCollection.cs
- FixedBufferAttribute.cs
- CachedPathData.cs
- XPathDocumentNavigator.cs
- ProcessModelInfo.cs
- validationstate.cs
- PropertyRecord.cs
- EdmValidator.cs
- EndpointInstanceProvider.cs
- CodeDomConfigurationHandler.cs
- SimpleHandlerFactory.cs
- XpsResource.cs
- FormatConvertedBitmap.cs
- MenuAdapter.cs
- HtmlTableCellCollection.cs
- BufferedGraphics.cs