Code:
/ DotNET / DotNET / 8.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
- DecimalFormatter.cs
- CellTreeSimplifier.cs
- FunctionMappingTranslator.cs
- Assign.cs
- Section.cs
- TypeReference.cs
- HttpCacheVaryByContentEncodings.cs
- CodeBlockBuilder.cs
- MultiByteCodec.cs
- HandledMouseEvent.cs
- xmlfixedPageInfo.cs
- CountAggregationOperator.cs
- SmiEventStream.cs
- Int32.cs
- Internal.cs
- StagingAreaInputItem.cs
- XmlNamespaceMapping.cs
- OutOfProcStateClientManager.cs
- SchemaElementDecl.cs
- ModuleBuilder.cs
- SerializationFieldInfo.cs
- TagPrefixCollection.cs
- TextParagraph.cs
- Panel.cs
- LayoutEngine.cs
- NullReferenceException.cs
- _CookieModule.cs
- ClientApiGenerator.cs
- _UriSyntax.cs
- SecurityValidationBehavior.cs
- ToolStripDropDown.cs
- WsiProfilesElement.cs
- FieldNameLookup.cs
- DataGridItemEventArgs.cs
- LicenseContext.cs
- SpanIndex.cs
- AsyncResult.cs
- ConstraintConverter.cs
- FileSystemEventArgs.cs
- Imaging.cs
- RemotingServices.cs
- XmlEnumAttribute.cs
- MailDefinition.cs
- UIntPtr.cs
- MyContact.cs
- ConfigXmlComment.cs
- EntitySqlQueryCacheEntry.cs
- MenuCommand.cs
- OrderByQueryOptionExpression.cs
- KnownBoxes.cs
- StringDictionary.cs
- DefaultParameterValueAttribute.cs
- VerticalConnector.xaml.cs
- SystemIPv4InterfaceProperties.cs
- ThreadStaticAttribute.cs
- EncoderExceptionFallback.cs
- TransformCollection.cs
- XmlQueryTypeFactory.cs
- SymDocumentType.cs
- XamlToRtfParser.cs
- Configuration.cs
- DataControlLinkButton.cs
- XmlObjectSerializerWriteContextComplex.cs
- ScriptReferenceBase.cs
- CustomValidator.cs
- AnnotationDocumentPaginator.cs
- EmptyStringExpandableObjectConverter.cs
- InvalidCommandTreeException.cs
- PropertyPathConverter.cs
- TypeSystem.cs
- ToolStripPanelRow.cs
- DesignRelationCollection.cs
- ApplicationDirectoryMembershipCondition.cs
- NameValueCollection.cs
- XmlReturnReader.cs
- columnmapfactory.cs
- MenuItemStyleCollection.cs
- LinqDataSource.cs
- Container.cs
- EndGetFileNameFromUserRequest.cs
- ListMarkerLine.cs
- ZipPackage.cs
- FastPropertyAccessor.cs
- DataGridParentRows.cs
- ConfigurationPropertyCollection.cs
- BufferBuilder.cs
- ECDiffieHellmanPublicKey.cs
- InstanceKeyCollisionException.cs
- PreviewKeyDownEventArgs.cs
- XPathArrayIterator.cs
- TemplateInstanceAttribute.cs
- SymLanguageType.cs
- QuaternionAnimation.cs
- XhtmlBasicTextBoxAdapter.cs
- loginstatus.cs
- CodeDirectiveCollection.cs
- QualifiedCellIdBoolean.cs
- ItemCollection.cs
- MobileUserControl.cs
- ExtendedPropertyDescriptor.cs