4
4
*/
5
5
6
6
#include <stdio.h>
7
- #include <signal.h>
8
7
#include <string.h>
9
8
#include <stdarg.h>
10
9
11
10
#include <libpq-fe.h>
12
11
#include "halt.h"
13
12
#include "pginterface.h"
14
13
15
- static void sig_disconnect ();
16
- static void set_signals ();
17
-
18
14
#define NUL '\0'
19
15
20
16
/* GLOBAL VARIABLES */
@@ -27,8 +23,6 @@ static PGresult *res = NULL;
27
23
static int on_error_state = ON_ERROR_STOP ;
28
24
29
25
/* LOCAL VARIABLES */
30
- static sigset_t block_sigs ,
31
- unblock_sigs ;
32
26
static int tuple ;
33
27
34
28
/*
@@ -48,7 +42,6 @@ connectdb(char *dbName,
48
42
if (PQstatus (conn ) == CONNECTION_BAD )
49
43
halt ("Connection to database '%s' failed.\n%s\n" , dbName ,
50
44
PQerrorMessage (conn ));
51
- set_signals ();
52
45
return conn ;
53
46
}
54
47
@@ -74,9 +67,7 @@ doquery(char *query)
74
67
if (res != NULL )
75
68
PQclear (res );
76
69
77
- sigprocmask (SIG_SETMASK , & block_sigs , NULL );
78
70
res = PQexec (conn , query );
79
- sigprocmask (SIG_SETMASK , & unblock_sigs , NULL );
80
71
81
72
if (on_error_state == ON_ERROR_STOP &&
82
73
(res == NULL ||
@@ -196,37 +187,3 @@ on_error_continue()
196
187
{
197
188
on_error_state = ON_ERROR_CONTINUE ;
198
189
}
199
-
200
- /*
201
- **
202
- ** sig_disconnect
203
- **
204
- */
205
- static void
206
- sig_disconnect ()
207
- {
208
- fprintf (stderr , "exiting...\n" );
209
- PQfinish (conn );
210
- exit (1 );
211
- }
212
-
213
- /*
214
- **
215
- ** set_signals
216
- **
217
- */
218
- static void
219
- set_signals ()
220
- {
221
- sigemptyset (& block_sigs );
222
- sigemptyset (& unblock_sigs );
223
- sigaddset (& block_sigs , SIGTERM );
224
- sigaddset (& block_sigs , SIGHUP );
225
- sigaddset (& block_sigs , SIGINT );
226
- /* sigaddset(&block_sigs,SIGQUIT); no block */
227
- sigprocmask (SIG_SETMASK , & unblock_sigs , NULL );
228
- signal (SIGTERM , sig_disconnect );
229
- signal (SIGHUP , sig_disconnect );
230
- signal (SIGINT , sig_disconnect );
231
- signal (SIGQUIT , sig_disconnect );
232
- }
0 commit comments