RT-Thread-多socket并发下，W5500突然网络异常，无法收发RT-Thread问答社区

多socket并发下，W5500突然网络异常，无法收发

发布于 2024-10-17 10:57:11 浏览：601 订阅该版

[tocm]

W5500一共有8个socket，SIR指示那几个socket来了中断，Sn_IR指示具体socket产生了什么中断（发送，接收或者超时等）

![screenshot_image.png](https://oss-club.rt-thread.org/uploads/20241021/bf92a4bbdea4a79b5b4ff726eaa3f61c.png.webp)

![screenshot_image.png](https://oss-club.rt-thread.org/uploads/20241021/b2ed2287e1e444c57b28fcffc832b2be.png.webp)

## 问题描述：
分析官方的源码，可知，当多个线程同时存在多个socket下或者一个线程存在多个socket下，接收到一个wiz_rx_mb下sir = getSIR()只会获取一次，getSIR的值在下面的for循环下可能已经被其他socket修改了，但是此时的INIT引脚还是低电平（空闲下应该是高电平），低电平的情况下无法响应中断，也就是会漏掉了部分的mailbox，导致SIR和Sn_IR的寄存器没有完全清0，INIT引脚一直为低，如果你网络异常情况下，INIT引脚一直为低，那么大概率也是这个原因；

## 解决办法：
多增加一个while和run_times，直至查询该getSIR寄存器为0 或者运行次数大于20次（这个次数自定义），这样可以不断更新sir的值，防止多线程下多socket并发导致的问题

官方源码：
```c
static void wiz_data_thread_entry(void *parameter)
{
#define IR_SOCK(ch)         (0x01 << ch)   /**< check socket interrupt */

struct rt_spi_device* dev;

while (1)
    {
        if (rt_mb_recv(wiz_rx_mb, (rt_ubase_t*) &dev, RT_WAITING_FOREVER) == RT_EOK)
        {
            uint8_t ir, sir, sn_ir;
            int8_t socket = -1;

/* get IR data than clean IR */
            ir = getIR();
            setIR(ir);

if ((ir & IR_CONFLICT) == IR_CONFLICT)
            {
                setIR(IR_CONFLICT);
            }

if ((ir & IR_UNREACH) == IR_UNREACH)
            {
                setIR(IR_UNREACH);
            }

/* get and process socket interrupt register */
            sir = getSIR();

for (socket = 0; socket < 8; socket++)
            {
                sn_ir = 0;

if (sir & IR_SOCK(socket))
                {
                    /* save interrupt value*/
                    sn_ir = getSn_IR(socket);

if (sn_ir & Sn_IR_CON)
                    {
                        setSn_IR(socket, Sn_IR_CON);
                    }
                    if (sn_ir & Sn_IR_DISCON)
                    {
                        wiz_closed_notice_cb(socket);
                        setSn_IR(socket, Sn_IR_DISCON);
                    }
                    if (sn_ir & Sn_IR_RECV)
                    {
                        wiz_recv_notice_cb(socket);
                        setSn_IR(socket, Sn_IR_RECV);
                    }
                    if (sn_ir & Sn_IR_TIMEOUT)
                    {
                        /* deal with timeout event in the wiznet ioLibrary */
                        //setSn_IR(socket, Sn_IR_TIMEOUT);
                    }
                }
            }
        }
    }
}
```

### 修改后的源码
```c
static void wiz_data_thread_entry(void *parameter)
{
#define IR_SOCK(ch)         (0x01 << ch)   /**< check socket interrupt */

struct rt_spi_device* dev;
    uint8_t run_times = 0;
    while (1)
    {
        if (rt_mb_recv(wiz_rx_mb, (rt_ubase_t*) &dev, RT_WAITING_FOREVER) == RT_EOK)
        {
            uint8_t ir, sir, sn_ir;
            int8_t socket = -1;

run_times = 0;
            /* get IR data than clean IR */
            ir = getIR();
            setIR(ir);

if ((ir & IR_CONFLICT) == IR_CONFLICT)
            {
                setIR(IR_CONFLICT);
            }

if ((ir & IR_UNREACH) == IR_UNREACH)
            {
                setIR(IR_UNREACH);
            }
            
           /* get and process socket interrupt register */

while ((sir=getSIR()) && run_times < 20)
            {
                run_times++;

for (socket = 0; socket < 8; socket++)
                {
                    sn_ir = 0;

if (sir & IR_SOCK(socket))
                    {
                        /* save interrupt value*/
                        sn_ir = getSn_IR(socket);

if (sn_ir & Sn_IR_CON)
                        {
                            setSn_IR(socket, Sn_IR_CON);
                        }
                        if (sn_ir & Sn_IR_DISCON)
                        {
                            wiz_closed_notice_cb(socket);
                            setSn_IR(socket, Sn_IR_DISCON);
                        }
                        if (sn_ir & Sn_IR_RECV)
                        {
                            wiz_recv_notice_cb(socket);
                            setSn_IR(socket, Sn_IR_RECV);
                        }
                        if (sn_ir & Sn_IR_TIMEOUT)
                        {
                            /* deal with timeout event in the wiznet ioLibrary */
                            //setSn_IR(socket, Sn_IR_TIMEOUT);
                        }
                    }
                }
            }
        }
    }
}
```