Improve error handling in case of stray characters
[elmcan.git] / module / elmcan.c
index ba4ef0d710ca00bf2d59b0b666837b8d3446e69f..49df7c1600ca993703e97811f3f5227d8822095f 100644 (file)
@@ -1,20 +1,13 @@
 // SPDX-License-Identifier: GPL-2.0
-/*
- * elmcan.c - ELM327 based CAN interface driver
- *            (tty line discipline)
- *
- * This file is derived from linux/drivers/net/can/slcan.c
- *
- * 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>
+/* 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, even
+ * after almost none of their code is left.
  */
 
 #define pr_fmt(fmt) "[elmcan] " fmt
 
-
 #include <linux/init.h>
 #include <linux/module.h>
 #include <linux/moduleparam.h>
 #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>
 #include <linux/can/led.h>
-
+#include <linux/can/rx-offload.h>
 
 MODULE_ALIAS_LDISC(N_ELMCAN);
 MODULE_DESCRIPTION("ELM327 based CAN interface");
@@ -54,12 +51,16 @@ static bool accept_flaky_uart;
 module_param_named(accept_flaky_uart, accept_flaky_uart, bool, 0444);
 MODULE_PARM_DESC(accept_flaky_uart, "Don't bail at the first invalid character. Behavior undefined.");
 
-
 /* Line discipline ID number */
 #ifndef N_ELMCAN
 #define N_ELMCAN 29
 #endif
 
+#define ELM327_NAPI_WEIGHT 4
+
+#define ELM327_SIZE_RXBUF 256
+#define ELM327_SIZE_TXBUF 32
+
 #define ELM327_CAN_CONFIG_SEND_SFF           0x8000
 #define ELM327_CAN_CONFIG_VARIABLE_DLC       0x4000
 #define ELM327_CAN_CONFIG_RECV_BOTH_SFF_EFF  0x2000
@@ -69,25 +70,25 @@ MODULE_PARM_DESC(accept_flaky_uart, "Don't bail at the first invalid character.
 #define ELM327_MAGIC_STRING "y"
 #define ELM327_READY_CHAR '>'
 
-
 /* Bits in elm->cmds_todo */
 enum ELM_TODO {
-       ELM_TODO_CAN_DATA = 0,
-       ELM_TODO_CANID_11BIT,
-       ELM_TODO_CANID_29BIT_LOW,
-       ELM_TODO_CANID_29BIT_HIGH,
-       ELM_TODO_CAN_CONFIG_PART2,
-       ELM_TODO_CAN_CONFIG,
-       ELM_TODO_RESPONSES,
-       ELM_TODO_SILENT_MONITOR,
-       ELM_TODO_INIT
+       TODO_CAN_DATA = 0,
+       TODO_CANID_11BIT,
+       TODO_CANID_29BIT_LOW,
+       TODO_CANID_29BIT_HIGH,
+       TODO_CAN_CONFIG_PART2,
+       TODO_CAN_CONFIG,
+       TODO_RESPONSES,
+       TODO_SILENT_MONITOR,
+       TODO_INIT
 };
 
-
 struct elmcan {
        /* This must be the first member when using alloc_candev() */
        struct can_priv can;
 
+       struct can_rx_offload offload;
+
        /* TTY and netdev devices that we're bridging */
        struct tty_struct       *tty;
        struct net_device       *dev;
@@ -111,12 +112,12 @@ struct elmcan {
 
        /* TTY TX helpers */
        struct work_struct      tx_work;        /* Flushes TTY TX buffer   */
-       unsigned char           txbuf[32];
+       unsigned char           *txbuf;
        unsigned char           *txhead;        /* Pointer to next TX byte */
        int                     txleft;         /* Bytes left to TX */
 
        /* TTY RX helpers */
-       unsigned char rxbuf[256];
+       unsigned char rxbuf[ELM327_SIZE_RXBUF];
        int rxfill;
 
        /* State machine */
@@ -143,7 +144,6 @@ struct elmcan {
        unsigned long cmds_todo;
 };
 
-
 /* A lock for all tty->disc_data handled by this ldisc.
  * This is to prevent a case where tty->disc_data is set to NULL,
  * yet someone is still trying to dereference it.
@@ -151,17 +151,9 @@ struct elmcan {
  */
 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;
@@ -183,8 +175,8 @@ static void elm327_send(struct elmcan *elm, const void *buf, size_t len)
        actual = elm->tty->ops->write(elm->tty, elm->txbuf, len);
        if (actual < 0) {
                netdev_err(elm->dev,
-                       "Failed to write to tty %s.\n",
-                       elm->tty->name);
+                          "Failed to write to tty %s.\n",
+                          elm->tty->name);
                elm327_hw_failure(elm);
                return;
        }
@@ -193,11 +185,12 @@ static void elm327_send(struct elmcan *elm, const void *buf, size_t len)
        elm->txhead = elm->txbuf + actual;
 }
 
-
 /* Take the ELM327 out of almost any state and back into command mode.
  * 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)
 {
@@ -208,8 +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 */
@@ -224,35 +219,31 @@ static void elm327_send_frame(struct elmcan *elm, struct can_frame *frame)
                                        | ELM327_CAN_CONFIG_RECV_BOTH_SFF_EFF
                                        | elm->can_bitrate_divisor;
 
-                       set_bit(ELM_TODO_CAN_CONFIG, &elm->cmds_todo);
+                       set_bit(TODO_CAN_CONFIG, &elm->cmds_todo);
                }
 
                if (frame->can_id & CAN_EFF_FLAG) {
-                       clear_bit(ELM_TODO_CANID_11BIT, &elm->cmds_todo);
-                       set_bit(ELM_TODO_CANID_29BIT_LOW, &elm->cmds_todo);
-                       set_bit(ELM_TODO_CANID_29BIT_HIGH, &elm->cmds_todo);
+                       clear_bit(TODO_CANID_11BIT, &elm->cmds_todo);
+                       set_bit(TODO_CANID_29BIT_LOW, &elm->cmds_todo);
+                       set_bit(TODO_CANID_29BIT_HIGH, &elm->cmds_todo);
                } else {
-                       set_bit(ELM_TODO_CANID_11BIT, &elm->cmds_todo);
-                       clear_bit(ELM_TODO_CANID_29BIT_LOW, &elm->cmds_todo);
-                       clear_bit(ELM_TODO_CANID_29BIT_HIGH, &elm->cmds_todo);
+                       set_bit(TODO_CANID_11BIT, &elm->cmds_todo);
+                       clear_bit(TODO_CANID_29BIT_LOW, &elm->cmds_todo);
+                       clear_bit(TODO_CANID_29BIT_HIGH, &elm->cmds_todo);
                }
        }
 
        /* Schedule the CAN frame itself. */
        elm->can_frame = *frame;
-       set_bit(ELM_TODO_CAN_DATA, &elm->cmds_todo);
+       set_bit(TODO_CAN_DATA, &elm->cmds_todo);
 
        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 */
@@ -275,7 +266,6 @@ static char *elm327_init_script[] = {
        NULL
 };
 
-
 static void elm327_init(struct elmcan *elm)
 {
        elm->state = ELM_NOTINIT;
@@ -295,22 +285,15 @@ static void elm327_init(struct elmcan *elm)
 
        /* Configure ELM327 and then start monitoring */
        elm->next_init_cmd = &elm327_init_script[0];
-       set_bit(ELM_TODO_INIT, &elm->cmds_todo);
-       set_bit(ELM_TODO_SILENT_MONITOR, &elm->cmds_todo);
-       set_bit(ELM_TODO_RESPONSES, &elm->cmds_todo);
-       set_bit(ELM_TODO_CAN_CONFIG, &elm->cmds_todo);
+       set_bit(TODO_INIT, &elm->cmds_todo);
+       set_bit(TODO_SILENT_MONITOR, &elm->cmds_todo);
+       set_bit(TODO_RESPONSES, &elm->cmds_todo);
+       set_bit(TODO_CAN_CONFIG, &elm->cmds_todo);
 
        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)
 {
@@ -327,22 +310,21 @@ static void elm327_feed_frame_to_netdev(struct elmcan *elm,
 
        memcpy(cf, frame, sizeof(struct can_frame));
 
-       elm->dev->stats.rx_packets++;
-       elm->dev->stats.rx_bytes += frame->can_dlc;
-       netif_rx_ni(skb);
+       /* Queue for NAPI pickup.
+        * rx-offload will update stats and LEDs for us.
+        */
+       if (can_rx_offload_queue_tail(&elm->offload, skb))
+               elm->dev->stats.rx_fifo_errors++;
 
-       can_led_event(elm->dev, CAN_LED_EVENT_RX);
+#if LINUX_VERSION_CODE >= KERNEL_VERSION(5,15,0)
+       /* Wake NAPI */
+       can_rx_offload_irq_finish(&elm->offload);
+#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;
@@ -361,14 +343,7 @@ static inline void elm327_hw_failure(struct elmcan *elm)
        can_bus_off(elm->dev);
 }
 
-
-
- /************************************************************************
-  *            ELM327: Reception parser                        *
-  *                                                            *
-  * (assumes elm->lock taken)                                  *
-  ************************************************************************/
-
+/* Assumes elm->lock taken. */
 static void elm327_parse_error(struct elmcan *elm, int len)
 {
        struct can_frame frame;
@@ -381,7 +356,7 @@ static void elm327_parse_error(struct elmcan *elm, int len)
        case 17:
                if (!memcmp(elm->rxbuf, "UNABLE TO CONNECT", 17)) {
                        netdev_err(elm->dev,
-                               "The ELM327 reported UNABLE TO CONNECT. Please check your setup.\n");
+                                  "ELM327 reported UNABLE TO CONNECT. Please check your setup.\n");
                }
                break;
        case 11:
@@ -415,20 +390,22 @@ static void elm327_parse_error(struct elmcan *elm, int len)
                break;
        case 5:
                if (!memcmp(elm->rxbuf, "ERR", 3)) {
-                       netdev_err(elm->dev, "The ELM327 reported an ERR%c%c. Please power it off and on again.\n",
-                               elm->rxbuf[3], elm->rxbuf[4]);
+                       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);
 }
 
-
 /* Parse CAN frames coming as ASCII from ELM327.
  * They can be of various formats:
  *
@@ -440,6 +417,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)
 {
@@ -456,8 +435,8 @@ static int elm327_parse_frame(struct elmcan *elm, int len)
         *  - An error message may replace the end of the data line.
         */
        for (hexlen = 0; hexlen <= len; hexlen++) {
-               if (hex_to_bin(elm->rxbuf[hexlen]) < 0
-                   && elm->rxbuf[hexlen] != ' ') {
+               if (hex_to_bin(elm->rxbuf[hexlen]) < 0 &&
+                   elm->rxbuf[hexlen] != ' ') {
                        break;
                }
        }
@@ -466,26 +445,25 @@ static int elm327_parse_frame(struct elmcan *elm, int len)
         * Check for stray characters on a payload line.
         * No idea what causes this.
         */
-       if (accept_flaky_uart
-           && hexlen < len
-           && !isdigit(elm->rxbuf[hexlen])
-           && !isupper(elm->rxbuf[hexlen])
-           && '<' != elm->rxbuf[hexlen]
-           && ' ' != elm->rxbuf[hexlen]) {
+       if (accept_flaky_uart &&
+           hexlen < len &&
+           !isdigit(elm->rxbuf[hexlen]) &&
+           !isupper(elm->rxbuf[hexlen]) &&
+           '<' != elm->rxbuf[hexlen] &&
+           ' ' != elm->rxbuf[hexlen]) {
                /* The line is likely garbled anyway, so bail.
                 * The main code will restart listening.
                 */
-               elm327_kick_into_cmd_mode(elm);
-               return 3;
+               return -ENODATA;
        }
 
        /* Use spaces in CAN ID to distinguish 29 or 11 bit address length.
         * No out-of-bounds access:
         * We use the fact that we can always read from elm->rxbuf.
         */
-       if (elm->rxbuf[2] == ' ' && elm->rxbuf[5] == ' '
-               && elm->rxbuf[8] == ' ' && elm->rxbuf[11] == ' '
-               && elm->rxbuf[13] == ' ') {
+       if (elm->rxbuf[2] == ' ' && elm->rxbuf[5] == ' ' &&
+           elm->rxbuf[8] == ' ' && elm->rxbuf[11] == ' ' &&
+           elm->rxbuf[13] == ' ') {
                frame.can_id = CAN_EFF_FLAG;
                datastart = 14;
        } else if (elm->rxbuf[3] == ' ' && elm->rxbuf[5] == ' ') {
@@ -495,14 +473,14 @@ static int elm327_parse_frame(struct elmcan *elm, int len)
                /* This is not a well-formatted data line.
                 * Assume it's an error message.
                 */
-               return 1;
+               return -ENODATA;
        }
 
        if (hexlen < datastart) {
                /* The line is too short to be a valid frame hex dump.
                 * Something interrupted the hex dump or it is invalid.
                 */
-               return 1;
+               return -ENODATA;
        }
 
        /* From here on all chars up to buf[hexlen] are hex or spaces,
@@ -529,16 +507,16 @@ 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)) {
+       if (elm->rxfill >= hexlen + 3 &&
+           !memcmp(&elm->rxbuf[hexlen], "RTR", 3)) {
                frame.can_id |= CAN_RTR_FLAG;
        }
 
        /* Is the line long enough to hold the advertised payload?
         * Note: RTR frames have a DLC, but no actual payload.
         */
-       if (!(frame.can_id & CAN_RTR_FLAG)
-           && (hexlen < frame.can_dlc * 3 + datastart)) {
+       if (!(frame.can_id & CAN_RTR_FLAG) &&
+           (hexlen < frame.can_dlc * 3 + datastart)) {
                /* Incomplete frame. */
 
                /* Probably the ELM327's RS232 TX buffer was full.
@@ -554,13 +532,13 @@ static int elm327_parse_frame(struct elmcan *elm, int len)
                 * However, this will correctly drop the state machine back into
                 * command mode.
                 */
-               return 2;
+               return -ENODATA;
        }
 
        /* Parse the data nibbles. */
        for (i = 0; i < frame.can_dlc; i++) {
-               frame.data[i] = (hex_to_bin(elm->rxbuf[datastart+3*i]) << 4)
-                             | (hex_to_bin(elm->rxbuf[datastart+3*i+1]) << 0);
+               frame.data[i] = (hex_to_bin(elm->rxbuf[datastart + 3*i]) << 4)
+                             | (hex_to_bin(elm->rxbuf[datastart + 3*i + 1]));
        }
 
        /* Feed the frame to the network layer. */
@@ -569,7 +547,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 */
@@ -600,6 +578,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;
@@ -614,44 +593,44 @@ static void elm327_handle_prompt(struct elmcan *elm)
        }
 
        /* Reconfigure ELM327 step by step as indicated by elm->cmds_todo */
-       if (test_bit(ELM_TODO_INIT, &elm->cmds_todo)) {
+       if (test_bit(TODO_INIT, &elm->cmds_todo)) {
                strcpy(local_txbuf, *elm->next_init_cmd);
 
                elm->next_init_cmd++;
                if (!(*elm->next_init_cmd)) {
-                       clear_bit(ELM_TODO_INIT, &elm->cmds_todo);
+                       clear_bit(TODO_INIT, &elm->cmds_todo);
                        netdev_info(elm->dev, "Initialization finished.\n");
                }
 
-       } else if (test_and_clear_bit(ELM_TODO_SILENT_MONITOR, &elm->cmds_todo)) {
+       } else if (test_and_clear_bit(TODO_SILENT_MONITOR, &elm->cmds_todo)) {
                sprintf(local_txbuf, "ATCSM%i\r",
                        !(!(elm->can.ctrlmode & CAN_CTRLMODE_LISTENONLY)));
 
-       } else if (test_and_clear_bit(ELM_TODO_RESPONSES, &elm->cmds_todo)) {
+       } else if (test_and_clear_bit(TODO_RESPONSES, &elm->cmds_todo)) {
                sprintf(local_txbuf, "ATR%i\r",
                        !(elm->can.ctrlmode & CAN_CTRLMODE_LISTENONLY));
 
-       } else if (test_and_clear_bit(ELM_TODO_CAN_CONFIG, &elm->cmds_todo)) {
+       } else if (test_and_clear_bit(TODO_CAN_CONFIG, &elm->cmds_todo)) {
                sprintf(local_txbuf, "ATPC\r");
-               set_bit(ELM_TODO_CAN_CONFIG_PART2, &elm->cmds_todo);
+               set_bit(TODO_CAN_CONFIG_PART2, &elm->cmds_todo);
 
-       } else if (test_and_clear_bit(ELM_TODO_CAN_CONFIG_PART2, &elm->cmds_todo)) {
+       } else if (test_and_clear_bit(TODO_CAN_CONFIG_PART2, &elm->cmds_todo)) {
                sprintf(local_txbuf, "ATPB%04X\r",
                        elm->can_config);
 
-       } else if (test_and_clear_bit(ELM_TODO_CANID_29BIT_HIGH, &elm->cmds_todo)) {
+       } else if (test_and_clear_bit(TODO_CANID_29BIT_HIGH, &elm->cmds_todo)) {
                sprintf(local_txbuf, "ATCP%02X\r",
                        (frame->can_id & CAN_EFF_MASK) >> 24);
 
-       } else if (test_and_clear_bit(ELM_TODO_CANID_29BIT_LOW, &elm->cmds_todo)) {
+       } else if (test_and_clear_bit(TODO_CANID_29BIT_LOW, &elm->cmds_todo)) {
                sprintf(local_txbuf, "ATSH%06X\r",
                        frame->can_id & CAN_EFF_MASK & ((1 << 24) - 1));
 
-       } else if (test_and_clear_bit(ELM_TODO_CANID_11BIT, &elm->cmds_todo)) {
+       } else if (test_and_clear_bit(TODO_CANID_11BIT, &elm->cmds_todo)) {
                sprintf(local_txbuf, "ATSH%03X\r",
                        frame->can_id & CAN_SFF_MASK);
 
-       } else if (test_and_clear_bit(ELM_TODO_CAN_DATA, &elm->cmds_todo)) {
+       } else if (test_and_clear_bit(TODO_CAN_DATA, &elm->cmds_todo)) {
                if (frame->can_id & CAN_RTR_FLAG) {
                        /* Send an RTR frame. Their DLC is fixed.
                         * Some chips don't send them at all.
@@ -662,11 +641,11 @@ static void elm327_handle_prompt(struct elmcan *elm)
                        int i;
 
                        for (i = 0; i < frame->can_dlc; i++) {
-                               sprintf(&local_txbuf[2*i], "%02X",
+                               sprintf(&local_txbuf[2 * i], "%02X",
                                        frame->data[i]);
                        }
 
-                       sprintf(&local_txbuf[2*i], "\r");
+                       sprintf(&local_txbuf[2 * i], "\r");
                }
 
                elm->drop_next_line = 1;
@@ -676,7 +655,6 @@ static void elm327_handle_prompt(struct elmcan *elm)
        elm327_send(elm, local_txbuf, strlen(local_txbuf));
 }
 
-
 static bool elm327_is_ready_char(char c)
 {
        /* Bits 0xc0 are sometimes set (randomly), hence the mask.
@@ -685,12 +663,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], sizeof(elm->rxbuf) - 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;
@@ -739,12 +719,12 @@ static void elm327_parse_rxbuf(struct elmcan *elm)
                        /* empty loop */
                }
 
-               if (len == sizeof(elm->rxbuf)) {
+               if (len == ELM327_SIZE_RXBUF) {
                        /* Line exceeds buffer. It's probably all garbage.
                         * Did we even connect at the right baud rate?
                         */
                        netdev_err(elm->dev,
-                               "RX buffer overflow. Faulty ELM327 or UART?\n");
+                                  "RX buffer overflow. Faulty ELM327 or UART?\n");
                        elm327_hw_failure(elm);
                        break;
                } else if (len == elm->rxfill) {
@@ -769,7 +749,7 @@ static void elm327_parse_rxbuf(struct elmcan *elm)
                elm327_parse_line(elm, len);
 
                /* Remove parsed data from RX buffer. */
-               elm327_drop_bytes(elm, len+1);
+               elm327_drop_bytes(elm, len + 1);
 
                /* More data to parse? */
                if (elm->rxfill)
@@ -777,15 +757,15 @@ static void elm327_parse_rxbuf(struct elmcan *elm)
        }
 }
 
+/* Dummy needed to use can_rx_offload */
+static struct sk_buff *elmcan_mailbox_read(struct can_rx_offload *offload,
+                                          unsigned int n, u32 *timestamp,
+                                          bool drop)
+{
+       WARN_ON_ONCE(1); /* This function is a dummy, so don't call it! */
 
-
-
-
- /***********************************************************************
-  *            netdev                                                  *
-  *                                                                    *
-  * (takes elm->lock)                                                  *
-  ***********************************************************************/
+       return ERR_PTR(-ENOBUFS);
+}
 
 static int elmcan_netdev_open(struct net_device *dev)
 {
@@ -799,7 +779,7 @@ static int elmcan_netdev_open(struct net_device *dev)
                return -EIO;
        }
 
-       if (elm->tty == NULL) {
+       if (!elm->tty) {
                spin_unlock_bh(&elm->lock);
                return -ENODEV;
        }
@@ -814,6 +794,15 @@ static int elmcan_netdev_open(struct net_device *dev)
        elm327_init(elm);
        spin_unlock_bh(&elm->lock);
 
+       elm->offload.mailbox_read = elmcan_mailbox_read;
+       err = can_rx_offload_add_fifo(dev, &elm->offload, ELM327_NAPI_WEIGHT);
+       if (err) {
+               close_candev(dev);
+               return err;
+       }
+
+       can_rx_offload_enable(&elm->offload);
+
        can_led_event(dev, CAN_LED_EVENT_OPEN);
        elm->can.state = CAN_STATE_ERROR_ACTIVE;
        netif_start_queue(dev);
@@ -825,6 +814,8 @@ static int elmcan_netdev_close(struct net_device *dev)
 {
        struct elmcan *elm = netdev_priv(dev);
 
+       netif_stop_queue(dev);
+
        spin_lock_bh(&elm->lock);
        if (elm->tty) {
                /* Interrupt whatever we're doing right now */
@@ -842,8 +833,9 @@ static int elmcan_netdev_close(struct net_device *dev)
                spin_unlock_bh(&elm->lock);
        }
 
+       can_rx_offload_disable(&elm->offload);
        elm->can.state = CAN_STATE_STOPPED;
-       netif_stop_queue(dev);
+       can_rx_offload_del(&elm->offload);
        close_candev(dev);
        can_led_event(dev, CAN_LED_EVENT_STOP);
 
@@ -855,7 +847,7 @@ static netdev_tx_t elmcan_netdev_start_xmit(struct sk_buff *skb,
                                            struct net_device *dev)
 {
        struct elmcan *elm = netdev_priv(dev);
-       struct can_frame *frame = (struct can_frame *) skb->data;
+       struct can_frame *frame = (struct can_frame *)skb->data;
 
        if (skb->len != sizeof(struct can_frame))
                goto out;
@@ -873,11 +865,11 @@ static netdev_tx_t elmcan_netdev_start_xmit(struct sk_buff *skb,
        /* We shouldn't get here after a hardware fault:
         * can_bus_off() calls netif_carrier_off()
         */
-       WARN_ON(elm->hw_failure);
+       WARN_ON_ONCE(elm->hw_failure);
 
-       if (elm->tty == NULL
-               || elm->hw_failure
-               || elm->can.ctrlmode & CAN_CTRLMODE_LISTENONLY) {
+       if (!elm->tty ||
+           elm->hw_failure ||
+           elm->can.ctrlmode & CAN_CTRLMODE_LISTENONLY) {
                spin_unlock(&elm->lock);
                goto out;
        }
@@ -897,7 +889,6 @@ out:
        return NETDEV_TX_OK;
 }
 
-
 static const struct net_device_ops elmcan_netdev_ops = {
        .ndo_open       = elmcan_netdev_open,
        .ndo_stop       = elmcan_netdev_close,
@@ -905,16 +896,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
@@ -927,7 +908,7 @@ static struct elmcan *get_elm(struct tty_struct *tty)
        bool got_ref;
 
        spin_lock_bh(&elmcan_discdata_lock);
-       elm = (struct elmcan *) tty->disc_data;
+       elm = (struct elmcan *)tty->disc_data;
 
        if (!elm) {
                spin_unlock_bh(&elmcan_discdata_lock);
@@ -948,30 +929,34 @@ static void put_elm(struct elmcan *elm)
        atomic_dec(&elm->refcount);
 }
 
-
 static bool elmcan_is_valid_rx_char(char c)
 {
-       return (accept_flaky_uart
-               || isdigit(c)
-               || isupper(c)
-               || ELM327_MAGIC_CHAR == c
-               || ELM327_READY_CHAR == c
-               || '<' == c
-               || 'a' == c
-               || 'b' == c
-               || 'v' == c
-               || '.' == c
-               || '?' == c
-               || '\r' == c
-               || ' ' == c);
+       return (accept_flaky_uart ||
+               isdigit(c) ||
+               isupper(c) ||
+               c == ELM327_MAGIC_CHAR ||
+               c == ELM327_READY_CHAR ||
+               c == '<' ||
+               c == 'a' ||
+               c == 'b' ||
+               c == 'v' ||
+               c == '.' ||
+               c == '?' ||
+               c == '\r' ||
+               c == ' ');
 }
 
 /* Handle incoming ELM327 ASCII data.
  * 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, char *fp, int count)
+                           const unsigned char *cp, const char *fp, int count)
+#endif
 {
        struct elmcan *elm = get_elm(tty);
 
@@ -980,11 +965,10 @@ static void elmcan_ldisc_rx(struct tty_struct *tty,
 
        spin_lock_bh(&elm->lock);
 
-       if (elm->hw_failure) {
+       if (elm->hw_failure)
                goto out;
-       }
 
-       while (count-- && elm->rxfill < sizeof(elm->rxbuf)) {
+       while (count-- && elm->rxfill < ELM327_SIZE_RXBUF) {
                if (fp && *fp++) {
                        netdev_err(elm->dev, "Error in received character stream. Check your wiring.");
 
@@ -1032,7 +1016,6 @@ out:
        put_elm(elm);
 }
 
-
 /* Write out remaining transmit buffer.
  * Scheduled when TTY is writable.
  */
@@ -1093,7 +1076,6 @@ static void elmcan_ldisc_tx_wakeup(struct tty_struct *tty)
        put_elm(elm);
 }
 
-
 /* ELM327 can only handle bitrates that are integer divisors of 500 kHz,
  * or 7/8 of that. Divisors are 1 to 64.
  * Currently we don't implement support for 7/8 rates.
@@ -1109,16 +1091,12 @@ static const u32 elmcan_bitrate_const[64] = {
        62500, 71428, 83333, 100000, 125000, 166666, 250000, 500000
 };
 
-
 /* Dummy needed to use bitrate_const */
 static int elmcan_do_set_bittiming(struct net_device *netdev)
 {
-       (void)netdev;
-
        return 0;
 }
 
-
 static int elmcan_ldisc_open(struct tty_struct *tty)
 {
        struct net_device *dev;
@@ -1131,12 +1109,17 @@ static int elmcan_ldisc_open(struct tty_struct *tty)
        if (!tty->ops->write)
                return -EOPNOTSUPP;
 
-
        dev = alloc_candev(sizeof(struct elmcan), 0);
        if (!dev)
                return -ENFILE;
        elm = netdev_priv(dev);
 
+       elm->txbuf = kmalloc(ELM327_SIZE_TXBUF, GFP_KERNEL);
+       if (!elm->txbuf) {
+               err = -ENOMEM;
+               goto out_err;
+       }
+
        /* Configure TTY interface */
        tty->receive_room = 65536; /* We don't flow control */
        elm->txleft = 0; /* Clear TTY TX buffer */
@@ -1151,7 +1134,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;
 
@@ -1163,14 +1146,17 @@ static int elmcan_ldisc_open(struct tty_struct *tty)
 
        /* Let 'er rip */
        err = register_candev(elm->dev);
-       if (err) {
-               free_candev(elm->dev);
-               return err;
-       }
+       if (err)
+               goto out_err;
 
        netdev_info(elm->dev, "elmcan on %s.\n", tty->name);
 
        return 0;
+
+out_err:
+       kfree(elm->txbuf);
+       free_candev(elm->dev);
+       return err;
 }
 
 /* Close down an elmcan channel.
@@ -1202,27 +1188,37 @@ static void elmcan_ldisc_close(struct tty_struct *tty)
 
        /* At this point, all ldisc calls to us have become no-ops. */
 
+       flush_work(&elm->tx_work);
+
        /* Mark channel as dead */
        spin_lock_bh(&elm->lock);
        tty->disc_data = NULL;
        elm->tty = NULL;
        spin_unlock_bh(&elm->lock);
 
-       flush_work(&elm->tx_work);
-
        netdev_info(elm->dev, "elmcan off %s.\n", tty->name);
 
+       kfree(elm->txbuf);
        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,
-                       unsigned int cmd, unsigned long arg)
+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);
        unsigned int tmp;
@@ -1247,14 +1243,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,
-       .magic          = TTY_LDISC_MAGIC,
        .name           = "elmcan",
+       .num            = N_ELMCAN,
        .receive_buf    = elmcan_ldisc_rx,
        .write_wakeup   = elmcan_ldisc_tx_wakeup,
        .open           = elmcan_ldisc_open,
@@ -1263,18 +1263,17 @@ static struct tty_ldisc_ops elmcan_ldisc = {
        .ioctl          = elmcan_ldisc_ioctl,
 };
 
-
-
 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");
+               pr_err("Can't register line discipline\n");
 
        return status;
 }
@@ -1284,12 +1283,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);