Skip to content

Commit

Permalink
use acl op response result to decide metadata update.
Browse files Browse the repository at this point in the history
  • Loading branch information
xiaoyuyao committed Aug 8, 2019
1 parent 27e959a commit db2cf91
Showing 1 changed file with 11 additions and 6 deletions.
Original file line number Diff line number Diff line change
Expand Up @@ -47,18 +47,23 @@ public void addToDBBatch(OMMetadataManager omMetadataManager,

// For OmResponse with failure, this should do nothing. This method is
// not called in failure scenario in OM code.
if (getOMResponse().getStatus() == OzoneManagerProtocolProtos.Status.OK &&
getOMResponse().getSuccess()) {
omMetadataManager.getVolumeTable().putWithBatch(batchOperation,
omMetadataManager.getVolumeKey(omVolumeArgs.getVolume()),
omVolumeArgs);
if (getOMResponse().getSuccess()) {
if ((getOMResponse().hasAddAclResponse() &&
getOMResponse().getAddAclResponse().getResponse()) ||
(getOMResponse().hasRemoveAclResponse() &&
getOMResponse().getRemoveAclResponse().getResponse()) ||
(getOMResponse().hasSetAclResponse() &&
getOMResponse().getSetAclResponse().getResponse())) {
omMetadataManager.getVolumeTable().putWithBatch(batchOperation,
omMetadataManager.getVolumeKey(omVolumeArgs.getVolume()),
omVolumeArgs);
}
}
}

@VisibleForTesting
public OmVolumeArgs getOmVolumeArgs() {
return omVolumeArgs;
}

}

0 comments on commit db2cf91

Please sign in to comment.