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

Revision c53aa229 trunk/Pithos.Core/PithosMonitor.cs

         [Export(typeof(PithosMonitor))]
         public class PithosMonitor:IDisposable
+        {
             private const string PithosContainer = "pithos";
             private const string TrashContainer = "trash";
             private const string FragmentsFolder = "fragments";
             private int _blockSize;
             private string _blockHash;
-...
             [Import]
             public IPithosWorkflow Workflow { get; set; }
             [Import]
             public ICloudClient CloudClient { get; set; }
             public IStatusNotification StatusNotification { get; set; }
-...
             public string UserName { get; set; }
             public string ApiKey { get; set; }
             private ServiceHost _statusService { get; set; }
             private Network.AccountInfo _accountInfo;
             private static readonly ILog Log = LogManager.GetLogger(typeof(PithosMonitor));
-...
             private bool _isInitialized;
             public void Start()
+            {
+            {
                 if (String.IsNullOrWhiteSpace(ApiKey))
                     throw new InvalidOperationException("The ApiKey is empty");
                 if (String.IsNullOrWhiteSpace(UserName))
                     throw new InvalidOperationException("The UserName is empty");
                 if (String.IsNullOrWhiteSpace(AuthenticationUrl))
                     throw new InvalidOperationException("The Authentication url is empty");
                 Contract.EndContractBlock();
                 StatusNotification.NotifyChange("Starting");
                 if (_isInitialized)
+                {
-...
+                }
                 _cancellationSource = new CancellationTokenSource();
                 CloudClient=new CloudFilesClient(UserName,ApiKey);
                 var proxyUri = ProxyFromSettings();
                 CloudClient.Proxy = proxyUri;
                 CloudClient.UsePithos = this.UsePithos;
                 CloudClient.AuthenticationUrl = this.AuthenticationUrl;
                 _accountInfo = CloudClient.Authenticate();
                 _accountInfo.AccountPath = RootPath;
                 EnsurePithosContainers();
                 StatusKeeper.BlockHash = _blockHash;
-...
                 StatusKeeper.StartProcessing(_cancellationSource.Token);
                 IndexLocalFiles(RootPath);
                 StartWatcherAgent(RootPath);
                 StartStatusService();
                 StartNetworkAgent();
                 StartWorkflowAgent();
                 WorkflowAgent.RestartInterruptedFiles();
                 WorkflowAgent.RestartInterruptedFiles(_accountInfo);
                 _isInitialized = true;
+            }
             private void EnsurePithosContainers()
+            {
                 CloudClient.UsePithos = this.UsePithos;
                 CloudClient.AuthenticationUrl = this.AuthenticationUrl;
                 CloudClient.Authenticate(UserName, ApiKey);
                 //Create the two default containers if they are missing
                 var pithosContainers = new List<string>{ TrashContainer,PithosContainer};
                 var pithosContainers = new List<string>{ FolderConstants.TrashContainer,FolderConstants.PithosContainer};
                 foreach (var container in pithosContainers)
+                {
                     var info=CloudClient.GetContainerInfo(this.UserName, container);
-...
+                    }
                     _blockSize = info.BlockSize;
                     _blockHash = info.BlockHash;
                     _accountInfo.BlockSize = _blockSize;
                     _accountInfo.BlockHash = _blockHash;
+                }
     /*
                 //Create folders for any other containers
                 var allContainers = CloudClient.ListContainers();
                 pithosContainers.AddRange(new[]{"shared","others"});
                 var extraContainers = from container in allContainers
                                       where !pithosContainers.Contains(container.Name.ToLower())
                                       select container;
                 foreach (var container in extraContainers)
+                {
                     var containerPath = Path.Combine(this.RootPath, container.Name);
                     if (!Directory.Exists(containerPath))
                         Directory.CreateDirectory(containerPath);
+                }
     */
+            }
             public string AuthenticationUrl { get; set; }
-...
                     Log.Info("START");
                     try
+                    {
                         var fragmentsPath = Path.Combine(RootPath, FragmentsFolder);
                         var fragmentsPath = Path.Combine(RootPath, FolderConstants.FragmentsFolder);
                         var directory = new DirectoryInfo(path);
                         var files =
                             from file in directory.EnumerateFiles("*", SearchOption.AllDirectories)
-...
+            }
             private void StartStatusService()
+            {
                 // Create a ServiceHost for the CalculatorService type and provide the base address.
                 var baseAddress = new Uri("net.pipe://localhost/pithos");
                 _statusService = new ServiceHost(typeof(StatusService), baseAddress);
                 var binding = new NetNamedPipeBinding(NetNamedPipeSecurityMode.None);
                 _statusService.AddServiceEndpoint(typeof(IStatusService), binding, "net.pipe://localhost/pithos/statuscache");
                 _statusService.AddServiceEndpoint(typeof (ISettingsService), binding, "net.pipe://localhost/pithos/settings");
                 //// Add a mex endpoint
                 var smb = new ServiceMetadataBehavior
+                              {
                                   HttpGetEnabled = true,
                                   HttpGetUrl = new Uri("http://localhost:30000/pithos/mex")
                               };
                 _statusService.Description.Behaviors.Add(smb);
                 _statusService.Open();
+            }
             private void StopStatusService()
+            {
                 if (_statusService == null)
                     return;
                 if (_statusService.State == CommunicationState.Faulted)
                     _statusService.Abort();
                 else if (_statusService.State != CommunicationState.Closed)
                     _statusService.Close();
                 _statusService = null;
+            }
             private void StartWorkflowAgent()
-...
                 try
+                {
                     CloudClient.UsePithos = this.UsePithos;
                     CloudClient.AuthenticationUrl = this.AuthenticationUrl;
                     CloudClient.Authenticate(UserName, ApiKey);
                     StartNetworkAgent(RootPath);
                     WorkflowAgent.StatusNotification = StatusNotification;
                     WorkflowAgent.FragmentsPath = Path.Combine(RootPath, FragmentsFolder);
                     WorkflowAgent.Start();
+                }
                 catch (Exception)
-...
             private Timer timer;
             private void StartNetworkAgent(string accountPath)
             private void StartNetworkAgent()
+            {
                 NetworkAgent.AddAccount(_accountInfo);
                 NetworkAgent.StatusNotification = StatusNotification;
                 NetworkAgent.Start(PithosContainer, TrashContainer,_blockSize,_blockHash);
                 NetworkAgent.Start();
                 NetworkAgent.ProcessRemoteFiles(accountPath);
                 NetworkAgent.ProcessRemoteFiles();
+            }
             //Make sure a hidden fragments folder exists to store partial downloads
-...
+            {
                 FileAgent.StatusKeeper = StatusKeeper;
                 FileAgent.Workflow = Workflow;
                 FileAgent.FragmentsPath = Path.Combine(RootPath, FragmentsFolder);
                 FileAgent.Start(path);
                 FileAgent.FragmentsPath = Path.Combine(RootPath, FolderConstants.FragmentsFolder);
                 FileAgent.Start(_accountInfo,path);
+            }
             public void Stop()
+            {
                 FileAgent.Stop();
+            {
                 if (FileAgent!=null)
                     FileAgent.Stop();
                 FileAgent = null;
                 if (timer != null)
                     timer.Dispose();
                 timer = null;
                 StopStatusService();
                 timer = null;
+            }

Also available in: Unified diff

Synnefo » Pithos MS Client

Revision c53aa229 trunk/Pithos.Core/PithosMonitor.cs