Code:
/ WCF / WCF / 3.5.30729.1 / untmp / Orcas / SP / ndp / cdf / src / WCF / ServiceModel / System / ServiceModel / Channels / TransactionFlowBindingElementImporter.cs / 1 / TransactionFlowBindingElementImporter.cs
//------------------------------------------------------------------------------ // Copyright (c) Microsoft Corporation. All rights reserved. //----------------------------------------------------------------------------- namespace System.ServiceModel.Channels { using System.ServiceModel; using System.ServiceModel.Description; using System.ServiceModel.Security; using System.Xml; using System.Collections.Generic; static class TransactionPolicyStrings { public const string OptionalLocal = MetadataStrings.WSPolicy.Attributes.Optional; public const string OptionalPrefix10 = MetadataStrings.WSPolicy.Prefix + "1"; public const string OptionalPrefix11 = MetadataStrings.WSPolicy.Prefix; public const string OptionalNamespaceLegacy = "http://schemas.xmlsoap.org/ws/2002/12/policy"; public const string WsatTransactionsPrefix = AtomicTransactionExternalStrings.Prefix; public const string WsatTransactionsNamespace10 = AtomicTransactionExternal10Strings.Namespace; public const string WsatTransactionsNamespace11 = AtomicTransactionExternal11Strings.Namespace; public const string WsatTransactionsLocal = "ATAssertion"; public const string OleTxTransactionsPrefix = OleTxTransactionExternalStrings.Prefix; public const string OleTxTransactionsNamespace = OleTxTransactionExternalStrings.Namespace; public const string OleTxTransactionsLocal = "OleTxAssertion"; public const string TrueValue = "true"; } public sealed class TransactionFlowBindingElementImporter : IPolicyImportExtension { void IPolicyImportExtension.ImportPolicy(MetadataImporter importer, PolicyConversionContext context) { if (context == null) { throw DiagnosticUtility.ExceptionUtility.ThrowHelperArgumentNull("context"); } // foreach property, we keep track of // - everyoneAgreesAbout: all operations agree on a value // - anOperationCaresAbout: at least one operation has expressed a preference // - agreed value itself (which only matters if anOperationCaresAbout && everyoneAgrees) bool everyoneAgreesAboutTransactions = true; bool everyoneAgreesAboutTransactionProtocol = true; TransactionFlowOption agreedTransactions = TransactionFlowOption.NotAllowed; TransactionProtocol agreedTransactionProtocol = TransactionFlowDefaults.TransactionProtocol; bool anOperationCaresAboutTransactions = false; bool anOperationCaresAboutTransactionProtocol = false; XmlElement oleTxTransactionsAssertion = null; XmlElement wsatTransactionsAssertion = null; foreach (OperationDescription operation in context.Contract.Operations) { ICollectionoperationAssertions = context.GetOperationBindingAssertions(operation); foreach (XmlElement element in operationAssertions) { if (element.NamespaceURI == TransactionPolicyStrings.OleTxTransactionsNamespace && element.LocalName == TransactionPolicyStrings.OleTxTransactionsLocal) { oleTxTransactionsAssertion = element; TransactionFlowOption txFlow = GetOption(element, true); UpdateTransactionFlowAtribute(operation, txFlow); TrackAgreement(ref everyoneAgreesAboutTransactions, txFlow, ref agreedTransactions, ref anOperationCaresAboutTransactions); TrackAgreementTransactionProtocol(ref everyoneAgreesAboutTransactionProtocol, TransactionProtocol.OleTransactions, ref agreedTransactionProtocol, ref anOperationCaresAboutTransactionProtocol); } else if (element.NamespaceURI == TransactionPolicyStrings.WsatTransactionsNamespace10 && element.LocalName == TransactionPolicyStrings.WsatTransactionsLocal) { wsatTransactionsAssertion = element; TransactionFlowOption txFlow = GetOption(element, true); UpdateTransactionFlowAtribute(operation, txFlow); TrackAgreement(ref everyoneAgreesAboutTransactions, txFlow, ref agreedTransactions, ref anOperationCaresAboutTransactions); TrackAgreementTransactionProtocol(ref everyoneAgreesAboutTransactionProtocol, TransactionProtocol.WSAtomicTransactionOctober2004, ref agreedTransactionProtocol, ref anOperationCaresAboutTransactionProtocol); } else if (element.NamespaceURI == TransactionPolicyStrings.WsatTransactionsNamespace11 && element.LocalName == TransactionPolicyStrings.WsatTransactionsLocal) { wsatTransactionsAssertion = element; TransactionFlowOption txFlow = GetOption(element, false); UpdateTransactionFlowAtribute(operation, txFlow); TrackAgreement(ref everyoneAgreesAboutTransactions, txFlow, ref agreedTransactions, ref anOperationCaresAboutTransactions); TrackAgreementTransactionProtocol(ref everyoneAgreesAboutTransactionProtocol, TransactionProtocol.WSAtomicTransaction11, ref agreedTransactionProtocol, ref anOperationCaresAboutTransactionProtocol); } } // remove any imported assertions. if (oleTxTransactionsAssertion != null) operationAssertions.Remove(oleTxTransactionsAssertion); if (wsatTransactionsAssertion != null) operationAssertions.Remove(wsatTransactionsAssertion); } // setup the ContextFlowBindingElement (if needed) with any agreed-on information if (anOperationCaresAboutTransactions) { TransactionFlowBindingElement tfbe = EnsureBindingElement(context); tfbe.Transactions = true; if (anOperationCaresAboutTransactionProtocol && everyoneAgreesAboutTransactionProtocol) tfbe.TransactionProtocol = agreedTransactionProtocol; else if (anOperationCaresAboutTransactionProtocol) throw DiagnosticUtility.ExceptionUtility.ThrowHelperError(new NotSupportedException( SR.GetString(SR.SFxCannotHaveDifferentTransactionProtocolsInOneBinding))); } } void UpdateTransactionFlowAtribute(OperationDescription operation, TransactionFlowOption txFlow) { operation.Behaviors.Remove (); operation.Behaviors.Add(new TransactionFlowAttribute(txFlow)); } static void TrackAgreement(ref bool everyoneAgrees, TransactionFlowOption option, ref TransactionFlowOption agreedOption, ref bool anOperationCares) { if (!anOperationCares) { // this is the first operation to express a preference agreedOption = option; anOperationCares = true; // everyoneAgrees is still true } else { if (option != agreedOption) everyoneAgrees = false; } } static void TrackAgreementTransactionProtocol(ref bool everyoneAgrees, TransactionProtocol option, ref TransactionProtocol agreedOption, ref bool anOperationCares) { if (!anOperationCares) { // this is the first operation to express a preference agreedOption = option; anOperationCares = true; // everyoneAgrees is still true } else { if (option != agreedOption) everyoneAgrees = false; } } TransactionFlowOption GetOption(XmlElement elem, bool useLegacyNs) { try { if (IsRealOptionalTrue(elem) || (useLegacyNs && IsLegacyOptionalTrue(elem))) { return TransactionFlowOption.Allowed; } return TransactionFlowOption.Mandatory; } catch (FormatException e) { throw DiagnosticUtility.ExceptionUtility.ThrowHelperError(new NotSupportedException( SR.GetString(SR.UnsupportedBooleanAttribute, TransactionPolicyStrings.OptionalLocal, e.Message))); } } static bool IsRealOptionalTrue(XmlElement elem) { string value12 = elem.GetAttribute(TransactionPolicyStrings.OptionalLocal, MetadataStrings.WSPolicy.NamespaceUri); string value15 = elem.GetAttribute(TransactionPolicyStrings.OptionalLocal, MetadataStrings.WSPolicy.NamespaceUri15); return XmlUtil.IsTrue(value12) || XmlUtil.IsTrue(value15); } static bool IsLegacyOptionalTrue(XmlElement elem) { string valueLegacy = elem.GetAttribute(TransactionPolicyStrings.OptionalLocal, TransactionPolicyStrings.OptionalNamespaceLegacy); return XmlUtil.IsTrue(valueLegacy); } TransactionFlowBindingElement EnsureBindingElement(PolicyConversionContext context) { TransactionFlowBindingElement settings = context.BindingElements.Find (); if (settings == null) { settings = new TransactionFlowBindingElement(false); context.BindingElements.Add(settings); } return settings; } } } // 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
- WebMessageEncoderFactory.cs
- SystemUnicastIPAddressInformation.cs
- DataSvcMapFileSerializer.cs
- EFDataModelProvider.cs
- ContentDisposition.cs
- PropertyFilterAttribute.cs
- SqlFileStream.cs
- TextBox.cs
- RC2CryptoServiceProvider.cs
- SystemTcpConnection.cs
- ServicePoint.cs
- AvTraceFormat.cs
- DocumentXmlWriter.cs
- HtmlFormWrapper.cs
- ImageMetadata.cs
- BlurBitmapEffect.cs
- GeneralTransformCollection.cs
- ConnectionManagementElement.cs
- ValueChangedEventManager.cs
- Effect.cs
- IdSpace.cs
- SpeechRecognitionEngine.cs
- DataServiceRequestException.cs
- ConsoleKeyInfo.cs
- PropertyBuilder.cs
- HeaderUtility.cs
- MemberInfoSerializationHolder.cs
- DisplayMemberTemplateSelector.cs
- WrappedKeySecurityTokenParameters.cs
- FileChangesMonitor.cs
- CookielessHelper.cs
- AuthenticationConfig.cs
- SoapReflectionImporter.cs
- _CacheStreams.cs
- TextBlock.cs
- GlyphInfoList.cs
- DateTime.cs
- GeneratedCodeAttribute.cs
- FixUpCollection.cs
- ObjectDataSourceDisposingEventArgs.cs
- RecognizeCompletedEventArgs.cs
- TriggerAction.cs
- RichTextBox.cs
- MetafileHeader.cs
- HttpCachePolicyBase.cs
- ListBoxItemWrapperAutomationPeer.cs
- Rect.cs
- SocketInformation.cs
- ReturnValue.cs
- ObjectConverter.cs
- StringPropertyBuilder.cs
- TaiwanLunisolarCalendar.cs
- KeyNotFoundException.cs
- StylusSystemGestureEventArgs.cs
- ControlPropertyNameConverter.cs
- BaseParser.cs
- SplitterCancelEvent.cs
- WebServiceTypeData.cs
- JapaneseLunisolarCalendar.cs
- MDIWindowDialog.cs
- SiteMapNodeCollection.cs
- LicenseException.cs
- SQLBinaryStorage.cs
- OrderedDictionary.cs
- Tile.cs
- NativeCppClassAttribute.cs
- XsltCompileContext.cs
- SecureEnvironment.cs
- LayoutTable.cs
- AssociationTypeEmitter.cs
- ButtonFlatAdapter.cs
- Utilities.cs
- BitmapEffectDrawingContent.cs
- HealthMonitoringSectionHelper.cs
- DesignerActionService.cs
- TextMarkerSource.cs
- Trace.cs
- EventMappingSettingsCollection.cs
- HttpCapabilitiesSectionHandler.cs
- OnOperation.cs
- ModuleConfigurationInfo.cs
- UInt64Converter.cs
- EntityAdapter.cs
- lengthconverter.cs
- VoiceSynthesis.cs
- FlowchartDesigner.xaml.cs
- ThicknessKeyFrameCollection.cs
- BooleanFunctions.cs
- BamlBinaryWriter.cs
- OrderedEnumerableRowCollection.cs
- IWorkflowDebuggerService.cs
- WindowsUserNameSecurityTokenAuthenticator.cs
- HeaderUtility.cs
- SmtpMail.cs
- DelegatingTypeDescriptionProvider.cs
- InputScope.cs
- HttpDictionary.cs
- XmlDocumentFragment.cs
- RegexCapture.cs
- ConfigurationManagerHelperFactory.cs