]> git.proxmox.com Git - mirror_frr.git/commitdiff
mgmtd: Fixing style warnings
authorrgirada <rgirada@vmware.com>
Tue, 28 Mar 2023 11:13:47 +0000 (11:13 +0000)
committerrgirada <rgirada@vmware.com>
Wed, 5 Apr 2023 10:30:24 +0000 (10:30 +0000)
Description:
Fixing the style warnings in the mgmtd code.

Signed-off-by: Rajesh Girada <rgirada@vmware.com>
lib/mgmt_be_client.c
lib/mgmt_fe_client.c
mgmtd/mgmt_be_adapter.c
mgmtd/mgmt_ds.c
mgmtd/mgmt_fe_adapter.c
mgmtd/mgmt_history.c
mgmtd/mgmt_history.h
mgmtd/mgmt_txn.c
mgmtd/mgmt_vty.c

index 36c78052bcfaf9b9c3244d70ce35b24f2aa3d2ee..7437eedfc7d81bcf40987883df7f0519c355ef72 100644 (file)
 #include "sockopt.h"
 
 #ifdef REDIRECT_DEBUG_TO_STDERR
-#define MGMTD_BE_CLIENT_DBG(fmt, ...)                                         \
+#define MGMTD_BE_CLIENT_DBG(fmt, ...)                                          \
        fprintf(stderr, "%s: " fmt "\n", __func__, ##__VA_ARGS__)
-#define MGMTD_BE_CLIENT_ERR(fmt, ...)                                         \
+#define MGMTD_BE_CLIENT_ERR(fmt, ...)                                          \
        fprintf(stderr, "%s: ERROR, " fmt "\n", __func__, ##__VA_ARGS__)
 #else /* REDIRECT_DEBUG_TO_STDERR */
-#define MGMTD_BE_CLIENT_DBG(fmt, ...)                                         \
+#define MGMTD_BE_CLIENT_DBG(fmt, ...)                                          \
        do {                                                                   \
-               if (mgmt_debug_be_client)                                     \
-                       zlog_debug("%s: " fmt, __func__, ##__VA_ARGS__);         \
+               if (mgmt_debug_be_client)                                      \
+                       zlog_debug("%s: " fmt, __func__, ##__VA_ARGS__);       \
        } while (0)
-#define MGMTD_BE_CLIENT_ERR(fmt, ...)                                         \
+#define MGMTD_BE_CLIENT_ERR(fmt, ...)                                          \
        zlog_err("%s: ERROR: " fmt, __func__, ##__VA_ARGS__)
 #endif /* REDIRECT_DEBUG_TO_STDERR */
 
@@ -597,7 +597,8 @@ static int mgmt_be_txn_cfg_prepare(struct mgmt_be_txn_ctx *txn)
                MGMTD_BE_CLIENT_DBG(
                        "Avg-nb-edit-duration %lu uSec, nb-prep-duration %lu (avg: %lu) uSec, batch size %u",
                        client_ctx->avg_edit_nb_cfg_tm, prep_nb_cfg_tm,
-                       client_ctx->avg_prep_nb_cfg_tm, (uint32_t)num_processed);
+                       client_ctx->avg_prep_nb_cfg_tm,
+                       (uint32_t)num_processed);
 
        if (error)
                mgmt_be_txn_cfg_abort(txn);
index a2c4fd6572a75878ead0f242491b7d6ac38d0bea..7cb9aa3defdee7272e5bab046a41830e4a9631c1 100644 (file)
@@ -109,8 +109,8 @@ mgmt_fe_find_session_by_session_id(struct mgmt_fe_client_ctx *client_ctx,
        FOREACH_SESSION_IN_LIST (client_ctx, session) {
                if (session->session_id == session_id) {
                        MGMTD_FE_CLIENT_DBG(
-                               "Found session %p for session-id %llu.", session,
-                               (unsigned long long)session_id);
+                               "Found session %p for session-id %llu.",
+                               session, (unsigned long long)session_id);
                        return session;
                }
        }
@@ -274,7 +274,8 @@ mgmt_fe_send_lockds_req(struct mgmt_fe_client_ctx *client_ctx,
 
        MGMTD_FE_CLIENT_DBG(
                "Sending %sLOCK_REQ message for Ds:%d session %llu to MGMTD Frontend server",
-               lock ? "" : "UN", ds_id, (unsigned long long)session->client_id);
+               lock ? "" : "UN", ds_id,
+               (unsigned long long)session->client_id);
 
        return mgmt_fe_client_send_msg(client_ctx, &fe_msg);
 }
@@ -310,12 +311,12 @@ mgmt_fe_send_setcfg_req(struct mgmt_fe_client_ctx *client_ctx,
        return mgmt_fe_client_send_msg(client_ctx, &fe_msg);
 }
 
-static int
-mgmt_fe_send_commitcfg_req(struct mgmt_fe_client_ctx *client_ctx,
-                              struct mgmt_fe_client_session *session,
-                              uint64_t req_id, Mgmtd__DatastoreId src_ds_id,
-                              Mgmtd__DatastoreId dest_ds_id, bool validate_only,
-                              bool abort)
+static int mgmt_fe_send_commitcfg_req(struct mgmt_fe_client_ctx *client_ctx,
+                                     struct mgmt_fe_client_session *session,
+                                     uint64_t req_id,
+                                     Mgmtd__DatastoreId src_ds_id,
+                                     Mgmtd__DatastoreId dest_ds_id,
+                                     bool validate_only, bool abort)
 {
        (void)req_id;
        Mgmtd__FeMessage fe_msg;
@@ -450,15 +451,17 @@ mgmt_fe_client_handle_msg(struct mgmt_fe_client_ctx *client_ctx,
                        if (session && fe_msg->session_reply->success) {
                                MGMTD_FE_CLIENT_DBG(
                                        "Session Create for client-id %llu successful.",
-                                       (unsigned long long)fe_msg
-                                               ->session_reply->client_conn_id);
+                                       (unsigned long long)
+                                               fe_msg->session_reply
+                                                       ->client_conn_id);
                                session->session_id =
                                        fe_msg->session_reply->session_id;
                        } else {
                                MGMTD_FE_CLIENT_ERR(
                                        "Session Create for client-id %llu failed.",
-                                       (unsigned long long)fe_msg
-                                               ->session_reply->client_conn_id);
+                                       (unsigned long long)
+                                               fe_msg->session_reply
+                                                       ->client_conn_id);
                        }
                } else if (!fe_msg->session_reply->create) {
                        MGMTD_FE_CLIENT_DBG(
index af43cf3eae3bca04e5d9eb5ac16f15068882498e..cf7d705943b53d531adf8a007d9e35f52943ae35 100644 (file)
@@ -80,23 +80,23 @@ static const struct mgmt_be_xpath_map_reg xpath_static_map_reg[] = {
         .be_clients =
                 (enum mgmt_be_client_id[]){
 #if HAVE_STATICD
-                MGMTD_BE_CLIENT_ID_STATICD,
+                        MGMTD_BE_CLIENT_ID_STATICD,
 #endif
                         MGMTD_BE_CLIENT_ID_MAX}},
        {.xpath_regexp = "/frr-interface:lib/*",
         .be_clients =
                 (enum mgmt_be_client_id[]){
 #if HAVE_STATICD
-                MGMTD_BE_CLIENT_ID_STATICD,
+                        MGMTD_BE_CLIENT_ID_STATICD,
 #endif
                         MGMTD_BE_CLIENT_ID_MAX}},
        {.xpath_regexp =
-                "/frr-routing:routing/control-plane-protocols/control-plane-protocol[type='frr-staticd:staticd'][name='staticd'][vrf='default']/frr-staticd:staticd/*",
+               "/frr-routing:routing/control-plane-protocols/control-plane-protocol[type='frr-staticd:staticd'][name='staticd'][vrf='default']/frr-staticd:staticd/*",
 
         .be_clients =
                 (enum mgmt_be_client_id[]){
 #if HAVE_STATICD
-                MGMTD_BE_CLIENT_ID_STATICD,
+                        MGMTD_BE_CLIENT_ID_STATICD,
 #endif
                         MGMTD_BE_CLIENT_ID_MAX}},
 };
@@ -347,8 +347,8 @@ mgmt_be_adapter_cleanup_old_conn(struct mgmt_be_client_adapter *adapter)
        struct mgmt_be_client_adapter *old;
 
        FOREACH_ADAPTER_IN_LIST (old) {
-               if (old != adapter
-                   && !strncmp(adapter->name, old->name, sizeof(adapter->name))) {
+               if (old != adapter &&
+                   !strncmp(adapter->name, old->name, sizeof(adapter->name))) {
                        /*
                         * We have a Zombie lingering around
                         */
index b41b9d23d351db336685bbf9b2b68d06c8790f7d..58c49b8789e067578b5e56503da3e075344aceb2 100644 (file)
@@ -174,6 +174,7 @@ static int mgmt_ds_load_cfg_from_file(const char *filepath,
 void mgmt_ds_reset_candidate(void)
 {
        struct lyd_node *dnode = mm->candidate_ds->root.cfg_root->dnode;
+
        if (dnode)
                yang_dnode_free(dnode);
 
index 5826b17de7a6a1125661268d60e14cfaa89894b4..90e6870fd45b1ce41723ab1b5617f36090a85b05 100644 (file)
@@ -495,7 +495,8 @@ static int mgmt_fe_send_setcfg_reply(struct mgmt_fe_session_ctx *session,
 
        if (implicit_commit) {
                if (mm->perf_stats_en)
-                       gettimeofday(&session->adapter->cmt_stats.last_end, NULL);
+                       gettimeofday(&session->adapter->cmt_stats.last_end,
+                                    NULL);
                mgmt_fe_session_compute_commit_timers(
                        &session->adapter->cmt_stats);
        }
@@ -715,8 +716,8 @@ mgmt_fe_adapter_cleanup_old_conn(struct mgmt_fe_client_adapter *adapter)
        struct mgmt_fe_client_adapter *old;
 
        FOREACH_ADAPTER_IN_LIST (old) {
-               if (old != adapter
-                   && !strncmp(adapter->name, old->name, sizeof(adapter->name))) {
+               if (old != adapter &&
+                   !strncmp(adapter->name, old->name, sizeof(adapter->name))) {
                        /*
                         * We have a Zombie lingering around
                         */
@@ -1109,8 +1110,8 @@ mgmt_fe_session_handle_getdata_req_msg(struct mgmt_fe_session_ctx *session,
                                                  MGMTD_TXN_TYPE_SHOW);
                if (session->txn_id == MGMTD_SESSION_ID_NONE) {
                        mgmt_fe_send_getdata_reply(
-                               session, getdata_req->ds_id, getdata_req->req_id,
-                               false, NULL,
+                               session, getdata_req->ds_id,
+                               getdata_req->req_id, false, NULL,
                                "Failed to create a Show transaction!");
                        goto mgmt_fe_sess_handle_getdata_req_failed;
                }
@@ -1780,8 +1781,8 @@ mgmt_fe_adapter_cmt_stats_write(struct vty *vty,
                                        sizeof(buf)));
                        vty_out(vty, "        Apply-Config Start: \t\t%s\n",
                                mgmt_realtime_to_string(
-                                       &adapter->cmt_stats.apply_cfg_start, buf,
-                                       sizeof(buf)));
+                                       &adapter->cmt_stats.apply_cfg_start,
+                                       buf, sizeof(buf)));
                        vty_out(vty, "        Apply-Config End: \t\t%s\n",
                                mgmt_realtime_to_string(
                                        &adapter->cmt_stats.apply_cfg_end, buf,
@@ -1818,8 +1819,9 @@ mgmt_fe_adapter_setcfg_stats_write(struct vty *vty,
                        adapter->setcfg_stats.avg_tm);
                vty_out(vty, "    Last-Set-Cfg-Details:\n");
                vty_out(vty, "      Set-Cfg Start: \t\t\t%s\n",
-                       mgmt_realtime_to_string(&adapter->setcfg_stats.last_start,
-                                               buf, sizeof(buf)));
+                       mgmt_realtime_to_string(
+                               &adapter->setcfg_stats.last_start, buf,
+                               sizeof(buf)));
                vty_out(vty, "      Set-Cfg End: \t\t\t%s\n",
                        mgmt_realtime_to_string(&adapter->setcfg_stats.last_end,
                                                buf, sizeof(buf)));
@@ -1894,9 +1896,11 @@ void mgmt_fe_adapter_reset_perf_stats(struct vty *vty)
        struct mgmt_fe_session_ctx *session;
 
        FOREACH_ADAPTER_IN_LIST (adapter) {
-               memset(&adapter->setcfg_stats, 0, sizeof(adapter->setcfg_stats));
+               memset(&adapter->setcfg_stats, 0,
+                      sizeof(adapter->setcfg_stats));
                FOREACH_SESSION_IN_LIST (adapter, session) {
-                       memset(&adapter->cmt_stats, 0, sizeof(adapter->cmt_stats));
+                       memset(&adapter->cmt_stats, 0,
+                              sizeof(adapter->cmt_stats));
                }
        }
 }
index 533b68628eebe4be8513835e6d1d7949b884b5b4..2251c49f1c1364b3f4e4182b730cbe6dc0edcb30 100644 (file)
@@ -33,7 +33,7 @@ DECLARE_DLIST(mgmt_cmt_infos, struct mgmt_cmt_info_t, cmts);
  * The only instance of VTY session that has triggered an ongoing
  * config rollback operation.
  */
-static struct vty *rollback_vty = NULL;
+static struct vty *rollback_vty;
 
 static bool mgmt_history_record_exists(char *file_path)
 {
@@ -100,7 +100,8 @@ static struct mgmt_cmt_info_t *mgmt_history_create_cmt_rec(void)
        return new;
 }
 
-static struct mgmt_cmt_info_t *mgmt_history_find_cmt_record(const char *cmtid_str)
+static struct mgmt_cmt_info_t *
+mgmt_history_find_cmt_record(const char *cmtid_str)
 {
        struct mgmt_cmt_info_t *cmt_info;
 
@@ -129,7 +130,8 @@ static bool mgmt_history_read_cmt_record_index(void)
 
        while ((fread(&cmt_info, sizeof(cmt_info), 1, fp)) > 0) {
                if (cnt < MGMTD_MAX_COMMIT_LIST) {
-                       if (!mgmt_history_record_exists(cmt_info.cmt_json_file)) {
+                       if (!mgmt_history_record_exists(
+                                   cmt_info.cmt_json_file)) {
                                zlog_err(
                                        "Commit record present in index_file, but commit file %s missing",
                                        cmt_info.cmt_json_file);
@@ -282,7 +284,8 @@ int mgmt_history_rollback_by_id(struct vty *vty, const char *cmtid_str)
        FOREACH_CMT_REC (mm, cmt_info) {
                if (strncmp(cmt_info->cmtid_str, cmtid_str,
                            MGMTD_MD5_HASH_STR_HEX_LEN) == 0) {
-                       ret = mgmt_history_rollback_to_cmt(vty, cmt_info, false);
+                       ret = mgmt_history_rollback_to_cmt(vty, cmt_info,
+                                                          false);
                        return ret;
                }
 
@@ -321,7 +324,8 @@ int mgmt_history_rollback_n(struct vty *vty, int num_cmts)
 
        FOREACH_CMT_REC (mm, cmt_info) {
                if (cnt == num_cmts) {
-                       ret = mgmt_history_rollback_to_cmt(vty, cmt_info, false);
+                       ret = mgmt_history_rollback_to_cmt(vty, cmt_info,
+                                                          false);
                        return ret;
                }
 
@@ -356,6 +360,7 @@ void show_mgmt_cmt_history(struct vty *vty)
 void mgmt_history_new_record(struct mgmt_ds_ctx *ds_ctx)
 {
        struct mgmt_cmt_info_t *cmt_info = mgmt_history_create_cmt_rec();
+
        mgmt_ds_dump_ds_to_file(cmt_info->cmt_json_file, ds_ctx);
        mgmt_history_dump_cmt_record_index();
 }
index 29a1d7738ea9a6357b2166123a82d1c398618338..5f96cf90e1c630d686960f380da1aab71cfd8c20 100644 (file)
@@ -1,10 +1,10 @@
 // SPDX-License-Identifier: GPL-2.0-or-later
 /*
 * Copyright (C) 2021  Vmware, Inc.
 *                   Pushpasis Sarkar <spushpasis@vmware.com>
 * Copyright (c) 2023, LabN Consulting, L.L.C.
 *
 */
+ * Copyright (C) 2021  Vmware, Inc.
                   Pushpasis Sarkar <spushpasis@vmware.com>
+ * Copyright (c) 2023, LabN Consulting, L.L.C.
+ *
+ */
 #ifndef _FRR_MGMTD_HISTORY_H_
 #define _FRR_MGMTD_HISTORY_H_
 
index 25943ff742441b18fb53c79246bb71a31a9a2693..2ba0cb413a1251f2fb3bc000fcd6d3fb563dff08 100644 (file)
@@ -1258,6 +1258,7 @@ static int mgmt_txn_prepare_config(struct mgmt_txn_ctx *txn)
        char err_buf[1024] = {0};
        nb_ctx.client = NB_CLIENT_MGMTD_SERVER;
        nb_ctx.user = (void *)txn;
+
        ret = nb_candidate_validate_yang(nb_config, false, err_buf,
                                         sizeof(err_buf) - 1);
        if (ret != NB_OK) {
index cb09544fdc459453a9030066765ccfb5c1bc6c17..fa34d90c7564f219d8354afbbb50d44f2ed56c7c 100644 (file)
@@ -391,6 +391,7 @@ static struct cmd_node debug_node = {
 static int config_write_mgmt_debug_helper(struct vty *vty, bool config)
 {
        int n = mgmt_debug_be + mgmt_debug_fe + mgmt_debug_ds + mgmt_debug_txn;
+
        if (!n)
                return 0;
 
@@ -442,6 +443,7 @@ DEFPY(debug_mgmt, debug_mgmt_cmd,
       "Transaction debug\n")
 {
        bool set = !no;
+
        if (all)
                be = fe = ds = txn = set ? all : NULL;