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

Revision 5ce54458 trunk/Pithos.Core/PithosMonitor.cs

     using Pithos.Core.Agents;
     using Pithos.Interfaces;
     using System.ServiceModel;
     using Pithos.Network;
     namespace Pithos.Core
+    {
-...
             private const string PithosContainer = "pithos";
             private const string TrashContainer = "trash";
             private const string FragmentsFolder = "fragments";
             private int _blockSize;
             private string _blockHash;
             [Import]
             public IPithosSettings Settings{get;set;}
-...
             public IStatusNotification StatusNotification { get; set; }
             [Import]
             public FileWatcherAgent FileWatcherAgent { get; set; }
             public FileAgent FileAgent { get; set; }
             [Import]
             public WorkflowAgent WorkflowAgent { get; set; }
-...
             public bool Pause
+            {
                 get { return FileWatcherAgent.Pause; }
                 get { return FileAgent.Pause; }
                 set
+                {
                     FileWatcherAgent.Pause = value;
                     FileAgent.Pause = value;
                     if (value)
+                    {
                         StatusKeeper.SetPithosStatus(PithosStatus.SyncPaused);
-...
                 EnsurePithosContainers();
                 StatusKeeper.BlockHash = "sha256";
                 StatusKeeper.BlockHash = _blockHash;
                 StatusKeeper.BlockSize = _blockSize;
                 StatusKeeper.StartProcessing(_cancellationSource.Token);
                 IndexLocalFiles(RootPath);
-...
                 CloudClient.AuthenticationUrl = this.AuthenticationUrl;
                 CloudClient.Authenticate(UserName, ApiKey);
                 var pithosContainers = new[] {PithosContainer, TrashContainer};
                 var pithosContainers = new[] { TrashContainer,PithosContainer};
                 foreach (var container in pithosContainers)
+                {
                     if (!CloudClient.ContainerExists(container))
                         CloudClient.CreateContainer(container);
                     var info=CloudClient.GetContainerInfo(container);
                     if (info == ContainerInfo.Empty)
+                    {
                         CloudClient.CreateContainer(container);
                         info = CloudClient.GetContainerInfo(container);
+                    }
                     _blockSize = info.BlockSize;
                     _blockHash = info.BlockHash;
+                }
                 var allContainers= CloudClient.ListContainers();
                 var extraContainers = from container in allContainers
                                       where !pithosContainers.Contains(container.Name.ToLower())
                                           select container;
+            }
             public string AuthenticationUrl { get; set; }
-...
                 Trace.TraceInformation("[START] Index Local");
                 try
+                {
                     var fragmentsPath=Path.Combine(RootPath, FragmentsFolder);
                     var files =
                         from filePath in Directory.EnumerateFiles(path, "*", SearchOption.AllDirectories).AsParallel()
                         where !filePath.StartsWith(fragmentsPath,StringComparison.InvariantCultureIgnoreCase) &&
                                 !filePath.EndsWith(".ignore",StringComparison.InvariantCultureIgnoreCase)
                         select filePath.ToLower();
                     StatusKeeper.StoreUnversionedFiles(files);
-...
                     StartNetworkAgent(RootPath);
                     WorkflowAgent.StatusNotification = StatusNotification;
                     WorkflowAgent.FragmentsPath = Path.Combine(RootPath, FragmentsFolder);
                     WorkflowAgent.Start();
+                }
                 catch (Exception)
-...
             private void StartNetworkAgent(string accountPath)
+            {
                 NetworkAgent.StatusNotification = StatusNotification;
                 NetworkAgent.Start(RootPath, PithosContainer,TrashContainer);
                 NetworkAgent.Start(PithosContainer, TrashContainer,_blockSize,_blockHash);
                 NetworkAgent.ProcessRemoteFiles(accountPath);
+            }
             //Make sure a hidden fragments folder exists to store partial downloads
             private static string CreateHiddenFolder(string rootPath, string folderName)
+            {
                 if (String.IsNullOrWhiteSpace(rootPath))
                     throw new ArgumentNullException("rootPath");
                 if (!Path.IsPathRooted(rootPath))
                     throw new ArgumentException("rootPath");
                 if (String.IsNullOrWhiteSpace(folderName))
                     throw new ArgumentNullException("folderName");
                 Contract.EndContractBlock();
                 var folder = Path.Combine(rootPath, folderName);
                 if (!Directory.Exists(folder))
+                {
                     var info = Directory.CreateDirectory(folder);
                     info.Attributes |= FileAttributes.Hidden;
                     Trace.TraceInformation("Created Fragments Folder: {0}", folder);
+                }
                 return folder;
+            }
             private void StartWatcherAgent(string path)
+            {
                 FileWatcherAgent.StatusKeeper = StatusKeeper;
                 FileWatcherAgent.Workflow = Workflow;
                 FileWatcherAgent.Start(path);
                 FileAgent.StatusKeeper = StatusKeeper;
                 FileAgent.Workflow = Workflow;
                 FileAgent.FragmentsPath = Path.Combine(RootPath, FragmentsFolder);
                 FileAgent.Start(path);
+            }
             public void Stop()
+            {
                 FileWatcherAgent.Stop();
                 FileAgent.Stop();
                 if (timer != null)
                     timer.Dispose();
                 timer = null;

Also available in: Unified diff

Synnefo » Pithos MS Client

Revision 5ce54458 trunk/Pithos.Core/PithosMonitor.cs