« Previous | Next » 

Revision 5db87ed5

ID5db87ed59660286d64ad0e04b31ce99101cc5c6a

Added by Vangelis Koukis about 13 years ago

Make ZMQ thread in db_controller stoppable.

Make db_controller run all 0mq operations in a separate StoppableThread
with a stop() method. The main thread calls it, then publishes on an in-proc
PUB socket to interrupt any zmq_recv() call and join the thread when cleaning
up on exceptions/errors.

Minor fix: use the hostname as a prefix for the 0mq SUB socket's identity, to
prevent bugs due to having multiple db_controllers running at the same time on
different machines.

Files

  • added
  • modified
  • copied
  • renamed
  • deleted

View differences