GpioChip
+ * + * @author Alexander Liggesmeyer (https://alexander.liggesmeyer.net/) + * @version $Id: $Id + */ +public class GpioChip extends CWrapper implements Closeable { + + public GpioChip(long cPointer) { + super(cPointer); + } + + public void close() { + GpioD.chipClose(this); + } + + public String getName() { + return GpioD.chipGetName(this); + } + + public String getLabel() { + return GpioD.chipGetLabel(this); + } + + public int getNumLines() { + return GpioD.chipGetNumLines(this); + } + + public GpioLine getLine(int offset) { + return GpioD.chipGetLine(this, offset); + } + + public GpioLineBulk getLines(int[] offsets) { + GpioLineBulk bulk = new GpioLineBulk(); + GpioD.chipGetLines(this, offsets, bulk); + return bulk; + } + + public GpioLineBulk getLines() { + GpioLineBulk bulk = new GpioLineBulk(); + GpioD.chipGetAllLines(this, bulk); + return bulk; + } + + public GpioLine getLine(String name) { + return GpioD.chipGetLine(this, name); + } + +} diff --git a/libraries/pi4j-library-gpiod/src/main/java/com/pi4j/library/gpiod/internal/GpioChipIterator.java b/libraries/pi4j-library-gpiod/src/main/java/com/pi4j/library/gpiod/internal/GpioChipIterator.java new file mode 100644 index 00000000..1be9c4c6 --- /dev/null +++ b/libraries/pi4j-library-gpiod/src/main/java/com/pi4j/library/gpiod/internal/GpioChipIterator.java @@ -0,0 +1,72 @@ +package com.pi4j.library.gpiod.internal; + +import java.util.Iterator; + +/** + *GpioChipIterator
+ * + * @author Alexander Liggesmeyer (https://alexander.liggesmeyer.net/) + * @version $Id: $Id + */ +public class GpioChipIterator extends CWrapper implements IteratorGpioD interface.
+ * + * @author Alexander Liggesmeyer (https://alexander.liggesmeyer.net/) + * @version $Id: $Id + */ +public class GpioD { + // C library: https://git.kernel.org/pub/scm/libs/libgpiod/libgpiod.git/tree/include/gpiod.h?h=v1.6.x + + private GpioD() { + // forbid object construction + } + + static { + // Load the platform library + NativeLibraryLoader.load("libgpiod.so", "pi4j-gpiod"); + NativeLibraryLoader.load("libpi4j-gpiod.so", "pi4j-gpiod"); + } + + static GpioChip chipOpen(String path) { + Long ptr = c_gpiod_chip_open(path); + if(ptr == null) { + throw new GpioDException("c_gpiod_chip_open failed!"); + } + return new GpioChip(ptr); + } + + private static native Long c_gpiod_chip_open(String path); + + static void chipClose(GpioChip chip) { + c_gpiod_chip_close(chip.getCPointer()); + } + + private static native void c_gpiod_chip_close(long chipPtr); + + static String chipGetName(GpioChip chip) { + return c_gpiod_chip_name(chip.getCPointer()); + } + + private static native String c_gpiod_chip_name(long chipPtr); + + static String chipGetLabel(GpioChip chip) { + return c_gpiod_chip_label(chip.getCPointer()); + } + + private static native String c_gpiod_chip_label(long chipPtr); + + static int chipGetNumLines(GpioChip chip) { + return c_gpiod_chip_num_lines(chip.getCPointer()); + } + + private static native int c_gpiod_chip_num_lines(long chipPtr); + + static GpioLine chipGetLine(GpioChip chip, int offset) { + Long linePtr = c_gpiod_chip_get_line(chip.getCPointer(), offset); + if (linePtr == null) { + throw new GpioDException("c_gpiod_chip_get_line failed!"); + } + return new GpioLine(linePtr); + } + private static native Long c_gpiod_chip_get_line(long chipPtr, int offset); + + static void chipGetLines(GpioChip chip, int[] offsets, GpioLineBulk lineBulk) { + if(c_gpiod_chip_get_lines(chip.getCPointer(), offsets, offsets.length, lineBulk.getCPointer()) < 0) { + throw new GpioDException("c_gpiod_chip_get_lines failed!"); + } + } + + private static native int c_gpiod_chip_get_lines(long chipPtr, int[] offsets, int numOffsets, long lineBulkPtr); + + static void chipGetAllLines(GpioChip chip, GpioLineBulk lineBulk) { + if(c_gpiod_chip_get_all_lines(chip.getCPointer(), lineBulk.getCPointer()) < 0) { + throw new GpioDException("c_gpiod_chip_get_all_lines failed!"); + } + } + + private static native int c_gpiod_chip_get_all_lines(long chipPtr, long lineBulkPtr); + + static GpioLine chipGetLine(GpioChip chip, String name) { + Long linePtr = c_gpiod_chip_find_line(chip.getCPointer(), name); + if (linePtr == null) { + throw new GpioDException("c_gpiod_chip_find_line failed!"); + } + return new GpioLine(linePtr); + } + + private static native Long c_gpiod_chip_find_line(long chipPtr, String name); + + static void lineBulkFree(GpioLineBulk lineBulk) { + c_gpiod_line_bulk_free(lineBulk.getCPointer()); + } + + private static native void c_gpiod_line_bulk_free(long lineBulkPtr); + + private static native void gpiod_line_bulk_init(long lineBulkPtr); + + static long lineBulkNew() { + Long ptr = c_gpiod_line_bulk_new(); + if(ptr == null) { + throw new GpioDException("c_gpiod_line_bulk_new failed!"); + } + gpiod_line_bulk_init(ptr); + return ptr; + } + + private static native Long c_gpiod_line_bulk_new(); + + static void lineBulkAdd(GpioLineBulk lineBulk, GpioLine line) { + c_gpiod_line_bulk_add(lineBulk.getCPointer(), line.getCPointer()); + } + + private static native void c_gpiod_line_bulk_add(long lineBulkPtr, long linePtr); + + static GpioLine lineBulkGetLine(GpioLineBulk lineBulk, int offset) { + return new GpioLine(c_gpiod_line_bulk_get_line(lineBulk.getCPointer(), offset)); + } + + private static native long c_gpiod_line_bulk_get_line(long lineBulkPtr, int offset); + + static int lineBulkGetNumLines(GpioLineBulk lineBulk) { + return c_gpiod_line_bulk_num_lines(lineBulk.getCPointer()); + } + + private static native int c_gpiod_line_bulk_num_lines(long lineBulkPtr); + + + public enum LINE_DIRECTION { + INPUT(1), OUTPUT(2); + final int val; + + public int getVal() { + return val; + } + + LINE_DIRECTION(int val) { + this.val = val; + } + + static LINE_DIRECTION fromInt(int val) { + for (LINE_DIRECTION dir : LINE_DIRECTION.values()) { + if (dir.val == val) { + return dir; + } + } + throw new IllegalStateException("Unexpected LINE_DIRECTION value: " + val); + } + } + + public enum LINE_ACTIVE_STATE { + HIGH(1), LOW(2); + final int val; + + public int getVal() { + return val; + } + + LINE_ACTIVE_STATE(int val) { + this.val = val; + } + + static LINE_ACTIVE_STATE fromInt(int val) { + for (LINE_ACTIVE_STATE dir : LINE_ACTIVE_STATE.values()) { + if (dir.val == val) { + return dir; + } + } + throw new IllegalStateException("Unexpected LINE_ACTIVE_STATE value: " + val); + } + } + + public enum LINE_BIAS { + AS_IS(1), DISABLE(2), PULL_UP(3), PULL_DOWN(4); + final int val; + + public int getVal() { + return val; + } + + LINE_BIAS(int val) { + this.val = val; + } + + static LINE_BIAS fromInt(int val) { + for (LINE_BIAS dir : LINE_BIAS.values()) { + if (dir.val == val) { + return dir; + } + } + throw new IllegalStateException("Unexpected LINE_BIAS value: " + val); + } + } + + static int lineGetOffset(GpioLine line) { + return c_gpiod_line_offset(line.getCPointer()); + } + + private static native int c_gpiod_line_offset(long linePtr); + + static String lineGetName(GpioLine line) { + return c_gpiod_line_name(line.getCPointer()); + } + + private static native String c_gpiod_line_name(long linePtr); + + static String lineGetConsumer(GpioLine line) { + return gpiod_line_consumer(line.getCPointer()); + } + + private static native String gpiod_line_consumer(long linePtr); + + static LINE_DIRECTION lineGetDirection(GpioLine line) { + return LINE_DIRECTION.fromInt(c_gpiod_line_direction(line.getCPointer())); + } + + private static native int c_gpiod_line_direction(long linePtr); + + static LINE_ACTIVE_STATE lineGetActiveState(GpioLine line) { + return LINE_ACTIVE_STATE.fromInt(c_gpiod_line_active_state(line.getCPointer())); + } + + private static native int c_gpiod_line_active_state(long linePtr); + + static LINE_BIAS lineGetBias(GpioLine line) { + return LINE_BIAS.fromInt(c_gpiod_line_bias(line.getCPointer())); + } + + private static native int c_gpiod_line_bias(long linePtr); + + static boolean lineIsUsed(GpioLine line) { + return c_gpiod_line_is_used(line.getCPointer()); + } + + private static native boolean c_gpiod_line_is_used(long linePtr); + + static boolean lineIsOpenDrain(GpioLine line) { + return c_gpiod_line_is_open_drain(line.getCPointer()); + } + + private static native boolean c_gpiod_line_is_open_drain(long linePtr); + + static boolean lineIsOpenSource(GpioLine line) { + return c_gpiod_line_is_open_source(line.getCPointer()); + } + + private static native boolean c_gpiod_line_is_open_source(long linePtr); + + static void lineUpdate(GpioLine line) { + if(c_gpiod_line_update(line.getCPointer()) < 0) { + throw new GpioDException("c_gpiod_line_update failed!"); + } + } + + private static native int c_gpiod_line_update(long linePtr); + + public enum LINE_REQUEST { + DIRECTION_AS_IS(1), DIRECTION_INPUT(2), DIRECTION_OUTPUT(3), EVENT_FALLING_EDGE(4), + EVENT_RISING_EDGE(5), EVENT_BOTH_EDGES(6); + final int val; + + public int getVal() { + return val; + } + + LINE_REQUEST(int val) { + this.val = val; + } + + static LINE_REQUEST fromInt(int val) { + for (LINE_REQUEST dir : LINE_REQUEST.values()) { + if (dir.val == val) { + return dir; + } + } + throw new IllegalStateException("Unexpected LINE_REQUEST value: " + val); + } + } + + public enum LINE_REQUEST_FLAG { + OPEN_DRAIN((byte) 1), OPEN_SOURCE((byte) (1 << 1)), ACTIVE_LOW((byte) (1 << 2)), BIAS_DISABLE((byte) (1 << 3)), + BIAS_PULL_DOWN((byte) (1 << 4)), BIAS_PULL_UP((byte) (1 << 5)); + final byte val; + + LINE_REQUEST_FLAG(byte val) { + this.val = val; + } + + public byte getVal() { + return val; + } + + static LINE_REQUEST_FLAG fromByte(byte val) { + for (LINE_REQUEST_FLAG dir : LINE_REQUEST_FLAG.values()) { + if (dir.val == val) { + return dir; + } + } + throw new IllegalStateException("Unexpected LINE_REQUEST_FLAG value: " + val); + } + } + + static void lineRequest(GpioLine line, GpioLineRequest request, int defaultVal) { + if(c_gpiod_line_request(line.getCPointer(), request.getCPointer(), defaultVal) < 0) { + throw new GpioDException("c_gpiod_line_request failed!"); + } + } + + private static native int c_gpiod_line_request(long linePtr, long lineRequestPtr, int default_val); + + static void lineRequestInput(GpioLine line, String consumer) { + if(c_gpiod_line_request_input(line.getCPointer(), consumer) < 0) { + throw new GpioDException("c_gpiod_line_request_input failed!"); + } + } + + private static native int c_gpiod_line_request_input(long linePtr, String consumer); + + static void lineRequestOutput(GpioLine line, String consumer, int defaultVal) { + if(c_gpiod_line_request_output(line.getCPointer(), consumer, defaultVal) < 0) { + throw new GpioDException("c_gpiod_line_request_output failed!"); + } + } + + private static native int c_gpiod_line_request_output(long linePtr, String consumer, int default_val); + + static void lineRequestRisingEdgeEvents(GpioLine line, String consumer) { + if(c_gpiod_line_request_rising_edge_events(line.getCPointer(), consumer) < 0) { + throw new GpioDException("c_gpiod_line_request_rising_edge_events failed!"); + } + } + + private static native int c_gpiod_line_request_rising_edge_events(long linePtr, String consumer); + + static void lineRequestFallingEdgeEvents(GpioLine line, String consumer) { + if(c_gpiod_line_request_falling_edge_events(line.getCPointer(), consumer) < 0) { + throw new GpioDException("c_gpiod_line_request_falling_edge_events failed!"); + } + } + + private static native int c_gpiod_line_request_falling_edge_events(long linePtr, String consumer); + + static void lineRequestBothEdgeEvents(GpioLine line, String consumer) { + if(c_gpiod_line_request_both_edges_events(line.getCPointer(), consumer) < 0) { + throw new GpioDException("c_gpiod_line_request_both_edges_events failed!"); + } + } + + private static native int c_gpiod_line_request_both_edges_events(long linePtr, String consumer); + + static void lineRequestInputFlags(GpioLine line, String consumer, int flags) { + if(c_gpiod_line_request_input_flags(line.getCPointer(), consumer, flags) < 0) { + throw new GpioDException("c_gpiod_line_request_input_flags failed!"); + } + } + + private static native int c_gpiod_line_request_input_flags(long linePtr, String consumer, int flags); + + static void lineRequestOutputFlags(GpioLine line, String consumer, int flags, int defaultVal) { + if(c_gpiod_line_request_output_flags(line.getCPointer(), consumer, flags, defaultVal) < 0) { + throw new GpioDException("c_gpiod_line_request_output_flags failed!"); + } + } + + private static native int c_gpiod_line_request_output_flags(long linePtr, String consumer, int flags, int default_val); + + static void lineRequestRisingEdgeEventsFlags(GpioLine line, String consumer, int flags) { + if(c_gpiod_line_request_rising_edge_events_flags(line.getCPointer(), consumer, flags) < 0) { + throw new GpioDException("c_gpiod_line_request_rising_edge_events_flags failed!"); + } + } + + private static native int c_gpiod_line_request_rising_edge_events_flags(long linePtr, String consumer, int flags); + + static void lineRequestFallingEdgeEventsFlags(GpioLine line, String consumer, int flags) { + if(c_gpiod_line_request_falling_edge_events_flags(line.getCPointer(), consumer, flags) < 0) { + throw new GpioDException("c_gpiod_line_request_falling_edge_events_flags failed!"); + } + } + + private static native int c_gpiod_line_request_falling_edge_events_flags(long linePtr, String consumer, int flags); + + static void lineRequestBothEdgeEventsFlags(GpioLine line, String consumer, int flags) { + if(c_gpiod_line_request_both_edges_events_flags(line.getCPointer(), consumer, flags) < 0) { + throw new GpioDException("c_gpiod_line_request_both_edges_events_flags failed!"); + } + } + + private static native int c_gpiod_line_request_both_edges_events_flags(long linePtr, String consumer, int flags); + + static void lineRequestBulk(GpioLineBulk lineBulk, GpioLineRequest lineRequest, int[] defaultVals) { + if(c_gpiod_line_request_bulk(lineBulk.getCPointer(), lineRequest.getCPointer(), defaultVals) < 0) { + throw new GpioDException("c_gpiod_line_request_bulk failed!"); + } + } + + private static native int c_gpiod_line_request_bulk(long lineBulkPtr, long lineRequestPtr, int[] default_vals); + + static void lineRequestBulkInput(GpioLineBulk lineBulk, String consumer) { + if(c_gpiod_line_request_bulk_input(lineBulk.getCPointer(), consumer) < 0) { + throw new GpioDException("c_gpiod_line_request_bulk_input failed!"); + } + } + + private static native int c_gpiod_line_request_bulk_input(long lineBulkPtr, String consumer); + + static void lineRequestBulkOutput(GpioLineBulk lineBulk, String consumer, int[] defaultVals) { + if(c_gpiod_line_request_bulk_output(lineBulk.getCPointer(), consumer, defaultVals) < 0) { + throw new GpioDException("c_gpiod_line_request_bulk_output failed!"); + } + } + + private static native int c_gpiod_line_request_bulk_output(long lineBulkPtr, String consumer, int[] default_vals); + + static void lineRequestBulkRisingEdgeEvents(GpioLineBulk lineBulk, String consumer) { + if(c_gpiod_line_request_bulk_rising_edge_events(lineBulk.getCPointer(), consumer) < 0) { + throw new GpioDException("c_gpiod_line_request_bulk_rising_edge_events failed!"); + } + } + + private static native int c_gpiod_line_request_bulk_rising_edge_events(long lineBulkPtr, String consumer); + + static void lineRequestBulkFallingEdgeEvents(GpioLineBulk lineBulk, String consumer) { + if(c_gpiod_line_request_bulk_falling_edge_events(lineBulk.getCPointer(), consumer) < 0) { + throw new GpioDException("c_gpiod_line_request_bulk_falling_edge_events failed!"); + } + } + + private static native int c_gpiod_line_request_bulk_falling_edge_events(long lineBulkPtr, String consumer); + + static void lineRequestBulkBothEdgeEvents(GpioLineBulk lineBulk, String consumer) { + if(c_gpiod_line_request_bulk_both_edges_events(lineBulk.getCPointer(), consumer) < 0) { + throw new GpioDException("c_gpiod_line_request_bulk_both_edges_events failed!"); + } + } + + private static native int c_gpiod_line_request_bulk_both_edges_events(long lineBulkPtr, String consumer); + + static void lineRequestBulkInputFlags(GpioLineBulk lineBulk, String consumer, int flags) { + if(c_gpiod_line_request_bulk_input_flags(lineBulk.getCPointer(), consumer, flags) < 0) { + throw new GpioDException("c_gpiod_line_request_bulk_input_flags failed!"); + } + } + + private static native int c_gpiod_line_request_bulk_input_flags(long lineBulkPtr, String consumer, int flags); + + static void lineRequestBulkOutputFlags(GpioLineBulk lineBulk, String consumer, int flags, int[] defaultVals) { + if(c_gpiod_line_request_bulk_output_flags(lineBulk.getCPointer(), consumer, flags, defaultVals) < 0) { + throw new GpioDException("c_gpiod_line_request_bulk_output_flags failed!"); + } + } + + private static native int c_gpiod_line_request_bulk_output_flags(long lineBulkPtr, String consumer, int flags, int[] default_vals); + + static void lineRequestBulkRisingEdgeEventFlags(GpioLineBulk lineBulk, String consumer, int flags) { + if(c_gpiod_line_request_bulk_rising_edge_events_flags(lineBulk.getCPointer(), consumer, flags) < 0) { + throw new GpioDException("c_gpiod_line_request_bulk_rising_edge_events_flags failed!"); + } + } + + private static native int c_gpiod_line_request_bulk_rising_edge_events_flags(long lineBulkPtr, String consumer, int flags); + + static void lineRequestBulkFallingEdgeEventFlags(GpioLineBulk lineBulk, String consumer, int flags) { + if(c_gpiod_line_request_bulk_falling_edge_events_flags(lineBulk.getCPointer(), consumer, flags) < 0) { + throw new GpioDException("c_gpiod_line_request_bulk_falling_edge_events_flags failed!"); + } + } + + private static native int c_gpiod_line_request_bulk_falling_edge_events_flags(long lineBulkPtr, String consumer, int flags); + + static void lineRequestBulkBothEdgeEventFlags(GpioLineBulk lineBulk, String consumer, int flags) { + if(c_gpiod_line_request_bulk_both_edges_events_flags(lineBulk.getCPointer(), consumer, flags) < 0) { + throw new GpioDException("c_gpiod_line_request_bulk_both_edges_events_flags failed!"); + } + } + + private static native int c_gpiod_line_request_bulk_both_edges_events_flags(long lineBulkPtr, String consumer, int flags); + + static void lineRelease(GpioLine line) { + c_gpiod_line_release(line.getCPointer()); + } + + private static native void c_gpiod_line_release(long linePtr); + + static void lineBulkRelease(GpioLineBulk lineBulk) { + c_gpiod_line_release_bulk(lineBulk.getCPointer()); + } + + private static native void c_gpiod_line_release_bulk(long lineBulkPtr); + + static boolean lineIsRequested(GpioLine line) { + return c_gpiod_line_is_requested(line.getCPointer()); + } + + private static native boolean c_gpiod_line_is_requested(long linePtr); + + static boolean lineIsFree(GpioLine line) { + return c_gpiod_line_is_free(line.getCPointer()); + } + + private static native boolean c_gpiod_line_is_free(long linePtr); + + static int lineGetValue(GpioLine line) { + int result = c_gpiod_line_get_value(line.getCPointer()); + if(result < 0) { + throw new GpioDException("c_gpiod_line_get_value failed!"); + } + return result; + } + + private static native int c_gpiod_line_get_value(long linePtr); + + static int[] lineBulkGetValues(GpioLineBulk lineBulk) { + int numVals = lineBulkGetNumLines(lineBulk); + int[] vals = new int[numVals]; + if(c_gpiod_line_get_value_bulk(lineBulk.getCPointer(), vals) < 0) { + throw new GpioDException("c_gpiod_line_get_value_bulk failed!"); + } + return vals; + } + + private static native int c_gpiod_line_get_value_bulk(long lineBulkPtr, int[] values); + + static void lineSetValue(GpioLine line, int value) { + if(c_gpiod_line_set_value(line.getCPointer(), value) < 0) { + throw new GpioDException("c_gpiod_line_set_value failed!"); + } + } + + private static native int c_gpiod_line_set_value(long linePtr, int value); + + static void lineBulkSetValue(GpioLineBulk lineBulk, int[] values) { + if(c_gpiod_line_set_value_bulk(lineBulk.getCPointer(), values) < 0) { + throw new GpioDException("c_gpiod_line_set_value_bulk failed!"); + } + } + + private static native int c_gpiod_line_set_value_bulk(long lineBulkPtr, int[] values); + + static void lineSetConfig(GpioLine line, LINE_REQUEST direction, int flags, int value) { + if(c_gpiod_line_set_config(line.getCPointer(), direction.val, flags, value) < 0) { + throw new GpioDException("c_gpiod_line_set_config failed!"); + } + } + + private static native int c_gpiod_line_set_config(long linePtr, int direction, int flags, int value); + + static void lineBulkSetConfig(GpioLineBulk lineBulk, LINE_REQUEST direction, int flags, int[] values) { + if(c_gpiod_line_set_config_bulk(lineBulk.getCPointer(), direction.val, flags, values) < 0) { + throw new GpioDException("c_gpiod_line_set_config_bulk failed!"); + } + } + + private static native int c_gpiod_line_set_config_bulk(long lineBulkPtr, int direction, int flags, int[] values); + + static void lineSetFlags(GpioLine line, int flags) { + if(c_gpiod_line_set_flags(line.getCPointer(), flags) < 0) { + throw new GpioDException("c_gpiod_line_set_flags failed!"); + } + } + + private static native int c_gpiod_line_set_flags(long linePtr, int flags); + + static void lineBulkSetFlags(GpioLineBulk lineBulk, int flags) { + if(c_gpiod_line_set_flags_bulk(lineBulk.getCPointer(), flags) < 0) { + throw new GpioDException("c_gpiod_line_set_flags_bulk failed!"); + } + } + + private static native int c_gpiod_line_set_flags_bulk(long lineBulkPtr, int flags); + + static void lineSetDirectionInput(GpioLine line) { + if(c_gpiod_line_set_direction_input(line.getCPointer()) < 0) { + throw new GpioDException("c_gpiod_line_set_direction_input failed!"); + } + } + + private static native int c_gpiod_line_set_direction_input(long linePtr); + + static void lineSetDirectionOutputBulk(GpioLineBulk lineBulk) { + if(c_gpiod_line_set_direction_input_bulk(lineBulk.getCPointer()) < 0) { + throw new GpioDException("c_gpiod_line_set_direction_input_bulk failed!"); + } + } + + private static native int c_gpiod_line_set_direction_input_bulk(long lineBulkPtr); + + static void lineSetDirectionOutput(GpioLine line, int value) { + if(c_gpiod_line_set_direction_output(line.getCPointer(), value) < 0) { + throw new GpioDException("c_gpiod_line_set_direction_output failed!"); + } + } + + private static native int c_gpiod_line_set_direction_output(long linePtr, int value); + + static void lineSetDirectionOutputBulk(GpioLineBulk lineBulk, int[] values) { + if(c_gpiod_line_set_direction_output_bulk(lineBulk.getCPointer(), values) < 0) { + throw new GpioDException("c_gpiod_line_set_direction_output_bulk failed!"); + } + } + + private static native int c_gpiod_line_set_direction_output_bulk(long lineBulkPtr, int[] values); + + public enum LINE_EVENT { + RISING_EDGE(1), FALLING_EDGE(2); + final int val; + + public int getVal() { + return val; + } + + LINE_EVENT(int val) { + this.val = val; + } + + static LINE_EVENT fromInt(int val) { + for (LINE_EVENT dir : LINE_EVENT.values()) { + if (dir.val == val) { + return dir; + } + } + throw new IllegalStateException("Unexpected LINE_EVENT value: " + val); + } + } + + static boolean lineEventWait(GpioLine line, long timeoutNs) { + int result = c_gpiod_line_event_wait(line.getCPointer(), timeoutNs); + if(result < 0) { + throw new GpioDException("c_gpiod_line_event_wait failed!"); + } + return result > 0; + } + + private static native int c_gpiod_line_event_wait(long linePtr, long timeoutNs); + + static boolean lineBulkEventWait(GpioLineBulk lineBulk, long timeoutNs, GpioLineBulk eventBulk) { + int result = c_gpiod_line_event_wait_bulk(lineBulk.getCPointer(), timeoutNs, eventBulk.getCPointer()); + if(result < 0) { + throw new GpioDException("c_gpiod_line_event_wait_bulk failed!"); + } + return result > 0; + } + + private static native int c_gpiod_line_event_wait_bulk(long lineBulkPtr, long timeoutNs, long eventBulkPtr); + + static boolean lineEventRead(GpioLine line, GpioLineEvent event) { + int result = c_gpiod_line_event_read(line.getCPointer(), event.getCPointer()); + if(result < 0) { + throw new GpioDException("c_gpiod_line_event_read failed!"); + } + return result > 0; + } + + private static native int c_gpiod_line_event_read(long linePtr, long eventPtr); + + static GpioLineEvent[] lineEventReadMultiple(GpioLine line, int maxRead) { + GpioLineEvent[] events = new GpioLineEvent[maxRead]; + for(int i = 0; i < events.length; i++) { + events[i] = new GpioLineEvent(); + } + + int numRead = c_gpiod_line_event_read_multiple(line.getCPointer(), + Arrays.stream(events).mapToLong(GpioLineEvent::getCPointer).toArray(), events.length); + if(numRead < 0) { + throw new GpioDException("c_gpiod_line_event_read_multiple failed!"); + } + + GpioLineEvent[] result = new GpioLineEvent[numRead]; + if(numRead == maxRead) { + result = events; + } else { + System.arraycopy(events, 0, result, 0, result.length); + } + return result; + } + + private static native int c_gpiod_line_event_read_multiple(long linePtr, long[] eventPtr, int num_events); + + static GpioLine lineGet(String device, int offset) { + Long ptr = c_gpiod_line_get(device, offset); + if(ptr == null) { + throw new GpioDException("c_gpiod_line_get failed!"); + } + return new GpioLine(ptr); + } + + private static native Long c_gpiod_line_get(String device, int offset); + + static GpioLine lineFind(String name) { + Long ptr = gpiod_line_find(name); + if(ptr == null) { + throw new GpioDException("gpiod_line_find failed!"); + } + return new GpioLine(ptr); + } + + private static native Long gpiod_line_find(String name); + + static void lineCloseChip(GpioLine line) { + c_gpiod_line_close_chip(line.getCPointer()); + } + + private static native void c_gpiod_line_close_chip(long linePtr); + + static GpioChip lineGetChip(GpioLine line) { + return new GpioChip(gpiod_line_get_chip(line.getCPointer())); + } + + private static native long gpiod_line_get_chip(long linePtr); + + static long chipIterNew() { + Long ptr = gpiod_chip_iter_new(); + if(ptr == null) { + throw new GpioDException("gpiod_chip_iter_new failed!"); + } + return ptr; + } + + private static native Long gpiod_chip_iter_new(); + + static void chipIterFree(GpioChipIterator iter) { + c_gpiod_chip_iter_free(iter.getCPointer()); + } + + private static native void c_gpiod_chip_iter_free(long chipIterPtr); + + static void chipIterFreeNoClose(GpioChipIterator iter) { + c_gpiod_chip_iter_free_noclose(iter.getCPointer()); + } + + private static native void c_gpiod_chip_iter_free_noclose(long chipIterPtr); + + static GpioChip chipIterNext(GpioChipIterator iter) { + Long ptr = c_gpiod_chip_iter_next(iter.getCPointer()); + if(ptr == null) { + return null; + } + return new GpioChip(ptr); + } + + private static native Long c_gpiod_chip_iter_next(long chipIterPtr); + + static GpioChip chipIterNextNoClose(GpioChipIterator iter) { + Long ptr = c_gpiod_chip_iter_next_noclose(iter.getCPointer()); + if(ptr == null) { + return null; + } + return new GpioChip(ptr); + } + + private static native Long c_gpiod_chip_iter_next_noclose(long chipIterPtr); + + static long lineIterNew(GpioChip chip) { + Long ptr = gpiod_line_iter_new(chip.getCPointer()); + if(ptr == null) { + throw new GpioDException("gpiod_line_iter_new failed!"); + } + return ptr; + } + + private static native Long gpiod_line_iter_new(long chipPtr); + + static void lineIterFree(GpioLineIterator iter) { + gpiod_line_iter_free(iter.getCPointer()); + } + + private static native void gpiod_line_iter_free(long lineIterPtr); + + static GpioLine lineIterNext(GpioLineIterator iter) { + Long ptr = gpiod_line_iter_next(iter.getCPointer()); + if(ptr == null) { + return null; + } + return new GpioLine(ptr); + } + + private static native Long gpiod_line_iter_next(long lineIterPtr); + + static long lineEventGetTimespec(GpioLineEvent event) { + return c_gpiod_line_event_get_timespec(event.getCPointer()); + } + + private static native long c_gpiod_line_event_get_timespec(long lineEventPtr); + + static LINE_EVENT lineEventGetType(GpioLineEvent event) { + return LINE_EVENT.fromInt(c_gpiod_line_event_get_type(event.getCPointer())); + } + + private static native int c_gpiod_line_event_get_type(long lineEventPtr); + + static long lineEventNew() { + Long ptr = c_gpiod_line_event_new(); + if(ptr == null) { + throw new GpioDException("c_gpiod_line_event_new failed!"); + } + return ptr; + } + + private static native Long c_gpiod_line_event_new(); + + static void lineEventFree(GpioLineEvent event) { + c_gpiod_line_event_free(event.getCPointer()); + } + + private static native void c_gpiod_line_event_free(long eventPtr); + + static String getVersion() { + return c_gpiod_version_string(); + } + + private static native String c_gpiod_version_string(); + +} diff --git a/libraries/pi4j-library-gpiod/src/main/java/com/pi4j/library/gpiod/internal/GpioDException.java b/libraries/pi4j-library-gpiod/src/main/java/com/pi4j/library/gpiod/internal/GpioDException.java new file mode 100644 index 00000000..849811b6 --- /dev/null +++ b/libraries/pi4j-library-gpiod/src/main/java/com/pi4j/library/gpiod/internal/GpioDException.java @@ -0,0 +1,17 @@ +package com.pi4j.library.gpiod.internal; + +/** + *GpioDException
+ * + * @author Alexander Liggesmeyer (https://alexander.liggesmeyer.net/) + * @version $Id: $Id + */ +public class GpioDException extends RuntimeException { + public GpioDException() { + super(); + } + + public GpioDException(String msg) { + super(msg); + } +} diff --git a/libraries/pi4j-library-gpiod/src/main/java/com/pi4j/library/gpiod/internal/GpioLine.java b/libraries/pi4j-library-gpiod/src/main/java/com/pi4j/library/gpiod/internal/GpioLine.java new file mode 100644 index 00000000..f50a6176 --- /dev/null +++ b/libraries/pi4j-library-gpiod/src/main/java/com/pi4j/library/gpiod/internal/GpioLine.java @@ -0,0 +1,151 @@ +package com.pi4j.library.gpiod.internal; + +import java.util.Objects; + +/** + *GpioLine
+ * + * @author Alexander Liggesmeyer (https://alexander.liggesmeyer.net/) + * @version $Id: $Id + */ +public class GpioLine extends CWrapper { + + GpioLine(long cPointer) { + super(cPointer); + } + + public int getOffset() { + return GpioD.lineGetOffset(this); + } + + public String getName() { + return GpioD.lineGetName(this); + } + + public String getConsumer() { + return GpioD.lineGetConsumer(this); + } + + public GpioD.LINE_DIRECTION getDirection() { + return GpioD.lineGetDirection(this); + } + + public GpioD.LINE_ACTIVE_STATE getActiveState() { + return GpioD.lineGetActiveState(this); + } + + public GpioD.LINE_BIAS getBias() { + return GpioD.lineGetBias(this); + } + + public boolean isUsed() { + return GpioD.lineIsUsed(this); + } + + public boolean isOpenDrain() { + return GpioD.lineIsOpenDrain(this); + } + + public boolean isOpenSource() { + return GpioD.lineIsOpenSource(this); + } + + public void update() { + GpioD.lineUpdate(this); + } + + public void request(GpioLineRequest config, int defaultVal) { + GpioD.lineRequest(this, config, defaultVal); + } + + public void requestInput(String consumer) { + GpioD.lineRequestInput(this, consumer); + } + + public void requestOutput(String consumer, int defaultVal) { + GpioD.lineRequestOutput(this, consumer, defaultVal); + } + + public void requestRisingEdgeEvents(String consumer) { + GpioD.lineRequestRisingEdgeEvents(this, consumer); + } + + public void requestFallingEdgeEvents(String consumer) { + GpioD.lineRequestFallingEdgeEvents(this, consumer); + } + + public void requestBothEdgeEvents(String consumer) { + GpioD.lineRequestBothEdgeEvents(this, consumer); + } + + public void requestInputFlags(String consumer, int flags) { + GpioD.lineRequestInputFlags(this, consumer, flags); + } + + public void requestOutputFlags(String consumer, int flags, int defaultValue) { + GpioD.lineRequestOutputFlags(this, consumer, flags, defaultValue); + } + + public void requestRisingEdgeEventsFlags(String consumer, int flags) { + GpioD.lineRequestRisingEdgeEventsFlags(this, consumer, flags); + } + + public void requestFallingEdgeEventsFlags(String consumer, int flags) { + GpioD.lineRequestFallingEdgeEventsFlags(this, consumer, flags); + } + + public void requestBothEdgeEventsFlags(String consumer, int flags) { + GpioD.lineRequestBothEdgeEventsFlags(this, consumer, flags); + } + + public void release() { + GpioD.lineRelease(this); + } + + public boolean isRequested() { + return GpioD.lineIsRequested(this); + } + + public boolean isFree() { + return GpioD.lineIsFree(this); + } + + public int getValue() { + return GpioD.lineGetValue(this); + } + + public void setValue(int value) { + GpioD.lineSetValue(this, value); + } + + public void setConfig(GpioD.LINE_REQUEST direction, int flags, int value) { + GpioD.lineSetConfig(this, direction, flags, value); + } + + public void setFlags(int flags) { + GpioD.lineSetFlags(this, flags); + } + + public void setDirectionInput() { + GpioD.lineSetDirectionInput(this); + } + + public void setDirectionOutput(int value) { + GpioD.lineSetDirectionOutput(this, value); + } + + public boolean eventWait(long timeoutNs) { + return GpioD.lineEventWait(this, timeoutNs); + } + + public GpioLineEvent eventRead() { + GpioLineEvent event = new GpioLineEvent(); + GpioD.lineEventRead(this, event); + return event; + } + + public GpioLineEvent[] eventReadMultiple(int maxRead) { + return GpioD.lineEventReadMultiple(this, maxRead); + } + +} diff --git a/libraries/pi4j-library-gpiod/src/main/java/com/pi4j/library/gpiod/internal/GpioLineBulk.java b/libraries/pi4j-library-gpiod/src/main/java/com/pi4j/library/gpiod/internal/GpioLineBulk.java new file mode 100644 index 00000000..21cf0840 --- /dev/null +++ b/libraries/pi4j-library-gpiod/src/main/java/com/pi4j/library/gpiod/internal/GpioLineBulk.java @@ -0,0 +1,114 @@ +package com.pi4j.library.gpiod.internal; + +/** + *GpioLineBulk
+ * + * @author Alexander Liggesmeyer (https://alexander.liggesmeyer.net/) + * @version $Id: $Id + */ +public class GpioLineBulk extends CWrapper { + + GpioLineBulk(long cPointer) { + super(cPointer); + } + + public GpioLineBulk() { + this(GpioD.lineBulkNew()); + } + + @Override + protected void finalize() { + GpioD.lineBulkFree(this); + } + + public void add(GpioLine line) { + GpioD.lineBulkAdd(this, line); + } + + public GpioLine getLine(int index) { + return GpioD.lineBulkGetLine(this, index); + } + + public int getNumLines() { + return GpioD.lineBulkGetNumLines(this); + } + + public void request(GpioLineRequest config, int[] defaultVals) { + GpioD.lineRequestBulk(this, config, defaultVals); + } + + public void requestInput(String consumer) { + GpioD.lineRequestBulkInput(this, consumer); + } + + public void requestOutput(String consumer, int[] defaultVals) { + GpioD.lineRequestBulkOutput(this, consumer, defaultVals); + } + + public void requestRisingEdgeEvents(String consumer) { + GpioD.lineRequestBulkRisingEdgeEvents(this, consumer); + } + + public void requestFallingEdgeEvents(String consumer) { + GpioD.lineRequestBulkFallingEdgeEvents(this, consumer); + } + + public void requestBothEdgeEvents(String consumer) { + GpioD.lineRequestBulkBothEdgeEvents(this, consumer); + } + + public void requestInputFlags(String consumer, int flags) { + GpioD.lineRequestBulkInputFlags(this, consumer, flags); + } + + public void requestOutputFlags(String consumer, int flags, int[] defaultValue) { + GpioD.lineRequestBulkOutputFlags(this, consumer, flags, defaultValue); + } + + public void requestRisingEdgeEventsFlags(String consumer, int flags) { + GpioD.lineRequestBulkRisingEdgeEventFlags(this, consumer, flags); + } + + public void requestFallingEdgeEventsFlags(String consumer, int flags) { + GpioD.lineRequestBulkFallingEdgeEventFlags(this, consumer, flags); + } + + public void requestBothEdgeEventsFlags(String consumer, int flags) { + GpioD.lineRequestBulkBothEdgeEventFlags(this, consumer, flags); + } + + public void release() { + GpioD.lineBulkRelease(this); + } + + public int[] getValues() { + return GpioD.lineBulkGetValues(this); + } + + public void setValue(int[] values) { + GpioD.lineBulkSetValue(this, values); + } + + public void setConfig(GpioD.LINE_REQUEST direction, int flags, int[] values) { + GpioD.lineBulkSetConfig(this, direction, flags, values); + } + + public void setFlags(int flags) { + GpioD.lineBulkSetFlags(this, flags); + } + + public void setDirectionInput() { + GpioD.lineSetDirectionOutputBulk(this); + } + + public void setDirectionOutput(int[] values) { + GpioD.lineSetDirectionOutputBulk(this, values); + } + + public GpioLineBulk eventWait(long timeoutNs) { + GpioLineBulk bulk = new GpioLineBulk(); + GpioD.lineBulkEventWait(this, timeoutNs, bulk); + return bulk; + } + +} diff --git a/libraries/pi4j-library-gpiod/src/main/java/com/pi4j/library/gpiod/internal/GpioLineEvent.java b/libraries/pi4j-library-gpiod/src/main/java/com/pi4j/library/gpiod/internal/GpioLineEvent.java new file mode 100644 index 00000000..29a617e8 --- /dev/null +++ b/libraries/pi4j-library-gpiod/src/main/java/com/pi4j/library/gpiod/internal/GpioLineEvent.java @@ -0,0 +1,31 @@ +package com.pi4j.library.gpiod.internal; + +/** + *GpioLineEvent
+ * + * @author Alexander Liggesmeyer (https://alexander.liggesmeyer.net/) + * @version $Id: $Id + */ +public class GpioLineEvent extends CWrapper { + + GpioLineEvent(long cPointer) { + super(cPointer); + } + + public GpioLineEvent() { + this(GpioD.lineEventNew()); + } + + @Override + protected void finalize() { + GpioD.lineEventFree(this); + } + + public long getTimeNs() { + return GpioD.lineEventGetTimespec(this); + } + + public GpioD.LINE_EVENT getType() { + return GpioD.lineEventGetType(this); + } +} diff --git a/libraries/pi4j-library-gpiod/src/main/java/com/pi4j/library/gpiod/internal/GpioLineIterator.java b/libraries/pi4j-library-gpiod/src/main/java/com/pi4j/library/gpiod/internal/GpioLineIterator.java new file mode 100644 index 00000000..9b216bf2 --- /dev/null +++ b/libraries/pi4j-library-gpiod/src/main/java/com/pi4j/library/gpiod/internal/GpioLineIterator.java @@ -0,0 +1,41 @@ +package com.pi4j.library.gpiod.internal; + +import java.util.Iterator; + +/** + *GpioLineIterator
+ * + * @author Alexander Liggesmeyer (https://alexander.liggesmeyer.net/) + * @version $Id: $Id + */ +public class GpioLineIterator extends CWrapper implements IteratorGpioLineRequest
+ * + * @author Alexander Liggesmeyer (https://alexander.liggesmeyer.net/) + * @version $Id: $Id + */ +public class GpioLineRequest extends CWrapper { + + GpioLineRequest(long cPointer) { + super(cPointer); + } + +} diff --git a/libraries/pi4j-library-gpiod/src/main/java/com/pi4j/library/gpiod/util/NativeLibraryLoader.java b/libraries/pi4j-library-gpiod/src/main/java/com/pi4j/library/gpiod/util/NativeLibraryLoader.java new file mode 100644 index 00000000..24ac868e --- /dev/null +++ b/libraries/pi4j-library-gpiod/src/main/java/com/pi4j/library/gpiod/util/NativeLibraryLoader.java @@ -0,0 +1,258 @@ +package com.pi4j.library.gpiod.util; +/* + * #%L + * ********************************************************************** + * ORGANIZATION : Pi4J + * PROJECT : Pi4J :: LIBRARY :: JNI Wrapper for LinuxFS Library + * FILENAME : NativeLibraryLoader.java + * + * This file is part of the Pi4J project. More information about + * this project can be found here: https://pi4j.com/ + * ********************************************************************** + * + * This program is free software: you can redistribute it and/or modify + * it under the terms of the GNU Lesser General Public License as + * published by the Free Software Foundation, either version 3 of the + * License, or (at your option) any later version. + * + * This program is distributed in the hope that it will be useful, + * but WITHOUT ANY WARRANTY; without even the implied warranty of + * MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the + * GNU General Lesser Public License for more details. + * + * You should have received a copy of the GNU General Lesser Public + * License along with this program. If not, see + *StringUtil class.
+ * + * @author Robert Savage (http://www.savagehomeautomation.com) + * @version $Id: $Id + */ +public class StringUtil { + + /** ConstantEMPTY="" */
+ public static final String EMPTY = "";
+ /** Constant DEFAULT_PAD_CHAR=' ' */
+ public static final char DEFAULT_PAD_CHAR = ' ';
+
+ /**
+ * isNullOrEmpty.
+ * + * @param data a {@link String} object. + * @param trim a boolean. + * @return a boolean. + */ + public static boolean isNullOrEmpty(String data, boolean trim){ + if(data == null) + return true; + + // trim if requested + String test = data; + if(trim) + test = data.trim(); + + return (test.length() <= 0); + } + + /** + *isNullOrEmpty.
+ * + * @param data a {@link String} object. + * @return a boolean. + */ + public static boolean isNullOrEmpty(String data){ + return isNullOrEmpty(data, false); + } + + /** + *isNotNullOrEmpty.
+ * + * @param data a {@link String} object. + * @return a boolean. + */ + public static boolean isNotNullOrEmpty(String data){ + return isNotNullOrEmpty(data, false); + } + + /** + *isNotNullOrEmpty.
+ * + * @param data a {@link String} object. + * @param trim a boolean. + * @return a boolean. + */ + public static boolean isNotNullOrEmpty(String data, boolean trim){ + return !(isNullOrEmpty(data, trim)); + } + + /** + *setIfNullOrEmpty.
+ * + * @param data a {@link String} object. + * @param replacement a {@link String} object. + * @param trim a boolean. + * @return a {@link String} object. + */ + public static String setIfNullOrEmpty(String data, String replacement, boolean trim){ + if(isNullOrEmpty(data, trim)) { + return replacement; + } + return data; + } + + /** + *setIfNullOrEmpty.
+ * + * @param data a {@link String} object. + * @param replacement a {@link String} object. + * @return a {@link String} object. + */ + public static String setIfNullOrEmpty(String data, String replacement){ + return setIfNullOrEmpty(data, replacement, false); + } + + /** + *contains.
+ * + * @param source a {@link String} object. + * @param target a {@link String} object. + * @return a boolean. + */ + public static boolean contains(String source, String target) { + return (null != source && null != target && source.contains(target)); + } + + /** + *contains.
+ * + * @param source a {@link String} object. + * @param targets an array of {@link String} objects. + * @return a boolean. + */ + public static boolean contains(String source, String[] targets) { + if (null != source && null != targets) { + for(var target : targets) { + if (source.contains(target)) { + return true; + } + } + } + return false; + } + + /** + *contains.
+ * + * @param sources an array of {@link String} objects. + * @param target a {@link String} object. + * @return a boolean. + */ + public static boolean contains(String[] sources, String target) { + if (null != sources && null != target) { + for (var source : sources) { + if(contains(source, target)) + return true; + } + } + return false; + } + + /** + *contains.
+ * + * @param sources an array of {@link String} objects. + * @param targets an array of {@link String} objects. + * @return a boolean. + */ + public static boolean contains(String[] sources, String[] targets) { + if (null != sources && null != targets) { + for (var source : sources) { + if(contains(source, targets)) + return true; + } + } + return false; + } + + /** + *create.
+ * + * @param length a int. + * @return a {@link String} object. + */ + public static String create(int length) { + return create(DEFAULT_PAD_CHAR, length); + } + + /** + *create.
+ * + * @param c a char. + * @param length a int. + * @return a {@link String} object. + */ + public static String create(char c, int length) { + StringBuilder sb = new StringBuilder(length); + for(var index = 0; index < length; index++) + sb.append(c); + return sb.toString(); + } + + /** + *create.
+ * + * @param s a {@link String} object. + * @param length a int. + * @return a {@link String} object. + */ + public static String create(String s, int length) { + StringBuilder sb = new StringBuilder(length * s.length()); + for(var index = 0; index < length; index++) + sb.append(s); + return sb.toString(); + } + + /** + *repeat.
+ * + * @param c a char. + * @param length a int. + * @return a {@link String} object. + */ + public static String repeat(char c, int length) { + return create(c, length); + } + + /** + *repeat.
+ * + * @param s a {@link String} object. + * @param length a int. + * @return a {@link String} object. + */ + public static String repeat(String s, int length) { + return create(s, length); + } + + /** + *padLeft.
+ * + * @param data a {@link String} object. + * @param length a int. + * @return a {@link String} object. + */ + public static String padLeft(String data, int length) { + return padLeft(data, DEFAULT_PAD_CHAR, length); + } + + /** + *padLeft.
+ * + * @param data a {@link String} object. + * @param pad a char. + * @param length a int. + * @return a {@link String} object. + */ + public static String padLeft(String data, char pad, int length) { + var sb = new StringBuilder(data.length() + length); + for(var index = 0; index < length; index++) + sb.append(pad); + sb.append(data); + return sb.toString(); + } + + /** + *padLeft.
+ * + * @param data a {@link String} object. + * @param pad a {@link String} object. + * @param length a int. + * @return a {@link String} object. + */ + public static String padLeft(String data, String pad, int length) { + var sb = new StringBuilder(data.length() + (length * pad.length())); + for(var index = 0; index < length; index++) + sb.append(pad); + sb.append(data); + return sb.toString(); + } + + /** + *padRight.
+ * + * @param data a {@link String} object. + * @param length a int. + * @return a {@link String} object. + */ + public static String padRight(String data, int length) { + return padRight(data, DEFAULT_PAD_CHAR, length); + } + + /** + *padRight.
+ * + * @param data a {@link String} object. + * @param pad a char. + * @param length a int. + * @return a {@link String} object. + */ + public static String padRight(String data, char pad, int length) { + var sb = new StringBuilder(data.length() + length); + sb.append(data); + for(var index = 0; index < length; index++) + sb.append(pad); + return sb.toString(); + } + + /** + *padRight.
+ * + * @param data a {@link String} object. + * @param pad a {@link String} object. + * @param length a int. + * @return a {@link String} object. + */ + public static String padRight(String data, String pad, int length) { + var sb = new StringBuilder(data.length() + (length * pad.length())); + sb.append(data); + for(var index = 0; index < length; index++) + sb.append(pad); + return sb.toString(); + } + + /** + *pad.
+ * + * @param data a {@link String} object. + * @param length a int. + * @return a {@link String} object. + */ + public static String pad(String data, int length) { + return pad(data, DEFAULT_PAD_CHAR, length); + } + + /** + *pad.
+ * + * @param data a {@link String} object. + * @param pad a char. + * @param length a int. + * @return a {@link String} object. + */ + public static String pad(String data, char pad, int length) { + return create(pad, length) + data + create(pad, length); + } + + /** + *pad.
+ * + * @param data a {@link String} object. + * @param pad a {@link String} object. + * @param length a int. + * @return a {@link String} object. + */ + public static String pad(String data, String pad, int length) { + return create(pad, length) + data + create(pad, length); + } + + /** + *padCenter.
+ * + * @param data a {@link String} object. + * @param length a int. + * @return a {@link String} object. + */ + public static String padCenter(String data, int length) { + return padCenter(data, DEFAULT_PAD_CHAR, length); + } + + /** + *padCenter.
+ * + * @param data a {@link String} object. + * @param pad a char. + * @param length a int. + * @return a {@link String} object. + */ + public static String padCenter(String data, char pad, int length) { + if(data.length() < length) { + int needed = length - data.length(); + int padNeeded = needed / 2; + StringBuilder result = new StringBuilder(); + result.append(create(pad, padNeeded)); + result.append(data); + result.append(create(pad, padNeeded)); + int remaining = length - result.length(); + result.append(create(pad, remaining)); + return result.toString(); + } + return data; + } + + /** + *trimLeft.
+ * + * @param data a {@link String} object. + * @return a {@link String} object. + */ + public static String trimLeft(String data) { + return trimLeft(data, DEFAULT_PAD_CHAR); + } + + /** + *trimLeft.
+ * + * @param data a {@link String} object. + * @param trim a char. + * @return a {@link String} object. + */ + public static String trimLeft(String data, char trim) { + for(var index = 0; index < data.length(); index++) + if(!(data.charAt(index) == trim)) + return data.substring(index); + return EMPTY; + } + + /** + *trimRight.
+ * + * @param data a {@link String} object. + * @return a {@link String} object. + */ + public static String trimRight(String data) { + return trimRight(data, DEFAULT_PAD_CHAR); + } + + /** + *trimRight.
+ * + * @param data a {@link String} object. + * @param trim a char. + * @return a {@link String} object. + */ + public static String trimRight(String data, char trim) { + int count = 0; + for(var index = data.length(); index > 0; index--) + if(data.charAt(index-1) == trim) + count++; + else + return data.substring(0, data.length() - count); + return EMPTY; + } + + /** + *trim.
+ * + * @param data a {@link String} object. + * @return a {@link String} object. + */ + public static String trim(String data) { + return trim(data, DEFAULT_PAD_CHAR); + } + + /** + *trim.
+ * + * @param data a {@link String} object. + * @param trim a char. + * @return a {@link String} object. + */ + public static String trim(String data, char trim) { + var result = trimLeft(data, trim); + return trimRight(result, trim); + } + + /** + *center.
+ * + * @param text a {@link String} object. + * @param length a int. + * @return a {@link String} object. + */ + public static String center(String text, int length){ + var out = String.format("%"+length+"s%s%"+length+"s", "",text,""); + var mid = (out.length()/2); + var start = mid - (length/2); + var end = start + length; + return out.substring((int) start, (int) end); + } + + /** + *concat.
+ * + * @param data a {@link String} object. + * @return a {@link String} object. + */ + public static String concat(String ... data) { + var sb = new StringBuilder(); + for(var d : data){ + sb.append(d); + } + return sb.toString(); + } + + /** + *appendHexString.
+ * + * @param builder a {@link StringBuilder} object. + * @param byt a byte. + */ + public static void appendHexString(StringBuilder builder, byte byt){ + builder.append(String.format("%02X", byt)); + } + /** + *toHexString.
+ * + * @param byt a byte. + * @return a {@link String} object. + */ + public static String toHexString(byte byt){ + return String.format("%02X", byt); + } + + /** + *appendHexString.
+ * + * @param builder a {@link StringBuilder} object. + * @param byt a int. + */ + public static void appendHexString(StringBuilder builder, int byt){ + builder.append(String.format("%02X", (byte)byt)); + } + /** + *toHexString.
+ * + * @param byt a int. + * @return a {@link String} object. + */ + public static String toHexString(int byt){ + return String.format("%02X", (byte)byt); + } + + /** + *appendHexString.
+ * + * @param builder a {@link StringBuilder} object. + * @param bytes an array of {@link byte} objects. + */ + public static void appendHexString(StringBuilder builder, byte[] bytes){ + for (byte b : bytes) { + builder.append(String.format("%02X ", b)); + } + } + /** + *toHexString.
+ * + * @param bytes an array of {@link byte} objects. + * @return a {@link String} object. + */ + public static String toHexString(byte[] bytes){ + StringBuilder sb = new StringBuilder(); + appendHexString(sb, bytes); + return sb.toString().trim(); + } + + /** + *appendHexString.
+ * + * @param builder a {@link StringBuilder} object. + * @param buffer a {@link ByteBuffer} object. + */ + public static void appendHexString(StringBuilder builder, ByteBuffer buffer){ + appendHexString(builder, buffer.array()); + } + /** + *toHexString.
+ * + * @param buffer a {@link ByteBuffer} object. + * @return a {@link String} object. + */ + public static String toHexString(ByteBuffer buffer){ + StringBuilder sb = new StringBuilder(); + appendHexString(sb, buffer); + return sb.toString().trim(); + } + + /** + *appendHexString.
+ * + * @param builder a {@link StringBuilder} object. + * @param bytes an array of {@link byte} objects. + * @param offset a int. + * @param length a int. + */ + public static void appendHexString(StringBuilder builder, byte[] bytes, int offset, int length){ + appendHexString(builder, Arrays.copyOfRange(bytes, offset, length)); + } + /** + *toHexString.
+ * + * @param bytes an array of {@link byte} objects. + * @param offset a int. + * @param length a int. + * @return a {@link String} object. + */ + public static String toHexString(byte[] bytes, int offset, int length){ + StringBuilder sb = new StringBuilder(); + appendHexString(sb, bytes, offset, length); + return sb.toString().trim(); + } + + /** + *appendHexString.
+ * + * @param builder a {@link StringBuilder} object. + * @param buffer a {@link ByteBuffer} object. + * @param offset a int. + * @param length a int. + */ + public static void appendHexString(StringBuilder builder, ByteBuffer buffer, int offset, int length){ + appendHexString(builder, buffer.array(), offset, length); + } + /** + *toHexString.
+ * + * @param buffer a {@link ByteBuffer} object. + * @param offset a int. + * @param length a int. + * @return a {@link String} object. + */ + public static String toHexString(ByteBuffer buffer, int offset, int length){ + StringBuilder sb = new StringBuilder(); + appendHexString(sb, buffer, offset, offset+length); + return sb.toString().trim(); + } + +} \ No newline at end of file diff --git a/libraries/pi4j-library-gpiod/src/main/java/module-info.java b/libraries/pi4j-library-gpiod/src/main/java/module-info.java new file mode 100644 index 00000000..8dde242c --- /dev/null +++ b/libraries/pi4j-library-gpiod/src/main/java/module-info.java @@ -0,0 +1,38 @@ +/*- + * #%L + * ********************************************************************** + * ORGANIZATION : Pi4J + * PROJECT : Pi4J :: LIBRARY :: JNI Wrapper for LinuxFS Library + * FILENAME : module-info.java + * + * This file is part of the Pi4J project. More information about + * this project can be found here: https://pi4j.com/ + * ********************************************************************** + * + * This program is free software: you can redistribute it and/or modify + * it under the terms of the GNU Lesser General Public License as + * published by the Free Software Foundation, either version 3 of the + * License, or (at your option) any later version. + * + * This program is distributed in the hope that it will be useful, + * but WITHOUT ANY WARRANTY; without even the implied warranty of + * MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the + * GNU General Lesser Public License for more details. + * + * You should have received a copy of the GNU General Lesser Public + * License along with this program. If not, see + *GpioDPlugin class.
+ * + * @author Alexander Liggesmeyer (https://alexander.liggesmeyer.net/) + * @version $Id: $Id + */ +public class GpioDPlugin implements Plugin { + + /** + * ConstantNAME="GpioD"
+ */
+ public static final String NAME = "GpioD";
+ /**
+ * Constant ID="gpiod"
+ */
+ public static final String ID = "gpiod";
+
+ // Digital Output (GPIO) Provider name and unique ID
+ /**
+ * Constant DIGITAL_OUTPUT_PROVIDER_NAME="NAME + Digital Output (GPIO) Provider"
+ */
+ public static final String DIGITAL_OUTPUT_PROVIDER_NAME = NAME + " Digital Output (GPIO) Provider";
+ /**
+ * Constant DIGITAL_OUTPUT_PROVIDER_ID="ID + -digital-output"
+ */
+ public static final String DIGITAL_OUTPUT_PROVIDER_ID = ID + "-digital-output";
+
+ /**
+ * Constant DIGITAL_INPUT_PROVIDER_NAME="NAME + Digital Input (GPIO) Provider"
+ */
+ public static final String DIGITAL_INPUT_PROVIDER_NAME = NAME + " Digital Input (GPIO) Provider";
+ /**
+ * Constant DIGITAL_INPUT_PROVIDER_ID="ID + -digital-input"
+ */
+ public static final String DIGITAL_INPUT_PROVIDER_ID = ID + "-digital-input";
+
+
+ private Logger logger = LoggerFactory.getLogger(this.getClass());
+
+ /**
+ * {@inheritDoc}
+ */
+ @Override
+ public void initialize(PluginService service) {
+ Provider[] providers = {
+ GpioDDigitalOutputProvider.newInstance()
+ };
+
+ service.register(providers);
+ }
+}
diff --git a/plugins/pi4j-plugin-gpiod/src/main/java/com/pi4j/plugin/gpiod/provider/gpio/digital/ActiveGpioChip.java b/plugins/pi4j-plugin-gpiod/src/main/java/com/pi4j/plugin/gpiod/provider/gpio/digital/ActiveGpioChip.java
new file mode 100644
index 00000000..501960e4
--- /dev/null
+++ b/plugins/pi4j-plugin-gpiod/src/main/java/com/pi4j/plugin/gpiod/provider/gpio/digital/ActiveGpioChip.java
@@ -0,0 +1,46 @@
+package com.pi4j.plugin.gpiod.provider.gpio.digital;
+
+import com.pi4j.library.gpiod.internal.GpioChip;
+import com.pi4j.library.gpiod.internal.GpioChipIterator;
+
+import java.io.Closeable;
+
+public class ActiveGpioChip implements Closeable {
+ private static GpioChip gpioChip;
+ private static int claimsOpen = 0;
+
+ public ActiveGpioChip() {
+ if(gpioChip == null) {
+ GpioChipIterator iterator = new GpioChipIterator();
+ GpioChip found = null;
+ while (iterator.hasNext()) {
+ GpioChip current = iterator.next();
+ if(current.getLabel().contains("pinctrl")) {
+ found = current;
+ iterator.noCloseCurrent();
+ break;
+ }
+ }
+ if(found == null) {
+ throw new IllegalStateException("Couldn't identify gpiochip!");
+ }
+ ActiveGpioChip.gpioChip = found;
+ }
+ ActiveGpioChip.claimsOpen += 1;
+ }
+
+ public GpioChip getGpioChip() {
+ return ActiveGpioChip.gpioChip;
+ }
+
+ public void close() {
+ ActiveGpioChip.claimsOpen -= 1;
+ if(ActiveGpioChip.claimsOpen == 0) {
+ ActiveGpioChip.gpioChip.close();
+ ActiveGpioChip.gpioChip = null;
+ } else if (ActiveGpioChip.claimsOpen < 0) {
+ ActiveGpioChip.claimsOpen = 0;
+ throw new IllegalStateException("ActiveGpioChip.chipsOpen < 0");
+ }
+ }
+}
diff --git a/plugins/pi4j-plugin-gpiod/src/main/java/com/pi4j/plugin/gpiod/provider/gpio/digital/GpioDDigitalInput.java b/plugins/pi4j-plugin-gpiod/src/main/java/com/pi4j/plugin/gpiod/provider/gpio/digital/GpioDDigitalInput.java
new file mode 100644
index 00000000..f4c2d5a6
--- /dev/null
+++ b/plugins/pi4j-plugin-gpiod/src/main/java/com/pi4j/plugin/gpiod/provider/gpio/digital/GpioDDigitalInput.java
@@ -0,0 +1,122 @@
+package com.pi4j.plugin.gpiod.provider.gpio.digital;
+
+import com.pi4j.context.Context;
+import com.pi4j.exception.InitializeException;
+import com.pi4j.exception.ShutdownException;
+import com.pi4j.io.gpio.digital.*;
+import com.pi4j.library.gpiod.internal.GpioD;
+import com.pi4j.library.gpiod.internal.GpioDException;
+import com.pi4j.library.gpiod.internal.GpioLine;
+import com.pi4j.library.gpiod.internal.GpioLineEvent;
+import org.slf4j.Logger;
+import org.slf4j.LoggerFactory;
+
+import java.util.concurrent.ExecutorService;
+import java.util.concurrent.Executors;
+
+/**
+ * PiGpioDigitalOutput class.
+ * + * @author Alexander Liggesmeyer (https://alexander.liggesmeyer.net/) + * @version $Id: $Id + */ +public class GpioDDigitalInput extends DigitalInputBase implements DigitalInput { + private Logger logger = LoggerFactory.getLogger(this.getClass()); + private final long inputMaxWaitNs = 500 * 1000 * 1000; // 0,5 seconds + protected ExecutorService executor = Executors.newSingleThreadExecutor(r -> new Thread(r, "Pi4J.GPIO.Monitor")); + private final GpioLine line; + private final long debounceNs; + + /** + *Constructor for GpioDDigitalInput.
+ * + * @param line a {@link com.pi4j.library.gpiod.internal.GpioLine} object. + * @param provider a {@link DigitalInputProvider} object. + * @param config a {@link DigitalInputConfig} object. + */ + public GpioDDigitalInput(GpioLine line, DigitalInputProvider provider, DigitalInputConfig config) { + super(provider, config); + this.line = line; + if(config.getDebounce() == 0) { + debounceNs = 0; + } else { + // Convert microseconds to nanoseconds + debounceNs = 1000 * config.getDebounce(); + } + } + + @Override + public DigitalInput initialize(Context context) throws InitializeException { + try { + switch (config.getPull()) { + case PULL_UP: + this.line.requestBothEdgeEventsFlags(config.getId(), GpioD.LINE_REQUEST_FLAG.BIAS_PULL_UP.getVal()); + break; + case PULL_DOWN: + this.line.requestBothEdgeEventsFlags(config.getId(), GpioD.LINE_REQUEST_FLAG.BIAS_PULL_DOWN.getVal()); + break; + case OFF: + this.line.requestBothEdgeEventsFlags(config.getId(), GpioD.LINE_REQUEST_FLAG.BIAS_DISABLE.getVal()); + break; + } + } catch (GpioDException e) { + logger.error(e.getMessage(), e); + throw new InitializeException(e); + } + super.initialize(context); + + Runnable monitorThread = new Runnable() { + @Override + public void run() { + DigitalState lastState = null; + while (true) { + long debounceNs = GpioDDigitalInput.this.debounceNs; + // We have to use this function before calling eventRead() directly, since native methods can't be interrupted. + // eventRead() is blocking and prevents thread interrupt while running + while (!GpioDDigitalInput.this.line.eventWait(inputMaxWaitNs)) { + continue; + } + GpioLineEvent lastEvent = GpioDDigitalInput.this.line.eventRead(); + long currentTime = System.nanoTime(); + + // Perform debouncing + // If the event is too new to be sure that it is debounced then ... + while (lastEvent.getTimeNs() + debounceNs >= currentTime) { + // ... wait for remaining debounce time and watch out for new event(s) + if(GpioDDigitalInput.this.line.eventWait(Math.min(inputMaxWaitNs, lastEvent.getTimeNs() + debounceNs - currentTime))) { + // Repeat if a second event occurred withing debounce interval + lastEvent = GpioDDigitalInput.this.line.eventRead(); + } + + currentTime = System.nanoTime(); + } + + // Apply event only if the new state is not the same as the last state. + DigitalState newState = DigitalState.getState(lastEvent.getType() == GpioD.LINE_EVENT.RISING_EDGE); + if(lastState != newState) { + lastState = newState; + GpioDDigitalInput.this.dispatch(new DigitalStateChangeEvent(GpioDDigitalInput.this, newState)); + } + + } + } + }; + + executor.submit(monitorThread); + return this; + } + + @Override + public DigitalInput shutdown(Context context) throws ShutdownException { + super.shutdown(context); + executor.shutdown(); + this.line.release(); + return this; + } + + @Override + public DigitalState state() { + return DigitalState.getState(this.line.getValue()); + } + +} diff --git a/plugins/pi4j-plugin-gpiod/src/main/java/com/pi4j/plugin/gpiod/provider/gpio/digital/GpioDDigitalInputProvider.java b/plugins/pi4j-plugin-gpiod/src/main/java/com/pi4j/plugin/gpiod/provider/gpio/digital/GpioDDigitalInputProvider.java new file mode 100644 index 00000000..4adff7ec --- /dev/null +++ b/plugins/pi4j-plugin-gpiod/src/main/java/com/pi4j/plugin/gpiod/provider/gpio/digital/GpioDDigitalInputProvider.java @@ -0,0 +1,26 @@ +package com.pi4j.plugin.gpiod.provider.gpio.digital; + +import com.pi4j.io.gpio.digital.DigitalInputProvider; +import com.pi4j.plugin.gpiod.GpioDPlugin; + +/** + *GpioDDigitalInputProvider interface.
+ * + * @author Alexander Liggesmeyer (https://alexander.liggesmeyer.net/) + * @version $Id: $Id + */ +public interface GpioDDigitalInputProvider extends DigitalInputProvider { + /** ConstantNAME="GpioDPlugin.DIGITAL_INPUT_PROVIDER_NAME" */
+ String NAME = GpioDPlugin.DIGITAL_INPUT_PROVIDER_NAME;
+ /** Constant ID="GpioDPlugin.DIGITAL_INPUT_PROVIDER_ID" */
+ String ID = GpioDPlugin.DIGITAL_INPUT_PROVIDER_ID;
+
+ /**
+ * newInstance.
+ * + * @return a {@link com.pi4j.plugin.gpiod.provider.gpio.digital.GpioDDigitalInputProvider} object. + */ + static GpioDDigitalInputProvider newInstance() { + return new GpioDDigitalInputProviderImpl(); + } +} diff --git a/plugins/pi4j-plugin-gpiod/src/main/java/com/pi4j/plugin/gpiod/provider/gpio/digital/GpioDDigitalInputProviderImpl.java b/plugins/pi4j-plugin-gpiod/src/main/java/com/pi4j/plugin/gpiod/provider/gpio/digital/GpioDDigitalInputProviderImpl.java new file mode 100644 index 00000000..5e4c69b0 --- /dev/null +++ b/plugins/pi4j-plugin-gpiod/src/main/java/com/pi4j/plugin/gpiod/provider/gpio/digital/GpioDDigitalInputProviderImpl.java @@ -0,0 +1,49 @@ +package com.pi4j.plugin.gpiod.provider.gpio.digital; + +import com.pi4j.context.Context; +import com.pi4j.exception.InitializeException; +import com.pi4j.exception.ShutdownException; +import com.pi4j.io.gpio.digital.*; +import com.pi4j.library.gpiod.internal.GpioLine; + +public class GpioDDigitalInputProviderImpl extends DigitalInputProviderBase implements GpioDDigitalInputProvider { + private ActiveGpioChip chipClaim; + + /** + *Constructor for GpioDDigitalInputProviderImpl.
+ */ + public GpioDDigitalInputProviderImpl(){ + this.id = ID; + this.name = NAME; + } + + /** {@inheritDoc} */ + @Override + public DigitalInput create(DigitalInputConfig config) { + // create new I/O instance based on I/O config + GpioLine line = this.chipClaim.getGpioChip().getLine(config.address()); + return new GpioDDigitalInput(line, this, config); + } + + @Override + public int getPriority() { + // GpioD should be used if available + return 150; + } + + /** {@inheritDoc} */ + @Override + public DigitalInputProvider initialize(Context context) throws InitializeException { + DigitalInputProvider provider = super.initialize(context); + this.chipClaim = new ActiveGpioChip(); + return provider; + } + + @Override + public DigitalInputProvider shutdown(Context context) throws ShutdownException { + if(chipClaim.getGpioChip() != null) { + this.chipClaim.close(); + } + return super.shutdown(context); + } +} diff --git a/plugins/pi4j-plugin-gpiod/src/main/java/com/pi4j/plugin/gpiod/provider/gpio/digital/GpioDDigitalOutput.java b/plugins/pi4j-plugin-gpiod/src/main/java/com/pi4j/plugin/gpiod/provider/gpio/digital/GpioDDigitalOutput.java new file mode 100644 index 00000000..884c7e85 --- /dev/null +++ b/plugins/pi4j-plugin-gpiod/src/main/java/com/pi4j/plugin/gpiod/provider/gpio/digital/GpioDDigitalOutput.java @@ -0,0 +1,94 @@ +package com.pi4j.plugin.gpiod.provider.gpio.digital; + +/*- + * #%L + * ********************************************************************** + * ORGANIZATION : Pi4J + * PROJECT : Pi4J :: PLUGIN :: PIGPIO I/O Providers + * FILENAME : PiGpioDigitalOutput.java + * + * This file is part of the Pi4J project. More information about + * this project can be found here: https://pi4j.com/ + * ********************************************************************** + * + * This program is free software: you can redistribute it and/or modify + * it under the terms of the GNU Lesser General Public License as + * published by the Free Software Foundation, either version 3 of the + * License, or (at your option) any later version. + * + * This program is distributed in the hope that it will be useful, + * but WITHOUT ANY WARRANTY; without even the implied warranty of + * MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the + * GNU General Lesser Public License for more details. + * + * You should have received a copy of the GNU General Lesser Public + * License along with this program. If not, see + *PiGpioDigitalOutput class.
+ * + * @author Alexander Liggesmeyer (https://alexander.liggesmeyer.net/) + * @version $Id: $Id + */ +public class GpioDDigitalOutput extends DigitalOutputBase implements DigitalOutput { + private Logger logger = LoggerFactory.getLogger(this.getClass()); + private final GpioLine line; + + /** + *Constructor for GpioDDigitalOutput.
+ * + * @param line a {@link com.pi4j.library.gpiod.internal.GpioLine} object. + * @param provider a {@link DigitalOutputProvider} object. + * @param config a {@link DigitalOutputConfig} object. + */ + public GpioDDigitalOutput(GpioLine line, DigitalOutputProvider provider, DigitalOutputConfig config) { + super(provider, config); + this.line = line; + } + + /** {@inheritDoc} */ + @Override + public DigitalOutput initialize(Context context) throws InitializeException { + try { + this.line.requestOutput(config.getId(), config.initialState().value().intValue()); + } catch (GpioDException e) { + logger.error(e.getMessage(), e); + throw new InitializeException(e); + } + super.initialize(context); + return this; + } + + @Override + public DigitalOutput shutdown(Context context) throws ShutdownException { + DigitalOutput returnMe = super.shutdown(context); + this.line.release(); + return returnMe; + } + + /** {@inheritDoc} */ + @Override + public DigitalOutput state(DigitalState state) throws IOException { + try { + this.line.setValue(state.value().intValue()); + } catch (GpioDException e) { + logger.error(e.getMessage(), e); + throw new IOException(e.getMessage(), e); + } + return super.state(state); + } +} diff --git a/plugins/pi4j-plugin-gpiod/src/main/java/com/pi4j/plugin/gpiod/provider/gpio/digital/GpioDDigitalOutputProvider.java b/plugins/pi4j-plugin-gpiod/src/main/java/com/pi4j/plugin/gpiod/provider/gpio/digital/GpioDDigitalOutputProvider.java new file mode 100644 index 00000000..1e4a681d --- /dev/null +++ b/plugins/pi4j-plugin-gpiod/src/main/java/com/pi4j/plugin/gpiod/provider/gpio/digital/GpioDDigitalOutputProvider.java @@ -0,0 +1,53 @@ +package com.pi4j.plugin.gpiod.provider.gpio.digital; + +/* + * #%L + * ********************************************************************** + * ORGANIZATION : Pi4J + * PROJECT : Pi4J :: PLUGIN :: PIGPIO I/O Providers + * FILENAME : PiGpioDigitalOutputProvider.java + * + * This file is part of the Pi4J project. More information about + * this project can be found here: https://pi4j.com/ + * ********************************************************************** + * + * This program is free software: you can redistribute it and/or modify + * it under the terms of the GNU Lesser General Public License as + * published by the Free Software Foundation, either version 3 of the + * License, or (at your option) any later version. + * + * This program is distributed in the hope that it will be useful, + * but WITHOUT ANY WARRANTY; without even the implied warranty of + * MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the + * GNU General Lesser Public License for more details. + * + * You should have received a copy of the GNU General Lesser Public + * License along with this program. If not, see + *PiGpioDigitalOutputProvider interface.
+ * + * @author Alexander Liggesmeyer (https://alexander.liggesmeyer.net/) + * @version $Id: $Id + */ +public interface GpioDDigitalOutputProvider extends DigitalOutputProvider { + /** ConstantNAME="GpioDPlugin.DIGITAL_OUTPUT_PROVIDER_NA"{trunked} */
+ String NAME = GpioDPlugin.DIGITAL_OUTPUT_PROVIDER_NAME;
+ /** Constant ID="GpioDPlugin.DIGITAL_OUTPUT_PROVIDER_ID" */
+ String ID = GpioDPlugin.DIGITAL_OUTPUT_PROVIDER_ID;
+
+ /**
+ * newInstance.
+ * + * @return a {@link GpioDDigitalOutputProvider} object. + */ + static GpioDDigitalOutputProvider newInstance() { + return new GpioDDigitalOutputProviderImpl(); + } +} diff --git a/plugins/pi4j-plugin-gpiod/src/main/java/com/pi4j/plugin/gpiod/provider/gpio/digital/GpioDDigitalOutputProviderImpl.java b/plugins/pi4j-plugin-gpiod/src/main/java/com/pi4j/plugin/gpiod/provider/gpio/digital/GpioDDigitalOutputProviderImpl.java new file mode 100644 index 00000000..5e36c034 --- /dev/null +++ b/plugins/pi4j-plugin-gpiod/src/main/java/com/pi4j/plugin/gpiod/provider/gpio/digital/GpioDDigitalOutputProviderImpl.java @@ -0,0 +1,89 @@ +package com.pi4j.plugin.gpiod.provider.gpio.digital; + +/* + * #%L + * ********************************************************************** + * ORGANIZATION : Pi4J + * PROJECT : Pi4J :: PLUGIN :: PIGPIO I/O Providers + * FILENAME : PiGpioDigitalOutputProviderImpl.java + * + * This file is part of the Pi4J project. More information about + * this project can be found here: https://pi4j.com/ + * ********************************************************************** + * + * This program is free software: you can redistribute it and/or modify + * it under the terms of the GNU Lesser General Public License as + * published by the Free Software Foundation, either version 3 of the + * License, or (at your option) any later version. + * + * This program is distributed in the hope that it will be useful, + * but WITHOUT ANY WARRANTY; without even the implied warranty of + * MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the + * GNU General Lesser Public License for more details. + * + * You should have received a copy of the GNU General Lesser Public + * License along with this program. If not, see + *PiGpioDigitalOutputProviderImpl class.
+ * + * @author Alexander Liggesmeyer (https://alexander.liggesmeyer.net/) + * @version $Id: $Id + */ +public class GpioDDigitalOutputProviderImpl extends DigitalOutputProviderBase implements GpioDDigitalOutputProvider { + private ActiveGpioChip chipClaim; + + + /** + *Constructor for PiGpioDigitalOutputProviderImpl.
+ * + */ + public GpioDDigitalOutputProviderImpl(){ + this.id = ID; + this.name = NAME; + } + + /** {@inheritDoc} */ + @Override + public DigitalOutput create(DigitalOutputConfig config) { + // create new I/O instance based on I/O config + GpioLine line = this.chipClaim.getGpioChip().getLine(config.address()); + return new GpioDDigitalOutput(line, this, config); + } + + @Override + public int getPriority() { + // GpioD should be used if available + return 150; + } + + @Override + public DigitalOutputProvider initialize(Context context) throws InitializeException { + DigitalOutputProvider provider = super.initialize(context); + this.chipClaim = new ActiveGpioChip(); + return provider; + } + + @Override + public DigitalOutputProvider shutdown(Context context) throws ShutdownException { + if(chipClaim.getGpioChip() != null) { + this.chipClaim.close(); + } + return super.shutdown(context); + } +} diff --git a/plugins/pi4j-plugin-gpiod/src/main/java/module-info.java b/plugins/pi4j-plugin-gpiod/src/main/java/module-info.java new file mode 100644 index 00000000..841408cc --- /dev/null +++ b/plugins/pi4j-plugin-gpiod/src/main/java/module-info.java @@ -0,0 +1,43 @@ +import com.pi4j.plugin.gpiod.GpioDPlugin; + +/*- + * #%L + * ********************************************************************** + * ORGANIZATION : Pi4J + * PROJECT : Pi4J :: PLUGIN :: LinuxFS I/O Providers + * FILENAME : module-info.java + * + * This file is part of the Pi4J project. More information about + * this project can be found here: https://pi4j.com/ + * ********************************************************************** + * + * This program is free software: you can redistribute it and/or modify + * it under the terms of the GNU Lesser General Public License as + * published by the Free Software Foundation, either version 3 of the + * License, or (at your option) any later version. + * + * This program is distributed in the hope that it will be useful, + * but WITHOUT ANY WARRANTY; without even the implied warranty of + * MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the + * GNU General Lesser Public License for more details. + * + * You should have received a copy of the GNU General Lesser Public + * License along with this program. If not, see + *