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
- CryptoStream.cs
- StorageEntityContainerMapping.cs
- ControlPropertyNameConverter.cs
- HtmlInputCheckBox.cs
- TimelineGroup.cs
- ControlCachePolicy.cs
- UnsafeNativeMethods.cs
- MailBnfHelper.cs
- ProcessActivityTreeOptions.cs
- X509Certificate2.cs
- RayHitTestParameters.cs
- HtmlImage.cs
- DiscoveryExceptionDictionary.cs
- DelimitedListTraceListener.cs
- DbConnectionPoolOptions.cs
- Trace.cs
- Soap12ProtocolImporter.cs
- CommaDelimitedStringAttributeCollectionConverter.cs
- Activator.cs
- ListSortDescriptionCollection.cs
- OrderByExpression.cs
- TextServicesDisplayAttributePropertyRanges.cs
- System.Data_BID.cs
- XmlSiteMapProvider.cs
- XmlnsDictionary.cs
- HostingEnvironmentException.cs
- DefaultTextStoreTextComposition.cs
- HyperLinkField.cs
- PolygonHotSpot.cs
- RequestCachingSection.cs
- XmlIncludeAttribute.cs
- HighContrastHelper.cs
- ServicePointManager.cs
- TransformCollection.cs
- HexParser.cs
- FileIOPermission.cs
- QuotedPairReader.cs
- TimeEnumHelper.cs
- LogReserveAndAppendState.cs
- XmlAnyElementAttributes.cs
- CustomTypeDescriptor.cs
- BindingMAnagerBase.cs
- Vector3dCollection.cs
- RowsCopiedEventArgs.cs
- GZipDecoder.cs
- MethodAccessException.cs
- WebSysDefaultValueAttribute.cs
- PackageStore.cs
- Events.cs
- SmiEventSink_DeferedProcessing.cs
- WsdlContractConversionContext.cs
- DbSourceParameterCollection.cs
- EntityContainerEntitySet.cs
- documentation.cs
- Queue.cs
- PassportPrincipal.cs
- TextEvent.cs
- WebPartConnectionsDisconnectVerb.cs
- ControlParameter.cs
- UIElementParaClient.cs
- SystemWebCachingSectionGroup.cs
- InfoCardProofToken.cs
- DBDataPermissionAttribute.cs
- CalendarDay.cs
- FormClosedEvent.cs
- AdCreatedEventArgs.cs
- ImagingCache.cs
- EmptyCollection.cs
- PropertyValueChangedEvent.cs
- RectValueSerializer.cs
- AsyncStreamReader.cs
- EncryptedData.cs
- DataObject.cs
- TypeResolver.cs
- SemanticResolver.cs
- ViewBox.cs
- ForceCopyBuildProvider.cs
- AppearanceEditorPart.cs
- Table.cs
- Html32TextWriter.cs
- MasterPageParser.cs
- DTCTransactionManager.cs
- BitmapEffectRenderDataResource.cs
- RuntimeResourceSet.cs
- TypeName.cs
- SecurityPolicyVersion.cs
- CalendarDay.cs
- SubpageParagraph.cs
- Merger.cs
- Shape.cs
- TextRangeEdit.cs
- StylusPointProperty.cs
- Automation.cs
- RelationshipEnd.cs
- Accessible.cs
- Point4DConverter.cs
- DetailsViewModeEventArgs.cs
- DelegateTypeInfo.cs
- OpenTypeLayout.cs
- CrossSiteScriptingValidation.cs