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

Revision ab2f6f79 trunk/Pithos.Core/Agents/StatusAgent.cs

                         //This file was deleted while we were down. We should mark it as deleted
                         //We have to go through UpdateStatus here because the state object we are using
                         //was created by a different ORM session.
                         UpdateStatus(fileState.Id,state=> state.FileStatus = FileStatus.Deleted);
                         FileState.UpdateStatus(fileState.Id,FileStatus.Deleted);
+                    }
                     else
+                    {
-...
                         //If the hashes don't match the file was changed
                         if (fileState.Checksum != hashString)
+                        {
                             UpdateStatus(fileState.Id, state => state.FileStatus = FileStatus.Modified);
                             FileState.UpdateStatus(fileState.Id, FileStatus.Modified);
+                        }
+                    }
                 });
-...
             private string _pithosDataPath;
             public T GetStatus<T>(string path,Func<FileState,T> getter,T defaultValue )
+            {
                 if (String.IsNullOrWhiteSpace(path))
                     throw new ArgumentNullException("path");
                 if (!Path.IsPathRooted(path))
                     throw new ArgumentException("path must be a rooted path", "path");
                 if (getter == null)
                     throw new ArgumentNullException("getter");
                 Contract.EndContractBlock();
                 try
+                {
                     var state = FileState.FindByFilePath(path);
                     return state == null ? defaultValue : getter(state);
+                }
                 catch (Exception exc)
+                {
                     Log.ErrorFormat(exc.ToString());
                     return defaultValue;
+                }
+            }
             /// <summary>
             /// Sets the status of a file, creating a new FileState entry if one doesn't already exist.
             /// </summary>
             /// <param name="path"></param>
             /// <param name="setter"></param>
             public void SetStatus(string path,Action<FileState> setter)
+            {
                 if (String.IsNullOrWhiteSpace(path))
                     throw new ArgumentNullException("path", "path can't be empty");
                 if (setter==null)
                     throw new ArgumentNullException("setter", "setter can't be empty");
                 Contract.EndContractBlock();
                 _persistenceAgent.Post(() =>
+                {
                     using (new SessionScope())
+                    {
                         var filePath = path.ToLower();
                         var state = FileState.FindByFilePath(filePath);
                         if (state != null)
+                        {
                             setter(state);
                             state.Save();
+                        }
                         else
+                        {
                             state = new FileState {FilePath = filePath};
                             setter(state);
                             state.Save();
+                        }
+                    }
                 });
+            }
             /// <summary>
             /// Sets the status of a file only if the file already exists
             /// </summary>
             /// <param name="path"></param>
             /// <param name="setter"></param>
             private void UpdateStatus(string path, Action<FileState> setter)
+            {
                 if (String.IsNullOrWhiteSpace(path))
                     throw new ArgumentNullException("path");
                 if (!Path.IsPathRooted(path))
                     throw new ArgumentException("The path must be rooted", "path");
                 if (setter == null)
                     throw new ArgumentNullException("setter");
                 Contract.EndContractBlock();
                 Debug.Assert(!path.Contains(FolderConstants.CacheFolder));
                 Debug.Assert(!path.EndsWith(".ignore"));
                 if (String.IsNullOrWhiteSpace(path))
                     throw new ArgumentNullException("path", "path can't be empty");
                 if (setter == null)
                     throw new ArgumentNullException("setter", "setter can't be empty");
                 _persistenceAgent.Post(() =>
+                {
                     using (new SessionScope())
+                    {
                         var filePath = path.ToLower();
                         var state = FileState.FindByFilePath(filePath);
                         if (state == null)
+                        {
                             Log.WarnFormat("[NOFILE] Unable to set status for {0}.", filePath);
                             return;
+                        }
                         setter(state);
                         state.Save();
+                    }
                 });
+            }
             /// <summary>
             /// Sets the status of a specific state
             /// </summary>
             /// <param name="path"></param>
             /// <param name="setter"></param>
             private void UpdateStatus(Guid stateID, Action<FileState> setter)
+            {
                 if (setter == null)
                     throw new ArgumentNullException("setter");
                 Contract.EndContractBlock();
                 _persistenceAgent.Post(() =>
+                {
                     using (new SessionScope())
+                    {
                         var state = FileState.Find(stateID);
                         if (state == null)
+                        {
                             Log.WarnFormat("[NOFILE] Unable to set status for {0}.", stateID);
                             return;
+                        }
                         setter(state);
                         state.Save();
+                    }
                 });
+            }
             public FileOverlayStatus GetFileOverlayStatus(string path)
+            {
-...
                 try
+                {
                     var state = FileState.FindByFilePath(path);
                     return state == null ? FileOverlayStatus.Unversioned : state.OverlayStatus;
                     var status = from state in  FileState.Queryable
                                      where state.FilePath ==path.ToLower()
                                      select state.OverlayStatus;
                     return status.Any()? status.First():FileOverlayStatus.Unversioned;
+                }
                 catch (Exception exc)
+                {
-...
                     throw new ArgumentException("The path must be rooted","path");
                 Contract.EndContractBlock();
                 SetStatus(path.ToLower(),s=>s.OverlayStatus=overlayStatus);
                 _persistenceAgent.Post(() => FileState.StoreOverlayStatus(path.ToLower(),overlayStatus));
+            }
             /*public void RemoveFileOverlayStatus(string path)
-...
                     throw new ArgumentException("The newPath must be rooted", "newPath");
                 Contract.EndContractBlock();
                 _persistenceAgent.Post(() =>
                     InnerRenameFileOverlayStatus(oldPath, newPath));
+            }
             private static void InnerRenameFileOverlayStatus(string oldPath, string newPath)
+            {
                 if (String.IsNullOrWhiteSpace(oldPath))
                     throw new ArgumentNullException("oldPath");
                 if (!Path.IsPathRooted(oldPath))
                     throw new ArgumentException("The oldPath must be rooted", "oldPath");
                 if (String.IsNullOrWhiteSpace(newPath))
                     throw new ArgumentNullException("newPath");
                 if (!Path.IsPathRooted(newPath))
                     throw new ArgumentException("The newPath must be rooted", "newPath");
                 Contract.EndContractBlock();
                 var state = FileState.FindByFilePath(oldPath);
                 if (state == null)
+                {
                     Log.WarnFormat("[NOFILE] Unable to set status for {0}.", oldPath);
                     return;
+                }
                 //NOTE: This will cause problems if path is used as a key in relationships
                 state.FilePath = newPath;
                 state.Update();
                 _persistenceAgent.Post(() =>FileState.RenameState(oldPath, newPath));
+            }
             public void SetFileState(string path, FileStatus fileStatus, FileOverlayStatus overlayStatus)
-...
                     throw new ArgumentException("The path must be rooted", "path");
                 Contract.EndContractBlock();
                 UpdateStatus(path.ToLower(),state=>
+                                      {
                                           state.FileStatus = fileStatus;
                                           state.OverlayStatus = overlayStatus;
                                       });
                 Debug.Assert(!path.Contains(FolderConstants.CacheFolder));
                 Debug.Assert(!path.EndsWith(".ignore"));
                 _persistenceAgent.Post(() => FileState.UpdateStatus(path.ToLower(), fileStatus, overlayStatus));
+            }
             public void StoreInfo(string path,ObjectInfo objectInfo)
-...
                         //Forgetting to use a sessionscope results in two sessions being created, one by
                         //FirstOrDefault and one by Save()
                         var state =FileState.FindByFilePath(filePath);
                         //Create a new empty state object if this is a new file
                         state = state ?? new FileState();
-...
             public void SetFileStatus(string path, FileStatus status)
+            {
                 UpdateStatus(path.ToLower(), state=>state.FileStatus = status);
+            {
                 if (String.IsNullOrWhiteSpace(path))
                     throw new ArgumentNullException("path");
                 if (!Path.IsPathRooted(path))
                     throw new ArgumentException("The path must be rooted", "path");
                 Contract.EndContractBlock();
                 _persistenceAgent.Post(() => FileState.UpdateStatus(path.ToLower(), status));
+            }
             public FileStatus GetFileStatus(string path)
-...
                     throw new ArgumentException("The path must be rooted", "path");
                 Contract.EndContractBlock();
                 var state = FileState.FindByFilePath(path);
                 return (state==null)?FileStatus.Missing:state.FileStatus ;
                 var status = from r in FileState.Queryable
                          where r.FilePath == path.ToLower()
                          select r.FileStatus;
                 return status.Any()?status.First(): FileStatus.Missing;
+            }
             public void ClearFileStatus(string path)
-...
                     throw new ArgumentException("The path must be rooted", "path");
                 Contract.EndContractBlock();
                 _persistenceAgent.Post(() =>
+                {
                     using (new SessionScope())
+                    {
                         var state = FileState.FindByFilePath(path);
                         if (state == null)
+                        {
                             Log.WarnFormat("[NOFILE] Unable to set checkesum for {0}.", path);
                             return;
+                        }
                         state.Checksum = checksum;
                         state.Update();
+                    }
                 });
                 _persistenceAgent.Post(() => FileState.UpdateChecksum(path.ToLower(), checksum));
+            }
+        }

Also available in: Unified diff

Synnefo » Pithos MS Client

Revision ab2f6f79 trunk/Pithos.Core/Agents/StatusAgent.cs