Ajout des fichiers sources du websocket

thubert
Showing 4 changed files with 213 additions and 0 deletions Show diff stats
SerialWebsocket/main.c
SerialWebsocket/serial.c
SerialWebsocket/serial.h
SerialWebsocket/websocket.c
+++ a/SerialWebsocket/main.c
@@ -0,0 +1,40 @@
+/*
+ * Test on serial device
+ */
+
+////
+// Include files
+////
+#include <stdio.h>
+#include <stdlib.h>
+#include <unistd.h>
+#include <termios.h>
+
+#include "serial.h"
+
+////
+// Constants
+////
+#define         SERIAL_DEVICE           "/dev/ttyACM0"
+
+////
+// Global variables
+////
+
+////
+// Main function
+////
+
+int main(void){
+int c=0;
+int sd=serialOpen(SERIAL_DEVICE,SERIAL_BOTH);
+serialConfig(sd,B9600);
+if(write(sd,&c,sizeof(char))!=1){ perror("main.write"); exit(-1); }
+int i;
+for(i=0;i<8;i++){
+  if(read(sd,&c,sizeof(char))!=1){ perror("main.read"); exit(-1); }
+  printf("%02x\n",c);
+  }
+serialClose(sd);
+exit(0);
+}
 \ No newline at end of file
+++ a/SerialWebsocket/serial.c
@@ -0,0 +1,55 @@
+/*
+ * Serial library
+ */
+
+////
+// Include files
+////
+#include <stdio.h>
+#include <stdlib.h>
+#include <unistd.h>
+#include <fcntl.h>
+#include <termios.h>
+#include <strings.h>
+#include <sys/types.h>
+#include <sys/ioctl.h>
+#include <sys/file.h>
+#include <linux/serial.h>
+
+#include "serial.h"
+
+////
+// Functions
+////
+
+//
+// Open serial port device
+//
+int serialOpen(char *device,int mode){
+int flags=(mode==SERIAL_READ?O_RDONLY:(mode==SERIAL_WRITE?O_WRONLY:O_RDWR));
+int fd=open(device,flags|O_NOCTTY); 
+if(fd<0){ perror(device); exit(-1); }
+return fd;
+}
+
+//
+// Serial port configuration
+//
+void serialConfig(int fd,int speed){
+struct termios new;
+bzero(&new,sizeof(new));
+new.c_cflag=CLOCAL|CREAD|speed|CS8;
+new.c_iflag=0;
+new.c_oflag=0;
+new.c_lflag=0;     /* set input mode (non-canonical, no echo,...) */
+new.c_cc[VTIME]=0; /* inter-character timer unused */
+new.c_cc[VMIN]=1;  /* blocking read until 1 char received */
+if(tcsetattr(fd,TCSANOW,&new)<0){ perror("serialInit.tcsetattr"); exit(-1); }
+}
+
+//
+// Serial port termination
+//
+void serialClose(int fd){
+close(fd);
+}
 \ No newline at end of file
+++ a/SerialWebsocket/serial.h
@@ -0,0 +1,18 @@
+/*
+ * Public definitions for serial library
+ */
+
+////
+// Constants
+////
+
+#define SERIAL_READ 0
+#define SERIAL_WRITE 1
+#define SERIAL_BOTH 2
+
+////
+// Public prototypes
+////
+int serialOpen(char *device,int mode);
+void serialConfig(int fd,int speed);
+void serialClose(int fd);
 \ No newline at end of file
+++ a/SerialWebsocket/websocket.c
@@ -0,0 +1,100 @@
+#include <stdio.h>
+#include <stdlib.h>
+#include <string.h>
+#include <libwebsockets.h>
+#include <unistd.h>
+#include <termios.h>
+
+#include "serial.h"
+
+#define         SERIAL_DEVICE           "/dev/ttyACM0"
+ 
+#define MAX_FRAME_SIZE  1024
+#define WAIT_DELAY      50
+ 
+int sd;
+static int callback_http(
+  struct libwebsocket_context *this,
+  struct libwebsocket *wsi,enum libwebsocket_callback_reasons reason,
+  void *user,void *in,size_t len)
+{
+return 0;
+}
+ 
+static int callback_my(
+  struct libwebsocket_context * this,
+  struct libwebsocket *wsi,enum libwebsocket_callback_reasons reason,
+  void *user,void *in,size_t len)
+{
+static char *message=NULL;
+static int msize=0;
+switch(reason){
+  case LWS_CALLBACK_ESTABLISHED:
+    printf("connection established\n");
+    message=NULL;
+                // Declenchement d'un prochain envoi au navigateur
+    libwebsocket_callback_on_writable(this,wsi);
+    break;
+  case LWS_CALLBACK_RECEIVE:
+                // Ici sont traites les messages envoyes par le navigateur
+    printf("received data: %s\n",(char *)in);
+    write(sd,in,sizeof(char));
+    message=malloc(len+LWS_SEND_BUFFER_PRE_PADDING+LWS_SEND_BUFFER_POST_PADDING);
+    if(message==NULL){ perror("callback_my.malloc"); exit(EXIT_FAILURE); }
+    memcpy(message+LWS_SEND_BUFFER_PRE_PADDING,in,len);
+                // Declenchement d'un prochain envoi au navigateur
+    msize=len;
+    libwebsocket_callback_on_writable(this,wsi);
+    break;
+  case LWS_CALLBACK_SERVER_WRITEABLE:
+                // Ici sont envoyes les messages au navigateur
+    if(message!=NULL){
+      char *out=message+LWS_SEND_BUFFER_PRE_PADDING;
+      libwebsocket_write(wsi,(unsigned char *)out,msize,LWS_WRITE_TEXT);
+      free(message);
+      message=NULL;
+      }
+    break;
+  default:
+    break;
+  }
+return 0;
+}
+ 
+static struct libwebsocket_protocols protocols[] = {
+  {
+    "http-only",   // name
+    callback_http, // callback
+    0,             // data size
+    0              // maximum frame size
+  },
+  {"myprotocol",callback_my,0,MAX_FRAME_SIZE},
+  {NULL,NULL,0,0}
+  };
+ 
+int main(void) {
+//Initialisation de la liaison série
+int c=0;
+sd=serialOpen(SERIAL_DEVICE,SERIAL_BOTH);
+serialConfig(sd,B9600);
+
+//Websocket
+int port=9000;
+struct lws_context_creation_info info;
+memset(&info,0,sizeof info);
+info.port=port;
+info.protocols=protocols;
+info.gid=-1;
+info.uid=-1;
+struct libwebsocket_context *context=libwebsocket_create_context(&info);
+if(context==NULL){
+  fprintf(stderr, "libwebsocket init failed\n");
+  return -1;
+  }
+printf("starting server...\n");
+while(1){
+  libwebsocket_service(context,WAIT_DELAY);
+  }
+libwebsocket_context_destroy(context);
+return 0;
+}