Fixed signal handleing

README.md

@@ -16,12 +16,14 @@ Cross Platform device manager for driving and flight simulators, for use with co
 - Includes utility to configure revburner tachometer
 - Can send data to any serial device. So far only tested with arduino. Includes sample arduino sketch for sim lights.
 - The support for haptic bass shakers is limited and needs the most work. So far the engine rev is a simple sine wave, which I find convincing. The gear shift event works but not convincing enough for me.
+- Choice of Portaudio or Pulseaudio backend.
 
 ## Dependencies
 - libserialport - arduino serial devices
 - hidapi - usb hid devices
 - libusb - used by hidapi
 - portaudio - sound devices (haptic bass shakers)
+- pulseaudio - sound devices (haptic bass shakers)
 - libenet - UDP support (not yet implemented)
 - libxml2
 - argtable2
@@ -44,6 +46,11 @@ cmake ..
 make
 ```
 
+to use the pulseaudio backend use this cmake command
+```
+cmake -DUSE_PULSEAUDIO=YES ..
+```
+
 ## Testing
 
 ### Setting up Your Arduino Device

conf/monocoque.config

@@ -5,12 +5,19 @@ devices = ( {   device      = "USB";
                 subtype     = "Revburner";
                 granularity = 4;
                 config      = "/home/paul/.config/monocoque/revburner1.xml"; },
-            {   device      = "Sound";
-                type        = "Engine"
-                devid       = "98FD:83AC"; },
-            {   device      = "Sound";
-                type        = "Gear"
-                devid       = "98FD:83AC"; },
+            {   device       = "Sound";
+                type         = "Engine";
+                devid        = "alsa_output.usb-Generic_USB2.0_Device_20170726905959-00.analog-stereo";
+                pan          = 1;
+                volume       = 90;
+                frequency    = 27; },
+            {   device       = "Sound";
+                type         = "Gear"
+                devid        = "alsa_output.usb-Generic_USB2.0_Device_20170726905959-00.analog-stereo";
+                pan          = 1;
+                duration     = .25;
+                volume       = 100;
+                frequency    = 27; },
             {   device      = "Serial";
                 type        = "ShiftLights";
                 config      = "None";

src/arduino/shiftlights/shiftlights.ino

@@ -7,6 +7,16 @@
 #define NUM_LEDS    6
 #define BRIGHTNESS  40
 
+#define COLOR1A 0
+#define COLOR1B 0
+#define COLOR1C 255
+#define COLOR2A 0
+#define COLOR2B 255
+#define COLOR2C 0
+#define COLOR3A 255
+#define COLOR3B 0
+#define COLOR3C 0
+
 CRGB leds[NUM_LEDS];
 SimData sd;
 int maxrpm = 0;
@@ -75,15 +85,15 @@ void loop()
 
         if (l >= numlights / 2)
         {
-            leds[l] = CRGB ( 0, 0, 255);
+            leds[l] = CRGB ( COLOR1A, COLOR1B, COLOR1C);
         }
         if (l < numlights / 2)
         {
-            leds[l] = CRGB ( 0, 255, 0);
+            leds[l] = CRGB ( COLOR2A, COLOR2B, COLOR2C);
         }
         if (l == numlights - 1)
         {
-            leds[l] = CRGB ( 255, 0, 0);
+            leds[l] = CRGB ( COLOR3A, COLOR3B, COLOR3C);
         }
         if (lights[l] <= 0)
         {

src/arduino/simwind/simwind.ino

@@ -3,7 +3,7 @@
 
 #define BYTE_SIZE sizeof(SimData)
 #define KPHTOMPH .621317
-
+#define FANPOWER .6
 
 Adafruit_MotorShield AFMS = Adafruit_MotorShield();
 
@@ -46,6 +46,6 @@ void loop() {
     {
       v = 255;
     }
-    myMotor1->setSpeed(v);
-    myMotor2->setSpeed(v);
+    myMotor1->setSpeed(v*FANPOWER);
+    myMotor2->setSpeed(v*FANPOWER);
 }

src/monocoque/devices/sound/usb_generic_shaker_pulse.c

@@ -123,7 +123,7 @@ int usb_generic_shaker_init(SoundDevice* sounddevice, pa_threaded_mainloop* main
 
     // recommended settings, i.e. server uses sensible values
     pa_buffer_attr buffer_attr;
-    buffer_attr.maxlength = (uint32_t) -1;
+    buffer_attr.maxlength = (uint32_t) 32767;
     buffer_attr.tlength = (uint32_t) -1;
     buffer_attr.prebuf = (uint32_t) -1;
     buffer_attr.minreq = (uint32_t) -1;
@@ -131,22 +131,17 @@ int usb_generic_shaker_init(SoundDevice* sounddevice, pa_threaded_mainloop* main
     pa_cvolume cv;
     uint16_t pvolume =  ceil(((double) volume/100.0d)*65535);
     // Settings copied as per the chromium browser source
-    pa_stream_flags_t stream_flags;
-    stream_flags = PA_STREAM_INTERPOLATE_TIMING |
-       PA_STREAM_NOT_MONOTONIC | PA_STREAM_AUTO_TIMING_UPDATE |
-       PA_STREAM_ADJUST_LATENCY;
 
-    //stream_flags = PA_STREAM_START_CORKED;
+    pa_stream_flags_t stream_flags;
+    stream_flags = PA_STREAM_INTERPOLATE_TIMING | PA_STREAM_NOT_MONOTONIC | PA_STREAM_AUTO_TIMING_UPDATE | PA_STREAM_ADJUST_LATENCY | PA_STREAM_START_CORKED;
+
     // Connect stream to the default audio output sink
     pa_cvolume_set(&cv, sample_specifications.channels, pvolume);
-    //pa_cvolume_set(&cv, 1, 0);
 
     pa_cvolume_set_balance(&cv, &channel_map, pan);
 
     assert(pa_stream_connect_playback(stream, devname, &buffer_attr, stream_flags, &cv, NULL) == 0);
 
-
-
     // Wait for the stream to be ready
     for(;;) {
         pa_stream_state_t stream_state = pa_stream_get_state(stream);

src/monocoque/gameloop/gameloop.c

@@ -6,6 +6,7 @@
 #include <sys/stat.h>
 #include <poll.h>
 #include <termios.h>
+#include <signal.h>
 
 #include "gameloop.h"
 #include "../helper/parameters.h"
@@ -17,6 +18,19 @@
 
 #define DEFAULT_UPDATE_RATE      240.0
 #define SIM_CHECK_RATE           1.0
+bool go = false;
+bool go2 = false;
+struct sigaction act;
+
+void sighandler(int signum, siginfo_t* info, void* ptr)
+{
+    sloge("caught signal");
+    go = false;
+    go2 = false;
+    //gfx_clear(pixels, pixels_len);
+    //gfx_swapbuffers();
+    //gfx_close();
+}
 
 int showstats(SimData* simdata)
 {
@@ -170,27 +184,13 @@ int showstats(SimData* simdata)
 
 int clilooper(SimDevice* devices, int numdevices, Parameters* p, SimData* simdata, SimMap* simmap)
 {
-
-    slogi("preparing game loop with %i devices...", numdevices);
-
-
-    slogi("sending initial data to devices");
-    simdata->velocity = 16;
-    simdata->rpms = 100;
-    for (int x = 0; x < numdevices; x++)
-    {
-        devices[x].update(&devices[x], simdata);
-    }
-    sleep(3);
-
-
     struct pollfd mypoll = { STDIN_FILENO, POLLIN|POLLPRI };
     double update_rate = DEFAULT_UPDATE_RATE;
     char ch;
     int t=0;
     int s=0;
-    bool go = true;
-    while (go == true && simdata->simstatus > 1)
+    go2 = true;
+    while (go2 == true && simdata->simstatus > 1)
     {
         simdatamap(simdata, simmap, p->sim);
         showstats(simdata);
@@ -203,15 +203,14 @@ int clilooper(SimDevice* devices, int numdevices, Parameters* p, SimData* simdat
         for (int x = 0; x < numdevices; x++)
         {
             devices[x].update(&devices[x], simdata);
-
         }
 
-    	if( poll(&mypoll, 1, 1000.0/DEFAULT_UPDATE_RATE) )
+    	if( poll(&mypoll, 1, 1000.0/update_rate) )
     	{
     	    scanf("%c", &ch);
     	    if(ch == 'q')
     	    {
-    	        go = false;
+    	        go2 = false;
     	    }
     	}
     }
@@ -230,6 +229,12 @@ int clilooper(SimDevice* devices, int numdevices, Parameters* p, SimData* simdat
 
 int looper(SimDevice* devices, int numdevices, Parameters* p)
 {
+    memset(&act, 0, sizeof(act));
+    act.sa_sigaction = sighandler;
+    act.sa_flags = SA_SIGINFO;
+    sigaction(SIGTERM, &act, NULL);
+    sigaction(SIGINT, &act, NULL);
+    sigaction(SIGTSTP, &act, NULL);
 
     SimData* simdata = malloc(sizeof(SimData));
     SimMap* simmap = malloc(sizeof(SimMap));
@@ -245,23 +250,28 @@ int looper(SimDevice* devices, int numdevices, Parameters* p)
     struct pollfd mypoll = { STDIN_FILENO, POLLIN|POLLPRI };
 
     fprintf(stdout, "Searching for sim data... Press q to quit...\n");
-
     p->simon = false;
     double update_rate = SIM_CHECK_RATE;
-    int go = true;
+    go = true;
     while (go == true)
     {
+        p->simon = false;
+        getSim(simdata, simmap, &p->simon, &p->sim);
 
-
-
-
-        if (p->simon == false)
+        if (p->simon == true && simdata->simstatus > 1)
         {
-            getSim(simdata, simmap, &p->simon, &p->sim);
-        }
+            slogi("preparing game loop with %i devices...", numdevices);
+
+
+            slogi("sending initial data to devices");
+            simdata->velocity = 16;
+            simdata->rpms = 100;
+            for (int x = 0; x < numdevices; x++)
+            {
+                devices[x].update(&devices[x], simdata);
+            }
+            sleep(3);
 
-        if (p->simon == true)
-        {
             clilooper(devices, numdevices, p, simdata, simmap);
         }
         if (p->simon == true)
@@ -271,12 +281,15 @@ int looper(SimDevice* devices, int numdevices, Parameters* p)
             sleep(2);
         }
 
-        if( poll(&mypoll, 1, 1000.0/update_rate) )
+        if (poll(&mypoll, 1, 1000.0/update_rate) )
         {
-            scanf("%c", &ch);
-            if(ch == 'q')
+            if (go != false )
             {
-                go = false;
+                scanf("%c", &ch);
+                if(ch == 'q')
+                {
+                    go = false;
+                }
             }
         }
     }