hackedteam/core-linux

#ifndef    H_RPMSQ
#define    H_RPMSQ

/** \ingroup rpmio
 * \file rpmio/rpmsq.h
 *
 */

#include <rpm/rpmsw.h>
#include <signal.h>
#if defined(_RPMSQ_INTERNAL)
#include <pthread.h>
#endif

#ifdef __cplusplus
extern "C" {
#endif

/** \ingroup rpmsq
 */
typedef struct rpmsig_s * rpmsig;

/** \ingroup rpmsq
 */
typedef struct rpmsqElem * rpmsq;

/** \ingroup rpmsq
 * Default signal handler prototype.
 * @param signum    signal number
 * @param info        (siginfo_t) signal info
 * @param context    signal context
 */
#ifdef SA_SIGINFO
typedef void (*rpmsqAction_t) (int signum, siginfo_t * info, void * context);
#else
typedef void (*rpmsqAction_t) (int signum);
#endif

/* XXX make this fully opaque? */
#if defined(_RPMSQ_INTERNAL)
/**
 * SIGCHLD queue element.
 */
struct rpmsqElem {
    struct rpmsqElem * q_forw;    /*!< for use by insque(3)/remque(3). */
    struct rpmsqElem * q_back;
    pid_t child;        /*!< Currently running child. */
    volatile pid_t reaped;    /*!< Reaped waitpid(3) return. */
    volatile int status;    /*!< Reaped waitpid(3) status. */
    struct rpmop_s op;        /*!< Scriptlet operation timestamp; */
    rpmtime_t ms_scriptlets;    /*!< Accumulated script duration (msecs). */
    int reaper;            /*!< Register SIGCHLD handler? */
    int pipes[2];        /*!< Parent/child interlock. */
    void * id;            /*!< Blocking thread id (pthread_t). */
    pthread_mutex_t mutex;    /*!< Signal delivery to thread condvar. */
    pthread_cond_t cond;
};
#endif /* _RPMSQ_INTERNAL */

/** \ingroup rpmsq
 * Test if given signal has been caught (while signals blocked).
 * Similar to sigismember() but operates on internal signal queue.
 * @param signum    signal to test for
 * @return        1 if caught, 0 if not and -1 on error
 */
int rpmsqIsCaught(int signum);

/** \ingroup rpmsq
 * Default signal handler.
 * @param signum    signal number
 * @param info        (siginfo_t) signal info
 * @param context    signal context
 */
#ifdef SA_SIGINFO
void rpmsqAction(int signum, siginfo_t * info, void * context);
#else
void rpmsqAction(int signum);
#endif

/** \ingroup rpmsq
 * Enable or disable a signal handler.
 * @param signum    signal to enable (or disable if negative)
 * @param handler    sa_sigaction handler (or NULL to use rpmsqHandler())
 * @return        no. of refs, -1 on error
 */
int rpmsqEnable(int signum, rpmsqAction_t handler);

/** \ingroup rpmsq
 * Fork a child process.
 * @param sq        scriptlet queue element
 * @return        fork(2) pid
 */
pid_t rpmsqFork(rpmsq sq);

/** \ingroup rpmsq
 * Wait for child process to be reaped.
 * @param sq        scriptlet queue element
 * @return        reaped child pid
 */
pid_t rpmsqWait(rpmsq sq);

#ifdef __cplusplus
}
#endif

#endif    /* H_RPMSQ */