Code:
/ 4.0 / 4.0 / untmp / 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.
Link Menu

This book is available now!
Buy at Amazon US or
Buy at Amazon UK
- ClientBuildManager.cs
- SafeSecurityHandles.cs
- XmlIgnoreAttribute.cs
- CoTaskMemSafeHandle.cs
- LoadMessageLogger.cs
- XmlElementList.cs
- ConnectionStringsSection.cs
- CompositeActivityDesigner.cs
- NonceToken.cs
- DeviceContext.cs
- UpdateCompiler.cs
- ExpressionBinding.cs
- SatelliteContractVersionAttribute.cs
- IRCollection.cs
- SymmetricAlgorithm.cs
- AtomServiceDocumentSerializer.cs
- SortAction.cs
- Guid.cs
- SystemUdpStatistics.cs
- HttpWebRequest.cs
- TextServicesContext.cs
- COM2IVsPerPropertyBrowsingHandler.cs
- LiteralControl.cs
- MDIClient.cs
- FlowDocumentScrollViewer.cs
- NotifyCollectionChangedEventArgs.cs
- ListParagraph.cs
- ChildTable.cs
- StringAttributeCollection.cs
- XmlWrappingReader.cs
- EnumConverter.cs
- RowCache.cs
- keycontainerpermission.cs
- CommandValueSerializer.cs
- LinqDataSourceView.cs
- RootProfilePropertySettingsCollection.cs
- Update.cs
- _AutoWebProxyScriptHelper.cs
- GcHandle.cs
- RecognitionResult.cs
- FormViewAutoFormat.cs
- MultiDataTrigger.cs
- ServicePerformanceCounters.cs
- CacheEntry.cs
- DataGridViewSelectedColumnCollection.cs
- CollectionMarkupSerializer.cs
- VisualBasicDesignerHelper.cs
- CollectionChangeEventArgs.cs
- DataServiceClientException.cs
- dataprotectionpermission.cs
- SplashScreen.cs
- HebrewNumber.cs
- ScaleTransform.cs
- MimeReflector.cs
- tibetanshape.cs
- WebContext.cs
- EncryptedPackageFilter.cs
- UIEndRequest.cs
- BitmapEffectrendercontext.cs
- QueryModel.cs
- LocatorBase.cs
- HtmlInputFile.cs
- Cursor.cs
- QueryExpr.cs
- Int64AnimationBase.cs
- PixelFormat.cs
- DictionaryBase.cs
- Rotation3DKeyFrameCollection.cs
- ProfileSettings.cs
- TraceSource.cs
- ComEventsHelper.cs
- ApplicationFileParser.cs
- DataRecordInfo.cs
- DeflateStream.cs
- SafeNativeHandle.cs
- SystemGatewayIPAddressInformation.cs
- BindingEntityInfo.cs
- WebCategoryAttribute.cs
- CheckPair.cs
- XmlSchemaParticle.cs
- PageThemeParser.cs
- ControlUtil.cs
- UInt16Converter.cs
- PropertyEmitter.cs
- SafeNativeMethodsMilCoreApi.cs
- NullableDoubleMinMaxAggregationOperator.cs
- streamingZipPartStream.cs
- ObjectQueryExecutionPlan.cs
- PeerCustomResolverSettings.cs
- ZipIOExtraFieldZip64Element.cs
- HttpModuleAction.cs
- NativeMethods.cs
- ReadOnlyCollectionBuilder.cs
- TheQuery.cs
- XPathNavigatorReader.cs
- DataErrorValidationRule.cs
- MediaPlayer.cs
- ScriptManager.cs
- XmlHierarchyData.cs
- AuthenticationService.cs