at socket驱动状态机缺失“CLOSE_WAIT”状态

发布于 2021-11-16 18:03:26 浏览：1200 订阅该版

3 个回答

crystal266 2022-03-09

嵌入式

你好，我试了一下打印的日志如下所示，在服务器主动断开连接后，URC回调函数会将当前的 sock_fd 的状态设置为 CLOSE，然后没有清除模组内部的 sock_fd。但是再一次执行 connect 函数时，发现模组内部的 sock_fd 处于未关闭状态，会执行模组的 sock_fd 关闭函数 ec200x_socket_close()，这样就不会存在模组内部的 sock_fd 未关闭的情况了。

![image.png](https://oss-club.rt-thread.org/uploads/20220309/7e2470451c33c3c0017696129269bc4f.png.webp)

连接的源码如下：
```
/**
 * create TCP/UDP client or server connect by AT commands.
 *
 * @param socket current socket
 * @param ip server or client IP address
 * @param port server or client port
 * @param type connect socket type(tcp, udp)
 * @param is_client connection is client
 *
 * @return   0: connect success
 *          -1: connect failed, send commands error or type error
 *          -2: wait socket event timeout
 *          -5: no memory
 */
static int ec200x_socket_connect(struct at_socket *socket, char *ip, int32_t port,
    enum at_socket_type type, rt_bool_t is_client)
{
    #define CONN_RETRY  2

int i = 0;
    const char *type_str = RT_NULL;
    uint32_t event = 0;
    at_response_t resp = RT_NULL;
    int result = 0, event_result = 0;
    int device_socket = (int) socket->user_data;
    struct at_device *device = (struct at_device *) socket->device;

RT_ASSERT(ip);
    RT_ASSERT(port >= 0);

if ( ! is_client)
    {
        return -RT_ERROR;
    }

switch(type)
    {
        case AT_SOCKET_TCP:
            type_str = "TCP";
            break;
        case AT_SOCKET_UDP:
            type_str = "UDP";
            break;
        default:
            LOG_E("%s device socket(%d)  connect type error.", device->name, device_socket);
            return -RT_ERROR;
    }

resp = at_create_resp(128, 0, rt_tick_from_millisecond(300));
    if (resp == RT_NULL)
    {
        LOG_E("no memory for resp create.");
        return -RT_ENOMEM;
    }

for(i=0; i<CONN_RETRY; i++)
    {
        /* clear socket connect event */
        event = SET_EVENT(device_socket, EC200X_EVENT_CONN_OK | EC200X_EVENT_CONN_FAIL);
        ec200x_socket_event_recv(device, event, 0, RT_EVENT_FLAG_OR);

if (at_obj_exec_cmd(device->client, resp, "AT+QIOPEN=1,%d,\"%s\",\"%s\",%d,0,1",
                            device_socket, type_str, ip, port) < 0)
        {
            result = -RT_ERROR;
            break;
        }

/* waiting result event from AT URC, the device default connection timeout is 60 seconds*/
        if (ec200x_socket_event_recv(device, SET_EVENT(device_socket, 0),
                                    60 * RT_TICK_PER_SECOND, RT_EVENT_FLAG_OR) < 0)
        {
            LOG_E("%s device socket(%d) wait connect result timeout.", device->name, device_socket);
            result = -RT_ETIMEOUT;
            break;
        }
        /* waiting OK or failed result */
        event_result = ec200x_socket_event_recv(device, EC200X_EVENT_CONN_OK | EC200X_EVENT_CONN_FAIL,
                                                1 * RT_TICK_PER_SECOND, RT_EVENT_FLAG_OR);
        if (event_result < 0)
        {
            LOG_E("%s device socket(%d) wait connect OK|FAIL timeout.", device->name, device_socket);
            result = -RT_ETIMEOUT;
            break;
        }
        /* check result */
        if (event_result & EC200X_EVENT_CONN_OK)
        {
            result = RT_EOK;
            break;
        }

LOG_D("%s device socket(%d) connect failed, the socket was not be closed and now will connect retry.",
                    device->name, device_socket);
        if (ec200x_socket_close(socket) < 0)
        {
            result = -RT_ERROR;
            break;
        }
    }

if (i == CONN_RETRY)
    {
        LOG_E("%s device socket(%d) connect failed.", device->name, device_socket);
        result = -RT_ERROR;
    }

if (resp)
    {
        at_delete_resp(resp);
    }

return result;
}
```