Code:
/ Dotnetfx_Win7_3.5.1 / Dotnetfx_Win7_3.5.1 / 3.5.1 / DEVDIV / depot / DevDiv / releases / whidbey / NetFXspW7 / ndp / clr / src / BCL / System / Runtime / Remoting / RemotingSurrogateSelector.cs / 1 / RemotingSurrogateSelector.cs
// ==++== // // Copyright (c) Microsoft Corporation. All rights reserved. // // ==--== namespace System.Runtime.Remoting.Messaging { using System; using System.Runtime.InteropServices; using System.Runtime.Remoting; using System.Runtime.Remoting.Metadata; using System.Runtime.Remoting.Activation; using System.Runtime.Remoting.Proxies; using System.Runtime.Serialization; using System.Runtime.Serialization.Formatters; using System.Text; using System.Reflection; using System.Threading; using System.Globalization; using System.Collections; using System.Security.Permissions; [System.Runtime.InteropServices.ComVisible(true)] public delegate bool MessageSurrogateFilter(String key, Object value); [SecurityPermissionAttribute(SecurityAction.LinkDemand, Flags=SecurityPermissionFlag.Infrastructure)] [SecurityPermissionAttribute(SecurityAction.InheritanceDemand, Flags=SecurityPermissionFlag.Infrastructure)] [System.Runtime.InteropServices.ComVisible(true)] public class RemotingSurrogateSelector : ISurrogateSelector { // Private static data private static Type s_IMethodCallMessageType = typeof(IMethodCallMessage); private static Type s_IMethodReturnMessageType = typeof(IMethodReturnMessage); private static Type s_ObjRefType = typeof(ObjRef); // Private member data private Object _rootObj = null; private ISurrogateSelector _next = null; private RemotingSurrogate _remotingSurrogate = new RemotingSurrogate(); private ObjRefSurrogate _objRefSurrogate = new ObjRefSurrogate(); private ISerializationSurrogate _messageSurrogate = null; private MessageSurrogateFilter _filter = null; public RemotingSurrogateSelector() { _messageSurrogate = new MessageSurrogate(this); } public MessageSurrogateFilter Filter { set { _filter = value; } get { return _filter; } } public void SetRootObject(Object obj) { if (obj == null) { throw new ArgumentNullException("obj"); } _rootObj = obj; SoapMessageSurrogate soapMsg = _messageSurrogate as SoapMessageSurrogate; if (null != soapMsg) { soapMsg.SetRootObject(_rootObj); } } public Object GetRootObject() { return _rootObj; } // Specifies the next ISurrogateSelector to be examined for surrogates if the current // instance doesn't have a surrogate for the given type and assembly in the given context. [SecurityPermissionAttribute(SecurityAction.LinkDemand, Flags=SecurityPermissionFlag.SerializationFormatter)] public virtual void ChainSelector(ISurrogateSelector selector) {_next = selector;} // Returns the appropriate surrogate for the given type in the given context. [SecurityPermissionAttribute(SecurityAction.LinkDemand, Flags=SecurityPermissionFlag.SerializationFormatter)] public virtual ISerializationSurrogate GetSurrogate(Type type, StreamingContext context, out ISurrogateSelector ssout) { if (type == null) { throw new ArgumentNullException("type"); } Message.DebugOut("Entered GetSurrogate for " + type.FullName + "\n"); if (type.IsMarshalByRef) { Message.DebugOut("Selected surrogate for " + type.FullName); ssout = this; return _remotingSurrogate; } else if (s_IMethodCallMessageType.IsAssignableFrom(type) || s_IMethodReturnMessageType.IsAssignableFrom(type)) { ssout = this; return _messageSurrogate; } else if (s_ObjRefType.IsAssignableFrom(type)) { ssout = this; return _objRefSurrogate; } else if (_next != null) { return _next.GetSurrogate(type, context, out ssout); } else { ssout = null; return null; } } // GetSurrogate [SecurityPermissionAttribute(SecurityAction.LinkDemand, Flags=SecurityPermissionFlag.SerializationFormatter)] public virtual ISurrogateSelector GetNextSelector() { return _next;} public virtual void UseSoapFormat() { _messageSurrogate = new SoapMessageSurrogate(this); ((SoapMessageSurrogate)_messageSurrogate).SetRootObject(_rootObj); } } internal class RemotingSurrogate : ISerializationSurrogate { [SecurityPermissionAttribute(SecurityAction.LinkDemand, Flags=SecurityPermissionFlag.SerializationFormatter)] public virtual void GetObjectData(Object obj, SerializationInfo info, StreamingContext context) { if (obj == null) { throw new ArgumentNullException("obj"); } if (info==null) { throw new ArgumentNullException("info"); } // // This code is to special case marshalling types inheriting from RemotingClientProxy // Check whether type inherits from RemotingClientProxy and serialize the correct ObjRef // after getting the correct proxy to the actual server object // Message.DebugOut("RemotingSurrogate::GetObjectData obj.Type: " + obj.GetType().FullName + " \n"); if(RemotingServices.IsTransparentProxy(obj)) { RealProxy rp = RemotingServices.GetRealProxy(obj); rp.GetObjectData(info, context); } else { RemotingServices.GetObjectData(obj, info, context); } } [SecurityPermissionAttribute(SecurityAction.LinkDemand, Flags=SecurityPermissionFlag.SerializationFormatter)] public virtual Object SetObjectData(Object obj, SerializationInfo info, StreamingContext context, ISurrogateSelector selector) { throw new NotSupportedException(Environment.GetResourceString("NotSupported_PopulateData")); } } // class RemotingSurrogate internal class ObjRefSurrogate : ISerializationSurrogate { [SecurityPermissionAttribute(SecurityAction.LinkDemand, Flags=SecurityPermissionFlag.SerializationFormatter)] public virtual void GetObjectData(Object obj, SerializationInfo info, StreamingContext context) { if (obj == null) { throw new ArgumentNullException("obj"); } if (info==null) { throw new ArgumentNullException("info"); } // // This code is to provide special handling for ObjRef's that are supposed // to be passed as parameters. // ((ObjRef)obj).GetObjectData(info, context); // add flag indicating the ObjRef was passed as a parameter info.AddValue("fIsMarshalled", 0); } // GetObjectData [SecurityPermissionAttribute(SecurityAction.LinkDemand, Flags=SecurityPermissionFlag.SerializationFormatter)] public virtual Object SetObjectData(Object obj, SerializationInfo info, StreamingContext context, ISurrogateSelector selector) { throw new NotSupportedException(Environment.GetResourceString("NotSupported_PopulateData")); } } // class ObjRefSurrogate internal class SoapMessageSurrogate : ISerializationSurrogate { // Private static data private static Type _voidType = typeof(void); private static Type _soapFaultType = typeof(SoapFault); // Member data String DefaultFakeRecordAssemblyName = "http://schemas.microsoft.com/urt/SystemRemotingSoapTopRecord"; Object _rootObj = null; RemotingSurrogateSelector _ss; internal SoapMessageSurrogate(RemotingSurrogateSelector ss) { _ss = ss; } internal void SetRootObject(Object obj) { _rootObj = obj; } internal virtual String[] GetInArgNames(IMethodCallMessage m, int c) { String[] names = new String[c]; for (int i = 0; i < c; i++) { String name = m.GetInArgName(i); if (name == null) { name = "__param" + i; } names[i] = name; } return names; } internal virtual String[] GetNames(IMethodCallMessage m, int c) { String[] names = new String[c]; for (int i = 0; i < c; i++) { String name = m.GetArgName(i); if (name == null) { name = "__param" + i; } names[i] = name; } return names; } [SecurityPermissionAttribute(SecurityAction.LinkDemand, Flags=SecurityPermissionFlag.SerializationFormatter)] public virtual void GetObjectData(Object obj, SerializationInfo info, StreamingContext context) { if (info==null) { throw new ArgumentNullException("info"); } if ( (obj!=null) && (obj !=_rootObj)) { (new MessageSurrogate(_ss)).GetObjectData(obj, info, context); } else { IMethodReturnMessage msg = obj as IMethodReturnMessage; if(null != msg) { if (msg.Exception == null) { String responseElementName; String responseElementNS; String returnElementName; // obtain response element name namespace MethodBase mb = msg.MethodBase; SoapMethodAttribute attr = (SoapMethodAttribute)InternalRemotingServices.GetCachedSoapAttribute(mb); responseElementName = attr.ResponseXmlElementName; responseElementNS = attr.ResponseXmlNamespace; returnElementName = attr.ReturnXmlElementName; ArgMapper mapper = new ArgMapper(msg, true /*fOut*/); Object[] args = mapper.Args; info.FullTypeName = responseElementName; info.AssemblyName = responseElementNS; Type retType = ((MethodInfo)mb).ReturnType; if (!((retType == null) || (retType == _voidType))) { info.AddValue(returnElementName, msg.ReturnValue, retType); } if (args != null) { Type[] types = mapper.ArgTypes; for (int i=0; i
Link Menu
This book is available now!
Buy at Amazon US or
Buy at Amazon UK
- DataServiceConfiguration.cs
- DesignerVerb.cs
- ComboBoxAutomationPeer.cs
- SafeHandle.cs
- PaperSize.cs
- KeyPullup.cs
- NumberFormatInfo.cs
- CRYPTPROTECT_PROMPTSTRUCT.cs
- MetabaseReader.cs
- xml.cs
- HasCopySemanticsAttribute.cs
- ModuleElement.cs
- WaitHandleCannotBeOpenedException.cs
- Int16Storage.cs
- SortExpressionBuilder.cs
- DynamicDataManager.cs
- TextElementEnumerator.cs
- IListConverters.cs
- ToolStripDropDownClosedEventArgs.cs
- AuthenticationModulesSection.cs
- FunctionImportMapping.ReturnTypeRenameMapping.cs
- MethodBuilderInstantiation.cs
- SignatureToken.cs
- BypassElementCollection.cs
- Package.cs
- PreparingEnlistment.cs
- DragCompletedEventArgs.cs
- SwitchLevelAttribute.cs
- JsonQNameDataContract.cs
- PrintingPermission.cs
- DefaultEventAttribute.cs
- CodePropertyReferenceExpression.cs
- PathGeometry.cs
- ArrayHelper.cs
- Color.cs
- ToolStripSeparatorRenderEventArgs.cs
- CoreChannel.cs
- CommandDesigner.cs
- InlineCollection.cs
- ListViewUpdateEventArgs.cs
- TraceFilter.cs
- CryptographicAttribute.cs
- PassportAuthentication.cs
- DBCommand.cs
- DataGridViewAdvancedBorderStyle.cs
- DescriptionAttribute.cs
- StructuredProperty.cs
- DataServiceCollectionOfT.cs
- HttpWrapper.cs
- Window.cs
- LinqDataSourceInsertEventArgs.cs
- HuffModule.cs
- SortableBindingList.cs
- Wow64ConfigurationLoader.cs
- RegexGroupCollection.cs
- CrossSiteScriptingValidation.cs
- WindowsEditBox.cs
- Hash.cs
- BoundingRectTracker.cs
- WebServiceTypeData.cs
- SafeMILHandleMemoryPressure.cs
- Grammar.cs
- TrustManagerPromptUI.cs
- ReflectionPermission.cs
- FieldBuilder.cs
- PngBitmapDecoder.cs
- FileDialog_Vista.cs
- HijriCalendar.cs
- CommaDelimitedStringAttributeCollectionConverter.cs
- RenderData.cs
- HelpKeywordAttribute.cs
- AuthorizationRuleCollection.cs
- BaseAppDomainProtocolHandler.cs
- WeakHashtable.cs
- EntityDataSourceChangedEventArgs.cs
- ADMembershipUser.cs
- KeyManager.cs
- DocumentOrderQuery.cs
- CodeMemberMethod.cs
- EntityDataSourceViewSchema.cs
- RootBrowserWindowAutomationPeer.cs
- CompositeDataBoundControl.cs
- JsonFormatGeneratorStatics.cs
- QueryOutputWriter.cs
- DockPatternIdentifiers.cs
- EntryPointNotFoundException.cs
- NullRuntimeConfig.cs
- BrowserCapabilitiesFactoryBase.cs
- AspNetPartialTrustHelpers.cs
- DataGridPagerStyle.cs
- PanelContainerDesigner.cs
- OleTxTransaction.cs
- SafeMILHandleMemoryPressure.cs
- SuppressIldasmAttribute.cs
- VirtualPath.cs
- CodeConditionStatement.cs
- manifestimages.cs
- ActivityWithResultWrapper.cs
- LinqDataSourceInsertEventArgs.cs
- AccessorTable.cs