mytasks : début d'implementation a l'aide de multiprocessing

1 files changed, 11 insertions, 4 deletions

diff --git a/raidguessfs.py b/raidguessfs.py
index ac56278..5aa8347 100755
--- a/raidguessfs.py
+++ b/raidguessfs.py
@@ -53,7 +53,7 @@ class RaidGuessFS(fuse.Fuse):
         self.raid = myraid.MyRaid()
         self.bmp = mybinview.MyBinView()
         self.st = mystat.MyStat()
-        self.tasks = mytasks.MyTasks()
+        self.tasks = mytasks.MyTasks(self.d)
 
         self.bmp.refresh_bmp()
 
@@ -73,7 +73,7 @@ class RaidGuessFS(fuse.Fuse):
                 self.raid.get_raid_start, self.raid.get_raid_end, self.raid.get_raid_chunk_size,
                 self.raid.get_raid_disk_order_str, self.raid.get_raid_layout,
                 self.bmp.get_bmp_height, self.bmp.get_bmp_width, self.bmp.get_bmp_start_offset,
-                self.tasks.get_task_start, self.tasks.get_task_kill, self.tasks.get_find_files_pathlist_str,
+                self.get_task_start, self.get_task_kill, self.tasks.get_find_files_pathlist_str,
                 ]
 
         self.settings_updaters = [
@@ -81,9 +81,10 @@ class RaidGuessFS(fuse.Fuse):
                 self.update_raid_start, self.update_raid_end, self.update_raid_chunk_size, self.update_raid_disk_order,
                 self.raid.set_raid_layout,
                 self.update_bmp_height, self.update_bmp_width, self.update_bmp_start_offset,
-                self.tasks.set_task_start, self.tasks.set_task_kill, self.update_task_find_files_pathlist,
+                self.tasks.task_start, self.tasks.task_kill, self.update_task_find_files_pathlist,
                 ]
 
+
         self.dentries = {
                 '/'      : [ fuse.Direntry(name) for name in ['config','disk','raid','tasks','visual'] ],
                 '/config': [ fuse.Direntry(name) for name in self.settings ],
@@ -215,11 +216,17 @@ class RaidGuessFS(fuse.Fuse):
         self.tasks.set_find_files_pathlist(l)
         logging.debug("Exit. update_task_find_files_pathlist(%s)"%arg)
 
+    def get_task_start(self):
+        return 'Write a task_name in this pseudo-file to start it\n'
+    
+    def get_task_kill(self):
+        return 'Write a task_name in this pseudo-file to kill it\n'
+
+
 ########################################################
 # Actual File System operations implementation follows #
 ########################################################
 
-
     def fsinit(self):
         """Make some run-time initalisations after argument parsing"""
         logging.info("Mounting filesystem...")