diff options
Diffstat (limited to 'xlators/protocol/server/src/server-protocol.c')
| -rw-r--r-- | xlators/protocol/server/src/server-protocol.c | 2580 |
1 files changed, 1048 insertions, 1532 deletions
diff --git a/xlators/protocol/server/src/server-protocol.c b/xlators/protocol/server/src/server-protocol.c index 27dd69e501c..ab3b4a6b915 100644 --- a/xlators/protocol/server/src/server-protocol.c +++ b/xlators/protocol/server/src/server-protocol.c @@ -43,18 +43,17 @@ static void -protocol_server_reply (call_frame_t *frame, - int type, int op, +protocol_server_reply (call_frame_t *frame, int type, int op, gf_hdr_common_t *hdr, size_t hdrlen, struct iovec *vector, int count, struct iobref *iobref) { server_state_t *state = NULL; - xlator_t *bound_xl = NULL; - transport_t *trans = NULL; + xlator_t *bound_xl = NULL; + transport_t *trans = NULL; - bound_xl = BOUND_XL(frame); - state = CALL_STATE(frame); + bound_xl = BOUND_XL (frame); + state = CALL_STATE (frame); trans = state->trans; hdr->callid = hton64 (frame->root->unique); @@ -77,19 +76,16 @@ protocol_server_reply (call_frame_t *frame, /* * server_fchmod_cbk */ -int32_t -server_fchmod_cbk (call_frame_t *frame, - void *cookie, - xlator_t *this, - int32_t op_ret, - int32_t op_errno, - struct stat *stbuf) +int +server_fchmod_cbk (call_frame_t *frame, void *cookie, xlator_t *this, + int32_t op_ret, int32_t op_errno, struct stat *stbuf) { gf_hdr_common_t *hdr = NULL; gf_fop_fchmod_rsp_t *rsp = NULL; - size_t hdrlen = 0; - int32_t gf_errno = 0; - server_state_t *state = NULL; + size_t hdrlen = 0; + int32_t gf_errno = 0; + server_state_t *state = NULL; + hdrlen = gf_hdr_len (rsp, 0); hdr = gf_hdr_new (rsp, 0); @@ -102,7 +98,7 @@ server_fchmod_cbk (call_frame_t *frame, if (op_ret == 0) { gf_stat_from_stat (&rsp->stat, stbuf); } else { - state = CALL_STATE(frame); + state = CALL_STATE (frame); gf_log (this->name, GF_LOG_TRACE, "%"PRId64": FCHMOD %"PRId64" (%"PRId64") ==> %"PRId32" (%s)", @@ -121,20 +117,19 @@ server_fchmod_cbk (call_frame_t *frame, * server_fchmod * */ -int32_t -server_fchmod (call_frame_t *frame, - xlator_t *bound_xl, +int +server_fchmod (call_frame_t *frame, xlator_t *bound_xl, gf_hdr_common_t *hdr, size_t hdrlen, struct iobuf *iobuf) { - server_connection_t *conn = NULL; - gf_fop_fchmod_req_t *req = NULL; - server_state_t *state = NULL; + server_connection_t *conn = NULL; + gf_fop_fchmod_req_t *req = NULL; + server_state_t *state = NULL; conn = SERVER_CONNECTION(frame); req = gf_param (hdr); - state = CALL_STATE(frame); + state = CALL_STATE (frame); { state->fd_no = ntoh64 (req->fd); if (state->fd_no >= 0) @@ -146,17 +141,14 @@ server_fchmod (call_frame_t *frame, GF_VALIDATE_OR_GOTO(bound_xl->name, state->fd, fail); - STACK_WIND (frame, - server_fchmod_cbk, + STACK_WIND (frame, server_fchmod_cbk, BOUND_XL(frame), BOUND_XL(frame)->fops->fchmod, - state->fd, - state->mode); + state->fd, state->mode); return 0; fail: - server_fchmod_cbk (frame, NULL, frame->this, - -1, EINVAL, NULL); + server_fchmod_cbk (frame, NULL, frame->this, -1, EINVAL, NULL); return 0; } @@ -164,19 +156,15 @@ fail: /* * server_fchown_cbk */ -int32_t -server_fchown_cbk (call_frame_t *frame, - void *cookie, - xlator_t *this, - int32_t op_ret, - int32_t op_errno, - struct stat *stbuf) -{ - gf_hdr_common_t *hdr = NULL; +int +server_fchown_cbk (call_frame_t *frame, void *cookie, xlator_t *this, + int32_t op_ret, int32_t op_errno, struct stat *stbuf) +{ + gf_hdr_common_t *hdr = NULL; gf_fop_fchown_rsp_t *rsp = NULL; - size_t hdrlen = 0; - int32_t gf_errno = 0; - server_state_t *state = NULL; + size_t hdrlen = 0; + int32_t gf_errno = 0; + server_state_t *state = NULL; hdrlen = gf_hdr_len (rsp, 0); hdr = gf_hdr_new (rsp, 0); @@ -208,15 +196,14 @@ server_fchown_cbk (call_frame_t *frame, * server_fchown * */ -int32_t -server_fchown (call_frame_t *frame, - xlator_t *bound_xl, +int +server_fchown (call_frame_t *frame, xlator_t *bound_xl, gf_hdr_common_t *hdr, size_t hdrlen, struct iobuf *iobuf) { - server_connection_t *conn = NULL; - gf_fop_fchown_req_t *req = NULL; - server_state_t *state = NULL; + server_connection_t *conn = NULL; + gf_fop_fchown_req_t *req = NULL; + server_state_t *state = NULL; conn = SERVER_CONNECTION(frame); @@ -234,18 +221,14 @@ server_fchown (call_frame_t *frame, GF_VALIDATE_OR_GOTO(bound_xl->name, state->fd, fail); - STACK_WIND (frame, - server_fchown_cbk, + STACK_WIND (frame, server_fchown_cbk, BOUND_XL(frame), BOUND_XL(frame)->fops->fchown, - state->fd, - state->uid, - state->gid); + state->fd, state->uid, state->gid); return 0; fail: - server_fchown_cbk (frame, NULL, frame->this, - -1, EINVAL, NULL); + server_fchown_cbk (frame, NULL, frame->this, -1, EINVAL, NULL); return 0; } @@ -259,17 +242,14 @@ fail: * * not for external reference */ -int32_t -server_setdents_cbk (call_frame_t *frame, - void *cookie, - xlator_t *this, - int32_t op_ret, - int32_t op_errno) +int +server_setdents_cbk (call_frame_t *frame, void *cookie, xlator_t *this, + int32_t op_ret, int32_t op_errno) { - gf_hdr_common_t *hdr = NULL; - gf_fop_setdents_rsp_t *rsp = NULL; - size_t hdrlen = 0; - int32_t gf_errno = 0; + gf_hdr_common_t *hdr = NULL; + gf_fop_setdents_rsp_t *rsp = NULL; + size_t hdrlen = 0; + int32_t gf_errno = 0; hdrlen = gf_hdr_len (rsp, 0); hdr = gf_hdr_new (rsp, 0); @@ -296,19 +276,15 @@ server_setdents_cbk (call_frame_t *frame, * * not for external reference */ -int32_t -server_lk_cbk (call_frame_t *frame, - void *cookie, - xlator_t *this, - int32_t op_ret, - int32_t op_errno, - struct flock *lock) -{ - gf_hdr_common_t *hdr = NULL; - gf_fop_lk_rsp_t *rsp = NULL; - size_t hdrlen = 0; - int32_t gf_errno = 0; - server_state_t *state = NULL; +int +server_lk_cbk (call_frame_t *frame, void *cookie, xlator_t *this, + int32_t op_ret, int32_t op_errno, struct flock *lock) +{ + gf_hdr_common_t *hdr = NULL; + gf_fop_lk_rsp_t *rsp = NULL; + size_t hdrlen = 0; + int32_t gf_errno = 0; + server_state_t *state = NULL; hdrlen = gf_hdr_len (rsp, 0); hdr = gf_hdr_new (rsp, 0); @@ -337,16 +313,16 @@ server_lk_cbk (call_frame_t *frame, } -int32_t -server_inodelk_cbk (call_frame_t *frame, void *cookie, - xlator_t *this, int32_t op_ret, int32_t op_errno) +int +server_inodelk_cbk (call_frame_t *frame, void *cookie, xlator_t *this, + int32_t op_ret, int32_t op_errno) { - server_connection_t *conn = NULL; - gf_hdr_common_t *hdr = NULL; + server_connection_t *conn = NULL; + gf_hdr_common_t *hdr = NULL; gf_fop_inodelk_rsp_t *rsp = NULL; - server_state_t *state = NULL; - size_t hdrlen = 0; - int32_t gf_errno = 0; + server_state_t *state = NULL; + size_t hdrlen = 0; + int32_t gf_errno = 0; conn = SERVER_CONNECTION(frame); @@ -384,16 +360,16 @@ server_inodelk_cbk (call_frame_t *frame, void *cookie, } -int32_t -server_finodelk_cbk (call_frame_t *frame, void *cookie, - xlator_t *this, int32_t op_ret, int32_t op_errno) +int +server_finodelk_cbk (call_frame_t *frame, void *cookie, xlator_t *this, + int32_t op_ret, int32_t op_errno) { - server_connection_t *conn = NULL; - gf_hdr_common_t *hdr = NULL; + server_connection_t *conn = NULL; + gf_hdr_common_t *hdr = NULL; gf_fop_finodelk_rsp_t *rsp = NULL; - server_state_t *state = NULL; - size_t hdrlen = 0; - int32_t gf_errno = 0; + server_state_t *state = NULL; + size_t hdrlen = 0; + int32_t gf_errno = 0; conn = SERVER_CONNECTION(frame); @@ -442,16 +418,16 @@ server_finodelk_cbk (call_frame_t *frame, void *cookie, * * not for external reference */ -int32_t -server_entrylk_cbk (call_frame_t *frame, void *cookie, - xlator_t *this, int32_t op_ret, int32_t op_errno) +int +server_entrylk_cbk (call_frame_t *frame, void *cookie, xlator_t *this, + int32_t op_ret, int32_t op_errno) { - server_connection_t *conn = NULL; + server_connection_t *conn = NULL; gf_hdr_common_t *hdr = NULL; gf_fop_entrylk_rsp_t *rsp = NULL; - server_state_t *state = NULL; - size_t hdrlen = 0; - int32_t gf_errno = 0; + server_state_t *state = NULL; + size_t hdrlen = 0; + int32_t gf_errno = 0; conn = SERVER_CONNECTION(frame); @@ -489,16 +465,16 @@ server_entrylk_cbk (call_frame_t *frame, void *cookie, } -int32_t -server_fentrylk_cbk (call_frame_t *frame, void *cookie, - xlator_t *this, int32_t op_ret, int32_t op_errno) +int +server_fentrylk_cbk (call_frame_t *frame, void *cookie, xlator_t *this, + int32_t op_ret, int32_t op_errno) { - server_connection_t *conn = NULL; + server_connection_t *conn = NULL; gf_hdr_common_t *hdr = NULL; gf_fop_fentrylk_rsp_t *rsp = NULL; - server_state_t *state = NULL; - size_t hdrlen = 0; - int32_t gf_errno = 0; + server_state_t *state = NULL; + size_t hdrlen = 0; + int32_t gf_errno = 0; conn = SERVER_CONNECTION(frame); @@ -543,18 +519,15 @@ server_fentrylk_cbk (call_frame_t *frame, void *cookie, * * not for external reference */ -int32_t -server_access_cbk (call_frame_t *frame, - void *cookie, - xlator_t *this, - int32_t op_ret, - int32_t op_errno) +int +server_access_cbk (call_frame_t *frame, void *cookie, xlator_t *this, + int32_t op_ret, int32_t op_errno) { gf_hdr_common_t *hdr = NULL; gf_fop_access_rsp_t *rsp = NULL; - server_state_t *state = NULL; - size_t hdrlen = 0; - int32_t gf_errno = 0; + server_state_t *state = NULL; + size_t hdrlen = 0; + int32_t gf_errno = 0; state = CALL_STATE(frame); @@ -585,19 +558,17 @@ server_access_cbk (call_frame_t *frame, * * not for external reference */ -int32_t -server_utimens_cbk (call_frame_t *frame, - void *cookie, - xlator_t *this, - int32_t op_ret, - int32_t op_errno, - struct stat *stbuf) +int +server_utimens_cbk (call_frame_t *frame, void *cookie, xlator_t *this, + int32_t op_ret, int32_t op_errno, struct stat *stbuf) { gf_hdr_common_t *hdr = NULL; gf_fop_utimens_rsp_t *rsp = NULL; - server_state_t *state = NULL; - size_t hdrlen = 0; - int32_t gf_errno = 0; + server_state_t *state = NULL; + size_t hdrlen = 0; + int32_t gf_errno = 0; + + state = CALL_STATE(frame); hdrlen = gf_hdr_len (rsp, 0); @@ -630,19 +601,15 @@ server_utimens_cbk (call_frame_t *frame, * * not for external reference */ -int32_t -server_chmod_cbk (call_frame_t *frame, - void *cookie, - xlator_t *this, - int32_t op_ret, - int32_t op_errno, - struct stat *stbuf) +int +server_chmod_cbk (call_frame_t *frame, void *cookie, xlator_t *this, + int32_t op_ret, int32_t op_errno, struct stat *stbuf) { - gf_hdr_common_t *hdr = NULL; - gf_fop_chmod_rsp_t *rsp = NULL; - server_state_t *state = NULL; - size_t hdrlen = 0; - int32_t gf_errno = 0; + gf_hdr_common_t *hdr = NULL; + gf_fop_chmod_rsp_t *rsp = NULL; + server_state_t *state = NULL; + size_t hdrlen = 0; + int32_t gf_errno = 0; state = CALL_STATE(frame); @@ -676,19 +643,15 @@ server_chmod_cbk (call_frame_t *frame, * * not for external reference */ -int32_t -server_chown_cbk (call_frame_t *frame, - void *cookie, - xlator_t *this, - int32_t op_ret, - int32_t op_errno, - struct stat *stbuf) +int +server_chown_cbk (call_frame_t *frame, void *cookie, xlator_t *this, + int32_t op_ret, int32_t op_errno, struct stat *stbuf) { - gf_hdr_common_t *hdr = NULL; + gf_hdr_common_t *hdr = NULL; gf_fop_chown_rsp_t *rsp = NULL; - server_state_t *state = NULL; - int32_t gf_errno = 0; - size_t hdrlen = 0; + server_state_t *state = NULL; + int32_t gf_errno = 0; + size_t hdrlen = 0; state = CALL_STATE(frame); @@ -721,18 +684,15 @@ server_chown_cbk (call_frame_t *frame, * * not for external reference */ -int32_t -server_rmdir_cbk (call_frame_t *frame, - void *cookie, - xlator_t *this, - int32_t op_ret, - int32_t op_errno) +int +server_rmdir_cbk (call_frame_t *frame, void *cookie, xlator_t *this, + int32_t op_ret, int32_t op_errno) { gf_hdr_common_t *hdr = NULL; gf_fop_rmdir_rsp_t *rsp = NULL; - server_state_t *state = NULL; - int32_t gf_errno = 0; - size_t hdrlen = 0; + server_state_t *state = NULL; + int32_t gf_errno = 0; + size_t hdrlen = 0; state = CALL_STATE(frame); @@ -774,20 +734,16 @@ server_rmdir_cbk (call_frame_t *frame, * * not for external reference */ -int32_t -server_mkdir_cbk (call_frame_t *frame, - void *cookie, - xlator_t *this, - int32_t op_ret, - int32_t op_errno, - inode_t *inode, +int +server_mkdir_cbk (call_frame_t *frame, void *cookie, xlator_t *this, + int32_t op_ret, int32_t op_errno, inode_t *inode, struct stat *stbuf) { gf_hdr_common_t *hdr = NULL; gf_fop_mkdir_rsp_t *rsp = NULL; - server_state_t *state = NULL; - size_t hdrlen = 0; - int32_t gf_errno = 0; + server_state_t *state = NULL; + size_t hdrlen = 0; + int32_t gf_errno = 0; state = CALL_STATE(frame); @@ -829,20 +785,16 @@ server_mkdir_cbk (call_frame_t *frame, * * not for external reference */ -int32_t -server_mknod_cbk (call_frame_t *frame, - void *cookie, - xlator_t *this, - int32_t op_ret, - int32_t op_errno, - inode_t *inode, - struct stat *stbuf) +int +server_mknod_cbk (call_frame_t *frame, void *cookie, xlator_t *this, + int32_t op_ret, int32_t op_errno, + inode_t *inode, struct stat *stbuf) { gf_hdr_common_t *hdr = NULL; gf_fop_mknod_rsp_t *rsp = NULL; - server_state_t *state = NULL; - int32_t gf_errno = 0; - size_t hdrlen = 0; + server_state_t *state = NULL; + int32_t gf_errno = 0; + size_t hdrlen = 0; state = CALL_STATE(frame); @@ -883,18 +835,15 @@ server_mknod_cbk (call_frame_t *frame, * * not for external reference */ -int32_t -server_fsyncdir_cbk (call_frame_t *frame, - void *cookie, - xlator_t *this, - int32_t op_ret, - int32_t op_errno) +int +server_fsyncdir_cbk (call_frame_t *frame, void *cookie, xlator_t *this, + int32_t op_ret, int32_t op_errno) { gf_hdr_common_t *hdr = NULL; gf_fop_fsyncdir_rsp_t *rsp = NULL; - size_t hdrlen = 0; - int32_t gf_errno = 0; - server_state_t *state = NULL; + size_t hdrlen = 0; + int32_t gf_errno = 0; + server_state_t *state = NULL; hdrlen = gf_hdr_len (rsp, 0); hdr = gf_hdr_new (rsp, 0); @@ -933,26 +882,22 @@ server_fsyncdir_cbk (call_frame_t *frame, * * not for external reference */ -int32_t -server_getdents_cbk (call_frame_t *frame, - void *cookie, - xlator_t *this, - int32_t op_ret, - int32_t op_errno, - dir_entry_t *entries, +int +server_getdents_cbk (call_frame_t *frame, void *cookie, xlator_t *this, + int32_t op_ret, int32_t op_errno, dir_entry_t *entries, int32_t count) { gf_hdr_common_t *hdr = NULL; gf_fop_getdents_rsp_t *rsp = NULL; - size_t hdrlen = 0; - int32_t vec_count = 0; - int32_t gf_errno = 0; - struct iobref *iobref = NULL; - struct iobuf *iobuf = NULL; - size_t buflen = 0; - struct iovec vector[1]; - server_state_t *state = NULL; - + size_t hdrlen = 0; + int32_t vec_count = 0; + int32_t gf_errno = 0; + struct iobref *iobref = NULL; + struct iobuf *iobuf = NULL; + size_t buflen = 0; + struct iovec vector[1]; + server_state_t *state = NULL; + state = CALL_STATE(frame); if (op_ret >= 0) { @@ -1033,20 +978,16 @@ out: * * not for external reference */ -int32_t -server_readdir_cbk (call_frame_t *frame, - void *cookie, - xlator_t *this, - int32_t op_ret, - int32_t op_errno, - gf_dirent_t *entries) +int +server_readdir_cbk (call_frame_t *frame, void *cookie, xlator_t *this, + int32_t op_ret, int32_t op_errno, gf_dirent_t *entries) { gf_hdr_common_t *hdr = NULL; gf_fop_readdir_rsp_t *rsp = NULL; - size_t hdrlen = 0; - size_t buf_size = 0; - int32_t gf_errno = 0; - server_state_t *state = NULL; + size_t hdrlen = 0; + size_t buf_size = 0; + int32_t gf_errno = 0; + server_state_t *state = NULL; if (op_ret > 0) buf_size = gf_dirent_serialize (entries, NULL, 0); @@ -1089,17 +1030,14 @@ server_readdir_cbk (call_frame_t *frame, * * not for external reference */ -int32_t -server_releasedir_cbk (call_frame_t *frame, - void *cookie, - xlator_t *this, - int32_t op_ret, - int32_t op_errno) +int +server_releasedir_cbk (call_frame_t *frame, void *cookie, xlator_t *this, + int32_t op_ret, int32_t op_errno) { gf_hdr_common_t *hdr = NULL; gf_cbk_releasedir_rsp_t *rsp = NULL; - size_t hdrlen = 0; - int32_t gf_errno = 0; + size_t hdrlen = 0; + int32_t gf_errno = 0; hdrlen = gf_hdr_len (rsp, 0); hdr = gf_hdr_new (rsp, 0); @@ -1127,24 +1065,20 @@ server_releasedir_cbk (call_frame_t *frame, * * not for external reference */ -int32_t -server_opendir_cbk (call_frame_t *frame, - void *cookie, - xlator_t *this, - int32_t op_ret, - int32_t op_errno, - fd_t *fd) +int +server_opendir_cbk (call_frame_t *frame, void *cookie, xlator_t *this, + int32_t op_ret, int32_t op_errno, fd_t *fd) { - server_connection_t *conn = NULL; - gf_hdr_common_t *hdr = NULL; - gf_fop_opendir_rsp_t *rsp = NULL; - server_state_t *state = NULL; - size_t hdrlen = 0; - int32_t gf_errno = 0; + server_connection_t *conn = NULL; + gf_hdr_common_t *hdr = NULL; + gf_fop_opendir_rsp_t *rsp = NULL; + server_state_t *state = NULL; + size_t hdrlen = 0; + int32_t gf_errno = 0; - conn = SERVER_CONNECTION(frame); + conn = SERVER_CONNECTION (frame); - state = CALL_STATE(frame); + state = CALL_STATE (frame); if (op_ret >= 0) { fd_bind (fd); @@ -1190,21 +1124,17 @@ server_opendir_cbk (call_frame_t *frame, * * not for external reference */ -int32_t -server_statfs_cbk (call_frame_t *frame, - void *cookie, - xlator_t *this, - int32_t op_ret, - int32_t op_errno, - struct statvfs *buf) +int +server_statfs_cbk (call_frame_t *frame, void *cookie, xlator_t *this, + int32_t op_ret, int32_t op_errno, struct statvfs *buf) { gf_hdr_common_t *hdr = NULL; gf_fop_statfs_rsp_t *rsp = NULL; - server_state_t *state = NULL; - size_t hdrlen = 0; - int32_t gf_errno = 0; + server_state_t *state = NULL; + size_t hdrlen = 0; + int32_t gf_errno = 0; - state = CALL_STATE(frame); + state = CALL_STATE (frame); hdrlen = gf_hdr_len (rsp, 0); hdr = gf_hdr_new (rsp, 0); @@ -1236,20 +1166,17 @@ server_statfs_cbk (call_frame_t *frame, * * not for external reference */ -int32_t -server_removexattr_cbk (call_frame_t *frame, - void *cookie, - xlator_t *this, - int32_t op_ret, - int32_t op_errno) +int +server_removexattr_cbk (call_frame_t *frame, void *cookie, xlator_t *this, + int32_t op_ret, int32_t op_errno) { gf_hdr_common_t *hdr = NULL; gf_fop_removexattr_rsp_t *rsp = NULL; - server_state_t *state = NULL; - size_t hdrlen = 0; - int32_t gf_errno = 0; + server_state_t *state = NULL; + size_t hdrlen = 0; + int32_t gf_errno = 0; - state = CALL_STATE(frame); + state = CALL_STATE (frame); hdrlen = gf_hdr_len (rsp, 0); hdr = gf_hdr_new (rsp, 0); @@ -1278,23 +1205,19 @@ server_removexattr_cbk (call_frame_t *frame, * * not for external reference */ -int32_t -server_getxattr_cbk (call_frame_t *frame, - void *cookie, - xlator_t *this, - int32_t op_ret, - int32_t op_errno, - dict_t *dict) +int +server_getxattr_cbk (call_frame_t *frame, void *cookie, xlator_t *this, + int32_t op_ret, int32_t op_errno, dict_t *dict) { gf_hdr_common_t *hdr = NULL; gf_fop_getxattr_rsp_t *rsp = NULL; - server_state_t *state = NULL; - size_t hdrlen = 0; - int32_t len = 0; - int32_t gf_errno = 0; - int32_t ret = -1; + server_state_t *state = NULL; + size_t hdrlen = 0; + int32_t len = 0; + int32_t gf_errno = 0; + int32_t ret = -1; - state = CALL_STATE(frame); + state = CALL_STATE (frame); if (op_ret >= 0) { len = dict_serialized_length (dict); @@ -1339,23 +1262,19 @@ server_getxattr_cbk (call_frame_t *frame, } -int32_t -server_fgetxattr_cbk (call_frame_t *frame, - void *cookie, - xlator_t *this, - int32_t op_ret, - int32_t op_errno, - dict_t *dict) +int +server_fgetxattr_cbk (call_frame_t *frame, void *cookie, xlator_t *this, + int32_t op_ret, int32_t op_errno, dict_t *dict) { - gf_hdr_common_t *hdr = NULL; + gf_hdr_common_t *hdr = NULL; gf_fop_fgetxattr_rsp_t *rsp = NULL; - server_state_t *state = NULL; - size_t hdrlen = 0; - int32_t len = 0; - int32_t gf_errno = 0; - int32_t ret = -1; + server_state_t *state = NULL; + size_t hdrlen = 0; + int32_t len = 0; + int32_t gf_errno = 0; + int32_t ret = -1; - state = CALL_STATE(frame); + state = CALL_STATE (frame); if (op_ret >= 0) { len = dict_serialized_length (dict); @@ -1409,19 +1328,17 @@ server_fgetxattr_cbk (call_frame_t *frame, * * not for external reference */ -int32_t -server_setxattr_cbk (call_frame_t *frame, - void *cookie, - xlator_t *this, - int32_t op_ret, - int32_t op_errno) +int +server_setxattr_cbk (call_frame_t *frame, void *cookie, xlator_t *this, + int32_t op_ret, int32_t op_errno) { - gf_hdr_common_t *hdr = NULL; - gf_fop_setxattr_rsp_t *rsp = NULL; - server_state_t *state = NULL; - size_t hdrlen = 0; - int32_t gf_errno = 0; - state = CALL_STATE(frame); + gf_hdr_common_t *hdr = NULL; + gf_fop_setxattr_rsp_t *rsp = NULL; + server_state_t *state = NULL; + size_t hdrlen = 0; + int32_t gf_errno = 0; + + state = CALL_STATE (frame); hdrlen = gf_hdr_len (rsp, 0); hdr = gf_hdr_new (rsp, 0); @@ -1440,18 +1357,16 @@ server_setxattr_cbk (call_frame_t *frame, } -int32_t -server_fsetxattr_cbk (call_frame_t *frame, - void *cookie, - xlator_t *this, - int32_t op_ret, - int32_t op_errno) +int +server_fsetxattr_cbk (call_frame_t *frame, void *cookie, xlator_t *this, + int32_t op_ret, int32_t op_errno) { gf_hdr_common_t *hdr = NULL; gf_fop_fsetxattr_rsp_t *rsp = NULL; - server_state_t *state = NULL; - size_t hdrlen = 0; - int32_t gf_errno = 0; + server_state_t *state = NULL; + size_t hdrlen = 0; + int32_t gf_errno = 0; + state = CALL_STATE(frame); hdrlen = gf_hdr_len (rsp, 0); @@ -1479,19 +1394,15 @@ server_fsetxattr_cbk (call_frame_t *frame, * * not for external reference */ -int32_t -server_rename_cbk (call_frame_t *frame, - void *cookie, - xlator_t *this, - int32_t op_ret, - int32_t op_errno, - struct stat *stbuf) +int +server_rename_cbk (call_frame_t *frame, void *cookie, xlator_t *this, + int32_t op_ret, int32_t op_errno, struct stat *stbuf) { gf_hdr_common_t *hdr = NULL; gf_fop_rename_rsp_t *rsp = NULL; - server_state_t *state = NULL; - size_t hdrlen = 0; - int32_t gf_errno = 0; + server_state_t *state = NULL; + size_t hdrlen = 0; + int32_t gf_errno = 0; state = CALL_STATE(frame); @@ -1541,18 +1452,15 @@ server_rename_cbk (call_frame_t *frame, * * not for external reference */ -int32_t -server_unlink_cbk (call_frame_t *frame, - void *cookie, - xlator_t *this, - int32_t op_ret, - int32_t op_errno) +int +server_unlink_cbk (call_frame_t *frame, void *cookie, xlator_t *this, + int32_t op_ret, int32_t op_errno) { - gf_hdr_common_t *hdr = NULL; - gf_fop_unlink_rsp_t *rsp = NULL; - server_state_t *state = NULL; - size_t hdrlen = 0; - int32_t gf_errno = 0; + gf_hdr_common_t *hdr = NULL; + gf_fop_unlink_rsp_t *rsp = NULL; + server_state_t *state = NULL; + size_t hdrlen = 0; + int32_t gf_errno = 0; state = CALL_STATE(frame); @@ -1598,20 +1506,16 @@ server_unlink_cbk (call_frame_t *frame, * * not for external reference */ -int32_t -server_symlink_cbk (call_frame_t *frame, - void *cookie, - xlator_t *this, - int32_t op_ret, - int32_t op_errno, - inode_t *inode, +int +server_symlink_cbk (call_frame_t *frame, void *cookie, xlator_t *this, + int32_t op_ret, int32_t op_errno, inode_t *inode, struct stat *stbuf) { gf_hdr_common_t *hdr = NULL; gf_fop_symlink_rsp_t *rsp = NULL; - server_state_t *state = NULL; - size_t hdrlen = 0; - int32_t gf_errno = 0; + server_state_t *state = NULL; + size_t hdrlen = 0; + int32_t gf_errno = 0; state = CALL_STATE(frame); @@ -1654,20 +1558,16 @@ server_symlink_cbk (call_frame_t *frame, * * not for external reference */ -int32_t -server_link_cbk (call_frame_t *frame, - void *cookie, - xlator_t *this, - int32_t op_ret, - int32_t op_errno, - inode_t *inode, +int +server_link_cbk (call_frame_t *frame, void *cookie, xlator_t *this, + int32_t op_ret, int32_t op_errno, inode_t *inode, struct stat *stbuf) { gf_hdr_common_t *hdr = NULL; gf_fop_link_rsp_t *rsp = NULL; - server_state_t *state = NULL; - int32_t gf_errno = 0; - size_t hdrlen = 0; + server_state_t *state = NULL; + int32_t gf_errno = 0; + size_t hdrlen = 0; state = CALL_STATE(frame); @@ -1684,8 +1584,10 @@ server_link_cbk (call_frame_t *frame, gf_stat_from_stat (&rsp->stat, stbuf); gf_log (state->bound_xl->name, GF_LOG_TRACE, "%"PRId64": LINK (%"PRId64") %"PRId64"/%s ==> %"PRId64"/%s", - frame->root->unique, inode->ino, state->loc2.parent->ino, - state->loc2.name, state->loc.parent->ino, state->loc.name); + frame->root->unique, inode->ino, + state->loc2.parent->ino, + state->loc2.name, state->loc.parent->ino, + state->loc.name); inode_link (inode, state->loc2.parent, state->loc2.name, stbuf); @@ -1693,8 +1595,10 @@ server_link_cbk (call_frame_t *frame, gf_log (state->bound_xl->name, GF_LOG_DEBUG, "%"PRId64": LINK (%"PRId64") %"PRId64"/%s ==> %"PRId64"/%s " " ==> %"PRId32" (%s)", - frame->root->unique, inode->ino, state->loc2.parent->ino, - state->loc2.name, state->loc.parent->ino, state->loc.name, + frame->root->unique, inode->ino, + state->loc2.parent->ino, + state->loc2.name, state->loc.parent->ino, + state->loc.name, op_ret, strerror (op_errno)); } @@ -1719,21 +1623,17 @@ server_link_cbk (call_frame_t *frame, * * not for external reference */ -int32_t -server_truncate_cbk (call_frame_t *frame, - void *cookie, - xlator_t *this, - int32_t op_ret, - int32_t op_errno, - struct stat *stbuf) +int +server_truncate_cbk (call_frame_t *frame, void *cookie, xlator_t *this, + int32_t op_ret, int32_t op_errno, struct stat *stbuf) { gf_hdr_common_t *hdr = NULL; gf_fop_truncate_rsp_t *rsp = NULL; - server_state_t *state = NULL; - size_t hdrlen = 0; - int32_t gf_errno = 0; + server_state_t *state = NULL; + size_t hdrlen = 0; + int32_t gf_errno = 0; - state = CALL_STATE(frame); + state = CALL_STATE (frame); hdrlen = gf_hdr_len (rsp, 0); hdr = gf_hdr_new (rsp, 0); @@ -1772,19 +1672,15 @@ server_truncate_cbk (call_frame_t *frame, * * not for external reference */ -int32_t -server_fstat_cbk (call_frame_t *frame, - void *cookie, - xlator_t *this, - int32_t op_ret, - int32_t op_errno, - struct stat *stbuf) +int +server_fstat_cbk (call_frame_t *frame, void *cookie, xlator_t *this, + int32_t op_ret, int32_t op_errno, struct stat *stbuf) { gf_hdr_common_t *hdr = NULL; gf_fop_fstat_rsp_t *rsp = NULL; - size_t hdrlen = 0; - int32_t gf_errno = 0; - server_state_t *state = NULL; + size_t hdrlen = 0; + int32_t gf_errno = 0; + server_state_t *state = NULL; hdrlen = gf_hdr_len (rsp, 0); hdr = gf_hdr_new (rsp, 0); @@ -1823,19 +1719,15 @@ server_fstat_cbk (call_frame_t *frame, * * not for external reference */ -int32_t -server_ftruncate_cbk (call_frame_t *frame, - void *cookie, - xlator_t *this, - int32_t op_ret, - int32_t op_errno, - struct stat *stbuf) +int +server_ftruncate_cbk (call_frame_t *frame, void *cookie, xlator_t *this, + int32_t op_ret, int32_t op_errno, struct stat *stbuf) { gf_hdr_common_t *hdr = NULL; gf_fop_ftruncate_rsp_t *rsp = NULL; - size_t hdrlen = 0; - int32_t gf_errno = 0; - server_state_t *state = NULL; + size_t hdrlen = 0; + int32_t gf_errno = 0; + server_state_t *state = NULL; hdrlen = gf_hdr_len (rsp, 0); hdr = gf_hdr_new (rsp, 0); @@ -1848,7 +1740,7 @@ server_ftruncate_cbk (call_frame_t *frame, if (op_ret == 0) { gf_stat_from_stat (&rsp->stat, stbuf); } else { - state = CALL_STATE(frame); + state = CALL_STATE (frame); gf_log (this->name, GF_LOG_DEBUG, "%"PRId64": FTRUNCATE %"PRId64" (%"PRId64") ==> %"PRId32" (%s)", @@ -1874,18 +1766,15 @@ server_ftruncate_cbk (call_frame_t *frame, * * not for external reference */ -int32_t -server_flush_cbk (call_frame_t *frame, - void *cookie, - xlator_t *this, - int32_t op_ret, - int32_t op_errno) +int +server_flush_cbk (call_frame_t *frame, void *cookie, xlator_t *this, + int32_t op_ret, int32_t op_errno) { gf_hdr_common_t *hdr = NULL; gf_fop_flush_rsp_t *rsp = NULL; - size_t hdrlen = 0; - int32_t gf_errno = 0; - server_state_t *state = NULL; + size_t hdrlen = 0; + int32_t gf_errno = 0; + server_state_t *state = NULL; if (op_ret < 0) { state = CALL_STATE(frame); @@ -1920,18 +1809,15 @@ server_flush_cbk (call_frame_t *frame, * * not for external reference */ -int32_t -server_fsync_cbk (call_frame_t *frame, - void *cookie, - xlator_t *this, - int32_t op_ret, - int32_t op_errno) +int +server_fsync_cbk (call_frame_t *frame, void *cookie, xlator_t *this, + int32_t op_ret, int32_t op_errno) { gf_hdr_common_t *hdr = NULL; gf_fop_fsync_rsp_t *rsp = NULL; - size_t hdrlen = 0; - int32_t gf_errno = 0; - server_state_t *state = NULL; + size_t hdrlen = 0; + int32_t gf_errno = 0; + server_state_t *state = NULL; if (op_ret < 0) { state = CALL_STATE(frame); @@ -1966,17 +1852,14 @@ server_fsync_cbk (call_frame_t *frame, * * not for external reference */ -int32_t -server_release_cbk (call_frame_t *frame, - void *cookie, - xlator_t *this, - int32_t op_ret, - int32_t op_errno) +int +server_release_cbk (call_frame_t *frame, void *cookie, xlator_t *this, + int32_t op_ret, int32_t op_errno) { gf_hdr_common_t *hdr = NULL; gf_cbk_release_rsp_t *rsp = NULL; - size_t hdrlen = 0; - int32_t gf_errno = 0; + size_t hdrlen = 0; + int32_t gf_errno = 0; hdrlen = gf_hdr_len (rsp, 0); hdr = gf_hdr_new (rsp, 0); @@ -2003,19 +1886,15 @@ server_release_cbk (call_frame_t *frame, * not for external reference */ -int32_t -server_writev_cbk (call_frame_t *frame, - void *cookie, - xlator_t *this, - int32_t op_ret, - int32_t op_errno, - struct stat *stbuf) +int +server_writev_cbk (call_frame_t *frame, void *cookie, xlator_t *this, + int32_t op_ret, int32_t op_errno, struct stat *stbuf) { gf_hdr_common_t *hdr = NULL; gf_fop_write_rsp_t *rsp = NULL; - size_t hdrlen = 0; - int32_t gf_errno = 0; - server_state_t *state = NULL; + size_t hdrlen = 0; + int32_t gf_errno = 0; + server_state_t *state = NULL; hdrlen = gf_hdr_len (rsp, 0); hdr = gf_hdr_new (rsp, 0); @@ -2037,8 +1916,7 @@ server_writev_cbk (call_frame_t *frame, strerror (op_errno)); } - protocol_server_reply (frame, - GF_OP_TYPE_FOP_REPLY, GF_FOP_WRITE, + protocol_server_reply (frame, GF_OP_TYPE_FOP_REPLY, GF_FOP_WRITE, hdr, hdrlen, NULL, 0, NULL); return 0; @@ -2057,22 +1935,17 @@ server_writev_cbk (call_frame_t *frame, * * not for external reference */ -int32_t -server_readv_cbk (call_frame_t *frame, - void *cookie, - xlator_t *this, - int32_t op_ret, - int32_t op_errno, - struct iovec *vector, - int32_t count, - struct stat *stbuf, - struct iobref *iobref) +int +server_readv_cbk (call_frame_t *frame, void *cookie, xlator_t *this, + int32_t op_ret, int32_t op_errno, + struct iovec *vector, int32_t count, + struct stat *stbuf, struct iobref *iobref) { gf_hdr_common_t *hdr = NULL; gf_fop_read_rsp_t *rsp = NULL; - size_t hdrlen = 0; - int32_t gf_errno = 0; - server_state_t *state = NULL; + size_t hdrlen = 0; + int32_t gf_errno = 0; + server_state_t *state = NULL; hdrlen = gf_hdr_len (rsp, 0); hdr = gf_hdr_new (rsp, 0); @@ -2112,24 +1985,20 @@ server_readv_cbk (call_frame_t *frame, * * not for external reference */ -int32_t -server_open_cbk (call_frame_t *frame, - void *cookie, - xlator_t *this, - int32_t op_ret, - int32_t op_errno, - fd_t *fd) +int +server_open_cbk (call_frame_t *frame, void *cookie, xlator_t *this, + int32_t op_ret, int32_t op_errno, fd_t *fd) { - server_connection_t *conn = NULL; - gf_hdr_common_t *hdr = NULL; - gf_fop_open_rsp_t *rsp = NULL; - server_state_t *state = NULL; - size_t hdrlen = 0; - int32_t gf_errno = 0; + server_connection_t *conn = NULL; + gf_hdr_common_t *hdr = NULL; + gf_fop_open_rsp_t *rsp = NULL; + server_state_t *state = NULL; + size_t hdrlen = 0; + int32_t gf_errno = 0; - conn = SERVER_CONNECTION(frame); + conn = SERVER_CONNECTION (frame); - state = CALL_STATE(frame); + state = CALL_STATE (frame); if (op_ret >= 0) { fd_bind (fd); @@ -2178,26 +2047,21 @@ server_open_cbk (call_frame_t *frame, * * not for external reference */ -int32_t -server_create_cbk (call_frame_t *frame, - void *cookie, - xlator_t *this, - int32_t op_ret, - int32_t op_errno, - fd_t *fd, - inode_t *inode, - struct stat *stbuf) +int +server_create_cbk (call_frame_t *frame, void *cookie, xlator_t *this, + int32_t op_ret, int32_t op_errno, + fd_t *fd, inode_t *inode, struct stat *stbuf) { server_connection_t *conn = NULL; gf_hdr_common_t *hdr = NULL; gf_fop_create_rsp_t *rsp = NULL; - server_state_t *state = NULL; - size_t hdrlen = 0; - int32_t gf_errno = 0; + server_state_t *state = NULL; + size_t hdrlen = 0; + int32_t gf_errno = 0; - conn = SERVER_CONNECTION(frame); + conn = SERVER_CONNECTION (frame); - state = CALL_STATE(frame); + state = CALL_STATE (frame); if (op_ret >= 0) { gf_log (state->bound_xl->name, GF_LOG_TRACE, @@ -2260,20 +2124,16 @@ server_create_cbk (call_frame_t *frame, * * not for external reference */ -int32_t -server_readlink_cbk (call_frame_t *frame, - void *cookie, - xlator_t *this, - int32_t op_ret, - int32_t op_errno, - const char *buf) +int +server_readlink_cbk (call_frame_t *frame, void *cookie, xlator_t *this, + int32_t op_ret, int32_t op_errno, const char *buf) { gf_hdr_common_t *hdr = NULL; gf_fop_readlink_rsp_t *rsp = NULL; - server_state_t *state = NULL; - size_t hdrlen = 0; - size_t linklen = 0; - int32_t gf_errno = 0; + server_state_t *state = NULL; + size_t hdrlen = 0; + size_t linklen = 0; + int32_t gf_errno = 0; state = CALL_STATE(frame); @@ -2317,21 +2177,17 @@ server_readlink_cbk (call_frame_t *frame, * * not for external reference */ -int32_t -server_stat_cbk (call_frame_t *frame, - void *cookie, - xlator_t *this, - int32_t op_ret, - int32_t op_errno, - struct stat *stbuf) +int +server_stat_cbk (call_frame_t *frame, void *cookie, xlator_t *this, + int32_t op_ret, int32_t op_errno, struct stat *stbuf) { gf_hdr_common_t *hdr = NULL; gf_fop_stat_rsp_t *rsp = NULL; - server_state_t *state = NULL; - size_t hdrlen = 0; - int32_t gf_errno = 0; + server_state_t *state = NULL; + size_t hdrlen = 0; + int32_t gf_errno = 0; - state = CALL_STATE(frame); + state = CALL_STATE (frame); hdrlen = gf_hdr_len (rsp, 0); hdr = gf_hdr_new (rsp, 0); @@ -2369,17 +2225,14 @@ server_stat_cbk (call_frame_t *frame, * * not for external reference */ -int32_t -server_forget_cbk (call_frame_t *frame, - void *cookie, - xlator_t *this, - int32_t op_ret, - int32_t op_errno) +int +server_forget_cbk (call_frame_t *frame, void *cookie, xlator_t *this, + int32_t op_ret, int32_t op_errno) { gf_hdr_common_t *hdr = NULL; gf_cbk_forget_rsp_t *rsp = NULL; - size_t hdrlen = 0; - int32_t gf_errno = 0; + size_t hdrlen = 0; + int32_t gf_errno = 0; hdrlen = gf_hdr_len (rsp, 0); hdr = gf_hdr_new (rsp, 0); @@ -2408,29 +2261,24 @@ server_forget_cbk (call_frame_t *frame, * * not for external reference */ -int32_t -server_lookup_cbk (call_frame_t *frame, - void *cookie, - xlator_t *this, - int32_t op_ret, - int32_t op_errno, - inode_t *inode, - struct stat *stbuf, - dict_t *dict) +int +server_lookup_cbk (call_frame_t *frame, void *cookie, xlator_t *this, + int32_t op_ret, int32_t op_errno, + inode_t *inode, struct stat *stbuf, dict_t *dict) { gf_hdr_common_t *hdr = NULL; gf_fop_lookup_rsp_t *rsp = NULL; - server_state_t *state = NULL; - inode_t *root_inode = NULL; - int32_t dict_len = 0; - size_t hdrlen = 0; - int32_t gf_errno = 0; - int32_t ret = -1; + server_state_t *state = NULL; + inode_t *root_inode = NULL; + int32_t dict_len = 0; + size_t hdrlen = 0; + int32_t gf_errno = 0; + int32_t ret = -1; + loc_t loc = {0,}; state = CALL_STATE(frame); if ((op_errno == ESTALE) && (op_ret == -1)) { /* Send lookup again with new ctx dictionary */ - loc_t loc = {0,}; root_inode = BOUND_XL(frame)->itable->root; if (state->loc.inode != root_inode) { @@ -2441,6 +2289,7 @@ server_lookup_cbk (call_frame_t *frame, loc.inode = state->loc.inode; loc.path = state->path; state->is_revalidate = 2; + STACK_WIND (frame, server_lookup_cbk, BOUND_XL(frame), BOUND_XL(frame)->fops->lookup, @@ -2515,23 +2364,19 @@ server_lookup_cbk (call_frame_t *frame, return 0; } -int32_t -server_xattrop_cbk (call_frame_t *frame, - void *cookie, - xlator_t *this, - int32_t op_ret, - int32_t op_errno, - dict_t *dict) +int +server_xattrop_cbk (call_frame_t *frame, void *cookie, xlator_t *this, + int32_t op_ret, int32_t op_errno, dict_t *dict) { - gf_hdr_common_t *hdr = NULL; - gf_fop_xattrop_rsp_t *rsp = NULL; - server_state_t *state = NULL; - size_t hdrlen = 0; - int32_t len = 0; - int32_t gf_errno = 0; - int32_t ret = -1; - - state = CALL_STATE(frame); + gf_hdr_common_t *hdr = NULL; + gf_fop_xattrop_rsp_t *rsp = NULL; + server_state_t *state = NULL; + size_t hdrlen = 0; + int32_t len = 0; + int32_t gf_errno = 0; + int32_t ret = -1; + + state = CALL_STATE (frame); if (op_ret < 0) { gf_log (this->name, GF_LOG_DEBUG, @@ -2583,21 +2428,18 @@ server_xattrop_cbk (call_frame_t *frame, return 0; } -int32_t -server_fxattrop_cbk (call_frame_t *frame, - void *cookie, - xlator_t *this, - int32_t op_ret, - int32_t op_errno, - dict_t *dict) + +int +server_fxattrop_cbk (call_frame_t *frame, void *cookie, xlator_t *this, + int32_t op_ret, int32_t op_errno, dict_t *dict) { gf_hdr_common_t *hdr = NULL; gf_fop_xattrop_rsp_t *rsp = NULL; - size_t hdrlen = 0; - int32_t len = 0; - int32_t gf_errno = 0; - int32_t ret = -1; - server_state_t *state = NULL; + size_t hdrlen = 0; + int32_t len = 0; + int32_t gf_errno = 0; + int32_t ret = -1; + server_state_t *state = NULL; state = CALL_STATE(frame); @@ -2666,23 +2508,24 @@ server_fxattrop_cbk (call_frame_t *frame, * * not for external reference */ -int32_t -server_stub_resume (call_stub_t *stub, - int32_t op_ret, - int32_t op_errno, - inode_t *inode, - inode_t *parent) +int +server_stub_resume (call_stub_t *stub, int32_t op_ret, int32_t op_errno, + inode_t *inode, inode_t *parent) { - inode_t *server_inode = inode; + inode_t *server_inode = NULL; + loc_t *newloc = NULL; + dict_t *dict = NULL; + + server_inode = inode; if (!stub) { return 0; } + switch (stub->fop) { case GF_FOP_RENAME: if (stub->args.rename.old.inode == NULL) { - loc_t *newloc = NULL; /* now we are called by lookup of oldpath. */ if (op_ret < 0) { gf_log (stub->frame->this->name, GF_LOG_DEBUG, @@ -2699,12 +2542,9 @@ server_stub_resume (call_stub_t *stub, * server_rename_cbk with ret=-1 and * errno=ENOENT */ - server_rename_cbk (stub->frame, - NULL, + server_rename_cbk (stub->frame, NULL, stub->frame->this, - -1, - ENOENT, - NULL); + -1, ENOENT, NULL); server_loc_wipe (&stub->args.rename.old); server_loc_wipe (&stub->args.rename.new); FREE (stub); @@ -2763,12 +2603,8 @@ server_stub_resume (call_stub_t *stub, BOUND_XL(stub->frame)->name, op_ret, op_errno); - server_open_cbk (stub->frame, - NULL, - stub->frame->this, - -1, - ENOENT, - NULL); + server_open_cbk (stub->frame, NULL, stub->frame->this, + -1, ENOENT, NULL); FREE (stub->args.open.loc.path); FREE (stub); return 0; @@ -2796,12 +2632,9 @@ server_stub_resume (call_stub_t *stub, BOUND_XL(stub->frame)->name, op_ret, op_errno); - server_lookup_cbk (stub->frame, - NULL, - stub->frame->this, - -1, ENOENT, - NULL, NULL, - NULL); + server_lookup_cbk (stub->frame, NULL, + stub->frame->this, -1, ENOENT, + NULL, NULL, NULL); server_loc_wipe (&stub->args.lookup.loc); FREE (stub); return 0; @@ -2830,11 +2663,8 @@ server_stub_resume (call_stub_t *stub, stub->args.stat.loc.path, BOUND_XL(stub->frame)->name, op_ret, op_errno); - server_stat_cbk (stub->frame, - NULL, - stub->frame->this, - -1, ENOENT, - NULL); + server_stat_cbk (stub->frame, NULL, stub->frame->this, + -1, ENOENT, NULL); server_loc_wipe (&stub->args.stat.loc); FREE (stub); return 0; @@ -2862,11 +2692,9 @@ server_stub_resume (call_stub_t *stub, stub->args.xattrop.loc.path, BOUND_XL(stub->frame)->name, op_ret, op_errno); - server_xattrop_cbk (stub->frame, - NULL, - stub->frame->this, - -1, ENOENT, - NULL); + server_xattrop_cbk (stub->frame, NULL, + stub->frame->this, -1, ENOENT, + NULL); server_loc_wipe (&stub->args.xattrop.loc); FREE (stub); return 0; @@ -2896,8 +2724,7 @@ server_stub_resume (call_stub_t *stub, BOUND_XL(stub->frame)->name, op_ret, op_errno); server_unlink_cbk (stub->frame, NULL, - stub->frame->this, - -1, ENOENT); + stub->frame->this, -1, ENOENT); server_loc_wipe (&stub->args.unlink.loc); FREE (stub); return 0; @@ -2926,8 +2753,7 @@ server_stub_resume (call_stub_t *stub, BOUND_XL(stub->frame)->name, op_ret, op_errno); server_symlink_cbk (stub->frame, NULL, - stub->frame->this, - -1, ENOENT, + stub->frame->this, -1, ENOENT, NULL, NULL); server_loc_wipe (&stub->args.symlink.loc); FREE (stub); @@ -2956,11 +2782,8 @@ server_stub_resume (call_stub_t *stub, stub->args.rmdir.loc.path, BOUND_XL(stub->frame)->name, op_ret, op_errno); - server_rmdir_cbk (stub->frame, - NULL, - stub->frame->this, - -1, - ENOENT); + server_rmdir_cbk (stub->frame, NULL, stub->frame->this, + -1, ENOENT); server_loc_wipe (&stub->args.rmdir.loc); FREE (stub); return 0; @@ -2987,12 +2810,8 @@ server_stub_resume (call_stub_t *stub, stub->args.chmod.loc.path, BOUND_XL(stub->frame)->name, op_ret, op_errno); - server_chmod_cbk (stub->frame, - NULL, - stub->frame->this, - -1, - ENOENT, - NULL); + server_chmod_cbk (stub->frame, NULL, stub->frame->this, + -1, ENOENT, NULL); server_loc_wipe (&stub->args.chmod.loc); FREE (stub); return 0; @@ -3019,12 +2838,8 @@ server_stub_resume (call_stub_t *stub, stub->args.chown.loc.path, BOUND_XL(stub->frame)->name, op_ret, op_errno); - server_chown_cbk (stub->frame, - NULL, - stub->frame->this, - -1, - ENOENT, - NULL); + server_chown_cbk (stub->frame, NULL, stub->frame->this, + -1, ENOENT, NULL); server_loc_wipe (&stub->args.chown.loc); FREE (stub); return 0; @@ -3055,10 +2870,8 @@ server_stub_resume (call_stub_t *stub, BOUND_XL(stub->frame)->name, op_ret, op_errno); - server_link_cbk (stub->frame, - NULL, - stub->frame->this, - -1, ENOENT, + server_link_cbk (stub->frame, NULL, + stub->frame->this, -1, ENOENT, NULL, NULL); server_loc_wipe (&stub->args.link.oldloc); server_loc_wipe (&stub->args.link.newloc); @@ -3096,9 +2909,8 @@ server_stub_resume (call_stub_t *stub, op_ret, op_errno); server_link_cbk (stub->frame, NULL, - stub->frame->this, - -1, ENOENT, - NULL, NULL); + stub->frame->this, -1, ENOENT, + NULL, NULL); server_loc_wipe (&stub->args.link.oldloc); server_loc_wipe (&stub->args.link.newloc); @@ -3135,10 +2947,8 @@ server_stub_resume (call_stub_t *stub, BOUND_XL(stub->frame)->name, op_ret, op_errno); - server_truncate_cbk (stub->frame, - NULL, - stub->frame->this, - -1, ENOENT, + server_truncate_cbk (stub->frame, NULL, + stub->frame->this, -1, ENOENT, NULL); server_loc_wipe (&stub->args.truncate.loc); FREE (stub); @@ -3168,11 +2978,9 @@ server_stub_resume (call_stub_t *stub, BOUND_XL(stub->frame)->name, op_ret, op_errno); - server_statfs_cbk (stub->frame, - NULL, - stub->frame->this, - -1, ENOENT, - NULL); + server_statfs_cbk (stub->frame, NULL, + stub->frame->this, -1, ENOENT, + NULL); server_loc_wipe (&stub->args.statfs.loc); FREE (stub); return 0; @@ -3191,7 +2999,7 @@ server_stub_resume (call_stub_t *stub, case GF_FOP_SETXATTR: { - dict_t *dict = stub->args.setxattr.dict; + dict = stub->args.setxattr.dict; if (op_ret < 0) { gf_log (stub->frame->this->name, GF_LOG_DEBUG, "%"PRId64": SETXATTR (%s) on %s returning error: " @@ -3201,10 +3009,8 @@ server_stub_resume (call_stub_t *stub, BOUND_XL(stub->frame)->name, op_ret, op_errno); - server_setxattr_cbk (stub->frame, - NULL, - stub->frame->this, - -1, ENOENT); + server_setxattr_cbk (stub->frame, NULL, + stub->frame->this, -1, ENOENT); server_loc_wipe (&stub->args.setxattr.loc); dict_unref (dict); @@ -3237,10 +3043,8 @@ server_stub_resume (call_stub_t *stub, stub->args.getxattr.name : "<nul>", op_ret, op_errno); - server_getxattr_cbk (stub->frame, - NULL, - stub->frame->this, - -1, ENOENT, + server_getxattr_cbk (stub->frame, NULL, + stub->frame->this, -1, ENOENT, NULL); server_loc_wipe (&stub->args.getxattr.loc); FREE (stub); @@ -3271,10 +3075,8 @@ server_stub_resume (call_stub_t *stub, stub->args.removexattr.name, op_ret, op_errno); - server_removexattr_cbk (stub->frame, - NULL, - stub->frame->this, - -1, + server_removexattr_cbk (stub->frame, NULL, + stub->frame->this, -1, ENOENT); server_loc_wipe (&stub->args.removexattr.loc); FREE (stub); @@ -3305,10 +3107,8 @@ server_stub_resume (call_stub_t *stub, BOUND_XL(stub->frame)->name, op_ret, op_errno); - server_opendir_cbk (stub->frame, - NULL, - stub->frame->this, - -1, ENOENT, + server_opendir_cbk (stub->frame, NULL, + stub->frame->this, -1, ENOENT, NULL); server_loc_wipe (&stub->args.opendir.loc); FREE (stub); @@ -3338,10 +3138,8 @@ server_stub_resume (call_stub_t *stub, BOUND_XL(stub->frame)->name, op_ret, op_errno); - server_access_cbk (stub->frame, - NULL, - stub->frame->this, - -1, ENOENT); + server_access_cbk (stub->frame, NULL, + stub->frame->this, -1, ENOENT); server_loc_wipe (&stub->args.access.loc); FREE (stub); return 0; @@ -3370,10 +3168,8 @@ server_stub_resume (call_stub_t *stub, BOUND_XL(stub->frame)->name, op_ret, op_errno); - server_utimens_cbk (stub->frame, - NULL, - stub->frame->this, - -1, ENOENT, + server_utimens_cbk (stub->frame, NULL, + stub->frame->this, -1, ENOENT, NULL); server_loc_wipe (&stub->args.utimens.loc); FREE (stub); @@ -3403,10 +3199,8 @@ server_stub_resume (call_stub_t *stub, BOUND_XL(stub->frame)->name, op_ret, op_errno); - server_readlink_cbk (stub->frame, - NULL, - stub->frame->this, - -1, ENOENT, + server_readlink_cbk (stub->frame, NULL, + stub->frame->this, -1, ENOENT, NULL); server_loc_wipe (&stub->args.readlink.loc); FREE (stub); @@ -3435,10 +3229,8 @@ server_stub_resume (call_stub_t *stub, BOUND_XL(stub->frame)->name, op_ret, op_errno); - server_mkdir_cbk (stub->frame, - NULL, - stub->frame->this, - -1, ENOENT, + server_mkdir_cbk (stub->frame, NULL, + stub->frame->this, -1, ENOENT, NULL, NULL); server_loc_wipe (&stub->args.mkdir.loc); FREE (stub); @@ -3468,12 +3260,9 @@ server_stub_resume (call_stub_t *stub, BOUND_XL(stub->frame)->name, op_ret, op_errno); - server_create_cbk (stub->frame, - NULL, - stub->frame->this, - -1, ENOENT, - NULL, NULL, - NULL); + server_create_cbk (stub->frame, NULL, + stub->frame->this, -1, ENOENT, + NULL, NULL, NULL); if (stub->args.create.fd) fd_unref (stub->args.create.fd); server_loc_wipe (&stub->args.create.loc); @@ -3504,11 +3293,9 @@ server_stub_resume (call_stub_t *stub, BOUND_XL(stub->frame)->name, op_ret, op_errno); - server_mknod_cbk (stub->frame, - NULL, - stub->frame->this, - -1, ENOENT, - NULL, NULL); + server_mknod_cbk (stub->frame, NULL, + stub->frame->this, -1, ENOENT, NULL, + NULL); server_loc_wipe (&stub->args.mknod.loc); FREE (stub); break; @@ -3537,10 +3324,8 @@ server_stub_resume (call_stub_t *stub, stub->args.entrylk.name : "<nul>", op_ret, op_errno); - server_entrylk_cbk (stub->frame, - NULL, - stub->frame->this, - -1, ENOENT); + server_entrylk_cbk (stub->frame, NULL, + stub->frame->this, -1, ENOENT); server_loc_wipe (&stub->args.entrylk.loc); FREE (stub); break; @@ -3567,10 +3352,8 @@ server_stub_resume (call_stub_t *stub, BOUND_XL(stub->frame)->name, op_ret, op_errno); - server_inodelk_cbk (stub->frame, - NULL, - stub->frame->this, - -1, ENOENT); + server_inodelk_cbk (stub->frame, NULL, + stub->frame->this, -1, ENOENT); server_loc_wipe (&stub->args.inodelk.loc); FREE (stub); break; @@ -3594,10 +3377,8 @@ server_stub_resume (call_stub_t *stub, return 0; } -static int -server_lookup_resume (call_frame_t *frame, - xlator_t *this, - loc_t *loc, +int +server_lookup_resume (call_frame_t *frame, xlator_t *this, loc_t *loc, dict_t *xattr_req) { server_state_t *state = NULL; @@ -3626,12 +3407,10 @@ server_lookup_resume (call_frame_t *frame, "%"PRId64": LOOKUP \'%"PRId64"/%s\'", frame->root->unique, state->par, state->bname); - STACK_WIND (frame, - server_lookup_cbk, + STACK_WIND (frame, server_lookup_cbk, BOUND_XL(frame), BOUND_XL(frame)->fops->lookup, - &(state->loc), - xattr_req); + &(state->loc), xattr_req); return 0; } @@ -3644,19 +3423,19 @@ server_lookup_resume (call_frame_t *frame, * not for external reference */ int -server_lookup (call_frame_t *frame, - xlator_t *bound_xl, +server_lookup (call_frame_t *frame, xlator_t *bound_xl, gf_hdr_common_t *hdr, size_t hdrlen, struct iobuf *iobuf) { gf_fop_lookup_req_t *req = NULL; server_state_t *state = NULL; - call_stub_t *lookup_stub = NULL; - int32_t ret = -1; - size_t pathlen = 0, baselen = 0; - size_t dictlen = 0; - dict_t *xattr_req = NULL; - char *req_dictbuf = NULL; + call_stub_t *lookup_stub = NULL; + int32_t ret = -1; + size_t pathlen = 0; + size_t baselen = 0; + size_t dictlen = 0; + dict_t *xattr_req = NULL; + char *req_dictbuf = NULL; req = gf_param (hdr); @@ -3682,13 +3461,15 @@ server_lookup (call_frame_t *frame, if (dictlen) { /* Unserialize the dictionary */ - req_dictbuf = memdup (req->dict + pathlen + baselen, dictlen); + req_dictbuf = memdup (req->dict + pathlen + baselen, + dictlen); GF_VALIDATE_OR_GOTO(bound_xl->name, req_dictbuf, fail); xattr_req = dict_new (); GF_VALIDATE_OR_GOTO(bound_xl->name, xattr_req, fail); - ret = dict_unserialize (req_dictbuf, dictlen, &xattr_req); + ret = dict_unserialize (req_dictbuf, dictlen, + &xattr_req); if (ret < 0) { gf_log (bound_xl->name, GF_LOG_ERROR, "%"PRId64": %s (%"PRId64"): failed to " @@ -3705,9 +3486,8 @@ server_lookup (call_frame_t *frame, } } - ret = server_loc_fill (&state->loc, state, - state->ino, state->par, state->bname, - state->path); + ret = server_loc_fill (&state->loc, state, state->ino, state->par, + state->bname, state->path); if (state->loc.inode) { /* revalidate */ @@ -3729,9 +3509,8 @@ server_lookup (call_frame_t *frame, return 0; fail: - server_lookup_cbk (frame, NULL, frame->this, - -1,EINVAL, - NULL, NULL, NULL); + server_lookup_cbk (frame, NULL, frame->this, -1,EINVAL, NULL, NULL, + NULL); if (xattr_req) dict_unref (xattr_req); @@ -3747,15 +3526,15 @@ fail: * * not for external reference */ -int32_t +int server_forget (call_frame_t *frame, xlator_t *bound_xl, gf_hdr_common_t *hdr, size_t hdrlen, struct iobuf *iobuf) { - int index = 0; - ino_t ino = 0; - int32_t count = 0; - inode_t *inode = NULL; + int index = 0; + ino_t ino = 0; + int32_t count = 0; + inode_t *inode = NULL; gf_cbk_forget_req_t *req = NULL; req = gf_param (hdr); @@ -3791,11 +3570,8 @@ server_forget (call_frame_t *frame, xlator_t *bound_xl, } - -int32_t -server_stat_resume (call_frame_t *frame, - xlator_t *this, - loc_t *loc) +int +server_stat_resume (call_frame_t *frame, xlator_t *this, loc_t *loc) { server_state_t *state = NULL; @@ -3805,8 +3581,7 @@ server_stat_resume (call_frame_t *frame, "%"PRId64": STAT \'%s (%"PRId64")\'", frame->root->unique, state->loc.path, state->loc.ino); - STACK_WIND (frame, - server_stat_cbk, + STACK_WIND (frame, server_stat_cbk, BOUND_XL(frame), BOUND_XL(frame)->fops->stat, loc); @@ -3821,17 +3596,16 @@ server_stat_resume (call_frame_t *frame, * * not for external reference */ -int32_t -server_stat (call_frame_t *frame, - xlator_t *bound_xl, +int +server_stat (call_frame_t *frame, xlator_t *bound_xl, gf_hdr_common_t *hdr, size_t hdrlen, struct iobuf *iobuf) { - call_stub_t *stat_stub = NULL; + call_stub_t *stat_stub = NULL; gf_fop_stat_req_t *req = NULL; - server_state_t *state = NULL; - int32_t ret = -1; - size_t pathlen = 0; + server_state_t *state = NULL; + int32_t ret = -1; + size_t pathlen = 0; req = gf_param (hdr); state = CALL_STATE(frame); @@ -3840,12 +3614,10 @@ server_stat (call_frame_t *frame, state->path = req->path; pathlen = STRLEN_0(state->path); - ret = server_loc_fill (&(state->loc), state, - state->ino, state->par, state->bname, - state->path); + ret = server_loc_fill (&(state->loc), state, state->ino, state->par, + state->bname, state->path); - stat_stub = fop_stat_stub (frame, - server_stat_resume, + stat_stub = fop_stat_stub (frame, server_stat_resume, &(state->loc)); GF_VALIDATE_OR_GOTO(bound_xl->name, stat_stub, fail); @@ -3857,17 +3629,13 @@ server_stat (call_frame_t *frame, } return 0; fail: - server_stat_cbk (frame, NULL, frame->this, - -1, EINVAL, - NULL); + server_stat_cbk (frame, NULL, frame->this, -1, EINVAL, NULL); return 0; } -int32_t -server_readlink_resume (call_frame_t *frame, - xlator_t *this, - loc_t *loc, +int +server_readlink_resume (call_frame_t *frame, xlator_t *this, loc_t *loc, size_t size) { server_state_t *state = NULL; @@ -3878,12 +3646,10 @@ server_readlink_resume (call_frame_t *frame, "%"PRId64": READLINK \'%s (%"PRId64")\'", frame->root->unique, state->loc.path, state->loc.ino); - STACK_WIND (frame, - server_readlink_cbk, + STACK_WIND (frame, server_readlink_cbk, BOUND_XL(frame), BOUND_XL(frame)->fops->readlink, - loc, - size); + loc, size); return 0; } @@ -3895,16 +3661,15 @@ server_readlink_resume (call_frame_t *frame, * * not for external reference */ -int32_t -server_readlink (call_frame_t *frame, - xlator_t *bound_xl, +int +server_readlink (call_frame_t *frame, xlator_t *bound_xl, gf_hdr_common_t *hdr, size_t hdrlen, struct iobuf *iobuf) { - call_stub_t *readlink_stub = NULL; + call_stub_t *readlink_stub = NULL; gf_fop_readlink_req_t *req = NULL; - server_state_t *state = NULL; - int32_t ret = -1; + server_state_t *state = NULL; + int32_t ret = -1; req = gf_param (hdr); state = CALL_STATE(frame); @@ -3914,13 +3679,11 @@ server_readlink (call_frame_t *frame, state->ino = ntoh64 (req->ino); state->path = req->path; - ret = server_loc_fill (&(state->loc), state, - state->ino, 0, NULL, state->path); + ret = server_loc_fill (&(state->loc), state, state->ino, 0, NULL, + state->path); - readlink_stub = fop_readlink_stub (frame, - server_readlink_resume, - &(state->loc), - state->size); + readlink_stub = fop_readlink_stub (frame, server_readlink_resume, + &(state->loc), state->size); GF_VALIDATE_OR_GOTO(bound_xl->name, readlink_stub, fail); if ((state->loc.parent == NULL) || @@ -3931,21 +3694,17 @@ server_readlink (call_frame_t *frame, } return 0; fail: - server_readlink_cbk (frame, NULL,frame->this, - -1, EINVAL, - NULL); + server_readlink_cbk (frame, NULL,frame->this, -1, EINVAL, NULL); return 0; } -int32_t -server_create_resume (call_frame_t *frame, - xlator_t *this, - loc_t *loc, - int32_t flags, - mode_t mode, - fd_t *fd) +int +server_create_resume (call_frame_t *frame, xlator_t *this, loc_t *loc, + int32_t flags, mode_t mode, fd_t *fd) { - server_state_t *state = CALL_STATE(frame); + server_state_t *state = NULL; + + state = CALL_STATE(frame); if (state->loc.parent == NULL) state->loc.parent = inode_ref (loc->parent); @@ -3963,20 +3722,15 @@ server_create_resume (call_frame_t *frame, "%"PRId64": CREATE \'%"PRId64"/%s\'", frame->root->unique, state->par, state->bname); - STACK_WIND (frame, - server_create_cbk, + STACK_WIND (frame, server_create_cbk, BOUND_XL(frame), BOUND_XL(frame)->fops->create, - &(state->loc), - flags, - mode, - state->fd); + &(state->loc), flags, mode, state->fd); return 0; fail: - server_create_cbk (frame, NULL, frame->this, - -1, EINVAL, - NULL, NULL, NULL); + server_create_cbk (frame, NULL, frame->this, -1, EINVAL, NULL, NULL, + NULL); return 0; } @@ -3989,7 +3743,7 @@ fail: * * not for external reference */ -int32_t +int server_create (call_frame_t *frame, xlator_t *bound_xl, gf_hdr_common_t *hdr, size_t hdrlen, struct iobuf *iobuf) @@ -3997,8 +3751,8 @@ server_create (call_frame_t *frame, xlator_t *bound_xl, gf_fop_create_req_t *req = NULL; server_state_t *state = NULL; call_stub_t *create_stub = NULL; - int32_t ret = -1; - size_t pathlen = 0; + int32_t ret = -1; + size_t pathlen = 0; req = gf_param (hdr); state = CALL_STATE(frame); @@ -4030,23 +3784,20 @@ server_create (call_frame_t *frame, xlator_t *bound_xl, } return 0; fail: - server_create_cbk (frame, NULL, frame->this, - -1, EINVAL, - NULL, NULL, NULL); + server_create_cbk (frame, NULL, frame->this, -1, EINVAL, NULL, NULL, + NULL); return 0; } -int32_t -server_open_resume (call_frame_t *frame, - xlator_t *this, - loc_t *loc, - int32_t flags, - fd_t *fd) +int +server_open_resume (call_frame_t *frame, xlator_t *this, loc_t *loc, + int32_t flags, fd_t *fd) { - server_state_t *state = CALL_STATE(frame); - fd_t *new_fd = NULL; + server_state_t *state = NULL; + fd_t *new_fd = NULL; + state = CALL_STATE(frame); new_fd = fd_create (loc->inode, frame->root->pid); GF_VALIDATE_OR_GOTO(BOUND_XL(frame)->name, new_fd, fail); @@ -4058,19 +3809,14 @@ server_open_resume (call_frame_t *frame, "%"PRId64": OPEN \'%s (%"PRId64")\'", frame->root->unique, state->path, state->ino); - STACK_WIND (frame, - server_open_cbk, + STACK_WIND (frame, server_open_cbk, BOUND_XL(frame), BOUND_XL(frame)->fops->open, - loc, - flags, - state->fd); + loc, flags, state->fd); return 0; fail: - server_open_cbk (frame, NULL, frame->this, - -1, EINVAL, - NULL); + server_open_cbk (frame, NULL, frame->this, -1, EINVAL, NULL); return 0; } @@ -4082,19 +3828,19 @@ fail: * * not for external reference */ -int32_t +int server_open (call_frame_t *frame, xlator_t *bound_xl, gf_hdr_common_t *hdr, size_t hdrlen, struct iobuf *iobuf) { - call_stub_t *open_stub = NULL; - gf_fop_open_req_t *req = NULL; - server_state_t *state = NULL; - int32_t ret = -1; - size_t pathlen = 0; + call_stub_t *open_stub = NULL; + gf_fop_open_req_t *req = NULL; + server_state_t *state = NULL; + int32_t ret = -1; + size_t pathlen = 0; req = gf_param (hdr); - state = CALL_STATE(frame); + state = CALL_STATE (frame); { state->ino = ntoh64 (req->ino); state->path = req->path; @@ -4117,9 +3863,7 @@ server_open (call_frame_t *frame, xlator_t *bound_xl, } return 0; fail: - server_open_cbk (frame, NULL, frame->this, - -1, EINVAL, - NULL); + server_open_cbk (frame, NULL, frame->this, -1, EINVAL, NULL); return 0; } @@ -4132,16 +3876,16 @@ fail: * * not for external reference */ -int32_t +int server_readv (call_frame_t *frame, xlator_t *bound_xl, gf_hdr_common_t *hdr, size_t hdrlen, struct iobuf *iobuf) { - gf_fop_read_req_t *req = NULL; - server_state_t *state = NULL; + gf_fop_read_req_t *req = NULL; + server_state_t *state = NULL; server_connection_t *conn = NULL; - conn = SERVER_CONNECTION(frame); + conn = SERVER_CONNECTION (frame); req = gf_param (hdr); @@ -4164,15 +3908,14 @@ server_readv (call_frame_t *frame, xlator_t *bound_xl, frame->root->unique, state->fd_no, state->fd->inode->ino, state->offset, (int64_t)state->size); - STACK_WIND (frame, - server_readv_cbk, + STACK_WIND (frame, server_readv_cbk, BOUND_XL(frame), BOUND_XL(frame)->fops->readv, state->fd, state->size, state->offset); return 0; fail: - server_readv_cbk (frame, NULL, frame->this, - -1, EINVAL, NULL, 0, NULL, NULL); + server_readv_cbk (frame, NULL, frame->this, -1, EINVAL, NULL, 0, + NULL, NULL); return 0; } @@ -4185,16 +3928,16 @@ fail: * * not for external reference */ -int32_t +int server_writev (call_frame_t *frame, xlator_t *bound_xl, gf_hdr_common_t *hdr, size_t hdrlen, struct iobuf *iobuf) { server_connection_t *conn = NULL; - gf_fop_write_req_t *req = NULL; - struct iovec iov = {0, }; - struct iobref *iobref = NULL; - server_state_t *state = NULL; + gf_fop_write_req_t *req = NULL; + struct iovec iov = {0, }; + struct iobref *iobref = NULL; + server_state_t *state = NULL; conn = SERVER_CONNECTION(frame); @@ -4227,8 +3970,7 @@ server_writev (call_frame_t *frame, xlator_t *bound_xl, frame->root->unique, state->fd_no, state->fd->inode->ino, state->offset, (int32_t)state->size); - STACK_WIND (frame, - server_writev_cbk, + STACK_WIND (frame, server_writev_cbk, BOUND_XL(frame), BOUND_XL(frame)->fops->writev, state->fd, &iov, 1, state->offset, iobref); @@ -4240,8 +3982,7 @@ server_writev (call_frame_t *frame, xlator_t *bound_xl, return 0; fail: - server_writev_cbk (frame, NULL, frame->this, - -1, EINVAL, NULL); + server_writev_cbk (frame, NULL, frame->this, -1, EINVAL, NULL); if (iobref) iobref_unref (iobref); @@ -4261,14 +4002,14 @@ fail: * * not for external reference */ -int32_t +int server_release (call_frame_t *frame, xlator_t *bound_xl, gf_hdr_common_t *hdr, size_t hdrlen, struct iobuf *iobuf) { - gf_cbk_release_req_t *req = NULL; - server_state_t *state = NULL; - server_connection_t *conn = NULL; + gf_cbk_release_req_t *req = NULL; + server_state_t *state = NULL; + server_connection_t *conn = NULL; conn = SERVER_CONNECTION(frame); @@ -4277,8 +4018,7 @@ server_release (call_frame_t *frame, xlator_t *bound_xl, state->fd_no = ntoh64 (req->fd); - gf_fd_put (conn->fdtable, - state->fd_no); + gf_fd_put (conn->fdtable, state->fd_no); gf_log (bound_xl->name, GF_LOG_TRACE, "%"PRId64": RELEASE \'fd=%"PRId64"\'", @@ -4297,14 +4037,13 @@ server_release (call_frame_t *frame, xlator_t *bound_xl, * * not for external reference */ -int32_t -server_fsync (call_frame_t *frame, - xlator_t *bound_xl, +int +server_fsync (call_frame_t *frame, xlator_t *bound_xl, gf_hdr_common_t *hdr, size_t hdrlen, struct iobuf *iobuf) { - gf_fop_fsync_req_t *req = NULL; - server_state_t *state = NULL; + gf_fop_fsync_req_t *req = NULL; + server_state_t *state = NULL; server_connection_t *conn = NULL; conn = SERVER_CONNECTION(frame); @@ -4326,15 +4065,13 @@ server_fsync (call_frame_t *frame, "%"PRId64": FSYNC \'fd=%"PRId64" (%"PRId64")\'", frame->root->unique, state->fd_no, state->fd->inode->ino); - STACK_WIND (frame, - server_fsync_cbk, + STACK_WIND (frame, server_fsync_cbk, BOUND_XL(frame), BOUND_XL(frame)->fops->fsync, state->fd, state->flags); return 0; fail: - server_fsync_cbk (frame, NULL, frame->this, - -1, EINVAL); + server_fsync_cbk (frame, NULL, frame->this, -1, EINVAL); return 0; } @@ -4348,16 +4085,16 @@ fail: * * not for external reference */ -int32_t +int server_flush (call_frame_t *frame, xlator_t *bound_xl, gf_hdr_common_t *hdr, size_t hdrlen, struct iobuf *iobuf) { - gf_fop_flush_req_t *req = NULL; - server_state_t *state = NULL; + gf_fop_flush_req_t *req = NULL; + server_state_t *state = NULL; server_connection_t *conn = NULL; - conn = SERVER_CONNECTION(frame); + conn = SERVER_CONNECTION (frame); req = gf_param (hdr); state = CALL_STATE(frame); @@ -4368,22 +4105,20 @@ server_flush (call_frame_t *frame, xlator_t *bound_xl, state->fd_no); } - GF_VALIDATE_OR_GOTO(bound_xl->name, state->fd, fail); + GF_VALIDATE_OR_GOTO (bound_xl->name, state->fd, fail); gf_log (bound_xl->name, GF_LOG_TRACE, "%"PRId64": FLUSH \'fd=%"PRId64" (%"PRId64")\'", frame->root->unique, state->fd_no, state->fd->inode->ino); - STACK_WIND (frame, - server_flush_cbk, + STACK_WIND (frame, server_flush_cbk, BOUND_XL(frame), BOUND_XL(frame)->fops->flush, state->fd); return 0; fail: - server_flush_cbk (frame, NULL, frame->this, - -1, EINVAL); + server_flush_cbk (frame, NULL, frame->this, -1, EINVAL); return 0; } @@ -4397,15 +4132,14 @@ fail: * * not for external reference */ -int32_t -server_ftruncate (call_frame_t *frame, - xlator_t *bound_xl, +int +server_ftruncate (call_frame_t *frame, xlator_t *bound_xl, gf_hdr_common_t *hdr, size_t hdrlen, struct iobuf *iobuf) { - gf_fop_ftruncate_req_t *req = NULL; - server_state_t *state = NULL; - server_connection_t *conn = NULL; + gf_fop_ftruncate_req_t *req = NULL; + server_state_t *state = NULL; + server_connection_t *conn = NULL; conn = SERVER_CONNECTION(frame); @@ -4429,16 +4163,13 @@ server_ftruncate (call_frame_t *frame, frame->root->unique, state->fd_no, state->fd->inode->ino, state->offset); - STACK_WIND (frame, - server_ftruncate_cbk, + STACK_WIND (frame, server_ftruncate_cbk, bound_xl, bound_xl->fops->ftruncate, - state->fd, - state->offset); + state->fd, state->offset); return 0; fail: - server_ftruncate_cbk (frame, NULL, frame->this, - -1, EINVAL, NULL); + server_ftruncate_cbk (frame, NULL, frame->this, -1, EINVAL, NULL); return 0; } @@ -4452,17 +4183,16 @@ fail: * * not for external reference */ -int32_t -server_fstat (call_frame_t *frame, - xlator_t *bound_xl, +int +server_fstat (call_frame_t *frame, xlator_t *bound_xl, gf_hdr_common_t *hdr, size_t hdrlen, struct iobuf *iobuf) { - gf_fop_fstat_req_t *req = NULL; - server_state_t *state = NULL; + gf_fop_fstat_req_t *req = NULL; + server_state_t *state = NULL; server_connection_t *conn = NULL; - conn = SERVER_CONNECTION(frame); + conn = SERVER_CONNECTION (frame); req = gf_param (hdr); state = CALL_STATE(frame); @@ -4489,8 +4219,7 @@ server_fstat (call_frame_t *frame, "%"PRId64": FSTAT \'fd=%"PRId64" (%"PRId64")\'", frame->root->unique, state->fd_no, state->fd->inode->ino); - STACK_WIND (frame, - server_fstat_cbk, + STACK_WIND (frame, server_fstat_cbk, bound_xl, bound_xl->fops->fstat, state->fd); @@ -4499,10 +4228,8 @@ out: } -int32_t -server_truncate_resume (call_frame_t *frame, - xlator_t *this, - loc_t *loc, +int +server_truncate_resume (call_frame_t *frame, xlator_t *this, loc_t *loc, off_t offset) { server_state_t *state = NULL; @@ -4513,12 +4240,10 @@ server_truncate_resume (call_frame_t *frame, "%"PRId64": TRUNCATE \'%s (%"PRId64")\'", frame->root->unique, state->path, state->ino); - STACK_WIND (frame, - server_truncate_cbk, + STACK_WIND (frame, server_truncate_cbk, BOUND_XL(frame), BOUND_XL(frame)->fops->truncate, - loc, - offset); + loc, offset); return 0; } @@ -4531,17 +4256,16 @@ server_truncate_resume (call_frame_t *frame, * * not for external reference */ -int32_t -server_truncate (call_frame_t *frame, - xlator_t *bound_xl, +int +server_truncate (call_frame_t *frame, xlator_t *bound_xl, gf_hdr_common_t *hdr, size_t hdrlen, struct iobuf *iobuf) { - call_stub_t *truncate_stub = NULL; + call_stub_t *truncate_stub = NULL; gf_fop_truncate_req_t *req = NULL; - server_state_t *state = NULL; - int32_t ret = -1; - size_t pathlen = 0; + server_state_t *state = NULL; + int32_t ret = -1; + size_t pathlen = 0; req = gf_param (hdr); state = CALL_STATE(frame); @@ -4557,8 +4281,7 @@ server_truncate (call_frame_t *frame, ret = server_loc_fill (&(state->loc), state, state->ino, 0, NULL, state->path); - truncate_stub = fop_truncate_stub (frame, - server_truncate_resume, + truncate_stub = fop_truncate_stub (frame, server_truncate_resume, &(state->loc), state->offset); if ((state->loc.parent == NULL) || @@ -4572,13 +4295,8 @@ server_truncate (call_frame_t *frame, } - - - -int32_t -server_unlink_resume (call_frame_t *frame, - xlator_t *this, - loc_t *loc) +int +server_unlink_resume (call_frame_t *frame, xlator_t *this, loc_t *loc) { server_state_t *state = NULL; @@ -4595,8 +4313,7 @@ server_unlink_resume (call_frame_t *frame, frame->root->unique, state->par, state->path, state->loc.inode->ino); - STACK_WIND (frame, - server_unlink_cbk, + STACK_WIND (frame, server_unlink_cbk, BOUND_XL(frame), BOUND_XL(frame)->fops->unlink, loc); @@ -4611,20 +4328,19 @@ server_unlink_resume (call_frame_t *frame, * * not for external reference */ -int32_t -server_unlink (call_frame_t *frame, - xlator_t *bound_xl, +int +server_unlink (call_frame_t *frame, xlator_t *bound_xl, gf_hdr_common_t *hdr, size_t hdrlen, struct iobuf *iobuf) { - call_stub_t *unlink_stub = NULL; + call_stub_t *unlink_stub = NULL; gf_fop_unlink_req_t *req = NULL; - server_state_t *state = NULL; - int32_t ret = -1; - size_t pathlen = 0; + server_state_t *state = NULL; + int32_t ret = -1; + size_t pathlen = 0; req = gf_param (hdr); - state = CALL_STATE(frame); + state = CALL_STATE (frame); pathlen = STRLEN_0(req->path); @@ -4633,12 +4349,10 @@ server_unlink (call_frame_t *frame, if (IS_NOT_ROOT(pathlen)) state->bname = req->bname + pathlen; - ret = server_loc_fill (&(state->loc), state, - 0, state->par, state->bname, - state->path); + ret = server_loc_fill (&(state->loc), state, 0, state->par, + state->bname, state->path); - unlink_stub = fop_unlink_stub (frame, - server_unlink_resume, + unlink_stub = fop_unlink_stub (frame, server_unlink_resume, &(state->loc)); if ((state->loc.parent == NULL) || @@ -4652,15 +4366,9 @@ server_unlink (call_frame_t *frame, } - - - -int32_t -server_setxattr_resume (call_frame_t *frame, - xlator_t *this, - loc_t *loc, - dict_t *dict, - int32_t flags) +int +server_setxattr_resume (call_frame_t *frame, xlator_t *this, loc_t *loc, + dict_t *dict, int32_t flags) { server_state_t *state = NULL; @@ -4670,13 +4378,10 @@ server_setxattr_resume (call_frame_t *frame, "%"PRId64": SETXATTR \'%s (%"PRId64")\'", frame->root->unique, state->path, state->ino); - STACK_WIND (frame, - server_setxattr_cbk, + STACK_WIND (frame, server_setxattr_cbk, BOUND_XL(frame), BOUND_XL(frame)->fops->setxattr, - loc, - dict, - flags); + loc, dict, flags); return 0; } @@ -4689,20 +4394,19 @@ server_setxattr_resume (call_frame_t *frame, * not for external reference */ -int32_t -server_setxattr (call_frame_t *frame, - xlator_t *bound_xl, +int +server_setxattr (call_frame_t *frame, xlator_t *bound_xl, gf_hdr_common_t *hdr, size_t hdrlen, struct iobuf *iobuf) { - call_stub_t *setxattr_stub = NULL; + call_stub_t *setxattr_stub = NULL; gf_fop_setxattr_req_t *req = NULL; - dict_t *dict = NULL; - server_state_t *state = NULL; - int32_t ret = -1; - size_t pathlen = 0; - size_t dict_len = 0; - char *req_dictbuf = NULL; + dict_t *dict = NULL; + server_state_t *state = NULL; + int32_t ret = -1; + size_t pathlen = 0; + size_t dict_len = 0; + char *req_dictbuf = NULL; req = gf_param (hdr); state = CALL_STATE(frame); @@ -4716,9 +4420,9 @@ server_setxattr (call_frame_t *frame, state->flags = ntoh32 (req->flags); } - ret = server_loc_fill (&(state->loc), state, - state->ino, 0, NULL, state->path); + ret = server_loc_fill (&(state->loc), state, state->ino, 0, NULL, + state->path); { /* Unserialize the dictionary */ req_dictbuf = memdup (req->dict, dict_len); @@ -4741,11 +4445,8 @@ server_setxattr (call_frame_t *frame, } } - setxattr_stub = fop_setxattr_stub (frame, - server_setxattr_resume, - &(state->loc), - dict, - state->flags); + setxattr_stub = fop_setxattr_stub (frame, server_setxattr_resume, + &(state->loc), dict, state->flags); GF_VALIDATE_OR_GOTO(bound_xl->name, setxattr_stub, fail); if (((state->loc.parent == NULL) && IS_NOT_ROOT(pathlen)) || @@ -4763,28 +4464,25 @@ fail: if (dict) dict_unref (dict); - server_setxattr_cbk (frame, NULL, frame->this, - -1, ENOENT); + server_setxattr_cbk (frame, NULL, frame->this, -1, ENOENT); return 0; } -int32_t -server_fsetxattr (call_frame_t *frame, - xlator_t *bound_xl, +int +server_fsetxattr (call_frame_t *frame, xlator_t *bound_xl, gf_hdr_common_t *hdr, size_t hdrlen, struct iobuf *iobuf) { - server_connection_t *conn = NULL; + server_connection_t *conn = NULL; gf_fop_fsetxattr_req_t *req = NULL; - - dict_t *dict = NULL; - server_state_t *state = NULL; - int32_t ret = -1; - size_t pathlen = 0; - size_t dict_len = 0; - char *req_dictbuf = NULL; + dict_t *dict = NULL; + server_state_t *state = NULL; + int32_t ret = -1; + size_t pathlen = 0; + size_t dict_len = 0; + char *req_dictbuf = NULL; conn = SERVER_CONNECTION (frame); @@ -4823,8 +4521,7 @@ server_fsetxattr (call_frame_t *frame, dict->extra_free = req_dictbuf; } - STACK_WIND (frame, - server_setxattr_cbk, + STACK_WIND (frame, server_setxattr_cbk, BOUND_XL(frame), BOUND_XL(frame)->fops->fsetxattr, state->fd, dict, state->flags); @@ -4843,19 +4540,18 @@ fail: } -int32_t -server_fxattrop (call_frame_t *frame, - xlator_t *bound_xl, +int +server_fxattrop (call_frame_t *frame, xlator_t *bound_xl, gf_hdr_common_t *hdr, size_t hdrlen, struct iobuf *iobuf) { - server_connection_t *conn = NULL; + server_connection_t *conn = NULL; gf_fop_fxattrop_req_t *req = NULL; - dict_t *dict = NULL; - server_state_t *state = NULL; - size_t dict_len = 0; - char *req_dictbuf = NULL; - int32_t ret = -1; + dict_t *dict = NULL; + server_state_t *state = NULL; + size_t dict_len = 0; + char *req_dictbuf = NULL; + int32_t ret = -1; conn = SERVER_CONNECTION(frame); @@ -4897,31 +4593,26 @@ server_fxattrop (call_frame_t *frame, "%"PRId64": FXATTROP \'fd=%"PRId64" (%"PRId64")\'", frame->root->unique, state->fd_no, state->fd->inode->ino); - STACK_WIND (frame, - server_fxattrop_cbk, + STACK_WIND (frame, server_fxattrop_cbk, bound_xl, bound_xl->fops->fxattrop, - state->fd, - state->flags, - dict); + state->fd, state->flags, dict); if (dict) dict_unref (dict); return 0; + fail: if (dict) dict_unref (dict); - server_fxattrop_cbk (frame, NULL, frame->this, - -1, EINVAL, NULL); + server_fxattrop_cbk (frame, NULL, frame->this, -1, EINVAL, NULL); return 0; } -int32_t -server_xattrop_resume (call_frame_t *frame, - xlator_t *this, - loc_t *loc, - gf_xattrop_flags_t flags, - dict_t *dict) + +int +server_xattrop_resume (call_frame_t *frame, xlator_t *this, + loc_t *loc, gf_xattrop_flags_t flags, dict_t *dict) { server_state_t *state = NULL; @@ -4931,30 +4622,27 @@ server_xattrop_resume (call_frame_t *frame, "%"PRId64": XATTROP \'%s (%"PRId64")\'", frame->root->unique, state->path, state->ino); - STACK_WIND (frame, - server_xattrop_cbk, + STACK_WIND (frame, server_xattrop_cbk, BOUND_XL(frame), BOUND_XL(frame)->fops->xattrop, - loc, - flags, - dict); + loc, flags, dict); return 0; } -int32_t -server_xattrop (call_frame_t *frame, - xlator_t *bound_xl, + +int +server_xattrop (call_frame_t *frame, xlator_t *bound_xl, gf_hdr_common_t *hdr, size_t hdrlen, struct iobuf *iobuf) { - gf_fop_xattrop_req_t *req = NULL; - dict_t *dict = NULL; - server_state_t *state = NULL; - call_stub_t *xattrop_stub = NULL; - int32_t ret = -1; - size_t pathlen = 0; - size_t dict_len = 0; - char *req_dictbuf = NULL; + gf_fop_xattrop_req_t *req = NULL; + dict_t *dict = NULL; + server_state_t *state = NULL; + call_stub_t *xattrop_stub = NULL; + int32_t ret = -1; + size_t pathlen = 0; + size_t dict_len = 0; + char *req_dictbuf = NULL; req = gf_param (hdr); state = CALL_STATE(frame); @@ -4988,11 +4676,8 @@ server_xattrop (call_frame_t *frame, dict->extra_free = req_dictbuf; } } - xattrop_stub = fop_xattrop_stub (frame, - server_xattrop_resume, - &(state->loc), - state->flags, - dict); + xattrop_stub = fop_xattrop_stub (frame, server_xattrop_resume, + &(state->loc), state->flags, dict); GF_VALIDATE_OR_GOTO(bound_xl->name, xattrop_stub, fail); if (((state->loc.parent == NULL) && IS_NOT_ROOT(pathlen)) || @@ -5009,17 +4694,13 @@ fail: if (dict) dict_unref (dict); - server_xattrop_cbk (frame, NULL, frame->this, - -1, EINVAL, - NULL); + server_xattrop_cbk (frame, NULL, frame->this, -1, EINVAL, NULL); return 0; } -int32_t -server_getxattr_resume (call_frame_t *frame, - xlator_t *this, - loc_t *loc, +int +server_getxattr_resume (call_frame_t *frame, xlator_t *this, loc_t *loc, const char *name) { server_state_t *state = NULL; @@ -5030,12 +4711,10 @@ server_getxattr_resume (call_frame_t *frame, "%"PRId64": GETXATTR \'%s (%"PRId64")\'", frame->root->unique, state->path, state->ino); - STACK_WIND (frame, - server_getxattr_cbk, + STACK_WIND (frame, server_getxattr_cbk, BOUND_XL(frame), BOUND_XL(frame)->fops->getxattr, - loc, - name); + loc, name); return 0; } @@ -5047,18 +4726,17 @@ server_getxattr_resume (call_frame_t *frame, * * not for external reference */ -int32_t -server_getxattr (call_frame_t *frame, - xlator_t *bound_xl, +int +server_getxattr (call_frame_t *frame, xlator_t *bound_xl, gf_hdr_common_t *hdr, size_t hdrlen, struct iobuf *iobuf) { - gf_fop_getxattr_req_t *req = NULL; - call_stub_t *getxattr_stub = NULL; - server_state_t *state = NULL; - int32_t ret = -1; - size_t namelen = 0; - size_t pathlen = 0; + gf_fop_getxattr_req_t *req = NULL; + call_stub_t *getxattr_stub = NULL; + server_state_t *state = NULL; + int32_t ret = -1; + size_t namelen = 0; + size_t pathlen = 0; req = gf_param (hdr); state = CALL_STATE(frame); @@ -5076,10 +4754,8 @@ server_getxattr (call_frame_t *frame, ret = server_loc_fill (&(state->loc), state, state->ino, 0, NULL, state->path); - getxattr_stub = fop_getxattr_stub (frame, - server_getxattr_resume, - &(state->loc), - state->name); + getxattr_stub = fop_getxattr_stub (frame, server_getxattr_resume, + &(state->loc), state->name); if (((state->loc.parent == NULL) && IS_NOT_ROOT(pathlen)) || (state->loc.inode == NULL)) { @@ -5092,17 +4768,15 @@ server_getxattr (call_frame_t *frame, } -int32_t -server_fgetxattr (call_frame_t *frame, - xlator_t *bound_xl, +int +server_fgetxattr (call_frame_t *frame, xlator_t *bound_xl, gf_hdr_common_t *hdr, size_t hdrlen, struct iobuf *iobuf) { server_connection_t *conn = NULL; gf_fop_fgetxattr_req_t *req = NULL; - server_state_t *state = NULL; - - size_t namelen = 0; + server_state_t *state = NULL; + size_t namelen = 0; conn = SERVER_CONNECTION (frame); @@ -5121,36 +4795,30 @@ server_fgetxattr (call_frame_t *frame, state->name = (req->name); } - STACK_WIND (frame, - server_fgetxattr_cbk, + STACK_WIND (frame, server_fgetxattr_cbk, BOUND_XL(frame), BOUND_XL(frame)->fops->fgetxattr, - state->fd, - state->name); + state->fd, state->name); return 0; } -int32_t -server_removexattr_resume (call_frame_t *frame, - xlator_t *this, - loc_t *loc, - const char *name) +int +server_removexattr_resume (call_frame_t *frame, xlator_t *this, + loc_t *loc, const char *name) { server_state_t *state = NULL; - state = CALL_STATE(frame); + state = CALL_STATE (frame); gf_log (BOUND_XL(frame)->name, GF_LOG_TRACE, "%"PRId64": REMOVEXATTR \'%s (%"PRId64")\'", frame->root->unique, state->path, state->ino); - STACK_WIND (frame, - server_removexattr_cbk, + STACK_WIND (frame, server_removexattr_cbk, BOUND_XL(frame), BOUND_XL(frame)->fops->removexattr, - loc, - name); + loc, name); return 0; } @@ -5162,17 +4830,16 @@ server_removexattr_resume (call_frame_t *frame, * * not for external reference */ -int32_t -server_removexattr (call_frame_t *frame, - xlator_t *bound_xl, +int +server_removexattr (call_frame_t *frame, xlator_t *bound_xl, gf_hdr_common_t *hdr, size_t hdrlen, struct iobuf *iobuf) { - gf_fop_removexattr_req_t *req = NULL; - call_stub_t *removexattr_stub = NULL; - server_state_t *state = NULL; - int32_t ret = -1; - size_t pathlen = 0; + gf_fop_removexattr_req_t *req = NULL; + call_stub_t *removexattr_stub = NULL; + server_state_t *state = NULL; + int32_t ret = -1; + size_t pathlen = 0; req = gf_param (hdr); state = CALL_STATE(frame); @@ -5189,7 +4856,7 @@ server_removexattr (call_frame_t *frame, state->ino, 0, NULL, state->path); removexattr_stub = fop_removexattr_stub (frame, - server_removexattr_resume, + server_removexattr_resume, &(state->loc), state->name); @@ -5212,15 +4879,14 @@ server_removexattr (call_frame_t *frame, * * not for external reference */ -int32_t -server_statfs (call_frame_t *frame, - xlator_t *bound_xl, +int +server_statfs (call_frame_t *frame, xlator_t *bound_xl, gf_hdr_common_t *hdr, size_t hdrlen, struct iobuf *iobuf) { gf_fop_statfs_req_t *req = NULL; - server_state_t *state = NULL; - int32_t ret = -1; + server_state_t *state = NULL; + int32_t ret = -1; req = gf_param (hdr); @@ -5228,15 +4894,14 @@ server_statfs (call_frame_t *frame, state->ino = ntoh64 (req->ino); state->path = req->path; - ret = server_loc_fill (&state->loc, state, - state->ino, 0, NULL, state->path); + ret = server_loc_fill (&state->loc, state, state->ino, 0, NULL, + state->path); gf_log (BOUND_XL(frame)->name, GF_LOG_TRACE, "%"PRId64": STATFS \'%s (%"PRId64")\'", frame->root->unique, state->path, state->ino); - STACK_WIND (frame, - server_statfs_cbk, + STACK_WIND (frame, server_statfs_cbk, BOUND_XL(frame), BOUND_XL(frame)->fops->statfs, &(state->loc)); @@ -5245,16 +4910,14 @@ server_statfs (call_frame_t *frame, } - -int32_t -server_opendir_resume (call_frame_t *frame, - xlator_t *this, - loc_t *loc, +int +server_opendir_resume (call_frame_t *frame, xlator_t *this, loc_t *loc, fd_t *fd) { - server_state_t *state = CALL_STATE(frame); - fd_t *new_fd = NULL; + server_state_t *state = NULL; + fd_t *new_fd = NULL; + state = CALL_STATE (frame); new_fd = fd_create (loc->inode, frame->root->pid); state->fd = fd_ref (new_fd); @@ -5262,12 +4925,11 @@ server_opendir_resume (call_frame_t *frame, "%"PRId64": OPENDIR \'%s (%"PRId64")\'", frame->root->unique, state->path, state->ino); - STACK_WIND (frame, - server_opendir_cbk, + STACK_WIND (frame, server_opendir_cbk, BOUND_XL(frame), BOUND_XL(frame)->fops->opendir, - loc, - state->fd); + loc, state->fd); + return 0; } @@ -5280,16 +4942,16 @@ server_opendir_resume (call_frame_t *frame, * * not for external reference */ -int32_t +int server_opendir (call_frame_t *frame, xlator_t *bound_xl, gf_hdr_common_t *hdr, size_t hdrlen, struct iobuf *iobuf) { - call_stub_t *opendir_stub = NULL; - gf_fop_opendir_req_t *req = NULL; - server_state_t *state = NULL; - int32_t ret = -1; - size_t pathlen = 0; + call_stub_t *opendir_stub = NULL; + gf_fop_opendir_req_t *req = NULL; + server_state_t *state = NULL; + int32_t ret = -1; + size_t pathlen = 0; req = gf_param (hdr); state = CALL_STATE(frame); @@ -5299,13 +4961,11 @@ server_opendir (call_frame_t *frame, xlator_t *bound_xl, state->ino = ntoh64 (req->ino); } - ret = server_loc_fill (&state->loc, state, - state->ino, 0, NULL, state->path); + ret = server_loc_fill (&state->loc, state, state->ino, 0, NULL, + state->path); - opendir_stub = fop_opendir_stub (frame, - server_opendir_resume, - &(state->loc), - NULL); + opendir_stub = fop_opendir_stub (frame, server_opendir_resume, + &(state->loc), NULL); if (((state->loc.parent == NULL) && IS_NOT_ROOT(pathlen)) || (state->loc.inode == NULL)) { @@ -5326,14 +4986,14 @@ server_opendir (call_frame_t *frame, xlator_t *bound_xl, * * not for external reference */ -int32_t +int server_releasedir (call_frame_t *frame, xlator_t *bound_xl, gf_hdr_common_t *hdr, size_t hdrlen, struct iobuf *iobuf) { gf_cbk_releasedir_req_t *req = NULL; - server_state_t *state = NULL; - server_connection_t *conn = NULL; + server_state_t *state = NULL; + server_connection_t *conn = NULL; conn = SERVER_CONNECTION(frame); @@ -5341,16 +5001,14 @@ server_releasedir (call_frame_t *frame, xlator_t *bound_xl, state = CALL_STATE(frame); state->fd_no = ntoh64 (req->fd); - state->fd = gf_fd_fdptr_get (conn->fdtable, - state->fd_no); + state->fd = gf_fd_fdptr_get (conn->fdtable, state->fd_no); if (state->fd == NULL) { gf_log (frame->this->name, GF_LOG_ERROR, "fd - %"PRId64": unresolved fd", state->fd_no); - server_releasedir_cbk (frame, NULL, frame->this, - -1, EBADF); + server_releasedir_cbk (frame, NULL, frame->this, -1, EBADF); goto out; } @@ -5360,8 +5018,7 @@ server_releasedir (call_frame_t *frame, xlator_t *bound_xl, gf_fd_put (conn->fdtable, state->fd_no); - server_releasedir_cbk (frame, NULL, frame->this, - 0, 0); + server_releasedir_cbk (frame, NULL, frame->this, 0, 0); out: return 0; } @@ -5375,17 +5032,16 @@ out: * * not for external reference */ -int32_t -server_getdents (call_frame_t *frame, - xlator_t *bound_xl, +int +server_getdents (call_frame_t *frame, xlator_t *bound_xl, gf_hdr_common_t *hdr, size_t hdrlen, struct iobuf *iobuf) { - gf_fop_getdents_req_t *req = NULL; - server_state_t *state = NULL; - server_connection_t *conn = NULL; + gf_fop_getdents_req_t *req = NULL; + server_state_t *state = NULL; + server_connection_t *conn = NULL; - conn = SERVER_CONNECTION(frame); + conn = SERVER_CONNECTION (frame); req = gf_param (hdr); state = CALL_STATE(frame); @@ -5406,9 +5062,8 @@ server_getdents (call_frame_t *frame, "fd - %"PRId64": unresolved fd", state->fd_no); - server_getdents_cbk (frame, NULL, frame->this, - -1, EBADF, NULL, 0); - + server_getdents_cbk (frame, NULL, frame->this, -1, EBADF, + NULL, 0); goto out; } @@ -5418,14 +5073,10 @@ server_getdents (call_frame_t *frame, frame->root->unique, state->fd_no, state->fd->inode->ino, state->offset, (int64_t)state->size); - STACK_WIND (frame, - server_getdents_cbk, + STACK_WIND (frame, server_getdents_cbk, bound_xl, bound_xl->fops->getdents, - state->fd, - state->size, - state->offset, - state->flags); + state->fd, state->size, state->offset, state->flags); out: return 0; } @@ -5439,7 +5090,7 @@ out: * * not for external reference */ -int32_t +int server_readdir (call_frame_t *frame, xlator_t *bound_xl, gf_hdr_common_t *hdr, size_t hdrlen, struct iobuf *iobuf) @@ -5468,9 +5119,7 @@ server_readdir (call_frame_t *frame, xlator_t *bound_xl, "fd - %"PRId64": unresolved fd", state->fd_no); - server_readdir_cbk (frame, NULL, frame->this, - -1, EBADF, NULL); - + server_readdir_cbk (frame, NULL, frame->this, -1, EBADF, NULL); goto out; } @@ -5480,8 +5129,7 @@ server_readdir (call_frame_t *frame, xlator_t *bound_xl, frame->root->unique, state->fd_no, state->fd->inode->ino, state->offset, (int64_t)state->size); - STACK_WIND (frame, - server_readdir_cbk, + STACK_WIND (frame, server_readdir_cbk, bound_xl, bound_xl->fops->readdir, state->fd, state->size, state->offset); @@ -5499,17 +5147,16 @@ out: * * not for external reference */ -int32_t -server_fsyncdir (call_frame_t *frame, - xlator_t *bound_xl, +int +server_fsyncdir (call_frame_t *frame, xlator_t *bound_xl, gf_hdr_common_t *hdr, size_t hdrlen, struct iobuf *iobuf) { gf_fop_fsyncdir_req_t *req = NULL; - server_state_t *state = NULL; - server_connection_t *conn = NULL; + server_state_t *state = NULL; + server_connection_t *conn = NULL; - conn = SERVER_CONNECTION(frame); + conn = SERVER_CONNECTION (frame); req = gf_param (hdr); state = CALL_STATE(frame); @@ -5527,8 +5174,7 @@ server_fsyncdir (call_frame_t *frame, "fd - %"PRId64": unresolved fd", state->fd_no); - server_fsyncdir_cbk (frame, NULL, frame->this, - -1, EBADF); + server_fsyncdir_cbk (frame, NULL, frame->this, -1, EBADF); goto out; } @@ -5536,8 +5182,7 @@ server_fsyncdir (call_frame_t *frame, "%"PRId64": FSYNCDIR \'fd=%"PRId64" (%"PRId64")\'", frame->root->unique, state->fd_no, state->fd->inode->ino); - STACK_WIND (frame, - server_fsyncdir_cbk, + STACK_WIND (frame, server_fsyncdir_cbk, bound_xl, bound_xl->fops->fsyncdir, state->fd, state->flags); @@ -5546,16 +5191,13 @@ out: } -int32_t -server_mknod_resume (call_frame_t *frame, - xlator_t *this, - loc_t *loc, - mode_t mode, - dev_t dev) +int +server_mknod_resume (call_frame_t *frame, xlator_t *this, loc_t *loc, + mode_t mode, dev_t dev) { server_state_t *state = NULL; - state = CALL_STATE(frame); + state = CALL_STATE (frame); if (state->loc.parent == NULL) state->loc.parent = inode_ref (loc->parent); @@ -5566,14 +5208,14 @@ server_mknod_resume (call_frame_t *frame, "%"PRId64": MKNOD \'%"PRId64"/%s\'", frame->root->unique, state->par, state->bname); - STACK_WIND (frame, - server_mknod_cbk, + STACK_WIND (frame, server_mknod_cbk, BOUND_XL(frame), BOUND_XL(frame)->fops->mknod, &(state->loc), mode, dev); return 0; } + /* * server_mknod - mknod function for server protocol * @frame: call frame @@ -5582,20 +5224,19 @@ server_mknod_resume (call_frame_t *frame, * * not for external reference */ -int32_t -server_mknod (call_frame_t *frame, - xlator_t *bound_xl, +int +server_mknod (call_frame_t *frame, xlator_t *bound_xl, gf_hdr_common_t *hdr, size_t hdrlen, struct iobuf *iobuf) { gf_fop_mknod_req_t *req = NULL; - server_state_t *state = NULL; - call_stub_t *mknod_stub = NULL; - int32_t ret = -1; - size_t pathlen = 0; + server_state_t *state = NULL; + call_stub_t *mknod_stub = NULL; + int32_t ret = -1; + size_t pathlen = 0; req = gf_param (hdr); - state = CALL_STATE(frame); + state = CALL_STATE (frame); { pathlen = STRLEN_0(req->path); @@ -5607,9 +5248,8 @@ server_mknod (call_frame_t *frame, state->mode = ntoh32 (req->mode); state->dev = ntoh64 (req->dev); } - ret = server_loc_fill (&(state->loc), state, - 0, state->par, state->bname, - state->path); + ret = server_loc_fill (&(state->loc), state, 0, state->par, + state->bname, state->path); mknod_stub = fop_mknod_stub (frame, server_mknod_resume, &(state->loc), state->mode, state->dev); @@ -5623,16 +5263,15 @@ server_mknod (call_frame_t *frame, return 0; } -int32_t -server_mkdir_resume (call_frame_t *frame, - xlator_t *this, - loc_t *loc, + +int +server_mkdir_resume (call_frame_t *frame, xlator_t *this, loc_t *loc, mode_t mode) { server_state_t *state = NULL; - state = CALL_STATE(frame); + state = CALL_STATE (frame); if (state->loc.parent == NULL) state->loc.parent = inode_ref (loc->parent); @@ -5643,12 +5282,10 @@ server_mkdir_resume (call_frame_t *frame, "%"PRId64": MKDIR \'%"PRId64"/%s\'", frame->root->unique, state->par, state->bname); - STACK_WIND (frame, - server_mkdir_cbk, + STACK_WIND (frame, server_mkdir_cbk, BOUND_XL(frame), BOUND_XL(frame)->fops->mkdir, - &(state->loc), - state->mode); + &(state->loc), state->mode); return 0; } @@ -5661,18 +5298,17 @@ server_mkdir_resume (call_frame_t *frame, * * not for external reference */ -int32_t -server_mkdir (call_frame_t *frame, - xlator_t *bound_xl, +int +server_mkdir (call_frame_t *frame, xlator_t *bound_xl, gf_hdr_common_t *hdr, size_t hdrlen, struct iobuf *iobuf) { gf_fop_mkdir_req_t *req = NULL; - server_state_t *state = NULL; - call_stub_t *mkdir_stub = NULL; - int32_t ret = -1; - size_t pathlen = 0; - + server_state_t *state = NULL; + call_stub_t *mkdir_stub = NULL; + int32_t ret = -1; + size_t pathlen = 0; + req = gf_param (hdr); state = CALL_STATE(frame); { @@ -5685,9 +5321,8 @@ server_mkdir (call_frame_t *frame, } - ret = server_loc_fill (&(state->loc), state, - 0, state->par, state->bname, - state->path); + ret = server_loc_fill (&(state->loc), state, 0, state->par, + state->bname, state->path); mkdir_stub = fop_mkdir_stub (frame, server_mkdir_resume, &(state->loc), state->mode); @@ -5702,10 +5337,8 @@ server_mkdir (call_frame_t *frame, } -int32_t -server_rmdir_resume (call_frame_t *frame, - xlator_t *this, - loc_t *loc) +int +server_rmdir_resume (call_frame_t *frame, xlator_t *this, loc_t *loc) { server_state_t *state = NULL; @@ -5721,8 +5354,7 @@ server_rmdir_resume (call_frame_t *frame, "%"PRId64": RMDIR \'%"PRId64"/%s\'", frame->root->unique, state->par, state->bname); - STACK_WIND (frame, - server_rmdir_cbk, + STACK_WIND (frame, server_rmdir_cbk, BOUND_XL(frame), BOUND_XL(frame)->fops->rmdir, loc); @@ -5737,17 +5369,16 @@ server_rmdir_resume (call_frame_t *frame, * * not for external reference */ -int32_t -server_rmdir (call_frame_t *frame, - xlator_t *bound_xl, +int +server_rmdir (call_frame_t *frame, xlator_t *bound_xl, gf_hdr_common_t *hdr, size_t hdrlen, struct iobuf *iobuf) { - call_stub_t *rmdir_stub = NULL; + call_stub_t *rmdir_stub = NULL; gf_fop_rmdir_req_t *req = NULL; - server_state_t *state = NULL; - int32_t ret = -1; - size_t pathlen = 0; + server_state_t *state = NULL; + int32_t ret = -1; + size_t pathlen = 0; req = gf_param (hdr); state = CALL_STATE(frame); @@ -5759,12 +5390,10 @@ server_rmdir (call_frame_t *frame, } - ret = server_loc_fill (&(state->loc), state, - state->ino, state->par, state->bname, - state->path); + ret = server_loc_fill (&(state->loc), state, state->ino, state->par, + state->bname, state->path); - rmdir_stub = fop_rmdir_stub (frame, - server_rmdir_resume, + rmdir_stub = fop_rmdir_stub (frame, server_rmdir_resume, &(state->loc)); if ((state->loc.parent == NULL) || @@ -5778,17 +5407,13 @@ server_rmdir (call_frame_t *frame, } - -int32_t -server_chown_resume (call_frame_t *frame, - xlator_t *this, - loc_t *loc, - uid_t uid, - gid_t gid) +int +server_chown_resume (call_frame_t *frame, xlator_t *this, loc_t *loc, + uid_t uid, gid_t gid) { server_state_t *state = NULL; - state = CALL_STATE(frame); + state = CALL_STATE (frame); gf_log (BOUND_XL(frame)->name, GF_LOG_TRACE, "%"PRId64": CHOWN \'%s (%"PRId64")\'", @@ -5810,17 +5435,16 @@ server_chown_resume (call_frame_t *frame, * * not for external reference */ -int32_t -server_chown (call_frame_t *frame, - xlator_t *bound_xl, +int +server_chown (call_frame_t *frame, xlator_t *bound_xl, gf_hdr_common_t *hdr, size_t hdrlen, struct iobuf *iobuf) { - call_stub_t *chown_stub = NULL; + call_stub_t *chown_stub = NULL; gf_fop_chown_req_t *req = NULL; - server_state_t *state = NULL; - int32_t ret = -1; - size_t pathlen = 0; + server_state_t *state = NULL; + int32_t ret = -1; + size_t pathlen = 0; req = gf_param (hdr); state = CALL_STATE(frame); @@ -5832,15 +5456,11 @@ server_chown (call_frame_t *frame, state->gid = ntoh32 (req->gid); } + ret = server_loc_fill (&(state->loc), state, state->ino, 0, NULL, + state->path); - ret = server_loc_fill (&(state->loc), state, - state->ino, 0, NULL, state->path); - - chown_stub = fop_chown_stub (frame, - server_chown_resume, - &(state->loc), - state->uid, - state->gid); + chown_stub = fop_chown_stub (frame, server_chown_resume, + &(state->loc), state->uid, state->gid); if (((state->loc.parent == NULL) && IS_NOT_ROOT(pathlen)) || (state->loc.inode == NULL)) { @@ -5853,10 +5473,8 @@ server_chown (call_frame_t *frame, } -int32_t -server_chmod_resume (call_frame_t *frame, - xlator_t *this, - loc_t *loc, +int +server_chmod_resume (call_frame_t *frame, xlator_t *this, loc_t *loc, mode_t mode) { server_state_t *state = NULL; @@ -5867,12 +5485,10 @@ server_chmod_resume (call_frame_t *frame, "%"PRId64": CHMOD \'%s (%"PRId64")\'", frame->root->unique, state->path, state->ino); - STACK_WIND (frame, - server_chmod_cbk, + STACK_WIND (frame, server_chmod_cbk, BOUND_XL(frame), BOUND_XL(frame)->fops->chmod, - loc, - mode); + loc, mode); return 0; } @@ -5885,17 +5501,16 @@ server_chmod_resume (call_frame_t *frame, * * not for external reference */ -int32_t -server_chmod (call_frame_t *frame, - xlator_t *bound_xl, +int +server_chmod (call_frame_t *frame, xlator_t *bound_xl, gf_hdr_common_t *hdr, size_t hdrlen, struct iobuf *iobuf) { - call_stub_t *chmod_stub = NULL; + call_stub_t *chmod_stub = NULL; gf_fop_chmod_req_t *req = NULL; - server_state_t *state = NULL; - int32_t ret = -1; - size_t pathlen = 0; + server_state_t *state = NULL; + int32_t ret = -1; + size_t pathlen = 0; req = gf_param (hdr); @@ -5908,13 +5523,11 @@ server_chmod (call_frame_t *frame, state->mode = ntoh32 (req->mode); } - ret = server_loc_fill (&(state->loc), state, - state->ino, 0, NULL, state->path); + ret = server_loc_fill (&(state->loc), state, state->ino, 0, NULL, + state->path); - chmod_stub = fop_chmod_stub (frame, - server_chmod_resume, - &(state->loc), - state->mode); + chmod_stub = fop_chmod_stub (frame, server_chmod_resume, + &(state->loc), state->mode); if (((state->loc.parent == NULL) && IS_NOT_ROOT(pathlen)) || (state->loc.inode == NULL)) { @@ -5927,10 +5540,8 @@ server_chmod (call_frame_t *frame, } -int32_t -server_utimens_resume (call_frame_t *frame, - xlator_t *this, - loc_t *loc, +int +server_utimens_resume (call_frame_t *frame, xlator_t *this, loc_t *loc, struct timespec *tv) { server_state_t *state = NULL; @@ -5941,12 +5552,10 @@ server_utimens_resume (call_frame_t *frame, "%"PRId64": UTIMENS \'%s (%"PRId64")\'", frame->root->unique, state->path, state->ino); - STACK_WIND (frame, - server_utimens_cbk, + STACK_WIND (frame, server_utimens_cbk, BOUND_XL(frame), BOUND_XL(frame)->fops->utimens, - loc, - tv); + loc, tv); return 0; } @@ -5958,17 +5567,16 @@ server_utimens_resume (call_frame_t *frame, * * not for external reference */ -int32_t -server_utimens (call_frame_t *frame, - xlator_t *bound_xl, +int +server_utimens (call_frame_t *frame, xlator_t *bound_xl, gf_hdr_common_t *hdr, size_t hdrlen, struct iobuf *iobuf) { - call_stub_t *utimens_stub = NULL; + call_stub_t *utimens_stub = NULL; gf_fop_utimens_req_t *req = NULL; - server_state_t *state = NULL; - int32_t ret = -1; - size_t pathlen = 0; + server_state_t *state = NULL; + int32_t ret = -1; + size_t pathlen = 0; req = gf_param (hdr); state = CALL_STATE(frame); @@ -5981,13 +5589,11 @@ server_utimens (call_frame_t *frame, } - ret = server_loc_fill (&(state->loc), state, - state->ino, 0, NULL, state->path); + ret = server_loc_fill (&(state->loc), state, state->ino, 0, NULL, + state->path); - utimens_stub = fop_utimens_stub (frame, - server_utimens_resume, - &(state->loc), - state->tv); + utimens_stub = fop_utimens_stub (frame, server_utimens_resume, + &(state->loc), state->tv); if (((state->loc.parent == NULL) && IS_NOT_ROOT(pathlen)) || (state->loc.inode == NULL)) { @@ -6000,10 +5606,8 @@ server_utimens (call_frame_t *frame, } - -int32_t -server_inodelk_resume (call_frame_t *frame, - xlator_t *this, +int +server_inodelk_resume (call_frame_t *frame, xlator_t *this, const char *volume, loc_t *loc, int32_t cmd, struct flock *flock) { @@ -6022,8 +5626,7 @@ server_inodelk_resume (call_frame_t *frame, "%"PRId64": INODELK \'%s (%"PRId64")\'", frame->root->unique, state->path, state->ino); - STACK_WIND (frame, - server_inodelk_cbk, + STACK_WIND (frame, server_inodelk_cbk, BOUND_XL(frame), BOUND_XL(frame)->fops->inodelk, volume, loc, cmd, flock); @@ -6032,17 +5635,16 @@ server_inodelk_resume (call_frame_t *frame, } -int32_t -server_inodelk (call_frame_t *frame, - xlator_t *bound_xl, +int +server_inodelk (call_frame_t *frame, xlator_t *bound_xl, gf_hdr_common_t *hdr, size_t hdrlen, struct iobuf *iobuf) { - call_stub_t *inodelk_stub = NULL; + call_stub_t *inodelk_stub = NULL; gf_fop_inodelk_req_t *req = NULL; - server_state_t *state = NULL; - size_t pathlen = 0; - size_t vollen = 0; + server_state_t *state = NULL; + size_t pathlen = 0; + size_t vollen = 0; req = gf_param (hdr); state = CALL_STATE(frame); @@ -6085,11 +5687,10 @@ server_inodelk (call_frame_t *frame, } - server_loc_fill (&(state->loc), state, - state->ino, 0, NULL, state->path); + server_loc_fill (&(state->loc), state, state->ino, 0, NULL, + state->path); - inodelk_stub = fop_inodelk_stub (frame, - server_inodelk_resume, + inodelk_stub = fop_inodelk_stub (frame, server_inodelk_resume, state->volume, &state->loc, state->cmd, &state->flock); @@ -6104,15 +5705,14 @@ server_inodelk (call_frame_t *frame, } -int32_t -server_finodelk (call_frame_t *frame, - xlator_t *bound_xl, +int +server_finodelk (call_frame_t *frame, xlator_t *bound_xl, gf_hdr_common_t *hdr, size_t hdrlen, struct iobuf *iobuf) { - gf_fop_finodelk_req_t *req = NULL; - server_state_t *state = NULL; - server_connection_t *conn = NULL; + gf_fop_finodelk_req_t *req = NULL; + server_state_t *state = NULL; + server_connection_t *conn = NULL; conn = SERVER_CONNECTION(frame); @@ -6179,9 +5779,8 @@ server_finodelk (call_frame_t *frame, } -int32_t -server_entrylk_resume (call_frame_t *frame, - xlator_t *this, +int +server_entrylk_resume (call_frame_t *frame, xlator_t *this, const char *volume, loc_t *loc, const char *name, entrylk_cmd cmd, entrylk_type type) { @@ -6200,8 +5799,7 @@ server_entrylk_resume (call_frame_t *frame, "%"PRId64": ENTRYLK \'%s (%"PRId64") \'", frame->root->unique, state->path, state->ino); - STACK_WIND (frame, - server_entrylk_cbk, + STACK_WIND (frame, server_entrylk_cbk, BOUND_XL(frame), BOUND_XL(frame)->fops->entrylk, volume, loc, name, cmd, type); @@ -6217,21 +5815,20 @@ server_entrylk_resume (call_frame_t *frame, * * not for external reference */ -int32_t -server_entrylk (call_frame_t *frame, - xlator_t *bound_xl, +int +server_entrylk (call_frame_t *frame, xlator_t *bound_xl, gf_hdr_common_t *hdr, size_t hdrlen, struct iobuf *iobuf) { gf_fop_entrylk_req_t *req = NULL; - server_state_t *state = NULL; - call_stub_t *entrylk_stub = NULL; - size_t pathlen = 0; - size_t namelen = 0; - size_t vollen = 0; + server_state_t *state = NULL; + call_stub_t *entrylk_stub = NULL; + size_t pathlen = 0; + size_t namelen = 0; + size_t vollen = 0; req = gf_param (hdr); - state = CALL_STATE(frame); + state = CALL_STATE (frame); { pathlen = STRLEN_0(req->path); @@ -6249,14 +5846,12 @@ server_entrylk (call_frame_t *frame, } - server_loc_fill (&(state->loc), state, - state->ino, 0, NULL, state->path); + server_loc_fill (&(state->loc), state, state->ino, 0, NULL, + state->path); - entrylk_stub = fop_entrylk_stub (frame, - server_entrylk_resume, - state->volume, - &state->loc, state->name, state->cmd, - state->type); + entrylk_stub = fop_entrylk_stub (frame, server_entrylk_resume, + state->volume, &state->loc, + state->name, state->cmd, state->type); if (((state->loc.parent == NULL) && IS_NOT_ROOT(pathlen)) || (state->loc.inode == NULL)) { @@ -6269,19 +5864,18 @@ server_entrylk (call_frame_t *frame, } -int32_t -server_fentrylk (call_frame_t *frame, - xlator_t *bound_xl, +int +server_fentrylk (call_frame_t *frame, xlator_t *bound_xl, gf_hdr_common_t *hdr, size_t hdrlen, struct iobuf *iobuf) { gf_fop_fentrylk_req_t *req = NULL; - server_state_t *state = NULL; - size_t namelen = 0; - size_t vollen = 0; - server_connection_t *conn = NULL; + server_state_t *state = NULL; + size_t namelen = 0; + size_t vollen = 0; + server_connection_t *conn = NULL; - conn = SERVER_CONNECTION(frame); + conn = SERVER_CONNECTION (frame); req = gf_param (hdr); state = CALL_STATE(frame); @@ -6307,8 +5901,7 @@ server_fentrylk (call_frame_t *frame, "fd - %"PRId64": unresolved fd", state->fd_no); - server_fentrylk_cbk (frame, NULL, frame->this, - -1, EBADF); + server_fentrylk_cbk (frame, NULL, frame->this, -1, EBADF); return -1; } @@ -6325,26 +5918,22 @@ server_fentrylk (call_frame_t *frame, } -int32_t -server_access_resume (call_frame_t *frame, - xlator_t *this, - loc_t *loc, +int +server_access_resume (call_frame_t *frame, xlator_t *this, loc_t *loc, int32_t mask) { server_state_t *state = NULL; - state = CALL_STATE(frame); + state = CALL_STATE (frame); gf_log (BOUND_XL(frame)->name, GF_LOG_TRACE, "%"PRId64": ACCESS \'%s (%"PRId64")\'", frame->root->unique, state->path, state->ino); - STACK_WIND (frame, - server_access_cbk, + STACK_WIND (frame, server_access_cbk, BOUND_XL(frame), BOUND_XL(frame)->fops->access, - loc, - mask); + loc, mask); return 0; } @@ -6356,17 +5945,16 @@ server_access_resume (call_frame_t *frame, * * not for external reference */ -int32_t -server_access (call_frame_t *frame, - xlator_t *bound_xl, +int +server_access (call_frame_t *frame, xlator_t *bound_xl, gf_hdr_common_t *hdr, size_t hdrlen, struct iobuf *iobuf) { - call_stub_t *access_stub = NULL; + call_stub_t *access_stub = NULL; gf_fop_access_req_t *req = NULL; - server_state_t *state = NULL; - int32_t ret = -1; - size_t pathlen = 0; + server_state_t *state = NULL; + int32_t ret = -1; + size_t pathlen = 0; req = gf_param (hdr); state = CALL_STATE(frame); @@ -6377,13 +5965,11 @@ server_access (call_frame_t *frame, state->path = req->path; pathlen = STRLEN_0(state->path); - ret = server_loc_fill (&(state->loc), state, - state->ino, 0, NULL, state->path); + ret = server_loc_fill (&(state->loc), state, state->ino, 0, NULL, + state->path); - access_stub = fop_access_stub (frame, - server_access_resume, - &(state->loc), - state->mask); + access_stub = fop_access_stub (frame, server_access_resume, + &(state->loc), state->mask); if (((state->loc.parent == NULL) && IS_NOT_ROOT(pathlen)) || (state->loc.inode == NULL)) { @@ -6396,15 +5982,13 @@ server_access (call_frame_t *frame, } -int32_t -server_symlink_resume (call_frame_t *frame, - xlator_t *this, - const char *linkname, - loc_t *loc) +int +server_symlink_resume (call_frame_t *frame, xlator_t *this, + const char *linkname, loc_t *loc) { server_state_t *state = NULL; - state = CALL_STATE(frame); + state = CALL_STATE (frame); if (state->loc.parent == NULL) state->loc.parent = inode_ref (loc->parent); @@ -6414,12 +5998,10 @@ server_symlink_resume (call_frame_t *frame, "%"PRId64": SYMLINK \'%"PRId64"/%s \'", frame->root->unique, state->par, state->bname); - STACK_WIND (frame, - server_symlink_cbk, + STACK_WIND (frame, server_symlink_cbk, BOUND_XL(frame), BOUND_XL(frame)->fops->symlink, - linkname, - &(state->loc)); + linkname, &(state->loc)); return 0; } @@ -6433,18 +6015,17 @@ server_symlink_resume (call_frame_t *frame, * not for external reference */ -int32_t -server_symlink (call_frame_t *frame, - xlator_t *bound_xl, +int +server_symlink (call_frame_t *frame, xlator_t *bound_xl, gf_hdr_common_t *hdr, size_t hdrlen, struct iobuf *iobuf) { - server_state_t *state = NULL; + server_state_t *state = NULL; gf_fop_symlink_req_t *req = NULL; - call_stub_t *symlink_stub = NULL; - int32_t ret = -1; - size_t pathlen = 0; - size_t baselen = 0; + call_stub_t *symlink_stub = NULL; + int32_t ret = -1; + size_t pathlen = 0; + size_t baselen = 0; req = gf_param (hdr); state = CALL_STATE(frame); @@ -6459,9 +6040,8 @@ server_symlink (call_frame_t *frame, state->name = (req->linkname + pathlen + baselen); } - ret = server_loc_fill (&(state->loc), state, - 0, state->par, state->bname, - state->path); + ret = server_loc_fill (&(state->loc), state, 0, state->par, + state->bname, state->path); symlink_stub = fop_symlink_stub (frame, server_symlink_resume, state->name, &(state->loc)); @@ -6475,15 +6055,14 @@ server_symlink (call_frame_t *frame, return 0; } -int32_t -server_link_resume (call_frame_t *frame, - xlator_t *this, - loc_t *oldloc, + +int +server_link_resume (call_frame_t *frame, xlator_t *this, loc_t *oldloc, loc_t *newloc) { server_state_t *state = NULL; - state = CALL_STATE(frame); + state = CALL_STATE (frame); if (state->loc.parent == NULL) state->loc.parent = inode_ref (oldloc->parent); @@ -6506,12 +6085,10 @@ server_link_resume (call_frame_t *frame, frame->root->unique, state->par2, state->bname2, state->path, state->ino); - STACK_WIND (frame, - server_link_cbk, + STACK_WIND (frame, server_link_cbk, BOUND_XL(frame), BOUND_XL(frame)->fops->link, - &(state->loc), - &(state->loc2)); + &(state->loc), &(state->loc2)); return 0; } @@ -6523,19 +6100,18 @@ server_link_resume (call_frame_t *frame, * * not for external reference */ -int32_t -server_link (call_frame_t *frame, - xlator_t *this, +int +server_link (call_frame_t *frame, xlator_t *this, gf_hdr_common_t *hdr, size_t hdrlen, struct iobuf *iobuf) { gf_fop_link_req_t *req = NULL; - server_state_t *state = NULL; - call_stub_t *link_stub = NULL; - int32_t ret = -1; - size_t oldpathlen = 0; - size_t newpathlen = 0; - size_t newbaselen = 0; + server_state_t *state = NULL; + call_stub_t *link_stub = NULL; + int32_t ret = -1; + size_t oldpathlen = 0; + size_t newpathlen = 0; + size_t newbaselen = 0; req = gf_param (hdr); @@ -6552,12 +6128,10 @@ server_link (call_frame_t *frame, state->par2 = ntoh64 (req->newpar); } - ret = server_loc_fill (&(state->loc), state, - state->ino, 0, NULL, + ret = server_loc_fill (&(state->loc), state, state->ino, 0, NULL, state->path); - ret = server_loc_fill (&(state->loc2), state, - 0, state->par2, state->bname2, - state->path2); + ret = server_loc_fill (&(state->loc2), state, 0, state->par2, + state->bname2, state->path2); link_stub = fop_link_stub (frame, server_link_resume, &(state->loc), &(state->loc2)); @@ -6575,15 +6149,13 @@ server_link (call_frame_t *frame, } -int32_t -server_rename_resume (call_frame_t *frame, - xlator_t *this, - loc_t *oldloc, +int +server_rename_resume (call_frame_t *frame, xlator_t *this, loc_t *oldloc, loc_t *newloc) { server_state_t *state = NULL; - state = CALL_STATE(frame); + state = CALL_STATE (frame); if (state->loc.parent == NULL) state->loc.parent = inode_ref (oldloc->parent); @@ -6601,12 +6173,10 @@ server_rename_resume (call_frame_t *frame, frame->root->unique, state->path, state->par, state->bname, state->path2, state->par2, state->bname2); - STACK_WIND (frame, - server_rename_cbk, + STACK_WIND (frame, server_rename_cbk, BOUND_XL(frame), BOUND_XL(frame)->fops->rename, - &(state->loc), - &(state->loc2)); + &(state->loc), &(state->loc2)); return 0; } @@ -6618,24 +6188,23 @@ server_rename_resume (call_frame_t *frame, * * not for external reference */ -int32_t -server_rename (call_frame_t *frame, - xlator_t *bound_xl, +int +server_rename (call_frame_t *frame, xlator_t *bound_xl, gf_hdr_common_t *hdr, size_t hdrlen, struct iobuf *iobuf) { gf_fop_rename_req_t *req = NULL; - server_state_t *state = NULL; - call_stub_t *rename_stub = NULL; - int32_t ret = -1; - size_t oldpathlen = 0; - size_t oldbaselen = 0; - size_t newpathlen = 0; - size_t newbaselen = 0; + server_state_t *state = NULL; + call_stub_t *rename_stub = NULL; + int32_t ret = -1; + size_t oldpathlen = 0; + size_t oldbaselen = 0; + size_t newpathlen = 0; + size_t newbaselen = 0; req = gf_param (hdr); - state = CALL_STATE(frame); + state = CALL_STATE (frame); { oldpathlen = STRLEN_0(req->oldpath); oldbaselen = STRLEN_0(req->oldbname + oldpathlen); @@ -6653,17 +6222,13 @@ server_rename (call_frame_t *frame, state->par2 = ntoh64 (req->newpar); } - ret = server_loc_fill (&(state->loc), state, - 0, state->par, state->bname, - state->path); - ret = server_loc_fill (&(state->loc2), state, - 0, state->par2, state->bname2, - state->path2); + ret = server_loc_fill (&(state->loc), state, 0, state->par, + state->bname, state->path); + ret = server_loc_fill (&(state->loc2), state, 0, state->par2, + state->bname2, state->path2); - rename_stub = fop_rename_stub (frame, - server_rename_resume, - &(state->loc), - &(state->loc2)); + rename_stub = fop_rename_stub (frame, server_rename_resume, + &(state->loc), &(state->loc2)); if ((state->loc.parent == NULL) || (state->loc.inode == NULL)){ @@ -6689,21 +6254,20 @@ server_rename (call_frame_t *frame, * not for external reference */ -int32_t -server_lk (call_frame_t *frame, - xlator_t *bound_xl, +int +server_lk (call_frame_t *frame, xlator_t *bound_xl, gf_hdr_common_t *hdr, size_t hdrlen, struct iobuf *iobuf) { - struct flock lock = {0, }; - gf_fop_lk_req_t *req = NULL; - server_state_t *state = NULL; + struct flock lock = {0, }; + gf_fop_lk_req_t *req = NULL; + server_state_t *state = NULL; server_connection_t *conn = NULL; - conn = SERVER_CONNECTION(frame); + conn = SERVER_CONNECTION (frame); req = gf_param (hdr); - state = CALL_STATE(frame); + state = CALL_STATE (frame); { state->fd_no = ntoh64 (req->fd); if (state->fd_no >= 0) @@ -6720,9 +6284,7 @@ server_lk (call_frame_t *frame, "fd - %"PRId64": unresolved fd", state->fd_no); - server_lk_cbk (frame, NULL, frame->this, - -1, EBADF, NULL); - + server_lk_cbk (frame, NULL, frame->this, -1, EBADF, NULL); goto out; } @@ -6765,7 +6327,6 @@ server_lk (call_frame_t *frame, BOUND_XL(frame), BOUND_XL(frame)->fops->lk, state->fd, state->cmd, &lock); - out: return 0; } @@ -6779,24 +6340,23 @@ out: * @params: * */ -int32_t -server_setdents (call_frame_t *frame, - xlator_t *bound_xl, +int +server_setdents (call_frame_t *frame, xlator_t *bound_xl, gf_hdr_common_t *hdr, size_t hdrlen, struct iobuf *iobuf) { - server_connection_t *conn = NULL; + server_connection_t *conn = NULL; gf_fop_setdents_req_t *req = NULL; server_state_t *state = NULL; - dir_entry_t *entry = NULL; - dir_entry_t *trav = NULL; - dir_entry_t *prev = NULL; - int32_t count = 0; - int32_t i = 0; - int32_t bread = 0; - char *ender = NULL; - char *buffer_ptr = NULL; - char tmp_buf[512] = {0,}; + dir_entry_t *entry = NULL; + dir_entry_t *trav = NULL; + dir_entry_t *prev = NULL; + int32_t count = 0; + int32_t i = 0; + int32_t bread = 0; + char *ender = NULL; + char *buffer_ptr = NULL; + char tmp_buf[512] = {0,}; conn = SERVER_CONNECTION(frame); @@ -6815,8 +6375,7 @@ server_setdents (call_frame_t *frame, "fd - %"PRId64": unresolved fd", state->fd_no); - server_setdents_cbk (frame, NULL, frame->this, - -1, EBADF); + server_setdents_cbk (frame, NULL, frame->this, -1, EBADF); goto out; } @@ -6827,8 +6386,7 @@ server_setdents (call_frame_t *frame, "returning EINVAL", state->fd_no, state->fd->inode->ino); - server_setdents_cbk (frame, NULL, frame->this, - -1, EINVAL); + server_setdents_cbk (frame, NULL, frame->this, -1, ENOMEM); goto out; } @@ -6882,22 +6440,9 @@ server_setdents (call_frame_t *frame, uint32_t ctime_nsec; sscanf (tmp_buf, GF_STAT_PRINT_FMT_STR, - &dev, - &ino, - &mode, - &nlink, - &uid, - &gid, - &rdev, - &size, - &blksize, - &blocks, - &atime, - &atime_nsec, - &mtime, - &mtime_nsec, - &ctime, - &ctime_nsec); + &dev, &ino, &mode, &nlink, &uid, &gid, &rdev, + &size, &blksize, &blocks, &atime, &atime_nsec, + &mtime, &mtime_nsec, &ctime, &ctime_nsec); trav->buf.st_dev = dev; trav->buf.st_ino = ino; @@ -6936,20 +6481,15 @@ server_setdents (call_frame_t *frame, prev = trav; } - gf_log (bound_xl->name, GF_LOG_TRACE, "%"PRId64": SETDENTS \'fd=%"PRId64" (%"PRId64"); count=%"PRId64, frame->root->unique, state->fd_no, state->fd->inode->ino, (int64_t)state->nr_count); - STACK_WIND (frame, - server_setdents_cbk, + STACK_WIND (frame, server_setdents_cbk, BOUND_XL(frame), BOUND_XL(frame)->fops->setdents, - state->fd, - state->flags, - entry, - state->nr_count); + state->fd, state->flags, entry, state->nr_count); /* Free the variables allocated in this fop here */ @@ -6974,8 +6514,6 @@ out: /* xxx_MOPS */ - - int _volfile_update_checksum (xlator_t *this, char *key, uint32_t checksum) { @@ -7115,7 +6653,7 @@ _validate_volfile_checksum (xlator_t *this, char *key, (checksum != temp_volfile->checksum)) ret = -1; - out: +out: return ret; } @@ -7127,29 +6665,27 @@ _validate_volfile_checksum (xlator_t *this, char *key, * @params: * */ -int32_t -mop_getspec (call_frame_t *frame, - xlator_t *bound_xl, +int +mop_getspec (call_frame_t *frame, xlator_t *bound_xl, gf_hdr_common_t *hdr, size_t hdrlen, struct iobuf *iobuf) { gf_hdr_common_t *_hdr = NULL; gf_mop_getspec_rsp_t *rsp = NULL; - int32_t ret = -1; - int32_t op_errno = ENOENT; - int32_t gf_errno = 0; - int32_t spec_fd = -1; - size_t file_len = 0; - size_t _hdrlen = 0; - char *filename = NULL; - struct stat stbuf = {0,}; - + int32_t ret = -1; + int32_t op_errno = ENOENT; + int32_t gf_errno = 0; + int32_t spec_fd = -1; + size_t file_len = 0; + size_t _hdrlen = 0; + char *filename = NULL; + struct stat stbuf = {0,}; gf_mop_getspec_req_t *req = NULL; - uint32_t checksum = 0; - uint32_t flags = 0; - uint32_t keylen = 0; - char *key = NULL; - server_conf_t *conf = NULL; + uint32_t checksum = 0; + uint32_t flags = 0; + uint32_t keylen = 0; + char *key = NULL; + server_conf_t *conf = NULL; req = gf_param (hdr); flags = ntoh32 (req->flags); @@ -7210,19 +6746,16 @@ fail: return 0; } -int32_t -server_checksum_cbk (call_frame_t *frame, - void *cookie, - xlator_t *this, - int32_t op_ret, - int32_t op_errno, - uint8_t *fchecksum, - uint8_t *dchecksum) + +int +server_checksum_cbk (call_frame_t *frame, void *cookie, xlator_t *this, + int32_t op_ret, int32_t op_errno, + uint8_t *fchecksum, uint8_t *dchecksum) { gf_hdr_common_t *hdr = NULL; gf_fop_checksum_rsp_t *rsp = NULL; - size_t hdrlen = 0; - int32_t gf_errno = 0; + size_t hdrlen = 0; + int32_t gf_errno = 0; hdrlen = gf_hdr_len (rsp, ZR_FILENAME_MAX + 1 + ZR_FILENAME_MAX + 1); hdr = gf_hdr_new (rsp, ZR_FILENAME_MAX + 1 + ZR_FILENAME_MAX + 1); @@ -7246,14 +6779,14 @@ server_checksum_cbk (call_frame_t *frame, return 0; } -int32_t -server_checksum (call_frame_t *frame, - xlator_t *bound_xl, + +int +server_checksum (call_frame_t *frame, xlator_t *bound_xl, gf_hdr_common_t *hdr, size_t hdrlen, struct iobuf *iobuf) { - loc_t loc = {0,}; - int32_t flag = 0; + loc_t loc = {0,}; + int32_t flag = 0; gf_fop_checksum_req_t *req = NULL; req = gf_param (hdr); @@ -7267,13 +6800,10 @@ server_checksum (call_frame_t *frame, "%"PRId64": CHECKSUM \'%s (%"PRId64")\'", frame->root->unique, loc.path, loc.ino); - STACK_WIND (frame, - server_checksum_cbk, + STACK_WIND (frame, server_checksum_cbk, BOUND_XL(frame), BOUND_XL(frame)->fops->checksum, - &loc, - flag); - + &loc, flag); return 0; } @@ -7285,9 +6815,8 @@ server_checksum (call_frame_t *frame, * @params: parameter dictionary * */ -int32_t -mop_getvolume (call_frame_t *frame, - xlator_t *bound_xl, +int +mop_getvolume (call_frame_t *frame, xlator_t *bound_xl, gf_hdr_common_t *hdr, size_t hdrlen, struct iobuf *iobuf) { @@ -7299,8 +6828,7 @@ struct __get_xl_struct { xlator_t *reply; }; -void __check_and_set (xlator_t *each, - void *data) +void __check_and_set (xlator_t *each, void *data) { if (!strcmp (each->name, ((struct __get_xl_struct *) data)->name)) @@ -7308,8 +6836,7 @@ void __check_and_set (xlator_t *each, } static xlator_t * -get_xlator_by_name (xlator_t *some_xl, - const char *name) +get_xlator_by_name (xlator_t *some_xl, const char *name) { struct __get_xl_struct get = { .name = name, @@ -7358,6 +6885,7 @@ mop_setvolume (call_frame_t *frame, xlator_t *bound_xl, char *msg = NULL; char *volfile_key = NULL; uint32_t checksum = 0; + int32_t lru_limit = 1024; params = dict_new (); reply = dict_new (); @@ -7539,8 +7067,6 @@ mop_setvolume (call_frame_t *frame, xlator_t *bound_xl, (conn->bound_xl->itable == NULL)) { /* create inode table for this bound_xl, if one doesn't already exist */ - int32_t lru_limit = 1024; - lru_limit = INODE_LRU_LIMIT (frame->this); gf_log (trans->xl->name, GF_LOG_TRACE, @@ -7606,35 +7132,28 @@ fail: * not for external reference */ -int32_t -server_mop_stats_cbk (call_frame_t *frame, - void *cookie, - xlator_t *xl, - int32_t ret, - int32_t op_errno, +int +server_mop_stats_cbk (call_frame_t *frame, void *cookie, xlator_t *this, + int32_t ret, int32_t op_errno, struct xlator_stats *stats) { /* TODO: get this information from somewhere else, not extern */ gf_hdr_common_t *hdr = NULL; gf_mop_stats_rsp_t *rsp = NULL; - char buffer[256] = {0,}; - int64_t glusterfsd_stats_nr_clients = 0; - size_t hdrlen = 0; - size_t buf_len = 0; - int32_t gf_errno = 0; + char buffer[256] = {0,}; + int64_t glusterfsd_stats_nr_clients = 0; + size_t hdrlen = 0; + size_t buf_len = 0; + int32_t gf_errno = 0; if (ret >= 0) { sprintf (buffer, "%"PRIx64",%"PRIx64",%"PRIx64 ",%"PRIx64",%"PRIx64",%"PRIx64 ",%"PRIx64",%"PRIx64"\n", - stats->nr_files, - stats->disk_usage, - stats->free_disk, - stats->total_disk_size, - stats->read_usage, - stats->write_usage, - stats->disk_speed, + stats->nr_files, stats->disk_usage, stats->free_disk, + stats->total_disk_size, stats->read_usage, + stats->write_usage, stats->disk_speed, glusterfsd_stats_nr_clients); buf_len = strlen (buffer); @@ -7664,21 +7183,19 @@ server_mop_stats_cbk (call_frame_t *frame, * @params: parameter dictionary * */ -static int32_t -mop_stats (call_frame_t *frame, - xlator_t *bound_xl, +int +mop_stats (call_frame_t *frame, xlator_t *bound_xl, gf_hdr_common_t *hdr, size_t hdrlen, struct iobuf *iobuf) { - int32_t flag = 0; + int32_t flag = 0; gf_mop_stats_req_t *req = NULL; req = gf_param (hdr); flag = ntoh32 (req->flags); - STACK_WIND (frame, - server_mop_stats_cbk, + STACK_WIND (frame, server_mop_stats_cbk, bound_xl, bound_xl->mops->stats, flag); @@ -7686,15 +7203,15 @@ mop_stats (call_frame_t *frame, return 0; } -int32_t -mop_ping (call_frame_t *frame, - xlator_t *bound_xl, + +int +mop_ping (call_frame_t *frame, xlator_t *bound_xl, gf_hdr_common_t *hdr, size_t hdrlen, struct iobuf *iobuf) { gf_hdr_common_t *rsp_hdr = NULL; gf_mop_ping_rsp_t *rsp = NULL; - size_t rsp_hdrlen = 0; + size_t rsp_hdrlen = 0; rsp_hdrlen = gf_hdr_len (rsp, 0); rsp_hdr = gf_hdr_new (rsp, 0); @@ -7716,15 +7233,14 @@ mop_ping (call_frame_t *frame, * */ -int32_t -unknown_op_cbk (call_frame_t *frame, - int32_t type, - int32_t opcode) +int +unknown_op_cbk (call_frame_t *frame, int32_t type, int32_t opcode) { gf_hdr_common_t *hdr = NULL; gf_fop_flush_rsp_t *rsp = NULL; - size_t hdrlen = 0; - int32_t gf_errno = 0; + size_t hdrlen = 0; + int32_t gf_errno = 0; + hdrlen = gf_hdr_len (rsp, 0); hdr = gf_hdr_new (rsp, 0); rsp = gf_param (hdr); @@ -7894,7 +7410,7 @@ int protocol_server_interpret (xlator_t *this, transport_t *trans, char *hdr_p, size_t hdrlen, struct iobuf *iobuf) { - server_connection_t *conn = NULL; + server_connection_t *conn = NULL; gf_hdr_common_t *hdr = NULL; xlator_t *bound_xl = NULL; call_frame_t *frame = NULL; @@ -7978,8 +7494,8 @@ protocol_server_interpret (xlator_t *this, transport_t *trans, * not for external reference */ int -server_nop_cbk (call_frame_t *frame, void *cookie, - xlator_t *this, int32_t op_ret, int32_t op_errno) +server_nop_cbk (call_frame_t *frame, void *cookie, xlator_t *this, + int32_t op_ret, int32_t op_errno) { server_state_t *state = NULL; @@ -7993,16 +7509,15 @@ server_nop_cbk (call_frame_t *frame, void *cookie, static void -get_auth_types (dict_t *this, - char *key, - data_t *value, - void *data) -{ - dict_t *auth_dict = data; - char *saveptr = NULL, *tmp = NULL; - char *key_cpy = NULL; - int32_t ret = -1; - +get_auth_types (dict_t *this, char *key, data_t *value, void *data) +{ + dict_t *auth_dict = NULL; + char *saveptr = NULL; + char *tmp = NULL; + char *key_cpy = NULL; + int32_t ret = -1; + + auth_dict = data; key_cpy = strdup (key); GF_VALIDATE_OR_GOTO("server", key_cpy, out); @@ -8030,16 +7545,17 @@ out: } -static int +int validate_auth_options (xlator_t *this, dict_t *dict) { - int ret = -1; - int error = 0; + int ret = -1; + int error = 0; xlator_list_t *trav = NULL; - data_pair_t *pair = NULL; - char *saveptr = NULL, *tmp = NULL; - char *key_cpy = NULL; - + data_pair_t *pair = NULL; + char *saveptr = NULL; + char *tmp = NULL; + char *key_cpy = NULL; + trav = this->children; while (trav) { error = -1; @@ -8084,10 +7600,10 @@ validate_auth_options (xlator_t *this, dict_t *dict) int init (xlator_t *this) { - int32_t ret = -1; - transport_t *trans = NULL; + int32_t ret = -1; + transport_t *trans = NULL; server_conf_t *conf = NULL; - data_t *data = NULL; + data_t *data = NULL; if (this->children == NULL) { gf_log (this->name, GF_LOG_ERROR, |