diff --git a/src/server/common.h b/src/server/common.h index 9f2c3b36d567b249e062f443b170a69f97a0b522..4fad81cb735ad2992e4e75efc1862d5a0abb38dc 100644 --- a/src/server/common.h +++ b/src/server/common.h @@ -71,7 +71,7 @@ extern int giDebugLevel; // --- Helpers -- extern void CompileRegex(regex_t *Regex, const char *Pattern, int Flags); extern int RunRegex(regex_t *regex, const char *string, int nMatches, regmatch_t *matches, const char *errorMessage); -extern void InitSerial(int FD, int BaudRate); +extern int InitSerial(const char *Path, int BaudRate); // --- Dispense --- extern int DispenseItem(int User, tItem *Item); diff --git a/src/server/handler_coke.c b/src/server/handler_coke.c index 53cbd0fd7d3be7afecefdd8cd97f84125fdd5953..c937756583c9bac0a7bbf1f9b65d03aface5d3f2 100644 --- a/src/server/handler_coke.c +++ b/src/server/handler_coke.c @@ -37,13 +37,12 @@ regex_t gCoke_StatusRegex; int Coke_InitHandler() { printf("connecting to coke machine...\n"); - giCoke_SerialFD = open(gsCoke_SerialPort, O_RDWR | O_NOCTTY | O_NONBLOCK); + + giCoke_SerialFD = InitSerial(gsCoke_SerialPort, 9600); if( giCoke_SerialFD == -1 ) { fprintf(stderr, "ERROR: Unable to open coke serial port ('%s')\n", gsCoke_SerialPort); } - InitSerial(giCoke_SerialFD, 9600); - CompileRegex(&gCoke_StatusRegex, "^slot\\s+(\\d)\\s+([^:]+):([a-zA-Z]+)\\s*", REG_EXTENDED); return 0; } @@ -61,6 +60,9 @@ int Coke_CanDispense(int User, int Item) sprintf(tmp, "s%i\n", Item); write(giCoke_SerialFD, tmp, 2); + // Wait a little + sleep(250); + // Read the response tmp[0] = '\0'; ret = read(giCoke_SerialFD, tmp, sizeof(tmp)-1); @@ -99,6 +101,9 @@ int Coke_DoDispense(int User, int Item) // Dispense sprintf(tmp, "d%i\n", Item); write(giCoke_SerialFD, tmp, 2); + + // Wait a little + sleep(250); // Get status read(giCoke_SerialFD, tmp, sizeof(tmp)-1); diff --git a/src/server/main.c b/src/server/main.c index a903f752aaea03ccee30403e3649e05a70eb72fd..17397c118e84132291ba1321289b70d189ce3e26 100644 --- a/src/server/main.c +++ b/src/server/main.c @@ -13,6 +13,9 @@ #include <signal.h> #include "common.h" #include <termios.h> +#include <unistd.h> +#include <sys/stat.h> +#include <fcntl.h> // === IMPORTS === extern void Init_Cokebank(const char *Argument); // cokebank.c @@ -120,10 +123,15 @@ void CompileRegex(regex_t *regex, const char *pattern, int flags) } // Serial helper -void InitSerial(int FD, int BaudRate) +int InitSerial(const char *File, int BaudRate) { struct termios info; int baud; + int fd; + + + fd = open(File, O_RDWR | O_NOCTTY); + if( fd == -1 ) return -1; switch(BaudRate) { @@ -134,7 +142,9 @@ void InitSerial(int FD, int BaudRate) cfmakeraw(&info); // Sets 8N1 cfsetspeed(&info, baud); - tcsetattr(FD, TCSANOW, &info); + tcsetattr(fd, TCSANOW, &info); + + return fd; }