diff options
author | Zhou Zhengping <johnzzpcrystal@gmail.com> | 2017-03-31 00:42:46 +0800 |
---|---|---|
committer | Jeff Darcy <jeff@pl.atyp.us> | 2017-05-05 15:04:17 +0000 |
commit | fe83a4ae84dd4345d6e958219d5a1dc59ecb039d (patch) | |
tree | ee99ad6503e434e11fb9c85d0da38c7a26c9dc1b /xlators/encryption/crypt | |
parent | fa10c8a3528b95dc575bfedd30bcd68cc2dff25b (diff) |
coreutils: use coreutils instead of duplicate code
Change-Id: I0e442331d2bbb22ec18c37af87ab2a8852737c43
BUG: 1448265
Signed-off-by: Zhou Zhengping <johnzzpcrystal@gmail.com>
Reviewed-on: https://review.gluster.org/16975
Smoke: Gluster Build System <jenkins@build.gluster.org>
NetBSD-regression: NetBSD Build System <jenkins@build.gluster.org>
CentOS-regression: Gluster Build System <jenkins@build.gluster.org>
Reviewed-by: Amar Tumballi <amarts@redhat.com>
Reviewed-by: Prashanth Pai <ppai@redhat.com>
Reviewed-by: Jeff Darcy <jeff@pl.atyp.us>
Diffstat (limited to 'xlators/encryption/crypt')
-rw-r--r-- | xlators/encryption/crypt/src/atom.c | 4 | ||||
-rw-r--r-- | xlators/encryption/crypt/src/crypt.c | 16 | ||||
-rw-r--r-- | xlators/encryption/crypt/src/crypt.h | 10 | ||||
-rw-r--r-- | xlators/encryption/crypt/src/data.c | 6 |
4 files changed, 13 insertions, 23 deletions
diff --git a/xlators/encryption/crypt/src/atom.c b/xlators/encryption/crypt/src/atom.c index 21d63e5d6d6..6d7b351b370 100644 --- a/xlators/encryption/crypt/src/atom.c +++ b/xlators/encryption/crypt/src/atom.c @@ -502,7 +502,7 @@ static int32_t rmw_partial_block(call_frame_t *frame, #endif set_local_io_params_writev(frame, object, atom, atom->offset_at(frame, object), - iovec_get_size(partial, 1)); + iov_length(partial, 1)); /* * write the whole block to disk */ @@ -522,7 +522,7 @@ static int32_t rmw_partial_block(call_frame_t *frame, gf_log("crypt", GF_LOG_DEBUG, "submit partial block: %d bytes from %d offset", - (int)iovec_get_size(partial, 1), + (int)iov_length(partial, 1), (int)atom->offset_at(frame, object)); exit: return 0; diff --git a/xlators/encryption/crypt/src/crypt.c b/xlators/encryption/crypt/src/crypt.c index 2982bb26db0..0dd076bd897 100644 --- a/xlators/encryption/crypt/src/crypt.c +++ b/xlators/encryption/crypt/src/crypt.c @@ -148,7 +148,7 @@ static void check_read(call_frame_t *frame, xlator_t *this, int32_t read, if (read <= 0) return; - if (read != iovec_get_size(vec, count)) + if (read != iov_length(vec, count)) gf_log ("crypt", GF_LOG_DEBUG, "op_ret differs from amount of read bytes"); @@ -340,8 +340,8 @@ int32_t crypt_readv_cbk(call_frame_t *frame, object_alg_should_pad(object)) gf_log(this->name, GF_LOG_DEBUG, "Bad offset in tail %d", conf->off_in_tail); - if (iovec_get_size(vec, count) != 0 && - in_same_lblock(conf->orig_offset + iovec_get_size(vec, count) - 1, + if (iov_length(vec, count) != 0 && + in_same_lblock(conf->orig_offset + iov_length(vec, count) - 1, local->cur_file_size - 1, object_alg_blkbits(object))) { gf_log(this->name, GF_LOG_DEBUG, "Compound last cblock"); @@ -1083,7 +1083,7 @@ int crypt_writev(call_frame_t *frame, struct gf_flock lock = {0, }; #if DEBUG_CRYPT gf_log ("crypt", GF_LOG_DEBUG, "writing %d bytes from offset %llu", - (int)iovec_get_size(vec, count), (long long)offset); + (int)iov_length(vec, count), (long long)offset); #endif local = crypt_alloc_local(frame, this, GF_FOP_WRITE); if (!local) { @@ -1113,11 +1113,11 @@ int crypt_writev(call_frame_t *frame, ret = EINVAL; goto error; } - if (iovec_get_size(vec, count) == 0) + if (iov_length(vec, count) == 0) goto trivial; ret = prepare_for_submit_data(frame, this, offset, - iovec_get_size(vec, count), + iov_length(vec, count), vec, count, 0 /* don't setup gup in tail: we don't know file size yet */); @@ -1403,7 +1403,7 @@ static int32_t prune_write(call_frame_t *frame, /* * At first, uptodate head block */ - if (iovec_get_size(vec, count) < conf->off_in_head) { + if (iov_length(vec, count) < conf->off_in_head) { gf_log(this->name, GF_LOG_WARNING, "Failed to uptodate head block for prune"); local->op_ret = -1; @@ -3454,7 +3454,7 @@ static int32_t __crypt_readv_done(call_frame_t *frame, gf_log("crypt", GF_LOG_DEBUG, "readv: ret_to_user: %d, iovec len: %d, ia_size: %llu", (int)(local->rw_count > 0 ? local->rw_count : local->op_ret), - (int)(local->rw_count > 0 ? iovec_get_size(avec, local->data_conf.acount) : 0), + (int)(local->rw_count > 0 ? iov_length(avec, local->data_conf.acount) : 0), (unsigned long long)local->buf.ia_size); STACK_UNWIND_STRICT(readv, diff --git a/xlators/encryption/crypt/src/crypt.h b/xlators/encryption/crypt/src/crypt.h index c1bfe3fcd0c..6c014535f0a 100644 --- a/xlators/encryption/crypt/src/crypt.h +++ b/xlators/encryption/crypt/src/crypt.h @@ -465,7 +465,6 @@ void submit_full(call_frame_t *frame, xlator_t *this); /* crypt.c */ end_writeback_handler_t dispatch_end_writeback(glusterfs_fop_t fop); -static size_t iovec_get_size(struct iovec *vec, uint32_t count); void set_local_io_params_writev(call_frame_t *frame, struct object_cipher_info *object, struct rmw_atom *atom, off_t io_offset, @@ -479,15 +478,6 @@ void rename_unwind(call_frame_t *frame); /* Inline functions */ -static inline size_t iovec_get_size(struct iovec *vec, uint32_t count) -{ - int i; - size_t size = 0; - for (i = 0; i < count; i++) - size += vec[i].iov_len; - return size; -} - static inline int32_t crypt_xlator_id(void) { return CRYPT_XLATOR_ID; diff --git a/xlators/encryption/crypt/src/data.c b/xlators/encryption/crypt/src/data.c index 2f96ed2bab5..8b467bf2c60 100644 --- a/xlators/encryption/crypt/src/data.c +++ b/xlators/encryption/crypt/src/data.c @@ -281,8 +281,8 @@ static void check_iovecs(struct iovec *vec, int cnt, char *s1, *s2; uint32_t size, asize; - size = iovec_get_size(vec, cnt); - asize = iovec_get_size(avec, acnt) - off_in_head; + size = iov_length(vec, cnt); + asize = iov_length(avec, acnt) - off_in_head; if (size != asize) { gf_log("crypt", GF_LOG_DEBUG, "size %d is not eq asize %d", size, asize); @@ -379,7 +379,7 @@ int32_t align_iov_by_atoms(xlator_t *this, size_t to_process; /* number of vec's bytes to copy and(or) re-use */ int32_t off_in_head = conf->off_in_head; - to_process = iovec_get_size(vec, count); + to_process = iov_length(vec, count); while (to_process > 0) { if (off_in_head || |