Code:
/ 4.0 / 4.0 / DEVDIV_TFS / Dev10 / Releases / RTMRel / ndp / cdf / src / WF / RunTime / Hosting / DefaultWorkflowTransactionService.cs / 1305376 / DefaultWorkflowTransactionService.cs
//------------------------------------------------------------------------------ //// Copyright (c) Microsoft Corporation. All rights reserved. // //----------------------------------------------------------------------------- using System; using System.Transactions; using System.Collections.Specialized; using System.Diagnostics; using System.Configuration; namespace System.Workflow.Runtime.Hosting { ///A simple TransactionService that creates /// public class DefaultWorkflowCommitWorkBatchService : WorkflowCommitWorkBatchService { private bool _enableRetries = false; private bool _ignoreCommonEnableRetries = false; public DefaultWorkflowCommitWorkBatchService() { } public DefaultWorkflowCommitWorkBatchService(NameValueCollection parameters) { if (parameters == null) throw new ArgumentNullException("parameters", ExecutionStringManager.MissingParameters); if (parameters.Count > 0) { foreach (string key in parameters.Keys) { if (0 == string.Compare("EnableRetries", key, StringComparison.OrdinalIgnoreCase)) { _enableRetries = bool.Parse(parameters[key]); _ignoreCommonEnableRetries = true; } } } } public bool EnableRetries { get { return _enableRetries; } set { _enableRetries = value; _ignoreCommonEnableRetries = true; } } protected internal override void Start() { WorkflowTrace.Host.TraceEvent(TraceEventType.Information, 0, "DefaultWorkflowCommitWorkBatchService: Starting"); // // If we didn't find a local value for enable retries // check in the common section if ((!_ignoreCommonEnableRetries)&&(null != base.Runtime)) { NameValueConfigurationCollection commonConfigurationParameters = base.Runtime.CommonParameters; if (commonConfigurationParameters != null) { // Then scan for connection string in the common configuration parameters section foreach (string key in commonConfigurationParameters.AllKeys) { if (string.Compare("EnableRetries", key, StringComparison.OrdinalIgnoreCase) == 0) { _enableRetries = bool.Parse(commonConfigurationParameters[key].Value); break; } } } } base.Start(); } protected override void OnStopped() { WorkflowTrace.Host.TraceEvent(TraceEventType.Information, 0, "DefaultWorkflowCommitWorkBatchService: Stopping"); base.OnStopped(); } internal protected override void CommitWorkBatch(CommitWorkBatchCallback commitWorkBatchCallback) { DbRetry dbRetry = new DbRetry(_enableRetries); short retryCounter = 0; while (true) { if (null != Transaction.Current) { // // Can't retry as we don't own the tx // Set the counter to only allow one iteration retryCounter = dbRetry.MaxRetries; } try { base.CommitWorkBatch(commitWorkBatchCallback); break; } catch( Exception e ) { WorkflowTrace.Host.TraceEvent(TraceEventType.Error, 0, "DefaultWorkflowCommitWorkBatchService caught exception from commitWorkBatchCallback: " + e.ToString()); if (dbRetry.TryDoRetry(ref retryCounter)) { WorkflowTrace.Host.TraceEvent(TraceEventType.Information, 0, "DefaultWorkflowCommitWorkBatchService retrying commitWorkBatchCallback (retry attempt " + retryCounter.ToString(System.Globalization.CultureInfo.InvariantCulture) + ")"); continue; } else throw; } } } } } // File provided for Reference Use Only by Microsoft Corporation (c) 2007. //------------------------------------------------------------------------------ //System.Transactions.CommittableTransaction .// Copyright (c) Microsoft Corporation. All rights reserved. // //----------------------------------------------------------------------------- using System; using System.Transactions; using System.Collections.Specialized; using System.Diagnostics; using System.Configuration; namespace System.Workflow.Runtime.Hosting { ///A simple TransactionService that creates /// public class DefaultWorkflowCommitWorkBatchService : WorkflowCommitWorkBatchService { private bool _enableRetries = false; private bool _ignoreCommonEnableRetries = false; public DefaultWorkflowCommitWorkBatchService() { } public DefaultWorkflowCommitWorkBatchService(NameValueCollection parameters) { if (parameters == null) throw new ArgumentNullException("parameters", ExecutionStringManager.MissingParameters); if (parameters.Count > 0) { foreach (string key in parameters.Keys) { if (0 == string.Compare("EnableRetries", key, StringComparison.OrdinalIgnoreCase)) { _enableRetries = bool.Parse(parameters[key]); _ignoreCommonEnableRetries = true; } } } } public bool EnableRetries { get { return _enableRetries; } set { _enableRetries = value; _ignoreCommonEnableRetries = true; } } protected internal override void Start() { WorkflowTrace.Host.TraceEvent(TraceEventType.Information, 0, "DefaultWorkflowCommitWorkBatchService: Starting"); // // If we didn't find a local value for enable retries // check in the common section if ((!_ignoreCommonEnableRetries)&&(null != base.Runtime)) { NameValueConfigurationCollection commonConfigurationParameters = base.Runtime.CommonParameters; if (commonConfigurationParameters != null) { // Then scan for connection string in the common configuration parameters section foreach (string key in commonConfigurationParameters.AllKeys) { if (string.Compare("EnableRetries", key, StringComparison.OrdinalIgnoreCase) == 0) { _enableRetries = bool.Parse(commonConfigurationParameters[key].Value); break; } } } } base.Start(); } protected override void OnStopped() { WorkflowTrace.Host.TraceEvent(TraceEventType.Information, 0, "DefaultWorkflowCommitWorkBatchService: Stopping"); base.OnStopped(); } internal protected override void CommitWorkBatch(CommitWorkBatchCallback commitWorkBatchCallback) { DbRetry dbRetry = new DbRetry(_enableRetries); short retryCounter = 0; while (true) { if (null != Transaction.Current) { // // Can't retry as we don't own the tx // Set the counter to only allow one iteration retryCounter = dbRetry.MaxRetries; } try { base.CommitWorkBatch(commitWorkBatchCallback); break; } catch( Exception e ) { WorkflowTrace.Host.TraceEvent(TraceEventType.Error, 0, "DefaultWorkflowCommitWorkBatchService caught exception from commitWorkBatchCallback: " + e.ToString()); if (dbRetry.TryDoRetry(ref retryCounter)) { WorkflowTrace.Host.TraceEvent(TraceEventType.Information, 0, "DefaultWorkflowCommitWorkBatchService retrying commitWorkBatchCallback (retry attempt " + retryCounter.ToString(System.Globalization.CultureInfo.InvariantCulture) + ")"); continue; } else throw; } } } } } // File provided for Reference Use Only by Microsoft Corporation (c) 2007.System.Transactions.CommittableTransaction .
Link Menu
This book is available now!
Buy at Amazon US or
Buy at Amazon UK
- StringConverter.cs
- FixedSOMTableRow.cs
- CodeNamespaceImport.cs
- TextCharacters.cs
- streamingZipPartStream.cs
- WindowsFormsLinkLabel.cs
- UriParserTemplates.cs
- SqlFacetAttribute.cs
- XamlPointCollectionSerializer.cs
- EmptyReadOnlyDictionaryInternal.cs
- HttpListenerRequest.cs
- AnnotationHighlightLayer.cs
- ImmutableCollection.cs
- BaseTemplateCodeDomTreeGenerator.cs
- SafeViewOfFileHandle.cs
- ColumnWidthChangingEvent.cs
- TreeWalkHelper.cs
- CompressionTransform.cs
- PersonalizationStateInfoCollection.cs
- ProfileParameter.cs
- EntityContainerAssociationSet.cs
- GlyphRun.cs
- CodeTypeOfExpression.cs
- Slider.cs
- AttributeCollection.cs
- WebPartConnectionsCloseVerb.cs
- WebDescriptionAttribute.cs
- NativeMethods.cs
- XmlNodeChangedEventManager.cs
- WindowsContainer.cs
- UnauthorizedAccessException.cs
- SharedDp.cs
- OptimalBreakSession.cs
- TransactionContextValidator.cs
- UInt16Converter.cs
- OleDbRowUpdatingEvent.cs
- ArraySortHelper.cs
- EditorZoneBase.cs
- ProfileGroupSettings.cs
- Stackframe.cs
- BamlLocalizationDictionary.cs
- ToolStripMenuItemCodeDomSerializer.cs
- TransactionScope.cs
- CompositeControl.cs
- FixedSOMTable.cs
- ContactManager.cs
- RotateTransform.cs
- Viewport3DVisual.cs
- ReaderContextStackData.cs
- RowType.cs
- DeviceContexts.cs
- GenericEnumConverter.cs
- TypeValidationEventArgs.cs
- Parameter.cs
- HttpServerUtilityBase.cs
- ShaperBuffers.cs
- ToolStripLabel.cs
- RC2.cs
- ProfileSettingsCollection.cs
- Label.cs
- RequestDescription.cs
- TextTreeInsertUndoUnit.cs
- ObjectContextServiceProvider.cs
- GridView.cs
- MediaTimeline.cs
- KnownIds.cs
- XmlElementCollection.cs
- SiteMapProvider.cs
- ProtocolElement.cs
- KeyGestureValueSerializer.cs
- Control.cs
- SamlAuthenticationStatement.cs
- BoundPropertyEntry.cs
- Latin1Encoding.cs
- ProvidersHelper.cs
- WebResourceAttribute.cs
- EventTrigger.cs
- controlskin.cs
- ChangeDirector.cs
- XmlEventCache.cs
- LocalizationComments.cs
- VisualStyleInformation.cs
- XmlQueryStaticData.cs
- HtmlEncodedRawTextWriter.cs
- RootCodeDomSerializer.cs
- DataGridCell.cs
- EditorZoneBase.cs
- SoundPlayerAction.cs
- BitmapEffectInput.cs
- designeractionlistschangedeventargs.cs
- BeginEvent.cs
- WebPartConnectionsConfigureVerb.cs
- BitConverter.cs
- ActivityExecutionWorkItem.cs
- DefaultValidator.cs
- ObjectSet.cs
- BaseInfoTable.cs
- ConcurrentStack.cs
- PageParser.cs
- ConfigurationSettings.cs