read flow modified

Author: sbk173

xlators/cluster/ec/src/ec-inode-read.c

@@ -1375,6 +1375,9 @@ ec_manager_readv(ec_fop_data_t *fop, int32_t state)
             if (ec->read_mask) {
                 fop->mask &= ec->read_mask;
             }
+            if (fop->fd->inode->read_mask != 0){
+                fop->mask &= fop->fd->inode->read_mask;
+            }
             ec_dispatch_min(fop);
 
             return EC_STATE_PREPARE_ANSWER;

xlators/cluster/ec/src/ec-inode-write.c

@@ -710,19 +710,27 @@ ec_setxattr(call_frame_t *frame, xlator_t *this, uintptr_t target,
     ec_cbk_t callback = {.setxattr = func};
     ec_fop_data_t *fop = NULL;
     int32_t error = ENOMEM;
-    int ret = 0;
     data_t *dict_data = NULL;
     char *mask_key = "user.readmask";
+    int ret = 0;
+    int op_ret = -1;
 
     gf_msg_trace("ec", 0, "EC(SETXATTR) %p", frame);
 
     VALIDATE_OR_GOTO(this, out);
     GF_VALIDATE_OR_GOTO(this->name, frame, out);
     GF_VALIDATE_OR_GOTO(this->name, this->private, out);
 
-    ret = dict_lookup(dict, mask_key, &data);
+    ret = dict_lookup(dict, mask_key, &dict_data);
     if(!ret && dict_data){
-        
+        if(loc != NULL && loc->inode != NULL){
+            loc->inode->read_mask = data_to_uint16(dict_data);
+        }
+        dict_deln(dict, mask_key, strlen(mask_key));
+        dict_data = NULL;
+        error = 0;
+        op_ret = 0;
+        goto out;
     }
 
     fop = ec_fop_data_allocate(frame, this, GF_FOP_SETXATTR, 0, target,
@@ -765,7 +773,7 @@ ec_setxattr(call_frame_t *frame, xlator_t *this, uintptr_t target,
 
     ec_t *ec = fop->xl->private;
     int64_t val = 0;
-    int ret = dict_get_int64(fop->dict, SQUOTA_LIMIT_KEY, &val);
+    ret = dict_get_int64(fop->dict, SQUOTA_LIMIT_KEY, &val);
     if (IS_SUCCESS(ret)) {
         /* divide the total usage to priv->fragments */
         int64_t new_value = val / ec->fragments;
@@ -783,7 +791,7 @@ ec_setxattr(call_frame_t *frame, xlator_t *this, uintptr_t target,
     if (fop != NULL) {
         ec_manager(fop, error);
     } else {
-        func(frame, NULL, this, -1, error, NULL);
+        func(frame, NULL, this, op_ret, error, NULL);
     }
 }