Code:
/ WCF / WCF / 3.5.30729.1 / untmp / Orcas / SP / ndp / cdf / src / WCF / ServiceModel / System / ServiceModel / MessageHeaderT.cs / 1 / MessageHeaderT.cs
//------------------------------------------------------------------------------ // Copyright (c) Microsoft Corporation. All rights reserved. //----------------------------------------------------------------------------- namespace System.ServiceModel { using System.Collections.Generic; using System.ServiceModel.Channels; using System.Threading; public class MessageHeader{ string actor; bool mustUnderstand; bool relay; T content; public MessageHeader() { } public MessageHeader(T content) : this(content, false, "", false) { } public MessageHeader(T content, bool mustUnderstand, string actor, bool relay) { this.content = content; this.mustUnderstand = mustUnderstand; this.actor = actor; this.relay = relay; } public string Actor { get { return this.actor; } set { this.actor = value; } } public T Content { get { return this.content; } set { this.content = value; } } public bool MustUnderstand { get { return this.mustUnderstand; } set { this.mustUnderstand = value; } } public bool Relay { get { return this.relay; } set { this.relay = value; } } internal Type GetGenericArgument() { return typeof(T); } public MessageHeader GetUntypedHeader(string name, string ns) { return MessageHeader.CreateHeader(name, ns, this.content, this.mustUnderstand, this.actor, this.relay); } } // problem: creating / getting content / settings content on a MessageHeader given the type at runtime // require reflection. // solution: This class creates a cache of adapters that provide an untyped wrapper over a particular // MessageHeader instantiation. // better solution: implement something like "IUntypedTypedHeader" that has a "object Content" property, // privately implement this on TypedHeader, and then just use that iface to operation on the header (actually // you'd still have the creation problem...). the issue with that is you now have a new public interface internal abstract class TypedHeaderManager { static Dictionary cache = new Dictionary (); static ReaderWriterLock cacheLock = new ReaderWriterLock(); static Type GenericAdapterType = typeof(GenericAdapter<>); internal static object Create(Type t, object content, bool mustUnderstand, bool relay, string actor) { return GetTypedHeaderManager(t).Create(content, mustUnderstand, relay, actor); } internal static object GetContent(Type t, object typedHeaderInstance, out bool mustUnderstand, out bool relay, out string actor) { return GetTypedHeaderManager(t).GetContent(typedHeaderInstance, out mustUnderstand, out relay, out actor); } internal static Type GetMessageHeaderType(Type contentType) { return GetTypedHeaderManager(contentType).GetMessageHeaderType(); } internal static Type GetHeaderType(Type headerParameterType) { if (headerParameterType.IsGenericType && headerParameterType.GetGenericTypeDefinition() == typeof(MessageHeader<>)) return headerParameterType.GetGenericArguments()[0]; return headerParameterType; } static TypedHeaderManager GetTypedHeaderManager(Type t) { TypedHeaderManager result = null; bool lockHeld = false; try { try { } finally { cacheLock.AcquireReaderLock(int.MaxValue); lockHeld = true; } if (!cache.TryGetValue(t, out result)) { cacheLock.UpgradeToWriterLock(int.MaxValue); result = (TypedHeaderManager)Activator.CreateInstance(GenericAdapterType.MakeGenericType(t)); cache.Add(t, result); } } finally { if (lockHeld) { cacheLock.ReleaseLock(); } } return result; } protected abstract object Create(object content, bool mustUnderstand, bool relay, string actor); protected abstract object GetContent(object typedHeaderInstance, out bool mustUnderstand, out bool relay, out string actor); protected abstract Type GetMessageHeaderType(); class GenericAdapter : TypedHeaderManager { protected override object Create(object content, bool mustUnderstand, bool relay, string actor) { MessageHeader header = new MessageHeader (); header.Content = (T)content; header.MustUnderstand = mustUnderstand; header.Relay = relay; header.Actor = actor; return header; } protected override object GetContent(object typedHeaderInstance, out bool mustUnderstand, out bool relay, out string actor) { mustUnderstand = false; relay = false; actor = null; if (typedHeaderInstance == null) return null; MessageHeader header = typedHeaderInstance as MessageHeader ; if (header == null) throw DiagnosticUtility.ExceptionUtility.ThrowHelperError(new ArgumentException("typedHeaderInstance")); mustUnderstand = header.MustUnderstand; relay = header.Relay; actor = header.Actor; return header.Content; } protected override Type GetMessageHeaderType() { return typeof(MessageHeader ); } } } } // File provided for Reference Use Only by Microsoft Corporation (c) 2007. // Copyright (c) Microsoft Corporation. All rights reserved.
Link Menu
This book is available now!
Buy at Amazon US or
Buy at Amazon UK
- TypeElement.cs
- PageBuildProvider.cs
- XmlSerializationGeneratedCode.cs
- FontCollection.cs
- CTreeGenerator.cs
- ToolStripOverflowButton.cs
- serverconfig.cs
- WebPartDisplayModeCollection.cs
- BatchParser.cs
- ListViewDeleteEventArgs.cs
- SourceLocationProvider.cs
- DispatcherEventArgs.cs
- ContainerVisual.cs
- FlowDocumentReader.cs
- SmtpDigestAuthenticationModule.cs
- EntityParameter.cs
- Accessible.cs
- xmlformatgeneratorstatics.cs
- ModelPropertyImpl.cs
- BatchServiceHost.cs
- PersonalizationStateInfoCollection.cs
- SkewTransform.cs
- AuthenticationServiceManager.cs
- JsonFormatMapping.cs
- Rfc2898DeriveBytes.cs
- SQLInt64Storage.cs
- RunWorkerCompletedEventArgs.cs
- GetWinFXPath.cs
- PermissionSetEnumerator.cs
- AddInStore.cs
- UpdateException.cs
- ClockGroup.cs
- DescendantQuery.cs
- IsolatedStorageException.cs
- FixedSOMTableCell.cs
- StorageEndPropertyMapping.cs
- NameValueFileSectionHandler.cs
- VoiceChangeEventArgs.cs
- DataViewSetting.cs
- CqlErrorHelper.cs
- WebRequestModulesSection.cs
- WebBrowserEvent.cs
- PropertyItem.cs
- XPathPatternParser.cs
- PasswordTextContainer.cs
- ToolStripContentPanelRenderEventArgs.cs
- ComplexBindingPropertiesAttribute.cs
- StreamWithDictionary.cs
- BitmapEffectGeneralTransform.cs
- Expression.cs
- Label.cs
- ReadOnlyDictionary.cs
- DataMemberAttribute.cs
- HeaderLabel.cs
- SoapServerMethod.cs
- EpmContentSerializer.cs
- Oid.cs
- ProtocolViolationException.cs
- AspNetHostingPermission.cs
- CommandHelper.cs
- SchemaTableColumn.cs
- ParentQuery.cs
- _BaseOverlappedAsyncResult.cs
- DocumentReference.cs
- MultiPartWriter.cs
- XmlQueryRuntime.cs
- BypassElementCollection.cs
- SqlCrossApplyToCrossJoin.cs
- RequiredAttributeAttribute.cs
- CommonServiceBehaviorElement.cs
- TemplateXamlParser.cs
- wmiprovider.cs
- DependencyObjectProvider.cs
- DataRelationPropertyDescriptor.cs
- Identity.cs
- TemplateXamlParser.cs
- CompareValidator.cs
- BaseTransportHeaders.cs
- StaticSiteMapProvider.cs
- CheckBox.cs
- SystemInfo.cs
- ManagementInstaller.cs
- sqlstateclientmanager.cs
- ScrollViewer.cs
- SystemParameters.cs
- RectKeyFrameCollection.cs
- SystemSounds.cs
- CompilerResults.cs
- EntityRecordInfo.cs
- WindowsTokenRoleProvider.cs
- ACL.cs
- CommonDialog.cs
- TextPointer.cs
- AnalyzedTree.cs
- UIElementCollection.cs
- XPathEmptyIterator.cs
- ScriptReferenceEventArgs.cs
- InstanceContextManager.cs
- SHA1CryptoServiceProvider.cs
- OptimisticConcurrencyException.cs