1*6b3a42afSjmmv // Copyright 2010 Google Inc.
2*6b3a42afSjmmv // All rights reserved.
3*6b3a42afSjmmv //
4*6b3a42afSjmmv // Redistribution and use in source and binary forms, with or without
5*6b3a42afSjmmv // modification, are permitted provided that the following conditions are
6*6b3a42afSjmmv // met:
7*6b3a42afSjmmv //
8*6b3a42afSjmmv // * Redistributions of source code must retain the above copyright
9*6b3a42afSjmmv // notice, this list of conditions and the following disclaimer.
10*6b3a42afSjmmv // * Redistributions in binary form must reproduce the above copyright
11*6b3a42afSjmmv // notice, this list of conditions and the following disclaimer in the
12*6b3a42afSjmmv // documentation and/or other materials provided with the distribution.
13*6b3a42afSjmmv // * Neither the name of Google Inc. nor the names of its contributors
14*6b3a42afSjmmv // may be used to endorse or promote products derived from this software
15*6b3a42afSjmmv // without specific prior written permission.
16*6b3a42afSjmmv //
17*6b3a42afSjmmv // THIS SOFTWARE IS PROVIDED BY THE COPYRIGHT HOLDERS AND CONTRIBUTORS
18*6b3a42afSjmmv // "AS IS" AND ANY EXPRESS OR IMPLIED WARRANTIES, INCLUDING, BUT NOT
19*6b3a42afSjmmv // LIMITED TO, THE IMPLIED WARRANTIES OF MERCHANTABILITY AND FITNESS FOR
20*6b3a42afSjmmv // A PARTICULAR PURPOSE ARE DISCLAIMED. IN NO EVENT SHALL THE COPYRIGHT
21*6b3a42afSjmmv // OWNER OR CONTRIBUTORS BE LIABLE FOR ANY DIRECT, INDIRECT, INCIDENTAL,
22*6b3a42afSjmmv // SPECIAL, EXEMPLARY, OR CONSEQUENTIAL DAMAGES (INCLUDING, BUT NOT
23*6b3a42afSjmmv // LIMITED TO, PROCUREMENT OF SUBSTITUTE GOODS OR SERVICES; LOSS OF USE,
24*6b3a42afSjmmv // DATA, OR PROFITS; OR BUSINESS INTERRUPTION) HOWEVER CAUSED AND ON ANY
25*6b3a42afSjmmv // THEORY OF LIABILITY, WHETHER IN CONTRACT, STRICT LIABILITY, OR TORT
26*6b3a42afSjmmv // (INCLUDING NEGLIGENCE OR OTHERWISE) ARISING IN ANY WAY OUT OF THE USE
27*6b3a42afSjmmv // OF THIS SOFTWARE, EVEN IF ADVISED OF THE POSSIBILITY OF SUCH DAMAGE.
28*6b3a42afSjmmv
29*6b3a42afSjmmv #include "utils/signals/programmer.hpp"
30*6b3a42afSjmmv
31*6b3a42afSjmmv extern "C" {
32*6b3a42afSjmmv #include <signal.h>
33*6b3a42afSjmmv }
34*6b3a42afSjmmv
35*6b3a42afSjmmv #include <cerrno>
36*6b3a42afSjmmv
37*6b3a42afSjmmv #include "utils/format/macros.hpp"
38*6b3a42afSjmmv #include "utils/logging/macros.hpp"
39*6b3a42afSjmmv #include "utils/sanity.hpp"
40*6b3a42afSjmmv #include "utils/signals/exceptions.hpp"
41*6b3a42afSjmmv
42*6b3a42afSjmmv
43*6b3a42afSjmmv namespace utils {
44*6b3a42afSjmmv namespace signals {
45*6b3a42afSjmmv
46*6b3a42afSjmmv
47*6b3a42afSjmmv /// Internal implementation for the signals::programmer class.
48*6b3a42afSjmmv struct programmer::impl {
49*6b3a42afSjmmv /// The number of the signal managed by this programmer.
50*6b3a42afSjmmv int signo;
51*6b3a42afSjmmv
52*6b3a42afSjmmv /// Whether the signal is currently programmed by us or not.
53*6b3a42afSjmmv bool programmed;
54*6b3a42afSjmmv
55*6b3a42afSjmmv /// The signal handler that we replaced; to be restored on unprogramming.
56*6b3a42afSjmmv struct ::sigaction old_sa;
57*6b3a42afSjmmv
58*6b3a42afSjmmv /// Initializes the internal implementation of the programmer.
59*6b3a42afSjmmv ///
60*6b3a42afSjmmv /// \param signo_ The signal number.
implutils::signals::programmer::impl61*6b3a42afSjmmv impl(const int signo_) :
62*6b3a42afSjmmv signo(signo_),
63*6b3a42afSjmmv programmed(false)
64*6b3a42afSjmmv {
65*6b3a42afSjmmv }
66*6b3a42afSjmmv };
67*6b3a42afSjmmv
68*6b3a42afSjmmv
69*6b3a42afSjmmv } // namespace signals
70*6b3a42afSjmmv } // namespace utils
71*6b3a42afSjmmv
72*6b3a42afSjmmv
73*6b3a42afSjmmv namespace signals = utils::signals;
74*6b3a42afSjmmv
75*6b3a42afSjmmv
76*6b3a42afSjmmv /// Programs a signal handler.
77*6b3a42afSjmmv ///
78*6b3a42afSjmmv /// \param signo The signal for which to install the handler.
79*6b3a42afSjmmv /// \param handler The handler to install.
80*6b3a42afSjmmv ///
81*6b3a42afSjmmv /// \throw signals::system_error If there is an error programming the signal.
programmer(const int signo,const handler_type handler)82*6b3a42afSjmmv signals::programmer::programmer(const int signo, const handler_type handler) :
83*6b3a42afSjmmv _pimpl(new impl(signo))
84*6b3a42afSjmmv {
85*6b3a42afSjmmv struct ::sigaction sa;
86*6b3a42afSjmmv sa.sa_handler = handler;
87*6b3a42afSjmmv sigemptyset(&sa.sa_mask);
88*6b3a42afSjmmv sa.sa_flags = SA_RESTART;
89*6b3a42afSjmmv
90*6b3a42afSjmmv if (::sigaction(_pimpl->signo, &sa, &_pimpl->old_sa) == -1) {
91*6b3a42afSjmmv const int original_errno = errno;
92*6b3a42afSjmmv throw system_error(F("Could not install handler for signal %s") %
93*6b3a42afSjmmv _pimpl->signo, original_errno);
94*6b3a42afSjmmv } else
95*6b3a42afSjmmv _pimpl->programmed = true;
96*6b3a42afSjmmv }
97*6b3a42afSjmmv
98*6b3a42afSjmmv
99*6b3a42afSjmmv /// Destructor; unprograms the signal handler if still programmed.
100*6b3a42afSjmmv ///
101*6b3a42afSjmmv /// Given that this is a destructor and it can't report errors back to the
102*6b3a42afSjmmv /// caller, the caller must attempt to call unprogram() on its own.
~programmer(void)103*6b3a42afSjmmv signals::programmer::~programmer(void)
104*6b3a42afSjmmv {
105*6b3a42afSjmmv if (_pimpl->programmed) {
106*6b3a42afSjmmv LW("Destroying still-programmed signals::programmer object");
107*6b3a42afSjmmv try {
108*6b3a42afSjmmv unprogram();
109*6b3a42afSjmmv } catch (const system_error& e) {
110*6b3a42afSjmmv UNREACHABLE;
111*6b3a42afSjmmv }
112*6b3a42afSjmmv }
113*6b3a42afSjmmv }
114*6b3a42afSjmmv
115*6b3a42afSjmmv
116*6b3a42afSjmmv /// Unprograms the signal handler.
117*6b3a42afSjmmv ///
118*6b3a42afSjmmv /// \pre The signal handler is programmed (i.e. this can only be called once).
119*6b3a42afSjmmv ///
120*6b3a42afSjmmv /// \throw system_error If unprogramming the signal failed. If this happens,
121*6b3a42afSjmmv /// the signal is left programmed, this object forgets about the signal and
122*6b3a42afSjmmv /// therefore there is no way to restore the original handler.
123*6b3a42afSjmmv void
unprogram(void)124*6b3a42afSjmmv signals::programmer::unprogram(void)
125*6b3a42afSjmmv {
126*6b3a42afSjmmv PRE(_pimpl->programmed);
127*6b3a42afSjmmv
128*6b3a42afSjmmv // If we fail, we don't want the destructor to attempt to unprogram the
129*6b3a42afSjmmv // handler again, as it would result in a crash.
130*6b3a42afSjmmv _pimpl->programmed = false;
131*6b3a42afSjmmv
132*6b3a42afSjmmv if (::sigaction(_pimpl->signo, &_pimpl->old_sa, NULL) == -1) {
133*6b3a42afSjmmv const int original_errno = errno;
134*6b3a42afSjmmv throw system_error(F("Could not reset handler for signal %s") %
135*6b3a42afSjmmv _pimpl->signo, original_errno);
136*6b3a42afSjmmv }
137*6b3a42afSjmmv }
138