VolatileResourceManager.cs source code in C# .NET

                        Code:
                         / 4.0 / 4.0 / DEVDIV_TFS / Dev10 / Releases / RTMRel / ndp / cdf / src / WF / RunTime / VolatileResourceManager.cs / 1305376 / VolatileResourceManager.cs
                        
                        
                            #pragma warning disable 1634, 1691 
using System;
using System.Diagnostics;
using System.Transactions;
using System.Collections; 
using System.Collections.Generic;
using System.Workflow.Runtime.Hosting; 
 
namespace System.Workflow.Runtime
{ 
    /// 
    /// Volatile Resource Manager
    /// 
    internal sealed class VolatileResourceManager 
    {
        // members 
        private WorkBatchCollection _workCollection = new WorkBatchCollection(); 
        private WorkBatch _mergedBatch = null;
 
        // constructor
        internal VolatileResourceManager()
        {
        } 

        // properties 
        internal WorkBatchCollection BatchCollection 
        {
            get 
            {
                return _workCollection;
            }
        } 

        internal bool IsBatchDirty 
        { 
            get
            { 
                IDictionaryEnumerator de = _workCollection.GetEnumerator();
                while (de.MoveNext())
                {
                    WorkBatch batch = (WorkBatch)de.Value; 
                    if (batch.IsDirty)
                        return true; 
                } 
                return false;
            } 
        }

        WorkBatch GetMergedBatch()
        { 
            return this._workCollection.GetMergedBatch();
        } 
 
        internal void Commit()
        { 
            _mergedBatch = GetMergedBatch();

            Transaction transaction = Transaction.Current;
            if (null == transaction) 
                throw new InvalidOperationException(ExecutionStringManager.NullAmbientTransaction);
 
            // Do Commit Sequence iteration over work collection 
            _mergedBatch.Commit(transaction);
        } 

        internal void Complete()
        {
            try 
            {
                _mergedBatch.Complete(true); 
            } 
            finally
            { 
                if (_mergedBatch != null)
                {
                    _mergedBatch.Dispose();
                    _mergedBatch = null; 
                }
                if (_workCollection != null) 
                { 
                    _workCollection.ClearSubBatches();
                } 
            }
        }

        internal void HandleFault() 
        {
            // 
            // We've failed, clear the merged batch 
            if (_mergedBatch != null)
            { 
                _mergedBatch.Dispose();
                _mergedBatch = null;
            }
            // clear transient batch which holds instance state primarily 
            if (_workCollection != null)
            { 
                _workCollection.ClearTransientBatch(); 
            }
        } 

        internal void ClearAllBatchedWork()
        {
            if (_workCollection != null) 
                _workCollection.RollbackAllBatchedWork();
        } 
    } 
}

// File provided for Reference Use Only by Microsoft Corporation (c) 2007.
// Copyright (c) Microsoft Corporation. All rights reserved.
#pragma warning disable 1634, 1691 
using System;
using System.Diagnostics;
using System.Transactions;
using System.Collections; 
using System.Collections.Generic;
using System.Workflow.Runtime.Hosting; 
 
namespace System.Workflow.Runtime
{ 
    /// 
    /// Volatile Resource Manager
    /// 
    internal sealed class VolatileResourceManager 
    {
        // members 
        private WorkBatchCollection _workCollection = new WorkBatchCollection(); 
        private WorkBatch _mergedBatch = null;
 
        // constructor
        internal VolatileResourceManager()
        {
        } 

        // properties 
        internal WorkBatchCollection BatchCollection 
        {
            get 
            {
                return _workCollection;
            }
        } 

        internal bool IsBatchDirty 
        { 
            get
            { 
                IDictionaryEnumerator de = _workCollection.GetEnumerator();
                while (de.MoveNext())
                {
                    WorkBatch batch = (WorkBatch)de.Value; 
                    if (batch.IsDirty)
                        return true; 
                } 
                return false;
            } 
        }

        WorkBatch GetMergedBatch()
        { 
            return this._workCollection.GetMergedBatch();
        } 
 
        internal void Commit()
        { 
            _mergedBatch = GetMergedBatch();

            Transaction transaction = Transaction.Current;
            if (null == transaction) 
                throw new InvalidOperationException(ExecutionStringManager.NullAmbientTransaction);
 
            // Do Commit Sequence iteration over work collection 
            _mergedBatch.Commit(transaction);
        } 

        internal void Complete()
        {
            try 
            {
                _mergedBatch.Complete(true); 
            } 
            finally
            { 
                if (_mergedBatch != null)
                {
                    _mergedBatch.Dispose();
                    _mergedBatch = null; 
                }
                if (_workCollection != null) 
                { 
                    _workCollection.ClearSubBatches();
                } 
            }
        }

        internal void HandleFault() 
        {
            // 
            // We've failed, clear the merged batch 
            if (_mergedBatch != null)
            { 
                _mergedBatch.Dispose();
                _mergedBatch = null;
            }
            // clear transient batch which holds instance state primarily 
            if (_workCollection != null)
            { 
                _workCollection.ClearTransientBatch(); 
            }
        } 

        internal void ClearAllBatchedWork()
        {
            if (_workCollection != null) 
                _workCollection.RollbackAllBatchedWork();
        } 
    } 
}

// File provided for Reference Use Only by Microsoft Corporation (c) 2007.
// Copyright (c) Microsoft Corporation. All rights reserved.
Link Menu

Network programming in C#, Network Programming in VB.NET, Network Programming in .NET
This book is available now!
Buy at Amazon US or
Buy at Amazon UK
VolatileResourceManager.cs source code in C# .NET

Source code for the .NET framework in C#

Code:

Link Menu
