summaryrefslogtreecommitdiff
path: root/controller/PostgreSQL.cpp
diff options
context:
space:
mode:
authorGrant Limberg <[email protected]>2022-06-16 10:50:07 -0700
committerGrant Limberg <[email protected]>2022-06-16 10:50:07 -0700
commit9de863e68b22be093efe856e38ed6c03ea1060de (patch)
treedc6a7cc4f34573ffb0d473a3d1e48095e810bf1b /controller/PostgreSQL.cpp
parent64b7f8e445f8e9a75a4b26dda3a62a36043de8bd (diff)
update controller db record
Diffstat (limited to 'controller/PostgreSQL.cpp')
-rw-r--r--controller/PostgreSQL.cpp5
1 files changed, 3 insertions, 2 deletions
diff --git a/controller/PostgreSQL.cpp b/controller/PostgreSQL.cpp
index a780520a..77c96480 100644
--- a/controller/PostgreSQL.cpp
+++ b/controller/PostgreSQL.cpp
@@ -968,15 +968,16 @@ void PostgreSQL::heartbeat()
std::string now = std::to_string(ts);
std::string host_port = std::to_string(_listenPort);
std::string use_redis = (_rc != NULL) ? "true" : "false";
+ std::string redis_mem_status = (_redisMemberStatus) ? "true" : "false";
try {
pqxx::result res = w.exec0("INSERT INTO ztc_controller (id, cluster_host, last_alive, public_identity, v_major, v_minor, v_rev, v_build, host_port, use_redis) "
"VALUES ("+w.quote(controllerId)+", "+w.quote(hostname)+", TO_TIMESTAMP("+now+"::double precision/1000), "+
- w.quote(publicIdentity)+", "+major+", "+minor+", "+rev+", "+build+", "+host_port+", "+use_redis+") "
+ w.quote(publicIdentity)+", "+major+", "+minor+", "+rev+", "+build+", "+host_port+", "+use_redis+", "+redis_mem_status+") "
"ON CONFLICT (id) DO UPDATE SET cluster_host = EXCLUDED.cluster_host, last_alive = EXCLUDED.last_alive, "
"public_identity = EXCLUDED.public_identity, v_major = EXCLUDED.v_major, v_minor = EXCLUDED.v_minor, "
"v_rev = EXCLUDED.v_rev, v_build = EXCLUDED.v_rev, host_port = EXCLUDED.host_port, "
- "use_redis = EXCLUDED.use_redis");
+ "use_redis = EXCLUDED.use_redis, redis_member_status = EXCLUDED.redis_member_status");
} catch (std::exception &e) {
fprintf(stderr, "Heartbeat update failed: %s\n", e.what());
w.abort();