ESP32 Forum

Code: Select all

void wifi_send_data_kt(char *wifi_data_send)
{
	
	const struct addrinfo hints = {
		.ai_family = AF_INET,
		.ai_socktype = SOCK_STREAM,
	};
	struct addrinfo *res;
	struct in_addr *addr;
	
	int s;
	
	
	fd_set readfds;
	struct timeval tv;
	
	int rv, n;	
	
	char recv_buf[550];
	memset(response_buffer,'\0',strlen(response_buffer));
	
	xEventGroupWaitBits(wifi_event_group, CONNECTED_BIT,false, true, 6000 / portTICK_PERIOD_MS);
	
	#if (defined WIFI_DEBUG_PRINT) && (defined WIFI_LINK_STATUS)
	ESP_LOGI(Display, "Connected to AP");
	#endif

	int err = getaddrinfo(WEB_SERVER,WEB_PORT, &hints, &res);

	if(err == 0 || res != NULL)
	{
		addr = &((struct sockaddr_in *)res->ai_addr)->sin_addr;
		
		#if (defined WIFI_DEBUG_PRINT) && (defined WIFI_SERVER_LINK_STATUS)
		ESP_LOGI(Display, "DNS lookup succeeded. IP=%s", inet_ntoa(*addr));
		#endif

		s = socket(res->ai_family, res->ai_socktype, 0);
		
		#if (defined WIFI_DEBUG_PRINT) && (defined WIFI_SERVER_LINK_STATUS)
		ESP_LOGI(Display,"\nsocket_id = %d\n",s);
		#endif

		if(s >= 0) 
		{		

			FD_ZERO(&readfds);
			FD_SET(s, &readfds);
			n = s + 1;
			
			tv.tv_sec = 2;
			tv.tv_usec = 000000;
	
			#if (defined WIFI_DEBUG_PRINT) && (defined WIFI_SERVER_LINK_STATUS)
			ESP_LOGI(Display, "... allocated socket\r\n");
			#endif
			
			if(connect(s, res->ai_addr, res->ai_addrlen) == 0)
			{
				
				//flags = fcntl(s, F_GETFL, 0); 
				//fcntl(s, F_SETFL, flags | O_NONBLOCK);
				
				#if (defined WIFI_DEBUG_PRINT) && (defined WIFI_SERVER_LINK_STATUS)
				ESP_LOGI(Display, "... connected");
				#endif

				freeaddrinfo(res);

				if (write(s, wifi_data_send, strlen(wifi_data_send)) >= 0) 
				{
					#if (defined WIFI_DEBUG_PRINT) && (defined WIFI_SERVER_LINK_STATUS)
					ESP_LOGI(Display, "... socket send success");
					#endif
					
					do{
						rv = select(n, &readfds, NULL, NULL, &tv);
					
						if (rv > 0) 
						{
							if (FD_ISSET(s, &readfds)) 
							{
								bzero(recv_buf, sizeof(recv_buf));
						   
								read(s, recv_buf, sizeof(recv_buf)-1);
						  
								strcat(response_buffer,recv_buf);
							}
						}
					}while(rv>0);

					
					#if (defined WIFI_DEBUG_PRINT) && (defined WIFI_SERVER_RESPONSE)
					ESP_LOGI(Display,"\nresponse_buffer=%s\n",response_buffer);
					#endif
					
					//#if (defined WIFI_DEBUG_PRINT) && (defined WIFI_SERVER_LINK_STATUS)
					//ESP_LOGI(Display, "\n... done reading from socket. Last read return=%d errno=%d\r\n", r, errno );
					//#endif	
	
					//-------check that server has saved client data or not-------//
						if(strstr(response_buffer,"data saved"))
						{
							server_saved_data_flag = True;
							
						//	#ifdef TEST_CASES_INDICATION
							indicate_server_communication_done_kt();
						//	#endif
							
						
						}
						else
						{
							server_saved_data_flag = False;
							
							#ifdef TEST_CASES_INDICATION
							indicate_server_communication_issue_kt();
							#endif
						}
					//------------------------------------------------------------//
					
					if(strstr(response_buffer,"deactivated"))
					{
						#if (defined WIFI_DEBUG_PRINT) && (defined WIFI_SERVER_RESPONSE)
						ESP_LOGE(Display,"\nsystem is deactivated\n");
						#endif
						
						paired_tags_status = DEACTIVATED;
						
						system_software_reset_kt();
					}
					else
						paired_tags_status = ACTIVATED;
				}
				else
				{
					#ifdef TEST_CASES_INDICATION
					indicate_server_communication_issue_to_write_kt();
					#endif
					
					server_saved_data_flag = False;			//	server has been not saved client data 
				}
			}
			else
			{
				#ifdef TEST_CASES_INDICATION
				indicate_server_connection_issue_kt();
				#endif
				
				server_saved_data_flag = False;			//	server has been not saved client data

				
			}
		}
		else
			server_saved_data_flag = False;				//	server has been not saved client data
		
		close(s);
	}
	else
	{
		server_saved_data_flag = False;					//	server has been not saved client data
		
		freeaddrinfo(res);
		
		
	}
}

Code: Select all

do{
rv = select(n, &readfds, NULL, NULL, &tv);

if (rv > 0)
{
if (FD_ISSET(s, &readfds))
{
bzero(recv_buf, sizeof(recv_buf));

read(s, recv_buf, sizeof(recv_buf)-1);

strcat(response_buffer,recv_buf);
}
}
}while(rv>0);