oxen-mq/oxenmq
Jason Rhinelander 445f214840
Fix a race condition with tagged thread startup
There's a very rare race condition where a tagged thread doesn't seem to
exist when the proxy tries syncing startup with them, and so the proxy
thread hangs in startup.

This addresses it by avoiding looking at the `proxy_thread` variable
(which probably isn't thread safe) in the worker's startup, and
signalling the you-need-to-shutdown condition via a third option for the
(formerly boolean) `tagged_go`.
2022-10-05 19:32:54 -03:00
..
address.cpp Use oxen-encoding and add compatibility shim headers 2022-01-18 10:30:23 -04:00
address.h Add std::hash implementation for oxenmq::address 2021-11-28 10:26:35 -04:00
auth.cpp Use oxen-encoding and add compatibility shim headers 2022-01-18 10:30:23 -04:00
auth.h adds custom formatter for OMQ structs that have to_string member 2022-08-04 10:50:02 +10:00
base32z.h Use oxen-encoding and add compatibility shim headers 2022-01-18 10:30:23 -04:00
base64.h Use oxen-encoding and add compatibility shim headers 2022-01-18 10:30:23 -04:00
batch.h Add simpler Job subclass of Batch for simple jobs 2022-05-12 12:20:51 -03:00
connections.cpp Fix zmq socket limit setting 2022-08-05 10:40:01 -03:00
connections.h adds custom formatter for OMQ structs that have to_string member 2022-08-04 10:50:02 +10:00
fmt.h adds custom formatter for OMQ structs that have to_string member 2022-08-04 10:50:02 +10:00
hex.h Use oxen-encoding and add compatibility shim headers 2022-01-18 10:30:23 -04:00
jobs.cpp Use raw index bytes in worker router 2022-05-12 12:38:13 -03:00
message.h Rebrand variables LMQ -> OMQ 2021-11-30 14:10:47 -04:00
oxenmq-internal.h adds custom formatter for OMQ structs that have to_string member 2022-08-04 10:50:02 +10:00
oxenmq.cpp Fix a race condition with tagged thread startup 2022-10-05 19:32:54 -03:00
oxenmq.h Fix a race condition with tagged thread startup 2022-10-05 19:32:54 -03:00
proxy.cpp Fix a race condition with tagged thread startup 2022-10-05 19:32:54 -03:00
pubsub.h initial implementation of generic pub/sub management 2022-09-28 15:43:45 -04:00
variant.h Use oxen-encoding and add compatibility shim headers 2022-01-18 10:30:23 -04:00
version.h.in Bump (and cmake-modernize) version 2021-04-15 15:15:44 -03:00
worker.cpp Fix a race condition with tagged thread startup 2022-10-05 19:32:54 -03:00