summaryrefslogtreecommitdiffstats
path: root/xlators/features/changelog/lib/src/gf-changelog-journal-handler.c
diff options
context:
space:
mode:
authorYaniv Kaul <ykaul@redhat.com>2018-08-21 19:23:01 +0300
committerAmar Tumballi <amarts@redhat.com>2018-08-31 06:14:47 +0000
commitdc6e6b71f87f6f89bb0b69816e92779595d716bd (patch)
treee9fbd7f4384a6ccb05a3537b064588ee30f1b6be /xlators/features/changelog/lib/src/gf-changelog-journal-handler.c
parent058d215174b93b3aa14be99073979f45642e519e (diff)
changelog xlator: strncpy()->sprintf(), reduce strlen()'s
xlators/features/changelog/lib/src/gf-changelog-journal-handler.c xlators/features/changelog/lib/src/gf-changelog.c xlators/features/changelog/src/changelog-helpers.c xlators/features/changelog/src/changelog-misc.h strncpy may not be very efficient for short strings copied into a large buffer: If the length of src is less than n, strncpy() writes additional null bytes to dest to ensure that a total of n bytes are written. Instead, use snprintf(). Where possible, ensure there's no truncation of the output. Also: - save the result of strlen() and re-use it when possible. - move from strlen to SLEN (sizeof() ) for const strings. - switch a strncpy to a memcpy. Compile-tested only! Change-Id: Ia7a52bce0b243613ad910192ec163c93d944e077 updates: bz#1193929 Signed-off-by: Yaniv Kaul <ykaul@redhat.com>
Diffstat (limited to 'xlators/features/changelog/lib/src/gf-changelog-journal-handler.c')
-rw-r--r--xlators/features/changelog/lib/src/gf-changelog-journal-handler.c36
1 files changed, 21 insertions, 15 deletions
diff --git a/xlators/features/changelog/lib/src/gf-changelog-journal-handler.c b/xlators/features/changelog/lib/src/gf-changelog-journal-handler.c
index 9c1a498f655..bdb410030f6 100644
--- a/xlators/features/changelog/lib/src/gf-changelog-journal-handler.c
+++ b/xlators/features/changelog/lib/src/gf-changelog-journal-handler.c
@@ -456,7 +456,7 @@ gf_changelog_decode (xlator_t *this, gf_changelog_journal_t *jnl,
size_t elen = 0;
char buffer[1024] = {0,};
- CHANGELOG_GET_HEADER_INFO (from_fd, buffer, 1024, encoding,
+ CHANGELOG_GET_HEADER_INFO (from_fd, buffer, sizeof (buffer), encoding,
major_version, minor_version, elen);
if (encoding == -1) /* unknown encoding */
goto out;
@@ -521,8 +521,9 @@ gf_changelog_publish (xlator_t *this,
char to_path[PATH_MAX] = {0,};
struct stat stbuf = {0,};
- (void) snprintf (to_path, PATH_MAX, "%s%s",
- jnl->jnl_current_dir, basename (from_path));
+ if (snprintf (to_path, PATH_MAX, "%s%s", jnl->jnl_current_dir,
+ basename (from_path)) >= PATH_MAX)
+ return -1;
/* handle zerob file that won't exist in current */
ret = sys_stat (to_path, &stbuf);
@@ -532,8 +533,9 @@ gf_changelog_publish (xlator_t *this,
goto out;
}
- (void) snprintf (dest, PATH_MAX, "%s%s",
- jnl->jnl_processing_dir, basename (from_path));
+ if (snprintf (dest, PATH_MAX, "%s%s", jnl->jnl_processing_dir,
+ basename (from_path)) >= PATH_MAX)
+ return -1;
ret = sys_rename (to_path, dest);
if (ret) {
@@ -561,6 +563,13 @@ gf_changelog_consume (xlator_t *this,
char dest[PATH_MAX] = {0,};
char to_path[PATH_MAX] = {0,};
+ if (snprintf (to_path, PATH_MAX, "%s%s", jnl->jnl_current_dir,
+ basename (from_path)) >= PATH_MAX)
+ goto out;
+ if (snprintf (dest, PATH_MAX, "%s%s", jnl->jnl_processing_dir,
+ basename (from_path)) >= PATH_MAX)
+ goto out;
+
ret = sys_stat (from_path, &stbuf);
if (ret || !S_ISREG(stbuf.st_mode)) {
ret = -1;
@@ -582,11 +591,6 @@ gf_changelog_consume (xlator_t *this,
goto out;
}
- (void) snprintf (to_path, PATH_MAX, "%s%s",
- jnl->jnl_current_dir, basename (from_path));
- (void) snprintf (dest, PATH_MAX, "%s%s",
- jnl->jnl_processing_dir, basename (from_path));
-
fd2 = open (to_path, O_CREAT | O_TRUNC | O_RDWR,
S_IRUSR | S_IWUSR | S_IRGRP | S_IROTH);
if (fd2 < 0) {
@@ -948,8 +952,9 @@ gf_changelog_init_history (xlator_t *this,
goto dealloc_hist;
}
- (void) strncpy (jnl->hist_jnl->jnl_brickpath, brick_path, PATH_MAX-1);
- jnl->hist_jnl->jnl_brickpath[PATH_MAX-1] = 0;
+ if (snprintf (jnl->hist_jnl->jnl_brickpath, PATH_MAX, "%s",
+ brick_path) >= PATH_MAX)
+ goto dealloc_hist;
for (i = 0; i < 256; i++) {
jnl->hist_jnl->rfc3986_space_newline[i] =
@@ -999,6 +1004,10 @@ gf_changelog_journal_init (void *xl, struct gf_brick_spec *brick)
if (!jnl)
goto error_return;
+ if (snprintf (jnl->jnl_brickpath, PATH_MAX, "%s",
+ brick->brick_path) >= PATH_MAX)
+ goto dealloc_private;
+
if (sys_stat (scratch_dir, &buf) && errno == ENOENT) {
ret = mkdir_p (scratch_dir, 0600, _gf_true);
if (ret)
@@ -1017,9 +1026,6 @@ gf_changelog_journal_init (void *xl, struct gf_brick_spec *brick)
goto dealloc_private;
}
- (void) strncpy (jnl->jnl_brickpath, brick->brick_path, PATH_MAX-1);
- jnl->jnl_brickpath[PATH_MAX-1] = 0;
-
/* RFC 3986 {de,en}coding */
for (i = 0; i < 256; i++) {
jnl->rfc3986_space_newline[i] =