heartbeat.h File Reference

#include "gwlib/gwlib.h"
#include "msg.h"

Go to the source code of this file.

Macros
#define	DEFAULT_HEARTBEAT   30
#define	ALL_HEARTBEATS   -1

Typedefs
typedef long	hb_load_func_t(void)
typedef void	hb_send_func_t(Msg *hb)

Functions
long	heartbeat_start (hb_send_func_t *send_func, double freq, hb_load_func_t *load_func)
void	heartbeat_stop (long hb_thread)

Macro Definition Documentation

ALL_HEARTBEATS

#define ALL_HEARTBEATS   -1

Definition at line 68 of file heartbeat.h.

Referenced by heartbeat_stop(), and main().

DEFAULT_HEARTBEAT

#define DEFAULT_HEARTBEAT   30

Definition at line 67 of file heartbeat.h.

Referenced by heartbeat_start(), main(), and run_smppbox().

Typedef Documentation

hb_load_func_t

typedef long hb_load_func_t(void)

Definition at line 72 of file heartbeat.h.

hb_send_func_t

typedef void hb_send_func_t(Msg *hb)

Definition at line 78 of file heartbeat.h.

Function Documentation

heartbeat_start()

long heartbeat_start	(	hb_send_func_t *	send_func,
		double	freq,
		hb_load_func_t *	load_func
	)

Definition at line 126 of file heartbeat.c.

References DEFAULT_HEARTBEAT, hb_info::freq, gwlist_append(), gwlist_create, gwthread_create, heartbeat_thread(), heartbeats, info(), hb_info::load_func, and hb_info::send_func.

Referenced by main(), and run_smppbox().

{
    struct hb_info *info;

    /* can't start with send_funct NULL */
    if (send_func == NULL)
        return -1;

    info = gw_malloc(sizeof(*info));
    info->send_func = send_func;
    info->freq = (freq <= 0 ? DEFAULT_HEARTBEAT : freq);
    info->load_func = load_func;
    info->running = 1;
    info->thread = gwthread_create(heartbeat_thread, info);
    if (info->thread >= 0) {
    if (heartbeats == NULL)
        heartbeats = gwlist_create();
    gwlist_append(heartbeats, info);
        return info->thread;
    } else {
        gw_free(info);
        return -1;
    }
}

heartbeat_stop()

void heartbeat_stop

(

long

hb_thread

)

Definition at line 160 of file heartbeat.c.

References ALL_HEARTBEATS, find_hb(), gw_assert(), gwlist_destroy(), gwlist_extract_first(), gwlist_extract_matching(), gwlist_len(), gwthread_join(), gwthread_wakeup(), heartbeats, info(), and warning().

Referenced by main().

{
    List *matching_info;
    struct hb_info *info;

    /*
     * First, check if there are heartbeats to stop.
     * If not, do not continue, otherwise this function will crash
     */
    if (heartbeats == NULL)
        return;

    if (hb_thread == ALL_HEARTBEATS) {
        while (NULL != (info = gwlist_extract_first(heartbeats))) {
            gw_assert(info);
            info->running = 0;
            gwthread_wakeup(info->thread);
            gwthread_join(info->thread);
            gw_free(info);
        }
    } else {
        matching_info = gwlist_extract_matching(heartbeats, &hb_thread, find_hb);
        if (matching_info == NULL) {
            warning(0, "Could not stop heartbeat %ld: not found.", hb_thread);
        return;
        }
        gw_assert(gwlist_len(matching_info) == 1);
        info = gwlist_extract_first(matching_info);
        gwlist_destroy(matching_info, NULL);
     
        info->running = 0;
        gwthread_wakeup(hb_thread);
        gwthread_join(hb_thread);
        gw_free(info);
    }
    if (gwlist_len(heartbeats) == 0) {
        gwlist_destroy(heartbeats, NULL);
        heartbeats = NULL;
    }
}