summaryrefslogtreecommitdiffstats
path: root/test
diff options
context:
space:
mode:
authorStefan Radomski <sradomski@mintwerk.de>2016-01-08 22:15:37 (GMT)
committerStefan Radomski <sradomski@mintwerk.de>2016-01-08 22:15:37 (GMT)
commit9f4d810400550d1b98ab944cd96f937720eb6b0d (patch)
treea30226ae642e54e217c9b89523d75f1346d5f7cb /test
parentf9eb54fc9c17116954846133b33f7a241e662cbc (diff)
downloaduscxml-9f4d810400550d1b98ab944cd96f937720eb6b0d.zip
uscxml-9f4d810400550d1b98ab944cd96f937720eb6b0d.tar.gz
uscxml-9f4d810400550d1b98ab944cd96f937720eb6b0d.tar.bz2
Fixed compilation for gcc on Linux again
Diffstat (limited to 'test')
-rw-r--r--test/CMakeLists.txt1
-rw-r--r--test/ctest/CTestCustom.ctest.in37
-rw-r--r--test/src/test-c-machine.cpp375
-rw-r--r--test/src/test-c-machine.machine.c400
-rw-r--r--test/src/test-misc.cpp23
-rw-r--r--test/src/test-w3c.cpp51
-rw-r--r--test/w3c/run_generated_c_test.cmake4
7 files changed, 695 insertions, 196 deletions
diff --git a/test/CMakeLists.txt b/test/CMakeLists.txt
index dcb145a..5af6a4a 100644
--- a/test/CMakeLists.txt
+++ b/test/CMakeLists.txt
@@ -154,6 +154,7 @@ if (NOT BUILD_MINIMAL)
-DPROJECT_SOURCE_DIR=${PROJECT_SOURCE_DIR}
-DUSCXML_PLATFORM_ID=${USCXML_PLATFORM_ID}
-DCMAKE_BINARY_DIR=${CMAKE_BINARY_DIR}
+ -DPROJECT_BINARY_DIR=${PROJECT_BINARY_DIR}
-DCMAKE_LIBRARY_OUTPUT_DIRECTORY=${CMAKE_LIBRARY_OUTPUT_DIRECTORY}
-DSCAFFOLDING_FOR_GENERATED_C:FILEPATH=${CMAKE_CURRENT_SOURCE_DIR}/src/test-c-machine.cpp
-P ${CMAKE_CURRENT_SOURCE_DIR}/w3c/run_generated_c_test.cmake)
diff --git a/test/ctest/CTestCustom.ctest.in b/test/ctest/CTestCustom.ctest.in
index 248ae8a..6a66839 100644
--- a/test/ctest/CTestCustom.ctest.in
+++ b/test/ctest/CTestCustom.ctest.in
@@ -198,6 +198,7 @@ set(CTEST_CUSTOM_TESTS_IGNORE
### Ignore for generated C sources
# we do not support invokers yet
+ "gen_c/ecma/test187.scxml"
"gen_c/ecma/test191.scxml"
"gen_c/ecma/test192.scxml"
"gen_c/ecma/test207.scxml"
@@ -229,9 +230,45 @@ set(CTEST_CUSTOM_TESTS_IGNORE
"gen_c/ecma/test252.scxml"
"gen_c/ecma/test253.scxml"
"gen_c/ecma/test276.scxml"
+ "gen_c/ecma/test338.scxml"
+ "gen_c/ecma/test347.scxml"
+ "gen_c/ecma/test422.scxml"
+ "gen_c/ecma/test530.scxml"
+ "gen_c/ecma/test554.scxml"
# we do not support io processors yet
"gen_c/ecma/test201.scxml"
+ "gen_c/ecma/test496.scxml"
+ "gen_c/ecma/test500.scxml"
+ "gen_c/ecma/test501.scxml"
+ "gen_c/ecma/test509.scxml"
+ "gen_c/ecma/test510.scxml"
+ "gen_c/ecma/test518.scxml"
+ "gen_c/ecma/test519.scxml"
+ "gen_c/ecma/test520.scxml"
+ "gen_c/ecma/test521.scxml"
+ "gen_c/ecma/test522.scxml"
+ "gen_c/ecma/test531.scxml"
+ "gen_c/ecma/test532.scxml"
+ "gen_c/ecma/test534.scxml"
+ "gen_c/ecma/test567.scxml"
+ "gen_c/ecma/test569.scxml"
+ "gen_c/ecma/test577.scxml"
+
+ # failing is succeeding
+ "gen_c/ecma/test301.scxml"
+
+ # manual test
+ "gen_c/ecma/test307.scxml"
+
+ # data from file
+ "gen_c/ecma/test446.scxml"
+ "gen_c/ecma/test552.scxml"
+ "gen_c/ecma/test557.scxml"
+ "gen_c/ecma/test558.scxml"
+
+ # XML DOM in data
+ "gen_c/ecma/test561.scxml"
)
diff --git a/test/src/test-c-machine.cpp b/test/src/test-c-machine.cpp
index a9e5ecb..4bbc653 100644
--- a/test/src/test-c-machine.cpp
+++ b/test/src/test-c-machine.cpp
@@ -6,13 +6,22 @@
#include <deque> // deque
#include <boost/algorithm/string.hpp> // trim
-#define SCXML_VERBOSE 1
+//#define SCXML_VERBOSE
+
+#include "uscxml/config.h"
+
+#ifdef APPLE
+#include <mach/mach.h>
+#include <mach/mach_time.h>
+#include <pthread.h>
+#endif
#ifndef AUTOINCLUDE_TEST
#include "test-c-machine.machine.c"
#endif
#include "uscxml/Convenience.h"
+#include "uscxml/concurrency/Timer.h"
//#include "uscxml/DOMUtils.h"
#include "uscxml/Factory.h"
#include "uscxml/InterpreterInfo.h"
@@ -21,6 +30,10 @@
#include "uscxml/concurrency/DelayedEventQueue.h"
#include "uscxml/concurrency/tinythread.h"
+#ifdef BUILD_PROFILING
+# include "uscxml/plugins/DataModel.h"
+# endif
+
#define USER_DATA(ctx) ((GenCInterpreterInfo*)(((scxml_ctx*)ctx)->user_data))
using namespace uscxml;
@@ -82,33 +95,49 @@ public:
int matches(const char* desc, const char* event) {
const char* dPtr = desc;
const char* ePtr = event;
- while(true) {
+ while(*dPtr != 0) {
- // next event descriptor
- if (*dPtr == ' ') {
+ if (*dPtr == '*' && *ePtr != 0) // something following
+ return true;
+
+ // descriptor differs from event name
+ if (*dPtr != *ePtr) {
+ // move to next descriptor
+ while(*dPtr != ' ' && *dPtr != 0) {
+ dPtr++;
+ }
+ if (*dPtr == 0)
+ return false;
dPtr++;
ePtr = event;
- continue;
+ } else {
+ // move both pointers one character
+ dPtr++;
+ ePtr++;
+
}
// descriptor is done, return match
- if (*dPtr == 0 || *dPtr == '*')
+ if (((*dPtr == 0 || *dPtr == ' ') && (*ePtr == 0 || *ePtr == ' ')) || // exact match, end of string
+ (*dPtr == ' ' && *ePtr == '.') || (*dPtr == 0 && *ePtr == '.')) // prefix match
return true;
-
- // descriptor differs from event name
- if (*dPtr != *ePtr)
- return false;
-
- // move both pointers one character
- dPtr++;
- ePtr++;
}
+ return false;
}
int exec_content_raise(const scxml_ctx* ctx, const char* event) {
Event* e = new Event();
e->name = strdup(event);
+
+ if (boost::starts_with(e->name, "error.")) {
+ e->eventType = Event::PLATFORM;
+ } else {
+ e->eventType = Event::INTERNAL;
+ }
+
+#ifdef SCXML_VERBOSE
printf("Raising Internal Event: %s\n", e->name.c_str());
+#endif
USER_DATA(ctx)->iq.push_back(e);
return SCXML_ERR_OK;
}
@@ -145,9 +174,42 @@ int is_enabled(const scxml_ctx* ctx, const scxml_transition* t, const void* e) {
return false;
}
-int raise_done_event(const scxml_ctx* ctx, const scxml_state* state) {
- std::string doneName = "done.state.";
- exec_content_raise(ctx, (doneName + state->name).c_str());
+int raise_done_event(const scxml_ctx* ctx, const scxml_state* state, const scxml_elem_donedata* donedata) {
+ Event* e = new Event();
+ e->name = std::string("done.state.") + state->name;
+
+ if (donedata) {
+ if (donedata->content != NULL) {
+ e->data = Data(donedata->content, Data::VERBATIM);
+ } else if (donedata->contentexpr != NULL) {
+ try {
+ e->data = USER_DATA(ctx)->datamodel->getStringAsData(donedata->contentexpr);
+ } catch (Event e) {
+ exec_content_raise(ctx, e.name.c_str());
+ }
+ } else {
+ try {
+ const scxml_elem_param* param = donedata->params;
+ while (param && ELEM_PARAM_IS_SET(param)) {
+ Data paramValue;
+ if (param->expr != NULL) {
+ paramValue = USER_DATA(ctx)->datamodel->getStringAsData(param->expr);
+ } else if(param->location) {
+ paramValue = USER_DATA(ctx)->datamodel->getStringAsData(param->location);
+ }
+ e->params.insert(std::make_pair(param->name, paramValue));
+ param++;
+ }
+ } catch (Event e) {
+ exec_content_raise(ctx, e.name.c_str());
+ }
+ }
+ }
+
+#ifdef SCXML_VERBOSE
+ printf("Raising Done Event: %s\n", e->name.c_str());
+#endif
+ USER_DATA(ctx)->iq.push_back(e);
return SCXML_ERR_OK;
}
@@ -156,10 +218,16 @@ void delayedSend(void* ctx, std::string eventName) {
SendRequest* e = USER_DATA(ctx)->sendIds[eventName];
if (e->target == "#_internal") {
+ e->eventType = Event::INTERNAL;
+#ifdef SCXML_VERBOSE
printf("Pushing Internal Event: %s\n", e->name.c_str());
+#endif
USER_DATA(ctx)->iq.push_back(e);
} else {
+ e->eventType = Event::EXTERNAL;
+#ifdef SCXML_VERBOSE
printf("Pushing External Event: %s\n", e->name.c_str());
+#endif
USER_DATA(ctx)->eq.push_back(e);
}
USER_DATA(ctx)->monitor.notify_all();
@@ -182,6 +250,27 @@ int exec_content_cancel(const scxml_ctx* ctx, const char* sendid, const char* se
return SCXML_ERR_OK;
}
+std::string spaceNormalize(const std::string& text) {
+ std::stringstream content;
+ std::string seperator;
+
+ size_t start = 0;
+ for (int i = 0; i < text.size(); i++) {
+ if (isspace(text[i])) {
+ if (i > 0 && start < i) {
+ content << seperator << text.substr(start, i - start);
+ seperator = " ";
+ }
+ while(isspace(text[++i])); // skip whitespaces
+ start = i;
+ } else if (i + 1 == text.size()) {
+ content << seperator << text.substr(start, i + 1 - start);
+ }
+ }
+ return content.str();
+}
+
+
int exec_content_send(const scxml_ctx* ctx, const scxml_elem_send* send) {
SendRequest* e = new SendRequest();
@@ -190,6 +279,8 @@ int exec_content_send(const scxml_ctx* ctx, const scxml_elem_send* send) {
e->target = send->target;
} else if (send->targetexpr != NULL) {
e->target = USER_DATA(ctx)->datamodel->evalAsString(send->targetexpr);
+ } else {
+ e->target = "#_external";
}
if (e->target.size() > 0 && (e->target[0] != '#' || e->target[1] != '_')) {
@@ -198,12 +289,20 @@ int exec_content_send(const scxml_ctx* ctx, const scxml_elem_send* send) {
return SCXML_ERR_INVALID_TARGET;
}
- if (send->type != NULL) {
- e->type = send->type;
- } else if (send->typeexpr != NULL) {
- e->type = USER_DATA(ctx)->datamodel->evalAsString(send->typeexpr);
- } else {
- e->type = "http://www.w3.org/TR/scxml/#SCXMLEventProcessor";
+ e->origintype = "http://www.w3.org/TR/scxml/#SCXMLEventProcessor";
+ e->origin = e->target;
+
+ try {
+ if (send->type != NULL) {
+ e->type = send->type;
+ } else if (send->typeexpr != NULL) {
+ e->type = USER_DATA(ctx)->datamodel->evalAsString(send->typeexpr);
+ } else {
+ e->type = "http://www.w3.org/TR/scxml/#SCXMLEventProcessor";
+ }
+ } catch (Event e) {
+ exec_content_raise(ctx, e.name.c_str());
+ return SCXML_ERR_EXEC_CONTENT;
}
// only one somewhat supported
@@ -221,31 +320,67 @@ int exec_content_send(const scxml_ctx* ctx, const scxml_elem_send* send) {
e->name = strdup(send->event);
}
- const scxml_elem_param* param = send->params;
- while (param && ELEM_PARAM_IS_SET(param)) {
- Data paramValue;
- if (param->expr != NULL) {
- paramValue = USER_DATA(ctx)->datamodel->getStringAsData(param->expr);
- } else if(param->location) {
- paramValue = USER_DATA(ctx)->datamodel->getStringAsData(param->location);
+ try {
+ const scxml_elem_param* param = send->params;
+ while (param && ELEM_PARAM_IS_SET(param)) {
+ Data paramValue;
+ if (param->expr != NULL) {
+ paramValue = USER_DATA(ctx)->datamodel->getStringAsData(param->expr);
+ } else if(param->location) {
+ paramValue = USER_DATA(ctx)->datamodel->getStringAsData(param->location);
+ }
+ e->params.insert(std::make_pair(param->name, paramValue));
+ param++;
}
- e->params.insert(std::make_pair(param->name, paramValue));
- param++;
+ } catch (Event e) {
+ exec_content_raise(ctx, e.name.c_str());
+ return SCXML_ERR_EXEC_CONTENT;
}
-
+
+ try {
+ if (send->namelist != NULL) {
+ const char* bPtr = &send->namelist[0];
+ const char* ePtr = bPtr;
+ while(*ePtr != '\0') {
+ ePtr++;
+ if (*ePtr == ' ' || *ePtr == '\0') {
+ std::string key(bPtr, ePtr - bPtr);
+ e->params.insert(std::make_pair(key, USER_DATA(ctx)->datamodel->getStringAsData(key)));
+ if (*ePtr == '\0')
+ break;
+ bPtr = ++ePtr;
+ }
+ }
+ }
+ } catch (Event e) {
+ exec_content_raise(ctx, e.name.c_str());
+ return SCXML_ERR_EXEC_CONTENT;
+ }
+
if (send->content != NULL) {
- e->data = Data(send->content, Data::VERBATIM);
+ // will it parse as json?
+ Data d = Data::fromJSON(send->content);
+ if (!d.empty()) {
+ e->data = d;
+ } else {
+ e->data = Data(spaceNormalize(send->content), Data::VERBATIM);
+ }
}
const char* sendid = NULL;
if (send->id != NULL) {
sendid = send->id;
+ e->sendid = sendid;
} else {
sendid = strdup(UUID::getUUID().c_str());
- if (send->idlocation != NULL)
+ if (send->idlocation != NULL) {
USER_DATA(ctx)->datamodel->assign(send->idlocation, Data(sendid, Data::VERBATIM));
+ } else {
+ e->hideSendId = true;
+ }
}
+
size_t delayMs = 0;
std::string delay;
if (send->delayexpr != NULL) {
@@ -299,9 +434,15 @@ int exec_content_init(const scxml_ctx* ctx, const scxml_elem_data* data) {
}
int exec_content_assign(const scxml_ctx* ctx, const char* location, const char* expr) {
+ std::string key = location;
+ if (key == "_sessionid" || key == "_name" || key == "_ioprocessors" || key == "_invokers" || key == "_event") {
+ exec_content_raise(ctx, "error.execution");
+ return SCXML_ERR_EXEC_CONTENT;
+ }
+
try {
Data d(expr, Data::INTERPRETED);
- USER_DATA(ctx)->datamodel->assign(location, d);
+ USER_DATA(ctx)->datamodel->assign(key, d);
} catch (Event e) {
exec_content_raise(ctx, e.name.c_str());
return SCXML_ERR_EXEC_CONTENT;
@@ -350,10 +491,25 @@ int exec_content_foreach_done(const scxml_ctx* ctx, const scxml_elem_foreach* fo
}
int exec_content_log(const scxml_ctx* ctx, const char* label, const char* expr) {
- if (label != 0) {
- printf("%s: %s\n", label, expr);
- } else {
- printf("%s\n", USER_DATA(ctx)->datamodel->evalAsString(expr).c_str());
+ try {
+ if (label != 0) {
+// printf("%s: %s\n", label, USER_DATA(ctx)->datamodel->evalAsString(expr).c_str());
+ } else {
+// printf("%s\n", USER_DATA(ctx)->datamodel->evalAsString(expr).c_str());
+ }
+ } catch (Event e) {
+ exec_content_raise(ctx, e.name.c_str());
+ return SCXML_ERR_EXEC_CONTENT;
+ }
+
+ return SCXML_ERR_OK;
+}
+
+int exec_content_script(const scxml_ctx* ctx, const char* src, const char* content) {
+ if (content != NULL) {
+ USER_DATA(ctx)->datamodel->eval(Arabica::DOM::Element<std::string>(), content);
+ } else if (src != NULL) {
+ return SCXML_ERR_UNSUPPORTED;
}
return SCXML_ERR_OK;
}
@@ -366,7 +522,9 @@ void* dequeue_external(const scxml_ctx* ctx) {
Event* e = USER_DATA(ctx)->eq.front();
USER_DATA(ctx)->eq.pop_front();
USER_DATA(ctx)->datamodel->setEvent(*e);
+#ifdef SCXML_VERBOSE
printf("Popping External Event: %s\n", e->name.c_str());
+#endif
return e;
}
@@ -376,54 +534,125 @@ void* dequeue_internal(const scxml_ctx* ctx) {
Event* e = USER_DATA(ctx)->iq.front();
USER_DATA(ctx)->iq.pop_front();
USER_DATA(ctx)->datamodel->setEvent(*e);
+#ifdef SCXML_VERBOSE
printf("Popping Internal Event: %s\n", e->name.c_str());
+#endif
return e;
}
int main(int argc, char** argv) {
+
+#ifdef APPLE
+ mach_timebase_info_data_t timebase_info;
+ mach_timebase_info(&timebase_info);
+
+ const uint64_t NANOS_PER_MSEC = 1000000ULL;
+ double clock2abs = ((double)timebase_info.denom / (double)timebase_info.numer) * NANOS_PER_MSEC;
+
+ thread_time_constraint_policy_data_t policy;
+ policy.period = 0;
+ policy.computation = (uint32_t)(5 * clock2abs); // 5 ms of work
+ policy.constraint = (uint32_t)(10 * clock2abs);
+ policy.preemptible = FALSE;
+
+ int kr = thread_policy_set(pthread_mach_thread_np(pthread_self()),
+ THREAD_TIME_CONSTRAINT_POLICY,
+ (thread_policy_t)&policy,
+ THREAD_TIME_CONSTRAINT_POLICY_COUNT);
+ if (kr != KERN_SUCCESS) {
+ mach_error("thread_policy_set:", kr);
+ exit(1);
+ }
+#endif
+
int err;
+ size_t benchmarkRuns = 1;
+ const char* envBenchmarkRuns = getenv("USCXML_BENCHMARK_ITERATIONS");
+ if (envBenchmarkRuns != NULL) {
+ benchmarkRuns = strTo<size_t>(envBenchmarkRuns);
+ }
+
+ size_t remainingRuns = benchmarkRuns;
+
// setup info object required for datamodel
GenCInterpreterInfo interpreterInfo;
- interpreterInfo.name = "adsf";
+ interpreterInfo.name = SCXML_MACHINE_NAME;
interpreterInfo.sessionId = "rfwef";
- interpreterInfo.datamodel = Factory::getInstance()->createDataModel("ecmascript", &interpreterInfo);
interpreterInfo.delayQueue.start();
scxml_ctx ctx;
- memset(&ctx, 0, sizeof(scxml_ctx));
interpreterInfo.ctx = &ctx;
-
- // set info object as user data
- ctx.user_data = (void*)&interpreterInfo;
-
- // register callbacks with scxml context
- ctx.is_enabled = &is_enabled;
- ctx.is_true = &is_true;
- ctx.raise_done_event = &raise_done_event;
-
- ctx.exec_content_send = &exec_content_send;
- ctx.exec_content_raise = &exec_content_raise;
- ctx.exec_content_cancel = &exec_content_cancel;
- ctx.exec_content_log = &exec_content_log;
- ctx.exec_content_assign = &exec_content_assign;
- ctx.exec_content_foreach_init = &exec_content_foreach_init;
- ctx.exec_content_foreach_next = &exec_content_foreach_next;
- ctx.exec_content_foreach_done = &exec_content_foreach_done;
- ctx.dequeue_external = &dequeue_external;
- ctx.dequeue_internal = &dequeue_internal;
- ctx.exec_content_init = &exec_content_init;
-
- while((err = scxml_step(&ctx)) == SCXML_ERR_OK);
- assert(ctx.flags & SCXML_CTX_TOP_LEVEL_FINAL);
-
- size_t passIdx = 0;
- for (int i = 0; i < SCXML_NUMBER_STATES; i++) {
- if (scxml_states[i].name && strcmp(scxml_states[i].name, "pass") == 0) {
- passIdx = i;
- break;
+
+ double avg = 0;
+ size_t microSteps = 0;
+#ifdef BUILD_PROFILING
+ double avgDm = 0;
+#endif
+
+ while(remainingRuns-- > 0) {
+ memset(&ctx, 0, sizeof(scxml_ctx));
+
+ // fresh dm (expensive :( )
+ interpreterInfo.datamodel = Factory::getInstance()->createDataModel("ecmascript", &interpreterInfo);
+
+ // set info object as user data
+ ctx.user_data = (void*)&interpreterInfo;
+
+ // register callbacks with scxml context
+ ctx.is_enabled = &is_enabled;
+ ctx.is_true = &is_true;
+ ctx.raise_done_event = &raise_done_event;
+
+ ctx.exec_content_send = &exec_content_send;
+ ctx.exec_content_raise = &exec_content_raise;
+ ctx.exec_content_cancel = &exec_content_cancel;
+ ctx.exec_content_log = &exec_content_log;
+ ctx.exec_content_assign = &exec_content_assign;
+ ctx.exec_content_foreach_init = &exec_content_foreach_init;
+ ctx.exec_content_foreach_next = &exec_content_foreach_next;
+ ctx.exec_content_foreach_done = &exec_content_foreach_done;
+ ctx.dequeue_external = &dequeue_external;
+ ctx.dequeue_internal = &dequeue_internal;
+ ctx.exec_content_init = &exec_content_init;
+ ctx.exec_content_script = &exec_content_script;
+
+ Timer t;
+ t.start();
+
+ microSteps = 0;
+ while((err = scxml_step(&ctx)) == SCXML_ERR_OK) { microSteps++; }
+ assert(ctx.flags & SCXML_CTX_TOP_LEVEL_FINAL);
+
+ t.stop();
+ avg += t.elapsed;
+#ifdef BUILD_PROFILING
+ avgDm += interpreterInfo.datamodel.get()->timer.elapsed;
+ interpreterInfo.datamodel.get()->timer.elapsed = 0;
+#endif
+ size_t passIdx = 0;
+ for (int i = 0; i < SCXML_NUMBER_STATES; i++) {
+ if (scxml_states[i].name && strcmp(scxml_states[i].name, "pass") == 0) {
+ passIdx = i;
+ break;
+ }
}
+
+ assert(IS_SET(passIdx, ctx.config));
+ interpreterInfo.delayQueue.cancelAllEvents();
+ interpreterInfo.eq.clear();
+ interpreterInfo.iq.clear();
}
- assert(IS_SET(passIdx, ctx.config));
+
+ // 14.25311111 us per microstep
+ // 1.923466667 us
+ std::cout << (avg * 1000.0) / (double)benchmarkRuns << " ms on average" << std::endl;
+ std::cout << microSteps << " microsteps per iteration (" << (avg * 1000.0) / ((double)benchmarkRuns * (double)microSteps) << " ms per microstep)" << std::endl;
+#ifdef BUILD_PROFILING
+ std::cout << (avgDm * 1000.0) / (double)benchmarkRuns << " ms in datamodel" << std::endl;
+ std::cout << ((avg - avgDm) * 1000.0) / ((double)benchmarkRuns * (double)microSteps) << " ms per microstep \\wo datamodel" << std::endl;
+#endif
+ interpreterInfo.delayQueue.stop();
+ tthread::this_thread::sleep_for(tthread::chrono::milliseconds(100));
return EXIT_SUCCESS;
} \ No newline at end of file
diff --git a/test/src/test-c-machine.machine.c b/test/src/test-c-machine.machine.c
index d4c924d..3663eac 100644
--- a/test/src/test-c-machine.machine.c
+++ b/test/src/test-c-machine.machine.c
@@ -5,6 +5,9 @@
#define SET_BIT(idx, bitset) bitset[idx >> 3] |= (1 << (idx & 7));
#define CLEARBIT(idx, bitset) bitset[idx >> 3] &= (1 << (idx & 7)) ^ 0xFF;
+#define likely(x) (__builtin_expect (!!(x), 1))
+#define unlikely(x) (__builtin_expect (!!(x), 0))
+
// error return codes
#define SCXML_ERR_OK 0
#define SCXML_ERR_IDLE 1
@@ -14,13 +17,16 @@
#define SCXML_ERR_EXEC_CONTENT 5
#define SCXML_ERR_INVALID_TARGET 6
#define SCXML_ERR_INVALID_TYPE 7
+#define SCXML_ERR_UNSUPPORTED 8
-#define SCXML_NUMBER_STATES 5
-#define SCXML_NUMBER_TRANSITIONS 4
+#define SCXML_MACHINE_NAME ""
+#define SCXML_NUMBER_STATES 14
+#define SCXML_NUMBER_TRANSITIONS 10
#define SCXML_TRANS_SPONTANEOUS 0x01
#define SCXML_TRANS_TARGETLESS 0x02
#define SCXML_TRANS_INTERNAL 0x04
+#define SCXML_TRANS_HISTORY 0x08
#define SCXML_STATE_ATOMIC 0x01
#define SCXML_STATE_PARALLEL 0x02
@@ -37,6 +43,7 @@
#define SCXML_CTX_TRANSITION_FOUND 0x08
#define ELEM_DATA_IS_SET(data) (data->id != NULL)
+#define ELEM_DONEDATA_IS_SET(donedata) (donedata->content != NULL || donedata->contentexpr != NULL || donedata->params != NULL)
#define ELEM_PARAM_IS_SET(param) (param->name != NULL)
@@ -48,6 +55,7 @@ typedef struct scxml_invoke scxml_invoke;
typedef struct scxml_elem_send scxml_elem_send;
typedef struct scxml_elem_param scxml_elem_param;
typedef struct scxml_elem_data scxml_elem_data;
+typedef struct scxml_elem_donedata scxml_elem_donedata;
typedef struct scxml_elem_foreach scxml_elem_foreach;
typedef void* (*dequeue_internal_cb_t)(const scxml_ctx* ctx);
@@ -55,7 +63,7 @@ typedef void* (*dequeue_external_cb_t)(const scxml_ctx* ctx);
typedef int (*is_enabled_cb_t)(const scxml_ctx* ctx, const scxml_transition* transition, const void* event);
typedef int (*is_true_cb_t)(const scxml_ctx* ctx, const char* expr);
typedef int (*exec_content_t)(const scxml_ctx* ctx, const scxml_state* state, const void* event);
-typedef int (*raise_done_event_t)(const scxml_ctx* ctx, const scxml_state* state);
+typedef int (*raise_done_event_t)(const scxml_ctx* ctx, const scxml_state* state, const scxml_elem_donedata* donedata);
typedef int (*invoke_t)(const scxml_ctx* ctx, const scxml_state* s, const scxml_invoke* x);
typedef int (*exec_content_log_t)(const scxml_ctx* ctx, const char* label, const char* expr);
@@ -79,25 +87,26 @@ struct scxml_elem_data {
struct scxml_state {
const char* name; // eventual name
+ uint16_t source; // parent
exec_content_t on_entry; // on entry handlers
exec_content_t on_exit; // on exit handlers
invoke_t invoke; // invocations
- char children[1]; // all children
- char completion[1]; // default completion
- char ancestors[1]; // all ancestors
+ char children[2]; // all children
+ char completion[2]; // default completion
+ char ancestors[2]; // all ancestors
const scxml_elem_data* data;
uint8_t type; // atomic, parallel, compound, final, history
};
struct scxml_transition {
uint16_t source;
- char target[1];
+ char target[2];
const char* event;
const char* condition;
exec_content_t on_transition;
uint8_t type;
- char conflicts[1];
- char exit_set[1];
+ char conflicts[2];
+ char exit_set[2];
};
struct scxml_elem_foreach {
@@ -112,6 +121,13 @@ struct scxml_elem_param {
const char* location;
};
+struct scxml_elem_donedata {
+ uint16_t source;
+ const char* content;
+ const char* contentexpr;
+ const scxml_elem_param* params;
+};
+
struct scxml_elem_invoke {
const char* type;
const char* typeexpr;
@@ -124,6 +140,7 @@ struct scxml_elem_invoke {
const scxml_elem_param* params;
const exec_content_finalize_t* finalize;
const char* content;
+ const char* contentexpr;
void* user_data;
};
@@ -140,6 +157,7 @@ struct scxml_elem_send {
const char* delayexpr;
const char* namelist;
const char* content;
+ const char* contentexpr;
const scxml_elem_param* params;
void* user_data;
};
@@ -147,10 +165,10 @@ struct scxml_elem_send {
struct scxml_ctx {
uint8_t flags;
- char config[1];
- char history[1];
- char pending_invokes[1];
- char initialized_data[1];
+ char config[2];
+ char history[2];
+ char pending_invokes[2];
+ char initialized_data[2];
void* user_data;
@@ -173,75 +191,162 @@ struct scxml_ctx {
invoke_t invoke;
};
-scxml_elem_data scxml_elem_datas[4] = {
- { "Var1", NULL, NULL, NULL },
- { NULL, NULL, NULL, NULL },
- { "Var2", NULL, "1", NULL },
+static scxml_elem_data scxml_elem_datas[2] = {
+ { "Var1", NULL, "0", NULL },
{ NULL, NULL, NULL, NULL }
};
-int s1_on_entry_0(const scxml_ctx* ctx, const scxml_state* state, const void* event) {
+static scxml_elem_send scxml_elem_sends[1] = {
+ { "timeout", NULL, NULL, NULL, NULL, NULL, NULL, NULL, "2s", NULL, NULL, NULL, NULL, NULL, NULL }
+};
+
+static int s0_on_entry_0(const scxml_ctx* ctx, const scxml_state* state, const void* event) {
+ int err = SCXML_ERR_OK;
+ if likely(ctx->exec_content_assign != NULL) {
+ if ((ctx->exec_content_assign(ctx, "Var1", "Var1 + 1")) != SCXML_ERR_OK) return err;
+ } else {
+ return SCXML_ERR_MISSING_CALLBACK;
+ }
+ return SCXML_ERR_OK;
+}
+
+static int s0_on_entry(const scxml_ctx* ctx, const scxml_state* state, const void* event) {
+ s0_on_entry_0(ctx, state, event);
+ return SCXML_ERR_OK;
+}
+
+static int s011_on_entry_0(const scxml_ctx* ctx, const scxml_state* state, const void* event) {
+ int err = SCXML_ERR_OK;
+ if likely(ctx->exec_content_raise != NULL) {
+ if ((ctx->exec_content_raise(ctx, "entering.s011")) != SCXML_ERR_OK) return err;
+ } else {
+ return SCXML_ERR_MISSING_CALLBACK;
+ }
+ return SCXML_ERR_OK;
+}
+
+static int s011_on_entry(const scxml_ctx* ctx, const scxml_state* state, const void* event) {
+ s011_on_entry_0(ctx, state, event);
+ return SCXML_ERR_OK;
+}
+
+static int s012_on_entry_0(const scxml_ctx* ctx, const scxml_state* state, const void* event) {
+ int err = SCXML_ERR_OK;
+ if likely(ctx->exec_content_raise != NULL) {
+ if ((ctx->exec_content_raise(ctx, "entering.s012")) != SCXML_ERR_OK) return err;
+ } else {
+ return SCXML_ERR_MISSING_CALLBACK;
+ }
+ return SCXML_ERR_OK;
+}
+
+static int s012_on_entry(const scxml_ctx* ctx, const scxml_state* state, const void* event) {
+ s012_on_entry_0(ctx, state, event);
+ return SCXML_ERR_OK;
+}
+
+static int s021_on_entry_0(const scxml_ctx* ctx, const scxml_state* state, const void* event) {
int err = SCXML_ERR_OK;
- if (ctx->exec_content_assign != NULL) {
- if ((ctx->exec_content_assign(ctx, "Var1", "Var2")) != SCXML_ERR_OK) return err;
+ if likely(ctx->exec_content_raise != NULL) {
+ if ((ctx->exec_content_raise(ctx, "entering.s021")) != SCXML_ERR_OK) return err;
} else {
return SCXML_ERR_MISSING_CALLBACK;
}
return SCXML_ERR_OK;
}
-int s1_on_entry(const scxml_ctx* ctx, const scxml_state* state, const void* event) {
- s1_on_entry_0(ctx, state, event);
+static int s021_on_entry(const scxml_ctx* ctx, const scxml_state* state, const void* event) {
+ s021_on_entry_0(ctx, state, event);
return SCXML_ERR_OK;
}
-int pass_on_entry_0(const scxml_ctx* ctx, const scxml_state* state, const void* event) {
+static int s022_on_entry_0(const scxml_ctx* ctx, const scxml_state* state, const void* event) {
int err = SCXML_ERR_OK;
- if (ctx->exec_content_log != NULL) {
- if ((ctx->exec_content_log(ctx, "Outcome", "'pass'")) != SCXML_ERR_OK) return err;
+ if likely(ctx->exec_content_raise != NULL) {
+ if ((ctx->exec_content_raise(ctx, "entering.s022")) != SCXML_ERR_OK) return err;
} else {
return SCXML_ERR_MISSING_CALLBACK;
}
return SCXML_ERR_OK;
}
-int pass_on_entry(const scxml_ctx* ctx, const scxml_state* state, const void* event) {
+static int s022_on_entry(const scxml_ctx* ctx, const scxml_state* state, const void* event) {
+ s022_on_entry_0(ctx, state, event);
+ return SCXML_ERR_OK;
+}
+
+static int pass_on_entry_0(const scxml_ctx* ctx, const scxml_state* state, const void* event) {
+ int err = SCXML_ERR_OK;
+ if likely(ctx->exec_content_log != NULL) {
+ if unlikely((ctx->exec_content_log(ctx, "Outcome", "'pass'")) != SCXML_ERR_OK) return err;
+ } else {
+ return SCXML_ERR_MISSING_CALLBACK;
+ }
+ return SCXML_ERR_OK;
+}
+
+static int pass_on_entry(const scxml_ctx* ctx, const scxml_state* state, const void* event) {
pass_on_entry_0(ctx, state, event);
return SCXML_ERR_OK;
}
-int fail_on_entry_0(const scxml_ctx* ctx, const scxml_state* state, const void* event) {
+static int fail_on_entry_0(const scxml_ctx* ctx, const scxml_state* state, const void* event) {
int err = SCXML_ERR_OK;
- if (ctx->exec_content_log != NULL) {
- if ((ctx->exec_content_log(ctx, "Outcome", "'fail'")) != SCXML_ERR_OK) return err;
+ if likely(ctx->exec_content_log != NULL) {
+ if unlikely((ctx->exec_content_log(ctx, "Outcome", "'fail'")) != SCXML_ERR_OK) return err;
} else {
return SCXML_ERR_MISSING_CALLBACK;
}
return SCXML_ERR_OK;
}
-int fail_on_entry(const scxml_ctx* ctx, const scxml_state* state, const void* event) {
+static int fail_on_entry(const scxml_ctx* ctx, const scxml_state* state, const void* event) {
fail_on_entry_0(ctx, state, event);
return SCXML_ERR_OK;
}
-scxml_state scxml_states[5] = {
- { NULL, NULL, NULL, NULL, { 0x1e /* 01111, 1 2 3 4 */ }, { 0x02 /* 01000, 1 */ }, { 0x00 /* 00000, */ }, (const scxml_elem_data*)&scxml_elem_datas[0], SCXML_STATE_COMPOUND },
- { "s0", NULL, NULL, NULL, { 0x00 /* 00000, */ }, { 0x00 /* 00000, */ }, { 0x01 /* 10000, 0 */ }, NULL, SCXML_STATE_ATOMIC },
- { "s1", s1_on_entry, NULL, NULL, { 0x00 /* 00000, */ }, { 0x00 /* 00000, */ }, { 0x01 /* 10000, 0 */ }, (const scxml_elem_data*)&scxml_elem_datas[1], SCXML_STATE_ATOMIC },
- { "pass", pass_on_entry, NULL, NULL, { 0x00 /* 00000, */ }, { 0x00 /* 00000, */ }, { 0x01 /* 10000, 0 */ }, NULL, SCXML_STATE_FINAL },
- { "fail", fail_on_entry, NULL, NULL, { 0x00 /* 00000, */ }, { 0x00 /* 00000, */ }, { 0x01 /* 10000, 0 */ }, NULL, SCXML_STATE_FINAL }
+static int s0_transition0_on_trans(const scxml_ctx* ctx, const scxml_state* state, const void* event) {
+ int err = SCXML_ERR_OK;
+ if likely(ctx->exec_content_send != NULL) {
+ if ((ctx->exec_content_send(ctx, &scxml_elem_sends[0])) != SCXML_ERR_OK) return err;
+ } else {
+ return SCXML_ERR_MISSING_CALLBACK;
+ }
+ return SCXML_ERR_OK;
+}
+
+static scxml_state scxml_states[14] = {
+ { NULL, 0, NULL, NULL, NULL, { 0x02, 0x3c /* 01000000001111, 1 10 11 12 13 */ }, { 0x40, 0x00 /* 00000010000000, 6 */ }, { 0x00, 0x00 /* 00000000000000, */ }, (const scxml_elem_data*)&scxml_elem_datas[0], SCXML_STATE_COMPOUND },
+ { "s0", 0, s0_on_entry, NULL, NULL, { 0x9c, 0x00 /* 00111001000000, 2 3 4 7 */ }, { 0x10, 0x00 /* 00001000000000, 4 */ }, { 0x01, 0x00 /* 10000000000000, 0 */ }, NULL, SCXML_STATE_COMPOUND },
+ { "s0HistShallow", 1, NULL, NULL, NULL, { 0x00, 0x00 /* 00000000000000, */ }, { 0x90, 0x00 /* 00001001000000, 4 7 */ }, { 0x03, 0x00 /* 11000000000000, 0 1 */ }, NULL, SCXML_STATE_HISTORY_SHALLOW },
+ { "s0HistDeep", 1, NULL, NULL, NULL, { 0x00, 0x00 /* 00000000000000, */ }, { 0xf0, 0x03 /* 00001111110000, 4 5 6 7 8 9 */ }, { 0x03, 0x00 /* 11000000000000, 0 1 */ }, NULL, SCXML_STATE_HISTORY_DEEP },
+ { "s01", 1, NULL, NULL, NULL, { 0x60, 0x00 /* 00000110000000, 5 6 */ }, { 0x20, 0x00 /* 00000100000000, 5 */ }, { 0x03, 0x00 /* 11000000000000, 0 1 */ }, NULL, SCXML_STATE_COMPOUND },
+ { "s011", 4, s011_on_entry, NULL, NULL, { 0x00, 0x00 /* 00000000000000, */ }, { 0x00, 0x00 /* 00000000000000, */ }, { 0x13, 0x00 /* 11001000000000, 0 1 4 */ }, NULL, SCXML_STATE_ATOMIC },
+ { "s012", 4, s012_on_entry, NULL, NULL, { 0x00, 0x00 /* 00000000000000, */ }, { 0x00, 0x00 /* 00000000000000, */ }, { 0x13, 0x00 /* 11001000000000, 0 1 4 */ }, NULL, SCXML_STATE_ATOMIC },
+ { "s02", 1, NULL, NULL, NULL, { 0x00, 0x03 /* 00000000110000, 8 9 */ }, { 0x00, 0x01 /* 00000000100000, 8 */ }, { 0x03, 0x00 /* 11000000000000, 0 1 */ }, NULL, SCXML_STATE_COMPOUND },
+ { "s021", 7, s021_on_entry, NULL, NULL, { 0x00, 0x00 /* 00000000000000, */ }, { 0x00, 0x00 /* 00000000000000, */ }, { 0x83, 0x00 /* 11000001000000, 0 1 7 */ }, NULL, SCXML_STATE_ATOMIC },
+ { "s022", 7, s022_on_entry, NULL, NULL, { 0x00, 0x00 /* 00000000000000, */ }, { 0x00, 0x00 /* 00000000000000, */ }, { 0x83, 0x00 /* 11000001000000, 0 1 7 */ }, NULL, SCXML_STATE_ATOMIC },
+ { "s1", 0, NULL, NULL, NULL, { 0x00, 0x00 /* 00000000000000, */ }, { 0x00, 0x00 /* 00000000000000, */ }, { 0x01, 0x00 /* 10000000000000, 0 */ }, NULL, SCXML_STATE_ATOMIC },
+ { "s2", 0, NULL, NULL, NULL, { 0x00, 0x00 /* 00000000000000, */ }, { 0x00, 0x00 /* 00000000000000, */ }, { 0x01, 0x00 /* 10000000000000, 0 */ }, NULL, SCXML_STATE_ATOMIC },
+ { "pass", 0, pass_on_entry, NULL, NULL, { 0x00, 0x00 /* 00000000000000, */ }, { 0x00, 0x00 /* 00000000000000, */ }, { 0x01, 0x00 /* 10000000000000, 0 */ }, NULL, SCXML_STATE_FINAL },
+ { "fail", 0, fail_on_entry, NULL, NULL, { 0x00, 0x00 /* 00000000000000, */ }, { 0x00, 0x00 /* 00000000000000, */ }, { 0x01, 0x00 /* 10000000000000, 0 */ }, NULL, SCXML_STATE_FINAL }
};
-scxml_transition scxml_transitions[4] = {
- { 1, { 0x04 /* 00100 */ }, NULL, "typeof Var2 === 'undefined' ", NULL, SCXML_TRANS_SPONTANEOUS, { 0x0f /* 1111 */ }, { 0x1e /* 01111 */ } },
- { 1, { 0x10 /* 00001 */ }, NULL, NULL, NULL, SCXML_TRANS_SPONTANEOUS, { 0x0f /* 1111 */ }, { 0x1e /* 01111 */ } },
- { 2, { 0x08 /* 00010 */ }, NULL, "Var1===Var2", NULL, SCXML_TRANS_SPONTANEOUS, { 0x0f /* 1111 */ }, { 0x1e /* 01111 */ } },
- { 2, { 0x10 /* 00001 */ }, NULL, NULL, NULL, SCXML_TRANS_SPONTANEOUS, { 0x0f /* 1111 */ }, { 0x1e /* 01111 */ } }
+static scxml_transition scxml_transitions[10] = {
+ { 2, { 0x80, 0x00 /* 00000001000000 */ }, NULL, NULL, NULL, SCXML_TRANS_SPONTANEOUS | SCXML_TRANS_HISTORY, { 0xff, 0x03 /* 1111111111 */ }, { 0xfe, 0x3f /* 01111111111111 */ } },
+ { 3, { 0x00, 0x02 /* 00000000010000 */ }, NULL, NULL, NULL, SCXML_TRANS_SPONTANEOUS | SCXML_TRANS_HISTORY, { 0xff, 0x03 /* 1111111111 */ }, { 0xfe, 0x3f /* 01111111111111 */ } },
+ { 1, { 0x00, 0x04 /* 00000000001000 */ }, "entering.s012", "Var1==1", s0_transition0_on_trans, 0, { 0xff, 0x03 /* 1111111111 */ }, { 0xfe, 0x3f /* 01111111111111 */ } },
+ { 1, { 0x00, 0x08 /* 00000000000100 */ }, "entering.s012", "Var1==2", NULL, 0, { 0xff, 0x03 /* 1111111111 */ }, { 0xfe, 0x3f /* 01111111111111 */ } },
+ { 1, { 0x00, 0x20 /* 00000000000001 */ }, "entering", "Var1==2", NULL, 0, { 0xff, 0x03 /* 1111111111 */ }, { 0xfe, 0x3f /* 01111111111111 */ } },
+ { 1, { 0x00, 0x10 /* 00000000000010 */ }, "entering.s011", "Var1==3", NULL, 0, { 0xff, 0x03 /* 1111111111 */ }, { 0xfe, 0x3f /* 01111111111111 */ } },
+ { 1, { 0x00, 0x20 /* 00000000000001 */ }, "entering", "Var1==3", NULL, 0, { 0xff, 0x03 /* 1111111111 */ }, { 0xfe, 0x3f /* 01111111111111 */ } },
+ { 1, { 0x00, 0x20 /* 00000000000001 */ }, "timeout", NULL, NULL, 0, { 0xff, 0x03 /* 1111111111 */ }, { 0xfe, 0x3f /* 01111111111111 */ } },
+ { 10, { 0x08, 0x00 /* 00010000000000 */ }, NULL, NULL, NULL, SCXML_TRANS_SPONTANEOUS, { 0xff, 0x03 /* 1111111111 */ }, { 0xfe, 0x3f /* 01111111111111 */ } },
+ { 11, { 0x04, 0x00 /* 00100000000000 */ }, NULL, NULL, NULL, SCXML_TRANS_SPONTANEOUS, { 0xff, 0x03 /* 1111111111 */ }, { 0xfe, 0x3f /* 01111111111111 */ } }
};
#ifdef SCXML_VERBOSE
-void printStateNames(const char* a) {
+static void printStateNames(const char* a) {
const char* seperator = "";
for (int i = 0; i < SCXML_NUMBER_STATES; i++) {
if (IS_SET(i, a)) {
@@ -252,7 +357,7 @@ void printStateNames(const char* a) {
printf("\n");
}
-void printBitsetIndices(const char* a, size_t length) {
+static void printBitsetIndices(const char* a, size_t length) {
const char* seperator = "";
for (int i = 0; i < length; i++) {
if (IS_SET(i, a)) {
@@ -264,43 +369,50 @@ void printBitsetIndices(const char* a, size_t length) {
}
#endif
-void bit_or(char* dest, const char* mask, size_t length) {
- for (int i = 0; i < length; ++i) {
- dest[i] |= mask[i];
- }
+static void bit_or(char* dest, const char* mask, size_t i) {
+ do {
+ dest[i - 1] |= mask[i - 1];
+ } while(--i);
}
-void bit_copy(char* dest, const char* source, size_t length) {
- for (int i = 0; i < length; ++i) {
- dest[i] = source[i];
- }
+static void bit_copy(char* dest, const char* source, size_t i) {
+ do {
+ dest[i - 1] = source[i - 1];
+ } while(--i);
}
-int bit_has_and(const char* a, const char* b, size_t length) {
- for (int i = 0; i < length; ++i) {
- if (a[i] & b[i])
+static int bit_has_and(const char* a, const char* b, size_t i) {
+ do {
+ if (a[i - 1] & b[i - 1])
return true;
- }
+ } while(--i);
return false;
}
-void bit_and_not(char* dest, const char* mask, size_t length) {
- for (int i = 0; i < length; ++i) {
- dest[i] &= ~mask[i];
- }
+static void bit_and_not(char* dest, const char* mask, size_t i) {
+ do {
+ dest[i - 1] &= ~mask[i - 1];
+ } while(--i);
+}
+
+static void bit_and(char* dest, const char* mask, size_t i) {
+ do {
+ dest[i - 1] &= mask[i - 1];
+ } while(--i);
}
-int bit_any_set(const char* a, size_t length) {
- for (int i = 0; i < length; ++i) {
- if (a[i] > 0)
+static int bit_any_set(const char* a, size_t i) {
+ do {
+ if (a[i - 1] > 0)
return true;
- }
+ } while(--i);
return false;
}
-int scxml_step(scxml_ctx* ctx) {
+static int scxml_step(scxml_ctx* ctx) {
#ifdef SCXML_VERBOSE
+ printf("Config: ");
printStateNames(ctx->config);
#endif
@@ -311,15 +423,15 @@ MACRO_STEP:
return SCXML_ERR_DONE;
int err = SCXML_ERR_OK;
- char conflicts[1] = {0};
- char target_set[1] = {0};
- char exit_set[1] = {0};
- char trans_set[1] = {0};
- char entry_set[1] = {0};
+ char conflicts[2] = {0, 0};
+ char target_set[2] = {0, 0};
+ char exit_set[2] = {0, 0};
+ char trans_set[2] = {0, 0};
+ char entry_set[2] = {0, 0};
void* event;
- if (ctx->flags == SCXML_CTX_PRISTINE) {
- bit_or(target_set, scxml_states[0].completion, 1);
+ if unlikely(ctx->flags == SCXML_CTX_PRISTINE) {
+ bit_or(target_set, scxml_states[0].completion, 2);
ctx->flags |= SCXML_CTX_SPONTANEOUS | SCXML_CTX_INITIALIZED;
goto COMPLETE_CONFIG;
}
@@ -337,6 +449,10 @@ MACRO_STEP:
SELECT_TRANSITIONS:
for (int i = 0; i < SCXML_NUMBER_TRANSITIONS; i++) {
+ // never select history or initial transitions automatically
+ if unlikely(scxml_transitions[i].type & (SCXML_TRANS_HISTORY | SCXML_TRANS_HISTORY))
+ continue;
+
// is the transition active?
if (IS_SET(scxml_transitions[i].source, ctx->config)) {
// is it non-conflicting?
@@ -347,46 +463,69 @@ SELECT_TRANSITIONS:
ctx->flags |= SCXML_CTX_TRANSITION_FOUND;
// transitions that are pre-empted
- bit_or(conflicts, scxml_transitions[i].conflicts, 1);
+ bit_or(conflicts, scxml_transitions[i].conflicts, 2);
// states that are directly targeted (resolve as entry-set later)
- bit_or(target_set, scxml_transitions[i].target, 1);
+ bit_or(target_set, scxml_transitions[i].target, 2);
// states that will be left
- bit_or(exit_set, scxml_transitions[i].exit_set, 1);
+ bit_or(exit_set, scxml_transitions[i].exit_set, 2);
SET_BIT(i, trans_set);
}
}
}
}
+ bit_and(exit_set, ctx->config, 2);
if (ctx->flags & SCXML_CTX_TRANSITION_FOUND) {
ctx->flags |= SCXML_CTX_SPONTANEOUS;
} else {
ctx->flags &= ~SCXML_CTX_SPONTANEOUS;
- goto MACRO_STEP;
+ // goto MACRO_STEP;
+ return SCXML_ERR_OK;
}
+#ifdef SCXML_VERBOSE
+ printf("Targets: ");
+ printStateNames(target_set);
+#endif
+
REMEMBER_HISTORY:
- // are my ancestors in the exit set?
for (int i = 0; i < SCXML_NUMBER_STATES; i++) {
- if (IS_SET(i, ctx->config) && bit_has_and(exit_set, scxml_states[i].ancestors, 1)) {
- SET_BIT(i, ctx->history);
+ if unlikely(scxml_states[i].type == SCXML_STATE_HISTORY_SHALLOW || scxml_states[i].type == SCXML_STATE_HISTORY_DEEP) {
+ // a history state whose parent is about to be exited
+ if unlikely(IS_SET(scxml_states[i].source, exit_set)) {
+ char history[2] = {0, 0};
+ bit_copy(history, scxml_states[i].completion, 2);
+
+ // set those states who were enabled
+ bit_and(history, ctx->config, 2);
+
+ // clear current history with completion mask
+ bit_and_not(ctx->history, scxml_states[i].completion, 2);
+
+ // set history
+ bit_or(ctx->history, history, 2);
+ }
}
}
-
#ifdef SCXML_VERBOSE
printf("Exiting: ");
printStateNames(exit_set);
#endif
+#ifdef SCXML_VERBOSE
+ printf("History: ");
+ printStateNames(ctx->history);
+#endif
+
EXIT_STATES:
for (int i = SCXML_NUMBER_STATES - 1; i >= 0; i--) {
if (IS_SET(i, exit_set) && IS_SET(i, ctx->config)) {
// call all on exit handlers
if (scxml_states[i].on_exit != NULL) {
- if((err = scxml_states[i].on_exit(ctx, &scxml_states[i], event)) != SCXML_ERR_OK)
+ if unlikely((err = scxml_states[i].on_exit(ctx, &scxml_states[i], event)) != SCXML_ERR_OK)
return err;
}
CLEARBIT(i, ctx->config);
@@ -395,12 +534,12 @@ EXIT_STATES:
COMPLETE_CONFIG:
// calculate new entry set
- bit_copy(entry_set, target_set, 1);
+ bit_copy(entry_set, target_set, 2);
// iterate for ancestors
for (int i = 0; i < SCXML_NUMBER_STATES; i++) {
if (IS_SET(i, entry_set)) {
- bit_or(entry_set, scxml_states[i].ancestors, 1);
+ bit_or(entry_set, scxml_states[i].ancestors, 2);
}
}
@@ -410,7 +549,27 @@ ADD_DESCENDANTS:
if (IS_SET(i, entry_set)) {
switch (scxml_states[i].type) {
case SCXML_STATE_PARALLEL: {
- bit_or(entry_set, scxml_states[i].completion, 1);
+ bit_or(entry_set, scxml_states[i].completion, 2);
+ break;
+ }
+ case SCXML_STATE_HISTORY_SHALLOW:
+ case SCXML_STATE_HISTORY_DEEP: {
+ char history_targets[2] = {0, 0};
+ if (!bit_has_and(scxml_states[i].completion, ctx->history, 2)) {
+ // nothing set for history, look for a default transition or enter parents completion
+ for (int j = 0; j < SCXML_NUMBER_TRANSITIONS; j++) {
+ if unlikely(scxml_transitions[j].source == i) {
+ bit_or(entry_set, scxml_transitions[j].target, 2);
+ SET_BIT(j, trans_set);
+ break;
+ }
+ }
+ // TODO: enter parents default completion here
+ } else {
+ bit_copy(history_targets, scxml_states[i].completion, 2);
+ bit_and(history_targets, ctx->history, 2);
+ bit_or(entry_set, history_targets, 2);
+ }
break;
}
case SCXML_STATE_INITIAL: {
@@ -418,16 +577,18 @@ ADD_DESCENDANTS:
if (scxml_transitions[j].source == i) {
SET_BIT(j, trans_set);
CLEARBIT(i, entry_set);
- bit_or(entry_set, scxml_transitions[j].target, 1);
+ bit_or(entry_set, scxml_transitions[j].target, 2);
// one target may have been above, reestablish completion
- goto ADD_DESCENDANTS;
+ // goto ADD_DESCENDANTS; // initial will have to be first!
}
}
break;
}
case SCXML_STATE_COMPOUND: { // we need to check whether one child is already in entry_set
- if (!bit_has_and(entry_set, scxml_states[i].children, 1)) {
- bit_or(entry_set, scxml_states[i].completion, 1);
+ if (!bit_has_and(entry_set, scxml_states[i].children, 2) &&
+ !bit_has_and(ctx->config, scxml_states[i].children, 2))
+ {
+ bit_or(entry_set, scxml_states[i].completion, 2);
}
break;
}
@@ -437,15 +598,15 @@ ADD_DESCENDANTS:
#ifdef SCXML_VERBOSE
printf("Transitions: ");
- printBitsetIndices(trans_set, sizeof(char) * 8 * 1);
+ printBitsetIndices(trans_set, sizeof(char) * 8 * 2);
#endif
TAKE_TRANSITIONS:
for (int i = 0; i < SCXML_NUMBER_TRANSITIONS; i++) {
- if (IS_SET(i, trans_set)) {
+ if (IS_SET(i, trans_set) && (scxml_transitions[i].type & SCXML_TRANS_HISTORY) == 0) {
// call executable content in transition
if (scxml_transitions[i].on_transition != NULL) {
- if((err = scxml_transitions[i].on_transition(ctx,
+ if unlikely((err = scxml_transitions[i].on_transition(ctx,
&scxml_states[scxml_transitions[i].source],
event)) != SCXML_ERR_OK)
return err;
@@ -461,39 +622,43 @@ TAKE_TRANSITIONS:
ENTER_STATES:
for (int i = 0; i < SCXML_NUMBER_STATES; i++) {
if (IS_SET(i, entry_set) && !IS_SET(i, ctx->config)) {
+ // these are no proper states
+ if unlikely(scxml_states[i].type == SCXML_STATE_HISTORY_DEEP ||
+ scxml_states[i].type == SCXML_STATE_HISTORY_SHALLOW ||
+ scxml_states[i].type == SCXML_STATE_INITIAL)
+ continue;
+
SET_BIT(i, ctx->config);
- if (scxml_states[i].on_entry != NULL) {
- if((err = scxml_states[i].on_entry(ctx, &scxml_states[i], event)) != SCXML_ERR_OK)
- return err;
- }
// initialize data
- if(!IS_SET(i, ctx->initialized_data)) {
- if (scxml_states[i].data != NULL && ctx->exec_content_init != NULL) {
+ if (!IS_SET(i, ctx->initialized_data)) {
+ if unlikely(scxml_states[i].data != NULL && ctx->exec_content_init != NULL) {
ctx->exec_content_init(ctx, scxml_states[i].data);
}
SET_BIT(i, ctx->initialized_data);
}
+ if (scxml_states[i].on_entry != NULL) {
+ if unlikely((err = scxml_states[i].on_entry(ctx, &scxml_states[i], event)) != SCXML_ERR_OK)
+ return err;
+ }
+
// handle final states
- if (scxml_states[i].type == SCXML_STATE_FINAL) {
- if (scxml_states[i].ancestors[0] == 0x01) {
+ if unlikely(scxml_states[i].type == SCXML_STATE_FINAL) {
+ if unlikely(scxml_states[i].ancestors[0] == 0x01) {
ctx->flags |= SCXML_CTX_TOP_LEVEL_FINAL;
} else {
// raise done event
size_t parent = 0;
- for (int j = 0; j < SCXML_NUMBER_STATES; j++) {
+ for (int j = SCXML_NUMBER_STATES - 1; j >= 0; j--) {
// we could trade runtime for memory here by saving the parent index
- if (!IS_SET(j, scxml_states[i].ancestors)) {
- if (parent != 0) {
- break;
- }
- continue;
- } else {
- parent = j;
+ if unlikely(IS_SET(j, scxml_states[i].ancestors)) {
+ parent = j;
+ break;
}
}
- ctx->raise_done_event(ctx, &scxml_states[parent]);
+ // is this raised for toplevel final as well?
+ ctx->raise_done_event(ctx, &scxml_states[parent], NULL);
}
/**
@@ -504,11 +669,11 @@ ENTER_STATES:
* 4. If a state remains, not all children of a parallel are final
*/
for (int j = 0; j < SCXML_NUMBER_STATES; j++) {
- if (scxml_states[j].type == SCXML_STATE_PARALLEL) {
+ if unlikely(scxml_states[j].type == SCXML_STATE_PARALLEL) {
char parallel_children[2] = {0, 0};
size_t parallel = j;
for (int k = 0; k < SCXML_NUMBER_STATES; k++) {
- if (IS_SET(parallel, scxml_states[k].ancestors) && IS_SET(k, ctx->config)) {
+ if unlikely(IS_SET(parallel, scxml_states[k].ancestors) && IS_SET(k, ctx->config)) {
if (scxml_states[k].type == SCXML_STATE_FINAL) {
bit_and_not(parallel_children, scxml_states[k].ancestors, 2);
} else {
@@ -516,8 +681,8 @@ ENTER_STATES:
}
}
}
- if (!bit_any_set(parallel_children, 2)) {
- ctx->raise_done_event(ctx, &scxml_states[parallel]);
+ if unlikely(!bit_any_set(parallel_children, 2)) {
+ ctx->raise_done_event(ctx, &scxml_states[parallel], NULL);
}
}
}
@@ -527,6 +692,19 @@ ENTER_STATES:
}
}
+HISTORY_TRANSITIONS:
+ for (int i = 0; i < SCXML_NUMBER_TRANSITIONS; i++) {
+ if unlikely(IS_SET(i, trans_set) && (scxml_transitions[i].type & SCXML_TRANS_HISTORY)) {
+ // call executable content in transition
+ if (scxml_transitions[i].on_transition != NULL) {
+ if unlikely((err = scxml_transitions[i].on_transition(ctx,
+ &scxml_states[scxml_transitions[i].source],
+ event)) != SCXML_ERR_OK)
+ return err;
+ }
+ }
+ }
+
return SCXML_ERR_OK;
}
diff --git a/test/src/test-misc.cpp b/test/src/test-misc.cpp
index 09cda31..6259d57 100644
--- a/test/src/test-misc.cpp
+++ b/test/src/test-misc.cpp
@@ -1,3 +1,24 @@
+#include "uscxml/config.h"
+#include "uscxml/Common.h"
+#include "uscxml/concurrency/Timer.h"
+#include "uscxml/concurrency/tinythread.h"
+
+#include <iostream>
+
+using namespace uscxml;
+
+Timer t1;
+
+bool testTimers() {
+ {
+ Measurement m(&t1);
+ tthread::this_thread::sleep_for(tthread::chrono::milliseconds(1000));
+ }
+ std::cout << t1.elapsed << std::endl;
+ return true;
+}
+
int main(int argc, char** argv) {
- return 0;
+ testTimers();
+ return 0;
} \ No newline at end of file
diff --git a/test/src/test-w3c.cpp b/test/src/test-w3c.cpp
index 0069d0d..a44fb57 100644
--- a/test/src/test-w3c.cpp
+++ b/test/src/test-w3c.cpp
@@ -1,4 +1,8 @@
+// I feel dirty, but we need to access the datamodel timer
+#define protected public
+
#include "uscxml/config.h"
+#include "uscxml/Convenience.h"
#include "uscxml/Interpreter.h"
#include "uscxml/DOMUtils.h"
@@ -13,6 +17,10 @@
#include <signal.h>
#endif
+#ifdef BUILD_PROFILING
+# include "uscxml/plugins/DataModel.h"
+# endif
+
#ifdef _WIN32
#include "XGetopt.h"
#include "XGetopt.cpp"
@@ -50,7 +58,7 @@ void printUsageAndExit(const char* progName) {
exit(1);
}
-class W3CStatusMonitor : public uscxml::StateTransitionMonitor {
+class W3CStatusMonitor : public uscxml::InterpreterMonitor {
void beforeCompletion(uscxml::Interpreter tmp) {
if (interpreter.getConfiguration().size() == 1 && interpreter.isInState("pass")) {
@@ -101,7 +109,12 @@ int main(int argc, char** argv) {
break;
}
}
-
+
+ const char* envBenchmarkRuns = getenv("USCXML_BENCHMARK_ITERATIONS");
+ if (envBenchmarkRuns != NULL) {
+ benchmarkRuns = strTo<size_t>(envBenchmarkRuns);
+ }
+
documentURI = argv[optind];
LOG(INFO) << "Processing " << documentURI << (withFlattening ? " FSM converted" : "") << (delayFactor ? "" : " with delays *= " + toStr(delayFactor)) << (benchmarkRuns > 0 ? " for " + toStr(benchmarkRuns) + " benchmarks" : "");
@@ -145,34 +158,50 @@ int main(int argc, char** argv) {
}
if (interpreter) {
+ W3CStatusMonitor* vm = new W3CStatusMonitor();
+ interpreter.addMonitor(vm);
+
if (benchmarkRuns > 0) {
LOG(INFO) << "Benchmarking " << documentURI << (withFlattening ? " FSM converted" : "") << (delayFactor ? "" : " with delays *= " + toStr(delayFactor));
InterpreterState state = interpreter.getState();
-
+
double avg = 0;
- uint64_t now = 0;
+#ifdef BUILD_PROFILING
+ double avgDm = 0;
+ double avgStep = 0;
+#endif
size_t remainingRuns = benchmarkRuns;
uint64_t start = tthread::chrono::system_clock::now();
while(remainingRuns-- > 0) {
- now = tthread::chrono::system_clock::now();
+ Timer t;
+ t.start();
for(;;) {
state = interpreter.step(true);
+ if (state == USCXML_FINISHED) {
+#ifdef BUILD_PROFILING
+ avgDm += interpreter.getDataModel()._impl.get()->timer.elapsed;
+ interpreter.getDataModel()._impl.get()->timer.elapsed = 0;
+ avgStep += interpreter.getImpl()->timer.elapsed;
+#endif
+ }
if (state < 0)
break;
}
- avg += (double)(tthread::chrono::system_clock::now() - now) / (double)benchmarkRuns;
+ t.stop();
+ avg += t.elapsed;
interpreter.reset();
}
uint64_t totalDuration = tthread::chrono::system_clock::now() - start;
std::cout << benchmarkRuns << " iterations in " << totalDuration << " ms" << std::endl;
- std::cout << avg << " ms on average" << std::endl;
-
- } else {
- W3CStatusMonitor* vm = new W3CStatusMonitor();
- interpreter.addMonitor(vm);
+ std::cout << (avg * 1000.0) / (double)benchmarkRuns << " ms on average" << std::endl;
+#ifdef BUILD_PROFILING
+ std::cout << (avgDm * 1000.0) / (double)benchmarkRuns << " ms in datamodel" << std::endl;
+ std::cout << (avgStep * 1000.0) / (double)benchmarkRuns << " ms in microsteps" << std::endl;
+#endif
+ } else {
interpreter.start();
while(interpreter.runOnMainThread(25));
}
diff --git a/test/w3c/run_generated_c_test.cmake b/test/w3c/run_generated_c_test.cmake
index 7ae7b4d..2c35762 100644
--- a/test/w3c/run_generated_c_test.cmake
+++ b/test/w3c/run_generated_c_test.cmake
@@ -10,8 +10,11 @@ if(CMD_RESULT)
endif()
message(STATUS "time for transforming to c machine")
+# message(FATAL_ERROR "PROJECT_BINARY_DIR: ${PROJECT_BINARY_DIR}")
+
set(COMPILE_CMD
"-o" "${OUTDIR}/${TEST_FILE_NAME}"
+"-Ofast"
"-L${CMAKE_LIBRARY_OUTPUT_DIRECTORY}"
"-luscxml64"
"-include" "${OUTDIR}/${TEST_FILE_NAME}.machine.c"
@@ -19,6 +22,7 @@ set(COMPILE_CMD
"-I${PROJECT_SOURCE_DIR}/contrib/prebuilt/${USCXML_PLATFORM_ID}/include/arabica"
"-I${PROJECT_SOURCE_DIR}/contrib/prebuilt/include"
"-I${CMAKE_BINARY_DIR}"
+"-I${PROJECT_BINARY_DIR}"
"-I${PROJECT_SOURCE_DIR}/src"
"-Wl,-rpath,${CMAKE_LIBRARY_OUTPUT_DIRECTORY}"
"-DAUTOINCLUDE_TEST=ON"