paho_mqtt.h

Go to the documentation of this file.

/*
 * SPDX-FileCopyrightText: 2019 Javier FILEIV <javier.fileiv@gmail.com>
 * SPDX-License-Identifier: LGPL-2.1-only
 */
 
#pragma once

 
#include "mutex.h"
#include "thread.h"
#include "net/sock/tcp.h"
 
#ifdef __cplusplus
extern "C" {
#endif

#ifndef MQTT_THREAD_PRIORITY
#define MQTT_THREAD_PRIORITY            (THREAD_PRIORITY_MAIN - 1)
#endif

 
#ifndef MQTT_THREAD_STACKSIZE
#define MQTT_THREAD_STACKSIZE           (THREAD_STACKSIZE_LARGE)
#endif
#ifndef MQTT_YIELD_POLLING_MS
#define MQTT_YIELD_POLLING_MS           (30)
#endif

typedef struct {
    uint32_t timeout;                   
    uint32_t time_set;                  
} Timer;

void TimerInit(Timer *timer);

char TimerIsExpired(Timer *timer);

void TimerCountdownMS(Timer *timer, unsigned int msecs);

void TimerCountdown(Timer *timer, unsigned int secs);

int TimerLeftMS(Timer *timer);

typedef struct Network {
    sock_tcp_t sock;    
    int (*mqttread) (struct Network*, unsigned char*, int, int);
    int (*mqttwrite) (struct Network*, unsigned char*, int, int);
} Network;

void NetworkInit(Network *n);

int NetworkConnect(Network *n, char* address_ip, int port_number);

void NetworkDisconnect(Network *n);

typedef struct {
    mutex_t lock;   
} Mutex;

void MutexInit(Mutex *mutex);

int MutexLock(Mutex *mutex);

int MutexUnlock(Mutex *mutex);

typedef struct {
    char stack[MQTT_THREAD_STACKSIZE];      
    kernel_pid_t pid;                       
} Thread;

int ThreadStart(Thread *thread, void (*fn)(void *), void *arg);
 
#ifdef __cplusplus
}
#endif