summaryrefslogtreecommitdiffstats
path: root/xlators/encryption/crypt
diff options
context:
space:
mode:
authorZhou Zhengping <johnzzpcrystal@gmail.com>2017-03-31 00:42:46 +0800
committerJeff Darcy <jeff@pl.atyp.us>2017-05-05 15:04:17 +0000
commitfe83a4ae84dd4345d6e958219d5a1dc59ecb039d (patch)
treeee99ad6503e434e11fb9c85d0da38c7a26c9dc1b /xlators/encryption/crypt
parentfa10c8a3528b95dc575bfedd30bcd68cc2dff25b (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.c4
-rw-r--r--xlators/encryption/crypt/src/crypt.c16
-rw-r--r--xlators/encryption/crypt/src/crypt.h10
-rw-r--r--xlators/encryption/crypt/src/data.c6
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 ||