Changeset View
Changeset View
Standalone View
Standalone View
src/zmq/zmqpublishnotifier.cpp
| Show First 20 Lines • Show All 82 Lines • ▼ Show 20 Lines | if (i == mapPublishNotifiers.end()) { | ||||
| } | } | ||||
| // register this notifier for the address, so it can be reused for other | // register this notifier for the address, so it can be reused for other | ||||
| // publish notifier | // publish notifier | ||||
| mapPublishNotifiers.insert(std::make_pair(address, this)); | mapPublishNotifiers.insert(std::make_pair(address, this)); | ||||
| return true; | return true; | ||||
| } else { | } else { | ||||
| LogPrint(BCLog::ZMQ, "zmq: Reusing socket for address %s\n", address); | LogPrint(BCLog::ZMQ, "zmq: Reusing socket for address %s\n", address); | ||||
| LogPrint(BCLog::ZMQ, | |||||
| "zmq: Outbound message high water mark for %s at %s is %d\n", | |||||
| type, address, outbound_message_high_water_mark); | |||||
| psocket = i->second->psocket; | psocket = i->second->psocket; | ||||
| mapPublishNotifiers.insert(std::make_pair(address, this)); | mapPublishNotifiers.insert(std::make_pair(address, this)); | ||||
| return true; | return true; | ||||
| } | } | ||||
| } | } | ||||
| ▲ Show 20 Lines • Show All 96 Lines • Show Last 20 Lines | |||||