diff options
author | Martin Sustrik <sustrik@250bpm.com> | 2010-11-05 17:39:51 +0100 |
---|---|---|
committer | Martin Sustrik <sustrik@250bpm.com> | 2010-11-05 17:39:51 +0100 |
commit | 9da84a5239e5356e34d872c2b5af1d19b9c7eb4f (patch) | |
tree | 62267a898b0890dc21425cf4120f690a8083877d /src/signaler.hpp | |
parent | 9cfdb441f45057c7106a101835d65164fce9470a (diff) |
signaler renamed to mailbox
For historical reasons queue to transfer commands between
threads was called 'signaler'. Given that it was used to
pass commands rather than signals it was renamed to 'mailbox',
see Erlang mailboxes.
Signed-off-by: Martin Sustrik <sustrik@250bpm.com>
Diffstat (limited to 'src/signaler.hpp')
-rw-r--r-- | src/signaler.hpp | 61 |
1 files changed, 0 insertions, 61 deletions
diff --git a/src/signaler.hpp b/src/signaler.hpp deleted file mode 100644 index faf3f1f..0000000 --- a/src/signaler.hpp +++ /dev/null @@ -1,61 +0,0 @@ -/* - Copyright (c) 2007-2010 iMatix Corporation - - This file is part of 0MQ. - - 0MQ is free software; you can redistribute it and/or modify it under - the terms of the GNU Lesser General Public License as published by - the Free Software Foundation; either version 3 of the License, or - (at your option) any later version. - - 0MQ is distributed in the hope that it will be useful, - but WITHOUT ANY WARRANTY; without even the implied warranty of - MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the - GNU Lesser General Public License for more details. - - You should have received a copy of the GNU Lesser General Public License - along with this program. If not, see <http://www.gnu.org/licenses/>. -*/ - -#ifndef __ZMQ_SIGNALER_HPP_INCLUDED__ -#define __ZMQ_SIGNALER_HPP_INCLUDED__ - -#include <stddef.h> - -#include "platform.hpp" -#include "fd.hpp" -#include "stdint.hpp" -#include "config.hpp" -#include "command.hpp" - -namespace zmq -{ - - class signaler_t - { - public: - - signaler_t (); - ~signaler_t (); - - fd_t get_fd (); - void send (const command_t &cmd_); - int recv (command_t *cmd_, bool block_); - - private: - - // Write & read end of the socketpair. - fd_t w; - fd_t r; - - // Platform-dependent function to create a socketpair. - static int make_socketpair (fd_t *r_, fd_t *w_); - - // Disable copying of signaler_t object. - signaler_t (const signaler_t&); - void operator = (const signaler_t&); - }; - -} - -#endif |