fixup annotate more functions

skupperproject · Dec 30, 2023 · 728f07e · 728f07e
1 parent 6f4cb90
commit 728f07e
Show file tree

Hide file tree

Showing 2 changed files with 5 additions and 5 deletions.
diff --git 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
@@ -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) {