Changeset 179

Show
Ignore:
Timestamp:
Tue Dec 20 14:04:00 2005
Author:
drew
Message:

bump

Files:

Legend:

Unmodified
Added
Removed
Modified

  • subprojects/LogGrok/trunk/loggrok/parse.py

    r155 r179  
    53 53  
    54 54     def __init__(self, pattern=None, meta_keys=None):  
    55           self.pattern = pattern or LOG_PATTERN_DEFAULT  
      55         if pattern:  
      56             self.pattern = re.compile(pattern)  
      57         else:  
      58             self.pattern = LOG_PATTERN_DEFAULT  
    56 59         self.meta_keys = meta_keys or ('timestamp', 'level')  
    57 60  

  • subprojects/LogGrok/trunk/loggrok/__init__.py

    r151 r179  
      1 def getLoggrok():  
      2     import log  
      3     import actions  
      4     import parse  
      5     class ModuleSpace:  
      6         log = log  
      7         actions = actions  
      8         parse = parse  
      9     return ModuleSpace()  
      10  

  • subprojects/LogGrok/trunk/loggrok/log.py

    r156 r179  
    27 27     """  
    28 28  
    29       def __init__(self, header=None, parser=None):  
      29     def __init__(self, header=None, parser=None, meta=None):  
    29 29         UserString.__init__(self, '')  
    30           header_parser = parser or parserFactory('log.header')  
    31           # TODO unit test alternate parser  
    32           self.data, meta = header_parser.parse(header)  
      30         if meta is None:  
      31             header_parser = parser or parserFactory('log.header')  
      32             self.data, meta = header_parser.parse(header)  
      33         else:  
      34             self.data = header  
    33 35         for key, value in meta.items():  
    34 36             if hasattr(self, key): # TODO - unit test cover this  
    …… 
    91 93         else:  
    92 94             self.fd = open(logfile)  
    93           self.fd = logfile  
    94 95         self.messageParser = parserFactory('log.message')  
    95 96         self.headerParser  = parserFactory('log.header')  
    …… 
    105 106     def __recvline(self, line):  
    106 107         try:  
    107               header, _ = self.headerParser.parse(line)  
      108             header, meta = self.headerParser.parse(line)  
    107 108             if header:  
      109                 #print 'Got header!', header  
      110                 #print 'length of header', len(header)  
    108 111                 try:  
    109 112                     entry = None  
    110 113                     if self.header:  
    111 114                         entry = self.__process_entry()  
    112                       self.header = LogHeader(header)  
      115                     self.header = LogHeader(header, meta=meta)  
      116                     #print line[len(self.header):]  
    113 117                     self.message_buffer.write(line[len(self.header):])  
    114 118                     return entry  
    115 119                 except LogParseException, lpe:  
      120                     #print lpe  
    116 121                     self.header = LogHeader(header)  
    117 122                     self.message_buffer.truncate(0)  
    …… 
    126 131  
    127 132     def __process_entry(self):  
      133         #print 'entering __process_entry'  
    128 134         message = self.message_buffer.getvalue()  
      135         #print 'processing message:', message  
    129 136         entry = LogEntry(self.header, message, parser=self.messageParser)  
    130 137         self.action(entry)  
    …… 
    212 219         matched = glob.glob(os.path.join(directory, basename + "." + ext + "*"))  
    213 220         matched = _sortmatched(matched, -1)  
      221         #print matched  
    214 222         RollingLogStream.__init__(self, matched)  
    215 223      

  • subprojects/LogGrok/trunk/runtests.py

    r176 r179  
    31 31  
    32 32 docFileTests = glob(pj('test', '*.txt'))  
      33 docFileTests.sort()  
    33 34          
    34 35 if __name__ == '__main__':  
    …… 
    43 44     if len(sys.argv) > 1 and sys.argv[1] == '-f':  
    44 45         print '=' * 80  
    45           print '== Beginning (COMPLETELY BROKEN!!) functional tests'  
      46         print '== Beginning functional tests'  
    45 46         print '=' * 80  
    46 47         import commands