fis-gtm/sr_port/gtmsource_heartbeat.h

/****************************************************************
 *								*
 *	Copyright 2001, 2013 Fidelity Information Services, Inc	*
 *								*
 *	This source code contains the intellectual property	*
 *	of its copyright holder(s), and is made available	*
 *	under a license.  If you do not know the terms of	*
 *	the license, please stop and do not read further.	*
 *								*
 ****************************************************************/

#ifndef GTMSOURCE_HEARTBEAT_H
#define GTMSOURCE_HEARTBEAT_H

#define gtmsource_is_heartbeat_stalled	(heartbeat_stalled)

#ifndef REPL_DISABLE_HEARTBEAT
#define GTMSOURCE_IS_HEARTBEAT_DUE(NOW)												\
	(0 != last_sent_time													\
	 && difftime(*(NOW), last_sent_time) >= (double)jnlpool.gtmsource_local->connect_parms[GTMSOURCE_CONN_HEARTBEAT_PERIOD])
#else
#define GTMSOURCE_IS_HEARTBEAT_DUE(NOW) FALSE
#endif

GBLREF	boolean_t			heartbeat_stalled;
GBLREF	repl_heartbeat_que_entry_t	*repl_heartbeat_que_head;
GBLREF	repl_heartbeat_que_entry_t	*repl_heartbeat_free_head;
GBLREF	time_t				last_sent_time;
GBLREF	time_t				earliest_sent_time;

void gtmsource_heartbeat_timer(TID tid, int4 interval_len, int *interval_ptr);

#endif /* GTMSOURCE_HEARTBEAT_H */