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
- GenericsInstances.cs
- X509CertificateValidator.cs
- IdleTimeoutMonitor.cs
- WebPartsPersonalization.cs
- CompilerParameters.cs
- MouseBinding.cs
- HtmlInputSubmit.cs
- SessionIDManager.cs
- TypeSource.cs
- ManipulationDevice.cs
- UnionCqlBlock.cs
- validation.cs
- LogicalTreeHelper.cs
- StaticFileHandler.cs
- PeerContact.cs
- MenuItemBindingCollection.cs
- SrgsSubset.cs
- GrabHandleGlyph.cs
- LinqDataSourceInsertEventArgs.cs
- WindowsBrush.cs
- templategroup.cs
- HtmlTernaryTree.cs
- TagPrefixAttribute.cs
- DefaultHttpHandler.cs
- OleDbTransaction.cs
- PanelStyle.cs
- FamilyTypefaceCollection.cs
- CacheEntry.cs
- PolyBezierSegment.cs
- ToolStripSettings.cs
- IsolatedStoragePermission.cs
- InvokePattern.cs
- EntityConnection.cs
- X509SecurityTokenAuthenticator.cs
- WebPartMenuStyle.cs
- AsyncDataRequest.cs
- XmlSchemaSimpleContentRestriction.cs
- SamlSecurityTokenAuthenticator.cs
- OdbcConnection.cs
- AssemblyName.cs
- ExpressionNode.cs
- DtrList.cs
- DataTableReader.cs
- Int64Storage.cs
- ActivityMarkupSerializer.cs
- MasterPageParser.cs
- GridViewDeletedEventArgs.cs
- VectorValueSerializer.cs
- ECDsa.cs
- IsolatedStorage.cs
- input.cs
- CompareValidator.cs
- basecomparevalidator.cs
- XmlSerializerNamespaces.cs
- AssemblyUtil.cs
- HttpListenerContext.cs
- Win32PrintDialog.cs
- SpecularMaterial.cs
- BinaryWriter.cs
- MultilineStringEditor.cs
- Point3DConverter.cs
- MutexSecurity.cs
- RowToFieldTransformer.cs
- OperationResponse.cs
- ExpressionBindingsDialog.cs
- WindowsFormsHostAutomationPeer.cs
- NotificationContext.cs
- GridViewDeletedEventArgs.cs
- X509SecurityTokenAuthenticator.cs
- CryptoStream.cs
- AvTrace.cs
- ZoneLinkButton.cs
- VirtualPathExtension.cs
- EntityReference.cs
- CodeSubDirectoriesCollection.cs
- ListViewGroupConverter.cs
- ResXResourceSet.cs
- SapiInterop.cs
- ItemCheckedEvent.cs
- CodeValidator.cs
- SiteMapDataSourceDesigner.cs
- WriteFileContext.cs
- StylusPlugin.cs
- LinkConverter.cs
- WeakReferenceList.cs
- CompiledXpathExpr.cs
- EntityDataSourceReferenceGroup.cs
- StrokeRenderer.cs
- GestureRecognitionResult.cs
- HttpCachePolicyElement.cs
- UnauthorizedWebPart.cs
- SoapObjectReader.cs
- XmlTypeAttribute.cs
- UpdateEventArgs.cs
- ExpressionConverter.cs
- KeyFrames.cs
- TextEncodedRawTextWriter.cs
- PropertyItem.cs
- BamlRecords.cs
- NavigatorInput.cs