freebsd-dev/contrib/sendmail/libmilter/signal.c
2001-01-21 22:17:06 +00:00

216 lines
3.6 KiB
C
Raw Blame History

This file contains invisible Unicode characters

This file contains invisible Unicode characters that are indistinguishable to humans but may be processed differently by a computer. If you think that this is intentional, you can safely ignore this warning. Use the Escape button to reveal them.

/*
* Copyright (c) 1999-2000 Sendmail, Inc. and its suppliers.
* All rights reserved.
*
* By using this file, you agree to the terms and conditions set
* forth in the LICENSE file which can be found at the top level of
* the sendmail distribution.
*
*/
#ifndef lint
static char id[] = "@(#)$Id: signal.c,v 8.10.4.8 2000/11/20 21:15:37 ca Exp $";
#endif /* ! lint */
#if _FFR_MILTER
#include "libmilter.h"
/*
** thread to handle signals
*/
static smutex_t M_Mutex;
static int MilterStop = MILTER_CONT;
/*
** MI_STOP -- return value of MilterStop
**
** Parameters:
** none.
**
** Returns:
** value of MilterStop
*/
int
mi_stop()
{
return MilterStop;
}
/*
** MI_STOP_MILTERS -- set value of MilterStop
**
** Parameters:
** v -- new value for MilterStop.
**
** Returns:
** none.
*/
void
mi_stop_milters(v)
int v;
{
(void) smutex_lock(&M_Mutex);
if (MilterStop < v)
MilterStop = v;
/* close listen socket */
mi_closener();
(void) smutex_unlock(&M_Mutex);
}
/*
** MI_CLEAN_SIGNALS -- clean up signal handler thread
**
** Parameters:
** none.
**
** Returns:
** none.
*/
void
mi_clean_signals()
{
(void) smutex_destroy(&M_Mutex);
}
/*
** MI_SIGNAL_THREAD -- thread to deal with signals
**
** Parameters:
** name -- name of milter
**
** Returns:
** NULL
*/
static void *
mi_signal_thread(name)
void *name;
{
int sig, errs;
sigset_t set;
sigemptyset(&set);
sigaddset(&set, SIGHUP);
sigaddset(&set, SIGTERM);
/* Handle Ctrl-C gracefully for debugging */
sigaddset(&set, SIGINT);
errs = 0;
while (TRUE)
{
sig = 0;
#ifdef SOLARIS
if ((sig = sigwait(&set)) < 0)
#else /* SOLARIS */
if (sigwait(&set, &sig) != 0)
#endif /* SOLARIS */
{
smi_log(SMI_LOG_ERR,
"%s: sigwait returned error: %s",
(char *)name, strerror(errno));
if (++errs > MAX_FAILS_T)
{
mi_stop_milters(MILTER_ABRT);
return NULL;
}
continue;
}
errs = 0;
switch (sig)
{
case SIGHUP:
case SIGTERM:
mi_stop_milters(MILTER_STOP);
return NULL;
case SIGINT:
mi_stop_milters(MILTER_ABRT);
return NULL;
default:
smi_log(SMI_LOG_ERR,
"%s: sigwait returned unmasked signal: %d",
(char *)name, sig);
break;
}
}
}
/*
** MI_SPAWN_SIGNAL_THREAD -- spawn thread to handle signals
**
** Parameters:
** name -- name of milter
**
** Returns:
** MI_SUCCESS/MI_FAILURE
*/
static int
mi_spawn_signal_thread(name)
char *name;
{
sthread_t tid;
sigset_t set;
/* Mask HUP and KILL signals */
sigemptyset(&set);
sigaddset(&set, SIGHUP);
sigaddset(&set, SIGTERM);
sigaddset(&set, SIGINT);
if (pthread_sigmask(SIG_BLOCK, &set, NULL) != 0)
{
smi_log(SMI_LOG_ERR,
"%s: Couldn't mask HUP and KILL signals", name);
return MI_FAILURE;
}
if (thread_create(&tid, mi_signal_thread,
(void *)name) != MI_SUCCESS)
{
smi_log(SMI_LOG_ERR,
"%s: Couldn't start signal thread", name);
return MI_FAILURE;
}
return MI_SUCCESS;
}
/*
** MI_CONTROL_STARTUP -- startup for thread to handle signals
**
** Parameters:
** name -- name of milter
**
** Returns:
** MI_SUCCESS/MI_FAILURE
*/
int
mi_control_startup(name)
char *name;
{
if (!smutex_init(&M_Mutex))
{
smi_log(SMI_LOG_ERR,
"%s: Couldn't initialize control pipe mutex", name);
return MI_FAILURE;
}
/*
** spawn_signal_thread must happen before other threads are spawned
** off so that it can mask the right signals and other threads
** will inherit that mask.
*/
if (mi_spawn_signal_thread(name) == MI_FAILURE)
{
smi_log(SMI_LOG_ERR,
"%s: Couldn't spawn signal thread", name);
(void) smutex_destroy(&M_Mutex);
return MI_FAILURE;
}
return MI_SUCCESS;
}
#endif /* _FFR_MILTER */