Details | Last modification | View Log | SVN | RSS feed
| Rev | Author | Line No. | Line |
|---|---|---|---|
| 736 | olof | 1 | ########################################################### |
| 2 | # |
||
| 3 | # The default implementation of the packet handler |
||
| 4 | # |
||
| 5 | ########################################################### |
||
| 6 | from CanPktHandlerBase import CanPktHandlerBase |
||
| 7 | |||
| 8 | class CanPktHandler1(CanPktHandlerBase): |
||
| 9 | |||
| 10 | daemonCfg = None |
||
| 11 | |||
| 12 | def __init__ (self, daemonCfg): |
||
| 13 | self.daemonCfg = daemonCfg |
||
| 14 | |||
| 15 | def input(self, data): |
||
| 16 | """Make data buffer into CanPkt and do early discard check """ |
||
| 17 | """Call all filters in chain """ |
||
| 18 | |||
| 19 | if len(data) < 2: |
||
| 20 | return |
||
| 21 | if data[0:3] != 'PKT': |
||
| 22 | return |
||
| 23 | |||
| 24 | print data |
||
| 25 | |||
| 26 | # FIXME: convert data to class canpkt before passing to filter chain |
||
| 27 | |||
| 28 | for filter in daemonConfig.filterChain: |
||
| 29 | fObj = cfg.filterCfg.filterModules[filter] |
||
| 30 | fObj.filter(data, fObj.__ASSOCIATED_SPACES__) |
||
| 31 | |||
| 32 | def output(self, data): |
||
| 33 | pass |