Agile_modbus 内存泄漏问题

发布于 2023-12-11 17:00:57 浏览：483 订阅该版

P/S: 问题已解决，这不是agile_modbus包中的错误，而是因为我启用了RT_DEVICE_FLAG_DMA_TX标志，看起来v1串行端口驱动程序不能与dma_tx很好地配合。 我将其关闭，设备工作正常

大家好，目前我正在使用agile_modbus包，出现了问题。 使用该库时设备的内存不断增加，导致设备内存不足时停止工作。

![screenshot_image.png](https://oss-club.rt-thread.org/uploads/20231211/108893d6c7c3c86137a7407f3d5a8bdc.png)

这是我与库的测试程序

```c
#include "usr_modbus_rtu_master.h"
#include <finsh.h>

static rt_sem_t modbus_sem;

#define MODBUS_FRAME_MAX 260

static rt_err_t modbus_rtu_rx_notify(rt_device_t device, rt_size_t size)
{
    return rt_sem_release(modbus_sem);
}

static rt_size_t modbus_rtu_read(rt_device_t device, rt_uint8_t *buf, rt_uint32_t timeout_ms)
{
    rt_size_t tmp, rlen = 0;
    rt_err_t rc = -RT_ETIMEOUT;
    rt_tick_t last_recv_tick = rt_tick_get_millisecond();

rc = rt_sem_take(modbus_sem, rt_tick_from_millisecond(timeout_ms));

if (rc == RT_EOK)
    {
        do
        {
            tmp = rt_device_read(device, 0, &buf[rlen], MODBUS_FRAME_MAX - rlen);
            if (tmp > 0)
            {
                rlen += tmp;
                last_recv_tick = rt_tick_get_millisecond();
            }
            if (rlen >= MODBUS_FRAME_MAX || rt_tick_get_millisecond() - last_recv_tick >= 1)
            {
                tmp = 0;
            }
            rt_thread_mdelay(1);
        } while (tmp > 0);
    }
    return rlen;
}

static rt_size_t modbus_rtu_write(rt_device_t device, rt_uint8_t *buff, rt_uint16_t len)
{
    return rt_device_write(device, 0, buff, len);
}

static void modbus_rtu_thread(void * parameter)
{
    static rt_device_t dev;

rt_uint8_t send_buf[MODBUS_FRAME_MAX];
    rt_uint8_t recv_buf[MODBUS_FRAME_MAX];
    uint16_t hold_register[10];

agile_modbus_rtu_t ctx_rtu;
    agile_modbus_t *ctx = &ctx_rtu._ctx;
    agile_modbus_rtu_init(&ctx_rtu, send_buf, sizeof(send_buf), recv_buf, sizeof(recv_buf));
    agile_modbus_set_slave(ctx, 1);

dev = rt_device_find("uart1");
    if (dev == RT_NULL)
    {
        rt_kprintf("can't find uart1\n");
        return;
    }

rt_device_set_rx_indicate(dev, modbus_rtu_rx_notify);

rt_device_open(dev, RT_DEVICE_FLAG_DMA_RX | RT_DEVICE_FLAG_DMA_TX);

for (;;)
    {
        /* throw away the dirty data in the uart buffer */
        rt_device_read(dev, 0, ctx->read_buf, MODBUS_FRAME_MAX);

int slen = agile_modbus_serialize_read_registers(ctx, 0, 10);

int send_len = modbus_rtu_write(dev, ctx->send_buf, slen);
        if (send_len < 0)
        {
            rt_kprintf("Send error\n");
            continue;
        }

int rlen = modbus_rtu_read(dev, ctx->read_buf, 200);
        if (rlen == 0)
        {
            rt_kprintf("Receive timeout.\n");
            continue;
        }

int rc = agile_modbus_deserialize_read_registers(ctx, rlen, hold_register);
        if (rc < 0)
        {
            rt_kprintf("Receive failed.\n");
            continue;
        }

//        for (int i = 0; i < 10; i++)
//        {
//            rt_kprintf("0x%X ", hold_register[i]);
//        }
//        rt_kprintf("\n");

rt_thread_mdelay(50);
    }
}

void user_modbus_init(void)
{
    rt_thread_t tid;
    tid = rt_thread_create("user_modbus", modbus_rtu_thread, RT_NULL, 2048, 15, 5);
    modbus_sem = rt_sem_create("modbus_sem", 0, RT_IPC_FLAG_FIFO);
    rt_thread_startup(tid);
}

MSH_CMD_EXPORT(user_modbus_init, init modbus thread);
```