paho_mqtt.h

Go to the documentation of this file.

/*
 * Copyright (C) 2019  Javier FILEIV <javier.fileiv@gmail.com>
 *
 * This file is subject to the terms and conditions of the GNU Lesser
 * General Public License v2.1. See the file LICENSE in the top level
 * directory for more details.
 *
 */
 
#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