sani7/2023-Webservices_And_Applications
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

Fixed position of '{' in mug.c

Browse Source
This commit is contained in:
RobinVdB8
2023-11-13 13:14:00 +01:00
parent 9aabdac7aa
commit 15bd0f3969
1 changed files with 12 additions and 19 deletions
Download Patch File Download Diff File Expand all files Collapse all files

31
project/Core/Src/mug.c
View File

@@ -21,16 +21,14 @@ static void mqtt_connection_cb(mqtt_client_t*, void*, mqtt_connection_status_t);
void example_do_connect(mqtt_client_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) { if(result != ERR_OK) {
printf("Publish result: %d\n", result); printf("Publish result: %d\n", result);
} }
} }
int teller = 0; 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"); printf("testing publish\n");
const char *pub_payload[20]; const char *pub_payload[20];
err_t err; err_t err;
@@ -45,8 +43,7 @@ void example_publish(mqtt_client_t *client, void *arg)
static int inpub_id; 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); 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 //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); printf("Incoming publish payload with length %d, flags %u\n", len, (unsigned int)flags);
if(flags & MQTT_DATA_FLAG_LAST) { 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); 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"); printf("entered connection cb function\n");
err_t err; err_t err;
if(status == MQTT_CONNECT_ACCEPTED) { 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"); printf("testing the connection\n");
struct mqtt_connect_client_info_t ci; struct mqtt_connect_client_info_t ci;
err_t err; err_t err;
@@ -136,9 +129,9 @@ void example_do_connect(mqtt_client_t *client)
} }
void mug_init() { void mug_init() {
mqtt_client_t *client = mqtt_client_new(); mqtt_client_t *client = mqtt_client_new();
if(client != NULL) { if(client != NULL) {
printf("Starting connection test\n"); printf("Starting connection test\n");
example_do_connect(client); example_do_connect(client);
} }
} }