diff options
Diffstat (limited to 'feature-test-transaction/src')
5 files changed, 436 insertions, 0 deletions
diff --git a/feature-test-transaction/src/assembly/assemble_zip.xml b/feature-test-transaction/src/assembly/assemble_zip.xml new file mode 100644 index 00000000..03c0bb58 --- /dev/null +++ b/feature-test-transaction/src/assembly/assemble_zip.xml @@ -0,0 +1,78 @@ +<!-- + ============LICENSE_START======================================================= + feature-test-transaction + ================================================================================ + Copyright (C) 2017 AT&T Intellectual Property. All rights reserved. + ================================================================================ + 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. + ============LICENSE_END========================================================= + --> + +<!-- Defines how we build the .zip file which is our distribution. --> + +<assembly + xmlns="http://maven.apache.org/plugins/maven-assembly-plugin/assembly/1.1.0" + xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance" + xsi:schemaLocation="http://maven.apache.org/plugins/maven-assembly-plugin/assembly/1.1.0 http://maven.apache.org/xsd/assembly-1.1.0.xsd"> + <id>feature-test-transaction</id> + <formats> + <format>zip</format> + </formats> + + <!-- we want "system" and related files right at the root level as this + file is suppose to be unzip on top of a karaf distro. --> + <includeBaseDirectory>false</includeBaseDirectory> + + <fileSets> + <fileSet> + <directory>target</directory> + <outputDirectory>lib/feature</outputDirectory> + <includes> + <include>feature-test-transaction-${project.version}.jar</include> + </includes> + </fileSet> + <fileSet> + <directory>target/assembly/lib</directory> + <outputDirectory>lib/dependencies</outputDirectory> + <includes> + <include>*.jar</include> + </includes> + </fileSet> + <fileSet> + <directory>src/main/feature/config</directory> + <outputDirectory>config</outputDirectory> + <fileMode>0644</fileMode> + <excludes/> + </fileSet> + <fileSet> + <directory>src/main/feature/bin</directory> + <outputDirectory>bin</outputDirectory> + <fileMode>0744</fileMode> + <excludes/> + </fileSet> + <fileSet> + <directory>src/main/feature/db</directory> + <outputDirectory>db</outputDirectory> + <fileMode>0744</fileMode> + <excludes/> + </fileSet> + <fileSet> + <directory>src/main/feature/install</directory> + <outputDirectory>install</outputDirectory> + <fileMode>0744</fileMode> + <excludes/> + </fileSet> + + </fileSets> + +</assembly> diff --git a/feature-test-transaction/src/main/java/org/onap/policy/drools/testtransaction/TestTransaction.java b/feature-test-transaction/src/main/java/org/onap/policy/drools/testtransaction/TestTransaction.java new file mode 100644 index 00000000..b167898a --- /dev/null +++ b/feature-test-transaction/src/main/java/org/onap/policy/drools/testtransaction/TestTransaction.java @@ -0,0 +1,227 @@ +/*- + * ============LICENSE_START======================================================= + * feature-test-transaction + * ================================================================================ + * Copyright (C) 2017 AT&T Intellectual Property. All rights reserved. + * ================================================================================ + * 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. + * ============LICENSE_END========================================================= + */ +package org.onap.policy.drools.testtransaction; + +import java.util.EventObject; +import java.util.HashMap; +import java.util.List; +import java.util.Map; + + + +import org.onap.policy.drools.controller.DroolsController; +import org.onap.policy.drools.controller.internal.MavenDroolsController; +import org.onap.policy.drools.system.PolicyController; +import org.slf4j.Logger; +import org.slf4j.LoggerFactory; +/** + * TestTransaction interface + * + */ +public interface TestTransaction { + + public static final String TT_FPC = "TT.FPC"; + public static final String TT_COUNTER = "$ttc"; + public static final String TT_UUID = "43868e59-d1f3-43c2-bd6f-86f89a61eea5"; + public static long DEFAULT_TT_TASK_SLEEP = 20000; + + public static final TestTransaction manager = new TTImpl(); + + public void register(PolicyController controller); + public void unregister(PolicyController controller); +} + +/** + * Implementation of TestTransaction interface. + * Controls the registering/unregistering of + * PolicyController objects and the management + * of their related TTControllerTask threads. + */ +class TTImpl implements TestTransaction { + + final protected Map<String, TTControllerTask> controllers = new HashMap<>(); + + @Override + public synchronized void register(PolicyController controller) { + if (controllers.containsValue(controller)) { + TTControllerTask controllerTask = controllers.get(controller.getName()); + if (controllerTask.isAlive()) + return; + + // continue : unregister, register operation + } + + TTControllerTask controllerTask = new TTControllerTask(controller); + controllers.put(controller.getName(), controllerTask); + } + + @Override + public synchronized void unregister(PolicyController controller) { + if (!controllers.containsValue(controller)) + return; + + TTControllerTask controllerTask = controllers.get(controller.getName()); + controllerTask.stop(); + + controllers.remove(controller.getName()); + } +} + +/** + * TTControllerTask implements the Runnabale interface + * Carries out the injection of an event into a drools + * session and subsequent query of a counter to ensure + * that forward progress is occuring. + * + */ +class TTControllerTask implements Runnable { + // get an instance of logger + private static final Logger logger = LoggerFactory.getLogger(TTControllerTask.class); + + protected final PolicyController controller; + + protected volatile boolean alive = true; + protected final Thread thread = new Thread(this); + + public TTControllerTask(PolicyController controller) { + this.controller = controller; + thread.setName("tt-controller-task-" + controller.getName()); + thread.start(); + } + + public PolicyController getController() { + return controller; + } + + public synchronized boolean isAlive() { + return alive; + } + + public synchronized void stop() { + this.alive = false; + thread.interrupt(); + try { + thread.join(1000); + } catch (InterruptedException e) { + logger.error("TestTransaction thread threw", e); + thread.interrupt(); + } + } + + public Thread getThread() { + return thread; + } + + @Override + public void run() { + try { + List<String> sessions = + controller.getDrools().getSessionNames(); + + if (!(controller.getDrools().isBrained())) { + alive = false; + logger.error(this + ": unknown drools controller"); + return; + } + + DroolsController drools = controller.getDrools(); + + HashMap<String,Long> fpcs = new HashMap<>(); + for (String session: sessions) { + fpcs.put(session, -1L); + } + + while (controller.isAlive() && + !controller.isLocked() && + drools.isBrained() && + alive) { + + for (String session : sessions) { + List<Object> facts = controller.getDrools().factQuery(session, + TestTransaction.TT_FPC, + TestTransaction.TT_COUNTER, + false); + if (facts == null || facts.size() != 1) { + /* + * unexpected something wrong here, can't expect to recover + * note this exception is caught right below at the exit of run() + */ + logger.error("Controller: {}, with rules artifact: (group) {}, (artifact) {}, (version) {} - FPC query failed after EventObject insertion! ", + controller.getName(), + controller.getDrools().getGroupId(), + controller.getDrools().getArtifactId(), + controller.getDrools().getVersion()); + break; + } + logger.debug("Facts: {}", facts); + + long fpc = (Long) facts.get(0); + if (fpc != fpcs.get(session)) + logger.info("Controller: {} , session {} - Forward progress successful: {} -> {}", + controller.getName(), + session, + fpcs.get(session), + fpc); + else + logger.error("Controller: {}, session {} - Forward progress failure: {}", + controller.getName(), + session, + fpc); + + fpcs.put(session, fpc); + drools.getContainer().insert(session, new EventObject(TestTransaction.TT_UUID)); + } + + if (!alive) + return; + + if (!Thread.currentThread().isInterrupted()) + Thread.sleep(TestTransaction.DEFAULT_TT_TASK_SLEEP); + } + } catch (InterruptedException e) { + logger.info("{}: stopping ...", this, e); + } + catch (IllegalArgumentException e) { + logger.error("{}: controller {} has not been enabled for testing: ", this, controller.getName(), e.getMessage()); + } catch (Exception e) { + logger.error("Controller: {} is not testable - TestTransaction caught exception: {} ", + controller.getName(), + e.getMessage()); + logger.error("TestTransaction thread threw", e); + } finally { + logger.info("Exiting: {}", this); + alive = false; + } + } + + @Override + public String toString() { + StringBuilder builder = new StringBuilder(); + builder.append("TTControllerTask [controller="); + builder.append(controller); + builder.append(", alive="); + builder.append(alive); + builder.append(", thread="); + builder.append(thread.getName()); + builder.append("]"); + return builder.toString(); + } + +} diff --git a/feature-test-transaction/src/main/java/org/onap/policy/drools/testtransaction/TestTransactionFeature.java b/feature-test-transaction/src/main/java/org/onap/policy/drools/testtransaction/TestTransactionFeature.java new file mode 100644 index 00000000..72c54969 --- /dev/null +++ b/feature-test-transaction/src/main/java/org/onap/policy/drools/testtransaction/TestTransactionFeature.java @@ -0,0 +1,83 @@ +/*- + * ============LICENSE_START======================================================= + * feature-test-transaction + * ================================================================================ + * Copyright (C) 2017 AT&T Intellectual Property. All rights reserved. + * ================================================================================ + * 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. + * ============LICENSE_END========================================================= + */ + +package org.onap.policy.drools.testtransaction; + +import org.onap.policy.drools.features.PolicyControllerFeatureAPI; +import org.onap.policy.drools.system.PolicyController; +import org.slf4j.Logger; +import org.slf4j.LoggerFactory; +/** + * TestTransactionFeature implements the PolicyControllerFeatureAPI. + * TestTransactionFeature is the interface to the TestTransaction feature logic. + * + */ +public class TestTransactionFeature implements PolicyControllerFeatureAPI { + + // get an instance of logger + private static final Logger logger = LoggerFactory.getLogger(TestTransactionFeature.class); + + @Override + public boolean afterStart(PolicyController controller){ + + logger.info("TEST_TRANSACTION FEATURE LOADED"); + + if (controller.isAlive() && + !controller.isLocked() && + controller.getDrools().isBrained()) + TestTransaction.manager.register(controller); + + return false; + } + + @Override + public boolean afterLock(PolicyController controller) { + logger.info("CONTROLLER " + controller.getName() + " LOCKED"); + + TestTransaction.manager.unregister(controller); + return false; + } + + @Override + public boolean afterUnlock(PolicyController controller) { + logger.info("CONTROLLER " + controller.getName() + " UNLOCKED"); + + if (controller.isAlive() && + !controller.isLocked() && + controller.getDrools().isBrained()) + TestTransaction.manager.register(controller); + + return false; + } + + @Override + public boolean beforeStop(PolicyController controller) { + logger.info("CONTROLLER " + controller.getName() + " ABOUT TO STOP"); + + TestTransaction.manager.unregister(controller); + + return false; + } + + @Override + public int getSequenceNumber() { + return 1000; + } +} diff --git a/feature-test-transaction/src/main/resources/META-INF/services/org.onap.policy.drools.features.PolicyControllerFeatureAPI b/feature-test-transaction/src/main/resources/META-INF/services/org.onap.policy.drools.features.PolicyControllerFeatureAPI new file mode 100644 index 00000000..6b60237d --- /dev/null +++ b/feature-test-transaction/src/main/resources/META-INF/services/org.onap.policy.drools.features.PolicyControllerFeatureAPI @@ -0,0 +1 @@ +org.onap.policy.drools.testtransaction.TestTransactionFeature diff --git a/feature-test-transaction/src/main/resources/TestTransactionTemplate.drl b/feature-test-transaction/src/main/resources/TestTransactionTemplate.drl new file mode 100644 index 00000000..381f0892 --- /dev/null +++ b/feature-test-transaction/src/main/resources/TestTransactionTemplate.drl @@ -0,0 +1,47 @@ +/*- + * ============LICENSE_START======================================================= + * feature-test-transaction + * ================================================================================ + * Copyright (C) 2017 AT&T Intellectual Property. All rights reserved. + * ================================================================================ + * 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. + * ============LICENSE_END========================================================= + */ +package org.onap.policy.drools.rules; + +import java.util.EventObject; + +declare ForwardProgress + counter : Long +end + +rule "TT.SETUP" +when +then + ForwardProgress fp = new ForwardProgress(); + fp.setCounter(0L); + insert(fp); +end + +rule "TT" +when + $fp : ForwardProgress() + $tt : EventObject(source == "43868e59-d1f3-43c2-bd6f-86f89a61eea5") +then + $fp.setCounter($fp.getCounter() + 1); + retract($tt); +end + +query "TT.FPC" + ForwardProgress(counter >= 0, $ttc : counter) +end |