/trunk/Pithos.Core/Agents/FileAgent.cs - Diff - Pithos MS Client - Greek Research and Technology Network's projects

Revision c945b450 trunk/Pithos.Core/Agents/FileAgent.cs

+        {
             private static readonly ILog Log = LogManager.GetLogger(MethodBase.GetCurrentMethod().DeclaringType);
             Agent<WorkflowState> _agent;
             /*
                     Agent<WorkflowState> _agent;
             */
             private FileSystemWatcher _watcher;
             private FileSystemWatcherAdapter _adapter;
             private FileEventIdleBatch _eventIdleBatch;
             //[Import]
             public IStatusKeeper StatusKeeper { get; set; }
-...
             //[Import]
             public IPithosWorkflow Workflow { get; set; }
             //[Import]
             public WorkflowAgent WorkflowAgent { get; set; }
             //public WorkflowAgent WorkflowAgent { get; set; }
             private AccountInfo AccountInfo { get; set; }
             internal string RootPath { get;  set; }
             private FileEventIdleBatch _eventIdleBatch;
             public TimeSpan IdleTimeout { get; set; }
             public PollAgent PollAgent { get; set; }
             private void ProcessBatchedEvents(Dictionary<string, FileSystemEventArgs[]> fileEvents)
+            {
                 PollAgent.SynchNow();
+            }
     /*
             private void ProcessBatchedEvents(Dictionary<string, FileSystemEventArgs[]> fileEvents)
+            {
                 StatusNotification.SetPithosStatus(PithosStatus.LocalSyncing,String.Format("Uploading {0} files",fileEvents.Count));
                 //Start with events that do not originate in one of the ignored folders
                 var initialEvents = from evt in fileEvents
-...
+                }
                 StatusNotification.SetPithosStatus(PithosStatus.LocalComplete);
+            }
     */
             public void Start(AccountInfo accountInfo,string rootPath)
+            {
-...
                     throw new ArgumentException("rootPath must be an absolute path","rootPath");
                 if (IdleTimeout == null)
                     throw new InvalidOperationException("IdleTimeout must have a valid value");
                 Contract.EndContractBlock();
                     Contract.EndContractBlock();
                 AccountInfo = accountInfo;
                 RootPath = rootPath;
                 _eventIdleBatch = new FileEventIdleBatch((int)IdleTimeout.TotalMilliseconds, ProcessBatchedEvents);
                 _watcher = new FileSystemWatcher(rootPath) {IncludeSubdirectories = true,InternalBufferSize=8*4096};
                 _watcher = new FileSystemWatcher(rootPath) { IncludeSubdirectories = true, InternalBufferSize = 8 * 4096 };
                 _adapter = new FileSystemWatcherAdapter(_watcher);
                 _adapter.Changed += OnFileEvent;
-...
                 _adapter.Moved += OnMoveEvent;
                 _watcher.EnableRaisingEvents = true;
     /*
                 _agent = Agent<WorkflowState>.Start(inbox =>
+                {
-...
                             Log.ErrorFormat("[ERROR] File Event Processing:\r{0}", ex));
                     };
                     loop();
                 });
                 });*/
+            }
     /*
             private Task<object> Process(WorkflowState state)
+            {
                 if (state==null)
-...
                         _watcher.EnableRaisingEvents = !value;
+                }
+            }
     */
             public string CachePath { get; set; }
-...
             public Selectives Selectives { get; set; }
     /*
             public void Post(WorkflowState workflowState)
+            {
                 if (workflowState == null)
-...
                     _agent.Stop();
+            }
     */
             // Enumerate all files in the Pithos directory except those in the Fragment folder
             // and files with a .ignore extension
             public IEnumerable<string> EnumerateFiles(string searchPattern="*")
+            {
                 var monitoredFiles = from filePath in Directory.EnumerateFileSystemEntries(RootPath, searchPattern, SearchOption.AllDirectories)
                                      where !Ignore(filePath)
                                      orderby filePath ascending
                                      select filePath;
                 return monitoredFiles;
+            }
-...
                 var rootDir = new DirectoryInfo(RootPath);
                 var monitoredFiles = from file in rootDir.EnumerateFiles(searchPattern, SearchOption.AllDirectories)
                                      where !Ignore(file.FullName)
                                      orderby file.FullName ascending
                                      select file;
                 return monitoredFiles;
+            }
             public IEnumerable<FileSystemInfo> EnumerateFileSystemInfos(string searchPattern="*")
+            {
                 var rootDir = new DirectoryInfo(RootPath);
                 //Ensure folders appear first, to allow folder processing as soon as possilbe
                 var monitoredFiles = (from file in rootDir.EnumerateDirectories(searchPattern, SearchOption.AllDirectories)
                                      where !Ignore(file.FullName)
                                      orderby file.FullName ascending
                                      select file)
                                      //Process small files first, leaving expensive large files for last
                                      .Concat(from file in rootDir.EnumerateFiles(searchPattern, SearchOption.AllDirectories)
                                              where !Ignore(file.FullName)
                                              orderby file.Length ascending
                                              select file as FileSystemInfo);
                 return monitoredFiles;
+            }
             public IEnumerable<string> EnumerateFilesAsRelativeUrls(string searchPattern="*")
+            {
                 var rootDir = new DirectoryInfo(RootPath);
                 var monitoredFiles = from file in rootDir.EnumerateFiles(searchPattern, SearchOption.AllDirectories)
                                      where !Ignore(file.FullName)
                                      orderby file.FullName ascending
                                      select file.AsRelativeUrlTo(RootPath);
                 return monitoredFiles;
+            }
-...
                 var rootDir = new DirectoryInfo(RootPath);
                 var monitoredFiles = from file in rootDir.EnumerateFileSystemInfos(searchPattern, SearchOption.AllDirectories)
                                      where !Ignore(file.FullName)
                                      orderby file.FullName ascending
                                      select file.AsRelativeUrlTo(RootPath);
                 return monitoredFiles;
+            }
-...
             private bool Ignore(string filePath)
             public bool Ignore(string filePath)
+            {
                 if (IgnorePaths(filePath)) return true;
                 //If selective sync is enabled,
                 if (Selectives.IsSelectiveEnabled(AccountInfo.AccountKey)
                     //propagate folder events
                     && Directory.Exists(filePath)
                     //from the container root folder only. Note, in the first level below the account root path are the containers
                     && FoundBelowRoot(filePath, RootPath, 2))
                 if (IsUnselectedRootFolder(filePath))
                         return false;
                 //Ignore if selective synchronization is defined,
                 //And the target file is not below any of the selective paths
                 return !Selectives.IsSelected(AccountInfo, filePath);
+            }
             private bool IgnorePaths(string filePath)
             public bool IsUnselectedRootFolder(string filePath)
+            {
                 return Selectives.IsSelectiveEnabled(AccountInfo.AccountKey) //propagate folder events
                        && Directory.Exists(filePath) //from the container root folder only. Note, in the first level below the account root path are the containers
                        && FoundBelowRoot(filePath, RootPath, 2);
+            }
             public bool IgnorePaths(string filePath)
+            {
     //Ignore all first-level directories and files (ie at the container folders level)
                 if (FoundBelowRoot(filePath, RootPath, 1))
-...
                 return false;
+            }
             //Post a Change message for all events except rename
             void OnFileEvent(object sender, FileSystemEventArgs e)
+            {
                 //Ignore events that affect the cache folder
                 var filePath = e.FullPath;
                 if (Ignore(filePath))
                     return;
                 _eventIdleBatch.Post(e);
+            }
     /*
             /*
             //Post a Change message for renames containing the old and new names
             void OnRenameEvent(object sender, RenamedEventArgs e)
+            {
-...
                     TriggeringChange = e.ChangeType
                 });
+            }
     */
             */
             //Post a Change message for all events except rename
             void OnFileEvent(object sender, FileSystemEventArgs e)
+            {
                 //Ignore events that affect the cache folder
                 var filePath = e.FullPath;
                 if (Ignore(filePath))
                     return;
                 _eventIdleBatch.Post(e);
+            }
             //Post a Change message for moves containing the old and new names
             void OnMoveEvent(object sender, MovedEventArgs e)

Also available in: Unified diff

Synnefo » Pithos MS Client

Revision c945b450 trunk/Pithos.Core/Agents/FileAgent.cs