Repository: incubator-ignite Updated Branches: refs/heads/sprint-1 9f5b28701 -> 41f324305
# ignite-263 Fixed filtration by task name Project: http://git-wip-us.apache.org/repos/asf/incubator-ignite/repo Commit: http://git-wip-us.apache.org/repos/asf/incubator-ignite/commit/41f32430 Tree: http://git-wip-us.apache.org/repos/asf/incubator-ignite/tree/41f32430 Diff: http://git-wip-us.apache.org/repos/asf/incubator-ignite/diff/41f32430 Branch: refs/heads/sprint-1 Commit: 41f324305e7e72f9f4fa5e1cfc779adadd01fbf2 Parents: 9f5b287 Author: anovikov <anovi...@gridgain.com> Authored: Mon Feb 16 15:21:27 2015 +0700 Committer: anovikov <anovi...@gridgain.com> Committed: Mon Feb 16 15:21:27 2015 +0700 ---------------------------------------------------------------------- .../internal/visor/node/VisorNodeEventsCollectorTask.java | 9 ++++++--- 1 file changed, 6 insertions(+), 3 deletions(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/incubator-ignite/blob/41f32430/modules/core/src/main/java/org/apache/ignite/internal/visor/node/VisorNodeEventsCollectorTask.java ---------------------------------------------------------------------- diff --git a/modules/core/src/main/java/org/apache/ignite/internal/visor/node/VisorNodeEventsCollectorTask.java b/modules/core/src/main/java/org/apache/ignite/internal/visor/node/VisorNodeEventsCollectorTask.java index 41090b7..55fc212 100644 --- a/modules/core/src/main/java/org/apache/ignite/internal/visor/node/VisorNodeEventsCollectorTask.java +++ b/modules/core/src/main/java/org/apache/ignite/internal/visor/node/VisorNodeEventsCollectorTask.java @@ -210,25 +210,28 @@ public class VisorNodeEventsCollectorTask extends VisorMultiNodeTask<VisorNodeEv * Filter events containing visor in it's name. * * @param e Event + * @param taskName Task name to filter of events. * @return {@code true} if not contains {@code visor} in task name. */ private boolean filterByTaskName(Event e, String taskName) { + String compareTaskName = taskName.toLowerCase(); + if (e.getClass().equals(TaskEvent.class)) { TaskEvent te = (TaskEvent)e; - return containsInTaskName(te.taskName(), te.taskClassName(), taskName); + return containsInTaskName(te.taskName(), te.taskClassName(), compareTaskName); } if (e.getClass().equals(JobEvent.class)) { JobEvent je = (JobEvent)e; - return containsInTaskName(je.taskName(), je.taskName(), taskName); + return containsInTaskName(je.taskName(), je.taskName(), compareTaskName); } if (e.getClass().equals(DeploymentEvent.class)) { DeploymentEvent de = (DeploymentEvent)e; - return de.alias().toLowerCase().contains(taskName); + return de.alias().toLowerCase().contains(compareTaskName); } return true;
