34 lines
1.2 KiB
C
34 lines
1.2 KiB
C
/****************************************************************
|
|
* *
|
|
* 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 */
|