You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@sling.apache.org by np...@apache.org on 2018/01/24 18:05:59 UTC
[sling-org-apache-sling-pipes] branch master updated: SLING-7444
add a few logs
This is an automated email from the ASF dual-hosted git repository.
npeltier pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/sling-org-apache-sling-pipes.git
The following commit(s) were added to refs/heads/master by this push:
new d3545c2 SLING-7444 add a few logs
d3545c2 is described below
commit d3545c2e326c4a651662ec360cf91ddce5ac1d5b
Author: Nicolas Peltier <pe...@gmail.com>
AuthorDate: Wed Jan 24 19:05:48 2018 +0100
SLING-7444 add a few logs
- container pipe,
- reference pipe,
- move
---
src/main/java/org/apache/sling/pipes/BasePipe.java | 1 +
src/main/java/org/apache/sling/pipes/ContainerPipe.java | 2 ++
src/main/java/org/apache/sling/pipes/ReferencePipe.java | 6 ++++++
src/main/java/org/apache/sling/pipes/internal/MovePipe.java | 1 +
4 files changed, 10 insertions(+)
diff --git a/src/main/java/org/apache/sling/pipes/BasePipe.java b/src/main/java/org/apache/sling/pipes/BasePipe.java
index e816e24..dee2fb5 100644
--- a/src/main/java/org/apache/sling/pipes/BasePipe.java
+++ b/src/main/java/org/apache/sling/pipes/BasePipe.java
@@ -173,6 +173,7 @@ public class BasePipe implements Pipe {
return bindings.getExecutedResource(previousPipe.getName());
}
}
+ logger.debug("input for this pipe is {}", resource != null ? resource.getPath() : null);
return resource;
}
diff --git a/src/main/java/org/apache/sling/pipes/ContainerPipe.java b/src/main/java/org/apache/sling/pipes/ContainerPipe.java
index 19f7438..e6122f8 100644
--- a/src/main/java/org/apache/sling/pipes/ContainerPipe.java
+++ b/src/main/java/org/apache/sling/pipes/ContainerPipe.java
@@ -186,11 +186,13 @@ public class ContainerPipe extends BasePipe {
Pipe nextPipe = container.pipeList.get(++cursor);
iterators.put(nextPipe, nextPipe.getOutput());
currentPipe = nextPipe;
+ log.debug("switching to {}", currentPipe);
it = iterators.get(currentPipe);
}
//go down (or stay) to the first pipe having a next item
while (!it.hasNext() && cursor > 0) {
currentPipe = container.pipeList.get(--cursor);
+ log.debug("switching to {}", currentPipe);
it = iterators.get(currentPipe);
}
} while (it.hasNext() && cursor < container.pipeList.size() - 1);
diff --git a/src/main/java/org/apache/sling/pipes/ReferencePipe.java b/src/main/java/org/apache/sling/pipes/ReferencePipe.java
index 8f946a9..41bcc8c 100644
--- a/src/main/java/org/apache/sling/pipes/ReferencePipe.java
+++ b/src/main/java/org/apache/sling/pipes/ReferencePipe.java
@@ -17,6 +17,8 @@
package org.apache.sling.pipes;
import org.apache.sling.api.resource.Resource;
+import org.slf4j.Logger;
+import org.slf4j.LoggerFactory;
import java.util.Iterator;
@@ -24,6 +26,8 @@ import java.util.Iterator;
* executes a pipe referred in the configuration
*/
public class ReferencePipe extends BasePipe {
+ private static final Logger log = LoggerFactory.getLogger(ReferencePipe.class);
+
public static final String RESOURCE_TYPE = "slingPipes/reference";
protected Pipe reference;
@@ -39,6 +43,7 @@ public class ReferencePipe extends BasePipe {
throw new Exception("Unable to build out pipe out of " + getPath());
}
reference.setReferrer(this);
+ log.info("set reference to {}", reference);
}
@Override
@@ -59,6 +64,7 @@ public class ReferencePipe extends BasePipe {
@Override
public Iterator<Resource> getOutput() {
+ log.debug("getting {} output", reference);
return reference.getOutput();
}
diff --git a/src/main/java/org/apache/sling/pipes/internal/MovePipe.java b/src/main/java/org/apache/sling/pipes/internal/MovePipe.java
index 9db1a86..a55de26 100644
--- a/src/main/java/org/apache/sling/pipes/internal/MovePipe.java
+++ b/src/main/java/org/apache/sling/pipes/internal/MovePipe.java
@@ -63,6 +63,7 @@ public class MovePipe extends BasePipe {
if (resource.adaptTo(Node.class) != null) {
session.move(resource.getPath(), targetPath);
} else {
+ logger.debug("resource is a property");
int lastLevel = targetPath.lastIndexOf("/");
// /a/b/c will get cut in /a/b for parent path, and c for name
String parentPath = targetPath.substring(0, lastLevel);
--
To stop receiving notification emails like this one, please contact
npeltier@apache.org.