use new robust mutex, circurar; rm timeout mutex.

lichao

2021-04-28 a6f67b4249525089fb97eb9418c7014f66c2a000

 src/defs.cpp

@@ -16,14 +16,11 @@
 * =====================================================================================
 */
#include "defs.h"
#include "shm.h"
#include "msg.h"
#include "shm_msg_queue.h"

namespace
{

const MQId kBHTopicBus = boost::uuids::string_generator()("01234567-89ab-cdef-8349-1234567890ff");
const MQId kBHTopicCenter = boost::uuids::string_generator()("12345670-89ab-cdef-8349-1234567890ff");
const MQId kBHUniCenter = boost::uuids::string_generator()("87654321-89ab-cdef-8349-1234567890ff");

struct LastError {
   int ec_ = 0;
@@ -38,16 +35,24 @@

} // namespace

const MQId &BHTopicBusAddress() { return kBHTopicBus; }
const MQId &BHTopicCenterAddress() { return kBHTopicCenter; }
const MQId &BHUniCenterAddress() { return kBHUniCenter; }

std::string BHomeShmName()
{
   return "bhome_default_shm_v0";
}
bhome_shm::SharedMemory &BHomeShm()
{
   static bhome_shm::SharedMemory shm("bhome_default_shm_v0", 1024 * 1024 * 512);
   static bhome_shm::SharedMemory shm(BHomeShmName(), 1024 * 1024 * 512);
   return shm;
}

bool GlobalInit(bhome_shm::SharedMemory &shm)
{
   MsgI::BindShm(shm);
   typedef std::atomic<MQId> IdSrc;
   IdSrc *psrc = shm.FindOrCreate<IdSrc>("shmqIdSrc0", 100000);
   return ShmMsgQueue::SetData(*psrc);
}

void SetLastError(const int ec, const std::string &msg)
{
   LastErrorStore().ec_ = ec;