1

import logging; log = logging.getLogger('pvl.syslog.filter')

     2

     3

class SyslogFilter (object) :

     4

    """

     8

    """

     9

    10

    def __init__ (self, prog=None) :

    11

        """

    12

            prog        - match tag (process name)

    13

        """

    15

        self.prog = prog

    16

    17

    def match_prog (self, prog) :

    18

        """

    19

            Match given prog?

    20

        """

    21

    25

        # normalize

    26

        prog = prog.lower()

    27

    28

        if prog.startswith('/') :

    29

            # base

    30

            prog = prog.split('/')[-1]

    31

    32

        # match

    33

        if not prog :

    34

            # never matches non-tagged lines

    35

            return False

    36

    37

        elif self.prog.endswith('*') :

    38

            # prefix match

    39

            return prog.startswith(self.prog[:-1])

    40

    41

        else :

    42

            return prog == self.prog

    43

    44

    def filter (self, item) :

    45

        """

    46

            Match given item?

    47

        """

    48

    53

    67

        else :

    69

    70

    def __call__ (self, items) :

    71

        for item in items:

    72

            if self.filter(item) :

    73

                yield item

    74