@@ -35,19 +35,19 @@
#include "libdmmp/libdmmp.h"
#include "libdmmp_private.h"
-#define _DEFAULT_UXSOCK_TIMEOUT 60000
+#define DEFAULT_UXSOCK_TIMEOUT 60000
/* ^ 60 seconds. On system with 10k sdX, dmmp_mpath_array_get()
* only take 3.5 seconds, so this default value should be OK for most users.
*/
-#define _DMMP_IPC_SHOW_JSON_CMD "show maps json"
-#define _DMMP_JSON_MAJOR_KEY "major_version"
-#define _DMMP_JSON_MAJOR_VERSION 0
-#define _DMMP_JSON_MAPS_KEY "maps"
-#define _ERRNO_STR_BUFF_SIZE 256
-#define _IPC_MAX_CMD_LEN 512
+#define DMMP_IPC_SHOW_JSON_CMD "show maps json"
+#define DMMP_JSON_MAJOR_KEY "major_version"
+#define DMMP_JSON_MAJOR_VERSION 0
+#define DMMP_JSON_MAPS_KEY "maps"
+#define ERRNO_STR_BUFF_SIZE 256
+#define IPC_MAX_CMD_LEN 512
/* ^ Was MAX_CMD_LEN in ./libmultipath/uxsock.h */
-#define _LAST_ERR_MSG_BUFF_SIZE 1024
+#define LAST_ERR_MSG_BUFF_SIZE 1024
struct dmmp_context {
void (*log_func)(struct dmmp_context *ctx, int priority,
@@ -56,7 +56,7 @@ struct dmmp_context {
int log_priority;
void *userdata;
unsigned int tmo;
- char last_err_msg[_LAST_ERR_MSG_BUFF_SIZE];
+ char last_err_msg[LAST_ERR_MSG_BUFF_SIZE];
};
/*
@@ -99,7 +99,7 @@ void _dmmp_log(struct dmmp_context *ctx, int priority, const char *file,
va_start(args, format);
ctx->log_func(ctx, priority, file, line, func_name, format, args);
if (priority == DMMP_LOG_PRIORITY_ERROR)
- vsnprintf(ctx->last_err_msg, _LAST_ERR_MSG_BUFF_SIZE,
+ vsnprintf(ctx->last_err_msg, LAST_ERR_MSG_BUFF_SIZE,
format, args);
va_end(args);
}
@@ -116,8 +116,8 @@ struct dmmp_context *dmmp_context_new(void)
ctx->log_func = _dmmp_log_stderr;
ctx->log_priority = DMMP_LOG_PRIORITY_DEFAULT;
ctx->userdata = NULL;
- ctx->tmo = _DEFAULT_UXSOCK_TIMEOUT;
- memset(ctx->last_err_msg, 0, _LAST_ERR_MSG_BUFF_SIZE);
+ ctx->tmo = DEFAULT_UXSOCK_TIMEOUT;
+ memset(ctx->last_err_msg, 0, LAST_ERR_MSG_BUFF_SIZE);
return ctx;
}
@@ -180,7 +180,7 @@ int dmmp_mpath_array_get(struct dmmp_context *ctx,
_good(_ipc_connect(ctx, &ipc_fd), rc, out);
- _good(_process_cmd(ctx, ipc_fd, _DMMP_IPC_SHOW_JSON_CMD, &j_str),
+ _good(_process_cmd(ctx, ipc_fd, DMMP_IPC_SHOW_JSON_CMD, &j_str),
rc, out);
_debug(ctx, "Got json output from multipathd: '%s'", j_str);
@@ -202,20 +202,20 @@ int dmmp_mpath_array_get(struct dmmp_context *ctx,
}
_json_obj_get_value(ctx, j_obj, cur_json_major_version,
- _DMMP_JSON_MAJOR_KEY, json_type_int,
+ DMMP_JSON_MAJOR_KEY, json_type_int,
json_object_get_int, rc, out);
- if (cur_json_major_version != _DMMP_JSON_MAJOR_VERSION) {
+ if (cur_json_major_version != DMMP_JSON_MAJOR_VERSION) {
rc = DMMP_ERR_INCOMPATIBLE;
_error(ctx, "Incompatible multipathd JSON major version %d, "
"should be %d", cur_json_major_version,
- _DMMP_JSON_MAJOR_VERSION);
+ DMMP_JSON_MAJOR_VERSION);
goto out;
}
_debug(ctx, "multipathd JSON major version(%d) check pass",
- _DMMP_JSON_MAJOR_VERSION);
+ DMMP_JSON_MAJOR_VERSION);
- _json_obj_get_value(ctx, j_obj, ar_maps, _DMMP_JSON_MAPS_KEY,
+ _json_obj_get_value(ctx, j_obj, ar_maps, DMMP_JSON_MAPS_KEY,
json_type_array, json_object_get_array, rc, out);
if (ar_maps == NULL) {
@@ -279,7 +279,7 @@ static int _process_cmd(struct dmmp_context *ctx, int fd, const char *cmd,
{
int errno_save = 0;
int rc = DMMP_OK;
- char errno_str_buff[_ERRNO_STR_BUFF_SIZE];
+ char errno_str_buff[ERRNO_STR_BUFF_SIZE];
struct timespec start_ts;
struct timespec cur_ts;
unsigned int ipc_tmo = 0;
@@ -300,7 +300,7 @@ static int _process_cmd(struct dmmp_context *ctx, int fd, const char *cmd,
ipc_tmo = ctx->tmo;
if (ctx->tmo == 0)
- ipc_tmo = _DEFAULT_UXSOCK_TIMEOUT;
+ ipc_tmo = DEFAULT_UXSOCK_TIMEOUT;
invoke:
_debug(ctx, "Invoking IPC command '%s' with IPC tmo %u milliseconds",
@@ -308,8 +308,8 @@ invoke:
flag_check_tmo = false;
if (mpath_process_cmd(fd, cmd, output, ipc_tmo) != 0) {
errno_save = errno;
- memset(errno_str_buff, 0, _ERRNO_STR_BUFF_SIZE);
- strerror_r(errno_save, errno_str_buff, _ERRNO_STR_BUFF_SIZE);
+ memset(errno_str_buff, 0, ERRNO_STR_BUFF_SIZE);
+ strerror_r(errno_save, errno_str_buff, ERRNO_STR_BUFF_SIZE);
if (errno_save == ETIMEDOUT) {
flag_check_tmo = true;
} else {
@@ -397,7 +397,7 @@ static int _ipc_connect(struct dmmp_context *ctx, int *fd)
{
int rc = DMMP_OK;
int errno_save = 0;
- char errno_str_buff[_ERRNO_STR_BUFF_SIZE];
+ char errno_str_buff[ERRNO_STR_BUFF_SIZE];
assert(ctx != NULL);
assert(fd != NULL);
@@ -407,8 +407,8 @@ static int _ipc_connect(struct dmmp_context *ctx, int *fd)
*fd = mpath_connect();
if (*fd == -1) {
errno_save = errno;
- memset(errno_str_buff, 0, _ERRNO_STR_BUFF_SIZE);
- strerror_r(errno_save, errno_str_buff, _ERRNO_STR_BUFF_SIZE);
+ memset(errno_str_buff, 0, ERRNO_STR_BUFF_SIZE);
+ strerror_r(errno_save, errno_str_buff, ERRNO_STR_BUFF_SIZE);
if (errno_save == ECONNREFUSED) {
rc = DMMP_ERR_NO_DAEMON;
_error(ctx, "Socket connection refuse. "
@@ -426,14 +426,14 @@ int dmmp_flush_mpath(struct dmmp_context *ctx, const char *mpath_name)
{
int rc = DMMP_OK;
int ipc_fd = -1;
- char cmd[_IPC_MAX_CMD_LEN];
+ char cmd[IPC_MAX_CMD_LEN];
char *output = NULL;
assert(ctx != NULL);
assert(mpath_name != NULL);
- snprintf(cmd, _IPC_MAX_CMD_LEN, "del map %s", mpath_name);
- if (strlen(cmd) == _IPC_MAX_CMD_LEN - 1) {
+ snprintf(cmd, IPC_MAX_CMD_LEN, "del map %s", mpath_name);
+ if (strlen(cmd) == IPC_MAX_CMD_LEN - 1) {
rc = DMMP_ERR_INVALID_ARGUMENT;
_error(ctx, "Invalid mpath name %s", mpath_name);
goto out;
@@ -461,9 +461,9 @@ int dmmp_reconfig(struct dmmp_context *ctx)
int rc = DMMP_OK;
int ipc_fd = -1;
char *output = NULL;
- char cmd[_IPC_MAX_CMD_LEN];
+ char cmd[IPC_MAX_CMD_LEN];
- snprintf(cmd, _IPC_MAX_CMD_LEN, "%s", "reconfigure");
+ snprintf(cmd, IPC_MAX_CMD_LEN, "%s", "reconfigure");
_good(_ipc_connect(ctx, &ipc_fd), rc, out);
_good(_process_cmd(ctx, ipc_fd, cmd, &output), rc, out);
@@ -30,7 +30,7 @@
#include "libdmmp/libdmmp.h"
#include "libdmmp_private.h"
-#define _DMMP_LOG_STRERR_ALIGN_WIDTH 80
+#define DMMP_LOG_STRERR_ALIGN_WIDTH 80
/* ^ Only used in _dmmp_log_stderr() for pretty log output.
* When provided log message is less than 80 bytes, fill it with space, then
* print code file name, function name, line after the 80th bytes.
@@ -81,9 +81,9 @@ void _dmmp_log_stderr(struct dmmp_context *ctx, int priority,
* bypass clang static analyzer about unused ctx argument warning
*/
- if (printed_bytes < _DMMP_LOG_STRERR_ALIGN_WIDTH) {
+ if (printed_bytes < DMMP_LOG_STRERR_ALIGN_WIDTH) {
fprintf(stderr, "%*s # %s:%s():%d\n",
- _DMMP_LOG_STRERR_ALIGN_WIDTH - printed_bytes, "", file,
+ DMMP_LOG_STRERR_ALIGN_WIDTH - printed_bytes, "", file,
func_name, line);
} else {
fprintf(stderr, " # %s:%s():%d\n", file, func_name, line);
@@ -78,7 +78,7 @@ struct dmmp_path_group *_dmmp_path_group_new(void)
malloc(sizeof(struct dmmp_path_group));
if (dmmp_pg != NULL) {
- dmmp_pg->id = _DMMP_PATH_GROUP_ID_UNKNOWN;
+ dmmp_pg->id = DMMP_PATH_GROUP_ID_UNKNOWN;
dmmp_pg->status = DMMP_PATH_GROUP_STATUS_UNKNOWN;
dmmp_pg->priority = 0;
dmmp_pg->selector = NULL;
@@ -127,10 +127,10 @@ int _dmmp_path_group_update(struct dmmp_context *ctx,
dmmp_pg->id = id;
- if (dmmp_pg->id == _DMMP_PATH_GROUP_ID_UNKNOWN) {
+ if (dmmp_pg->id == DMMP_PATH_GROUP_ID_UNKNOWN) {
rc = DMMP_ERR_BUG;
_error(ctx, "BUG: Got unknown(%d) path group ID",
- _DMMP_PATH_GROUP_ID_UNKNOWN);
+ DMMP_PATH_GROUP_ID_UNKNOWN);
goto out;
}
@@ -46,7 +46,7 @@ extern "C" {
goto out; \
} while(0)
-#define _DMMP_PATH_GROUP_ID_UNKNOWN 0
+#define DMMP_PATH_GROUP_ID_UNKNOWN 0
struct DMMP_DLL_LOCAL _num_str_conv;
struct _num_str_conv {
Signed-off-by: Martin Wilck <mwilck@suse.com> --- libdmmp/libdmmp.c | 60 +++++++++++++++++++-------------------- libdmmp/libdmmp_misc.c | 6 ++-- libdmmp/libdmmp_pg.c | 6 ++-- libdmmp/libdmmp_private.h | 2 +- 4 files changed, 37 insertions(+), 37 deletions(-)