X-Git-Url: https://git.ucc.asn.au/?a=blobdiff_plain;ds=sidebyside;f=src%2Fserver%2Fmain.c;h=b612f6fcc8864b52e5dbb7fd51795ded979ac5d1;hb=97baaecf7affaf561a0ee6329cc5dee30d52713c;hp=d327db38ee67abaf8f5e5693e038491cce28d8f6;hpb=650ed689f2d8c30fe9c448fbec0e58037cc2ce25;p=tpg%2Fopendispense2.git diff --git a/src/server/main.c b/src/server/main.c index d327db3..b612f6f 100644 --- a/src/server/main.c +++ b/src/server/main.c @@ -10,21 +10,33 @@ #include #include #include +#include #include "common.h" +#include +#include +#include +#include // === IMPORTS === extern void Init_Cokebank(const char *Argument); // cokebank.c +extern void Init_Handlers(void); extern void Load_Itemlist(void); extern void Server_Start(void); extern int giServer_Port; extern char* gsItemListFile; extern char* gsCoke_SerialPort; +extern char* gsSnack_SerialPort; // === GLOBALS === int giDebugLevel = 0; char *gsCokebankPath = "cokebank.db"; // === CODE === +void sigint_handler() +{ + exit(0); +} + int main(int argc, char *argv[]) { int i; @@ -52,9 +64,12 @@ int main(int argc, char *argv[]) if( strcmp(arg, "--itemsfile") == 0 ) { gsItemListFile = argv[++i]; } - if( strcmp(arg, "--cokeport") == 0 ) { + else if( strcmp(arg, "--cokeport") == 0 ) { gsCoke_SerialPort = argv[++i]; } + else if( strcmp(arg, "--snackport") == 0 ) { + gsSnack_SerialPort = argv[++i]; + } else { // Usage error? } @@ -64,12 +79,75 @@ int main(int argc, char *argv[]) } } - Init_Cokebank(gsCokebankPath); + signal(SIGINT, sigint_handler); + Init_Cokebank(gsCokebankPath); + + Init_Handlers(); + Load_Itemlist(); Server_Start(); + return 0; } +int RunRegex(regex_t *regex, const char *string, int nMatches, regmatch_t *matches, const char *errorMessage) +{ + int ret; + + ret = regexec(regex, string, nMatches, matches, 0); + if( ret ) { + size_t len = regerror(ret, regex, NULL, 0); + char errorStr[len]; + regerror(ret, regex, errorStr, len); + printf("string = '%s'\n", string); + fprintf(stderr, "%s\n%s", errorMessage, errorStr); + exit(-1); + } + + return ret; +} + +void CompileRegex(regex_t *regex, const char *pattern, int flags) +{ + int ret = regcomp(regex, pattern, flags); + if( ret ) { + size_t len = regerror(ret, regex, NULL, 0); + char errorStr[len]; + regerror(ret, regex, errorStr, len); + fprintf(stderr, "Regex compilation failed - %s\n", errorStr); + exit(-1); + } +} + +// Serial helper +int InitSerial(const char *File, int BaudRate) +{ + struct termios info; + int baud; + int fd; + + fd = open(File, O_RDWR | O_NOCTTY | O_NONBLOCK); + if( fd == -1 ) return -1; + + switch(BaudRate) + { + case 9600: baud = B9600; break; + default: close(fd); return -1; + } + + info.c_lflag = 0; // Non-Canoical, No Echo + info.c_cflag = baud | CS8 | CLOCAL | CREAD; // baud, 8N1 + cfsetspeed(&info, baud); + info.c_cc[VTIME] = 0; // No time limit + info.c_cc[VMIN] = 1; // Block until 1 char + + tcflush(fd, TCIFLUSH); + tcsetattr(fd, TCSANOW, &info); + + return fd; +} + +