From 728f07ecce28c3e8afa5a0eb5f273ae5267774d1 Mon Sep 17 00:00:00 2001
From: =?UTF-8?q?Jiri=20Dan=C4=9Bk?= <jdanek@redhat.com>
Date: Sat, 30 Dec 2023 18:27:54 +0100
Subject: [PATCH] fixup annotate more functions

---
 src/log.c    | 4 ++--
 src/server.c | 6 +++---
 2 files changed, 5 insertions(+), 5 deletions(-)

diff --git a/src/log.c b/src/log.c
index 9f42516a1..68bfeca01 100644
--- a/src/log.c
+++ b/src/log.c
@@ -156,7 +156,7 @@ qd_log_module_t get_log_module_from_module_name(char *module_name)
     return -1;
 }
 
-static void qd_log_entry_free_lh(qd_log_entry_t *entry)
+static void qd_log_entry_free_lh(qd_log_entry_t *entry) TA_REQ(log_source_lock)
 {
     DEQ_REMOVE(entries, entry);
     free(entry->file);
@@ -461,7 +461,7 @@ bool qd_log_enabled(qd_log_module_t module, qd_log_level_t level)
     return level & mask;
 }
 
-bool log_enabled_lh(qd_log_source_t *source, qd_log_level_t level)
+bool log_enabled_lh(qd_log_source_t *source, qd_log_level_t level) TA_REQ(log_source_lock)
 {
     if (!source)
         return false;
diff --git a/src/server.c b/src/server.c
index 6039f4643..df286842e 100644
--- a/src/server.c
+++ b/src/server.c
@@ -979,7 +979,7 @@ static void startup_timer_handler(void *context)
     qd_connection_invoke_deferred(ctx, timeout_on_handshake, context);
 }
 
-static void qd_increment_conn_index_lh(qd_connection_t *ctx)
+static void qd_increment_conn_index_lh(qd_connection_t *ctx) TA_REQ(ctx->connector->lock)
 {
     if (ctx->connector) {
         qd_failover_item_t *item = qd_connector_get_conn_info_lh(ctx->connector);
@@ -1172,8 +1172,8 @@ static void *thread_run(void *arg)
 }
 
 
-static qd_failover_item_t *qd_connector_get_conn_info_lh(qd_connector_t *ct) {
-
+static qd_failover_item_t *qd_connector_get_conn_info_lh(qd_connector_t *ct) TA_REQ(ct->lock)
+{
     qd_failover_item_t *item = DEQ_HEAD(ct->conn_info_list);
 
     if (DEQ_SIZE(ct->conn_info_list) > 1) {