Function serial_uart_isr

modules/io/serial/zephyr/serial.c:120–176

}

static void serial_uart_isr(const struct device *dev, void *user_data)
{
	modSerial serial = (modSerial)user_data;
    uint8_t flags = 0;

	while (uart_irq_update(dev) && uart_irq_is_pending(dev)) {
        if (serial->onError) {
            int error = uart_err_check(dev);
            if (error) {
                serial->lastError = error;
                flags |= kSerialError;
            }
        }

		if (uart_irq_rx_ready(dev)) {
			uint8_t rx_data[MODDEF_SERIAL_RX_CHUNKSIZE];
			int bytes_read;

			while ((bytes_read = uart_fifo_read(dev, rx_data, sizeof(rx_data))) > 0) {
				uint32_t written = ring_buf_put(&serial->rxRingBuffer, rx_data, bytes_read);
				if (serial->onReadable && (written > 0))
					flags |= kSerialReadable;

				if (serial->onError && (written < bytes_read)) {
					serial->lastError = -ENOMEM;		// buffer overflow
					flags |= kSerialError;
				}
			}
		}

		uint32_t space = uart_irq_tx_ready(dev);
		if (space > 0) {
			uint8_t tx_data[MODDEF_SERIAL_TX_CHUNKSIZE];
			uint32_t len = ring_buf_get(&serial->txRingBuffer, tx_data, 
						(space < MODDEF_SERIAL_TX_CHUNKSIZE) ? space : MODDEF_SERIAL_TX_CHUNKSIZE);
			if (len > 0) {
				uart_fifo_fill(dev, tx_data, len);

				if (serial->onWritable && (ring_buf_space_get(&serial->txRingBuffer) > 0))    //@@ this could fire less often
					flags |= kSerialWritable;
			}
			else {
				uart_irq_tx_disable(dev);
				serial->txEnabled = false;
				if (serial->onWritable)
					flags |= kSerialWritable;
			}
		}
	}

	uint8_t currentFlags = serial->flags;
	serial->flags |= flags;
	if (flags && !currentFlags) {
		serial->useCount++;
		modMessagePostToMachineFromISR(serial->the, serialDeliver, serial);
	}
}