Introduce _memstrcmp() to beautify elm327_parse_error()
[elmcan.git] / module / elmcan.c
index 7ae344ef52477aae8b589ddee41db3f8021a9c1e..ac7036e778c41b1740847e7f43436e0bb808d59c 100644 (file)
@@ -1,24 +1,9 @@
 // SPDX-License-Identifier: GPL-2.0
-/* elmcan.c - ELM327 based CAN interface driver
- *            (tty line discipline)
+/* ELM327 based CAN interface driver (tty line discipline)
  *
  * This driver started as a derivative of linux/drivers/net/can/slcan.c
- * and my thanks go to the original authors for their inspiration.
- *
- * elmcan.c Author : Max Staudt <max-linux@enpas.org>
- * slcan.c Author  : Oliver Hartkopp <socketcan@hartkopp.net>
- * slip.c Authors  : Laurence Culhane <loz@holmes.demon.co.uk>
- *                   Fred N. van Kempen <waltje@uwalt.nl.mugnet.org>
- *
- * This code barely bears any resemblance to slcan anymore, and whatever
- * may be left is Linux specific boilerplate anyway, however I am leaving
- * the GPL-2.0 identifier at the top just to be sure.
- *
- * Please feel free to use my own code, especially the ELM327 communication
- * logic, in accordance with SPDX-License-Identifier BSD-3-Clause to port
- * this driver to other systems.
- *    - Max
- *
+ * and my thanks go to the original authors for their inspiration, even
+ * after almost none of their code is left.
  */
 
 #define pr_fmt(fmt) "[elmcan] " fmt
 #include <linux/spinlock.h>
 #include <linux/string.h>
 #include <linux/tty.h>
+#include <linux/tty_ldisc.h>
 #include <linux/version.h>
 #include <linux/workqueue.h>
 
+#include <uapi/linux/tty.h>
+
 #include <linux/can.h>
 #include <linux/can/dev.h>
 #include <linux/can/error.h>
@@ -165,12 +153,7 @@ static DEFINE_SPINLOCK(elmcan_discdata_lock);
 
 static inline void elm327_hw_failure(struct elmcan *elm);
 
- /***********************************************************************
-  *            ELM327: Transmission                                    *
-  *                                                                    *
-  * (all functions assume elm->lock taken)                             *
-  ***********************************************************************/
-
+/* Assumes elm->lock taken. */
 static void elm327_send(struct elmcan *elm, const void *buf, size_t len)
 {
        int actual;
@@ -206,6 +189,8 @@ static void elm327_send(struct elmcan *elm, const void *buf, size_t len)
  * We send ELM327_MAGIC_CHAR which will either abort any running
  * operation, or be echoed back to us in case we're already in command
  * mode.
+ *
+ * Assumes elm->lock taken.
  */
 static void elm327_kick_into_cmd_mode(struct elmcan *elm)
 {
@@ -216,7 +201,10 @@ static void elm327_kick_into_cmd_mode(struct elmcan *elm)
        }
 }
 
-/* Schedule a CAN frame and necessary config changes to be sent to the TTY. */
+/* Schedule a CAN frame and necessary config changes to be sent to the TTY.
+ *
+ * Assumes elm->lock taken.
+ */
 static void elm327_send_frame(struct elmcan *elm, struct can_frame *frame)
 {
        /* Schedule any necessary changes in ELM327's CAN configuration */
@@ -252,12 +240,10 @@ static void elm327_send_frame(struct elmcan *elm, struct can_frame *frame)
        elm327_kick_into_cmd_mode(elm);
 }
 
- /***********************************************************************
-  *            ELM327: Initialization sequence                         *
-  *                                                                    *
-  * (assumes elm->lock taken)                                          *
-  ***********************************************************************/
-
+/* ELM327 initialization sequence.
+ *
+ * Assumes elm->lock taken.
+ */
 static char *elm327_init_script[] = {
        "AT WS\r",        /* v1.0: Warm Start */
        "AT PP FF OFF\r", /* v1.0: All Programmable Parameters Off */
@@ -307,12 +293,7 @@ static void elm327_init(struct elmcan *elm)
        elm327_kick_into_cmd_mode(elm);
 }
 
- /***********************************************************************
-  *            ELM327: Reception -> netdev glue                        *
-  *                                                                    *
-  * (assumes elm->lock taken)                                          *
-  ***********************************************************************/
-
+/* Assumes elm->lock taken. */
 static void elm327_feed_frame_to_netdev(struct elmcan *elm,
                                        const struct can_frame *frame)
 {
@@ -341,13 +322,9 @@ static void elm327_feed_frame_to_netdev(struct elmcan *elm,
 #endif
 }
 
- /***********************************************************************
-  *            ELM327: "Panic" handler                                 *
-  *                                                                    *
-  * (assumes elm->lock taken)                                          *
-  ***********************************************************************/
-
-/* Called when we're out of ideas and just want it all to end. */
+/* Called when we're out of ideas and just want it all to end.
+ * Assumes elm->lock taken.
+ */
 static inline void elm327_hw_failure(struct elmcan *elm)
 {
        struct can_frame frame;
@@ -366,12 +343,13 @@ static inline void elm327_hw_failure(struct elmcan *elm)
        can_bus_off(elm->dev);
 }
 
- /***********************************************************************
-  *            ELM327: Reception parser                                *
-  *                                                                    *
-  * (assumes elm->lock taken)                                          *
-  ***********************************************************************/
+/* Compare a buffer to a fixed string */
+static int _memstrcmp(const u8 *mem, const char *str)
+{
+       return memcmp(mem, str, strlen(str));
+}
 
+/* Assumes elm->lock taken. */
 static void elm327_parse_error(struct elmcan *elm, int len)
 {
        struct can_frame frame;
@@ -380,15 +358,16 @@ static void elm327_parse_error(struct elmcan *elm, int len)
        frame.can_id = CAN_ERR_FLAG;
        frame.can_dlc = CAN_ERR_DLC;
 
+       /* Filter possible error messages based on length of RX'd line */
        switch (len) {
        case 17:
-               if (!memcmp(elm->rxbuf, "UNABLE TO CONNECT", 17)) {
+               if (!_memstrcmp(elm->rxbuf, "UNABLE TO CONNECT")) {
                        netdev_err(elm->dev,
                                   "ELM327 reported UNABLE TO CONNECT. Please check your setup.\n");
                }
                break;
        case 11:
-               if (!memcmp(elm->rxbuf, "BUFFER FULL", 11)) {
+               if (!_memstrcmp(elm->rxbuf, "BUFFER FULL")) {
                        /* This case will only happen if the last data
                         * line was complete.
                         * Otherwise, elm327_parse_frame() will heuristically
@@ -399,33 +378,36 @@ static void elm327_parse_error(struct elmcan *elm, int len)
                }
                break;
        case 9:
-               if (!memcmp(elm->rxbuf, "BUS ERROR", 9))
+               if (!_memstrcmp(elm->rxbuf, "BUS ERROR"))
                        frame.can_id |= CAN_ERR_BUSERROR;
-               if (!memcmp(elm->rxbuf, "CAN ERROR", 9))
+               if (!_memstrcmp(elm->rxbuf, "CAN ERROR"))
                        frame.can_id |= CAN_ERR_PROT;
-               if (!memcmp(elm->rxbuf, "<RX ERROR", 9))
+               if (!_memstrcmp(elm->rxbuf, "<RX ERROR"))
                        frame.can_id |= CAN_ERR_PROT;
                break;
        case 8:
-               if (!memcmp(elm->rxbuf, "BUS BUSY", 8)) {
+               if (!_memstrcmp(elm->rxbuf, "BUS BUSY")) {
                        frame.can_id |= CAN_ERR_PROT;
                        frame.data[2] = CAN_ERR_PROT_OVERLOAD;
                }
-               if (!memcmp(elm->rxbuf, "FB ERROR", 8)) {
+               if (!_memstrcmp(elm->rxbuf, "FB ERROR")) {
                        frame.can_id |= CAN_ERR_PROT;
                        frame.data[2] = CAN_ERR_PROT_TX;
                }
                break;
-       case 5:
-               if (!memcmp(elm->rxbuf, "ERR", 3)) {
+       case 5: /* ERR is followed by two digits, hence line length 5 */
+               if (!_memstrcmp(elm->rxbuf, "ERR")) {
                        netdev_err(elm->dev, "ELM327 reported an ERR%c%c. Please power it off and on again.\n",
                                   elm->rxbuf[3], elm->rxbuf[4]);
                        frame.can_id |= CAN_ERR_CRTL;
                }
                break;
        default:
-               /* Don't emit an error frame if we're unsure */
-               return;
+               /* Something else has happened.
+                * Maybe garbage on the UART line.
+                * Emit a generic error frame.
+                */
+               break;
        }
 
        elm327_feed_frame_to_netdev(elm, &frame);
@@ -442,6 +424,8 @@ static void elm327_parse_error(struct elmcan *elm, int len)
  * Instead of a payload, RTR indicates a remote request.
  *
  * We will use the spaces and line length to guess the format.
+ *
+ * Assumes elm->lock taken.
  */
 static int elm327_parse_frame(struct elmcan *elm, int len)
 {
@@ -477,7 +461,6 @@ static int elm327_parse_frame(struct elmcan *elm, int len)
                /* The line is likely garbled anyway, so bail.
                 * The main code will restart listening.
                 */
-               elm327_kick_into_cmd_mode(elm);
                return -ENODATA;
        }
 
@@ -532,7 +515,7 @@ static int elm327_parse_frame(struct elmcan *elm, int len)
 
        /* Check for RTR frame */
        if (elm->rxfill >= hexlen + 3 &&
-           !memcmp(&elm->rxbuf[hexlen], "RTR", 3)) {
+           !_memstrcmp(&elm->rxbuf[hexlen], "RTR")) {
                frame.can_id |= CAN_RTR_FLAG;
        }
 
@@ -571,6 +554,7 @@ static int elm327_parse_frame(struct elmcan *elm, int len)
        return 0;
 }
 
+/* Assumes elm->lock taken. */
 static void elm327_parse_line(struct elmcan *elm, int len)
 {
        /* Skip empty lines */
@@ -581,7 +565,7 @@ static void elm327_parse_line(struct elmcan *elm, int len)
        if (elm->drop_next_line) {
                elm->drop_next_line = 0;
                return;
-       } else if (elm->rxbuf[0] == 'A' && elm->rxbuf[1] == 'T') {
+       } else if (!_memstrcmp(elm->rxbuf, "AT")) {
                return;
        }
 
@@ -601,6 +585,7 @@ static void elm327_parse_line(struct elmcan *elm, int len)
        }
 }
 
+/* Assumes elm->lock taken. */
 static void elm327_handle_prompt(struct elmcan *elm)
 {
        struct can_frame *frame = &elm->can_frame;
@@ -685,12 +670,14 @@ static bool elm327_is_ready_char(char c)
        return (c & 0x3f) == ELM327_READY_CHAR;
 }
 
+/* Assumes elm->lock taken. */
 static void elm327_drop_bytes(struct elmcan *elm, int i)
 {
        memmove(&elm->rxbuf[0], &elm->rxbuf[i], ELM327_SIZE_RXBUF - i);
        elm->rxfill -= i;
 }
 
+/* Assumes elm->lock taken. */
 static void elm327_parse_rxbuf(struct elmcan *elm)
 {
        int len;
@@ -777,12 +764,6 @@ static void elm327_parse_rxbuf(struct elmcan *elm)
        }
 }
 
- /***********************************************************************
-  *            netdev                                                  *
-  *                                                                    *
-  * (takes elm->lock)                                                  *
-  ***********************************************************************/
-
 /* Dummy needed to use can_rx_offload */
 static struct sk_buff *elmcan_mailbox_read(struct can_rx_offload *offload,
                                           unsigned int n, u32 *timestamp,
@@ -922,12 +903,6 @@ static const struct net_device_ops elmcan_netdev_ops = {
        .ndo_change_mtu = can_change_mtu,
 };
 
- /***********************************************************************
-  *            Line discipline                                         *
-  *                                                                    *
-  * (takes elm->lock)                                                  *
-  ***********************************************************************/
-
 /* Get a reference to our struct, taking into account locks/refcounts.
  * This is to ensure ordering in case we are shutting down, and to ensure
  * there is a refcount at all (otherwise tty->disc_data may be freed and
@@ -982,8 +957,13 @@ static bool elmcan_is_valid_rx_char(char c)
  * This will not be re-entered while running, but other ldisc
  * functions may be called in parallel.
  */
+#if LINUX_VERSION_CODE < KERNEL_VERSION(5,14,0)
 static void elmcan_ldisc_rx(struct tty_struct *tty,
                            const unsigned char *cp, char *fp, int count)
+#else
+static void elmcan_ldisc_rx(struct tty_struct *tty,
+                           const unsigned char *cp, const char *fp, int count)
+#endif
 {
        struct elmcan *elm = get_elm(tty);
 
@@ -1121,8 +1101,6 @@ static const u32 elmcan_bitrate_const[64] = {
 /* Dummy needed to use bitrate_const */
 static int elmcan_do_set_bittiming(struct net_device *netdev)
 {
-       (void)netdev;
-
        return 0;
 }
 
@@ -1163,7 +1141,7 @@ static int elmcan_ldisc_open(struct tty_struct *tty)
        elm->can.do_set_bittiming = elmcan_do_set_bittiming;
        elm->can.ctrlmode_supported = CAN_CTRLMODE_LISTENONLY;
 
-       /* Configure netlink interface */
+       /* Configure netdev interface */
        elm->dev = dev;
        dev->netdev_ops = &elmcan_netdev_ops;
 
@@ -1231,13 +1209,22 @@ static void elmcan_ldisc_close(struct tty_struct *tty)
        free_candev(elm->dev);
 }
 
+#if LINUX_VERSION_CODE < KERNEL_VERSION(5,16,0)
 static int elmcan_ldisc_hangup(struct tty_struct *tty)
+#else
+static void elmcan_ldisc_hangup(struct tty_struct *tty)
+#endif
 {
        elmcan_ldisc_close(tty);
+#if LINUX_VERSION_CODE < KERNEL_VERSION(5,16,0)
        return 0;
+#endif
 }
 
-static int elmcan_ldisc_ioctl(struct tty_struct *tty, struct file *file,
+static int elmcan_ldisc_ioctl(struct tty_struct *tty,
+#if LINUX_VERSION_CODE < KERNEL_VERSION(5,17,0)
+                             struct file *file,
+#endif
                              unsigned int cmd, unsigned long arg)
 {
        struct elmcan *elm = get_elm(tty);
@@ -1263,13 +1250,18 @@ static int elmcan_ldisc_ioctl(struct tty_struct *tty, struct file *file,
 
        default:
                put_elm(elm);
+#if LINUX_VERSION_CODE < KERNEL_VERSION(5,16,0)
                return tty_mode_ioctl(tty, file, cmd, arg);
+#else
+               return tty_mode_ioctl(tty, cmd, arg);
+#endif
        }
 }
 
 static struct tty_ldisc_ops elmcan_ldisc = {
        .owner          = THIS_MODULE,
        .name           = "elmcan",
+       .num            = N_ELMCAN,
        .receive_buf    = elmcan_ldisc_rx,
        .write_wakeup   = elmcan_ldisc_tx_wakeup,
        .open           = elmcan_ldisc_open,
@@ -1282,10 +1274,11 @@ static int __init elmcan_init(void)
 {
        int status;
 
-       pr_info("ELM327 based best-effort CAN interface driver\n");
-       pr_info("This device is severely limited as a CAN interface, see documentation.\n");
-
+#if LINUX_VERSION_CODE < KERNEL_VERSION(5,14,0)
        status = tty_register_ldisc(N_ELMCAN, &elmcan_ldisc);
+#else
+       status = tty_register_ldisc(&elmcan_ldisc);
+#endif
        if (status)
                pr_err("Can't register line discipline\n");
 
@@ -1297,12 +1290,16 @@ static void __exit elmcan_exit(void)
        /* This will only be called when all channels have been closed by
         * userspace - tty_ldisc.c takes care of the module's refcount.
         */
+#if LINUX_VERSION_CODE < KERNEL_VERSION(5,14,0)
        int status;
 
        status = tty_unregister_ldisc(N_ELMCAN);
        if (status)
                pr_err("Can't unregister line discipline (error: %d)\n",
                       status);
+#else
+       tty_unregister_ldisc(&elmcan_ldisc);
+#endif
 }
 
 module_init(elmcan_init);