Revision 6bcdd8e2 trunk/Pithos.Core/Agents/WorkflowAgent.cs
| b/trunk/Pithos.Core/Agents/WorkflowAgent.cs | ||
|---|---|---|
| 70 | 70 |
[System.ComponentModel.Composition.Import] |
| 71 | 71 |
public NetworkAgent NetworkAgent { get; set; }
|
| 72 | 72 |
|
| 73 |
[System.ComponentModel.Composition.Import] |
|
| 74 |
public IPithosSettings Settings { get; set; }
|
|
| 73 | 75 |
|
| 74 | 76 |
|
| 75 | 77 |
public WorkflowAgent() |
| ... | ... | |
| 210 | 212 |
{
|
| 211 | 213 |
|
| 212 | 214 |
|
| 213 |
using (log4net.ThreadContext.Stacks["Workflow"].Push("Restart"))
|
|
| 215 |
using (log4net.ThreadContext.Stacks["Operation"].Push("RestartInterrupted"))
|
|
| 214 | 216 |
{
|
| 215 | 217 |
if (Log.IsDebugEnabled) |
| 216 | 218 |
Log.Debug("Starting interrupted files");
|
| ... | ... | |
| 219 | 221 |
.ToLower(); |
| 220 | 222 |
|
| 221 | 223 |
|
| 222 |
|
|
| 224 |
|
|
| 225 |
|
|
| 223 | 226 |
var account = accountInfo; |
| 224 | 227 |
var pendingEntries = (from state in FileState.Queryable |
| 225 | 228 |
where state.FileStatus != FileStatus.Unchanged && |
| 226 | 229 |
!state.FilePath.StartsWith(cachePath) && |
| 227 | 230 |
!state.FilePath.EndsWith(".ignore") &&
|
| 228 |
state.FilePath.StartsWith(account.AccountPath) |
|
| 231 |
state.FilePath.StartsWith(account.AccountPath)
|
|
| 229 | 232 |
select state).ToList(); |
| 230 | 233 |
if (pendingEntries.Count>0) |
| 231 | 234 |
StatusNotification.NotifyChange("Restart processing interrupted files", TraceLevel.Verbose);
|
Also available in: Unified diff