[jboss-svn-commits] JBL Code SVN: r19262 - in labs/jbossrules/trunk/drools-core/src: test/java/org/drools/reteoo and 1 other directory.
jboss-svn-commits at lists.jboss.org
jboss-svn-commits at lists.jboss.org
Wed Mar 26 22:01:42 EDT 2008
Author: mark.proctor at jboss.com
Date: 2008-03-26 22:01:42 -0400 (Wed, 26 Mar 2008)
New Revision: 19262
Added:
labs/jbossrules/trunk/drools-core/src/test/java/org/drools/reteoo/MockLeftTupleSink.java
labs/jbossrules/trunk/drools-core/src/test/java/org/drools/reteoo/MockRightTupleSink.java
Removed:
labs/jbossrules/trunk/drools-core/src/test/java/org/drools/reteoo/MockTupleSink.java
Modified:
labs/jbossrules/trunk/drools-core/src/main/java/org/drools/reteoo/CollectNode.java
labs/jbossrules/trunk/drools-core/src/test/java/org/drools/reteoo/AccumulateNodeTest.java
labs/jbossrules/trunk/drools-core/src/test/java/org/drools/reteoo/CollectNodeTest.java
labs/jbossrules/trunk/drools-core/src/test/java/org/drools/reteoo/EvalConditionNodeTest.java
labs/jbossrules/trunk/drools-core/src/test/java/org/drools/reteoo/ExistsNodeTest.java
labs/jbossrules/trunk/drools-core/src/test/java/org/drools/reteoo/FromNodeTest.java
labs/jbossrules/trunk/drools-core/src/test/java/org/drools/reteoo/JoinNodeTest.java
labs/jbossrules/trunk/drools-core/src/test/java/org/drools/reteoo/LeftInputAdapterNodeTest.java
labs/jbossrules/trunk/drools-core/src/test/java/org/drools/reteoo/NotNodeTest.java
labs/jbossrules/trunk/drools-core/src/test/java/org/drools/reteoo/TupleSourceTest.java
Log:
JBRULES-1520 RightTuple merge for asymmetrical Rete propagations
-Added MockRightTupleSink
-Refactored MockTupleSink to MockLeftTupleSink
Modified: labs/jbossrules/trunk/drools-core/src/main/java/org/drools/reteoo/CollectNode.java
===================================================================
--- labs/jbossrules/trunk/drools-core/src/main/java/org/drools/reteoo/CollectNode.java 2008-03-27 01:55:49 UTC (rev 19261)
+++ labs/jbossrules/trunk/drools-core/src/main/java/org/drools/reteoo/CollectNode.java 2008-03-27 02:01:42 UTC (rev 19262)
@@ -155,7 +155,7 @@
handle = ((LeftTuple) handle.getObject()).getLastHandle();
}
result.add( handle.getObject() );
-
+
// linking left tuple to the right tuple children list
leftTuple.setRightParentNext( rightTuple.getBetaChildren() );
rightTuple.setBetaChildren( leftTuple );
@@ -243,11 +243,11 @@
LeftTuple tuple = (LeftTuple) tuples[i];
if ( this.constraints.isAllowedCachedRight( memory.betaMemory.getContext(),
tuple ) ) {
- this.modifyTuple( true,
- tuple,
- rightTuple,
- context,
- workingMemory );
+ modifyTuple( true,
+ tuple,
+ rightTuple,
+ context,
+ workingMemory );
}
}
@@ -270,7 +270,7 @@
workingMemory,
rightTuple.getFactHandle() );
- for( LeftTuple leftTuple = rightTuple.getBetaChildren(); leftTuple != null; leftTuple = rightTuple.getBetaChildren() ) {
+ for ( LeftTuple leftTuple = rightTuple.getBetaChildren(); leftTuple != null; leftTuple = rightTuple.getBetaChildren() ) {
this.modifyTuple( false,
leftTuple,
rightTuple,
@@ -306,7 +306,7 @@
}
// if there is a subnetwork, we need to unwrapp the object from inside the tuple
- InternalFactHandle handle = rightTuple.getFactHandle();
+ InternalFactHandle handle = rightTuple.getFactHandle();
if ( this.unwrapRightObject ) {
handle = ((LeftTuple) handle.getObject()).getLastHandle();
}
@@ -353,17 +353,17 @@
public void updateSink(final LeftTupleSink sink,
final PropagationContext context,
final InternalWorkingMemory workingMemory) {
-// final CollectMemory memory = (CollectMemory) workingMemory.getNodeMemory( this );
-//
-// final Iterator it = memory.betaMemory.getCreatedHandles().iterator();
-//
-// for ( ObjectEntry entry = (ObjectEntry) it.next(); entry != null; entry = (ObjectEntry) it.next() ) {
-// CollectResult result = (CollectResult) entry.getValue();
-// sink.assertLeftTuple( new LeftTuple( (LeftTuple) entry.getKey(),
-// result.handle ),
-// context,
-// workingMemory );
-// }
+ // final CollectMemory memory = (CollectMemory) workingMemory.getNodeMemory( this );
+ //
+ // final Iterator it = memory.betaMemory.getCreatedHandles().iterator();
+ //
+ // for ( ObjectEntry entry = (ObjectEntry) it.next(); entry != null; entry = (ObjectEntry) it.next() ) {
+ // CollectResult result = (CollectResult) entry.getValue();
+ // sink.assertLeftTuple( new LeftTuple( (LeftTuple) entry.getKey(),
+ // result.handle ),
+ // context,
+ // workingMemory );
+ // }
}
/* (non-Javadoc)
Modified: labs/jbossrules/trunk/drools-core/src/test/java/org/drools/reteoo/AccumulateNodeTest.java
===================================================================
--- labs/jbossrules/trunk/drools-core/src/test/java/org/drools/reteoo/AccumulateNodeTest.java 2008-03-27 01:55:49 UTC (rev 19261)
+++ labs/jbossrules/trunk/drools-core/src/test/java/org/drools/reteoo/AccumulateNodeTest.java 2008-03-27 02:01:42 UTC (rev 19262)
@@ -49,7 +49,7 @@
ReteooWorkingMemory workingMemory;
MockObjectSource objectSource;
MockTupleSource tupleSource;
- MockTupleSink sink;
+ MockLeftTupleSink sink;
BetaNode node;
BetaMemory memory;
MockConstraint constraint = new MockConstraint();
@@ -75,7 +75,7 @@
this.tupleSource = new MockTupleSource( 4 );
this.objectSource = new MockObjectSource( 4 );
- this.sink = new MockTupleSink();
+ this.sink = new MockLeftTupleSink();
this.accumulator = new MockAccumulator();
@@ -139,7 +139,7 @@
2,
this.sink.getAsserted().size() );
- final MockTupleSink otherSink = new MockTupleSink();
+ final MockLeftTupleSink otherSink = new MockLeftTupleSink();
this.node.addTupleSink( otherSink );
this.node.updateSink( otherSink,
Modified: labs/jbossrules/trunk/drools-core/src/test/java/org/drools/reteoo/CollectNodeTest.java
===================================================================
--- labs/jbossrules/trunk/drools-core/src/test/java/org/drools/reteoo/CollectNodeTest.java 2008-03-27 01:55:49 UTC (rev 19261)
+++ labs/jbossrules/trunk/drools-core/src/test/java/org/drools/reteoo/CollectNodeTest.java 2008-03-27 02:01:42 UTC (rev 19262)
@@ -50,7 +50,7 @@
ReteooWorkingMemory workingMemory;
MockObjectSource objectSource;
MockTupleSource tupleSource;
- MockTupleSink sink;
+ MockLeftTupleSink sink;
BetaNode node;
CollectMemory memory;
MockConstraint constraint = new MockConstraint();
@@ -79,7 +79,7 @@
this.tupleSource = new MockTupleSource( 4 );
this.objectSource = new MockObjectSource( 4 );
- this.sink = new MockTupleSink();
+ this.sink = new MockLeftTupleSink();
final ObjectType srcObjType = new ClassObjectType( String.class );
final Pattern sourcePattern = new Pattern( 0,
@@ -143,7 +143,7 @@
2,
this.sink.getAsserted().size() );
- final MockTupleSink otherSink = new MockTupleSink();
+ final MockLeftTupleSink otherSink = new MockLeftTupleSink();
this.node.addTupleSink( otherSink );
this.node.updateSink( otherSink,
Modified: labs/jbossrules/trunk/drools-core/src/test/java/org/drools/reteoo/EvalConditionNodeTest.java
===================================================================
--- labs/jbossrules/trunk/drools-core/src/test/java/org/drools/reteoo/EvalConditionNodeTest.java 2008-03-27 01:55:49 UTC (rev 19261)
+++ labs/jbossrules/trunk/drools-core/src/test/java/org/drools/reteoo/EvalConditionNodeTest.java 2008-03-27 02:01:42 UTC (rev 19262)
@@ -100,7 +100,7 @@
eval,
buildContext );
- final MockTupleSink sink = new MockTupleSink();
+ final MockLeftTupleSink sink = new MockLeftTupleSink();
node.addTupleSink( sink );
// Create the Tuple
@@ -146,7 +146,7 @@
eval,
buildContext );
- final MockTupleSink sink = new MockTupleSink();
+ final MockLeftTupleSink sink = new MockLeftTupleSink();
node.addTupleSink( sink );
// Create the Tuple
@@ -220,7 +220,7 @@
eval,
buildContext );
- final MockTupleSink sink = new MockTupleSink();
+ final MockLeftTupleSink sink = new MockLeftTupleSink();
node.addTupleSink( sink );
// Create the Tuple
@@ -275,7 +275,7 @@
// Add the first tuple sink and assert a tuple and object
// The sink has no memory
- final MockTupleSink sink1 = new MockTupleSink( 2 );
+ final MockLeftTupleSink sink1 = new MockLeftTupleSink( 2 );
node.addTupleSink( sink1 );
final DefaultFactHandle f0 = new DefaultFactHandle( 0,
@@ -292,7 +292,7 @@
// Add the new sink, this should be updated from the re-processed
// joinnode memory
- final MockTupleSink sink2 = new MockTupleSink( 3 );
+ final MockLeftTupleSink sink2 = new MockLeftTupleSink( 3 );
node.addTupleSink( sink2 );
assertLength( 0,
sink2.getAsserted() );
Modified: labs/jbossrules/trunk/drools-core/src/test/java/org/drools/reteoo/ExistsNodeTest.java
===================================================================
--- labs/jbossrules/trunk/drools-core/src/test/java/org/drools/reteoo/ExistsNodeTest.java 2008-03-27 01:55:49 UTC (rev 19261)
+++ labs/jbossrules/trunk/drools-core/src/test/java/org/drools/reteoo/ExistsNodeTest.java 2008-03-27 02:01:42 UTC (rev 19262)
@@ -44,7 +44,7 @@
ReteooWorkingMemory workingMemory;
MockObjectSource objectSource;
MockTupleSource tupleSource;
- MockTupleSink sink;
+ MockLeftTupleSink sink;
ExistsNode node;
RightInputAdapterNode ria;
BetaMemory memory;
@@ -77,7 +77,7 @@
configuration ),
buildContext );
- this.sink = new MockTupleSink();
+ this.sink = new MockLeftTupleSink();
this.node.addTupleSink( this.sink );
this.memory = (BetaMemory) this.workingMemory.getNodeMemory( this.node );
Modified: labs/jbossrules/trunk/drools-core/src/test/java/org/drools/reteoo/FromNodeTest.java
===================================================================
--- labs/jbossrules/trunk/drools-core/src/test/java/org/drools/reteoo/FromNodeTest.java 2008-03-27 01:55:49 UTC (rev 19261)
+++ labs/jbossrules/trunk/drools-core/src/test/java/org/drools/reteoo/FromNodeTest.java 2008-03-27 02:01:42 UTC (rev 19262)
@@ -71,7 +71,7 @@
null,
new AlphaNodeFieldConstraint[]{constraint},
null );
- final MockTupleSink sink = new MockTupleSink( 5 );
+ final MockLeftTupleSink sink = new MockLeftTupleSink( 5 );
from.addTupleSink( sink );
final Person person1 = new Person( "xxx1",
@@ -178,7 +178,7 @@
null,
new AlphaNodeFieldConstraint[0],
betaConstraints );
- final MockTupleSink sink = new MockTupleSink( 5 );
+ final MockLeftTupleSink sink = new MockLeftTupleSink( 5 );
from.addTupleSink( sink );
final Person person1 = new Person( "xxx1",
@@ -268,7 +268,7 @@
null,
new AlphaNodeFieldConstraint[]{constraint},
null );
- final MockTupleSink sink = new MockTupleSink( 5 );
+ final MockLeftTupleSink sink = new MockLeftTupleSink( 5 );
from.addTupleSink( sink );
final List asserted = sink.getAsserted();
Modified: labs/jbossrules/trunk/drools-core/src/test/java/org/drools/reteoo/JoinNodeTest.java
===================================================================
--- labs/jbossrules/trunk/drools-core/src/test/java/org/drools/reteoo/JoinNodeTest.java 2008-03-27 01:55:49 UTC (rev 19261)
+++ labs/jbossrules/trunk/drools-core/src/test/java/org/drools/reteoo/JoinNodeTest.java 2008-03-27 02:01:42 UTC (rev 19262)
@@ -43,7 +43,7 @@
ReteooWorkingMemory workingMemory;
MockObjectSource objectSource;
MockTupleSource tupleSource;
- MockTupleSink sink;
+ MockLeftTupleSink sink;
BetaNode node;
BetaMemory memory;
MockConstraint constraint = new MockConstraint();
@@ -62,7 +62,7 @@
this.tupleSource = new MockTupleSource( 4 );
this.objectSource = new MockObjectSource( 4 );
- this.sink = new MockTupleSink();
+ this.sink = new MockLeftTupleSink();
final RuleBaseConfiguration configuration = new RuleBaseConfiguration();
@@ -468,7 +468,7 @@
// Add the first tuple sink and assert a tuple and object
// The sink has no memory
- final MockTupleSink sink1 = new MockTupleSink( 2 );
+ final MockLeftTupleSink sink1 = new MockLeftTupleSink( 2 );
joinNode.addTupleSink( sink1 );
final DefaultFactHandle f0 = new DefaultFactHandle( 0,
@@ -493,7 +493,7 @@
// Add the new sink, this should be updated from the re-processed
// joinnode memory
- final MockTupleSink sink2 = new MockTupleSink( 3 );
+ final MockLeftTupleSink sink2 = new MockLeftTupleSink( 3 );
assertLength( 0,
sink2.getAsserted() );
Modified: labs/jbossrules/trunk/drools-core/src/test/java/org/drools/reteoo/LeftInputAdapterNodeTest.java
===================================================================
--- labs/jbossrules/trunk/drools-core/src/test/java/org/drools/reteoo/LeftInputAdapterNodeTest.java 2008-03-27 01:55:49 UTC (rev 19261)
+++ labs/jbossrules/trunk/drools-core/src/test/java/org/drools/reteoo/LeftInputAdapterNodeTest.java 2008-03-27 02:01:42 UTC (rev 19262)
@@ -101,7 +101,7 @@
final LeftInputAdapterNode liaNode = new LeftInputAdapterNode( 1,
new MockObjectSource( 15 ),
buildContext );
- final MockTupleSink sink = new MockTupleSink();
+ final MockLeftTupleSink sink = new MockLeftTupleSink();
liaNode.addTupleSink( sink );
final Object string1 = "cheese";
Copied: labs/jbossrules/trunk/drools-core/src/test/java/org/drools/reteoo/MockLeftTupleSink.java (from rev 19232, labs/jbossrules/trunk/drools-core/src/test/java/org/drools/reteoo/MockTupleSink.java)
===================================================================
--- labs/jbossrules/trunk/drools-core/src/test/java/org/drools/reteoo/MockLeftTupleSink.java (rev 0)
+++ labs/jbossrules/trunk/drools-core/src/test/java/org/drools/reteoo/MockLeftTupleSink.java 2008-03-27 02:01:42 UTC (rev 19262)
@@ -0,0 +1,168 @@
+package org.drools.reteoo;
+
+/*
+ * Copyright 2005 JBoss Inc
+ *
+ * Licensed under the Apache License, Version 2.0 (the "License");
+ * you may not use this file except in compliance with the License.
+ * You may obtain a copy of the License at
+ *
+ * http://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing, software
+ * distributed under the License is distributed on an "AS IS" BASIS,
+ * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+ * See the License for the specific language governing permissions and
+ * limitations under the License.
+ */
+
+import java.util.ArrayList;
+import java.util.Collections;
+import java.util.HashMap;
+import java.util.List;
+
+import org.drools.FactException;
+import org.drools.RuleBaseConfiguration;
+import org.drools.common.BaseNode;
+import org.drools.common.InternalWorkingMemory;
+import org.drools.common.NodeMemory;
+import org.drools.spi.PropagationContext;
+
+public class MockLeftTupleSink extends LeftTupleSource
+ implements
+ LeftTupleSinkNode,
+ NodeMemory {
+ /**
+ *
+ */
+ private static final long serialVersionUID = 400L;
+ private final List asserted = new ArrayList();
+ private final List retracted = new ArrayList();
+
+ private LeftTupleSinkNode previousTupleSinkNode;
+ private LeftTupleSinkNode nextTupleSinkNode;
+
+ public MockLeftTupleSink() {
+ super( 0 );
+ }
+
+ public MockLeftTupleSink(final int id) {
+ super( id );
+ }
+
+ public void assertLeftTuple(final LeftTuple tuple,
+ final PropagationContext context,
+ final InternalWorkingMemory workingMemory) {
+ this.asserted.add( new Object[]{tuple, context, workingMemory} );
+
+ }
+
+ public void retractLeftTuple(final LeftTuple tuple,
+ final PropagationContext context,
+ final InternalWorkingMemory workingMemory) {
+ this.retracted.add( new Object[]{tuple, context, workingMemory} );
+
+ }
+
+ public List getAsserted() {
+ return this.asserted;
+ }
+
+ public List getRetracted() {
+ return this.retracted;
+ }
+
+ public void ruleAttached() {
+ // TODO Auto-generated method stub
+ }
+
+ public int getId() {
+ return this.id;
+ }
+
+ public Object createMemory(final RuleBaseConfiguration config) {
+ return new HashMap();
+ }
+
+ public void attach() {
+ // TODO Auto-generated method stub
+
+ }
+
+ public void updateSink(final LeftTupleSink sink,
+ final PropagationContext context,
+ final InternalWorkingMemory workingMemory) throws FactException {
+ // TODO Auto-generated method stub
+
+ }
+
+ protected void doRemove(final RuleRemovalContext context,
+ final ReteooBuilder builder,
+ final BaseNode node,
+ final InternalWorkingMemory[] workingMemories) {
+ }
+
+ public void attach(final InternalWorkingMemory[] workingMemories) {
+ // TODO Auto-generated method stub
+
+ }
+
+ public List getPropagatedTuples(final ReteooWorkingMemory workingMemory,
+ final LeftTupleSink sink) {
+ // TODO Auto-generated method stub
+ return Collections.EMPTY_LIST;
+ }
+
+ /**
+ * Returns the next node
+ * @return
+ * The next TupleSinkNode
+ */
+ public LeftTupleSinkNode getNextLeftTupleSinkNode() {
+ return this.nextTupleSinkNode;
+ }
+
+ /**
+ * Sets the next node
+ * @param next
+ * The next TupleSinkNode
+ */
+ public void setNextLeftTupleSinkNode(final LeftTupleSinkNode next) {
+ this.nextTupleSinkNode = next;
+ }
+
+ /**
+ * Returns the previous node
+ * @return
+ * The previous TupleSinkNode
+ */
+ public LeftTupleSinkNode getPreviousLeftTupleSinkNode() {
+ return this.previousTupleSinkNode;
+ }
+
+ /**
+ * Sets the previous node
+ * @param previous
+ * The previous TupleSinkNode
+ */
+ public void setPreviousLeftTupleSinkNode(final LeftTupleSinkNode previous) {
+ this.previousTupleSinkNode = previous;
+ }
+
+ public boolean isLeftTupleMemoryEnabled() {
+ // TODO Auto-generated method stub
+ return false;
+ }
+
+ public void setLeftTupleMemoryEnabled(boolean tupleMemoryEnabled) {
+ // TODO Auto-generated method stub
+
+ }
+
+ @Override
+ public void networkUpdated() {
+ // TODO Auto-generated method stub
+
+ }
+
+}
\ No newline at end of file
Added: labs/jbossrules/trunk/drools-core/src/test/java/org/drools/reteoo/MockRightTupleSink.java
===================================================================
--- labs/jbossrules/trunk/drools-core/src/test/java/org/drools/reteoo/MockRightTupleSink.java (rev 0)
+++ labs/jbossrules/trunk/drools-core/src/test/java/org/drools/reteoo/MockRightTupleSink.java 2008-03-27 02:01:42 UTC (rev 19262)
@@ -0,0 +1,26 @@
+package org.drools.reteoo;
+
+import java.util.ArrayList;
+import java.util.List;
+
+import org.drools.common.InternalWorkingMemory;
+import org.drools.spi.PropagationContext;
+
+public class MockRightTupleSink
+ implements
+ RightTupleSink {
+
+ private final List retracted = new ArrayList();
+
+ public void retractRightTuple(RightTuple rightTuple,
+ PropagationContext context,
+ InternalWorkingMemory workingMemory) {
+ this.retracted.add( new Object[]{rightTuple, context, workingMemory} );
+
+ }
+
+ public List getRetracted() {
+ return this.retracted;
+ }
+
+}
Deleted: labs/jbossrules/trunk/drools-core/src/test/java/org/drools/reteoo/MockTupleSink.java
===================================================================
--- labs/jbossrules/trunk/drools-core/src/test/java/org/drools/reteoo/MockTupleSink.java 2008-03-27 01:55:49 UTC (rev 19261)
+++ labs/jbossrules/trunk/drools-core/src/test/java/org/drools/reteoo/MockTupleSink.java 2008-03-27 02:01:42 UTC (rev 19262)
@@ -1,168 +0,0 @@
-package org.drools.reteoo;
-
-/*
- * Copyright 2005 JBoss Inc
- *
- * Licensed under the Apache License, Version 2.0 (the "License");
- * you may not use this file except in compliance with the License.
- * You may obtain a copy of the License at
- *
- * http://www.apache.org/licenses/LICENSE-2.0
- *
- * Unless required by applicable law or agreed to in writing, software
- * distributed under the License is distributed on an "AS IS" BASIS,
- * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
- * See the License for the specific language governing permissions and
- * limitations under the License.
- */
-
-import java.util.ArrayList;
-import java.util.Collections;
-import java.util.HashMap;
-import java.util.List;
-
-import org.drools.FactException;
-import org.drools.RuleBaseConfiguration;
-import org.drools.common.BaseNode;
-import org.drools.common.InternalWorkingMemory;
-import org.drools.common.NodeMemory;
-import org.drools.spi.PropagationContext;
-
-public class MockTupleSink extends LeftTupleSource
- implements
- LeftTupleSinkNode,
- NodeMemory {
- /**
- *
- */
- private static final long serialVersionUID = 400L;
- private final List asserted = new ArrayList();
- private final List retracted = new ArrayList();
-
- private LeftTupleSinkNode previousTupleSinkNode;
- private LeftTupleSinkNode nextTupleSinkNode;
-
- public MockTupleSink() {
- super( 0 );
- }
-
- public MockTupleSink(final int id) {
- super( id );
- }
-
- public void assertLeftTuple(final LeftTuple tuple,
- final PropagationContext context,
- final InternalWorkingMemory workingMemory) {
- this.asserted.add( new Object[]{tuple, context, workingMemory} );
-
- }
-
- public void retractLeftTuple(final LeftTuple tuple,
- final PropagationContext context,
- final InternalWorkingMemory workingMemory) {
- this.retracted.add( new Object[]{tuple, context, workingMemory} );
-
- }
-
- public List getAsserted() {
- return this.asserted;
- }
-
- public List getRetracted() {
- return this.retracted;
- }
-
- public void ruleAttached() {
- // TODO Auto-generated method stub
- }
-
- public int getId() {
- return this.id;
- }
-
- public Object createMemory(final RuleBaseConfiguration config) {
- return new HashMap();
- }
-
- public void attach() {
- // TODO Auto-generated method stub
-
- }
-
- public void updateSink(final LeftTupleSink sink,
- final PropagationContext context,
- final InternalWorkingMemory workingMemory) throws FactException {
- // TODO Auto-generated method stub
-
- }
-
- protected void doRemove(final RuleRemovalContext context,
- final ReteooBuilder builder,
- final BaseNode node,
- final InternalWorkingMemory[] workingMemories) {
- }
-
- public void attach(final InternalWorkingMemory[] workingMemories) {
- // TODO Auto-generated method stub
-
- }
-
- public List getPropagatedTuples(final ReteooWorkingMemory workingMemory,
- final LeftTupleSink sink) {
- // TODO Auto-generated method stub
- return Collections.EMPTY_LIST;
- }
-
- /**
- * Returns the next node
- * @return
- * The next TupleSinkNode
- */
- public LeftTupleSinkNode getNextLeftTupleSinkNode() {
- return this.nextTupleSinkNode;
- }
-
- /**
- * Sets the next node
- * @param next
- * The next TupleSinkNode
- */
- public void setNextLeftTupleSinkNode(final LeftTupleSinkNode next) {
- this.nextTupleSinkNode = next;
- }
-
- /**
- * Returns the previous node
- * @return
- * The previous TupleSinkNode
- */
- public LeftTupleSinkNode getPreviousLeftTupleSinkNode() {
- return this.previousTupleSinkNode;
- }
-
- /**
- * Sets the previous node
- * @param previous
- * The previous TupleSinkNode
- */
- public void setPreviousLeftTupleSinkNode(final LeftTupleSinkNode previous) {
- this.previousTupleSinkNode = previous;
- }
-
- public boolean isLeftTupleMemoryEnabled() {
- // TODO Auto-generated method stub
- return false;
- }
-
- public void setLeftTupleMemoryEnabled(boolean tupleMemoryEnabled) {
- // TODO Auto-generated method stub
-
- }
-
- @Override
- public void networkUpdated() {
- // TODO Auto-generated method stub
-
- }
-
-}
\ No newline at end of file
Modified: labs/jbossrules/trunk/drools-core/src/test/java/org/drools/reteoo/NotNodeTest.java
===================================================================
--- labs/jbossrules/trunk/drools-core/src/test/java/org/drools/reteoo/NotNodeTest.java 2008-03-27 01:55:49 UTC (rev 19261)
+++ labs/jbossrules/trunk/drools-core/src/test/java/org/drools/reteoo/NotNodeTest.java 2008-03-27 02:01:42 UTC (rev 19262)
@@ -42,7 +42,7 @@
ReteooWorkingMemory workingMemory;
MockObjectSource objectSource;
MockTupleSource tupleSource;
- MockTupleSink sink;
+ MockLeftTupleSink sink;
NotNode node;
RightInputAdapterNode ria;
BetaMemory memory;
@@ -75,7 +75,7 @@
configuration ),
buildContext );
- this.sink = new MockTupleSink();
+ this.sink = new MockLeftTupleSink();
this.node.addTupleSink( this.sink );
// this.ria = new RightInputAdapterNode( 2,
Modified: labs/jbossrules/trunk/drools-core/src/test/java/org/drools/reteoo/TupleSourceTest.java
===================================================================
--- labs/jbossrules/trunk/drools-core/src/test/java/org/drools/reteoo/TupleSourceTest.java 2008-03-27 01:55:49 UTC (rev 19261)
+++ labs/jbossrules/trunk/drools-core/src/test/java/org/drools/reteoo/TupleSourceTest.java 2008-03-27 02:01:42 UTC (rev 19262)
@@ -39,7 +39,7 @@
assertSame( EmptyLeftTupleSinkAdapter.getInstance(),
sink );
- final MockTupleSink sink1 = new MockTupleSink();
+ final MockLeftTupleSink sink1 = new MockLeftTupleSink();
source.addTupleSink( sink1 );
sink = (LeftTupleSinkPropagator) field.get( source );
assertSame( SingleLeftTupleSinkAdapter.class,
@@ -47,7 +47,7 @@
assertEquals( 1,
sink.getSinks().length );
- final MockTupleSink sink2 = new MockTupleSink();
+ final MockLeftTupleSink sink2 = new MockLeftTupleSink();
source.addTupleSink( sink2 );
sink = (LeftTupleSinkPropagator) field.get( source );
assertSame( CompositeLeftTupleSinkAdapter.class,
@@ -55,7 +55,7 @@
assertEquals( 2,
sink.getSinks().length );
- final MockTupleSink sink3 = new MockTupleSink();
+ final MockLeftTupleSink sink3 = new MockLeftTupleSink();
source.addTupleSink( sink3 );
assertSame( CompositeLeftTupleSinkAdapter.class,
sink.getClass() );
More information about the jboss-svn-commits
mailing list