From deb76203c6b4451a19361e965ee455d3f7adcfa3 Mon Sep 17 00:00:00 2001 From: willemc Date: Thu, 29 Nov 2007 00:17:34 +0100 Subject: [PATCH] [svn r300] fixed counting ofd ports --- src/com/idcanet/foei/core/impl/EventExecutorImpl.java | 4 +++- 1 file changed, 3 insertions(+), 1 deletion(-) diff --git a/src/com/idcanet/foei/core/impl/EventExecutorImpl.java b/src/com/idcanet/foei/core/impl/EventExecutorImpl.java index 85539b9..123bbf4 100644 --- a/src/com/idcanet/foei/core/impl/EventExecutorImpl.java +++ b/src/com/idcanet/foei/core/impl/EventExecutorImpl.java @@ -98,18 +98,20 @@ public class EventExecutorImpl implements EventExecutor { ready = false; try { FoeiProcess foeiProcess = FoeiProcessFactory.getFoeiProcess(); - eventPort.addEventsPassed(); if(eventPort.getEventPortType()==EventPortType.input) { EventInput eventInput = (EventInput)eventPort.getEventObject(); + eventPort.addEventsPassed(); // inc input port eventInput.doEvent(eventPort,eventObject); return; } if(eventPort.getEventPortType()==EventPortType.output) { + eventPort.addEventsPassed(); // inc output port List bindings = foeiProcess.getBindings(eventPort); for(EventPort port:bindings) { EventInput eventInput = (EventInput)port.getEventObject(); if(port.isImmediate()) { logger.finer("Executing event of: "+port.getEventObject()+" port:"+port.getName()+" object: "+eventObject); + port.addEventsPassed(); // inc Immediate import port eventInput.doEvent(port,eventObject); } else { logger.finest("Adding event to event queue");