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
- HtmlEncodedRawTextWriter.cs
- TypeDescriptor.cs
- Console.cs
- CatalogZone.cs
- ProgressChangedEventArgs.cs
- Point3DCollection.cs
- Zone.cs
- LicFileLicenseProvider.cs
- ProxyGenerator.cs
- OptimizedTemplateContentHelper.cs
- PassportAuthentication.cs
- TreeView.cs
- HttpCookiesSection.cs
- ExeContext.cs
- MimeTypeMapper.cs
- GenericAuthenticationEventArgs.cs
- DialogDivider.cs
- UIHelper.cs
- WebPartConnection.cs
- ReliableChannelListener.cs
- Button.cs
- TreeViewItem.cs
- XmlTextReaderImplHelpers.cs
- DBSchemaTable.cs
- ListViewDataItem.cs
- StateInitializationDesigner.cs
- ListBox.cs
- TransactionManagerProxy.cs
- Annotation.cs
- DependentList.cs
- OdbcConnectionFactory.cs
- DocumentViewer.cs
- BitmapScalingModeValidation.cs
- WebPartVerbCollection.cs
- StatusBarPanelClickEvent.cs
- ProcessModelInfo.cs
- WsatExtendedInformation.cs
- XmlSchemaAny.cs
- DebuggerAttributes.cs
- MediaEntryAttribute.cs
- TemplateComponentConnector.cs
- ToolboxBitmapAttribute.cs
- Selection.cs
- BitmapEffectInputConnector.cs
- HttpWebResponse.cs
- PolyLineSegment.cs
- WinCategoryAttribute.cs
- ApplicationSecurityManager.cs
- TabPage.cs
- QualifiedCellIdBoolean.cs
- Material.cs
- PkcsMisc.cs
- NameValueConfigurationElement.cs
- XmlMtomWriter.cs
- HttpModuleAction.cs
- GZipDecoder.cs
- NestPullup.cs
- StdValidatorsAndConverters.cs
- DocumentViewerAutomationPeer.cs
- RectKeyFrameCollection.cs
- DataBoundControlHelper.cs
- PropVariant.cs
- RootBrowserWindowAutomationPeer.cs
- FrameworkElement.cs
- Visual.cs
- TokenBasedSetEnumerator.cs
- CodeSubDirectory.cs
- RowUpdatingEventArgs.cs
- CreateUserWizard.cs
- ComponentSerializationService.cs
- SQLResource.cs
- DefinitionBase.cs
- CustomAttributeFormatException.cs
- RemoteWebConfigurationHost.cs
- BidPrivateBase.cs
- SoapMessage.cs
- login.cs
- CodePrimitiveExpression.cs
- XPathScanner.cs
- AxisAngleRotation3D.cs
- XsltConvert.cs
- ArrayHelper.cs
- ArrangedElementCollection.cs
- GCHandleCookieTable.cs
- ExpandSegmentCollection.cs
- CreateSequenceResponse.cs
- EditorZoneBase.cs
- DataTableExtensions.cs
- ToolStripDropDownClosingEventArgs.cs
- CodeAssignStatement.cs
- AmbientEnvironment.cs
- PasswordRecoveryAutoFormat.cs
- PlatformCulture.cs
- UTF8Encoding.cs
- DbException.cs
- TaskExtensions.cs
- StylusDevice.cs
- ClusterUtils.cs
- LabelLiteral.cs
- CryptoKeySecurity.cs