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 69 70 71 72 73 74 75 76 77 78 79 80 81 82 83 84 85 86 87 88 89 90 91 92 93 94 95 96 97 98 99 100 101 102 103 104 105
|
/**
* Signal Handling
*
* Copyright (C) 2000-2007 by
* Jeffrey Fulmer - <jeff@joedog.org>, et al.
* This file is distributed as part of Siege
*
* This program is free software; you can redistribute it and/or modify
* it under the terms of the GNU General Public License as published by
* the Free Software Foundation; either version 2 of the License, or
* (at your option) any later version.
*
* This program 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 General Public License for more details.
*
* You should have received a copy of the GNU General Public License
* along with this program; if not, write to the Free Software
* Foundation, Inc., 675 Mass Ave, Cambridge, MA 02139, USA.
* --
*
*/
#ifdef HAVE_CONFIG_H
# include <config.h>
#endif/*HAVE_CONFIG_H*/
#ifdef HAVE_PTHREAD_H
# include <pthread.h>
#endif/*HAVE_PTHREAD_H*/
#include <setup.h>
#include <handler.h>
#include <util.h>
#include <crew.h>
#include <joedog/boolean.h>
void
spin_doctor(CREW crew)
{
long x;
char h[4] = {'-','\\','|','/'};
if(my.spinner==FALSE){
return;
}
for(x = 0; crew_get_total(crew) > 1 || x < 55; x++){
fflush(stderr);
fprintf(stderr,"%c", h[x%4]);
pthread_usleep_np(20000);
fprintf(stderr, "\b");
}
return;
}
void
sig_handler(CREW crew)
{
int gotsig = 0;
sigset_t sigs;
#if defined (hpux) || defined(__hpux)
#else
int result;
pthread_t spinner;
#endif
sigemptyset(&sigs);
sigaddset(&sigs, SIGHUP);
sigaddset(&sigs, SIGINT);
sigaddset(&sigs, SIGTERM);
sigprocmask(SIG_BLOCK, &sigs, NULL);
/**
* Now wait around for something to happen ...
*/
sigwait(&sigs, &gotsig);
my.verbose = FALSE;
fprintf(stderr, "\nLifting the server siege...");
crew_set_shutdown(crew, TRUE);
#if defined (hpux) || defined(__hpux)
#else
if((result = pthread_create(&spinner, NULL, (void*)spin_doctor, crew)) < 0){
joe_error("failed to create handler: %d\n", result);
}
#endif
/**
* The signal consistently arrives early,
* so we artificially extend the life of
* the siege to make up the discrepancy.
*/
pthread_usleep_np(501125);
crew_cancel(crew);
#if defined(hpux) || defined(__hpux)
#else
pthread_join(spinner, NULL);
#endif
pthread_exit(NULL);
}
|