---

jean-philippe-martin · neozwu · commit 23ac77e8095d · 2017-06-20T11:05:17.000-07:00
yaml --- r: 5749 b: refs/heads/master c: 466a8d4 h: refs/heads/master i: 5747: b2c30be
diff --git a/[refs] b/[refs]
@@ -1,5 +1,5 @@
 ---
-refs/heads/master: 7c20c6f0663147ed667d782c1e37551d80fc74e7
+refs/heads/master: 466a8d4f70aab42596007f4a3fb07b791f363509
 refs/heads/travis: dae77e558b884bc1b165155482d76c8e40b0fca4
 refs/heads/gh-pages: 3c5e576ef43acaafb4d9c2c093fad59827a77ffa
 refs/tags/0.0.9: 22f1839238f66c39e67ed4dfdcd273b1ae2e8444
diff --git a/trunk/google-cloud-contrib/google-cloud-nio/src/main/java/com/google/cloud/storage/contrib/nio/CloudStorageFileSystemProvider.java b/trunk/google-cloud-contrib/google-cloud-nio/src/main/java/com/google/cloud/storage/contrib/nio/CloudStorageFileSystemProvider.java
@@ -97,9 +97,13 @@ private static class LazyPathIterator extends AbstractIterator<Path> {
     private final Iterator<Blob> blobIterator;
     private final Filter<? super Path> filter;
     private final CloudStorageFileSystem fileSystem;
+    private final String prefix;
 
-    LazyPathIterator(CloudStorageFileSystem fileSystem, Iterator<Blob> blobIterator,
+    LazyPathIterator(CloudStorageFileSystem fileSystem,
+                     String prefix,
+                     Iterator<Blob> blobIterator,
                      Filter<? super Path> filter) {
+      this.prefix = prefix;
       this.blobIterator = blobIterator;
       this.filter = filter;
       this.fileSystem = fileSystem;
@@ -110,6 +114,10 @@ protected Path computeNext() {
       while (blobIterator.hasNext()) {
         Path path = fileSystem.getPath(blobIterator.next().getName());
         try {
+          if (path.toString().equals(prefix)) {
+            // do not return ourselves, because that confuses recursive descents.
+            continue;
+          }
           if (filter.accept(path)) {
             return path;
           }
@@ -617,14 +625,14 @@ public DirectoryStream<Path> newDirectoryStream(Path dir, final Filter<? super P
     final CloudStoragePath cloudPath = CloudStorageUtil.checkPath(dir);
     checkNotNull(filter);
     initStorage();
-    String prefix = cloudPath.toRealPath().toString();
+    final String prefix = cloudPath.toRealPath().toString();
     final Iterator<Blob> blobIterator = storage.list(cloudPath.bucket(),
         Storage.BlobListOption.prefix(prefix), Storage.BlobListOption.currentDirectory(),
         Storage.BlobListOption.fields()).iterateAll().iterator();
     return new DirectoryStream<Path>() {
       @Override
       public Iterator<Path> iterator() {
-        return new LazyPathIterator(cloudPath.getFileSystem(), blobIterator, filter);
+        return new LazyPathIterator(cloudPath.getFileSystem(), prefix, blobIterator, filter);
       }
 
       @Override
