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
- VarRefManager.cs
- ThousandthOfEmRealDoubles.cs
- ExportFileRequest.cs
- CookieHandler.cs
- Help.cs
- ExtendedPropertyDescriptor.cs
- RawStylusInputCustomDataList.cs
- AsyncResult.cs
- CookieProtection.cs
- XmlReaderSettings.cs
- AccessControlList.cs
- XmlSerializerFactory.cs
- NativeMethods.cs
- ValidationSummary.cs
- MiniLockedBorderGlyph.cs
- ToolStripSplitButton.cs
- RoutingConfiguration.cs
- AuthenticationModulesSection.cs
- XmlTextReaderImplHelpers.cs
- IdSpace.cs
- UnsafeNativeMethods.cs
- VariableDesigner.xaml.cs
- PerformanceCounterScope.cs
- ResourcePool.cs
- EntityClientCacheEntry.cs
- SimpleParser.cs
- ColorPalette.cs
- GPPOINTF.cs
- TextDecorations.cs
- TraceHandlerErrorFormatter.cs
- DataGridToolTip.cs
- MgmtConfigurationRecord.cs
- DESCryptoServiceProvider.cs
- StylusSystemGestureEventArgs.cs
- Localizer.cs
- FontFamilyValueSerializer.cs
- HttpListenerRequest.cs
- UnionCodeGroup.cs
- UrlMapping.cs
- SpinLock.cs
- RuntimeIdentifierPropertyAttribute.cs
- RootContext.cs
- ExpressionVisitor.cs
- XmlIlGenerator.cs
- DelegateOutArgument.cs
- FormsAuthenticationUser.cs
- IssuanceLicense.cs
- dbdatarecord.cs
- BitmapCache.cs
- LambdaExpression.cs
- TypeDescriptionProvider.cs
- QilGenerator.cs
- SelectionEditingBehavior.cs
- PageAdapter.cs
- PDBReader.cs
- MethodBuilderInstantiation.cs
- Relationship.cs
- PenLineJoinValidation.cs
- DelayedRegex.cs
- ArrayElementGridEntry.cs
- XsdValidatingReader.cs
- HttpCookie.cs
- ProjectedSlot.cs
- QueryCursorEventArgs.cs
- WSIdentityFaultException.cs
- IOThreadScheduler.cs
- WeakHashtable.cs
- ProcessInfo.cs
- XmlFormatWriterGenerator.cs
- CustomWebEventKey.cs
- WebUtil.cs
- NavigationProperty.cs
- XmlTextReader.cs
- TileBrush.cs
- SerializationTrace.cs
- PresentationSource.cs
- OdbcRowUpdatingEvent.cs
- RijndaelCryptoServiceProvider.cs
- DesignBindingPicker.cs
- BitmapImage.cs
- COAUTHIDENTITY.cs
- ButtonBase.cs
- ModelPropertyDescriptor.cs
- UpdatableWrapper.cs
- PassportPrincipal.cs
- Bidi.cs
- SqlErrorCollection.cs
- CodeGeneratorOptions.cs
- ContentControl.cs
- ActivationServices.cs
- ProcessStartInfo.cs
- Calendar.cs
- HandlerBase.cs
- BufferedOutputStream.cs
- Delegate.cs
- OutputCacheSettings.cs
- InputScope.cs
- AxisAngleRotation3D.cs
- ToolStripItemTextRenderEventArgs.cs
- ContentElement.cs