X-Git-Url: https://git.ucc.asn.au/?a=blobdiff_plain;f=src%2Fserver%2Fhandler_door.c;h=1db954fdbd304ba3e10a33a4c0b92893297c8f9e;hb=6b70240e4975aa8a5cfe1c4f01f79c64ec1ba5e1;hp=b2c6c2bb0d2960c475183ef9cc75c526605245d5;hpb=27821403db9a9488cc508899af92f90c9bbade34;p=tpg%2Fopendispense2.git diff --git a/src/server/handler_door.c b/src/server/handler_door.c index b2c6c2b..1db954f 100644 --- a/src/server/handler_door.c +++ b/src/server/handler_door.c @@ -2,13 +2,12 @@ * OpenDispense 2 * UCC (University [of WA] Computer Club) Electronic Accounting System * - * handler_doror.c - Door Relay code + * handler_door.c - Door Relay code * * This file is licenced under the 3-clause BSD Licence. See the file * COPYING for full details. */ #define DEBUG 1 -#define USE_POPEN 0 #include "common.h" #include @@ -18,13 +17,18 @@ #include #include #include -#include +#include +#include +#include +#include +#include -#define DOOR_UNLOCKED_DELAY 10 // 10 seconds before it re-locks +#define DOOR_UNLOCKED_DELAY 10 // Time in seconds before the door re-locks // === IMPORTS === // === PROTOTYPES === +void* Door_Lock(void* Unused); int Door_InitHandler(); int Door_CanDispense(int User, int Item); int Door_DoDispense(int User, int Item); @@ -36,20 +40,54 @@ tHandler gDoor_Handler = { Door_CanDispense, Door_DoDispense }; -char *gsDoor_Password = ""; -volatile int giDoor_ChildStatus; +char *gsDoor_SerialPort; // Set from config in main.c +sem_t gDoor_UnlockSemaphore; +pthread_t gDoor_LockThread; +bool gbDoor_LockThreadStarted; -// == CODE === -void Door_SIGCHLDHandler(int signum) +// === CODE === +void* Door_Lock(void* Unused __attribute__((unused))) { - signum = 0; - giDoor_ChildStatus ++; - printf("SIGCHLD: giDoor_ChildStatus = %i \n", giDoor_ChildStatus); + gbDoor_LockThreadStarted = true; + while(1) + { + sem_wait(&gDoor_UnlockSemaphore); + + int door_serial_handle = InitSerial(gsDoor_SerialPort, 9600); + if(door_serial_handle < 0) + { + fprintf(stderr, "Unable to open door serial '%s'\n", gsDoor_SerialPort); + perror("Opening door port"); + } + + // Disable local echo + { + struct termios info; + tcgetattr(door_serial_handle, &info); + info.c_cflag &= ~CLOCAL; + tcsetattr(door_serial_handle, TCSANOW, &info); + } + + if(write(door_serial_handle, "\xff\x01\x01", 3) != 3) // Relay ON + { + fprintf(stderr, "Failed to write Relay ON (unlock) command, errstr: %s", strerror(errno)); + } + + sleep(DOOR_UNLOCKED_DELAY); + + if(write(door_serial_handle, "\xff\x01\x00", 3) != 3) // Relay OFF + { + fprintf(stderr, "Failed to write Relay OFF (lock) command, errstr: %s", strerror(errno)); + } + + close(door_serial_handle); + } } int Door_InitHandler(void) { - signal(SIGCHLD, Door_SIGCHLDHandler); + // Thread started later + return 0; } @@ -63,7 +101,7 @@ int Door_CanDispense(int User, int Item) // Sanity please if( Item != 0 ) return -1; - if( !(Bank_GetFlags(User) & USER_FLAG_DOORGROUP) ) + if( !(Bank_GetFlags(User) & (USER_FLAG_DOORGROUP|USER_FLAG_ADMIN)) ) { #if DEBUG printf("Door_CanDispense: User %i not in door\n", User); @@ -82,23 +120,16 @@ int Door_CanDispense(int User, int Item) * \brief Actually do a dispense from the coke machine */ int Door_DoDispense(int User, int Item) -{ - FILE *child_stdin; - char buf[512]; - int stdin_pair[2]; - int stdout_pair[2]; - pid_t childPid; - pid_t parentPid; - +{ #if DEBUG printf("Door_DoDispense: (User=%i,Item=%i)\n", User, Item); #endif - + // Sanity please if( Item != 0 ) return -1; // Check if user is in door - if( !(Bank_GetFlags(User) & USER_FLAG_DOORGROUP) ) + if( !(Bank_GetFlags(User) & (USER_FLAG_DOORGROUP|USER_FLAG_ADMIN)) ) { #if DEBUG printf("Door_CanDispense: User %i not in door\n", User); @@ -106,109 +137,24 @@ int Door_DoDispense(int User, int Item) return 1; } - // Create stdin/stdout - if( pipe(stdin_pair) || pipe(stdout_pair) ) - { - perror("pipe"); - return -1; - } - - giDoor_ChildStatus = 0; // Set child status to zero - parentPid = getpid(); - childPid = fork(); - - if( childPid < 0 ) - { - perror("fork"); - return -1; - } - - // Child process - if( childPid == 0 ) + // Door thread spun up here because program is forked after thread created + if( !gbDoor_LockThreadStarted ) { - // Close write end of stdin, and set it to #0 - close(stdin_pair[1]); dup2(stdin_pair[0], 0); - // Close read end of stdout, and set it to #1 - close(stdout_pair[0]); dup2(stdout_pair[1], 1); - - //execl("/bin/sh", "sh", "-c", "llogin door -w-", NULL); - execl("/usr/bin/llogin", "llogin" "door" "-w-", NULL); - perror("execl"); - exit(-1); + // Initialize semaphore, triggers door lock release if semaphore is greater than 0 + sem_init(&gDoor_UnlockSemaphore, 0, 0); + + pthread_create(&gDoor_LockThread, NULL, &Door_Lock, NULL); } - - child_stdin = fdopen(stdin_pair[1], "w"); - close(stdin_pair[0]); // child stdin read - close(stdout_pair[1]); // child stdout write - + + if(sem_post(&gDoor_UnlockSemaphore)) { - int len; - if( giDoor_ChildStatus || (len = read(stdout_pair[0], buf, 512)) < 0) - { - #if DEBUG - int child_exit; - waitpid(childPid, &child_exit, 0); - printf("Door_DoDispense: fread fail (child status %i)\n", child_exit); - #endif - return -1; - } - buf[len] = '\0'; - - #if DEBUG - printf("Door_DoDispense: buf = %i '%s'\n", len, buf); - #endif - } - - // Send password - if( giDoor_ChildStatus || fputs(gsDoor_Password, child_stdin) <= 0 ) { - #if DEBUG - int child_exit; - waitpid(childPid, &child_exit, 0); - printf("Door_DoDispense: fputs password fail (child status %i)\n", child_exit); - #endif - return -1; - } - fputs("\n", child_stdin); - - - #if DEBUG - printf("Door_DoDispense: Door unlock\n"); - #endif - - // ATH1 - Unlock door - if( giDoor_ChildStatus || fputs("ATH1\n", child_stdin) <= 0) { - #if DEBUG - printf("Door_DoDispense: fputs unlock\n"); - #endif + perror("Failed to post \"Unlock Door\" semaphore, sem_post returned"); return -1; } - - // Wait before re-locking - sleep(DOOR_UNLOCKED_DELAY); - - - #if DEBUG - printf("Door_DoDispense: Door re-lock\n"); - #endif - // Re-lock the door (and quit llogin) - if( giDoor_ChildStatus || fputs("ATH0\n\x1D", child_stdin) == 0 ) { - #if DEBUG - printf("Door_DoDispense: fputs lock\n"); - #endif - return -1; - } - - fclose(child_stdin); - close(stdin_pair[1]); // child stdin write - close(stdout_pair[0]); // child stdout read - #if DEBUG printf("Door_DoDispense: User %i opened door\n", User); #endif - kill(childPid, SIGKILL); - return 0; } -