* http://www.pulse-eight.net/
*/
-#include "USBCECAdapterMessage.h"
-#include "../platform/threads/threads.h"
+#include "lib/platform/threads/threads.h"
+#include "lib/platform/util/buffer.h"
#include <map>
namespace CEC
{
class CUSBCECAdapterCommunication;
class CCECAdapterMessageQueue;
+ class CCECAdapterMessage;
class CCECAdapterMessageQueueEntry
{
* @param com The communication handler callback to use.
* @param iQueueSize The outgoing message queue size.
*/
- CCECAdapterMessageQueue(CUSBCECAdapterCommunication *com) :
- PLATFORM::CThread(),
- m_com(com),
- m_iNextMessage(0)
- {
- m_currentCECFrame.Clear();
- }
-
+ CCECAdapterMessageQueue(CUSBCECAdapterCommunication *com);
virtual ~CCECAdapterMessageQueue(void);
/*!
std::map<uint64_t, CCECAdapterMessageQueueEntry *> m_messages; /**< the outgoing message queue */
PLATFORM::SyncedBuffer<CCECAdapterMessageQueueEntry *> m_writeQueue; /**< the queue for messages that are to be written */
uint64_t m_iNextMessage; /**< the index of the next message */
- CCECAdapterMessage m_incomingAdapterMessage; /**< the current incoming message that's being assembled */
+ CCECAdapterMessage *m_incomingAdapterMessage; /**< the current incoming message that's being assembled */
cec_command m_currentCECFrame; /**< the current incoming CEC command that's being assembled */
};
}