| | |
|---|
| | | |
|---|
| | | BHCenter::BHCenter(Socket::Shm &shm) |
|---|
| | | { |
|---|
| | | auto gc = [&](const MQId id) { |
|---|
| | | auto r = ShmSocket::Remove(shm, id); |
|---|
| | | if (r) { |
|---|
| | | LOG_DEBUG() << "remove mq " << id << " ok\n"; |
|---|
| | | } |
|---|
| | | }; |
|---|
| | | |
|---|
| | | auto nsec = NodeTimeoutSec(); |
|---|
| | | auto center_ptr = std::make_shared<Synced<NodeCenter>>("#bhome_center", gc, nsec, nsec * 3); // *3 to allow other clients to finish sending msgs. |
|---|
| | | auto center_ptr = std::make_shared<Synced<NodeCenter>>("#bhome_center", nsec, nsec * 3); // *3 to allow other clients to finish sending msgs. |
|---|
| | | AddCenter(center_ptr); |
|---|
| | | |
|---|
| | | for (auto &kv : Centers()) { |
|---|
