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

Revision 3c43ec9b trunk/Pithos.Core/StatusKeeper.cs

     using System;
     using System.Collections;
     using System.Collections.Concurrent;
     using System.Collections.Generic;
     using System.ComponentModel.Composition;
-...
     using System.Threading;
     using System.Threading.Tasks;
     using Castle.ActiveRecord;
     using Castle.ActiveRecord.Framework;
     using Castle.ActiveRecord.Framework.Config;
     using Pithos.Interfaces;
-...
             [System.ComponentModel.Composition.Import]
             public IPithosSettings Settings { get; set; }
             private BlockingCollection<Action> _statusUpdateQueue = new BlockingCollection<Action>();
             //private readonly CancellationToken _cancel=new CancellationToken();
             private BlockingCollection<Action> _statusUpdateQueue = new BlockingCollection<Action>();
             public StatusKeeper()
+            {
                 var source = new XmlConfigurationSource("DbConfig.xml");
                 ActiveRecordStarter.Initialize(source,typeof(FileState));
+            {
                 var appDataPath = Environment.GetFolderPath(Environment.SpecialFolder.LocalApplicationData);
                 var pithosDbPath = Path.Combine(appDataPath , "Pithos");
                 var source = GetConfiguration(pithosDbPath);
                 ActiveRecordStarter.Initialize(source,typeof(FileState),typeof(FileTag));
                 if (!File.Exists("pithos.db"))
                 if (!File.Exists(Path.Combine(pithosDbPath ,"pithos.db")))
                     ActiveRecordStarter.CreateSchema();
                 Task.Factory.StartNew(ProcessUpdates);
+            }
             private static InPlaceConfigurationSource GetConfiguration(string pithosDbPath)
+            {
                 var properties = new Dictionary<string, string>
+                                     {
                                          {"connection.driver_class", "NHibernate.Driver.SQLite20Driver"},
                                          {"dialect", "NHibernate.Dialect.SQLiteDialect"},
                                          {"connection.provider", "NHibernate.Connection.DriverConnectionProvider"},
+                                         {
                                              "proxyfactory.factory_class",
                                              "NHibernate.ByteCode.Castle.ProxyFactoryFactory, NHibernate.ByteCode.Castle"
                                              },
                                      };
                 var connectionString = String.Format(@"Data Source={0}\pithos.db;Version=3", pithosDbPath);
                 properties.Add("connection.connection_string", connectionString);
                 var source = new InPlaceConfigurationSource();
                 source.Add(typeof (ActiveRecordBase), properties);
                 return source;
+            }
             public void StartProcessing(CancellationToken token)
+            {
                 Task.Factory.StartNew(ProcessUpdates,token);
+            }
             public void ProcessUpdates()
-...
             public void Stop()
+            {
                 _statusUpdateQueue.CompleteAdding();
                 _statusUpdateQueue.CompleteAdding();
+            }
-...
                 return NetworkState.None;
+            }
             public T GetStatus<T>(string path,Func<FileState,T> getter,T defaultValue )
+            {
-...
                 SetStatus(path,s=>s.OverlayStatus=overlayStatus);
+            }
            /* private static void InnerSetOverlayStatus(string path, FileOverlayStatus overlayStatus)
+            {
                 var filePath = path.ToLower();
                 var state = FileState.TryFind(filePath);
                 if (state != null)
+                {
                     state.OverlayStatus = overlayStatus;
                     state.Update();
+                }
                 else
+                {
                     state = new FileState
                                 {FilePath = filePath, OverlayStatus = overlayStatus};
                     state.Save();
+                }
             }*/
             public void RemoveFileOverlayStatus(string path)
+            {
                 _statusUpdateQueue.Add(() =>
-...
                 state.FilePath = path.ToLower();
                 state.Checksum = objectInfo.Hash;
                 state.FileStatus = FileStatus.Unchanged;
                 state.OverlayStatus = FileOverlayStatus.Normal;
                 state.OverlayStatus = FileOverlayStatus.Normal;
                 foreach (var tag in objectInfo.Tags)
+                {
                     state.Tags.Add(new FileTag
+                                       {
                                            FilePath=state.FilePath,
                                            FileState=state,
                                            Value=tag.Value
                                        });
+                }
                 state.Save();

Also available in: Unified diff

Synnefo » Pithos MS Client

Revision 3c43ec9b trunk/Pithos.Core/StatusKeeper.cs