add: random status sending to broker
This commit is contained in:
		
							parent
							
								
									ce674a746a
								
							
						
					
					
						commit
						db7eb6305c
					
				
					 2 changed files with 6 additions and 2 deletions
				
			
		| 
						 | 
					@ -1,6 +1,6 @@
 | 
				
			||||||
cmake_minimum_required (VERSION 3.7)
 | 
					cmake_minimum_required (VERSION 3.7)
 | 
				
			||||||
project(controller
 | 
					project(controller
 | 
				
			||||||
        VERSION 0.3.3
 | 
					        VERSION 0.3.4
 | 
				
			||||||
        LANGUAGES C)
 | 
					        LANGUAGES C)
 | 
				
			||||||
 | 
					
 | 
				
			||||||
add_executable(controller src/main.c)
 | 
					add_executable(controller src/main.c)
 | 
				
			||||||
| 
						 | 
					
 | 
				
			||||||
| 
						 | 
					@ -60,9 +60,13 @@ handler_loop(struct mg_connection *c_mqtt)
 | 
				
			||||||
            sprintf(topic_buf, "controller/%s/relay/%u", controller_uid, i);
 | 
					            sprintf(topic_buf, "controller/%s/relay/%u", controller_uid, i);
 | 
				
			||||||
            sprintf(payload_buf, "%u", is_on);
 | 
					            sprintf(payload_buf, "%u", is_on);
 | 
				
			||||||
            mg_mqtt_publish(c_mqtt, topic_buf, 0, MG_MQTT_QOS(0), payload_buf, strlen(payload_buf));
 | 
					            mg_mqtt_publish(c_mqtt, topic_buf, 0, MG_MQTT_QOS(0), payload_buf, strlen(payload_buf));
 | 
				
			||||||
            relay->sent_to_broker = 1;
 | 
					            relay->sent_to_broker = (rand() % 45) + 15;
 | 
				
			||||||
            LOGGER_DEBUG("sent relay %d status (%d) to mqtt broker\n", i, is_on);
 | 
					            LOGGER_DEBUG("sent relay %d status (%d) to mqtt broker\n", i, is_on);
 | 
				
			||||||
        }
 | 
					        }
 | 
				
			||||||
 | 
					        if(relay->sent_to_broker)
 | 
				
			||||||
 | 
					        {
 | 
				
			||||||
 | 
					            --relay->sent_to_broker;
 | 
				
			||||||
 | 
					        }
 | 
				
			||||||
        relay->is_on = is_on;
 | 
					        relay->is_on = is_on;
 | 
				
			||||||
        relay->is_on_schedule = is_on_schedule;
 | 
					        relay->is_on_schedule = is_on_schedule;
 | 
				
			||||||
 | 
					
 | 
				
			||||||
| 
						 | 
					
 | 
				
			||||||
		Loading…
	
	Add table
		Add a link
		
	
		Reference in a new issue