libzmq
master
ZeroMQ C++ Core Engine (LIBZMQ)
Main Page
Classes
Files
File List
File Members
signaler.hpp
Go to the documentation of this file.
1
/*
2
Copyright (c) 2007-2016 Contributors as noted in the AUTHORS file
3
4
This file is part of libzmq, the ZeroMQ core engine in C++.
5
6
libzmq is free software; you can redistribute it and/or modify it under
7
the terms of the GNU Lesser General Public License (LGPL) as published
8
by the Free Software Foundation; either version 3 of the License, or
9
(at your option) any later version.
10
11
As a special exception, the Contributors give you permission to link
12
this library with independent modules to produce an executable,
13
regardless of the license terms of these independent modules, and to
14
copy and distribute the resulting executable under terms of your choice,
15
provided that you also meet, for each linked independent module, the
16
terms and conditions of the license of that module. An independent
17
module is a module which is not derived from or based on this library.
18
If you modify this library, you must extend this exception to your
19
version of the library.
20
21
libzmq is distributed in the hope that it will be useful, but WITHOUT
22
ANY WARRANTY; without even the implied warranty of MERCHANTABILITY or
23
FITNESS FOR A PARTICULAR PURPOSE. See the GNU Lesser General Public
24
License for more details.
25
26
You should have received a copy of the GNU Lesser General Public License
27
along with this program. If not, see <http://www.gnu.org/licenses/>.
28
*/
29
30
#ifndef __ZMQ_SIGNALER_HPP_INCLUDED__
31
#define __ZMQ_SIGNALER_HPP_INCLUDED__
32
33
#ifdef HAVE_FORK
34
#include <unistd.h>
35
#endif
36
37
#include "
fd.hpp
"
38
39
namespace
zmq
40
{
41
42
// This is a cross-platform equivalent to signal_fd. However, as opposed
43
// to signal_fd there can be at most one signal in the signaler at any
44
// given moment. Attempt to send a signal before receiving the previous
45
// one will result in undefined behaviour.
46
47
class
signaler_t
48
{
49
public
:
50
51
signaler_t
();
52
~signaler_t
();
53
54
fd_t
get_fd
()
const
;
55
void
send
();
56
int
wait
(
int
timeout_);
57
void
recv
();
58
int
recv_failable
();
59
60
#ifdef HAVE_FORK
61
// close the file descriptors in a forked child process so that they
62
// do not interfere with the context in the parent process.
63
void
forked ();
64
#endif
65
66
private
:
67
68
// Creates a pair of file descriptors that will be used
69
// to pass the signals.
70
static
int
make_fdpair
(
fd_t
*r_,
fd_t
*w_);
71
72
// Underlying write & read file descriptor
73
// Will be -1 if we exceeded number of available handles
74
fd_t
w
;
75
fd_t
r
;
76
77
// Disable copying of signaler_t object.
78
signaler_t
(
const
signaler_t
&);
79
const
signaler_t
&
operator =
(
const
signaler_t
&);
80
81
#ifdef HAVE_FORK
82
// the process that created this context. Used to detect forking.
83
pid_t pid;
84
// idempotent close of file descriptors that is safe to use by destructor
85
// and forked().
86
void
close_internal ();
87
#endif
88
};
89
}
90
91
#endif
zmq::signaler_t::recv_failable
int recv_failable()
Definition:
signaler.cpp:313
fd.hpp
zmq::signaler_t::operator=
const signaler_t & operator=(const signaler_t &)
zmq::signaler_t::wait
int wait(int timeout_)
Definition:
signaler.cpp:207
zmq::signaler_t::~signaler_t
~signaler_t()
Definition:
signaler.cpp:133
zmq::signaler_t::get_fd
fd_t get_fd() const
Definition:
signaler.cpp:166
zmq::signaler_t::make_fdpair
static int make_fdpair(fd_t *r_, fd_t *w_)
Definition:
signaler.cpp:376
zmq::signaler_t::recv
void recv()
Definition:
signaler.cpp:281
zmq::signaler_t::w
fd_t w
Definition:
signaler.hpp:74
zmq::signaler_t::send
void send()
Definition:
signaler.cpp:171
zmq::signaler_t::signaler_t
signaler_t()
Definition:
signaler.cpp:119
zmq
Definition:
address.hpp:35
zmq::signaler_t::r
fd_t r
Definition:
signaler.hpp:75
zmq::signaler_t
Definition:
signaler.hpp:47
int
zeromq
libzmq
src
signaler.hpp
Generated by
1.8.11