Repository navigation
Expand file tree
/
Copy pathsignalfd.cc
More file actions
68 lines (51 loc) · 1.73 KB
/
Copy pathsignalfd.cc
File metadata and controls
68 lines (51 loc) · 1.73 KB
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
/* -*-mode:c++; tab-width: 4; indent-tabs-mode: nil; c-basic-offset: 4 -*- */
#include <csignal>
#include "signalfd.hh"
using namespace std;
/* add given signals to the mask */
SignalMask::SignalMask( const initializer_list< int > signals )
: mask_()
{
SystemCall( "sigemptyset", sigemptyset( &mask_ ) );
for ( const auto signal : signals ) {
SystemCall( "sigaddset", sigaddset( &mask_, signal ) );
}
}
/* get the current mask */
SignalMask SignalMask::current_mask( void )
{
SignalMask mask = {};
SystemCall( "sigprocmask", sigprocmask( SIG_BLOCK, nullptr, &mask.mask_ ) );
return mask;
}
/* challenging to compare two sigset_t's for equality */
bool SignalMask::operator==( const SignalMask & other ) const
{
for ( int signum = 0; signum < SIGRTMAX; signum++ ) {
if ( sigismember( &mask_, signum ) != sigismember( &other.mask_, signum ) ) {
return false;
}
}
return true;
}
/* mask these signals from interrupting our process */
/* (because we'll use a signalfd instead to read them */
void SignalMask::set_as_mask( void ) const
{
SystemCall( "sigprocmask", sigprocmask( SIG_SETMASK, &mask_, nullptr ) );
}
SignalFD::SignalFD( const SignalMask & signals )
: fd_( SystemCall( "signalfd", signalfd( -1, &signals.mask(), 0 ) ) )
{
}
/* read one signal */
signalfd_siginfo SignalFD::read_signal( void )
{
signalfd_siginfo delivered_signal;
string delivered_signal_str = fd_.read( sizeof( signalfd_siginfo ) );
if ( delivered_signal_str.size() != sizeof( signalfd_siginfo ) ) {
throw Exception( "signalfd read size mismatch" );
}
memcpy( &delivered_signal, delivered_signal_str.data(), sizeof( signalfd_siginfo ) );
return delivered_signal;
}