ESP32 Forum

Code: Select all

void pinTaskIn(void *pArg)
{

		intdef param;
		param.count=0;
		param.timer=0;
		param.lowHigh=0;

		intdef param1;

		gpio_config_t io_conf;
		uint64_t mask=1;  

		io_conf.intr_type = GPIO_INTR_NEGEDGE;
		io_conf.pin_bit_mask = (mask<<whichPin);
		io_conf.mode = GPIO_MODE_INPUT;
		io_conf.pull_down_en =GPIO_PULLDOWN_DISABLE;
		io_conf.pull_up_en =GPIO_PULLUP_ENABLE;
		gpio_config(&io_conf);
		gpio_install_isr_service(0);
		gpio_set_intr_type(whichPin, GPIO_INTR_NEGEDGE);

		isrQ = xQueueCreate( 100, sizeof( param ) );

		gpio_isr_handler_add((gpio_num_t)whichPin, gpio_isr_handler,(void*)&param);
		printf("Ready Input\n");
		while(1)
		{
			if( xQueueReceive( isrQ, &param, portMAX_DELAY ))
					{
					printf("Count %d lowHigh %d timer %d\n",param.count,param.lowHigh, param.timer);
					}
			vTaskDelay(100/portTICK_PERIOD_MS);

		}
}

Code: Select all

void pinTaskStep(void *pArg)
{
		mystruct *defs=(mystruct*)pArg;
		gpio_config_t io_conf;
		uint64_t mask=1; 
		int sent=0;
		io_conf.intr_type = GPIO_INTR_DISABLE;
		io_conf.pin_bit_mask = (mask<<defs->elpin);
		io_conf.mode = GPIO_MODE_OUTPUT;
		io_conf.pull_down_en =GPIO_PULLDOWN_DISABLE;
		io_conf.pull_up_en =GPIO_PULLUP_DISABLE;
		gpio_config(&io_conf);


		printf("Ready Output\n");
		while(1)
		{
			if(sendit)
			{	sent++;
				printf("Sending[%d] %d\n",defs->elpin,sent);
				sendit=0;
				gpio_set_level((gpio_num_t)defs->elpin, 1);
				vTaskDelay(100/portTICK_PERIOD_MS);
				gpio_set_level((gpio_num_t)defs->elpin, 0);
			}
			vTaskDelay(100/portTICK_PERIOD_MS);

		}
}

Code: Select all

static void pollTask(void * arg)
{
//will ask state of each meter and see any change from pos to neg

	while(1)
	{
	for (int a=0;a<MAXDEVS;a++){ //MAXDEVS = 3
		//A simulated interrupt is a LOW now with a Previous HIGH (state)
	if(!gpio_get_level((gpio_num_t)who[a].elpin) && who[a].state)
	{ //Change from High to Low
		// how long ago. Has to be longer the MINBEAT (40ms)
		if((millis()-who[a].when)>MINBEAT)
		{
			who[a].when=millis();
			who[a].state=0;
			currentBeat[who[a].portid]++;
			beatSave[who[a].portid]++;
			who[a].fcount++;
			who[a].beatc++;

			if((currentBeat[who[a].portid] % GMAXLOSSPER)==0) //GMAXLOSSPER =80
			{ //every GMAXLOSSPER interval
				if(beatSave[who[a].portid]>=dia24h[horag]) //dia24h = 800
				{
					who[a].fullkwh=1;
					beatSave[who[a].portid]=0;
					who[a].beatc=0;
				}
				else
					who[a].fullkwh=0;
					xQueueSendFromISR( isrQ, (void*)&who[a],( TickType_t ) 0 );
			}
		}
	}
	else //Save the current state of the Pin
	{
		who[a].state=gpio_get_level((gpio_num_t)who[a].elpin);
		who[a].when=millis();
	}

	}
	delay(40); //as fast as possible and less than or equal MINBEAT
}
}