Erwan

- Merge some linux and Windows code in JGE to improve maintenance

JGE/src/pc/JSocket.cpp

@@ -0,0 +1,230 @@
+#pragma comment(lib,"WSOCK32.LIB")
+#include <stdio.h>
+#include <conio.h>
+#include <winsock.h>
+#include <errno.h>
+#include <winsock.h>
+
+#include "../../include/JSocket.h"
+JSocket * JSocket::mInstance = NULL;
+
+#define SERVER_PORT 20666
+unsigned char ADRESSE_IP_SERVEUR [4] = {127,0,0,1};
+
+
+int JSocket::connected = 0;
+
+void JSocket::init(){
+	//TODO ?
+}
+
+JSocket::JSocket(){
+  init();
+}
+
+JSocket::~JSocket(){
+ //TODO ?
+}
+
+
+void JSocket::readWrite(int val){
+  char data[1024];
+
+  	fd_set set;
+    FD_ZERO(&set);
+	  FD_SET(val, &set);
+    struct timeval tv;
+   int result = select(0, &set, NULL, NULL, &tv);
+		if( result< 0)
+		{
+      printf("Socket %d closed\n", val);
+		  closesocket(val);
+      connected= 0;
+			printf("select error\n");
+			return;
+		}
+    
+    if (result > 0){
+      OutputDebugString("Receiving!\n");
+      int readbytes = recv(val, data, sizeof(data),0);
+	    if(readbytes < 0)
+	    {
+        int error = WSAGetLastError();
+        if (error != WSAEWOULDBLOCK){
+		      printf("Socket %d closed\n", val);
+		      closesocket(val);
+          connected= 0;
+        }
+	    }
+	    else
+	    {
+        OutputDebugString("received Data!!!\n");
+		    for (int i = 0; i < readbytes; i++){
+		      received_data.push(data[i]);
+          OutputDebugString("getting byte\n");
+		    }
+	    }
+    }
+
+  //Write
+  int size = 0;
+  while(!tosend_data.empty()){
+    size++;
+    if (size > sizeof(data)){
+      send(val,data,sizeof(data),0);
+      size = 0;
+    }
+    data[size-1] = tosend_data.front();
+    tosend_data.pop();
+  }
+  if (size) {
+    send(val,data,size-1,0);
+    OutputDebugString("sending Data\n");
+  }
+}
+
+/* Start a client */
+int JSocket::start_client(const char *szIpAddr){
+  SOCKET Desc_Socket_Cliente;
+  SOCKADDR_IN Adresse_Socket_Serveur;
+  WORD wVersionRequested;
+  WSADATA wsaData;
+
+  struct hostent *hostentptr;
+
+  wVersionRequested=MAKEWORD(1,1);
+  WSAStartup(wVersionRequested,&wsaData);
+
+  Desc_Socket_Cliente=socket(AF_INET,SOCK_STREAM,0);
+  unsigned int addr_dest = inet_addr(szIpAddr); 
+  hostentptr=gethostbyaddr((char*) &addr_dest,4,AF_INET);
+
+  ZeroMemory(&Adresse_Socket_Serveur,sizeof(Adresse_Socket_Serveur));
+
+  Adresse_Socket_Serveur.sin_family=(*hostentptr).h_addrtype;
+  Adresse_Socket_Serveur.sin_port=htons(SERVER_PORT);
+  Adresse_Socket_Serveur.sin_addr=*((struct in_addr*)(*hostentptr).h_addr);
+
+  int result = connect(
+    Desc_Socket_Cliente,
+    (const struct sockaddr*)&Adresse_Socket_Serveur,
+    sizeof(Adresse_Socket_Serveur));
+
+OutputDebugString("client state 0\n");
+
+  if (result != 0){
+    connected = 0;
+    return 0;
+  }
+
+OutputDebugString("client state 1\n");
+
+
+  connected = 1;
+
+while(1){
+  readWrite(Desc_Socket_Cliente);
+/*  Nb_Caracteres_Recus=recv(Desc_Socket_Cliente,Message_Recu,sizeof(Message_Recu),0);
+  if(Nb_Caracteres_Recus<=0){
+    //continuer=FALSE;
+  }else{
+    strcpy(message,Message_Recu);
+    len=strlen(message);
+  }
+  */
+}
+#
+closesocket(Desc_Socket_Cliente);
+WSACleanup();
+return 0;
+}
+
+/* Start a server */
+int JSocket::start_server(const char *szIpAddr){
+  OutputDebugString("server state 0\n");
+  connected= 0;
+  int Code_Retour;
+  SOCKET Desc_Socket_Connection;
+  SOCKADDR_IN Adresse_Socket_Connection;
+  WORD wVersionRequested;
+  WSADATA wsaData;
+
+  wVersionRequested=MAKEWORD(1,1);
+
+  Code_Retour=WSAStartup(wVersionRequested,&wsaData);
+
+  if(Code_Retour!=0){
+    perror("WSAStartup\t");
+    _getch();
+    WSACleanup();
+    return Code_Retour;
+  }
+  OutputDebugString("server state 1\n");
+/*    printf("la version supportee est : %d.%d\n",
+LOBYTE(wsaData.wHighVersion),
+HIBYTE(wsaData.wHighVersion)
+);*/
+
+  Desc_Socket_Connection=socket( AF_INET, SOCK_STREAM,0);
+
+//printf("valeur de la socket = %d\n",Desc_Socket_Connection);
+
+  ZeroMemory(&Adresse_Socket_Connection,sizeof(Adresse_Socket_Connection));
+  Adresse_Socket_Connection.sin_family=AF_INET;
+  Adresse_Socket_Connection.sin_port=htons(SERVER_PORT);
+
+  Code_Retour=bind(Desc_Socket_Connection,
+    (struct sockaddr*)&Adresse_Socket_Connection,
+    sizeof(Adresse_Socket_Connection));
+
+
+
+  if(Code_Retour!=0){
+    perror("bind\t");
+    _getch();
+    closesocket(Desc_Socket_Connection);
+    WSACleanup();
+    return Code_Retour;
+  }
+  OutputDebugString("server state 3\n");
+
+  Code_Retour=listen(Desc_Socket_Connection,1);
+  if(Code_Retour!=0){
+    perror("listen\n");
+    WSACleanup();
+    return Code_Retour;
+  }
+  OutputDebugString("server state 4\n");
+  printf("serveur en attente d'une connection\n\n");
+  printf("***************arret du serveur par<CTRL><C>**************\n\n");
+  connected = 1;
+  while(1){
+    SOCKET * pt_Nouveau_Socket_Serveur;
+    SOCKADDR_IN Adresse_Socket_Cliente;
+    int Longueur_Adresse;
+
+    pt_Nouveau_Socket_Serveur = new SOCKET;
+
+    Longueur_Adresse = sizeof(Adresse_Socket_Cliente);
+
+    int val=accept(
+      Desc_Socket_Connection,
+      (struct sockaddr*)&Adresse_Socket_Cliente,
+      &Longueur_Adresse);
+    printf("connection accepte depuis le port client %d\n", ntohs(Adresse_Socket_Cliente.sin_port));
+      OutputDebugString("connection accepte depuis le port client\n");
+
+
+    while(1)
+    {
+	    readWrite(val);
+    }
+    closesocket(*pt_Nouveau_Socket_Serveur);
+    return 0;
+  }
+}
+
+
+
+
+