--- /dev/null
+/*-
+ * ============LICENSE_START=======================================================
+ * ONAP-PDP
+ * ================================================================================
+ * 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.pdp.test.conformance;
+
+import org.onap.policy.common.logging.flexlogger.FlexLogger;
+import org.onap.policy.common.logging.flexlogger.Logger;
+
+import com.att.research.xacml.api.Request;
+import com.att.research.xacml.api.Response;
+import com.att.research.xacml.api.pdp.PDPEngine;
+import com.att.research.xacml.api.pdp.PDPEngineFactory;
+import com.att.research.xacml.api.pdp.ScopeResolver;
+import com.att.research.xacml.std.dom.DOMProperties;
+import com.att.research.xacml.std.dom.DOMRequest;
+import com.att.research.xacml.std.dom.DOMResponse;
+import com.att.research.xacml.util.FactoryException;
+
+/**
+ * ConformanceTestEngine handles the creation of the PDPEngine for a ConformanceTest instance.
+ *
+ * @version $Revision: 1.2 $
+ */
+public class ConformanceTestEngine {
+ private Logger logger = FlexLogger.getLogger(ConformanceTestEngine.class);
+
+ private PDPEngineFactory pdpEngineFactory;
+ private ScopeResolver scopeResolver;
+ private boolean lenientRequests;
+ private boolean lenientPolicies;
+ private int iterations = 1;
+
+ // total of all first calls to decide()
+ private long firstDecideTime;
+ private int numberOfFirstDecides = 0;
+
+ // total of all non-first-calls to decide()
+ private long decideTimeMultiple;
+
+ // total of average time each test case uses for a Request
+ // (sum of : for each test case, average of all non-first-call calls to decide() )
+ private long avgDecideTimeMultiple = 0;
+
+ protected PDPEngineFactory getPDPEngineFactory() throws FactoryException {
+ if (this.pdpEngineFactory == null) {
+ this.pdpEngineFactory = PDPEngineFactory.newInstance();
+ this.pdpEngineFactory.setScopeResolver(this.scopeResolver);
+ }
+ return this.pdpEngineFactory;
+ }
+
+ public ConformanceTestEngine(ScopeResolver scopeResolverIn, boolean lenientRequestsIn, boolean lenientPoliciesIn, int iterationsIn) {
+ this.scopeResolver = scopeResolverIn;
+ this.lenientRequests = lenientRequestsIn;
+ this.lenientPolicies = lenientPoliciesIn;
+ this.iterations = iterationsIn;
+ }
+
+ public ConformanceTestResult run(ConformanceTest conformanceTest) {
+ if (conformanceTest.getRequest() == null || conformanceTest.getResponse() == null || conformanceTest.getRepository() == null) {
+ logger.error("Incomplete Conformance Test: " + conformanceTest.getTestName());
+ }
+ PDPEngineFactory thisPDPEngineFactory = null;
+ try {
+ thisPDPEngineFactory = this.getPDPEngineFactory();
+ } catch (FactoryException ex) {
+ return new ConformanceTestResult(conformanceTest, ex);
+ }
+
+ ConformanceTestResult conformanceTestResult = new ConformanceTestResult(conformanceTest, iterations);
+
+ /*
+ * Load the request
+ */
+ Request request = null;
+ boolean isLenient = DOMProperties.isLenient();
+ try {
+ DOMProperties.setLenient(this.lenientRequests);
+ try {
+ request = DOMRequest.load(conformanceTest.getRequest());
+ conformanceTestResult.setRequest(request);
+ } catch (Exception ex) {
+ logger.error("Exception loading Request file " + conformanceTest.getRequest().getAbsolutePath(), ex);
+ conformanceTestResult.setError(ex);
+ return conformanceTestResult;
+
+ }
+
+ /*
+ * Load the expected response
+ */
+ Response response = null;
+ try {
+ response = DOMResponse.load(conformanceTest.getResponse());
+ conformanceTestResult.setExpectedResponse(response);
+ } catch (Exception ex) {
+ logger.error("Exception loading Response file " + conformanceTest.getResponse().getAbsolutePath(), ex);
+ conformanceTestResult.setError(ex);
+ return conformanceTestResult;
+ }
+
+ /*
+ * Set up the configuration for the policy finder
+ */
+ conformanceTest.getRepository().setXACMLProperties();
+ DOMProperties.setLenient(this.lenientPolicies);
+
+ /*
+ * Create the engine
+ */
+ PDPEngine pdpEngine = null;
+ try {
+ // pdpEngine = thisPDPEngineFactory.newEngine(conformanceTest.getRootPolicy(), conformanceTest.getReferencedPolicies(), pipFinderEngine);
+ pdpEngine = thisPDPEngineFactory.newEngine();
+ } catch (Exception ex) {
+ logger.error("Exception getting PDP engine instance", ex);
+ conformanceTestResult.setError(ex);
+ return conformanceTestResult;
+ }
+ if (pdpEngine == null) {
+ logger.error("Null PDP engine");
+ conformanceTestResult.setError(new NullPointerException("Null engine"));
+ return conformanceTestResult;
+ }
+
+ /*
+ * Run the request
+ */
+ long startTime, endTime;
+ long curDecideTime = this.firstDecideTime;
+ try {
+ startTime = System.nanoTime();
+ response = pdpEngine.decide(request);
+ endTime = System.nanoTime();
+//System.out.println(endTime - startTime);
+ // add to total
+ this.firstDecideTime += endTime - startTime;
+ this.numberOfFirstDecides++;
+ // remember just this test
+ conformanceTestResult.setFirstCallTime(endTime - startTime);
+ conformanceTestResult.setActualResponse(response);
+ } catch (Exception ex) {
+ logger.error("Exception in decide", ex);
+ conformanceTestResult.setError(ex);
+ return conformanceTestResult;
+ }
+ if (response == null) {
+ logger.error("Null Response");
+ conformanceTestResult.setError(new NullPointerException("Null Response"));
+ return conformanceTestResult;
+ }
+
+ long localLoopTime = 0;
+ try {
+ // if user requested non-first-call calls to decide() to get performance info, run them now.
+ // We can ignore the result since we are only interested in how long they take to process the Request.
+ for (int i = 0 ; i < this.iterations ; i++) {
+ startTime = System.nanoTime();
+ pdpEngine.decide(request);
+ endTime = System.nanoTime();
+//System.out.println(endTime - startTime);
+ // add to the global total for all tests
+ this.decideTimeMultiple += (endTime - startTime);
+ // remember just this one test's info
+ localLoopTime += (endTime - startTime);
+ }
+ } catch (Exception ex) {
+ logger.error("Exception in iterated decide", ex);
+ return conformanceTestResult;
+ }
+
+ // add to total average for non-first-call times for all test cases
+ avgDecideTimeMultiple += (localLoopTime / iterations);
+//System.out.println("localLoop="+localLoopTime + " it="+iterations + " avg=" + (localLoopTime / iterations) );
+ // remember average time for just this test
+ conformanceTestResult.setAverageTotalLoopTime(localLoopTime/iterations);
+
+ long elapsedDecideTime = this.firstDecideTime - curDecideTime;
+ logger.info("Decide Time: " + elapsedDecideTime + "ns");
+
+ return conformanceTestResult;
+ } finally {
+ DOMProperties.setLenient(isLenient);
+ }
+ }
+
+ public long getFirstDecideTime() {
+ return this.firstDecideTime;
+ }
+
+ public long getDecideTimeMultiple() {
+ return this.decideTimeMultiple;
+ }
+
+
+ public long getAvgFirstDecideTime() {
+ return this.firstDecideTime / numberOfFirstDecides;
+ }
+ public long getAvgDecideTimeMultiple() {
+ return this.avgDecideTimeMultiple / numberOfFirstDecides;
+ }
+}
Code Review / policy / engine.git / blobdiff