Updated Branches: refs/heads/master 74ad7bc6a -> 0a83b24c2
restoring a missing signature. Project: http://git-wip-us.apache.org/repos/asf/ode-jacob/repo Commit: http://git-wip-us.apache.org/repos/asf/ode-jacob/commit/0a83b24c Tree: http://git-wip-us.apache.org/repos/asf/ode-jacob/tree/0a83b24c Diff: http://git-wip-us.apache.org/repos/asf/ode-jacob/diff/0a83b24c Branch: refs/heads/master Commit: 0a83b24c2c2e31aa75d17681c96f3a4f493177d6 Parents: 74ad7bc Author: Tammo van Lessen <[email protected]> Authored: Fri May 10 17:43:03 2013 +0200 Committer: Tammo van Lessen <[email protected]> Committed: Fri May 10 17:43:03 2013 +0200 ---------------------------------------------------------------------- .../java/org/apache/ode/jacob/JacobObject.java | 6 +++ .../java/org/apache/ode/jacob/JacobThread.java | 2 + .../java/org/apache/ode/jacob/vpu/JacobVPU.java | 26 +++++++++++++++ 3 files changed, 34 insertions(+), 0 deletions(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/ode-jacob/blob/0a83b24c/src/main/java/org/apache/ode/jacob/JacobObject.java ---------------------------------------------------------------------- diff --git a/src/main/java/org/apache/ode/jacob/JacobObject.java b/src/main/java/org/apache/ode/jacob/JacobObject.java index 062c750..c39d03a 100644 --- a/src/main/java/org/apache/ode/jacob/JacobObject.java +++ b/src/main/java/org/apache/ode/jacob/JacobObject.java @@ -89,6 +89,12 @@ public abstract class JacobObject implements Serializable { protected static void object(boolean replication, ChannelListener methodList) { JacobVPU.activeJacobThread().object(replication, methodList); } + + protected static void object(boolean replication, Set<ChannelListener> methodLists) { + JacobVPU.activeJacobThread().object(replication, + methodLists.toArray(new ChannelListener[methodLists.size()])); + } + /** * Obtain a replicated channel broadcaster. http://git-wip-us.apache.org/repos/asf/ode-jacob/blob/0a83b24c/src/main/java/org/apache/ode/jacob/JacobThread.java ---------------------------------------------------------------------- diff --git a/src/main/java/org/apache/ode/jacob/JacobThread.java b/src/main/java/org/apache/ode/jacob/JacobThread.java index 802539f..4c06133 100644 --- a/src/main/java/org/apache/ode/jacob/JacobThread.java +++ b/src/main/java/org/apache/ode/jacob/JacobThread.java @@ -85,4 +85,6 @@ public interface JacobThread { * if the method list does not match the channel kind */ public void object(boolean replicate, ChannelListener methodList) throws IllegalArgumentException; + public void object(boolean reaplicate, ChannelListener[] methodLists) throws IllegalArgumentException; + } http://git-wip-us.apache.org/repos/asf/ode-jacob/blob/0a83b24c/src/main/java/org/apache/ode/jacob/vpu/JacobVPU.java ---------------------------------------------------------------------- diff --git a/src/main/java/org/apache/ode/jacob/vpu/JacobVPU.java b/src/main/java/org/apache/ode/jacob/vpu/JacobVPU.java index 5d7660c..81c4992 100644 --- a/src/main/java/org/apache/ode/jacob/vpu/JacobVPU.java +++ b/src/main/java/org/apache/ode/jacob/vpu/JacobVPU.java @@ -329,6 +329,32 @@ public final class JacobVPU { return ChannelFactory.createChannel(cframe, channelType); } + public void object(boolean replicate, ChannelListener[] ml) { + if (LOG.isTraceEnabled()) { + StringBuffer msg = new StringBuffer(); + msg.append(_cycle); + msg.append(": "); + for (int i = 0; i < ml.length; ++i) { + if (i != 0) msg.append(" + "); + if (ml[i] instanceof ReceiveProcess) { + ReceiveProcess rp = (ReceiveProcess)ml[i]; + msg.append(rp.getChannel()); + msg.append(" ? "); + msg.append(rp.toString()); + } + } + LOG.debug(msg.toString()); + } + + _statistics.numContinuations++; + + CommGroup grp = new CommGroup(replicate); + for (int i = 0; i < ml.length; ++i) { + addCommChannel(grp, ml[i]); + } + _executionQueue.add(grp); + } + public void object(boolean replicate, ChannelListener ml) { if (LOG.isTraceEnabled()) { StringBuffer msg = new StringBuffer();
