summaryrefslogtreecommitdiffstats
path: root/utils/mirror_vfd/mirror_writer.c
diff options
context:
space:
mode:
authorDana Robinson <43805+derobins@users.noreply.github.com>2023-06-14 15:01:04 (GMT)
committerGitHub <noreply@github.com>2023-06-14 15:01:04 (GMT)
commit69e8c8f58d394cc8928bae1a1dc7c84dd0c6891f (patch)
tree216549076fa13990d48297efe15828386f113731 /utils/mirror_vfd/mirror_writer.c
parent61d43eb867e1cec7882a2c55c611950c63de8cf4 (diff)
downloadhdf5-69e8c8f58d394cc8928bae1a1dc7c84dd0c6891f.zip
hdf5-69e8c8f58d394cc8928bae1a1dc7c84dd0c6891f.tar.gz
hdf5-69e8c8f58d394cc8928bae1a1dc7c84dd0c6891f.tar.bz2
Clean up mirror VFD code in utils dir (#3121)
* Remove dead code * Replace mybzero with memset * Replace hbool_t/TRUE/FALSE with bool/true/false
Diffstat (limited to 'utils/mirror_vfd/mirror_writer.c')
-rw-r--r--utils/mirror_vfd/mirror_writer.c51
1 files changed, 9 insertions, 42 deletions
diff --git a/utils/mirror_vfd/mirror_writer.c b/utils/mirror_vfd/mirror_writer.c
index ad7cd91..2752121 100644
--- a/utils/mirror_vfd/mirror_writer.c
+++ b/utils/mirror_vfd/mirror_writer.c
@@ -154,32 +154,9 @@ struct mirror_writer_opts {
char *logpath;
};
-static void mybzero(void *dest, size_t size);
-
static int do_open(struct mirror_session *session, const H5FD_mirror_xmit_open_t *xmit_open);
/* ---------------------------------------------------------------------------
- * Function: mybzero
- *
- * Purpose: Introduce bzero without neededing it on the system.
- *
- * Programmer: Jacob Smith
- * 2020-03-30
- * ---------------------------------------------------------------------------
- */
-static void
-mybzero(void *dest, size_t size)
-{
- size_t i = 0;
- char *s = NULL;
- HDassert(dest);
- s = (char *)dest;
- for (i = 0; i < size; i++) {
- *(s + i) = 0;
- }
-} /* end mybzero() */
-
-/* ---------------------------------------------------------------------------
* Function: session_init
*
* Purpose: Populate mirror_session structure with default and
@@ -217,10 +194,9 @@ session_init(struct mirror_writer_opts *opts)
session->reply.pub.version = H5FD_MIRROR_XMIT_CURR_VERSION;
session->reply.pub.op = H5FD_MIRROR_OP_REPLY;
session->reply.pub.session_token = 0;
- mybzero(session->reply.message, H5FD_MIRROR_STATUS_MESSAGE_MAX);
+ HDmemset(session->reply.message, 0, H5FD_MIRROR_STATUS_MESSAGE_MAX);
- /* Options-derived population
- */
+ /* Options-derived population */
session->loginfo = mirror_log_init(opts->logpath, "W- ", MIRROR_LOG_DEFAULT_VERBOSITY);
@@ -291,25 +267,16 @@ session_start(int socketfd, const H5FD_mirror_xmit_open_t *xmit_open)
{
struct mirror_session *session = NULL;
struct mirror_writer_opts opts;
-#if 0 /* TODO: behavior option */
- char logpath[H5FD_MIRROR_XMIT_FILEPATH_MAX] = "";
-#endif
mirror_log(NULL, V_INFO, "session_start()");
- if (FALSE == H5FD_mirror_xmit_is_open(xmit_open)) {
+ if (false == H5FD_mirror_xmit_is_open(xmit_open)) {
mirror_log(NULL, V_ERR, "invalid OPEN xmit");
return NULL;
}
- opts.magic = MW_OPTS_MAGIC;
-#if 0 /* TODO: behavior option */
- HDsnprintf(logpath, H5FD_MIRROR_XMIT_FILEPATH_MAX, "%s.log",
- xmit_open->filename);
- opts.logpath = logpath;
-#else
+ opts.magic = MW_OPTS_MAGIC;
opts.logpath = NULL;
-#endif
session = session_init(&opts);
if (NULL == session) {
@@ -391,7 +358,7 @@ reply_ok(struct mirror_session *session)
mirror_log(session->loginfo, V_ALL, "reply_ok()");
reply->status = H5FD_MIRROR_STATUS_OK;
- mybzero(reply->message, H5FD_MIRROR_STATUS_MESSAGE_MAX);
+ HDmemset(reply->message, 0, H5FD_MIRROR_STATUS_MESSAGE_MAX);
return _xmit_reply(session);
} /* end reply_ok() */
@@ -489,7 +456,7 @@ do_lock(struct mirror_session *session, const unsigned char *xmit_buf)
}
mirror_log(session->loginfo, V_INFO, "lock rw: (%d)", xmit_lock.rw);
- if (H5FDlock(session->file, (hbool_t)xmit_lock.rw) < 0) {
+ if (H5FDlock(session->file, (bool)xmit_lock.rw) < 0) {
mirror_log(session->loginfo, V_ERR, "H5FDlock()");
reply_error(session, "remote H5FDlock() failure");
return -1;
@@ -520,7 +487,7 @@ do_open(struct mirror_session *session, const H5FD_mirror_xmit_open_t *xmit_open
haddr_t _maxaddr = HADDR_UNDEF;
HDassert(session && (session->magic == MW_SESSION_MAGIC) && xmit_open &&
- TRUE == H5FD_mirror_xmit_is_open(xmit_open));
+ true == H5FD_mirror_xmit_is_open(xmit_open));
mirror_log(session->loginfo, V_INFO, "do_open()");
@@ -664,7 +631,7 @@ do_truncate(struct mirror_session *session)
mirror_log(session->loginfo, V_INFO, "do_truncate()");
- /* default DXPL ID (0), 0 for "FALSE" closing -- both probably unused */
+ /* default DXPL ID (0), 0 for "false" closing -- both probably unused */
if (H5FDtruncate(session->file, 0, 0) < 0) {
mirror_log(session->loginfo, V_ERR, "H5FDtruncate()");
reply_error(session, "remote H5FDtruncate() failure");
@@ -853,7 +820,7 @@ receive_communique(struct mirror_session *session, struct sock_comm *comm)
mirror_log(session->loginfo, V_INFO, "receive_communique()");
- mybzero(comm->raw, comm->raw_size);
+ HDmemset(comm->raw, 0, comm->raw_size);
comm->recd_die = 0;
mirror_log(session->loginfo, V_INFO, "ready to receive"); /* TODO */