fix asserts
This commit is contained in:
parent
cb3302160b
commit
27c77ba74b
1 changed files with 2 additions and 2 deletions
|
|
@ -1080,9 +1080,9 @@ std::vector<zmq::message_t> zmq_listener::receive_multipart() {
|
||||||
void zmq_listener::handle_zmq() {
|
void zmq_listener::handle_zmq() {
|
||||||
int linger = 0;
|
int linger = 0;
|
||||||
auto rc = zmq_setsockopt(socket, ZMQ_SUBSCRIBE, "hashblock", 9);
|
auto rc = zmq_setsockopt(socket, ZMQ_SUBSCRIBE, "hashblock", 9);
|
||||||
FC_ASSERT(rc);
|
FC_ASSERT(0 == rc);
|
||||||
rc = zmq_setsockopt(socket, ZMQ_LINGER, &linger, sizeof(linger));
|
rc = zmq_setsockopt(socket, ZMQ_LINGER, &linger, sizeof(linger));
|
||||||
FC_ASSERT(rc);
|
FC_ASSERT(0 == rc);
|
||||||
//socket.setsockopt( ZMQ_SUBSCRIBE, "hashtx", 6 );
|
//socket.setsockopt( ZMQ_SUBSCRIBE, "hashtx", 6 );
|
||||||
//socket.setsockopt( ZMQ_SUBSCRIBE, "rawblock", 8 );
|
//socket.setsockopt( ZMQ_SUBSCRIBE, "rawblock", 8 );
|
||||||
//socket.setsockopt( ZMQ_SUBSCRIBE, "rawtx", 5 );
|
//socket.setsockopt( ZMQ_SUBSCRIBE, "rawtx", 5 );
|
||||||
|
|
|
||||||
Loading…
Reference in a new issue