Changeset 454

Show
Ignore:
Timestamp:
05/12/08 15:34:11 (8 months ago)
Author:
mgoldman
Message:

Server polls for log files and stores them.

Files:

Legend:

Unmodified
Added
Removed
Modified
Copied
Moved

  • branches/trunk-pmd-intproto/server/master.py

    r453 r454  
    195195                                elif val.msg == 'remove': 
    196196                                        res = self.storeremove((mgr, info), val) 
     197                                elif val.msg == 'log query': 
     198                                        ''' 
     199                                        This section should query the messages and return the 
     200                                        results back to the manager server side. 
     201 
     202                                        The body should hold a simple query (time, (min, max))  
     203                                        (IP, [list of ips]) (group, [groups]) 
     204                                        ''' 
     205                                        print 'Unimplemented' 
     206                                        res = "Unimplemented" 
    197207                                else: 
    198208                                        res = self.comm(ret2, val, (mgr, info)) 
    …… 
    300310                # None for the manager and info since we aren't going to use it. 
    301311                res = self.comm(lambda *x: msg, msg, (None, None)) 
    302                 # FIXME: Put in code here to store the messages in the storage subsytem 
     312                s = storage.Layer(storage_root) 
     313                [s.append_log_messages(id, lst) for ((clientsock,lst), id) in res] 
     314                s.update() 
    303315 
    304316