YunZhiNeng před 1 rokem
rodič
revize
e04866b35b
1 změnil soubory, kde provedl 14 přidání a 13 odebrání
  1. 14 13
      Drivers/Modules/bc260y/BC260Y_UDP_Client5.c

+ 14 - 13
Drivers/Modules/bc260y/BC260Y_UDP_Client5.c

@@ -401,19 +401,9 @@ void UDP_Client_Handle(void)
 				goto_failure("查询信号质量失败");
 			}
 			break;
-//		case STEP_CLOSE: // 关闭连接
-//			result = bc260y.close_socket(connectID);
-//			if(result == Result_Success)
-//			{
-//				goto_step(STEP_OPEN);
-//			}
-//			else if(result == Result_Failed)
-//			{
-//				goto_failure("关闭连接失败");
-//			}
-//			break;
+	
 		case STEP_QUERY_SOCKET:		 
-			 result =bc260y.query_socket_state_sync(connectID,&connectstate);
+			 result =bc260y.query_socket_state(connectID,&connectstate);
 		    if(result == Result_Success)
 			{
 				if(connectstate==2)
@@ -422,7 +412,7 @@ void UDP_Client_Handle(void)
 				}
 				else
 				{
-				 goto_step(STEP_OPEN);
+				 goto_step(STEP_CLOSE);
 				}
 			}
 			else if(result == Result_Failed)
@@ -430,6 +420,17 @@ void UDP_Client_Handle(void)
 				goto_failure("查询UDP连接失败");
 			}
 			break;
+		case STEP_CLOSE: // 关闭连接
+			result = bc260y.close_socket(connectID);
+			if(result == Result_Success)
+			{
+				goto_step(STEP_OPEN);
+			}
+			else if(result == Result_Failed)
+			{
+				goto_failure("关闭连接失败");
+			}
+			break;
 		case STEP_OPEN: // 打开客户端
 			result = bc260y.open_socket(connectID, "UDP",aliyuniot_get_host(), aliyuniot_get_port(), 1, &socket_err);
 			if(result == Result_Success)