Code:
/ 4.0 / 4.0 / DEVDIV_TFS / Dev10 / Releases / RTMRel / ndp / clr / src / BCL / System / Runtime / Remoting / RedirectionProxy.cs / 1305376 / 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; [System.Security.SecurityCritical /*auto-generated*/] private RealProxy _realProxy; private Type _serverType; private WellKnownObjectMode _objectMode; [System.Security.SecurityCritical] // auto-generated 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 [System.Security.SecurityCritical] // auto-generated 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 [System.Security.SecurityCritical] // auto-generated 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 { [System.Security.SecurityCritical] // auto-generated 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 [System.Security.SecurityCritical] // auto-generated 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 [System.Security.SecurityCritical] // auto-generated 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 { [System.Security.SecurityCritical] // auto-generated 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. // // ==--== // 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; [System.Security.SecurityCritical /*auto-generated*/] private RealProxy _realProxy; private Type _serverType; private WellKnownObjectMode _objectMode; [System.Security.SecurityCritical] // auto-generated 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 [System.Security.SecurityCritical] // auto-generated 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 [System.Security.SecurityCritical] // auto-generated 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 { [System.Security.SecurityCritical] // auto-generated 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 [System.Security.SecurityCritical] // auto-generated 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 [System.Security.SecurityCritical] // auto-generated 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 { [System.Security.SecurityCritical] // auto-generated get { return null; } } } // class ComRedirectionProxy } // namespace System.Runtime.Remoting // File provided for Reference Use Only by Microsoft Corporation (c) 2007.
Link Menu
This book is available now!
Buy at Amazon US or
Buy at Amazon UK
- ItemCheckEvent.cs
- ValidationError.cs
- IPGlobalProperties.cs
- QilScopedVisitor.cs
- ErrorItem.cs
- XmlNavigatorFilter.cs
- UnionQueryOperator.cs
- ResourceManagerWrapper.cs
- MarginCollapsingState.cs
- EdmRelationshipRoleAttribute.cs
- altserialization.cs
- LocationReferenceEnvironment.cs
- TextContainer.cs
- Formatter.cs
- ComponentManagerBroker.cs
- URLAttribute.cs
- RuntimeArgumentHandle.cs
- SafeHandles.cs
- BitmapMetadataBlob.cs
- WebPartDisplayModeCancelEventArgs.cs
- path.cs
- XmlSchemaFacet.cs
- InlinedAggregationOperator.cs
- HashSet.cs
- XPathParser.cs
- MobileCapabilities.cs
- ServiceNameCollection.cs
- Privilege.cs
- ReferenceConverter.cs
- SoapCodeExporter.cs
- OlePropertyStructs.cs
- XmlCharType.cs
- BinaryCommonClasses.cs
- EventPrivateKey.cs
- DataGridDefaultColumnWidthTypeConverter.cs
- XhtmlBasicTextViewAdapter.cs
- DbCommandTree.cs
- StringTraceRecord.cs
- BrushConverter.cs
- DelegatingTypeDescriptionProvider.cs
- ArraySegment.cs
- LinkClickEvent.cs
- SpellCheck.cs
- StreamSecurityUpgradeInitiatorAsyncResult.cs
- Package.cs
- DataGridViewRowPrePaintEventArgs.cs
- SessionParameter.cs
- ErrorWebPart.cs
- XamlBuildTaskServices.cs
- TableLayoutRowStyleCollection.cs
- FileSecurity.cs
- WindowsIPAddress.cs
- ControlBindingsCollection.cs
- IsolatedStoragePermission.cs
- FontSource.cs
- SafeRightsManagementHandle.cs
- CommandSet.cs
- ComponentSerializationService.cs
- MessageDecoder.cs
- PopOutPanel.cs
- XmlTextWriter.cs
- sitestring.cs
- NameValueCollection.cs
- AsyncCodeActivityContext.cs
- KoreanLunisolarCalendar.cs
- ScriptHandlerFactory.cs
- PolyQuadraticBezierSegment.cs
- GeometryCollection.cs
- LongAverageAggregationOperator.cs
- ScriptMethodAttribute.cs
- XmlSchemaObjectCollection.cs
- WsatRegistrationHeader.cs
- PropertyStore.cs
- OracleRowUpdatedEventArgs.cs
- WindowsGraphicsCacheManager.cs
- WebConfigurationManager.cs
- XamlInterfaces.cs
- ThreadStaticAttribute.cs
- TableParaClient.cs
- DbSourceParameterCollection.cs
- DataBinding.cs
- ForEachAction.cs
- DrawingContextDrawingContextWalker.cs
- SqlComparer.cs
- DeviceContext.cs
- ActivityExecutorDelegateInfo.cs
- PointAnimationBase.cs
- TileBrush.cs
- RelatedPropertyManager.cs
- KnownAssemblyEntry.cs
- SpeechRecognizer.cs
- XamlFigureLengthSerializer.cs
- Help.cs
- SelectionRangeConverter.cs
- WinEventWrap.cs
- FigureParagraph.cs
- EndpointDispatcher.cs
- MetricEntry.cs
- UnionQueryOperator.cs
- SQLUtility.cs