#ifndef _NT_MSQ_H_

#define _NT_MSQ_H_

#include "nt_abi.h"

#include "nt_object.h"

/* semaphore command flags */

#define NT_MSQ_FLAG_NOWAIT		(0x0800)

#define NT_MSQ_FLAG_NOERROR		(0x1000)

/* msgqueue info */

typedef struct __attr_ptr_size_aligned__ _nt_msq_info {

	void *		hport;

	void *		section;

	void *		section_addr;

	size_t		section_size;

	void *		hevent;

	void *		apc_routine;

	void *		apc_context;

	int32_t		msqkey;

	int32_t		msqid;

	int32_t		msqspid;

	int32_t		msqrpid;

	intptr_t	msqrank;

	uintptr_t	msqslots;

	uintptr_t	msqcbytes;

	uintptr_t	msqqbytes;

	uint32_t	msqscnt;

	uint32_t	msqrcnt;

	nt_filetime	msqstime;

	nt_filetime	msqrtime;

	nt_filetime	msqctime;

	uint64_t	ipcuid;

	uint64_t	ipcgid;

	uint64_t	ipccuid;

	uint64_t	ipccgid;

	uint32_t	ipcmode;

	int32_t		ipcseq;

	uint32_t	ntaccess;

	uint32_t	ntattr;

	uint32_t	ntshare;

	uint32_t	ntoptions;

	nt_iosb		ntiosb;

	nt_iosb *	riosb;

} nt_msq_info;

/* msgqueue client interfaces */

typedef int32_t	__stdcall ntapi_msq_create(

	__in	void *			hport,

	__out	nt_msq_info *		msq,

	__in	uint32_t		access,

	__in	nt_object_attributes *	oa,

	__out	nt_iosb *		iosb,

	__in	uint32_t		share,

	__in	uint32_t		nslots);

typedef int32_t	__stdcall ntapi_msq_open(

	__in	void *			hport,

	__out	nt_msq_info *		msq,

	__in	uint32_t		access,

	__in	nt_object_attributes *	oa,

	__out	nt_iosb *		iosb,

	__in	uint32_t		share,

	__in	uint32_t		nslots);

typedef int32_t __stdcall ntapi_msq_send(

	__in	nt_msq_info *		msq,

	__in 	void *			hevent		__optional,

	__in	nt_io_apc_routine *	apc_routine	__optional,

	__in	void * 			apc_context	__optional,

	__in	const void *		buffer,

	__in	size_t			len,

	__in	intptr_t		rank,

	__in	uint32_t		options,

	__out	nt_io_status_block *	iosb);

typedef int32_t __stdcall ntapi_msq_recv(

	__in	nt_msq_info *		msq,

	__in 	void *			hevent		__optional,

	__in	nt_io_apc_routine *	apc_routine	__optional,

	__in	void * 			apc_context	__optional,

	__out	void *			buffer,

	__in	size_t			len,

	__in	intptr_t		rank,

	__in	uint32_t		options,

	__out	nt_io_status_block *	iosb);

typedef int32_t	__stdcall ntapi_msq_fcntl(

	__in	nt_msq_info *		msq,

	__in	void *			hevent			__optional,

	__in	nt_io_apc_routine *	apc_routine		__optional,

	__in	void *			apc_context		__optional,

	__out	nt_iosb *		iosb,

	__in	uint32_t		tty_control_code,

	__in	void *			input_buffer		__optional,

	__in	uint32_t		input_buffer_length,

	__out	void *			output_buffer		__optional,

	__in	uint32_t		output_buffer_length);

typedef int32_t	__stdcall ntapi_msq_ioctl(

	__in	nt_msq_info *		msq,

	__in	void *			hevent			__optional,

	__in	nt_io_apc_routine *	apc_routine		__optional,

	__in	void *			apc_context		__optional,

	__out	nt_iosb *		iosb,

	__in	uint32_t		ipc_control_code,

	__in	void *			input_buffer		__optional,

	__in	uint32_t		input_buffer_length,

	__out	void *			output_buffer		__optional,

	__in	uint32_t		output_buffer_length);

typedef int32_t	__stdcall ntapi_msq_query(

	__in	nt_msq_info *		msq,

	__out	nt_io_status_block *	iosb,

	__out	void *			sem_info,

	__in	uint32_t		sem_info_length,

	__in	int32_t			sem_ipc_cmd);

typedef int32_t	__stdcall ntapi_msq_set(

	__in	nt_msq_info *		msq,

	__out	nt_io_status_block *	iosb,

	__in	void *			sem_info,

	__in	uint32_t		sem_info_length,

	__in	int32_t			sem_ipc_cmd);

typedef int32_t	__stdcall ntapi_msq_cancel(

	__in	nt_msq_info *		msq,

	__out	nt_iosb *		iosb);

typedef int32_t	__stdcall ntapi_msq_free(

	__in	nt_msq_info *		msq,

	__out	nt_iosb *		iosb);

#endif