rpmio/rpmsq.c File Reference

#include "system.h"
#include <signal.h>
#include <sys/signal.h>
#include <sys/wait.h>
#include <search.h>
#include <pthread.h>
#include <rpmsq.h>
#include "debug.h"

Go to the source code of this file.

Data Structures
struct	rpmsig_s
Defines
#define	DO_LOCK() pthread_mutex_lock(&rpmsigTbl_lock);
#define	DO_UNLOCK() pthread_mutex_unlock(&rpmsigTbl_lock);
#define	INIT_LOCK()
#define	ADD_REF(__tbl) (__tbl)->active++
#define	SUB_REF(__tbl) --(__tbl)->active
#define	CLEANUP_HANDLER(__handler, __arg, __oldtypeptr)
#define	CLEANUP_RESET(__execute, __oldtype)
#define	SAME_THREAD(_a, _b) pthread_equal(((pthread_t)_a), ((pthread_t)_b))
#define	ME() ((void *)pthread_self())
#define	_RPMSQ_DEBUG 0
#define	rpmsigTbl_sigint (&rpmsigTbl[0])
#define	rpmsigTbl_sigquit (&rpmsigTbl[1])
#define	rpmsigTbl_sigchld (&rpmsigTbl[2])
#define	rpmsigTbl_sighup (&rpmsigTbl[3])
#define	rpmsigTbl_sigterm (&rpmsigTbl[4])
#define	rpmsigTbl_sigpipe (&rpmsigTbl[5])
Functions
int	rpmsqInsert (void elem, void prev)
	Insert node into from queue.
int	rpmsqRemove (void *elem)
	Remove node from queue.
void	rpmsqAction (int signum, void info, void context)
	Default signal handler.
int	rpmsqEnable (int signum, rpmsqAction_t handler)
	Enable or disable a signal handler.
pid_t	rpmsqFork (rpmsq sq)
	Fork a child process.
static int	rpmsqWaitUnregister (rpmsq sq)
	Wait for child process to be reaped, and unregister SIGCHLD handler.
pid_t	rpmsqWait (rpmsq sq)
	Wait for child process to be reaped.
void *	rpmsqThread (void (start)(void arg), void arg)
	Call a function in a thread.
int	rpmsqJoin (void *thread)
	Wait for thread to terminate.
int	rpmsqThreadEqual (void *thread)
	Compare thread with current thread.
static void	sigchld_cancel (void *arg)
	SIGCHLD cancellation handler.
int	rpmsqExecve (const char **argv)
	Execute a command, returning its status.
Variables
static pthread_mutex_t	rpmsigTbl_lock = PTHREAD_MUTEX_INITIALIZER
int	_rpmsq_debug = 0
static struct rpmsqElem	rpmsqRock
rpmsq	rpmsqQueue = &rpmsqRock
sigset_t	rpmsqCaught
static struct rpmsig_s	rpmsigTbl []

Detailed Description

Definition in file rpmsq.c.

Define Documentation

#define _RPMSQ_DEBUG 0

Definition at line 187 of file rpmsq.c.

#define ADD_REF ( __tbl ) (__tbl)->active++

Definition at line 154 of file rpmsq.c.

Referenced by rpmsqEnable(), and rpmsqExecve().

#define CLEANUP_HANDLER	(	__handler,
		__arg,
		__oldtypeptr	)

Value:

(void) pthread_setcanceltype (PTHREAD_CANCEL_ASYNCHRONOUS, (__oldtypeptr));\
        pthread_cleanup_push((__handler), (__arg));

Definition at line 156 of file rpmsq.c.

Referenced by rpmsqExecve().

#define CLEANUP_RESET	(	__execute,
		__oldtype		)

Value:

pthread_cleanup_pop(__execute); \
    (void) pthread_setcanceltype ((__oldtype), &(__oldtype));

Definition at line 159 of file rpmsq.c.

Referenced by rpmsqExecve().

#define DO_LOCK ( ) pthread_mutex_lock(&rpmsigTbl_lock);

Definition at line 144 of file rpmsq.c.

Referenced by rpmsqEnable(), rpmsqExecve(), and sigchld_cancel().

#define DO_UNLOCK ( ) pthread_mutex_unlock(&rpmsigTbl_lock);

Definition at line 145 of file rpmsq.c.

Referenced by rpmsqEnable(), rpmsqExecve(), and sigchld_cancel().

#define INIT_LOCK ( )

Value:

{       pthread_mutexattr_t attr; \
        (void) pthread_mutexattr_init(&attr); \
        (void) pthread_mutexattr_settype(&attr, PTHREAD_MUTEX_RECURSIVE); \
        (void) pthread_mutex_init (&rpmsigTbl_lock, &attr); \
        (void) pthread_mutexattr_destroy(&attr); \
        rpmsigTbl_sigchld->active = 0; \
    }

Definition at line 146 of file rpmsq.c.

Referenced by rpmsqExecve().

#define ME ( ) ((void *)pthread_self())

Definition at line 165 of file rpmsq.c.

Referenced by rpmsqEnable(), rpmsqFork(), rpmsqInsert(), rpmsqRemove(), rpmsqWait(), and rpmsqWaitUnregister().