diff --git a/project/Core/Src/mug.c b/project/Core/Src/mug.c index b1eba9a..c85a17f 100644 --- a/project/Core/Src/mug.c +++ b/project/Core/Src/mug.c @@ -21,16 +21,14 @@ static void mqtt_connection_cb(mqtt_client_t*, void*, mqtt_connection_status_t); void example_do_connect(mqtt_client_t*); -static void mqtt_pub_request_cb(void *arg, err_t result) -{ +static void mqtt_pub_request_cb(void *arg, err_t result) { if(result != ERR_OK) { printf("Publish result: %d\n", result); } } int teller = 0; -void example_publish(mqtt_client_t *client, void *arg) -{ +void example_publish(mqtt_client_t *client, void *arg) { printf("testing publish\n"); const char *pub_payload[20]; err_t err; @@ -45,8 +43,7 @@ void example_publish(mqtt_client_t *client, void *arg) static int inpub_id; -static void mqtt_incoming_publish_cb(void *arg, const char *topic, u32_t tot_len) -{ +static void mqtt_incoming_publish_cb(void *arg, const char *topic, u32_t tot_len) { printf("Incoming publish at topic %s with total length %u\n", topic, (unsigned int)tot_len); //check for which topic a publish was received for @@ -64,8 +61,7 @@ static void mqtt_incoming_publish_cb(void *arg, const char *topic, u32_t tot_len } } -static void mqtt_incoming_data_cb(void *arg, const u8_t *data, u16_t len, u8_t flags) -{ +static void mqtt_incoming_data_cb(void *arg, const u8_t *data, u16_t len, u8_t flags) { printf("Incoming publish payload with length %d, flags %u\n", len, (unsigned int)flags); if(flags & MQTT_DATA_FLAG_LAST) { @@ -84,13 +80,11 @@ static void mqtt_incoming_data_cb(void *arg, const u8_t *data, u16_t len, u8_t f } } -static void mqtt_sub_request_cb(void *arg, err_t result) -{ +static void mqtt_sub_request_cb(void *arg, err_t result) { printf("Subscribe result: %d\n", result); } -static void mqtt_connection_cb(mqtt_client_t *client, void *arg, mqtt_connection_status_t status) -{ +static void mqtt_connection_cb(mqtt_client_t *client, void *arg, mqtt_connection_status_t status) { printf("entered connection cb function\n"); err_t err; if(status == MQTT_CONNECT_ACCEPTED) { @@ -114,8 +108,7 @@ static void mqtt_connection_cb(mqtt_client_t *client, void *arg, mqtt_connection } } -void example_do_connect(mqtt_client_t *client) -{ +void example_do_connect(mqtt_client_t *client) { printf("testing the connection\n"); struct mqtt_connect_client_info_t ci; err_t err; @@ -136,9 +129,9 @@ void example_do_connect(mqtt_client_t *client) } void mug_init() { - mqtt_client_t *client = mqtt_client_new(); - if(client != NULL) { - printf("Starting connection test\n"); - example_do_connect(client); - } + mqtt_client_t *client = mqtt_client_new(); + if(client != NULL) { + printf("Starting connection test\n"); + example_do_connect(client); + } }