X-Git-Url: https://git.ucc.asn.au/?a=blobdiff_plain;f=server%2Factuator.c;h=f5d7cd647a51904ffc1a9d2e3e8f387fa3979c1a;hb=f7835777d9a2e85ab310919a150a200ea55c7222;hp=4df06bc828a02047674c358fe9277c057e5d36a2;hpb=466cbf5433adfc4fef7065164918201039159aff;p=matches%2FMCTX3420.git diff --git a/server/actuator.c b/server/actuator.c index 4df06bc..f5d7cd6 100644 --- a/server/actuator.c +++ b/server/actuator.c @@ -6,7 +6,7 @@ #include "actuator.h" #include "options.h" // Files containing GPIO and PWM definitions -#include "gpio.h" +#include "bbb_pin.h" /** Array of Actuators (global to this file) initialised by Actuator_Init **/ @@ -14,7 +14,7 @@ static Actuator g_actuators[NUMACTUATORS]; /** Human readable names for the Actuators **/ const char * g_actuator_names[NUMACTUATORS] = { - "actuator_test0", "actuator_test1", "actuator_test2" + "actuator_test0", "gpio1_16", "EHRPWM0A_duty@60Hz" }; /** @@ -28,6 +28,11 @@ void Actuator_Init() Data_Init(&(g_actuators[i].data_file)); pthread_mutex_init(&(g_actuators[i].mutex), NULL); } + + // Initialise pins used + GPIO_Export(GPIO1_16); + PWM_Export(EHRPWM0A); + } /** @@ -47,7 +52,6 @@ void Actuator_SetMode(Actuator * a, ControlModes mode, void *arg) { char filename[BUFSIZ]; const char *experiment_name = (const char*) arg; - int ret; if (snprintf(filename, BUFSIZ, "%s_a%d", experiment_name, a->id) >= BUFSIZ) { @@ -57,34 +61,43 @@ void Actuator_SetMode(Actuator * a, ControlModes mode, void *arg) Log(LOGDEBUG, "Actuator %d with DataFile \"%s\"", a->id, filename); // Open DataFile Data_Open(&(a->data_file), filename); - + } + case CONTROL_RESUME: //Case fallthrough; no break before + { + int ret; a->activated = true; // Don't forget this - a->allow_actuation = true; - a->control_changed = false; - // Create the thread ret = pthread_create(&(a->thread), NULL, Actuator_Loop, (void*)(a)); if (ret != 0) { Fatal("Failed to create Actuator_Loop for Actuator %d", a->id); } + + Log(LOGDEBUG, "Resuming actuator %d", a->id); } break; case CONTROL_EMERGENCY: //TODO add proper case for emergency case CONTROL_PAUSE: - a->allow_actuation = false; + a->activated = false; + Actuator_SetControl(a, NULL); + pthread_join(a->thread, NULL); // Wait for thread to exit + + Log(LOGDEBUG, "Paused actuator %d", a->id); break; - case CONTROL_RESUME: - a->allow_actuation = true; + break; case CONTROL_STOP: - a->allow_actuation = false; - a->activated = false; - Actuator_SetControl(a, NULL); - pthread_join(a->thread, NULL); // Wait for thread to exit + if (a->activated) //May have been paused before + { + a->activated = false; + Actuator_SetControl(a, NULL); + pthread_join(a->thread, NULL); // Wait for thread to exit + } Data_Close(&(a->data_file)); // Close DataFile + + Log(LOGDEBUG, "Stopped actuator %d", a->id); break; default: Fatal("Unknown control mode: %d", mode); @@ -124,8 +137,6 @@ void * Actuator_Loop(void * arg) pthread_mutex_unlock(&(a->mutex)); if (!a->activated) break; - else if (!a->allow_actuation) - continue; Actuator_SetValue(a, a->control.value); } @@ -192,35 +203,15 @@ void Actuator_SetValue(Actuator * a, double value) } break; case ACTUATOR_TEST1: - // GPIO pin digital actuator - { - // Quick actuator function for testing pins - // GPIOPin can be passed as argument, but is just defined here for testing purposes - // Modify this to only export on first run, only unexport on shutdown - pinExport(60); - pinDirection(60, 1); - pinSet(value, 60); - pinUnexport(60); - } + GPIO_Set(GPIO1_16, (bool)(value)); break; case ACTUATOR_TEST2: + { // PWM analogue actuator (currently generates one PWM signal with first PWM module) - /* - { - if (pwminit == 0) { // If inactive, start the pwm module - pwm_init(); - } - if (pwmstart == 0) { - pwm_start(); - pwm_set_period(FREQ); // Frequency is 50Hz defined in pwm header file - } - if(value >= 0 && value <= 1000) { - double duty = value/1000 * 100; // Convert pressure to duty percentage - pwm_set_duty((int)duty); // Set duty percentage for actuator (0-100%) - } - } - */ + static long freq = 16666666; // This is 60Hz + PWM_Set(EHRPWM0A, true, freq, value * freq); // Set the duty cycle break; + } } Log(LOGDEBUG, "Actuator %s set to %f", g_actuator_names[a->id], value); @@ -243,6 +234,7 @@ void Actuator_BeginResponse(FCGIContext * context, ActuatorId id, DataFormat for case JSON: FCGI_BeginJSON(context, STATUS_OK); FCGI_JSONLong("id", id); + FCGI_JSONPair("name", g_actuator_names[id]); break; default: FCGI_PrintRaw("Content-type: text/plain\r\n\r\n"); @@ -270,8 +262,6 @@ void Actuator_EndResponse(FCGIContext * context, ActuatorId id, DataFormat forma } - - /** * Handle a request for an Actuator * @param context - FCGI context