X-Git-Url: http://git.onelab.eu/?a=blobdiff_plain;f=omf_keys%2Fkey_fs.py;h=e3deadcf9724c860c92458fd75d789e4cad898e5;hb=4f1a974f8f742aa5ed88ed23fc73aff0dea3750c;hp=b9f6c33e9cf4cb0464a8ff9eaf60e980bb313a57;hpb=0252ca4a573eb70be6015cf39324d33fb06d051b;p=playground.git

diff --git a/omf_keys/key_fs.py b/omf_keys/key_fs.py
index b9f6c33..e3deadc 100644
--- a/omf_keys/key_fs.py
+++ b/omf_keys/key_fs.py
@@ -11,23 +11,56 @@
 # Sliver has to have following ccapabilities set.
 # SECURE_MOUNT
 # BINARY_MOUNT
+#
+# we also depend on fuse and python-fuse packages.
+#
 
 
 import os
+import sys
 import stat
 import errno
 import fuse
-import sys
+import fcntl
+import select
 from fuse import Fuse
 
 fuse.fuse_python_api = (0, 2)
 
 keys_dir = "/keys"
-keys_file = os.path.join(keys_dir, "all")
 
-# TODO: for Giovanni
+
 def read_keys():
-    return "reading PLC users' public keys\n"
+    fin = os.open("/vsys/publickeys.in", os.O_NONBLOCK | os.O_WRONLY)
+    fout = os.open("/vsys/publickeys.out", os.O_NONBLOCK | os.O_RDONLY)
+    
+    in_flags = fcntl.fcntl(fin, fcntl.F_GETFL)
+    out_flags = fcntl.fcntl(fin, fcntl.F_GETFL)
+    
+    res = select.select([fout], [], [])
+    
+    fcntl.fcntl(fin, fcntl.F_SETFL, in_flags & ~os.O_NONBLOCK)
+    fcntl.fcntl(fout, fcntl.F_SETFL, out_flags & ~os.O_NONBLOCK)
+    
+    f = os.fdopen(fout, "r")
+    return f.read()
+
+def all_keys():
+    keys = read_keys()
+
+    files = {}
+    num = 0
+    for line in keys.split('\n'):
+        line = line.strip()
+        fields = line.split()
+        try:
+            name = fields[2]
+            files[name] = line
+        except:
+            num += 1
+            files["unnamed_key%d" % num] = line
+
+    return files
 
 class MyStat(fuse.Stat):
     def __init__(self):
@@ -52,14 +85,26 @@ class KeyFS(Fuse):
         if path == '/':
             st.st_mode = stat.S_IFDIR | 0755
             st.st_nlink = 2
-        else:
+        elif os.path.basename(path) == "all":
             st.st_mode = stat.S_IFREG | 0444
             st.st_nlink = 1
             st.st_size = len(read_keys())
+        else:
+            filename = os.path.basename(path)
+            keys = all_keys()
+            st.st_mode = stat.S_IFREG | 0444
+            st.st_nlink = 1
+            try:
+                st.st_size = len(keys[filename])
+            except:
+                st.st_size = 0
         return st
 
     def readdir(self, path, offset):
-        for r in  '.', '..', os.path.basename(keys_file):
+        files = ['.', '..', "all"]
+        keys = all_keys()
+        files.extend(keys.keys())
+        for r in files:
             yield fuse.Direntry(r)
 
     def open(self, path, flags):
@@ -68,8 +113,14 @@ class KeyFS(Fuse):
             return -errno.EACCES
 
     def read (self, path, size, offset):
-        keys = read_keys()
-        slen = len(keys)
+        if os.path.basename(path) == "all":
+            content = read_keys()
+        else:
+            filename = os.path.basename(path)
+            keys = all_keys()
+            content = keys[filename]
+
+        slen = len(content)
 
         if offset < slen:
             if offset + size > slen: