Add additional tests/profiling

.travis.yml

@@ -1,3 +1,17 @@
 script:
     - cd events-c
+
+      # Strict compilation of library
+    - CFLAGS='-pedantic -Werror' make
+
+      # Runtime tests
     - make test
+
+      # Relative profiling with current master
+    - if ( git clone https://github.com/armmbed/mbed-events tests/master &&
+           make -s -C tests/master/$(basename $(pwd)) prof | tee tests/results.txt ) ;
+      then
+        cat tests/results.txt | make prof ; 
+      else
+        make prof ;
+      fi

events-c/.travis.yml

@@ -1,2 +1,15 @@
 script:
+      # Strict compilation of library
+    - CFLAGS='-pedantic -Werror' make
+
+      # Runtime tests
     - make test
+
+      # Relative profiling with current master
+    - if ( git clone https://github.com/geky/events tests/master &&
+           make -s -C tests/master prof | tee tests/results.txt ) ;
+      then
+        cat tests/results.txt | make prof ; 
+      else
+        make prof ;
+      fi

events-c/Makefile

@@ -9,14 +9,8 @@ OBJ := $(SRC:.c=.o)
 DEP := $(SRC:.c=.d)
 ASM := $(SRC:.c=.s)
 
-TESTS = tests/tests
-TSRC += $(wildcard tests/*.c)
-TOBJ := $(TSRC:.c=.o)
-TDEP := $(TSRC:.c=.d)
-
 ifdef DEBUG
-CFLAGS += -O0 -g3 -DMU_DEBUG
-CFLAGS += -fkeep-inline-functions
+CFLAGS += -O0 -g3
 else
 CFLAGS += -O2
 endif
@@ -25,17 +19,21 @@ CFLAGS += -m$(WORD)
 endif
 CFLAGS += -I.
 CFLAGS += -std=c99
-CFLAGS += -Wall -Winline
+CFLAGS += -Wall
 CFLAGS += -D_XOPEN_SOURCE=500
 
 LFLAGS += -lpthread
 
 
 all: $(TARGET)
 
-test: $(TOBJ) $(OBJ)
-	$(CC) $(CFLAGS) $^ $(LFLAGS) -o $(TESTS)
-	$(TESTS)
+test: tests/tests.o $(OBJ)
+	$(CC) $(CFLAGS) $^ $(LFLAGS) -o tests/tests
+	tests/tests
+
+prof: tests/prof.o $(OBJ)
+	$(CC) $(CFLAGS) $^ $(LFLAGS) -o tests/prof
+	tests/prof
 
 asm: $(ASM)
 
@@ -55,8 +53,8 @@ size: $(OBJ)
 
 clean:
 	rm -f $(TARGET)
-	rm -f $(TESTS)
-	rm -f $(TOBJ) $(TDEP)
+	rm -f tests/tests tests/tests.o tests/tests.d
+	rm -f tests/prof tests/prof.o tests/prof.d
 	rm -f $(OBJ)
 	rm -f $(DEP)
 	rm -f $(ASM)

events-c/README.md

@@ -37,13 +37,32 @@ supports multithreaded environments. More information on the idea
 behind composable event loops 
 [here](https://gist.github.com/geky/4969d940f1bd5596bdc10e79093e2553).
 
-## Porting ##
+## Tests ##
+
+The events library uses a set of local tests based on the posix implementation.
+
+Runtime tests are located in [tests.c](tests/tests.c):
+
+``` bash
+make test
+```
+
+Profiling tests based on rdtsc are located in [prof.c](tests/prof.c):
 
-The events library only requires the following:
-- monotonic counter
-- non-recursive mutex
-- binary semaphore
+``` bash
+make prof
+```
+
+To make profiling results more tangible, the profiler also supports percentage
+comparison with previous runs:
+``` bash
+make prof | tee results.txt
+cat results.txt | make prof
+```
+
+## Porting ##
 
-Supported implementations are hosted as branches on this repo:
-- Posix
-- mbed
+The events library requires a small porting layer:
+- [events_tick](events_tick.h) - monotonic counter
+- [events_mutex](events_mutex.h) - non-recursive mutex
+- [events_sema](events_sema.h) - binary semaphore

events-c/events.c

@@ -157,8 +157,8 @@ static inline int equeue_tickdiff(unsigned a, unsigned b) {
     return (int)(a - b);
 }
 
-static int equeue_enqueue(equeue_t *q, struct event *e, int ms) {
-    e->target = events_tick() + (unsigned)ms;
+static void equeue_enqueue(equeue_t *q, struct event *e, unsigned ms) {
+    e->target = events_tick() + ms;
 
     struct event **p = &q->queue;
     while (*p && equeue_tickdiff((*p)->target, e->target) <= 0) {
@@ -167,8 +167,6 @@ static int equeue_enqueue(equeue_t *q, struct event *e, int ms) {
 
     e->next = *p;
     *p = e;
-
-    return e->id;
 }
 
 static struct event *equeue_dequeue(equeue_t *q, int id) {
@@ -184,9 +182,16 @@ static struct event *equeue_dequeue(equeue_t *q, int id) {
 }
 
 static int equeue_post(equeue_t *q, struct event *e, int ms) {
+    int id = e->id;
+    if (ms < 0) {
+        event_dealloc(q, e+1);
+        return id;
+    }
+
     events_mutex_lock(&q->queuelock);
-    int id = equeue_enqueue(q, e, ms);
+    equeue_enqueue(q, e, ms);
     events_mutex_unlock(&q->queuelock);
+
     events_sema_release(&q->eventsema);
     return id;
 }