code.grnet.gr Git - pithos-ms-client/blob - trunk/Pithos.Core/PithosWorkflow.cs

   1 #region
   2 /* -----------------------------------------------------------------------
   3  * <copyright file="PithosWorkflow.cs" company="GRNet">
   4  *
   5  * Copyright 2011-2012 GRNET S.A. All rights reserved.
   6  *
   7  * Redistribution and use in source and binary forms, with or
   8  * without modification, are permitted provided that the following
   9  * conditions are met:
  10  *
  11  *   1. Redistributions of source code must retain the above
  12  *      copyright notice, this list of conditions and the following
  13  *      disclaimer.
  14  *
  15  *   2. Redistributions in binary form must reproduce the above
  16  *      copyright notice, this list of conditions and the following
  17  *      disclaimer in the documentation and/or other materials
  18  *      provided with the distribution.
  19  *
  20  *
  21  * THIS SOFTWARE IS PROVIDED BY GRNET S.A. ``AS IS'' AND ANY EXPRESS
  22  * OR IMPLIED WARRANTIES, INCLUDING, BUT NOT LIMITED TO, THE IMPLIED
  23  * WARRANTIES OF MERCHANTABILITY AND FITNESS FOR A PARTICULAR
  24  * PURPOSE ARE DISCLAIMED. IN NO EVENT SHALL GRNET S.A OR
  25  * CONTRIBUTORS BE LIABLE FOR ANY DIRECT, INDIRECT, INCIDENTAL,
  26  * SPECIAL, EXEMPLARY, OR CONSEQUENTIAL DAMAGES (INCLUDING, BUT NOT
  27  * LIMITED TO, PROCUREMENT OF SUBSTITUTE GOODS OR SERVICES; LOSS OF
  28  * USE, DATA, OR PROFITS; OR BUSINESS INTERRUPTION) HOWEVER CAUSED
  29  * AND ON ANY THEORY OF LIABILITY, WHETHER IN CONTRACT, STRICT
  30  * LIABILITY, OR TORT (INCLUDING NEGLIGENCE OR OTHERWISE) ARISING IN
  31  * ANY WAY OUT OF THE USE OF THIS SOFTWARE, EVEN IF ADVISED OF THE
  32  * POSSIBILITY OF SUCH DAMAGE.
  33  *
  34  * The views and conclusions contained in the software and
  35  * documentation are those of the authors and should not be
  36  * interpreted as representing official policies, either expressed
  37  * or implied, of GRNET S.A.
  38  * </copyright>
  39  * -----------------------------------------------------------------------
  40  */
  41 #endregion
  42 using System;
  43 using System.Collections.Generic;
  44 using System.ComponentModel.Composition;
  45 using System.Linq;
  46 using System.Runtime.InteropServices;
  47 using System.Text;
  48 using System.Threading;
  49 using System.Threading.Tasks;
  50 using Pithos.Interfaces;
  51 using System.IO;
  52 using System.Diagnostics;
  53 using Pithos.Network;
  54
  55 namespace Pithos.Core
  56 {
  57     [Export(typeof(IPithosWorkflow))]
  58     public class PithosWorkflow:IPithosWorkflow
  59     {
  60         [Import]
  61         public IPithosSettings Settings { get; set; }
  62
  63         [Import]
  64         public IStatusKeeper StatusKeeper { get; set; }
  65
  66         public FileStatus SetFileStatus(string path, FileStatus status)
  67         {
  68             Debug.Assert(!path.Contains(FolderConstants.CacheFolder));
  69             Debug.Assert(!path.EndsWith(".ignore",StringComparison.InvariantCultureIgnoreCase));
  70
  71             if (String.IsNullOrWhiteSpace(path))
  72                 throw new ArgumentNullException("path", "The path parameter must not be emtpy");
  73
  74             var oldStatus=StatusKeeper.GetFileStatus(path);
  75
  76             if (oldStatus == status)
  77                 return oldStatus;
  78
  79             switch(oldStatus)
  80             {
  81                 case FileStatus.Unchanged :
  82                     break;
  83                 case FileStatus.Created:
  84                     if (status == FileStatus.Modified)
  85                         return oldStatus;
  86                     break;
  87                 case FileStatus.Modified:
  88                 case FileStatus.Renamed:
  89                     if (status == FileStatus.Created)
  90                         return oldStatus;
  91                     break;
  92             }
  93             StatusKeeper.SetFileStatus(path, status);
  94             return status;
  95         }
  96
  97         public void ClearFileStatus(string path)
  98         {
  99             if (String.IsNullOrWhiteSpace(path))
 100                 throw new ArgumentNullException("path", "The path parameter must not be emtpy");
 101
 102             StatusKeeper.ClearFileStatus(path.ToLower());
 103         }
 104
 105
 106         public Task<FileStream> OpenStreamWithWaiting(string path)
 107         {
 108             if (String.IsNullOrWhiteSpace(path))
 109                 throw new ArgumentNullException("path","The path parameter must not be emtpy");
 110
 111             if (!File.Exists(path))
 112                 throw new FileNotFoundException("The specified file or path does not exist", path);
 113
 114             return new Task<FileStream>(() =>
 115                     {
 116                         int counter = 0;
 117                         while (true)
 118                         {
 119                             try
 120                             {
 121                                 var stream=File.OpenRead(path);
 122                                 return stream;
 123                             }
 124                             catch
 125                             {
 126                                 Thread.Sleep(500);
 127                                 if (++counter > 10)
 128                                     throw;
 129                             }
 130                         }
 131                     });
 132         }
 133     }
 134 }