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
- PropertyTab.cs
- TableRowCollection.cs
- GenericIdentity.cs
- DataControlHelper.cs
- ActivityTypeResolver.xaml.cs
- SynchronizationContext.cs
- InstanceDescriptor.cs
- SchemaImporterExtensionsSection.cs
- EncodingInfo.cs
- EntityClassGenerator.cs
- XamlDesignerSerializationManager.cs
- PenContext.cs
- DataSpaceManager.cs
- ProcessingInstructionAction.cs
- MessageDecoder.cs
- DataGrid.cs
- PolicyStatement.cs
- RoutedEventConverter.cs
- ParallelRangeManager.cs
- PropertyGridView.cs
- XmlDocumentFragment.cs
- DocumentViewer.cs
- OleServicesContext.cs
- DocumentSequence.cs
- WindowsUserNameCachingSecurityTokenAuthenticator.cs
- FragmentQueryKB.cs
- CategoryValueConverter.cs
- RC2.cs
- ServerProtocol.cs
- FileDialog_Vista.cs
- ScriptingWebServicesSectionGroup.cs
- EditModeSwitchButton.cs
- PaperSource.cs
- CroppedBitmap.cs
- SiteMapProvider.cs
- ParameterReplacerVisitor.cs
- SessionParameter.cs
- Pair.cs
- unsafeIndexingFilterStream.cs
- DataControlCommands.cs
- DataGridViewRowStateChangedEventArgs.cs
- GiveFeedbackEvent.cs
- ServiceTimeoutsElement.cs
- ClientSideQueueItem.cs
- EntityDataSourceQueryBuilder.cs
- SoapRpcServiceAttribute.cs
- ping.cs
- RangeValuePattern.cs
- BindingExpressionBase.cs
- ReachDocumentPageSerializer.cs
- InkCollectionBehavior.cs
- DiscoveryMessageSequence11.cs
- SqlDataSourceSelectingEventArgs.cs
- ConfigXmlElement.cs
- GC.cs
- ISFClipboardData.cs
- ProjectionRewriter.cs
- WorkflowRequestContext.cs
- HttpListenerException.cs
- UnauthorizedAccessException.cs
- HttpCachePolicyWrapper.cs
- CompositeControl.cs
- ClientFormsAuthenticationMembershipProvider.cs
- AutomationElementIdentifiers.cs
- SqlDataAdapter.cs
- ZipIOCentralDirectoryBlock.cs
- CanonicalFontFamilyReference.cs
- _NegotiateClient.cs
- AssemblyAttributesGoHere.cs
- WebPartZoneBase.cs
- RSAPKCS1SignatureFormatter.cs
- SafeCertificateContext.cs
- Emitter.cs
- OrthographicCamera.cs
- KnownColorTable.cs
- ConfigurationSchemaErrors.cs
- TextShapeableCharacters.cs
- SQLString.cs
- TileBrush.cs
- XmlTextReaderImplHelpers.cs
- EmptyEnumerator.cs
- GridViewSortEventArgs.cs
- XmlDigitalSignatureProcessor.cs
- GridViewUpdateEventArgs.cs
- InputReferenceExpression.cs
- ReturnEventArgs.cs
- SectionRecord.cs
- XPathDocumentIterator.cs
- HMACRIPEMD160.cs
- _SafeNetHandles.cs
- XmlNodeList.cs
- XmlArrayAttribute.cs
- Int32CollectionConverter.cs
- PropertyNames.cs
- NamedElement.cs
- IProvider.cs
- FacetDescription.cs
- DBNull.cs
- TerminatorSinks.cs
- HashMembershipCondition.cs