Changeset 439

Timestamp:

05/07/08 10:24:55 (8 months ago)

Author:

jmowery

Message:

adding status message processing
output not yet formatted

Files:

• branches/trunk-pmd-intproto/mgmt/manager.py (modified) (9 diffs)

branches/trunk-pmd-intproto/mgmt/manager.py

@@ -32 +32 @@
-                return resp
-
+        def client_status(self):
+                print 'client status'
+                msg = protocol.Message()
+                msg.msg = 'client status'
+                msg.type = 'query'
+                msg.body = []
+                return msg
+
-        def update(self):
-                print "update"
@@ -88 +96 @@
-                return msg
-
-
-
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
-                # targets is a pair, (group|IP, [t-list])
-=======
-        def add_message(self, group=''):
-                msg = protocol.Message()
-                msg.msg = 'add'
-                msg.type = 'query'
-                msg.body = (group, [])
-                return msg
-
-        def remove_message(self, group=''):
-                msg = protocol.Message()
-                msg.msg = 'remove'
-                msg.type = 'query'
-                msg.body = (group, [])
-                return msg
-
-        def query_server(self, msg):
->>>>>>> .r436
-                if msg is None:
-                        return None
@@ -131 +135 @@
-### returns the response from the server.
-def handlestorage(mgr, cmd, argv):
-
+...
-        if(len(argv) < 2):
-                print useage
@@ -139 +143 @@
-                print 'Group \'' + argv[0] + '\' does not exist'
-                sys.exit(1)
+        files = []
-        if cmd == 'add':
-
-
-
-
+
+
+
-                        else:
-arg))), file_util.checksum(arg
+file_name))), file_util.checksum(file_name
-                if len(files) != len(argv[1:]):
-                        sys.exit(1)
@@ -176 +180 @@
-                print useage
-                sys.exit(1)
- 
+
-
-def handlelist(mgr, argv):
@@ -201 +205 @@
-                print 'list what?'
-                sys.exit(1)
- 
+
-
-def handlelog(manager, arglist):
@@ -224 +228 @@
-        return resp
-
+def handlestatus(mgr, argv):
+        msg = m.client_status()
+        print_bools = False
+        print_enforcing = False
+        print_modules = False
+        clientlist = []
+        resp = m.query_server(m.list_clients())
+        for arg in argv:
+                if arg == 'all':
+                        print_bools = True
+                        print_enforcing = True
+                        print_modules = True
+                        break
+                elif arg == 'bools':
+                        print_bools = True
+                elif arg == 'enforcing':
+                        print_enforcing = True
+                elif arg == 'modules':
+                        print_modules = True
+                else:
+                        if arg not in resp.body:
+                                print 'No client with ID \'' + arg + '\' exists'
+                        else:
+                                clientlist.append(arg)
+        if print_bools:
+                msg.body[1].append('bools')
+        if print_modules:
+                msg.body[1].append('modules')
+        if print_enforcing:
+                msg.body[1].append('enforcing')
+        if len(clientlist) == 0:
+                print 'missing valid client ID'
+                sys.exit(1)
+        targets = ['IP'] + clientlist
+        return mgr.query_server(msg, targets)
+
-if __name__ == '__main__':
-        m = Manager('localhost')
@@ -236 +276 @@
-                res = handleupdate(m, sys.argv[2:])
-        elif cmd == 'status':
-print 'status requests not yet implemented'
+res = handlestatus(m, sys.argv[2:])
-        elif cmd == 'list':
-                res = handlelist(m, sys.argv[2:])
@@ -242 +282 @@
-                res = handlelog(m, sys.argv[2:])
-        else:
-
+n
-                sys.exit(1)
-        pprint.pprint(repr(res))
-
-
-
-
-
-
-
-
-
-
+
+
+