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
- HttpApplicationFactory.cs
- AppDomainShutdownMonitor.cs
- ImageList.cs
- StructureChangedEventArgs.cs
- DetailsViewUpdatedEventArgs.cs
- DispatchWrapper.cs
- WebPartsSection.cs
- IdentityReference.cs
- XPathAncestorIterator.cs
- XhtmlStyleClass.cs
- SqlNotificationRequest.cs
- DropShadowEffect.cs
- HtmlHistory.cs
- StylusPlugin.cs
- PeerName.cs
- PropertyInformation.cs
- VersionValidator.cs
- COM2IPerPropertyBrowsingHandler.cs
- SqlHelper.cs
- PartialCachingAttribute.cs
- DisposableCollectionWrapper.cs
- StrokeNodeData.cs
- OracleNumber.cs
- Marshal.cs
- BookmarkCallbackWrapper.cs
- CorrelationService.cs
- EnumMember.cs
- ExpressionBuilderCollection.cs
- AlignmentXValidation.cs
- EntityContainerRelationshipSet.cs
- ReadWriteObjectLock.cs
- HtmlShimManager.cs
- AspNetCompatibilityRequirementsAttribute.cs
- PenThreadWorker.cs
- BamlBinaryReader.cs
- Stylus.cs
- ButtonBase.cs
- UnmanagedMemoryAccessor.cs
- OdbcDataAdapter.cs
- WinInetCache.cs
- DataConnectionHelper.cs
- XPathEmptyIterator.cs
- ICollection.cs
- FormViewAutoFormat.cs
- NamespaceCollection.cs
- PaperSource.cs
- ToolStripDropDownDesigner.cs
- PerspectiveCamera.cs
- SqlConnectionPoolProviderInfo.cs
- TransformerInfoCollection.cs
- DataGridViewCheckBoxCell.cs
- SafeNativeMethodsOther.cs
- SystemFonts.cs
- HMACRIPEMD160.cs
- XmlCDATASection.cs
- XmlSecureResolver.cs
- SystemMulticastIPAddressInformation.cs
- ObjectFullSpanRewriter.cs
- ComponentEditorPage.cs
- MultiView.cs
- WindowsTooltip.cs
- _CommandStream.cs
- Int32KeyFrameCollection.cs
- KeyValuePairs.cs
- CodeCommentStatement.cs
- objectquery_tresulttype.cs
- ReflectionHelper.cs
- FullTextLine.cs
- WindowsImpersonationContext.cs
- ProfilePropertySettings.cs
- ClusterRegistryConfigurationProvider.cs
- EntityCommand.cs
- TypePropertyEditor.cs
- TypefaceMap.cs
- TrackingCondition.cs
- PropertyTabAttribute.cs
- ReferenceService.cs
- SplitContainer.cs
- PropertyState.cs
- StoreItemCollection.Loader.cs
- InfiniteTimeSpanConverter.cs
- UrlMappingsModule.cs
- InternalSafeNativeMethods.cs
- ManipulationStartedEventArgs.cs
- DataKey.cs
- EmbossBitmapEffect.cs
- IResourceProvider.cs
- WindowsAuthenticationModule.cs
- CollectionChangeEventArgs.cs
- METAHEADER.cs
- TraceHandler.cs
- SqlErrorCollection.cs
- OrderedDictionaryStateHelper.cs
- ProfileSettingsCollection.cs
- CodeDirectoryCompiler.cs
- ProxyDataContractResolver.cs
- SafeSecurityHelper.cs
- DTCTransactionManager.cs
- LinkButton.cs
- TileBrush.cs