fix rays limit not work (apache#1284)

Change-Id: Ie62ff563944280795d14adad0f5cfc577c828004
tmljob · Dec 10, 2020 · 210dddc · 210dddc
1 parent 5b6d58f
commit 210dddc
Showing 1 changed file with 7 additions and 3 deletions.
diff --git a/hugegraph-core/src/main/java/com/baidu/hugegraph/traversal/algorithm/SubGraphTraverser.java b/hugegraph-core/src/main/java/com/baidu/hugegraph/traversal/algorithm/SubGraphTraverser.java
@@ -155,7 +155,7 @@ public PathSet forward(Directions direction) {
                         // Store rays
                         paths.add(new Path(n.path()));
                         this.pathCount++;
-                        if (reachLimit()) {
+                        if (this.reachLimit()) {
                             return paths;
                         }
                     }
@@ -190,7 +190,7 @@ public PathSet forward(Directions direction) {
                         if (!this.rings && bothBack && uniqueEdge) {
                             paths.add(new Path(node.path()));
                             this.pathCount++;
-                            if (reachLimit()) {
+                            if (this.reachLimit()) {
                                 return paths;
                             }
                         }
@@ -215,7 +215,7 @@ public PathSet forward(Directions direction) {
                                 path.add(target);
                                 paths.add(new RingPath(null, path));
                                 this.pathCount++;
-                                if (reachLimit()) {
+                                if (this.reachLimit()) {
                                     return paths;
                                 }
                             }
@@ -230,6 +230,10 @@ public PathSet forward(Directions direction) {
                 for (List<Node> list : newVertices.values()) {
                     for (Node n : list) {
                         paths.add(new Path(n.path()));
+                        this.pathCount++;
+                        if (this.reachLimit()) {
+                            return paths;
+                        }
                     }
                 }
             }