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
- AdornerPresentationContext.cs
- ExpressionNormalizer.cs
- FamilyTypeface.cs
- EpmSyndicationContentSerializer.cs
- SqlNamer.cs
- MemberJoinTreeNode.cs
- RedistVersionInfo.cs
- GridViewSelectEventArgs.cs
- XLinq.cs
- UntypedNullExpression.cs
- ApplicationFileCodeDomTreeGenerator.cs
- ToolStripProfessionalLowResolutionRenderer.cs
- SafeArchiveContext.cs
- RecordBuilder.cs
- SchemaImporterExtensionElementCollection.cs
- CellParaClient.cs
- SqlFormatter.cs
- RoleGroupCollection.cs
- SimpleModelProvider.cs
- DataGridPagerStyle.cs
- XmlIgnoreAttribute.cs
- FixedSOMFixedBlock.cs
- Executor.cs
- TextSchema.cs
- OneWayBindingElementImporter.cs
- SqlBulkCopyColumnMappingCollection.cs
- RepeatBehavior.cs
- SqlDataSourceCache.cs
- StatusBar.cs
- ApplicationInfo.cs
- PageRequestManager.cs
- ChangeToolStripParentVerb.cs
- __Filters.cs
- VirtualDirectoryMapping.cs
- ProjectionQueryOptionExpression.cs
- Trace.cs
- TextDocumentView.cs
- RtfControlWordInfo.cs
- SyndicationItemFormatter.cs
- ArrangedElement.cs
- NameTable.cs
- RulePatternOps.cs
- FormsAuthenticationUserCollection.cs
- Nullable.cs
- SimplePropertyEntry.cs
- PartialClassGenerationTask.cs
- EnumerableCollectionView.cs
- BinarySerializer.cs
- PersonalizationDictionary.cs
- ComNativeDescriptor.cs
- EventLogRecord.cs
- WebPartEventArgs.cs
- TemplateBaseAction.cs
- DataRowView.cs
- StyleSheetRefUrlEditor.cs
- TouchFrameEventArgs.cs
- HttpContext.cs
- VisualStyleRenderer.cs
- DbConnectionClosed.cs
- LateBoundBitmapDecoder.cs
- StringSorter.cs
- DataTableTypeConverter.cs
- XmlBinaryReader.cs
- SupportingTokenAuthenticatorSpecification.cs
- AdapterDictionary.cs
- QueryIntervalOp.cs
- FocusTracker.cs
- UdpSocketReceiveManager.cs
- UrlMapping.cs
- BaseTemplateCodeDomTreeGenerator.cs
- TextSelectionHighlightLayer.cs
- path.cs
- FormViewInsertEventArgs.cs
- GridViewSelectEventArgs.cs
- MsmqReceiveHelper.cs
- TraceLevelStore.cs
- LocalsItemDescription.cs
- DBSqlParserTableCollection.cs
- ArgIterator.cs
- CounterSample.cs
- ArrangedElement.cs
- MexTcpBindingCollectionElement.cs
- IconHelper.cs
- PlainXmlSerializer.cs
- RenderData.cs
- RSAPKCS1SignatureFormatter.cs
- JpegBitmapEncoder.cs
- XPathParser.cs
- COM2Properties.cs
- TimeoutValidationAttribute.cs
- RtfFormatStack.cs
- AttributeUsageAttribute.cs
- NamespaceEmitter.cs
- WebPartConnectionsCancelVerb.cs
- SystemWebCachingSectionGroup.cs
- CollectionDataContract.cs
- MailWebEventProvider.cs
- SqlTriggerAttribute.cs
- TempFiles.cs
- CheckBox.cs