Code:
/ FX-1434 / FX-1434 / 1.0 / untmp / whidbey / REDBITS / 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
Link Menu
This book is available now!
Buy at Amazon US or
Buy at Amazon UK
- X509WindowsSecurityToken.cs
- CachedRequestParams.cs
- CompiledRegexRunner.cs
- FontConverter.cs
- PublishLicense.cs
- UInt32Storage.cs
- CachedResourceDictionaryExtension.cs
- LinqDataSourceContextData.cs
- SamlAuthorizationDecisionClaimResource.cs
- DPCustomTypeDescriptor.cs
- XmlWrappingWriter.cs
- UpDownBase.cs
- DataGridDefaultColumnWidthTypeConverter.cs
- PointF.cs
- StatusStrip.cs
- NumberFunctions.cs
- TriState.cs
- MailSettingsSection.cs
- Rotation3D.cs
- PersonalizableTypeEntry.cs
- LicFileLicenseProvider.cs
- AsyncWaitHandle.cs
- TextSelectionHelper.cs
- SpotLight.cs
- GradientSpreadMethodValidation.cs
- OleDbStruct.cs
- WebPartDisplayModeCancelEventArgs.cs
- DebugView.cs
- MyContact.cs
- ConstraintEnumerator.cs
- DataGridViewComboBoxColumn.cs
- CultureSpecificCharacterBufferRange.cs
- DodSequenceMerge.cs
- DrawingContextWalker.cs
- DBPropSet.cs
- SecurityKeyUsage.cs
- EdmEntityTypeAttribute.cs
- MetadataSerializer.cs
- UniqueID.cs
- SqlStatistics.cs
- WebPartDeleteVerb.cs
- SpellerError.cs
- GPRECTF.cs
- FocusWithinProperty.cs
- StoreItemCollection.Loader.cs
- ConvertTextFrag.cs
- XmlWrappingReader.cs
- DoubleAnimationClockResource.cs
- TrustLevelCollection.cs
- NativeMethods.cs
- WebScriptMetadataMessage.cs
- FieldInfo.cs
- EnumerableRowCollectionExtensions.cs
- TypeResolver.cs
- DocumentSchemaValidator.cs
- PerformanceCounterLib.cs
- ExternalException.cs
- IdentifierCollection.cs
- BindingElementExtensionElement.cs
- MissingManifestResourceException.cs
- AssemblyGen.cs
- Variable.cs
- EncoderParameter.cs
- DataSet.cs
- PackageDigitalSignatureManager.cs
- DataGridHyperlinkColumn.cs
- NgenServicingAttributes.cs
- TemplateFactory.cs
- ContextBase.cs
- DataGridViewRowHeaderCell.cs
- QueryResponse.cs
- ReadOnlyNameValueCollection.cs
- ContentFilePart.cs
- CommandDevice.cs
- MsdtcClusterUtils.cs
- UInt64.cs
- WebPartConnectionsConfigureVerb.cs
- CommandLibraryHelper.cs
- DataRowCollection.cs
- FontFamily.cs
- BamlReader.cs
- StrokeCollection2.cs
- JsonGlobals.cs
- KnownColorTable.cs
- Dump.cs
- SourceFilter.cs
- DataGridTablesFactory.cs
- DeviceContext.cs
- ScrollChrome.cs
- Control.cs
- ReadOnlyHierarchicalDataSourceView.cs
- SafeRightsManagementQueryHandle.cs
- OdbcConnectionFactory.cs
- XhtmlBasicPanelAdapter.cs
- DataGridSortCommandEventArgs.cs
- IImplicitResourceProvider.cs
- Inflater.cs
- ProfileManager.cs
- StreamWithDictionary.cs
- GeometryDrawing.cs