summaryrefslogtreecommitdiff
diff options
context:
space:
mode:
authorHaoran S. Diao <0@hairydiode.xyz>2019-04-13 17:52:47 -0400
committerHaoran S. Diao <0@hairydiode.xyz>2019-04-13 17:52:47 -0400
commitf14a8e9006a84c44a65163f301efaa8a000bfa06 (patch)
tree012d050e4deb313e3d9c98760a8f8826f74f05d3
parent75be47d49296f39a07cfb882f4fa6e1c7f06b6cf (diff)
Implemented communication w/ Arduino via rs232
-rw-r--r--Makefile4
-rw-r--r--guardian.c153
-rw-r--r--rs232.c820
-rw-r--r--rs232.h86
4 files changed, 1061 insertions, 2 deletions
diff --git a/Makefile b/Makefile
index 3c206cc..9dd09ed 100644
--- a/Makefile
+++ b/Makefile
@@ -1,2 +1,2 @@
-guardian : guardian.c
- gcc guardian.c -o guardian
+guardian : guardian.c rs232.c
+ gcc guardian.c rs232.c -o guardian
diff --git a/guardian.c b/guardian.c
index 0e6d93c..5b5c99d 100644
--- a/guardian.c
+++ b/guardian.c
@@ -4,6 +4,8 @@
#include<ctype.h>
#include <sys/types.h>
#include <dirent.h>
+#include "rs232.h"
+#include <unistd.h>
/* struct describing the various templates that alerts can use
* these are loaded from /etc/squishy
*/
@@ -33,6 +35,10 @@ struct template {
struct template * * templates;
unsigned int templates_len = 0;
/*
+ * Comport number of the comport in use
+ */
+int comport_number;
+/*
* Reads alert template from file, returns null on failure, otherwise returns
* pointer to the template w/ all data already allocated by the function
*/
@@ -292,6 +298,11 @@ char * str_concat(char * s1, char * s2) {
strncpy(return_str + strlen(s1) + strlen(s2) ,"\0", sizeof(char) * 1);
return return_str;
}
+/*
+ * Loads all templates
+ * looks in templates/
+ * returns NULL on error
+ */
struct template * * load_templates() {
/*ensures that templates is alteast 1 element big*/
struct template * * templates = (struct template * *)malloc(sizeof(struct template * ));
@@ -347,6 +358,12 @@ struct template * * load_templates() {
closedir(templates_dir);
return templates;
}
+/*
+ * Sends alert to all pseudoterminals the process has permission to
+ * returns -1 on error
+ * template_name is used to select a template and not a pointer to a template
+ * class, this way broadcast handles template selection directly from arguments
+ */
int broadcast(char * template_name, char * message) {
struct template * tm = NULL;
/*
@@ -409,13 +426,149 @@ int broadcast(char * template_name, char * message) {
}
} while (pts_entry != NULL);
}
+/*
+ * Initializes RS232 connection with the guardian, returns -1 on error
+ */
+int startcom (char * device_path) {
+ comport_number = -1;
+ /*
+ * Looks for device in the RS232 library array comports that match the
+ * device specified by the user. If one is not found then comport_number
+ * will remain -1;
+ */
+ for (int i = 0; i < 38; i++) {
+ if (strcmp(comports[i], device_path) == 0) {
+ comport_number = i;
+ }
+ }
+ /*
+ * Deals with the condition described above
+ */
+ if (comport_number == -1 ) {
+ fprintf(stderr, "Could not find device %s\n",device_path);
+ return -1;
+ }
+ /*
+ * Opens RS232 Connection w/ the Guardian. The connection is at
+ * 9600baud. 8N1 means 8 data bits and no parity bits
+ */
+ int err = RS232_OpenComport(comport_number ,9600,"8N1");
+ if (err != 0) {
+ fprintf(stderr, "Error opening comport %s, number %d\n",
+ device_path, comport_number);
+ return -1;
+ }
+ /* waits for arduino to respond, this indicates that it is ready to
+ * accept commands. We know for a fact that the response is less than
+ * 256 bytes so the buffer is more than safe
+ */
+ char poll_buffer[256];
+ /*
+ * Timeout is implemented with a timer w/ no regard to actual time
+ * passed. For now it will be 200 tries
+ */
+ int timeout = 0;
+ do {
+ /*On EAGAIN( no data), the function returns 0, however if there
+ * is an error it returns <0. Otherwise it returns the number of
+ * bytes read
+ */
+ err = RS232_PollComport(comport_number, poll_buffer, 256);
+ timeout++;
+ /*
+ * Checks for timeout
+ */
+ if (timeout >= 200) {
+ fprintf(stderr, "Polling %s timed out\n",device_path);
+ err = -1;
+ }
+
+ } while (err == 0);
+ if (err < 0) {
+ fprintf(stderr, "Error polling from comport %s, number %d\n",
+ device_path, comport_number);
+ return -1;
+ }
+ return 0;
+}
+/*
+ * Makes the Guardian block the keyboard, returns -1 on error
+ */
+int slap(char pos) {
+ /* positions commands are sent in the form of
+ * p[int] where the letter 'p' is followed by an integer ranging 0 to
+ * 180 that determines the angle of the servo. We will cast this as an
+ * char for simplicity. On the microcontroller side this gets casted
+ * into an int 180 flat to the extreme
+ * ------
+ * =====O | 180 Degrees
+ * ------
+ *
+ * |
+ * __|___
+ * | O | 90 Degrees
+ * ------
+ */
+ char command[2] = {'p', pos};
+ int error = RS232_SendBuf(comport_number,command, 2);
+ if (error != 0) {
+ fprintf(stderr, "Error sending command to comport %d\n",
+ comport_number);
+ return error;
+ }
+ return 0;
+}
int main (int argc, char * argv[]) {
+
+ /*
+ * Checks for the proper number of arguments, also checks for argv[1] ==
+ * "raise" and there are 2 arguments.
+ */
+ if (argc < 4) {
+ /*
+ * Tests for raise
+ */
+ if (argc >= 3) {
+ if (strcmp(argv[1], "raise") == 0 ) {
+ /*
+ * Starts com based on 2nd argument device and
+ * raises the arm
+ */
+ startcom(argv[2]);
+ slap(90);
+ /* exits */
+ return 0;
+ }
+ }
+ /*
+ * Not enough arguments, display help and exit
+ */
+ fprintf(stdout, "Usage: guardian [template] [message] [guardian\
+ device]\n\
+ OR guardian raise");
+ return -1;
+ }
+ /*
+ * Loads templates for the alert
+ */
templates = load_templates();
if (templates == NULL) {
return -1;
}
+ /*
+ * Sends the alert to all pttys
+ */
if (broadcast(argv[1],argv[2])) {
return -1;
}
+ /*
+ * Starts serial communications w/ the Arduino, uses 3rd argument as the
+ * device to connect to.
+ */
+ startcom(argv[3]);
+ /*
+ * For normal operation it lowers the arm
+ */
+ slap(180);
}
diff --git a/rs232.c b/rs232.c
new file mode 100644
index 0000000..4f943f7
--- /dev/null
+++ b/rs232.c
@@ -0,0 +1,820 @@
+/*
+***************************************************************************
+*
+* Author: Teunis van Beelen
+*
+* Copyright (C) 2005, 2006, 2007, 2008, 2009, 2010, 2011, 2012, 2013, 2014, 2015, 2016, 2017 Teunis van Beelen
+*
+* Email: teuniz@gmail.com
+*
+***************************************************************************
+*
+* This program is free software: you can redistribute it and/or modify
+* it under the terms of the GNU General Public License as published by
+* the Free Software Foundation, either version 3 of the License, or
+* (at your option) any later version.
+*
+* This program is distributed in the hope that it will be useful,
+* but WITHOUT ANY WARRANTY; without even the implied warranty of
+* MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the
+* GNU General Public License for more details.
+*
+* You should have received a copy of the GNU General Public License
+* along with this program. If not, see <http://www.gnu.org/licenses/>.
+*
+***************************************************************************
+*/
+
+
+/* Last revision: November 22, 2017 */
+
+/* For more info and how to use this library, visit: http://www.teuniz.net/RS-232/ */
+
+
+#include "rs232.h"
+
+
+#if defined(__linux__) || defined(__FreeBSD__) /* Linux & FreeBSD */
+
+#define RS232_PORTNR 38
+
+
+int Cport[RS232_PORTNR],
+ error;
+
+struct termios new_port_settings,
+ old_port_settings[RS232_PORTNR];
+
+char * comports[RS232_PORTNR]={"/dev/ttyS0","/dev/ttyS1","/dev/ttyS2","/dev/ttyS3","/dev/ttyS4","/dev/ttyS5",
+ "/dev/ttyS6","/dev/ttyS7","/dev/ttyS8","/dev/ttyS9","/dev/ttyS10","/dev/ttyS11",
+ "/dev/ttyS12","/dev/ttyS13","/dev/ttyS14","/dev/ttyS15","/dev/ttyUSB0",
+ "/dev/ttyUSB1","/dev/ttyUSB2","/dev/ttyUSB3","/dev/ttyUSB4","/dev/ttyUSB5",
+ "/dev/ttyAMA0","/dev/ttyAMA1","/dev/ttyACM0","/dev/ttyACM1",
+ "/dev/rfcomm0","/dev/rfcomm1","/dev/ircomm0","/dev/ircomm1",
+ "/dev/cuau0","/dev/cuau1","/dev/cuau2","/dev/cuau3",
+ "/dev/cuaU0","/dev/cuaU1","/dev/cuaU2","/dev/cuaU3"};
+
+int RS232_OpenComport(int comport_number, int baudrate, const char *mode)
+{
+ int baudr,
+ status;
+
+ if((comport_number>=RS232_PORTNR)||(comport_number<0))
+ {
+ printf("illegal comport number\n");
+ return(1);
+ }
+
+ switch(baudrate)
+ {
+ case 50 : baudr = B50;
+ break;
+ case 75 : baudr = B75;
+ break;
+ case 110 : baudr = B110;
+ break;
+ case 134 : baudr = B134;
+ break;
+ case 150 : baudr = B150;
+ break;
+ case 200 : baudr = B200;
+ break;
+ case 300 : baudr = B300;
+ break;
+ case 600 : baudr = B600;
+ break;
+ case 1200 : baudr = B1200;
+ break;
+ case 1800 : baudr = B1800;
+ break;
+ case 2400 : baudr = B2400;
+ break;
+ case 4800 : baudr = B4800;
+ break;
+ case 9600 : baudr = B9600;
+ break;
+ case 19200 : baudr = B19200;
+ break;
+ case 38400 : baudr = B38400;
+ break;
+ case 57600 : baudr = B57600;
+ break;
+ case 115200 : baudr = B115200;
+ break;
+ case 230400 : baudr = B230400;
+ break;
+ case 460800 : baudr = B460800;
+ break;
+ case 500000 : baudr = B500000;
+ break;
+ case 576000 : baudr = B576000;
+ break;
+ case 921600 : baudr = B921600;
+ break;
+ case 1000000 : baudr = B1000000;
+ break;
+ case 1152000 : baudr = B1152000;
+ break;
+ case 1500000 : baudr = B1500000;
+ break;
+ case 2000000 : baudr = B2000000;
+ break;
+ case 2500000 : baudr = B2500000;
+ break;
+ case 3000000 : baudr = B3000000;
+ break;
+ case 3500000 : baudr = B3500000;
+ break;
+ case 4000000 : baudr = B4000000;
+ break;
+ default : printf("invalid baudrate\n");
+ return(1);
+ break;
+ }
+
+ int cbits=CS8,
+ cpar=0,
+ ipar=IGNPAR,
+ bstop=0;
+
+ if(strlen(mode) != 3)
+ {
+ printf("invalid mode \"%s\"\n", mode);
+ return(1);
+ }
+
+ switch(mode[0])
+ {
+ case '8': cbits = CS8;
+ break;
+ case '7': cbits = CS7;
+ break;
+ case '6': cbits = CS6;
+ break;
+ case '5': cbits = CS5;
+ break;
+ default : printf("invalid number of data-bits '%c'\n", mode[0]);
+ return(1);
+ break;
+ }
+
+ switch(mode[1])
+ {
+ case 'N':
+ case 'n': cpar = 0;
+ ipar = IGNPAR;
+ break;
+ case 'E':
+ case 'e': cpar = PARENB;
+ ipar = INPCK;
+ break;
+ case 'O':
+ case 'o': cpar = (PARENB | PARODD);
+ ipar = INPCK;
+ break;
+ default : printf("invalid parity '%c'\n", mode[1]);
+ return(1);
+ break;
+ }
+
+ switch(mode[2])
+ {
+ case '1': bstop = 0;
+ break;
+ case '2': bstop = CSTOPB;
+ break;
+ default : printf("invalid number of stop bits '%c'\n", mode[2]);
+ return(1);
+ break;
+ }
+
+/*
+http://pubs.opengroup.org/onlinepubs/7908799/xsh/termios.h.html
+
+http://man7.org/linux/man-pages/man3/termios.3.html
+*/
+
+ Cport[comport_number] = open(comports[comport_number], O_RDWR | O_NOCTTY | O_NDELAY);
+ if(Cport[comport_number]==-1)
+ {
+ perror("unable to open comport ");
+ return(1);
+ }
+
+ /* lock access so that another process can't also use the port */
+ if(flock(Cport[comport_number], LOCK_EX | LOCK_NB) != 0)
+ {
+ close(Cport[comport_number]);
+ perror("Another process has locked the comport.");
+ return(1);
+ }
+
+ error = tcgetattr(Cport[comport_number], old_port_settings + comport_number);
+ if(error==-1)
+ {
+ close(Cport[comport_number]);
+ flock(Cport[comport_number], LOCK_UN); /* free the port so that others can use it. */
+ perror("unable to read portsettings ");
+ return(1);
+ }
+ memset(&new_port_settings, 0, sizeof(new_port_settings)); /* clear the new struct */
+
+ new_port_settings.c_cflag = cbits | cpar | bstop | CLOCAL | CREAD;
+ new_port_settings.c_iflag = ipar;
+ new_port_settings.c_oflag = 0;
+ new_port_settings.c_lflag = 0;
+ new_port_settings.c_cc[VMIN] = 0; /* block untill n bytes are received */
+ new_port_settings.c_cc[VTIME] = 0; /* block untill a timer expires (n * 100 mSec.) */
+
+ cfsetispeed(&new_port_settings, baudr);
+ cfsetospeed(&new_port_settings, baudr);
+
+ error = tcsetattr(Cport[comport_number], TCSANOW, &new_port_settings);
+ if(error==-1)
+ {
+ tcsetattr(Cport[comport_number], TCSANOW, old_port_settings + comport_number);
+ close(Cport[comport_number]);
+ flock(Cport[comport_number], LOCK_UN); /* free the port so that others can use it. */
+ perror("unable to adjust portsettings ");
+ return(1);
+ }
+
+/* http://man7.org/linux/man-pages/man4/tty_ioctl.4.html */
+
+ if(ioctl(Cport[comport_number], TIOCMGET, &status) == -1)
+ {
+ tcsetattr(Cport[comport_number], TCSANOW, old_port_settings + comport_number);
+ flock(Cport[comport_number], LOCK_UN); /* free the port so that others can use it. */
+ perror("unable to get portstatus");
+ return(1);
+ }
+
+ status |= TIOCM_DTR; /* turn on DTR */
+ status |= TIOCM_RTS; /* turn on RTS */
+
+ if(ioctl(Cport[comport_number], TIOCMSET, &status) == -1)
+ {
+ tcsetattr(Cport[comport_number], TCSANOW, old_port_settings + comport_number);
+ flock(Cport[comport_number], LOCK_UN); /* free the port so that others can use it. */
+ perror("unable to set portstatus");
+ return(1);
+ }
+
+ return(0);
+}
+
+
+int RS232_PollComport(int comport_number, unsigned char *buf, int size)
+{
+ int n;
+
+ n = read(Cport[comport_number], buf, size);
+
+ if(n < 0)
+ {
+ if(errno == EAGAIN) return 0;
+ }
+
+ return(n);
+}
+
+
+int RS232_SendByte(int comport_number, unsigned char byte)
+{
+ int n = write(Cport[comport_number], &byte, 1);
+ if(n < 0)
+ {
+ if(errno == EAGAIN)
+ {
+ return 0;
+ }
+ else
+ {
+ return 1;
+ }
+ }
+
+ return(0);
+}
+
+
+int RS232_SendBuf(int comport_number, unsigned char *buf, int size)
+{
+ int n = write(Cport[comport_number], buf, size);
+ if(n < 0)
+ {
+ if(errno == EAGAIN)
+ {
+ return 0;
+ }
+ else
+ {
+ return -1;
+ }
+ }
+
+ return(n);
+}
+
+
+void RS232_CloseComport(int comport_number)
+{
+ int status;
+
+ if(ioctl(Cport[comport_number], TIOCMGET, &status) == -1)
+ {
+ perror("unable to get portstatus");
+ }
+
+ status &= ~TIOCM_DTR; /* turn off DTR */
+ status &= ~TIOCM_RTS; /* turn off RTS */
+
+ if(ioctl(Cport[comport_number], TIOCMSET, &status) == -1)
+ {
+ perror("unable to set portstatus");
+ }
+
+ tcsetattr(Cport[comport_number], TCSANOW, old_port_settings + comport_number);
+ close(Cport[comport_number]);
+
+ flock(Cport[comport_number], LOCK_UN); /* free the port so that others can use it. */
+}
+
+/*
+Constant Description
+TIOCM_LE DSR (data set ready/line enable)
+TIOCM_DTR DTR (data terminal ready)
+TIOCM_RTS RTS (request to send)
+TIOCM_ST Secondary TXD (transmit)
+TIOCM_SR Secondary RXD (receive)
+TIOCM_CTS CTS (clear to send)
+TIOCM_CAR DCD (data carrier detect)
+TIOCM_CD see TIOCM_CAR
+TIOCM_RNG RNG (ring)
+TIOCM_RI see TIOCM_RNG
+TIOCM_DSR DSR (data set ready)
+
+http://man7.org/linux/man-pages/man4/tty_ioctl.4.html
+*/
+
+int RS232_IsDCDEnabled(int comport_number)
+{
+ int status;
+
+ ioctl(Cport[comport_number], TIOCMGET, &status);
+
+ if(status&TIOCM_CAR) return(1);
+ else return(0);
+}
+
+
+int RS232_IsCTSEnabled(int comport_number)
+{
+ int status;
+
+ ioctl(Cport[comport_number], TIOCMGET, &status);
+
+ if(status&TIOCM_CTS) return(1);
+ else return(0);
+}
+
+
+int RS232_IsDSREnabled(int comport_number)
+{
+ int status;
+
+ ioctl(Cport[comport_number], TIOCMGET, &status);
+
+ if(status&TIOCM_DSR) return(1);
+ else return(0);
+}
+
+
+void RS232_enableDTR(int comport_number)
+{
+ int status;
+
+ if(ioctl(Cport[comport_number], TIOCMGET, &status) == -1)
+ {
+ perror("unable to get portstatus");
+ }
+
+ status |= TIOCM_DTR; /* turn on DTR */
+
+ if(ioctl(Cport[comport_number], TIOCMSET, &status) == -1)
+ {
+ perror("unable to set portstatus");
+ }
+}
+
+
+void RS232_disableDTR(int comport_number)
+{
+ int status;
+
+ if(ioctl(Cport[comport_number], TIOCMGET, &status) == -1)
+ {
+ perror("unable to get portstatus");
+ }
+
+ status &= ~TIOCM_DTR; /* turn off DTR */
+
+ if(ioctl(Cport[comport_number], TIOCMSET, &status) == -1)
+ {
+ perror("unable to set portstatus");
+ }
+}
+
+
+void RS232_enableRTS(int comport_number)
+{
+ int status;
+
+ if(ioctl(Cport[comport_number], TIOCMGET, &status) == -1)
+ {
+ perror("unable to get portstatus");
+ }
+
+ status |= TIOCM_RTS; /* turn on RTS */
+
+ if(ioctl(Cport[comport_number], TIOCMSET, &status) == -1)
+ {
+ perror("unable to set portstatus");
+ }
+}
+
+
+void RS232_disableRTS(int comport_number)
+{
+ int status;
+
+ if(ioctl(Cport[comport_number], TIOCMGET, &status) == -1)
+ {
+ perror("unable to get portstatus");
+ }
+
+ status &= ~TIOCM_RTS; /* turn off RTS */
+
+ if(ioctl(Cport[comport_number], TIOCMSET, &status) == -1)
+ {
+ perror("unable to set portstatus");
+ }
+}
+
+
+void RS232_flushRX(int comport_number)
+{
+ tcflush(Cport[comport_number], TCIFLUSH);
+}
+
+
+void RS232_flushTX(int comport_number)
+{
+ tcflush(Cport[comport_number], TCOFLUSH);
+}
+
+
+void RS232_flushRXTX(int comport_number)
+{
+ tcflush(Cport[comport_number], TCIOFLUSH);
+}
+
+
+#else /* windows */
+
+#define RS232_PORTNR 16
+
+HANDLE Cport[RS232_PORTNR];
+
+
+char *comports[RS232_PORTNR]={"\\\\.\\COM1", "\\\\.\\COM2", "\\\\.\\COM3", "\\\\.\\COM4",
+ "\\\\.\\COM5", "\\\\.\\COM6", "\\\\.\\COM7", "\\\\.\\COM8",
+ "\\\\.\\COM9", "\\\\.\\COM10", "\\\\.\\COM11", "\\\\.\\COM12",
+ "\\\\.\\COM13", "\\\\.\\COM14", "\\\\.\\COM15", "\\\\.\\COM16"};
+
+char mode_str[128];
+
+
+int RS232_OpenComport(int comport_number, int baudrate, const char *mode)
+{
+ if((comport_number>=RS232_PORTNR)||(comport_number<0))
+ {
+ printf("illegal comport number\n");
+ return(1);
+ }
+
+ switch(baudrate)
+ {
+ case 110 : strcpy(mode_str, "baud=110");
+ break;
+ case 300 : strcpy(mode_str, "baud=300");
+ break;
+ case 600 : strcpy(mode_str, "baud=600");
+ break;
+ case 1200 : strcpy(mode_str, "baud=1200");
+ break;
+ case 2400 : strcpy(mode_str, "baud=2400");
+ break;
+ case 4800 : strcpy(mode_str, "baud=4800");
+ break;
+ case 9600 : strcpy(mode_str, "baud=9600");
+ break;
+ case 19200 : strcpy(mode_str, "baud=19200");
+ break;
+ case 38400 : strcpy(mode_str, "baud=38400");
+ break;
+ case 57600 : strcpy(mode_str, "baud=57600");
+ break;
+ case 115200 : strcpy(mode_str, "baud=115200");
+ break;
+ case 128000 : strcpy(mode_str, "baud=128000");
+ break;
+ case 256000 : strcpy(mode_str, "baud=256000");
+ break;
+ case 500000 : strcpy(mode_str, "baud=500000");
+ break;
+ case 1000000 : strcpy(mode_str, "baud=1000000");
+ break;
+ default : printf("invalid baudrate\n");
+ return(1);
+ break;
+ }
+
+ if(strlen(mode) != 3)
+ {
+ printf("invalid mode \"%s\"\n", mode);
+ return(1);
+ }
+
+ switch(mode[0])
+ {
+ case '8': strcat(mode_str, " data=8");
+ break;
+ case '7': strcat(mode_str, " data=7");
+ break;
+ case '6': strcat(mode_str, " data=6");
+ break;
+ case '5': strcat(mode_str, " data=5");
+ break;
+ default : printf("invalid number of data-bits '%c'\n", mode[0]);
+ return(1);
+ break;
+ }
+
+ switch(mode[1])
+ {
+ case 'N':
+ case 'n': strcat(mode_str, " parity=n");
+ break;
+ case 'E':
+ case 'e': strcat(mode_str, " parity=e");
+ break;
+ case 'O':
+ case 'o': strcat(mode_str, " parity=o");
+ break;
+ default : printf("invalid parity '%c'\n", mode[1]);
+ return(1);
+ break;
+ }
+
+ switch(mode[2])
+ {
+ case '1': strcat(mode_str, " stop=1");
+ break;
+ case '2': strcat(mode_str, " stop=2");
+ break;
+ default : printf("invalid number of stop bits '%c'\n", mode[2]);
+ return(1);
+ break;
+ }
+
+ strcat(mode_str, " dtr=on rts=on");
+
+/*
+http://msdn.microsoft.com/en-us/library/windows/desktop/aa363145%28v=vs.85%29.aspx
+
+http://technet.microsoft.com/en-us/library/cc732236.aspx
+*/
+
+ Cport[comport_number] = CreateFileA(comports[comport_number],
+ GENERIC_READ|GENERIC_WRITE,
+ 0, /* no share */
+ NULL, /* no security */
+ OPEN_EXISTING,
+ 0, /* no threads */
+ NULL); /* no templates */
+
+ if(Cport[comport_number]==INVALID_HANDLE_VALUE)
+ {
+ printf("unable to open comport\n");
+ return(1);
+ }
+
+ DCB port_settings;
+ memset(&port_settings, 0, sizeof(port_settings)); /* clear the new struct */
+ port_settings.DCBlength = sizeof(port_settings);
+
+ if(!BuildCommDCBA(mode_str, &port_settings))
+ {
+ printf("unable to set comport dcb settings\n");
+ CloseHandle(Cport[comport_number]);
+ return(1);
+ }
+
+ if(!SetCommState(Cport[comport_number], &port_settings))
+ {
+ printf("unable to set comport cfg settings\n");
+ CloseHandle(Cport[comport_number]);
+ return(1);
+ }
+
+ COMMTIMEOUTS Cptimeouts;
+
+ Cptimeouts.ReadIntervalTimeout = MAXDWORD;
+ Cptimeouts.ReadTotalTimeoutMultiplier = 0;
+ Cptimeouts.ReadTotalTimeoutConstant = 0;
+ Cptimeouts.WriteTotalTimeoutMultiplier = 0;
+ Cptimeouts.WriteTotalTimeoutConstant = 0;
+
+ if(!SetCommTimeouts(Cport[comport_number], &Cptimeouts))
+ {
+ printf("unable to set comport time-out settings\n");
+ CloseHandle(Cport[comport_number]);
+ return(1);
+ }
+
+ return(0);
+}
+
+
+int RS232_PollComport(int comport_number, unsigned char *buf, int size)
+{
+ int n;
+
+/* added the void pointer cast, otherwise gcc will complain about */
+/* "warning: dereferencing type-punned pointer will break strict aliasing rules" */
+
+ ReadFile(Cport[comport_number], buf, size, (LPDWORD)((void *)&n), NULL);
+
+ return(n);
+}
+
+
+int RS232_SendByte(int comport_number, unsigned char byte)
+{
+ int n;
+
+ WriteFile(Cport[comport_number], &byte, 1, (LPDWORD)((void *)&n), NULL);
+
+ if(n<0) return(1);
+
+ return(0);
+}
+
+
+int RS232_SendBuf(int comport_number, unsigned char *buf, int size)
+{
+ int n;
+
+ if(WriteFile(Cport[comport_number], buf, size, (LPDWORD)((void *)&n), NULL))
+ {
+ return(n);
+ }
+
+ return(-1);
+}
+
+
+void RS232_CloseComport(int comport_number)
+{
+ CloseHandle(Cport[comport_number]);
+}
+
+/*
+http://msdn.microsoft.com/en-us/library/windows/desktop/aa363258%28v=vs.85%29.aspx
+*/
+
+int RS232_IsDCDEnabled(int comport_number)
+{
+ int status;
+
+ GetCommModemStatus(Cport[comport_number], (LPDWORD)((void *)&status));
+
+ if(status&MS_RLSD_ON) return(1);
+ else return(0);
+}
+
+
+int RS232_IsCTSEnabled(int comport_number)
+{
+ int status;
+
+ GetCommModemStatus(Cport[comport_number], (LPDWORD)((void *)&status));
+
+ if(status&MS_CTS_ON) return(1);
+ else return(0);
+}
+
+
+int RS232_IsDSREnabled(int comport_number)
+{
+ int status;
+
+ GetCommModemStatus(Cport[comport_number], (LPDWORD)((void *)&status));
+
+ if(status&MS_DSR_ON) return(1);
+ else return(0);
+}
+
+
+void RS232_enableDTR(int comport_number)
+{
+ EscapeCommFunction(Cport[comport_number], SETDTR);
+}
+
+
+void RS232_disableDTR(int comport_number)
+{
+ EscapeCommFunction(Cport[comport_number], CLRDTR);
+}
+
+
+void RS232_enableRTS(int comport_number)
+{
+ EscapeCommFunction(Cport[comport_number], SETRTS);
+}
+
+
+void RS232_disableRTS(int comport_number)
+{
+ EscapeCommFunction(Cport[comport_number], CLRRTS);
+}
+
+/*
+https://msdn.microsoft.com/en-us/library/windows/desktop/aa363428%28v=vs.85%29.aspx
+*/
+
+void RS232_flushRX(int comport_number)
+{
+ PurgeComm(Cport[comport_number], PURGE_RXCLEAR | PURGE_RXABORT);
+}
+
+
+void RS232_flushTX(int comport_number)
+{
+ PurgeComm(Cport[comport_number], PURGE_TXCLEAR | PURGE_TXABORT);
+}
+
+
+void RS232_flushRXTX(int comport_number)
+{
+ PurgeComm(Cport[comport_number], PURGE_RXCLEAR | PURGE_RXABORT);
+ PurgeComm(Cport[comport_number], PURGE_TXCLEAR | PURGE_TXABORT);
+}
+
+
+#endif
+
+
+void RS232_cputs(int comport_number, const char *text) /* sends a string to serial port */
+{
+ while(*text != 0) RS232_SendByte(comport_number, *(text++));
+}
+
+
+/* return index in comports matching to device name or -1 if not found */
+int RS232_GetPortnr(const char *devname)
+{
+ int i;
+
+ char str[32];
+
+#if defined(__linux__) || defined(__FreeBSD__) /* Linux & FreeBSD */
+ strcpy(str, "/dev/");
+#else /* windows */
+ strcpy(str, "\\\\.\\");
+#endif
+ strncat(str, devname, 16);
+ str[31] = 0;
+
+ for(i=0; i<RS232_PORTNR; i++)
+ {
+ if(!strcmp(comports[i], str))
+ {
+ return i;
+ }
+ }
+
+ return -1; /* device not found */
+}
+
+
+
+
+
+
+
+
+
+
+
diff --git a/rs232.h b/rs232.h
new file mode 100644
index 0000000..e4fc8f6
--- /dev/null
+++ b/rs232.h
@@ -0,0 +1,86 @@
+/*
+***************************************************************************
+*
+* Author: Teunis van Beelen
+*
+* Copyright (C) 2005, 2006, 2007, 2008, 2009, 2010, 2011, 2012, 2013, 2014, 2015, 2016, 2017 Teunis van Beelen
+*
+* Email: teuniz@gmail.com
+*
+***************************************************************************
+*
+* This program is free software: you can redistribute it and/or modify
+* it under the terms of the GNU General Public License as published by
+* the Free Software Foundation, either version 3 of the License, or
+* (at your option) any later version.
+*
+* This program is distributed in the hope that it will be useful,
+* but WITHOUT ANY WARRANTY; without even the implied warranty of
+* MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the
+* GNU General Public License for more details.
+*
+* You should have received a copy of the GNU General Public License
+* along with this program. If not, see <http://www.gnu.org/licenses/>.
+*
+***************************************************************************
+*/
+
+/* Last revision: August 5, 2017 */
+
+/* For more info and how to use this library, visit: http://www.teuniz.net/RS-232/ */
+
+
+#ifndef rs232_INCLUDED
+#define rs232_INCLUDED
+
+#ifdef __cplusplus
+extern "C" {
+#endif
+
+#include <stdio.h>
+#include <string.h>
+
+
+
+#if defined(__linux__) || defined(__FreeBSD__)
+
+#include <termios.h>
+#include <sys/ioctl.h>
+#include <unistd.h>
+#include <fcntl.h>
+#include <sys/types.h>
+#include <sys/stat.h>
+#include <limits.h>
+#include <sys/file.h>
+#include <errno.h>
+
+#else
+
+#include <windows.h>
+
+#endif
+char * comports[38];
+int RS232_OpenComport(int, int, const char *);
+int RS232_PollComport(int, unsigned char *, int);
+int RS232_SendByte(int, unsigned char);
+int RS232_SendBuf(int, unsigned char *, int);
+void RS232_CloseComport(int);
+void RS232_cputs(int, const char *);
+int RS232_IsDCDEnabled(int);
+int RS232_IsCTSEnabled(int);
+int RS232_IsDSREnabled(int);
+void RS232_enableDTR(int);
+void RS232_disableDTR(int);
+void RS232_enableRTS(int);
+void RS232_disableRTS(int);
+void RS232_flushRX(int);
+void RS232_flushTX(int);
+void RS232_flushRXTX(int);
+int RS232_GetPortnr(const char *);
+#ifdef __cplusplus
+} /* extern "C" */
+#endif
+
+#endif
+
+