EPSIAE » eneraptor

/*

 * main.c

 *

 * 2011, Aleksander Besir (alex.besir@gmail.com)

 *

 */

#include <stdio.h>

#include <stdlib.h>

#include <pthread.h>

#include <syslog.h>

#include "../hci_comm/hciChanged.h"

#include "../hci_comm/hci_comm.h"

#include "../init/scenariolist.h"

#include "../init/devicelist.h"

#include "../logics/device_threads.h"

//#include "../logics/scenario_threads.h"

// Inter-thread shared variables

// TODO: These variables could be configuration variables

//       (eg: static boolean loggingEnabled)

static device           *hDevice;       //device list

static scenario         *hScenario;     //scenario list

static thread_id_holder *hThrIDhold_dev;//holds IDs of running threads (devices)

static thread_id_holder *hThrIDhold_scn;//holds IDs of running threads (scenarios)

//extern scenario *test;   //device list

// Crtitical section mutual exclusion security

pthread_mutex_t mtx = PTHREAD_MUTEX_INITIALIZER;

pthread_t       decisionMakingThread;

pthread_t       hciConnectionThread;

// Global variable to check, if HCI made any changes that need

// to be updated by the logic.

// Changing this variable's value must be done using the

// mutex mtx declared before.

// To change variables value you should do this:

//    pthread_mutex_lock(&mtx);

//    hciChanged = 0;

//    pthread_mutex_unlock(&mtx);

// The meaning of hciChanged possible values is in hci_comm/hciChanged.h.

// HCI should always reset hciChanged value to HCI_CHANGED_RESET after

// checking it's value.

// To use mtx and hciChanged variables in other .c files, write

//    extern int hciChanged;

//    extern pthread_mutex_t mtx;

// on top of the class.

int hciChanged = HCI_CHANGED_RESET;

void *decisionMakingThread_routine(void *dummy);

void *hciConnectionThread_routine(void *dummy);

void *randomValThread_routine(void *dummy);

void *scenarioThread_routine(void *dummy);

int  reinitialiseLogic(); // on HCI request

int  shutDownLogic();

// Application entry point

int main(int argc, char *argv[]) {

    /** //DAEMON

    pid_t pid, sid;

    pid = fork();

    if (pid < 0) {

            exit(EXIT_FAILURE);

    }

    // EXIT PARENT

    if (pid > 0) {

            exit(EXIT_SUCCESS);

    }

    //umask(0);

    // Open any logs here

    // Create a new SID for the child process

    sid = setsid();

    if (sid < 0) {

            // Log the failure

            exit(EXIT_FAILURE);

    }

    // Close out the standard file descriptors

    // Because daemons generally dont interact directly with user so there is no need of keeping these open

    close(STDIN_FILENO);

    close(STDOUT_FILENO);

    close(STDERR_FILENO);

    /**/

    /* initialisation */

    hDevice   = setDeviceList();

    hScenario = setNewScenarioList(hDevice);

    printf("Devices present:\t%d\n",   getNumberOfDevices());

    printf("Scenarios present:\t%d\n", getNumberOfScenarios());

    /* regular work */

    //*

        pthread_create(&hciConnectionThread, NULL,hciConnectionThread_routine, NULL);

        pthread_create(&decisionMakingThread,NULL,decisionMakingThread_routine,NULL);

        pthread_join(hciConnectionThread,NULL);

        //pthread_join(decisionMakingThread,NULL);

    /**/

        exit(0);

}

// Decision-making thread routine

// Should just call a function that implements decision making module of the logic

void *decisionMakingThread_routine(void *dummy) {

    printf("-- decisionMakingThread_routine started --\n");

    /**dummy threads for input devices (sensors)**/

    hThrIDhold_dev = NULL;

    thread_id_holder *t_holder, *t_holder_old; //just for list of IDs creation, for both scenarios and devices

    t_holder_old = NULL;

    int i;

    for(i=0; i<getNumberOfDevices(); i++)

    {

        t_holder = (thread_id_holder *)malloc(sizeof(thread_id_holder));

        pthread_create(&t_holder->pthr_idx,NULL,randomValThread_routine,NULL);

        t_holder->nxt=NULL;

        if(t_holder_old!=NULL)

            t_holder_old->nxt=t_holder;

        t_holder_old=t_holder;

        if(hThrIDhold_dev==NULL)

            hThrIDhold_dev=t_holder_old;

    }

    /**start scenario threads**/

    t_holder_old = NULL;

    hThrIDhold_scn=NULL;

    for(i=0; i<getNumberOfScenarios(); i++)

    {

        t_holder = (thread_id_holder *)malloc(sizeof(thread_id_holder));

        pthread_create(&t_holder->pthr_idx,NULL,scenarioThread_routine,NULL);

        t_holder->nxt=NULL;

        if(t_holder_old!=NULL)

            t_holder_old->nxt=t_holder;

        t_holder_old=t_holder;

        if(hThrIDhold_scn==NULL)

            hThrIDhold_scn=t_holder_old;

    }

    /*start some sort of control over scenarios? - hmm morda ne...bom jutri :)*/

    printf("Exiting main thread\n");

        pthread_exit(0);

}

// HCI connection thread routine

// Start listening to some port

void *hciConnectionThread_routine(void *dummy) {

    printf("hciConnectionThread_routine started\n");

        int hciErrorCode = listenTo(1100);

        pthread_exit(0);

}

// scenario thread routine

void *scenarioThread_routine(void *dummy)

{

    scenario *scen;

    device   *inDev;

    int      active = 0;

    float    scenarioBuffer;

    //printf("My scen ID> %ld\n",pthread_self());

    /*load scenario*/

    scen = getAvailableScenario(hScenario);

    if(!scen) pthread_exit(0);

    // TODO add pointer to this device (all of them actually) to scenario structure - problems with segfault

    //indev = scen->inDev;

    inDev = getDevice(hDevice, scen->inDevice_id);

    scen->buf=inDev->buf;

    printf("Scenario %s buffer updated to %.2f!\n", scen->scen_id, inDev->buf);

    //set its value

    //*

    while(1) //TODO signal == true

    {

        /// main scenario loop

        //printf("inDev->buf %.2f\n", 1.0f*inDev->buf);

        if(active)

            sleep(scen->actvChkItv);

        else

            sleep(scen->idleChkItv);

        //checking primary condition

        if(scen->buf) // is not null

        {

            scen->buf = scen->buf*scen->alpha+inDev->buf*(1-scen->alpha);

            //printf("Scenario %s buffer updated to %f, alpha: %.2f!\n", scen->scen_id, scenarioBuffer, scen->alpha);

            syslog(LOG_MAIL, "%s:%.2f", scen->inDevice_id, scen->buf);

            active = 1;

            if((scen->buf > scen->optval + scen->tolval) ||

               (scen->buf < scen->optval - scen->tolval))

            {

                if(evaluateAdditionalConditions(scen->cond_l, hDevice))

                {

                    // TODO syslog - "action:scen_ID:power_percentage"

                    int power = getPowerPercentage(scen->minval, scen->maxval, scen->optval, &scen->buf, scen->func);

                    /// Forking to execute action!

                    pid_t pid, sid;

                    pid = fork();

                    if (pid < 0) {

                            exit(EXIT_FAILURE);

                    }

                    // ignore parent

                    if (pid > 0) {}

                    else

                    {

                        /*TODO execute action with parameter(s)*/

                        syslog(LOG_MAIL, "%s:%s:%.2f", scen->action, scen->scen_id, power);

                        execl(scen->action, power);

                        printf("Zaganjam napravo %s z mocjo %d\n", scen->scen_id, power);

                        shutDownLogic();

                    }

                }

                else

                    printf("Scenario %s not updated!\n", scen->scen_id);

            }

            else

                active = 0;

        }

        /*

        if(active)

            printf("%s main buffer %.2f, sleeping %d\n",scen->scen_id, scen->buf, scen->actvChkItv);

        else

            printf("%s main buffer %.2f, sleeping %d\n",scen->scen_id, scen->buf, scen->idleChkItv);

        /**/

    }

    /**/

           pthread_exit(0);

}

void *randomValThread_routine(void *dummy)

{

    //get device

    device *dev;

    dev = getAvailableDevice(hDevice);

    if(dev){}

    else

        pthread_exit(0);

    //set its value

    while(1) //TODO signal == true

    {

        dev->buf=random()%10+20;// random 20-30

        //printf("device %s buf = %d\n", dev->id, dev->buf);

        sleep(dev->readitv);

    }

           pthread_exit(0);

}

void freeDeviceList(device *dev)

{

    if(dev->nxt!=NULL)

        freeDeviceList(dev->nxt);

    free(dev);

}

void freeScenarioList(scenario *scn)

{

    if(scn->nxt!=NULL)

        freeScenarioList(scn->nxt);

    free(scn);

}

void freeThreadIDList(thread_id_holder *tih)

{

    if(tih->nxt!=NULL)

        freeThreadIDList(tih->nxt);

    free(tih);

}

int reinitialiseLogic()

{

    thread_id_holder *hold;

    hold = hThrIDhold_dev;

    //hThrIDhold_dev = NULL;

    //kill device threads

    printf("Attempting to cancel threads!\n");

    while(hold)

    {

        printf("Cancelling dev thread %ld with return state %d\n", hold->pthr_idx,pthread_cancel(hold->pthr_idx));

        //TODO free thread_id_holder list too!

        hold=hold->nxt;

    }

    //kill scenario threads

    hold = hThrIDhold_scn;

    //hThrIDhold_scn = NULL;

    while(hold)

    {

        printf("Cancelling scn thread %ld with return state %d\n", hold->pthr_idx,pthread_cancel(hold->pthr_idx));

        //TODO free thread_id_holder list too!

        hold=hold->nxt;

    }

    //free memory

    printf("Freeing memory!\n");

    freeDeviceList(hDevice);

    freeScenarioList(hScenario);

    freeThreadIDList(hThrIDhold_dev);

    freeThreadIDList(hThrIDhold_scn);

    //reinit devices

    printf("Reinitializing devices!\n");

    hDevice   = setDeviceList();

    //reinit scenarios

    printf("Reinitializing scenarios!\n");

    hScenario = setNewScenarioList(hDevice);

    //restart main thread

    printf("Restarting main thread!\n");

        pthread_create(&decisionMakingThread,NULL,decisionMakingThread_routine,NULL);

        return 1; //sucess, TODO add fail conditions

}

int shutDownLogic()

{

    thread_id_holder *hold;

    hold = hThrIDhold_dev;

    //hThrIDhold_dev = NULL;

    //kill device threads

    printf("Attempting to cancel threads!\n");

    while(hold)

    {

        printf("Cancelling dev thread %ld with return state %d\n", hold->pthr_idx,pthread_cancel(hold->pthr_idx));

        //TODO free thread_id_holder list too!

        hold=hold->nxt;

    }

    //kill scenario threads

    hold = hThrIDhold_scn;

    //hThrIDhold_scn = NULL;

    while(hold)

    {

        printf("Cancelling scn thread %ld with return state %d\n", hold->pthr_idx,pthread_cancel(hold->pthr_idx));

        //TODO free thread_id_holder list too!

        hold=hold->nxt;

    }

    //free memory

    printf("Freeing memory!\n");

    freeDeviceList(hDevice);

    freeScenarioList(hScenario);

    freeThreadIDList(hThrIDhold_dev);

    freeThreadIDList(hThrIDhold_scn);

    //stop main thread and HCI comm thread

    pthread_cancel(decisionMakingThread);

    pthread_cancel(hciConnectionThread);

        return 1; //sucess, TODO add fail conditions

}