Changeset 508

Show
Ignore:
Timestamp:
05/29/08 14:44:37 (7 months ago)
Author:
mgoldman
Message:

Fix log storage and retrieval.

Files:

Legend:

Unmodified
Added
Removed
Modified
Copied
Moved

  • branches/trunk-pmd-intproto/agent/agent_log.py

    r437 r508  
    1717        def __init__(self, log_path = None): 
    1818                self.log_path = log_path 
    19                 f = open(self.log_path) 
    20                 self.log = audit.AuditLog(f) 
    21                 self.offset = f.tell() 
    22                 self.len = len(self.log) 
     19                #f = open(self.log_path) 
     20                #self.log = audit.AuditLog(f) 
     21                #self.offset = f.tell() 
     22                #self.len = len(self.log) 
     23                self.log = audit.AuditLog() 
     24                self.offset = 0 
     25                self.len = 0 
    2326                pass 
    2427         

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

    r504 r508  
    292292                                        val.type = "response" 
    293293                                        root_layer = storage.Layer(storage_root) 
    294                                         all_messages = [root_layer.get_log_messages(x) for x in root_layer.list_nodes()] 
     294                                        all_messages = [(x,root_layer.get_log_messages(x)) for x in root_layer.list_nodes()] 
    295295                                        root_layer.update() 
    296                                         res = self.filtermsgs(all_messages, val.body) 
     296                                        x = self.filtermsgs(all_messages, val.body) 
     297                                        val.body = x 
     298                                        res = val 
    297299                                elif val.msg == "client status": 
    298300                                        val.type = 'response' 

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

    r487 r508  
    10061006        def get_log_messages(self, id): 
    10071007                '''Retrieve all log messages stored for node id.''' 
    1008                 if not storage: 
     1008                if not self.storage: 
    10091009                        return [] 
    10101010                if id not in self.list_nodes(): 
    10111011                        return [] 
    10121012                log_file = open(os.path.join(self.storage.logs_dir, id), 'r') 
    1013                 messages = pickle.load(log_file) 
     1013                messages = [] 
     1014                while True: 
     1015                        try: 
     1016                                messages.append( pickle.load(log_file) ) 
     1017                        except: 
     1018                                break 
    10141019                log_file.close() 
    10151020                return messages