Zabbix

/*

** Copyright (C) 2001-2025 Zabbix SIA

**

** This program is free software: you can redistribute it and/or modify it under the terms of

** the GNU Affero General Public License as published by the Free Software Foundation, version 3.

**

** This program is distributed in the hope that it will be useful, but WITHOUT ANY WARRANTY;

** without even the implied warranty of MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.

** See the GNU Affero General Public License for more details.

**

** You should have received a copy of the GNU Affero General Public License along with this program.

** If not, see <https://www.gnu.org/licenses/>.

**/

​

#include "zbxcacheconfig.h"

#include "dbsync.h"

#include "user_macro.h"

​

#include "zbx_host_constants.h"

#include "zbx_trigger_constants.h"

#include "zbxcrypto.h"

#include "zbxeval.h"

#include "zbxnum.h"

#include "zbxdbhigh.h"

#include "zbxexpr.h"

#include "zbxstr.h"

#include "zbxinterface.h"

#include "zbxip.h"

#include <stddef.h>

​

/* global correlation constants */

#define ZBX_CORRELATION_ENABLED             0

/*#define ZBX_CORRELATION_DISABLED          1*/

​

#define ZBX_DBSYNC_OBJ_HOST     1

#define ZBX_DBSYNC_OBJ_HOST_TAG     2

#define ZBX_DBSYNC_OBJ_ITEM     3

#define ZBX_DBSYNC_OBJ_ITEM_TAG     4

#define ZBX_DBSYNC_OBJ_TRIGGER      5

#define ZBX_DBSYNC_OBJ_TRIGGER_TAG  6

#define ZBX_DBSYNC_OBJ_FUNCTION     7

#define ZBX_DBSYNC_OBJ_ITEM_PREPROC 8

#define ZBX_DBSYNC_OBJ_DRULE        9

#define ZBX_DBSYNC_OBJ_DCHECK       10

#define ZBX_DBSYNC_OBJ_HTTPTEST     11

#define ZBX_DBSYNC_OBJ_HTTPTEST_FIELD   12

#define ZBX_DBSYNC_OBJ_HTTPTEST_ITEM    13

#define ZBX_DBSYNC_OBJ_HTTPSTEP     14

#define ZBX_DBSYNC_OBJ_HTTPSTEP_FIELD   15

#define ZBX_DBSYNC_OBJ_HTTPSTEP_ITEM    16

#define ZBX_DBSYNC_OBJ_CONNECTOR    17

#define ZBX_DBSYNC_OBJ_CONNECTOR_TAG    18

#define ZBX_DBSYNC_OBJ_PROXY        19

#define ZBX_DBSYNC_OBJ_PROXY_GROUP  20

#define ZBX_DBSYNC_OBJ_HOST_PROXY   21

/* number of dbsync objects - keep in sync with above defines */

#define ZBX_DBSYNC_OBJ_COUNT        21

​

#define ZBX_DBSYNC_JOURNAL(X)       (X - 1)

​

#define ZBX_DBSYNC_CHANGELOG_PRUNE_INTERVAL SEC_PER_MIN * 10

#define ZBX_DBSYNC_CHANGELOG_MAX_AGE        SEC_PER_HOUR

​

#define ZBX_DBSYNC_BATCH_SIZE           1000

​

typedef struct

{

    zbx_uint64_t    changelogid;

    int     clock;

}

zbx_dbsync_changelog_t;

​

ZBX_VECTOR_DECL(dbsync_changelog, zbx_dbsync_changelog_t)

ZBX_VECTOR_IMPL(dbsync_changelog, zbx_dbsync_changelog_t)

​

typedef struct

{

    zbx_uint64_t        objectid;

    zbx_dbsync_changelog_t  changelog;

}

zbx_dbsync_obj_changelog_t;

​

ZBX_VECTOR_DECL(dbsync_obj_changelog, zbx_dbsync_obj_changelog_t)

ZBX_VECTOR_IMPL(dbsync_obj_changelog, zbx_dbsync_obj_changelog_t)

​

ZBX_PTR_VECTOR_DECL(dbsync, zbx_dbsync_t *)

ZBX_PTR_VECTOR_IMPL(dbsync, zbx_dbsync_t *)

​

typedef struct

{

    zbx_vector_uint64_t         inserts;