lslder_uni.cc

// lslder.cc -- GW/20200110
//
// LSL Digital Event Recorder
//
// This program offers a maximum of eight LSL event streams, each triggered by positive edges on
// raspberry pi GPIO digital inputs. Visual feedback is provided bij eight LEDs.
// The stream type is "Digital Events - $HOSTNAME", where HOSTNAME is the ip hostname of
// the raspberry. This is to uniquely identify devices on the network.
// The data sent with the events is an int8 with value 1, with 1 indicating a rising edge.
// Falling edges can be sent with a 0 value. However this is not implemented in this
// program.
//
// Dependencies: labstreaminglayer C++ and wiringPi

// CHANGES
// GW/20180716 initial version for 8-channel LSL Digital Event Recorder

#include <lsl_cpp.h>
#include <stdlib.h>
#include <unistd.h>
#include <iostream>
#include <mutex>
#include <thread>         // std::this_thread::sleep_for
#include <chrono>         // std::chrono::seconds
#include <wiringPi.h>
#include "led.h"

#define DEBUG

using namespace lsl;

#ifdef LSLDER_1CHAN

// 1 channel portable version without LEDs
const int ngpio = 1;
const int gpioinp[ngpio] = { 8 };

const int default_debouncetime = 100;

const int *ledgpio = 0;
const int nled = 0;

#endif

#ifdef LSLDER_4CHAN

// 4-chan version with 4 LEDs
const int ngpio = 4;
const int gpioinp[ngpio] = { 24, 23, 18, 15 };

const int default_debouncetime = 0;

const int ledgpio[] = { 5, 14, 3, 2 };
const int nled = 4;

#endif

#ifdef LSLDER_8CHAN

// 8-chan version with 8 LEDs
const int ngpio = 8;
const int gpioinp[ngpio] = { 12, 7, 8, 25, 24, 23, 18, 15 };

const int default_debouncetime = 0;

const int ledgpio[] = { 21, 20, 16, 13, 5, 14, 3, 2 };
const int nled = 8;

#endif

int ledtime=2; // in 1/100 sec., see infinite loop in main()
volatile int ledtimer[ngpio] = { 0, };
int ledstatus[ngpio] = { 0, };

int debouncetimes[ngpio] = { 0, };
volatile int debouncetimer[ngpio] = { 0, };

#ifdef DEBUG
volatile int interrupt_count[ngpio] = { 0, };
#endif

stream_outlet *outlet[ngpio];
std::mutex lsl_mutex;
typedef char int8;

void gpioInterrupt(int channel)
{
    if (debouncetimer[channel])
       return;
    else
       debouncetimer[channel] = debouncetimes[channel];

#ifdef DEBUG
    std::cout 
       << "Interrupt on channel " << channel 
       << " (GPIO " << gpioinp[channel] << ")"
       << std::endl;
#endif

    static int edge=1;
    std::lock_guard<std::mutex> guard(lsl_mutex);
    outlet[channel]->push_sample(&edge);
    ledtimer[channel]=ledtime;

#ifdef DEBUG
    interrupt_count[channel]++;
    std::cout << channel << " (count=" << interrupt_count[channel] << ")" << std::endl;
#endif
}

void handleLeds()
{
    for (int i=0; (i<ngpio) && (i<nled); i++)
    {
       if (ledtimer[i] > 0) {
          if (!ledstatus[i]) {
             setled(i,1);
             ledstatus[i]=1;
          }
          ledtimer[i]--;
       }
       else {
          if (ledstatus[i]) {
             setled(i,0);
             ledstatus[i]=0;
          }
       }
   }
}


void gpioISR_0()
{
    gpioInterrupt(0);
}

void gpioISR_1()
{
    gpioInterrupt(1);
}

void gpioISR_2()
{
    gpioInterrupt(2);
}

void gpioISR_3()
{
    gpioInterrupt(3);
}

void gpioISR_4()
{
    gpioInterrupt(4); 
}

void gpioISR_5()
{
    gpioInterrupt(5);
}

void gpioISR_6()
{
    gpioInterrupt(6);
}

void gpioISR_7()
{
    gpioInterrupt(7);
}

typedef void(*gpioISR)();

gpioISR ISR[] = { gpioISR_0, gpioISR_1, gpioISR_2, gpioISR_3, 
                   gpioISR_4, gpioISR_5, gpioISR_6, gpioISR_7 };

int main(int argc, char* argv[]) {
        piHiPri(99);  // shortcut for running at real time priority
        
        // configure inputs 
        wiringPiSetupGpio();

        initleds(nled, ledgpio);

        for (int i=0; i<ngpio; i++)
        {
           pinMode(gpioinp[i], INPUT);
           pullUpDnControl(gpioinp[i], PUD_UP);
        }

        for (int i=0; i<ngpio; i++) {
           debouncetimes[i] = default_debouncetime;
        }

        char hostname[255];
        gethostname(hostname,255);
        for (int i=0; i<ngpio; i++)
        {
           // make a new stream_info and open an outlet with it
           char info_name[255];
           sprintf(info_name, "Digital Events %d", i);

           char info_type[255+18];
           sprintf(info_type,"Digital Events @ %s",hostname);

           stream_info info(info_name, info_type, 1, lsl::IRREGULAR_RATE,
              lsl::cf_int8,"Raspberry Pi Digital Event Recorder");
           outlet[i] = new stream_outlet(info);
        }

        // The 4N35 optocoupler in the input circuit inverts the signal, we want to
        // detect rising edges in the input signal, so here we program INT_EDGE_FALLING.
        for (int i=0; i<ngpio; i++)
        {
           wiringPiISR(gpioinp[i], INT_EDGE_FALLING, ISR[i]);
        }

        // do this forever
        while(true) {
           std::this_thread::sleep_for(std::chrono::milliseconds(10));
           handleLeds();

           for (int i=0; i<ngpio; i++) {
              if (debouncetimer[i] > 0)
                 debouncetimer[i]--;
           }
        }
        return 0;
}