rt_completion_wait函数clash问题

发布于 2024-06-17 17:54:08 浏览：347 订阅该版

求助大佬，我的程序小概率会clash，定位发现是在rt_completion_wait函数中，没想明白这个函数为什么会clash，附件中附上clash信息。

![screenshot_image.png](https://oss-club.rt-thread.org/uploads/20240617/6fbb168430d7081f98162c95932205d1.png)

我的程序很简单，我在一个中断回调函数中发送完成量，然后在一个线程中等待完成量。下面是我的代码：

```c
/* gpio中断回调函数 */
void handshake_call(void *args)
{
    rt_kprintf("esp32 handshake call!\n");
    rt_completion_done(&completion);
}

static void spi2_master_thread_entry(void *parameter)
{
    CODE_PROTEC(chip_id_str, PASSWORD_STR, true);
    while (1)
    {
        switch (e_spi_read)
        {
            case SPI_READ_WAIT: {
                LOG_D("wait spi handshake");
                rt_completion_wait(&completion, RT_WAITING_FOREVER);
                e_spi_read = SPI_READ_FLAG;
            } break;
            case SPI_READ_FLAG: {
                memset(spi_recv_buff, 0, SPI_RECV_SIZE);
                rt_size_t ret = rt_spi_recv(spi2_dev, spi_recv_buff, sizeof(struct data_info));
                memcpy(&g_data_info, spi_recv_buff, ret);
                LOG_D("spi recv data info, ret = %d data len = %d", ret, g_data_info.data_len);
                e_spi_read = SPI_READ_DATA;
            } break;
            case SPI_READ_DATA: {
                memset(spi_recv_buff, 0, SPI_RECV_SIZE);
                rt_size_t ret = rt_spi_recv(spi2_dev, spi_recv_buff, g_data_info.data_len);
                LOG_D("spi recv data, ret = %d", ret);
                if((memcmp(spi_recv_buff, end_sign, 8) == 0) && (ret <= 10)) {
                    LOG_D("The receiving file is completed! last len = %d", ret);
                    // 如果是文件结束标志
                    fpga_data_src = WRITE_FPGA_SPI;
                    write_fpga_data_process();
                } else {
                    // 把接收到的数据放到缓冲区中
                    rt_ringbuffer_put(write_fpga_rb, spi_recv_buff, ret);
                }
                e_spi_read = SPI_READ_WAIT;
            } break;
            default: break;
        }
        rt_thread_mdelay(1);
    }
}

void spi2_master_init(void)
{
    struct rt_spi_device *spi_device = RT_NULL;

spi_device = (struct rt_spi_device *)rt_malloc(sizeof(struct rt_spi_device));
    if(RT_NULL == spi_device)
    {
        LOG_E("Failed to malloc the spi device.");
    }
    if (RT_EOK != rt_spi_bus_attach_device_cspin(spi_device, "spi20", "spi2", GET_PIN(B, 9), RT_NULL))
    {
        LOG_E("Failed to attach the spi device.");
    }

struct rt_spi_configuration cfg;
    cfg.data_width = 8;
    cfg.mode = RT_SPI_MASTER | RT_SPI_MODE_0 | RT_SPI_MSB;
    cfg.max_hz = 20 * 1000 *1000;

rt_spi_configure(spi_device, &cfg);

/* 查找 spi 设备获取设备句柄 */
    spi2_dev = (struct rt_spi_device *)rt_device_find("spi20");

// 向FPGA写数据的缓冲区
    spi_recv_buff = rt_malloc(SPI_RECV_SIZE);
    if (spi_recv_buff == RT_NULL)
    {
        rt_kprintf("No memory:spi_recv_buff\n");
        return;
    }

/* 创建线程 */
    rt_thread_t spi2_master_tid = rt_thread_create("spi2_master", spi2_master_thread_entry, RT_NULL, 1024, 3, 5);
    if (spi2_master_tid != RT_NULL)
        rt_thread_startup(spi2_master_tid);
    else
        LOG_E("spi2_master thread creation failed!");

/* 初始化完成量对象 */
    rt_completion_init(&completion);

/* 握手信号 */
    rt_pin_mode(PIN_HANDSHAKE, PIN_MODE_INPUT_PULLUP);
    rt_pin_attach_irq(PIN_HANDSHAKE, PIN_IRQ_MODE_RISING, handshake_call, RT_NULL);
    rt_pin_irq_enable(PIN_HANDSHAKE, PIN_IRQ_ENABLE);
}

```

- [clash_log.txt](https://club.rt-thread.org/file_download/bdbb6a5064fda3eb)