server session NEW function for checking CH client and endpt existence

Author: michalvasko

src/session_server.c

@@ -1989,6 +1989,10 @@ nc_server_is_endpt(const char *name)
     uint16_t i;
     int found = 0;
 
+    if (!name) {
+        return found;
+    }
+
     /* ENDPT READ LOCK */
     pthread_rwlock_rdlock(&server_opts.endpt_lock);
 
@@ -2532,6 +2536,33 @@ nc_server_ch_del_client(const char *name)
     return ret;
 }
 
+API int
+nc_server_ch_is_client(const char *name)
+{
+    uint16_t i;
+    int found = 0;
+
+    if (!name) {
+        return found;
+    }
+
+    /* READ LOCK */
+    pthread_rwlock_rdlock(&server_opts.ch_client_lock);
+
+    /* check name uniqueness */
+    for (i = 0; i < server_opts.ch_client_count; ++i) {
+        if (!strcmp(server_opts.ch_clients[i].name, name)) {
+            found = 1;
+            break;
+        }
+    }
+
+    /* UNLOCK */
+    pthread_rwlock_unlock(&server_opts.ch_client_lock);
+
+    return found;
+}
+
 API int
 nc_server_ch_client_add_endpt(const char *client_name, const char *endpt_name, NC_TRANSPORT_IMPL ti)
 {
@@ -2642,6 +2673,44 @@ nc_server_ch_client_del_endpt(const char *client_name, const char *endpt_name, N
     return ret;
 }
 
+API int
+nc_server_ch_client_is_endpt(const char *client_name, const char *endpt_name)
+{
+    uint16_t i;
+    struct nc_ch_client *client = NULL;
+    int found = 0;
+
+    if (!client_name || !endpt_name) {
+        return found;
+    }
+
+    /* READ LOCK */
+    pthread_rwlock_rdlock(&server_opts.ch_client_lock);
+
+    for (i = 0; i < server_opts.ch_client_count; ++i) {
+        if (!strcmp(server_opts.ch_clients[i].name, client_name)) {
+            client = &server_opts.ch_clients[i];
+            break;
+        }
+    }
+
+    if (!client) {
+        goto cleanup;
+    }
+
+    for (i = 0; i < client->ch_endpt_count; ++i) {
+        if (!strcmp(client->ch_endpts[i].name, endpt_name)) {
+            found = 1;
+            break;
+        }
+    }
+
+cleanup:
+    /* UNLOCK */
+    pthread_rwlock_unlock(&server_opts.ch_client_lock);
+    return found;
+}
+
 API int
 nc_server_ch_client_endpt_set_address(const char *client_name, const char *endpt_name, const char *address)
 {

src/session_server_ch.h

@@ -51,6 +51,14 @@ int nc_server_ch_add_client(const char *name);
  */
 int nc_server_ch_del_client(const char *name);
 
+/**
+ * @brief Check if a Call Home client exists.
+ *
+ * @param[in] name Client name.
+ * @return 0 if does not exists, non-zero otherwise.
+ */
+int nc_server_ch_is_client(const char *name);
+
 /**
  * @brief Add a new Call Home client endpoint.
  *
@@ -73,6 +81,15 @@ int nc_server_ch_client_add_endpt(const char *client_name, const char *endpt_nam
  */
 int nc_server_ch_client_del_endpt(const char *client_name, const char *endpt_name, NC_TRANSPORT_IMPL ti);
 
+/**
+ * @brief Check if an endpoint of a Call Home client exists.
+ *
+ * @param[in] client_name Client name.
+ * @param[in] endpt_name Endpoint name.
+ * @return 0 if does not exists, non-zero otherwise.
+ */
+int nc_server_ch_client_is_endpt(const char *client_name, const char *endpt_name);
+
 /**
  * @brief Change Call Home client endpoint listening address.
  *