mailbox_safe.hpp

Go to the documentation of this file.

/* SPDX-License-Identifier: MPL-2.0 */
 
#ifndef __ZMQ_MAILBOX_SAFE_HPP_INCLUDED__
#define __ZMQ_MAILBOX_SAFE_HPP_INCLUDED__
 
#include <vector>
#include <stddef.h>
 
#include "signaler.hpp"
#include "fd.hpp"
#include "config.hpp"
#include "command.hpp"
#include "ypipe.hpp"
#include "mutex.hpp"
#include "i_mailbox.hpp"
#include "condition_variable.hpp"
 
namespace zmq
{
class mailbox_safe_t ZMQ_FINAL : public i_mailbox
{
  public:
    mailbox_safe_t (mutex_t *sync_);
    ~mailbox_safe_t ();
 
    void send (const command_t &cmd_);
    int recv (command_t *cmd_, int timeout_);
 
    // Add signaler to mailbox which will be called when a message is ready
    void add_signaler (signaler_t *signaler_);
    void remove_signaler (signaler_t *signaler_);
    void clear_signalers ();
 
#ifdef HAVE_FORK
    // close the file descriptors in the signaller. This is used in a forked
    // child process to close the file descriptors so that they do not interfere
    // with the context in the parent process.
    void forked () ZMQ_FINAL
    {
        // TODO: call fork on the condition variable
    }
#endif
 
  private:
    //  The pipe to store actual commands.
    typedef ypipe_t<command_t, command_pipe_granularity> cpipe_t;
    cpipe_t _cpipe;
 
    //  Condition variable to pass signals from writer thread to reader thread.
    condition_variable_t _cond_var;
 
    //  Synchronize access to the mailbox from receivers and senders
    mutex_t *const _sync;
 
    std::vector<zmq::signaler_t *> _signalers;
 
    ZMQ_NON_COPYABLE_NOR_MOVABLE (mailbox_safe_t)
};
}
 
#endif