RTCS组件连接机应答的问题

huan-413183

MQX版本：MQX4.2
采用RTCS组件进行以太网通信，器件调试通过抓包工具发现，TCP的连接应答部分及TCP应答标志如下图

测试发现，作为TCP服务器是连接应答偶尔出现两次SYN+ACK包；
同时所以的应答标志均为PSH+ACK，
请问这正常吗，需要怎么设置。

我知道答案 目前已有4人回答

阅读全文

huan-413183

楼上微笑是表示没有问题吗？

小恩GG

这个问题已转给MQX工程师，希望楼主能将问题描述的更加详细一点，比如代码是否来自，基于板子或者芯片等等。

huan-413183

芯片K60  MQX版本4.2

1. void rtcs_init(void)
   
2. {
   
3.     uint32_t         error;
   
4.     _enet_address enet_addr = ENET_MAC;
   
5.    
   
6.     //初始化RTCS的一些全局变量，按需求设置减少内存使用
   
7.     _RTCSPCB_init = 4; //表示数据包控制块 ， 指的是你希望RTCS协议栈能够处理的包的数量
   
8.     _RTCSPCB_grow = 2;
   
9.     _RTCSPCB_max = 20;
   
10.     _RTCS_msgpool_init = 2; //表示RTCS消息池, 它用来封装对RTCS协议栈的应用请求，该值指的是应用程式同时能发多少个请求给RTCS协议栈
    
11.     _RTCS_msgpool_grow = 1;
    
12.     _RTCS_msgpool_max  = 4;
    
13.     _RTCS_socket_part_init = 2; //应用中创建的所有的socket的数量
    
14.     _RTCS_socket_part_grow = 1;
    
15.     _RTCS_socket_part_max  = 8;
    
16.         
    
17.     error = RTCS_create();  //RTCS创建
    
18.     if (error == RTCS_OK)  {  printf("\nRTCS创建成功\n");  }
    
19.     else{ printf("\nRTCS创建失败\n");}
    
20.    
    
21.     error = ipcfg_init_device(BSP_DEFAULT_ENET_DEVICE, enet_addr); //网络设备初始化
    
22.     if (error == IPCFG_OK)  {  printf("\n网络设备初始化成功\n");  }
    
23.     else{ printf("\n网络设备初始化失败\n");}
    
24. //    _lwsem_create (&lock, 1);
    
25. }
    
26. 
    
27. /*函数---------------------------------------------------------------
    
28. *   
    
29. * 函数名称: enet_set
    
30. * 功能概要：以太网参数设置
    
31. * 参数说明：
    
32. * 函数返回：无
    
33. * 备注：              
    
34. *END*--------------------------------------------------------------*/
    
35. void enet_set(void)
    
36. {
    
37.     uint32_t temp;
    
38.     uint32_t server_sock; //用于服务器待连接刘套接字
    
39.     IPCFG_IP_ADDRESS_DATA        ip_data;
    
40.     sockaddr  local_sockin; //本端套接字参数
    
41.    
    
42.     //变更参数
    
43.     ip_data.ip = local_ipaddr;
    
44.         ip_data.mask = local_ipmask;
    
45.         ip_data.gateway = local_ipgateway;
    
46.    
    
47.     //静态IP绑定
    
48.     temp =ipcfg_bind_staticip (BSP_DEFAULT_ENET_DEVICE, &ip_data);
    
49.     if (temp == IPCFG_OK)  {  printf("\n静态IP绑定成功\n");  }
    
50.     else{ printf("\n静态IP绑定失败\n");}
    
51.    
    
52.     //创建套接字 参数：协议  流套接字（有链接，以字节为单位传输）/保温套接字（无连接，以数据块为单位传输）
    
53.     server_sock = socket(AF_INET, SOCK_STREAM, 0);
    
54.     if (server_sock == RTCS_SOCKET_ERROR) { printf("\n套接字创建错误 \n");  }
    
55.     else { printf("\nTCP套接字创建成功 \n");  }
    
56.    
    
57.     //设置发送接收缓冲大小,设置超时时间
    
58.     temp = SOCKET_SEND_BUFFER_SIZE;
    
59.     (void) setsockopt(server_sock, SOL_TCP, OPT_TBSIZE, &temp, sizeof(temp));
    
60.     temp = SOCKET_RECEIVE_BUFFER_SIZE;
    
61.     (void) setsockopt(server_sock, SOL_TCP, OPT_RBSIZE, &temp, sizeof(temp));
    
62.     temp = RTCSCFG_TELNETSRV_TIMEWAIT_TIMEOUT;
    
63.         setsockopt(server_sock, SOL_TCP, OPT_TIMEWAIT_TIMEOUT, &temp, sizeof(temp));
    
64.    
    
65.     //调用bind()函数将套接字与本地地址绑定（服务器绑定）
    
66.     local_sockin.sin_family = AF_INET;
    
67.     local_sockin.sin_port = local_port;
    
68.     local_sockin.sin_addr.s_addr = INADDR_ANY;
    
69.     temp = bind(server_sock, &local_sockin, sizeof(local_sockin));
    
70.     if (temp != RTCS_OK)  {  printf("\n绑定套接字失败\n");  }
    
71.     else
    
72.     {
    
73.         printf("\n绑定套接字成功\n");
    
74.         //套接字设置监听
    
75.         temp = listen(server_sock, 0);
    
76.         if (temp != RTCS_OK)  {  printf("Error 0x%X: Unable to put IPv4 socket in listening state.\n", temp);  }
    
77.     }
    
78.     printf("监听参数：  IPv4 Address: %d.%d.%d.%d, port:%d\n", IPBYTES(local_ipaddr), local_port);
    
79.     printf("\nWaiting for incoming connection...");
    
80.    
    
81.     dmu_tid.server_socket_tid = _task_create(0, SERVER_SOCKET_TASK, server_sock);
    
82. //    enet_rx_num=0;
    
83. }
    
84. 
    
85. /*任务---------------------------------------------------------------
    
86. *   
    
87. * 任务名称: server_socket_task
    
88. * 功能概要：等待服务器流连接套接字的建立，建立后创建接收任务enet_rx_task()
    
89. * 备注：
    
90. *END*--------------------------------------------------------------*/
    
91. void server_socket_task(uint32_t parameter)
    
92. {
    
93.     uint32_t option;
    
94.     while (1)
    
95.     {
    
96. //        if(enet_rx_num>2)
    
97. //        {
    
98. //            shutdown(iodhsocks[0], FLAG_CLOSE_TX); //断开套接字
    
99. //            _task_destroy(dmu_tid.enet_rx_tid[0]);
    
100. //            shutdown(iodhsocks[1], FLAG_CLOSE_TX); //断开套接字
     
101. //            _task_destroy(dmu_tid.enet_rx_tid[1]);
     
102. //            enet_rx_num=0;
     
103. //        }
     
104.         //等待新的套接字流来从远程端点接收传入的连接
     
105.         iodh_sock= accept(parameter, NULL, NULL);
     
106. //        iodhsocks[enet_rx_num]=iodh_sock;
     
107.         if (iodh_sock == RTCS_SOCKET_ERROR)
     
108.         {
     
109.             uint32_t status;
     
110.             status = RTCS_geterror(iodh_sock);
     
111.             printf("Fatal Error: Unable to accept incoming connection. ");
     
112.             if (status == RTCS_OK){printf("Connection reset by peer.");}
     
113.             else {  printf("Accept() failed with error code 0x%X.\n", status); }
     
114.         }
     
115. //        //设置接收不等待（非阻塞I/O），  TCP的PUSH 接收压栈（延迟传输）
     
116. //        option = TRUE;
     
117. //        retval = setsockopt(client_sock, SOL_TCP, OPT_RECEIVE_NOWAIT, &option, sizeof(option)); //FALSE（默认值）
     
118. //        retval = setsockopt(client_sock, SOL_TCP, OPT_RECEIVE_PUSH, &option, sizeof(option));   //TRUE（默认值）
     
119. //        if (retval != RTCS_OK){  printf("Fatal Error: Unable to set socket options."); }
     
120.         option = TRUE;
     
121.         setsockopt(client_sock, SOL_TCP, OPT_SEND_NOWAIT, &option, sizeof(option));   //TRUE（默认值）
     
122.         option = FALSE;
     
123.         setsockopt(client_sock, SOL_TCP, OPT_SEND_PUSH, &option, sizeof(option));   //TRUE（默认值）
     
124.         printf("\naccept starting 0x%lx\n",iodh_sock);
     
125. 
     
126. //        dmu_tid.enet_rx_tid[enet_rx_num] = _task_create(0, ENET_RX_TASK, iodh_sock);
     
127. //        if (dmu_tid.enet_rx_tid[enet_rx_num] == MQX_NULL_TASK_ID)
     
128. //        {
     
129. //            fprintf(stderr, "Fatal Error 0x%X: Unable to create receive task.", _task_get_error());
     
130. //        }
     
131. //        enet_rx_num++;
     
132.         dmu_tid.enet_rx_tid = _task_create(0, ENET_RX_TASK, iodh_sock);
     
133.         if (dmu_tid.enet_rx_tid == MQX_NULL_TASK_ID)
     
134.         {
     
135.             fprintf(stderr, "Fatal Error 0x%X: Unable to create receive task.", _task_get_error());
     
136.         }
     
137.         
     
138.         _time_delay(1);
     
139.     }
     
140. }
     
141. 
     
142. /*任务---------------------------------------------------------------
     
143. *   
     
144. * 任务名称: enet_rx_task
     
145. * 功能概要：服务器流套接字产生，接收以太网数据；
     
146. *          当接收数据错误时，断开套接字，销毁任务释放内存
     
147. * 参数说明：parameter：任务参数的结构体指针，主要：连接的套接字句柄
     
148. *
     
149. *END*--------------------------------------------------------------*/
     
150. void enet_rx_task(uint32_t parameter)
     
151. {
     
152.     uint8_t RecvBuf[1050];
     
153.     uint32_t count = 0;
     
154.    
     
155.     while(1)
     
156.     {
     
157.         count = recv(parameter, (void *)RecvBuf, sizeof(RecvBuf), 0);
     
158.         if (count == RTCS_ERROR)
     
159.         {
     
160.             printf("\nError, recv() failed with error code %lx", RTCS_geterror(parameter)); //1636：连接对端重置  1638：连接断开
     
161.             shutdown(parameter, FLAG_CLOSE_TX); //连接错误，断开套接字
     
162.             _task_destroy(_task_get_id());
     
163. //            enet_rx_num--;
     
164.         }
     
165.         else
     
166.         {
     
167.             i3r_package(RecvBuf,count);
     
168. //            printf("%s\n%d\n",RecvBuf,count);
     
169.         }        
     
170.         _time_delay(1);
     
171.     }
     
172. }
     

复制代码

星星-418393

PSH为1的情况，一般只出现在 DATA内容不为0的包中，也就是说PSH为1表示的是有真正的TCP数据包内容被传递