messagequeue.h

Go to the documentation of this file.

#pragma once
#include <wut.h>
#include "threadqueue.h"
 
#ifdef __cplusplus
extern "C" {
#endif
 
typedef struct OSMessage OSMessage;
typedef struct OSMessageQueue OSMessageQueue;
 
typedef enum OSMessageFlags
{
 OS_MESSAGE_FLAGS_NONE = 0,
 OS_MESSAGE_FLAGS_BLOCKING = 1 << 0,
 OS_MESSAGE_FLAGS_HIGH_PRIORITY = 1 << 1,
} OSMessageFlags;
 
typedef enum OSFunctionType
{
 OS_FUNCTION_TYPE_HIO_OPEN = 1,
 OS_FUNCTION_TYPE_HIO_READ_ASYNC = 2,
 OS_FUNCTION_TYPE_HIO_WRITE_ASYNC = 3,
 OS_FUNCTION_TYPE_FSA_CMD_ASYNC = 4,
 OS_FUNCTION_TYPE_FSA_PR_CMD_ASYNC = 5,
 OS_FUNCTION_TYPE_FSA_PR_CMD_ASYNC_NO_ALLOC = 6,
 OS_FUNCTION_TYPE_FSA_ATTACH_EVENT = 7,
 OS_FUNCTION_TYPE_FS_CMD_ASYNC = 8,
 OS_FUNCTION_TYPE_FS_CMD_HANDLER = 9,
 OS_FUNCTION_TYPE_FS_ATTACH_EVENT = 10,
 OS_FUNCTION_TYPE_FS_STATE_CHANGE_EVENT = 11,
} OSFunctionType;
 
struct OSMessage
{
 void *message;
 uint32_t args[3];
};
WUT_CHECK_OFFSET(OSMessage, 0x00, message);
WUT_CHECK_OFFSET(OSMessage, 0x04, args);
WUT_CHECK_SIZE(OSMessage, 0x10);
 
#define OS_MESSAGE_QUEUE_TAG 0x6D536751u
 
struct OSMessageQueue
{
 uint32_t tag;
 const char *name;
 WUT_UNKNOWN_BYTES(4);
 OSThreadQueue sendQueue;
 OSThreadQueue recvQueue;
 OSMessage *messages;
 uint32_t size;
 uint32_t first;
 uint32_t used;
};
WUT_CHECK_OFFSET(OSMessageQueue, 0x00, tag);
WUT_CHECK_OFFSET(OSMessageQueue, 0x04, name);
WUT_CHECK_OFFSET(OSMessageQueue, 0x0c, sendQueue);
WUT_CHECK_OFFSET(OSMessageQueue, 0x1c, recvQueue);
WUT_CHECK_OFFSET(OSMessageQueue, 0x2c, messages);
WUT_CHECK_OFFSET(OSMessageQueue, 0x30, size);
WUT_CHECK_OFFSET(OSMessageQueue, 0x34, first);
WUT_CHECK_OFFSET(OSMessageQueue, 0x38, used);
WUT_CHECK_SIZE(OSMessageQueue, 0x3c);
 
void
OSInitMessageQueue(OSMessageQueue *queue,
 OSMessage *messages,
 int32_t size);
 
void
OSInitMessageQueueEx(OSMessageQueue *queue,
 OSMessage *messages,
 int32_t size,
 const char *name);
 
BOOL
OSSendMessage(OSMessageQueue *queue,
 OSMessage *message,
 OSMessageFlags flags);
 
BOOL
OSReceiveMessage(OSMessageQueue *queue,
 OSMessage *message,
 OSMessageFlags flags);
 
BOOL
OSPeekMessage(OSMessageQueue *queue,
 OSMessage *message);
 
OSMessageQueue *
OSGetSystemMessageQueue();
 
OSMessageQueue *
OSGetDefaultAppIOQueue();
 
#ifdef __cplusplus
}
#endif