RyanMqtt/platform/linux/platformSystem.h

#ifndef __platformSystem__
#define __platformSystem__

#ifdef __cplusplus
extern "C" {
#endif

#include <stdio.h>
#include <stdint.h>
#include <string.h>
#include <assert.h>
#include <pthread.h>
#include <unistd.h>
#include <stdlib.h>
#include <time.h>
#include "RyanMqttPublic.h"
#include "valloc.h"

#define platformAssert(EX) assert(EX)
#define RyanMqttMemset     memset
#define RyanMqttStrlen     strlen
#define RyanMqttMemcpy     memcpy
#define RyanMqttStrcmp     strcmp

typedef struct
{
	pthread_t thread;
	pthread_mutex_t mutex;
	pthread_cond_t cond;
} platformThread_t;

typedef struct
{
	pthread_mutex_t mutex;
} platformMutex_t;

typedef struct
{
	pthread_spinlock_t spin;
} platformCritical_t;

extern void *platformMemoryMalloc(size_t size);
extern void platformMemoryFree(void *ptr);

extern void platformPrint(char *str, uint16_t strLen);
extern void platformDelay(uint32_t ms);
extern uint32_t platformUptimeMs(void);

extern RyanMqttError_e platformThreadInit(void *userData, platformThread_t *platformThread, const char *name,
					  void (*entry)(void *), void *const param, uint32_t stackSize,
					  uint32_t priority);
extern RyanMqttError_e platformThreadDestroy(void *userData, platformThread_t *platformThread);
extern RyanMqttError_e platformThreadStart(void *userData, platformThread_t *platformThread);
extern RyanMqttError_e platformThreadStop(void *userData, platformThread_t *platformThread);

extern RyanMqttError_e platformMutexInit(void *userData, platformMutex_t *platformMutex);
extern RyanMqttError_e platformMutexDestroy(void *userData, platformMutex_t *platformMutex);
extern RyanMqttError_e platformMutexLock(void *userData, platformMutex_t *platformMutex);
extern RyanMqttError_e platformMutexUnLock(void *userData, platformMutex_t *platformMutex);

extern RyanMqttError_e platformCriticalInit(void *userData, platformCritical_t *platformCritical);
extern RyanMqttError_e platformCriticalDestroy(void *userData, platformCritical_t *platformCritical);
extern RyanMqttError_e platformCriticalEnter(void *userData, platformCritical_t *platformCritical);
extern RyanMqttError_e platformCriticalExit(void *userData, platformCritical_t *platformCritical);

#ifdef __cplusplus
}
#endif

#endif