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
- CqlLexer.cs
- HttpAsyncResult.cs
- TreeBuilderXamlTranslator.cs
- ArrangedElement.cs
- BoundingRectTracker.cs
- XamlBuildProvider.cs
- Matrix3DStack.cs
- WebControlAdapter.cs
- CommandHelper.cs
- PanelDesigner.cs
- ToolTipAutomationPeer.cs
- ElementAction.cs
- WindowsClientElement.cs
- TreeNodeCollection.cs
- SineEase.cs
- RouteUrlExpressionBuilder.cs
- DesignTimeTemplateParser.cs
- ExtenderProvidedPropertyAttribute.cs
- _BasicClient.cs
- List.cs
- ApplicationGesture.cs
- DesignerCategoryAttribute.cs
- LogExtent.cs
- QuestionEventArgs.cs
- WeakReferenceKey.cs
- AsymmetricKeyExchangeFormatter.cs
- Memoizer.cs
- GenericParameterDataContract.cs
- TextTreeRootTextBlock.cs
- WebPartActionVerb.cs
- AutomationPeer.cs
- SpellerError.cs
- PeerCollaboration.cs
- ChtmlMobileTextWriter.cs
- Duration.cs
- SmiConnection.cs
- BulletChrome.cs
- ScriptingJsonSerializationSection.cs
- RelationHandler.cs
- SessionStateModule.cs
- TransformerInfo.cs
- OleDbParameterCollection.cs
- RepeaterItemCollection.cs
- SamlAttributeStatement.cs
- bindurihelper.cs
- Drawing.cs
- TransactionManager.cs
- JavascriptXmlWriterWrapper.cs
- PropertyKey.cs
- MatrixTransform3D.cs
- IndentTextWriter.cs
- mediapermission.cs
- WindowsSpinner.cs
- PageRequestManager.cs
- AutomationPatternInfo.cs
- QuaternionAnimationBase.cs
- ClientOptions.cs
- WebServiceHandlerFactory.cs
- CodeSnippetExpression.cs
- ScriptReferenceEventArgs.cs
- SqlFacetAttribute.cs
- D3DImage.cs
- SQLBinary.cs
- CorrelationToken.cs
- ClientRoleProvider.cs
- SchemaType.cs
- AlphaSortedEnumConverter.cs
- IndexedEnumerable.cs
- LinqDataSourceDeleteEventArgs.cs
- LoadedOrUnloadedOperation.cs
- MLangCodePageEncoding.cs
- FloaterBaseParaClient.cs
- FileVersionInfo.cs
- CanExecuteRoutedEventArgs.cs
- XmlSchemaType.cs
- ReturnType.cs
- InputProcessorProfilesLoader.cs
- CheckBoxFlatAdapter.cs
- SpeechAudioFormatInfo.cs
- WorkflowQueue.cs
- CalendarDataBindingHandler.cs
- DictionarySectionHandler.cs
- Binding.cs
- ReplyAdapterChannelListener.cs
- TrailingSpaceComparer.cs
- AlignmentYValidation.cs
- Registry.cs
- DataGridViewColumnDividerDoubleClickEventArgs.cs
- PointValueSerializer.cs
- EncoderReplacementFallback.cs
- ObjectManager.cs
- XsltContext.cs
- MenuItem.cs
- AsyncPostBackErrorEventArgs.cs
- WorkflowPrinting.cs
- ScrollBar.cs
- HiddenFieldPageStatePersister.cs
- Pkcs9Attribute.cs
- ControlValuePropertyAttribute.cs
- VScrollProperties.cs