uchicago-cs / chistributed

8 stars 7 forks source link

Add lock to protect broker PUB socket #7

Closed kwzhao closed 6 years ago

kwzhao commented 6 years ago

Messages may be sent concurrently on the broker's PUB socket; this can cause simulated nodes to receive jumbled multi-part ZMQ messages.

This pull request adds a pub_lock that provides mutual exclusion for sending messages on the broker's PUB socket.