diff options
| author | Pavan Sondur <pavan@gluster.com> | 2010-10-01 05:45:12 +0000 | 
|---|---|---|
| committer | Vijay Bellur <vijay@dev.gluster.com> | 2010-10-01 05:05:53 -0700 | 
| commit | fd2e7d007e5362f0738cd9a825349abcf5d27d8f (patch) | |
| tree | d86cd9b0162cd43cb6d1e573b24f6c49a5e353f4 /xlators/cluster/afr/src | |
| parent | 55c6e672503a2451186e17b9c1b7daf6e3ae5463 (diff) | |
Changes to replace flock with gf_flock across GlusterFS.
Signed-off-by: Pavan Vilas Sondur <pavan@gluster.com>
Signed-off-by: Vijay Bellur <vijay@dev.gluster.com>
BUG: 865 (Add locks recovery support in GlusterFS)
URL: http://bugs.gluster.com/cgi-bin/bugzilla3/show_bug.cgi?id=865
Diffstat (limited to 'xlators/cluster/afr/src')
| -rw-r--r-- | xlators/cluster/afr/src/afr-common.c | 10 | ||||
| -rw-r--r-- | xlators/cluster/afr/src/afr-lk-common.c | 26 | ||||
| -rw-r--r-- | xlators/cluster/afr/src/afr.h | 6 | 
3 files changed, 21 insertions, 21 deletions
diff --git a/xlators/cluster/afr/src/afr-common.c b/xlators/cluster/afr/src/afr-common.c index e5a7e87c72f..ee5fa3a606e 100644 --- a/xlators/cluster/afr/src/afr-common.c +++ b/xlators/cluster/afr/src/afr-common.c @@ -1871,7 +1871,7 @@ afr_inodelk_cbk (call_frame_t *frame, void *cookie,  int32_t  afr_inodelk (call_frame_t *frame, xlator_t *this, -             const char *volume, loc_t *loc, int32_t cmd, struct flock *flock) +             const char *volume, loc_t *loc, int32_t cmd, struct gf_flock *flock)  {          afr_private_t *priv = NULL;          afr_local_t *local  = NULL; @@ -1953,7 +1953,7 @@ afr_finodelk_cbk (call_frame_t *frame, void *cookie,  int32_t  afr_finodelk (call_frame_t *frame, xlator_t *this, -              const char *volume, fd_t *fd, int32_t cmd, struct flock *flock) +              const char *volume, fd_t *fd, int32_t cmd, struct gf_flock *flock)  {          afr_private_t *priv = NULL;          afr_local_t *local  = NULL; @@ -2264,7 +2264,7 @@ out:  int32_t  afr_lk_unlock_cbk (call_frame_t *frame, void *cookie, xlator_t *this, -                   int32_t op_ret, int32_t op_errno, struct flock *lock) +                   int32_t op_ret, int32_t op_errno, struct gf_flock *lock)  {          afr_local_t * local = NULL; @@ -2325,7 +2325,7 @@ afr_lk_unlock (call_frame_t *frame, xlator_t *this)  int32_t  afr_lk_cbk (call_frame_t *frame, void *cookie, xlator_t *this, -            int32_t op_ret, int32_t op_errno, struct flock *lock) +            int32_t op_ret, int32_t op_errno, struct gf_flock *lock)  {  	afr_local_t *local = NULL;  	afr_private_t *priv = NULL; @@ -2391,7 +2391,7 @@ afr_lk_cbk (call_frame_t *frame, void *cookie, xlator_t *this,  int  afr_lk (call_frame_t *frame, xlator_t *this,          fd_t *fd, int32_t cmd, -        struct flock *flock) +        struct gf_flock *flock)  {          afr_private_t *priv = NULL;          afr_local_t *local = NULL; diff --git a/xlators/cluster/afr/src/afr-lk-common.c b/xlators/cluster/afr/src/afr-lk-common.c index 12050af1d35..06f35597429 100644 --- a/xlators/cluster/afr/src/afr-lk-common.c +++ b/xlators/cluster/afr/src/afr-lk-common.c @@ -120,7 +120,7 @@ internal_lock_count (call_frame_t *frame, xlator_t *this,  static void  afr_print_inodelk (char *str, int size, int cmd, -                   struct flock *flock, uint64_t owner) +                   struct gf_flock *flock, uint64_t owner)  {          char *cmd_str = NULL;          char *type_str = NULL; @@ -247,7 +247,7 @@ afr_set_lock_call_type (afr_lock_call_type_t lock_call_type,  static void  afr_trace_inodelk_out (call_frame_t *frame, afr_lock_call_type_t lock_call_type, -                       afr_lock_op_type_t lk_op_type, struct flock *flock, +                       afr_lock_op_type_t lk_op_type, struct gf_flock *flock,                         int op_ret, int op_errno, int32_t child_index)  {          xlator_t            *this     = NULL; @@ -286,7 +286,7 @@ afr_trace_inodelk_out (call_frame_t *frame, afr_lock_call_type_t lock_call_type,  static void  afr_trace_inodelk_in (call_frame_t *frame, afr_lock_call_type_t lock_call_type, -                      afr_lock_op_type_t lk_op_type, struct flock *flock, +                      afr_lock_op_type_t lk_op_type, struct gf_flock *flock,                        int32_t cmd, int32_t child_index)  {          xlator_t            *this     = NULL; @@ -578,7 +578,7 @@ afr_unlock_inodelk (call_frame_t *frame, xlator_t *this)          afr_local_t         *local    = NULL;          afr_private_t       *priv     = NULL; -        struct flock flock; +        struct gf_flock flock;          int call_count = 0;          int i = 0; @@ -908,7 +908,7 @@ afr_lock_blocking (call_frame_t *frame, xlator_t *this, int child_index)  	const char          *lower_name  = NULL;  	const char          *higher_name = NULL; -	struct flock flock; +	struct gf_flock flock;          uint64_t ctx;          int ret = 0; @@ -1360,7 +1360,7 @@ afr_nonblocking_inodelk (call_frame_t *frame, xlator_t *this)          uint64_t ctx        = 0;          int      i          = 0;          int      ret        = 0; -        struct flock flock; +        struct gf_flock flock;          local    = frame->local;          int_lock = &local->internal_lock; @@ -1836,15 +1836,15 @@ out:  int32_t  afr_get_locks_fd_cbk (call_frame_t *frame, void *cookie, xlator_t *this, -                      int32_t op_ret, int32_t op_errno, struct flock *lock); +                      int32_t op_ret, int32_t op_errno, struct gf_flock *lock);  int32_t  afr_recover_lock_cbk (call_frame_t *frame, void *cookie, xlator_t *this, -                      int32_t op_ret, int32_t op_errno, struct flock *lock) +                      int32_t op_ret, int32_t op_errno, struct gf_flock *lock)  {          afr_local_t   *local = NULL;          afr_private_t *priv  = NULL;          int32_t source_child = 0; -        struct flock flock   = {0,}; +        struct gf_flock flock   = {0,};          if (op_ret) {                  gf_log (this->name, GF_LOG_DEBUG, @@ -1871,7 +1871,7 @@ cleanup:  int  afr_recover_lock (call_frame_t *frame, xlator_t *this, -                  struct flock *flock) +                  struct gf_flock *flock)  {          afr_local_t   *local             = NULL;          afr_private_t *priv              = NULL; @@ -1892,7 +1892,7 @@ afr_recover_lock (call_frame_t *frame, xlator_t *this,  }  static int -is_afr_lock_eol (struct flock *lock) +is_afr_lock_eol (struct gf_flock *lock)  {          int ret = 0; @@ -1904,7 +1904,7 @@ is_afr_lock_eol (struct flock *lock)  int32_t  afr_get_locks_fd_cbk (call_frame_t *frame, void *cookie, xlator_t *this, -                      int32_t op_ret, int32_t op_errno, struct flock *lock) +                      int32_t op_ret, int32_t op_errno, struct gf_flock *lock)  {          if (op_ret) {                  gf_log (this->name, GF_LOG_DEBUG, @@ -1939,7 +1939,7 @@ afr_lock_recovery (call_frame_t *frame, xlator_t *this)          fd_t          *fd           = NULL;          int            ret          = 0;          int32_t        source_child = 0; -        struct flock   flock        = {0,}; +        struct gf_flock   flock        = {0,};          priv  = this->private;          local = frame->local; diff --git a/xlators/cluster/afr/src/afr.h b/xlators/cluster/afr/src/afr.h index 005847b412f..ed50fdfbfd2 100644 --- a/xlators/cluster/afr/src/afr.h +++ b/xlators/cluster/afr/src/afr.h @@ -235,7 +235,7 @@ afr_index_for_transaction_type (afr_transaction_type type)  typedef struct {          loc_t *lk_loc; -        struct flock lk_flock; +        struct gf_flock lk_flock;          const char *lk_basename;          const char *lower_basename; @@ -347,8 +347,8 @@ typedef struct _afr_local {  		struct {  			int32_t cmd; -                        struct flock user_flock; -                        struct flock ret_flock; +                        struct gf_flock user_flock; +                        struct gf_flock ret_flock;  			unsigned char *locked_nodes;  		} lk;  | 
