/*
 * =====================================================================================
 *
 *       Filename:  shm_msg_queue.h
 *
 *    Description:  
 *
 *        Version:  1.0
 *        Created:  2021年04月26日 16时25分21秒
 *       Revision:  none
 *       Compiler:  gcc
 *
 *         Author:  Li Chao (), lichao@aiotlink.com
 *   Organization:  
 *
 * =====================================================================================
 */
#ifndef SHM_MSG_QUEUE_D847TQXH
#define SHM_MSG_QUEUE_D847TQXH

#include "defs.h"
#include "msg.h"
#include "shm_queue.h"

using namespace bhome_shm;
using namespace bhome_msg;

class ShmMsgQueue
{
public:
	typedef int64_t RawData;
	typedef NamedShmObject<SharedQ63> Shmq;
	typedef Shmq::Data Queue;
	typedef Shmq::ShmType ShmType;
	typedef uint64_t MQId;

	ShmMsgQueue(ShmType &segment, const MQId id, Mode mode);
	ShmMsgQueue(const int64_t abs_addr, ShmType &segment, const MQId id);
	~ShmMsgQueue();
	static bool Remove(ShmType &shm, const MQId id);
	MQId Id() const { return id_; }
	ShmType &shm() const { return queue_.shm(); }
	int64_t AbsAddr() const { return queue_.offset(); }

	// bool Recv(RawData &val, const int timeout_ms) { return queue().Read(val, timeout_ms); }
	bool TryRecv(RawData &val) { return queue().TryRead(val); }

	// bool Recv(MsgI &msg, const int timeout_ms) { return Recv(msg.OffsetRef(), timeout_ms); }
	bool TryRecv(MsgI &msg) { return TryRecv(msg.OffsetRef()); }
	static Queue *Find(ShmType &shm, const MQId remote);
	static bool TrySend(ShmType &shm, const MQInfo &remote, const RawData val);
	bool TrySend(const MQInfo &remote, const RawData val) { return TrySend(shm(), remote, val); }

private:
	MQId id_;
	Queue &queue() { return *queue_.data(); }
	Shmq queue_;
};

#endif // end of include guard: SHM_MSG_QUEUE_D847TQXH