nrntimeout.cpp

Go to the documentation of this file.

#include <../../nrnconf.h>
#include <nrnmpi.h>


#if NRNMPI
void (*nrntimeout_call)();

#if defined(HAVE_SETITIMER) && defined(HAVE_SIGACTION)

#include <stdio.h>
#include <signal.h>
#include <sys/time.h>
#include <section.h>

static double told;
static struct itimerval value;
static struct sigaction act, oact;

#define NRNTIMEOUT_DEBUG 0
#if NRNTIMEOUT_DEBUG
extern double nrn_time();
static old_nrn_time;
#endif

static void timed_out(int sig) {
#if NRNTIMEOUT_DEBUG
double z = nrn_time();
printf("timed_out(%d) wall_elapse=%g told=%g t=%g\n", sig, z-old_nrn_time, told, nrn_threads->_t);
old_nrn_time = z;
#endif
    if (nrn_threads->_t == told) { /* nothing has been accomplished since last signal*/
        printf("nrn_timeout t=%g\n", nrn_threads->_t);
        if (nrntimeout_call) {
            (*nrntimeout_call)();
        }
        nrnmpi_abort(0);
    }
    told = nrn_threads->_t;
}

void nrn_timeout(int seconds) {
    if (nrnmpi_myid != 0) { return; }
#if NRNTIMEOUT_DEBUG
    printf("nrn_timeout(%d) t=%g\n", seconds, nrn_threads->_t);
    old_nrn_time = nrn_time();
#endif
    if (seconds) {
        told = nrn_threads->_t;
        act.sa_handler = timed_out;
        act.sa_flags = SA_RESTART;
        if(sigaction(SIGALRM, &act, &oact)) {
            printf("sigaction failed\n");
            nrnmpi_abort(0);
        }
    } else {
        sigaction(SIGALRM, &oact, (struct sigaction*)0);
    }
    value.it_interval.tv_sec = seconds;
    value.it_interval.tv_usec = 0;
    value.it_value.tv_sec = seconds;
    value.it_value.tv_usec = 0;
    if(setitimer(ITIMER_REAL, &value, (struct itimerval*)0)) {
        printf("setitimer failed\n");
        nrnmpi_abort(0);
    }

}

#else

void nrn_timeout(int seconds) { }

#endif /* not HAVE_SETITIMER */

#endif /*NRNMPI*/