双网口调试出现bug（单网口调试无问题）

发布于 2023-04-10 20:57:41 浏览：753 订阅该版

cpu：stm32F407VE
os：rt-thread
问题：现在已按照官方文档移植lan8720和ksz8851网络芯片成功，单独调试每一个网络芯片，通讯都正常；双网口同时通讯，大多数时候，在客户端连接时，导致板件死机，死机地方为ethernetif.c中的接收函数eth0_rx_thread_entry和eth1_rx_thread_entry（大多时候在此函数），报错地方为函数中的LWIP_ASSERT("Should not happen!\n",0)，已知为线程报超时导致，具体原因不清楚，社区大神能给出一些建议吗？
```c
int eth_system_device_init_private(void)
{
    rt_err_t result = RT_EOK;

/**********************************>>ksz8851<<**********************************/ 
    /* initialize Rx thread. */
#ifndef LWIP_NO_RX_THREAD    
    /* initialize mailbox and create Ethernet Rx thread */
    result = rt_mb_init(ð0_rx_thread_mb, "e0rxmb",
                        ð0_rx_thread_mb_pool[0], sizeof(eth0_rx_thread_mb_pool)/4,
                        RT_IPC_FLAG_FIFO);
    RT_ASSERT(result == RT_EOK);

result = rt_thread_init(ð0_rx_thread, "e0rx", eth0_rx_thread_entry, RT_NULL,
                            ð0_rx_thread_stack[0], sizeof(eth0_rx_thread_stack),
                            RT_ETHERNETIF_THREAD_PREORITY, 16);
    RT_ASSERT(result == RT_EOK);
    result = rt_thread_startup(ð0_rx_thread);
    RT_ASSERT(result == RT_EOK);
#endif

/* initialize Tx thread */
#ifndef LWIP_NO_TX_THREAD
    /* initialize mailbox and create Ethernet Tx thread */
    result = rt_mb_init(ð0_tx_thread_mb, "e0txmb",
                        ð0_tx_thread_mb_pool[0], sizeof(eth0_tx_thread_mb_pool)/4,
                        RT_IPC_FLAG_FIFO);
    RT_ASSERT(result == RT_EOK);

result = rt_thread_init(ð0_tx_thread, "e0tx", eth0_tx_thread_entry, RT_NULL,
                            ð0_tx_thread_stack[0], sizeof(eth0_tx_thread_stack),
                            RT_ETHERNETIF_THREAD_PREORITY, 16);
    RT_ASSERT(result == RT_EOK);

result = rt_thread_startup(ð0_tx_thread);
    RT_ASSERT(result == RT_EOK);
#endif
/**********************************>>ksz8851<<**********************************/ 
    
/**********************************>>lan8720<<**********************************/   
    /* initialize Rx thread. */
#ifndef LWIP_NO_RX_THREAD  
    /* initialize mailbox and create Ethernet Rx thread */
    result = rt_mb_init(ð1_rx_thread_mb, "e1rxmb",
                        ð1_rx_thread_mb_pool[0], sizeof(eth1_rx_thread_mb_pool)/4,
                        RT_IPC_FLAG_FIFO);
    RT_ASSERT(result == RT_EOK);

result = rt_thread_init(ð1_rx_thread, "e1rx", eth1_rx_thread_entry, RT_NULL,
                            ð1_rx_thread_stack[0], sizeof(eth1_rx_thread_stack),
                            RT_ETHERNETIF_THREAD_PREORITY, 16);
    RT_ASSERT(result == RT_EOK);
    result = rt_thread_startup(ð1_rx_thread);
    RT_ASSERT(result == RT_EOK);
#endif

/* initialize Tx thread */
#ifndef LWIP_NO_TX_THREAD
    /* initialize mailbox and create Ethernet Tx thread */
    result = rt_mb_init(ð1_tx_thread_mb, "e1txmb",
                        ð1_tx_thread_mb_pool[0], sizeof(eth1_tx_thread_mb_pool)/4,
                        RT_IPC_FLAG_FIFO);
    RT_ASSERT(result == RT_EOK);

result = rt_thread_init(ð1_tx_thread, "e1tx", eth1_tx_thread_entry, RT_NULL,
                            ð1_tx_thread_stack[0], sizeof(eth1_tx_thread_stack),
                            RT_ETHERNETIF_THREAD_PREORITY, 16);
    RT_ASSERT(result == RT_EOK);

result = rt_thread_startup(ð1_tx_thread);
    RT_ASSERT(result == RT_EOK);
#endif
/**********************************>>lan8720<<**********************************/

return (int)result;
}

/* Ethernet Rx Thread */
static void eth0_rx_thread_entry(void* parameter)
{
    struct eth_device* device;

while (1)
    {
        extern int g_udtaskflag;
        g_udtaskflag = 3; 
        if (rt_mb_recv(ð0_rx_thread_mb, (rt_ubase_t *)&device, RT_WAITING_FOREVER) == RT_EOK)
        {
            g_udtaskflag = 3*9; 
            struct pbuf *p;

/* check link status */
            if (device->link_changed)
            {
                int status;
                rt_uint32_t level;

level = rt_hw_interrupt_disable();
                status = device->link_status;
                device->link_changed = 0x00;
                rt_hw_interrupt_enable(level);

if (status)
                    netifapi_netif_set_link_up(device->netif);
                else
                    netifapi_netif_set_link_down(device->netif);
                g_udtaskflag = 3*10;
            }

/* receive all of buffer */
            while (1)
            {
                if(device->eth_rx == RT_NULL) break;
                
                p = device->eth_rx(&(device->parent));
                g_udtaskflag = 3*11;
                if (p != RT_NULL)
                {
					#if 1
					char *pbuf;
					pbuf = (char*)p->payload;
					uint16_t type = (pbuf[12]<<8)+(pbuf[13]<<0);
					switch (type)
						{
						case 0x0806:    //ARP
              device->netif = &Mnetif0;
							break;
						case 0x0800:   //IPV4
              device->netif = &Mnetif0;
							break;
						}
					#endif
                    /* notify to upper layer */
                    if( device->netif->input(p, device->netif) != ERR_OK )
                    {
                        LWIP_DEBUGF(NETIF_DEBUG, ("ethernetif_input: Input error\n"));
                        pbuf_free(p);
                        p = NULL;
                    }
                    g_udtaskflag = 3*12;
                }
                else break;
            }
        }
        else
        {
            g_udtaskflag = 3*13;
            LWIP_ASSERT("Should not happen!\n",0);
        }
    }
}
```