1

import gevent.core as event

     2

     3

class EventBase (object) :

     4

    """

     5

        libevent-style event base.

     6

     7

        XXX: just a wrapper around the gevent libevent bindings, uses implict state..

     8

    """

     9

    10

    def __init__ (self) :

    11

        event.init()

    12

    13

    def timer (self, timeout, cb) :

    14

        return event.event(0, 0, timeout, cb)

    15

    16

    def read (self, fd, cb, timeout=-1) :

    17

        return event.event(event.EV_READ, fd, cb)

    18

    19

    def main (self) :

    20

        """

    21

            Run mainloop until exit.

    22

        """

    23

    24

        event.dispatch()

    25

    26

class SyslogSource (object) :

    27

    def __init__ (self, source, parser) :

    28

        self.source = source

    29

        self.parser = parser

    30

    31

    def event (self, event, evtype) :

    32

        """

    33

            Process source

    34

        """

    35

    36

        # directly iter across source

    37

        for item in self.parser.process(self.source) :

    38

            yield item

    39

    40

    def process (self, item) :

    41

        """

    42

            Handle item from syslog.

    43

        """

    44

    45