generic-library/libzmq
1
0
Fork 0
mirror of https://github.com/zeromq/libzmq.git synced 2025-11-08 14:56:14 +01:00
Code Issues Projects Releases Wiki Activity

Problem: get_opt function read the options value maybe not thread safe

Browse Source 
Solution: use scoped lock to prevent them from being modified during reading
This commit is contained in:
Abama cai
2022-08-10 22:35:14 +08:00
parent 0251be4d77
commit 717d1980ee
1 changed files with 7 additions and 0 deletions
Download Patch File Download Diff File Expand all files Collapse all files

7
src/ctx.cpp
View File

@@ -328,6 +328,7 @@ int zmq::ctx_t::get (int option_, void *optval_, const size_t *optvallen_)
switch (option_) { switch (option_) {
case ZMQ_MAX_SOCKETS: case ZMQ_MAX_SOCKETS:
if (is_int) { if (is_int) {
scoped_lock_t locker (_opt_sync);
*value = _max_sockets; *value = _max_sockets;
return 0; return 0;
} }
@@ -342,6 +343,7 @@ int zmq::ctx_t::get (int option_, void *optval_, const size_t *optvallen_)
case ZMQ_IO_THREADS: case ZMQ_IO_THREADS:
if (is_int) { if (is_int) {
scoped_lock_t locker (_opt_sync);
*value = _io_thread_count; *value = _io_thread_count;
return 0; return 0;
} }
@@ -349,6 +351,7 @@ int zmq::ctx_t::get (int option_, void *optval_, const size_t *optvallen_)
case ZMQ_IPV6: case ZMQ_IPV6:
if (is_int) { if (is_int) {
scoped_lock_t locker (_opt_sync);
*value = _ipv6; *value = _ipv6;
return 0; return 0;
} }
@@ -356,6 +359,7 @@ int zmq::ctx_t::get (int option_, void *optval_, const size_t *optvallen_)
case ZMQ_BLOCKY: case ZMQ_BLOCKY:
if (is_int) { if (is_int) {
scoped_lock_t locker (_opt_sync);
*value = _blocky; *value = _blocky;
return 0; return 0;
} }
@@ -363,6 +367,7 @@ int zmq::ctx_t::get (int option_, void *optval_, const size_t *optvallen_)
case ZMQ_MAX_MSGSZ: case ZMQ_MAX_MSGSZ:
if (is_int) { if (is_int) {
scoped_lock_t locker (_opt_sync);
*value = _max_msgsz; *value = _max_msgsz;
return 0; return 0;
} }
@@ -370,6 +375,7 @@ int zmq::ctx_t::get (int option_, void *optval_, const size_t *optvallen_)
case ZMQ_MSG_T_SIZE: case ZMQ_MSG_T_SIZE:
if (is_int) { if (is_int) {
scoped_lock_t locker (_opt_sync);
*value = sizeof (zmq_msg_t); *value = sizeof (zmq_msg_t);
return 0; return 0;
} }
@@ -377,6 +383,7 @@ int zmq::ctx_t::get (int option_, void *optval_, const size_t *optvallen_)
case ZMQ_ZERO_COPY_RECV: case ZMQ_ZERO_COPY_RECV:
if (is_int) { if (is_int) {
scoped_lock_t locker (_opt_sync);
*value = _zero_copy; *value = _zero_copy;
return 0; return 0;
} }