ESP32 Forum

Code: Select all

static void IRAM_ATTR i2s_isr(void* arg)
{
	I2S0.conf.rx_start = 0;
	I2S0.int_clr.val = I2S0.int_raw.val;       
	/******************switch buffer to let camera data fill***************************/              
    	s_cur_buffer = !s_cur_buffer;
  	if (s_isr_count == 239) 
	{
		i2s_stop();
    	}
	else 
    	{
    		++s_isr_count;
	}
	i2s_fill_buf(s_cur_buffer);
	BaseType_t xHigherPriorityTaskWoken;
	/******************notify udp_thread***************************/     
    	xSemaphoreGiveFromISR(s_data_ready, &xHigherPriorityTaskWoken);
    	if (xHigherPriorityTaskWoken != pdFALSE) 
	{      
        	portYIELD_FROM_ISR();
    	}
}

Code: Select all

void udp_thread(void *p)
{
		int prev_buf = -1;
		int sock;
		struct sockaddr_in toAddr;
		LWIP_UNUSED_ARG(p);
		sock = socket(AF_INET,SOCK_DGRAM,IPPROTO_UDP);
		if(sock < 0)
		{
			ESP_LOGI(TAG, "socket err");
		}
		memset(&toAddr,0,sizeof(toAddr));
		toAddr.sin_family=AF_INET;
		toAddr.sin_addr.s_addr=inet_addr("192.168.23.1");
		toAddr.sin_port = htons(REMOTE_PORT);
		while (true) 
		{
                        /******************waiting notification from udp_i2s_isr***************************/     
			xSemaphoreTake(s_data_ready, portMAX_DELAY);
                        FD_ZERO(&rdfds); 
			FD_SET(sock,&rdfds); 
			usertimeout.tv_sec=0;
			usertimeout.tv_usec=1000;
                        /******************buf_idx is the buffer which has just been filled fully ***************************/   
			int buf_idx = !s_cur_buffer;
			if (prev_buf != -1 && prev_buf == buf_idx) 
			{	  
				ets_printf("! %d\n", s_line_count);
			}
                        const uint32_t* buf = s_dma_buf[buf_idx];
			prev_buf = buf_idx;
                        /******************A frame has been collected fully from  camera***************************/  
			if (!s_i2s_running) 
			{
				prev_buf = -1;
				s_frame_count++;
                                /******************frame_end tells the receiver that this is the end of this frame***************************/   
				sendto(sock,frame_end,SEND_END_LEN ,0,(struct sockaddr*)&toAddr,sizeof(toAddr));
                                /******************new fram collect***************************/ 
				i2s_run(s_fb_w, s_fb_h);
                               /******************frame_start tells the receiver that this is the start of this frame***************************/   
				sendto(sock,frame_start,SEND_START_LEN ,0,(struct sockaddr*)&toAddr,sizeof(toAddr));
				continue;
			}
			ret=select(sock+1,NULL,&rdfds,NULL,&usertimeout);

			if(ret < 0) 
			{
				perror("select error\n");
			}
			else if(ret == 0)
			{
				printf("time out\n"); 
			}
			else
			{ 
		        	if(FD_ISSET(sock,&rdfds))   
				{
				/******************send the part of centent of frame.***************************/  
					sendto(sock,buf,960,0,(struct sockaddr*)&toAddr,sizeof(toAddr));
                                        ++s_line_count;
				}
        		
    		         }
	      }
				close(sock);
				vTaskDelete(NULL);
}