From b1500aef0245f93a776f636bb9ffaf1dd4999621 Mon Sep 17 00:00:00 2001 From: Matt Davies Date: Sat, 20 Apr 2013 14:42:59 +0800 Subject: [PATCH] Add a publicly accessible getter for LeaseId within AutoRenewLease --- AutoRenewLease.cs | 15 ++++++++------- 1 file changed, 8 insertions(+), 7 deletions(-) diff --git a/AutoRenewLease.cs b/AutoRenewLease.cs index 924ba07..a51b3f4 100644 --- a/AutoRenewLease.cs +++ b/AutoRenewLease.cs @@ -8,10 +8,11 @@ namespace smarx.WazStorageExtensions { public class AutoRenewLease : IDisposable { - public bool HasLease { get { return leaseId != null; } } + public bool HasLease { get { return LeaseId != null; } } + + public string LeaseId { get; private set; } private CloudBlob blob; - private string leaseId; private Thread renewalThread; private bool disposed = false; @@ -27,7 +28,7 @@ public static void DoOnce(CloudBlob blob, Action action, TimeSpan pollingFrequen { action(); blob.Metadata["progress"] = "done"; - blob.SetMetadata(arl.leaseId); + blob.SetMetadata(arl.LeaseId); } else { @@ -53,7 +54,7 @@ public static void DoEvery(CloudBlob blob, TimeSpan interval, Action action) action(); lastPerformed = DateTimeOffset.UtcNow; blob.Metadata["lastPerformed"] = lastPerformed.ToString("R"); - blob.SetMetadata(arl.leaseId); + blob.SetMetadata(arl.LeaseId); } } } @@ -82,7 +83,7 @@ public AutoRenewLease(CloudBlob blob) throw; } } - leaseId = blob.TryAcquireLease(); + LeaseId = blob.TryAcquireLease(); if (HasLease) { renewalThread = new Thread(() => @@ -90,7 +91,7 @@ public AutoRenewLease(CloudBlob blob) while (true) { Thread.Sleep(TimeSpan.FromSeconds(40)); - blob.RenewLease(leaseId); + blob.RenewLease(LeaseId); } }); renewalThread.Start(); @@ -112,7 +113,7 @@ protected virtual void Dispose(bool disposing) if (renewalThread != null) { renewalThread.Abort(); - blob.ReleaseLease(leaseId); + blob.ReleaseLease(LeaseId); renewalThread = null; } }