You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@ode.apache.org by va...@apache.org on 2013/05/10 17:43:31 UTC
git commit: restoring a missing signature.
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 <tv...@gmail.com>
Authored: Fri May 10 17:43:03 2013 +0200
Committer: Tammo van Lessen <tv...@gmail.com>
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();