From: Melissa LeBlanc-Williams Date: Mon, 1 May 2023 17:11:06 +0000 (-0700) Subject: Merge pull request #677 from Gerriko/patch-1 X-Git-Tag: 8.19.0 X-Git-Url: https://git.ayoreis.com/Adafruit_Blinka-hackapet.git/commitdiff_plain/b84de4800b2c31023f29a536d26209bd7517d504?hp=296fab9e4cce0687546e0232708a198ef59ff9b2 Merge pull request #677 from Gerriko/patch-1 Uses libgpiod_pin.py --- diff --git a/.gitignore b/.gitignore index 5fb597b..4c18ddf 100644 --- a/.gitignore +++ b/.gitignore @@ -14,3 +14,4 @@ bundles dist **/*.egg-info .vscode +build diff --git a/setup.py b/setup.py index 51df791..c94ab3c 100755 --- a/setup.py +++ b/setup.py @@ -75,6 +75,9 @@ setup( "libgpiod_pulsein", "libgpiod_pulsein64", ], + "adafruit_blinka.microcontroller.amlogic.meson_g12_common.pulseio": [ + "libgpiod_pulsein", + ], "micropython-stubs": ["*.pyi"], }, include_package_data=True, diff --git a/src/adafruit_blinka/board/hardkernel/odroidc4.py b/src/adafruit_blinka/board/hardkernel/odroidc4.py index 2191013..814f374 100644 --- a/src/adafruit_blinka/board/hardkernel/odroidc4.py +++ b/src/adafruit_blinka/board/hardkernel/odroidc4.py @@ -9,8 +9,9 @@ for it in pin.i2cPorts: globals()["SCL" + str(it[0])] = it[1] globals()["SDA" + str(it[0])] = it[2] -SCL = pin.i2cPorts[0][1] -SDA = pin.i2cPorts[0][2] +if pin.i2cPorts: + SCL = pin.i2cPorts[0][1] + SDA = pin.i2cPorts[0][2] SCLK = pin.SPI0_SCLK MOSI = pin.SPI0_MOSI diff --git a/src/adafruit_blinka/microcontroller/amlogic/meson_g12_common/pin.py b/src/adafruit_blinka/microcontroller/amlogic/meson_g12_common/pin.py index 41cf8f2..87f4571 100644 --- a/src/adafruit_blinka/microcontroller/amlogic/meson_g12_common/pin.py +++ b/src/adafruit_blinka/microcontroller/amlogic/meson_g12_common/pin.py @@ -14,23 +14,34 @@ Linux kernel 5.4.y (mainline) from typing import Optional import os import re -import gpiod + +try: + import gpiod +except ImportError: + raise ImportError( + "libgpiod Python bindings not found, please install and try again!" + ) from ImportError from adafruit_blinka.microcontroller.generic_linux.libgpiod_pin import Pin -chip0 = gpiod.Chip("0") -chip1 = gpiod.Chip("1") +if hasattr(gpiod, "Chip"): + chip0 = gpiod.Chip("0") + chip1 = gpiod.Chip("1") +else: + chip0 = gpiod.chip("0") + chip1 = gpiod.chip("1") + -if chip0.num_lines() < 20: +if chip0.num_lines < 20: aobus = 0 periphs = 1 - periphs_offset = chip1.num_lines() - 85 + periphs_offset = chip1.num_lines - 85 else: aobus = 1 periphs = 0 - periphs_offset = chip0.num_lines() - 85 + periphs_offset = chip0.num_lines - 85 -chip0.close() -chip1.close() +del chip0 +del chip1 GPIOAO_0 = GPIO496 = Pin((aobus, 0)) GPIOAO_1 = GPIO497 = Pin((aobus, 1)) diff --git a/src/adafruit_blinka/microcontroller/amlogic/meson_g12_common/pulseio/PulseIn.py b/src/adafruit_blinka/microcontroller/amlogic/meson_g12_common/pulseio/PulseIn.py new file mode 100644 index 0000000..ae82f1c --- /dev/null +++ b/src/adafruit_blinka/microcontroller/amlogic/meson_g12_common/pulseio/PulseIn.py @@ -0,0 +1,183 @@ +# SPDX-FileCopyrightText: 2021 Melissa LeBlanc-Williams for Adafruit Industries +# +# SPDX-License-Identifier: MIT +"""Custom PulseIn Class to read PWM signals""" +import time +import subprocess +import os +import atexit +import random +import sysv_ipc + +DEBUG = False +queues = [] +procs = [] + +# The message queues live outside of python space, and must be formally cleaned! +def final(): + """In case the program is cancelled or quit, we need to clean up the PulseIn + helper process and also the message queue, this is called at exit to do so""" + if DEBUG: + print("Cleaning up message queues", queues) + print("Cleaning up processes", procs) + for q in queues: + q.remove() + for proc in procs: + proc.terminate() + + +atexit.register(final) + +# pylint: disable=c-extension-no-member +class PulseIn: + """PulseIn Class to read PWM signals""" + + def __init__(self, pin, maxlen=2, idle_state=False): + """Create a PulseIn object associated with the given pin. + The object acts as a read-only sequence of pulse lengths with + a given max length. When it is active, new pulse lengths are + added to the end of the list. When there is no more room + (len() == maxlen) the oldest pulse length is removed to make room.""" + + if isinstance(pin.id, tuple): + self._pin = str(pin.id[1]) + self._chip = "gpiochip{}".format(pin.id[0]) + else: + self._pin = str(pin.id) + self._chip = "gpiochip0" + + self._maxlen = maxlen + self._idle_state = idle_state + self._queue_key = random.randint(1, 9999) + try: + self._mq = sysv_ipc.MessageQueue(None, flags=sysv_ipc.IPC_CREX) + if DEBUG: + print("Message Queue Key: ", self._mq.key) + queues.append(self._mq) + except sysv_ipc.ExistentialError: + raise RuntimeError( + "Message queue creation failed" + ) from sysv_ipc.ExistentialError + + # Check if OS is 64-bit + libgpiod_filename = "libgpiod_pulsein" + dir_path = os.path.dirname(os.path.realpath(__file__)) + cmd = [ + dir_path + "/" + libgpiod_filename, + "--pulses", + str(maxlen), + "--queue", + str(self._mq.key), + ] + if idle_state: + cmd.append("-i") + cmd.append(self._chip) + cmd.append(self._pin) + if DEBUG: + print(cmd) + + self._process = subprocess.Popen(cmd) # pylint: disable=consider-using-with + procs.append(self._process) + + # wait for it to start up + if DEBUG: + print("Waiting for startup success message from subprocess") + message = self._wait_receive_msg(timeout=0.25) + if message[0] != b"!": + raise RuntimeError("Could not establish message queue with subprocess") + self._paused = False + + # pylint: disable=redefined-builtin + def _wait_receive_msg(self, timeout=0, type=2): + """Internal helper that will wait for new messages of a given type, + and throw an exception on timeout""" + if timeout > 0: + stamp = time.monotonic() + while (time.monotonic() - stamp) < timeout: + try: + message = self._mq.receive(block=False, type=type) + return message + except sysv_ipc.BusyError: + time.sleep(0.001) # wait a bit then retry! + # uh-oh timed out + raise RuntimeError( + "Timed out waiting for PulseIn message. Make sure libgpiod is installed." + ) + message = self._mq.receive(block=True, type=type) + return message + + # pylint: enable=redefined-builtin + + def deinit(self): + """Deinitialises the PulseIn and releases any hardware and software + resources for reuse.""" + # Clean up after ourselves + self._process.terminate() + procs.remove(self._process) + self._mq.remove() + queues.remove(self._mq) + + def __enter__(self): + """No-op used by Context Managers.""" + return self + + def __exit__(self, exc_type, exc_value, tb): + """Automatically deinitializes the hardware when exiting a context.""" + self.deinit() + + def resume(self, trigger_duration=0): + """Resumes pulse capture after an optional trigger pulse.""" + if trigger_duration != 0: + self._mq.send("t%d" % trigger_duration, True, type=1) + else: + self._mq.send("r", True, type=1) + self._paused = False + + def pause(self): + """Pause pulse capture""" + self._mq.send("p", True, type=1) + self._paused = True + + @property + def paused(self): + """True when pulse capture is paused as a result of pause() or + an error during capture such as a signal that is too fast.""" + return self._paused + + @property + def maxlen(self): + """The maximum length of the PulseIn. When len() is equal to maxlen, + it is unclear which pulses are active and which are idle.""" + return self._maxlen + + def clear(self): + """Clears all captured pulses""" + self._mq.send("c", True, type=1) + + def popleft(self): + """Removes and returns the oldest read pulse.""" + self._mq.send("^", True, type=1) + message = self._wait_receive_msg() + reply = int(message[0].decode("utf-8")) + # print(reply) + if reply == -1: + raise IndexError("pop from empty list") + return reply + + def __len__(self): + """Returns the current pulse length""" + self._mq.send("l", True, type=1) + message = self._wait_receive_msg() + return int(message[0].decode("utf-8")) + + # pylint: disable=redefined-builtin + def __getitem__(self, index, type=None): + """Returns the value at the given index or values in slice.""" + self._mq.send("i%d" % index, True, type=1) + message = self._wait_receive_msg() + ret = int(message[0].decode("utf-8")) + if ret == -1: + raise IndexError("list index out of range") + return ret + + # pylint: enable=redefined-builtin diff --git a/src/adafruit_blinka/microcontroller/amlogic/meson_g12_common/pulseio/__init__.py b/src/adafruit_blinka/microcontroller/amlogic/meson_g12_common/pulseio/__init__.py new file mode 100644 index 0000000..e69de29 diff --git a/src/adafruit_blinka/microcontroller/amlogic/meson_g12_common/pulseio/libgpiod_pulsein b/src/adafruit_blinka/microcontroller/amlogic/meson_g12_common/pulseio/libgpiod_pulsein new file mode 100755 index 0000000..51bcb9a Binary files /dev/null and b/src/adafruit_blinka/microcontroller/amlogic/meson_g12_common/pulseio/libgpiod_pulsein differ diff --git a/src/adafruit_blinka/microcontroller/amlogic/meson_g12_common/pulseio/libgpiod_pulsein.license b/src/adafruit_blinka/microcontroller/amlogic/meson_g12_common/pulseio/libgpiod_pulsein.license new file mode 100644 index 0000000..3165372 --- /dev/null +++ b/src/adafruit_blinka/microcontroller/amlogic/meson_g12_common/pulseio/libgpiod_pulsein.license @@ -0,0 +1,3 @@ +# SPDX-FileCopyrightText: 2023 Jan Volckaert for Adafruit Industries +# +# SPDX-License-Identifier: MIT diff --git a/src/pulseio.py b/src/pulseio.py index f80459e..c6aa49e 100644 --- a/src/pulseio.py +++ b/src/pulseio.py @@ -20,5 +20,9 @@ if detector.board.any_raspberry_pi: from adafruit_blinka.microcontroller.bcm283x.pulseio.PulseIn import PulseIn elif "sphinx" in sys.modules: pass +elif detector.board.any_odroid_40_pin: + from adafruit_blinka.microcontroller.amlogic.meson_g12_common.pulseio.PulseIn import ( + PulseIn, + ) else: raise NotImplementedError("pulseio not supported for this board.")