[Project] Add preliminary support of the heartbeats

1 files changed, 8 insertions, 1 deletions

diff --git a/src/rspamd.h b/src/rspamd.h
index ea11965fb..3cd6c391b 100644
--- a/src/rspamd.h
+++ b/src/rspamd.h
@@ -76,6 +76,12 @@ struct rspamd_worker_accept_event {
 typedef void (*rspamd_worker_term_cb) (EV_P_ ev_child *, struct rspamd_main *,
 									   struct rspamd_worker *);
 
+struct rspamd_worker_heartbeat {
+	ev_timer heartbeat_ev;          /**< used by main for checking heartbeats and by workers to send heartbeats */
+	ev_tstamp last_event;
+	gint64 nbeats; /* positive for beats received, negative for beats missed */
+};
+
 /**
  * Worker process structure
  */
@@ -90,7 +96,7 @@ struct rspamd_worker {
 	struct rspamd_main *srv;        /**< pointer to server structure					*/
 	GQuark type;                    /**< process type									*/
 	GHashTable *signal_events;      /**< signal events									*/
-	struct rspamd_worker_accept_event *accept_events; /**< socket events									*/
+	struct rspamd_worker_accept_event *accept_events; /**< socket events				*/
 	struct rspamd_worker_conf *cf;  /**< worker config data								*/
 	gpointer ctx;                   /**< worker's specific data							*/
 	enum rspamd_worker_flags flags; /**< worker's flags									*/
@@ -99,6 +105,7 @@ struct rspamd_worker {
 	gint srv_pipe[2];               /**< used by workers to request something from the
 	                                     main process. [0] - main, [1] - worker			*/
 	ev_io srv_ev;                   /**< used by main for read workers' requests		*/
+	struct rspamd_worker_heartbeat hb; /**< heartbeat data */
 	gpointer control_data;          /**< used by control protocol to handle commands	*/
 	gpointer tmp_data;              /**< used to avoid race condition to deal with control messages */
 	GPtrArray *finish_actions;      /**< called when worker is terminated				*/