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
- PersonalizationDictionary.cs
- EventToken.cs
- XmlDataProvider.cs
- InternalControlCollection.cs
- RoutedCommand.cs
- PerformanceCounterLib.cs
- AjaxFrameworkAssemblyAttribute.cs
- GeometryGroup.cs
- CategoryNameCollection.cs
- TransactionOptions.cs
- ClickablePoint.cs
- StoreItemCollection.cs
- Int32CAMarshaler.cs
- MsmqIntegrationChannelListener.cs
- Int64.cs
- MemoryStream.cs
- TextSelectionHelper.cs
- CollectionViewGroupInternal.cs
- SqlCommandAsyncResult.cs
- CheckBoxField.cs
- GeneralTransform.cs
- DataErrorValidationRule.cs
- ExpressionPrinter.cs
- BooleanFacetDescriptionElement.cs
- ChildrenQuery.cs
- ArrayHelper.cs
- Sql8ConformanceChecker.cs
- SecurityToken.cs
- UmAlQuraCalendar.cs
- Lasso.cs
- ThemeDirectoryCompiler.cs
- TrackingServices.cs
- SiteMapNodeItem.cs
- QuaternionAnimation.cs
- TextEditor.cs
- BStrWrapper.cs
- CookieHandler.cs
- TypeSchema.cs
- FrugalMap.cs
- DbQueryCommandTree.cs
- Propagator.ExtentPlaceholderCreator.cs
- SoapMessage.cs
- IxmlLineInfo.cs
- WorkerRequest.cs
- RegexWriter.cs
- Geometry.cs
- TextLineResult.cs
- PersistenceProviderDirectory.cs
- BufferedOutputStream.cs
- MailAddressCollection.cs
- TripleDES.cs
- KnownTypesProvider.cs
- UnsafeNativeMethods.cs
- OdbcConnectionString.cs
- SerialErrors.cs
- ProxyFragment.cs
- MenuItem.cs
- MetafileHeaderWmf.cs
- KnownTypes.cs
- FileDialog_Vista.cs
- CommandField.cs
- SourceLineInfo.cs
- AnnotationService.cs
- Clock.cs
- MemoryFailPoint.cs
- VariableExpressionConverter.cs
- RawKeyboardInputReport.cs
- BindingExpressionBase.cs
- FontFamily.cs
- ProcessInfo.cs
- MemberRelationshipService.cs
- METAHEADER.cs
- PackWebResponse.cs
- SQLGuidStorage.cs
- DataGridItemAttachedStorage.cs
- QueryHandler.cs
- ConsumerConnectionPoint.cs
- Tool.cs
- FlowLayout.cs
- FamilyTypefaceCollection.cs
- XPathDescendantIterator.cs
- UIHelper.cs
- LoginViewDesigner.cs
- TransformerInfoCollection.cs
- ContentPlaceHolder.cs
- DeviceSpecificChoiceCollection.cs
- RowUpdatingEventArgs.cs
- RenderingEventArgs.cs
- EditorPart.cs
- XmlSchemaFacet.cs
- XmlSchemaAnnotation.cs
- FrameDimension.cs
- RowUpdatedEventArgs.cs
- WarningException.cs
- TCEAdapterGenerator.cs
- XmlLoader.cs
- DataGridViewToolTip.cs
- odbcmetadatafactory.cs
- LinearGradientBrush.cs
- listitem.cs