Services/Transaction/Castle.Services.Transaction/TLSActivityManager.cs

   1 namespace Castle.Services.Transaction
   2 {
   3         using System;
   4         using System.Threading;
   5
   6         public class TLSActivityManager : MarshalByRefObject, IActivityManager
   7         {
   8                 private const string Key = "Castle.Services.Transaction.TLSActivity";
   9
  10                 private object lockObj = new object();
  11                 private static LocalDataStoreSlot dataSlot;
  12
  13                 static TLSActivityManager()
  14                 {
  15                         dataSlot = Thread.AllocateNamedDataSlot(Key);
  16                 }
  17
  18                 #region MarshalByRefObject
  19
  20                 ///<summary>
  21                 ///Obtains a lifetime service object to control the lifetime policy for this instance.
  22                 ///</summary>
  23                 ///
  24                 ///<returns>
  25                 ///An object of type <see cref="T:System.Runtime.Remoting.Lifetime.ILease"></see> used to control the lifetime policy for this instance. This is the current lifetime service object for this instance if one exists; otherwise, a new lifetime service object initialized to the value of the <see cref="P:System.Runtime.Remoting.Lifetime.LifetimeServices.LeaseManagerPollTime"></see> property.
  26                 ///</returns>
  27                 ///
  28                 ///<exception cref="T:System.Security.SecurityException">The immediate caller does not have infrastructure permission. </exception><filterpriority>2</filterpriority><PermissionSet><IPermission class="System.Security.Permissions.SecurityPermission, mscorlib, Version=2.0.3600.0, Culture=neutral, PublicKeyToken=b77a5c561934e089" version="1" Flags="RemotingConfiguration, Infrastructure" /></PermissionSet>
  29                 public override object InitializeLifetimeService()
  30                 {
  31                         return null;
  32                 }
  33
  34                 #endregion
  35
  36                 /// <summary>
  37                 /// Gets the current activity.
  38                 /// </summary>
  39                 /// <value>The current activity.</value>
  40                 public Activity CurrentActivity
  41                 {
  42                         get
  43                         {
  44                                 lock (lockObj)
  45                                 {
  46                                         Activity activity = (Activity) Thread.GetData(dataSlot);
  47
  48                                         if (activity == null)
  49                                         {
  50                                                 activity = new Activity();
  51                                                 Thread.SetData(dataSlot, activity);
  52                                         }
  53
  54                                         return activity;
  55                                 }
  56                         }
  57                 }
  58         }
  59 }