| | |
|---|
| | | } |
|---|
| | | } |
|---|
| | | auto &mq = GetCenterInfo(shm)->mq_sender_; |
|---|
| | | store.emplace_back(&shm, new ShmSocket(mq.offset_, shm, mq.id_)); |
|---|
| | | store.emplace_back(&shm, std::make_shared<ShmSocket>(mq.offset_, shm, mq.id_)); |
|---|
| | | // store.emplace_back(&shm, new ShmSocket(mq.offset_, shm, mq.id_)); |
|---|
| | | local_cache = store.back(); |
|---|
| | | return *local_cache.second; |
|---|
| | | } |
|---|
| | |
|---|
| | | std::string BHomeShmName() |
|---|
| | | { |
|---|
| | | auto bhome_meta = Ptr<BHomeMetaInfo>(kShmMetaInfoFixedAddress + Addr(BHomeMetaShm().get_address())); |
|---|
| | | return "bhome_shmq_id_" + std::to_string(bhome_meta->shm_id_.load()); |
|---|
| | | return "bhshmq_sid_" + std::to_string(bhome_meta->shm_id_.load()); |
|---|
| | | } |
|---|
| | | |
|---|
| | | SharedMemory &BHomeShm() |
|---|
