xiaoyuyao commented on a change in pull request #1134:
URL: https://github.com/apache/hadoop-ozone/pull/1134#discussion_r447251957
##########
File path:
hadoop-ozone/ozonefs-common/src/main/java/org/apache/hadoop/fs/ozone/BasicOzoneFileSystem.java
##########
@@ -606,6 +607,52 @@ public String getUsername() {
return userName;
}
+ /**
+ * Get the root directory of Trash for a path.
+ * Returns /.Trash/<username>
+ * Caller appends either Current or checkpoint timestamp for trash
destination
+ * @param path the trash root of the path to be determined.
+ * @return trash root
+ */
+ @Override
+ public Path getTrashRoot(Path path) {
+ final Path pathToTrash = new Path(OZONE_URI_DELIMITER, TRASH_PREFIX);
+ return new Path(pathToTrash, getUsername());
+ }
+
+ /**
+ * Get all the trash roots for current user or all users.
+ *
+ * @param allUsers return trash roots for all users if true.
+ * @return all the trash root directories.
+ * Returns .Trash of users if {@code /.Trash/$USER} exists.
+ */
+ @Override
+ public Collection<FileStatus> getTrashRoots(boolean allUsers) {
+ Path trashRoot = new Path(OZONE_URI_DELIMITER, TRASH_PREFIX);
+ List<FileStatus> ret = new ArrayList<>();
+ try {
+ if (!allUsers) {
+ Path userTrash = new Path(trashRoot, userName);
+ if (exists(userTrash)) {
Review comment:
should we check both existing and isDirectory before return?
----------------------------------------------------------------
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.
For queries about this service, please contact Infrastructure at:
[email protected]
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
