1

import serial

     2

import exceptions

     3

from threading import Lock

     4

import time

     5

     6

class LPCProtoError(exceptions.Exception):

     7

        """Exception class"""

     8

        def __init__(self, msg):

     9

                self.msg = msg

    10

    11

        def __str__(self):

    12

                return "Exception in PLC protocol : " + str(self.msg)

    13

    14

class LPCProto:

    15

    def __init__(self, port, rate, timeout):

    16

        # serialize access lock

    17

        if BMZ_DBG:

    18

            # Debugging serial stuff

    19

            self._serialPort = serial.Serial( port, rate, timeout = timeout, writeTimeout = timeout )

    20

            class myser:

    21

                def readline(self_):

    22

                    res = self._serialPort.readline() 

    23

                    print 'Recv :"', res, '"' 

    24

                    return res

    25

    26

                def read(self_,cnt):

    27

                    res = self._serialPort.read(cnt)

    28

                    if len(res) > 16:

    29

                        print "Recv :", map(hex,map(ord,res[:16])), "[...]"

    30

                    else:

    31

                        print "Recv :", map(hex,map(ord,res))

    32

    33

                    return res

    34

                def write(self_, string):

    35

                    lstr=len(string)

    36

                    if lstr > 16:

    37

                        print "Send :", map(hex,map(ord,string[:16])), "[...]"

    38

                    else:

    39

                        print "Send :", map(hex,map(ord,string))

    40

                    return self._serialPort.write(string)

    41

                    # while len(string)>0:

    42

                    #     i = self._serialPort.write(string[:4096])

    43

                    #     print ".",

    44

                    #     string = string[i:]

    45

                    # print

    46

                    #return lstr

    47

                def flush(self_):

    48

                    return self._serialPort.flush()

    49

                def close(self_):

    50

                    self._serialPort.close()

    51

            self.serialPort = myser()

    52

        else:

    53

            # open serial port

    54

            self.serialPort = serial.Serial( port, rate, timeout = timeout )

    55

        # start with empty buffer

    56

        self.serialPort.flush()

    57

    58

    def __del__(self):

    59

        if self.serialPort:

    60

            self.serialPort.close()

    61

    62

    def close(self):

    63

        self.serialPort.close()

    64

        self.serialPort = None