/*******************************************************************************
--                                                                            --
--                    CedarX Multimedia Framework                             --
--                                                                            --
--          the Multimedia Framework for Linux/Android System                 --
--                                                                            --
--       This software is confidential and proprietary and may be used        --
--        only as expressly authorized by a licensing agreement from          --
--                         Softwinner Products.                               --
--                                                                            --
--                   (C) COPYRIGHT 2011 SOFTWINNER PRODUCTS                   --
--                            ALL RIGHTS RESERVED                             --
--                                                                            --
--                 The entire notice above must be reproduced                 --
--                  on all copies and should not be removed.                  --
--                                                                            --
*******************************************************************************/
#ifdef __cplusplus
extern "C" {
#endif

#ifndef __MESSAGE_H_8X3E__
#define __MESSAGE_H_8X3E__

//ref platform headers
#include "plat_type.h"
#include <pthread.h>
#include <tsemaphore.h>

//cts test may send 1000 messages.
//we must make sure message queue longer than 10000.

#define MAX_MESSAGE_ELEMENTS (8)    //20000

typedef struct MessageReply
{
    cdx_sem_t ReplySem;
    int ReplyResult;
    void *pReplyExtra;   //message processor malloc memory, message sender free memory.
    int nReplyExtraSize;
}MessageReply;
MessageReply *ConstructMessageReply();
void DestructMessageReply(MessageReply *pReply);

//typedef struct message_t message_t;
typedef struct message_t
{
	int 				id;
	int 				command;
//	int                 priority;
	int 				para0;
	int 				para1;
    void*               mpData;
    int                 mDataSize;
    MessageReply        *pReply;
	struct list_head    mList;
}message_t;
int InitMessage(message_t *pMsg);

typedef struct message_queue_t
{
    struct list_head    mIdleMessageList;   //message_t
    struct list_head    mReadyMessageList;   //message_t
    //struct list_head    mMessageBufList;   //DynamicBuffer, sizeof(message_t)*MAX_MESSAGE_ELEMENTS
	int                 message_count;
	pthread_mutex_t     mutex;
    pthread_cond_t      mCondMessageQueueChanged;
    int                 mWaitMessageFlag;
}message_queue_t;

int  message_create(message_queue_t* message);
void message_destroy(message_queue_t* msg_queue);
void flush_message(message_queue_t* msg_queue);
int  put_message(message_queue_t* msg_queue, message_t *msg_in);
int  get_message(message_queue_t* msg_queue, message_t *msg_out);
int putMessageWithData(message_queue_t* msg_queue, message_t *msg_in);
int  get_message_count(message_queue_t* message);
int TMessage_WaitQueueNotEmpty(message_queue_t* msg_queue, unsigned int timeout);   //unit:ms

#endif

#ifdef __cplusplus
}
#endif