标签：serv addr ESP max esp32 tcpserver c++ TAG sockfd

static void app_tcp_server_multi_conn_task(void *arg)
{
    struct sockaddr_in serv_addr;
    fd_set all_set, read_set; /*!< 定义文件句柄集合 */
    int sockfd_max = 0;       /*!< 文件句柄最大值 */

    int serv_sockfd = socket(AF_INET, SOCK_STREAM, 0);
    if (serv_sockfd < 0)
    {
        ESP_LOGE(TAG, "Unable to create socket: errno %d", errno);
        vTaskDelete(NULL);
    }
    ESP_LOGI(TAG, "Socket created, serv_sockfd=%d", serv_sockfd);

    bzero(&serv_addr, sizeof(struct sockaddr_in));
    serv_addr.sin_family = AF_INET;
    serv_addr.sin_addr.s_addr = htonl(INADDR_ANY);
    serv_addr.sin_port = htons(TCP_SERVER_PORT);

    if (bind(serv_sockfd, (struct sockaddr *)&serv_addr, sizeof(serv_addr)) < 0)
    {
        ESP_LOGE(TAG, "Socket unable to bind: errno %d", errno);
        vTaskDelete(NULL);
    }
    ESP_LOGI(TAG, "Socket binded");

    if (listen(serv_sockfd, TCP_SERVER_LISTEN_CLIENT_NUM) < 0)
    {
        ESP_LOGE(TAG, "Error occured during listen: errno %d", errno);
        vTaskDelete(NULL);
    }
    ESP_LOGI(TAG, "Socket listening");

    FD_ZERO(&all_set);             /*!< 清空集合 */
    FD_SET(serv_sockfd, &all_set); /*!< 添加serv_sockfd */
    sockfd_max = serv_sockfd;

    while (1)
    {
        read_set = all_set;
        if (select(sockfd_max + 1, &read_set, NULL, NULL, NULL) == -1) /*!< 监听句柄集的可读性 */
        {
            ESP_LOGE(TAG, "Sever select error");
        }
        for (int sockfd = 0; sockfd <= sockfd_max; sockfd++) /*!< 从零开始判断 */
        {
            if (!FD_ISSET(sockfd, &read_set)) /*!< sockfd在集合中状态是否变化 */
            {
                continue; /*!< 跳出当前循环 */
            }
            if (sockfd == serv_sockfd) /*!< 新的客户端连接 */
            {
                struct sockaddr_in cli_addr;
                socklen_t cli_addr_len;
                int cli_sockfd;
                cli_addr_len = sizeof(cli_addr);
                memset(&cli_addr, 0, cli_addr_len);
                cli_sockfd = accept(serv_sockfd, (struct sockaddr *)&cli_addr, &cli_addr_len);
                if (cli_sockfd < 0)
                {
                    ESP_LOGE(TAG, "Unable to accept connection: errno %d", errno);
                }
                else
                {
                    FD_SET(cli_sockfd, &all_set);
                    if (cli_sockfd > sockfd_max)
                    {
                        sockfd_max = cli_sockfd;
                    }
                    ESP_LOGI(TAG, "sockfd_max=%d", sockfd_max);
                    ESP_LOGI(TAG, "A new client[cli_sockfd=%d] is connected from %s", cli_sockfd, inet_ntoa(cli_addr.sin_addr));
                }
            }
            else /*!< 客户端的通信数据 */
            {
                char rx_buffer[128] = {0};
                int len = recv(sockfd, rx_buffer, sizeof(rx_buffer) - 1, 0);
                if (len < 0)
                {
                    ESP_LOGE(TAG, "Recv failed: errno %d", errno);
                    FD_CLR(sockfd, &all_set); /*!< 从集合中删除 */
                    close(sockfd);
                    ESP_LOGI(TAG, "sockfd_max=%d", sockfd_max);
                    break;
                }
                else if (len == 0)
                {
                    ESP_LOGI(TAG, "Connection closed");
                    FD_CLR(sockfd, &all_set); /*!< 从集合中删除 */
                    close(sockfd);
                    ESP_LOGI(TAG, "sockfd_max=%d", sockfd_max);
                    break;
                }
                else
                {
                    ESP_LOGI(TAG, "Received %d bytes from socket_fd[%d]:", len, sockfd);
                    ESP_LOGI(TAG, "%s", rx_buffer);

                    flow_control_msg_t msg = {
                        .packet = rx_buffer,
                        .length = len};
                    if (xQueueSend(flow_control_queue, &msg, pdMS_TO_TICKS(FLOW_CONTROL_QUEUE_TIMEOUT_MS)) != pdTRUE)
                    {
                        ESP_LOGE(TAG, "send flow control message failed or timeout");
                       //free rx_buffer?
                    }
                }
            }
        }
    }

    vTaskDelete(NULL);
}

标签：serv,addr,ESP,max,esp32,tcpserver,c++,TAG,sockfd
来源： https://www.cnblogs.com/hshy/p/16672998.html

本站声明： 1. iCode9 技术分享网（下文简称本站）提供的所有内容，仅供技术学习、探讨和分享；
2. 关于本站的所有留言、评论、转载及引用，纯属内容发起人的个人观点，与本站观点和立场无关；
3. 关于本站的所有言论和文字，纯属内容发起人的个人观点，与本站观点和立场无关；
4. 本站文章均是网友提供，不完全保证技术分享内容的完整性、准确性、时效性、风险性和版权归属；如您发现该文章侵犯了您的权益，可联系我们第一时间进行删除；
5. 本站为非盈利性的个人网站，所有内容不会用来进行牟利，也不会利用任何形式的广告来间接获益，纯粹是为了广大技术爱好者提供技术内容和技术思想的分享性交流网站。