box/node_center.cpp
@@ -164,7 +164,7 @@ // create sockets. try { ShmSocket tmp(shm, true, ssn, 16); ShmSocket tmp(shm, ssn, eCreate); node->addrs_.emplace(ssn, tmp.AbsAddr()); return true; } catch (...) { @@ -333,7 +333,7 @@ auto &node = pos->second; try { for (int i = 0; i < msg.extra_mq_num(); ++i) { ShmSocket tmp(node->shm_, true, head.ssn_id() + i + 1, 16); ShmSocket tmp(node->shm_, head.ssn_id() + i + 1, eCreate); node->addrs_.emplace(tmp.id(), tmp.AbsAddr()); auto addr = reply.add_extra_mqs(); addr->set_mq_id(tmp.id());