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
- DesignConnection.cs
- DataListItem.cs
- ListBox.cs
- Set.cs
- KnownBoxes.cs
- JournalNavigationScope.cs
- DataProtection.cs
- ExternalException.cs
- BinaryReader.cs
- ConditionalBranch.cs
- SystemDropShadowChrome.cs
- TreeViewBindingsEditorForm.cs
- InputScope.cs
- TrimSurroundingWhitespaceAttribute.cs
- ImageButton.cs
- ToolStripItemImageRenderEventArgs.cs
- XamlSerializer.cs
- InternalMappingException.cs
- BufferedGraphicsManager.cs
- ContextBase.cs
- TargetParameterCountException.cs
- TemplateBindingExpressionConverter.cs
- CodeTypeReferenceExpression.cs
- ParallelQuery.cs
- ColorAnimation.cs
- FocusTracker.cs
- LightweightCodeGenerator.cs
- Evaluator.cs
- ColumnPropertiesGroup.cs
- ClassHandlersStore.cs
- DelegatingConfigHost.cs
- ExceptionUtil.cs
- Object.cs
- DrawingDrawingContext.cs
- RightsManagementEncryptedStream.cs
- EventSourceCreationData.cs
- dsa.cs
- SmtpSection.cs
- _MultipleConnectAsync.cs
- odbcmetadatafactory.cs
- DelegatingTypeDescriptionProvider.cs
- UserControlCodeDomTreeGenerator.cs
- CodeThrowExceptionStatement.cs
- QilBinary.cs
- Table.cs
- DataServiceQuery.cs
- ISessionStateStore.cs
- GcHandle.cs
- ConfigurationSectionCollection.cs
- AppDomainAttributes.cs
- SiteMapNodeItemEventArgs.cs
- DbDeleteCommandTree.cs
- RequestCacheManager.cs
- PathSegment.cs
- ConcurrentDictionary.cs
- ByteConverter.cs
- SystemIPv4InterfaceProperties.cs
- WsatServiceCertificate.cs
- CompiledXpathExpr.cs
- CompositionTarget.cs
- PeerNameRegistration.cs
- Attributes.cs
- SHA1Managed.cs
- DataSetMappper.cs
- DataGridViewColumnStateChangedEventArgs.cs
- EntityDataSourceMemberPath.cs
- XmlElement.cs
- RepeaterItem.cs
- ReverseInheritProperty.cs
- WebBrowserDocumentCompletedEventHandler.cs
- DateTimeStorage.cs
- UriScheme.cs
- Mappings.cs
- AnnotationComponentChooser.cs
- ResourceReferenceKeyNotFoundException.cs
- NativeMethods.cs
- ParserHooks.cs
- ConfigurationSettings.cs
- ErrorsHelper.cs
- DataGridViewCellCancelEventArgs.cs
- SoapMessage.cs
- XmlArrayItemAttribute.cs
- ArgumentNullException.cs
- ChildrenQuery.cs
- AnimationStorage.cs
- RoleManagerModule.cs
- DataSourceSelectArguments.cs
- SqlNotificationEventArgs.cs
- MonitoringDescriptionAttribute.cs
- SymbolMethod.cs
- _HeaderInfo.cs
- SqlDataSourceFilteringEventArgs.cs
- XmlSchemaNotation.cs
- FileInfo.cs
- GetReadStreamResult.cs
- ClientSession.cs
- InputLanguageCollection.cs
- _TimerThread.cs
- ChannelAcceptor.cs
- ReadOnlyNameValueCollection.cs