1 write to retryQueue
System.Activities.DurableInstancing (1)
System\Activities\DurableInstancing\LoadRetryHandler.cs (1)
20
this.
retryQueue
= new BinaryHeap<DateTime, LoadRetryAsyncResult>();
7 references to retryQueue
System.Activities.DurableInstancing (7)
System\Activities\DurableInstancing\LoadRetryHandler.cs (7)
32
firstInQueue = this.
retryQueue
.Enqueue(retryTime, command);
51
result = this.
retryQueue
.RemoveAll(x => x.Value != null);
76
if (!this.
retryQueue
.IsEmpty)
79
DateTime expirationTime =
retryQueue
.Peek().Key;
97
retryList =
retryQueue
.TakeWhile(x => currentTime.CompareTo(x) >= 0);
99
if (!this.
retryQueue
.IsEmpty)
101
DateTime expirationTime = this.
retryQueue
.Peek().Key;