From 8c590cd15470b36afcacd0417b77e1ddfeb41210 Mon Sep 17 00:00:00 2001 From: johan Date: Sat, 7 Jan 2023 08:49:44 +0100 Subject: [PATCH 01/32] =?UTF-8?q?ajout=20de=20message=20au=20cas=20o=C3=B9?= =?UTF-8?q?=20socket=20create=20et=20socket=20bind=20aurait=20=C3=A9chou?= =?UTF-8?q?=C3=A9?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- WEB/server.php | 13 +++++++++++++ 1 file changed, 13 insertions(+) diff --git a/WEB/server.php b/WEB/server.php index 08a1f4f1..3ddb0750 100644 --- a/WEB/server.php +++ b/WEB/server.php @@ -15,10 +15,23 @@ ob_implicit_flush(); // Créer une socket d'écoute $socket = socket_create(AF_INET, SOCK_STREAM,0) or die("la socket n'a pas pu être crée ERROR : ".socket_strerror(socket_last_error())."\n"); +if($socket===false) +{ + echo "socket_create a échoué : " . socket_strerror(socket_last_error()) . "\n"; +} else { + echo "socket_create a réussi.\n"; +} // Attacher la socket à unde adresse ip et un port $result = socket_bind($socket, $serverAdress, $port) or die("la socket n'a pas pu être attachée à l'adresse ip et au port ERROR : ".socket_strerror(socket_last_error())."\n"); +if ($result === false) { + // L'attachement de la socket à l'adresse et au port a échoué + echo "socket_bind a échoué : " . socket_strerror(socket_last_error()) . "\n"; +} else { + echo "socket_bind a réussi.\n"; + // L'attachement de la socket à l'adresse et au port a réussi +} socket_set_block($socket) or die("N'a pas pu mettre la socket en mode bloquant ERROR : ".socket_strerror(socket_last_error())."\n"); From 12910b5e20b26bf61af8f84ff855c1559393167b Mon Sep 17 00:00:00 2001 From: johan Date: Sat, 7 Jan 2023 08:52:27 +0100 Subject: [PATCH 02/32] ajout de message d'erreur pour socket listen --- WEB/server.php | 7 +++++++ 1 file changed, 7 insertions(+) diff --git a/WEB/server.php b/WEB/server.php index 3ddb0750..76ea3b0b 100644 --- a/WEB/server.php +++ b/WEB/server.php @@ -58,6 +58,13 @@ while(true) { // Commencer à écouter sur le port $result = socket_listen($socket, 10) or die ("N'a pas pu configurer l'écoute sur la socket ERROR : ".socket_strerror(socket_last_error())."\n"); + if ($result === false) { + // L'écoute sur le port a échoué + echo "socket_listen a échoué : " . socket_strerror(socket_last_error()) . "\n"; + } else { + echo "socket listen sur le port :".$port."\n"; + // L'écoute sur le port a réussi + } //Si c'est une connection entrante, on la rajoute à la liste des sockets à surveiller if(in_array($socket,$read)) From f481d9e6242b18abc7603c012b3c74cbdf88ac3b Mon Sep 17 00:00:00 2001 From: johan Date: Sat, 7 Jan 2023 09:27:45 +0100 Subject: [PATCH 03/32] test --- WEB/server.php | 18 +++++++++++++++--- 1 file changed, 15 insertions(+), 3 deletions(-) diff --git a/WEB/server.php b/WEB/server.php index 76ea3b0b..36bb98c6 100644 --- a/WEB/server.php +++ b/WEB/server.php @@ -33,7 +33,14 @@ if ($result === false) { // L'attachement de la socket à l'adresse et au port a réussi } -socket_set_block($socket) or die("N'a pas pu mettre la socket en mode bloquant ERROR : ".socket_strerror(socket_last_error())."\n"); +$result=socket_set_block($socket) or die("N'a pas pu mettre la socket en mode bloquant ERROR : ".socket_strerror(socket_last_error())."\n"); +if ($result === false) { + // La mise en mode bloquant de la socket a échoué + echo "socket_set_block a échoué : " . socket_strerror(socket_last_error()) . "\n"; +} else { + echo "socket_set_block a réussi.\n"; + // La mise en mode bloquant de la socket a réussi +} // tableau des sockets à surveiller en lecture $read=array($socket); @@ -54,6 +61,8 @@ $response=''; $request=''; +$client=null; + while(true) { // Commencer à écouter sur le port @@ -70,13 +79,16 @@ while(true) { if(in_array($socket,$read)) { // Accepter la connection entrante - if($client = socket_accept($socket) == false) + if($client = socket_accept($socket) === false || $client===null) { echo "N'a pas pu accepter la connection entrante ERROR : ".socket_strerror(socket_last_error())."\n"; return; } + else + { + $read[]=$client; + } // Ajouter la socket du client à la liste des sockets à surveiller - $read[]=$client; } var_dump($client); From a3e47bc1d8f64c3a407a8ee871388187daa9cabd Mon Sep 17 00:00:00 2001 From: johan Date: Sat, 7 Jan 2023 09:38:35 +0100 Subject: [PATCH 04/32] test --- WEB/Client/Client.php | 1 - 1 file changed, 1 deletion(-) diff --git a/WEB/Client/Client.php b/WEB/Client/Client.php index 16d83e46..42f4992e 100644 --- a/WEB/Client/Client.php +++ b/WEB/Client/Client.php @@ -32,7 +32,6 @@ class Client{ header('Location : '.$rep.$vues['Queue']); } } - sleep(1); } socket_close($socket); } From 8da07f2000ed2836d1a62e8257fcfd0425bd908c Mon Sep 17 00:00:00 2001 From: johan Date: Sat, 7 Jan 2023 09:38:45 +0100 Subject: [PATCH 05/32] test --- WEB/server.php | 4 +--- 1 file changed, 1 insertion(+), 3 deletions(-) diff --git a/WEB/server.php b/WEB/server.php index 36bb98c6..b8a8665a 100644 --- a/WEB/server.php +++ b/WEB/server.php @@ -61,8 +61,6 @@ $response=''; $request=''; -$client=null; - while(true) { // Commencer à écouter sur le port @@ -79,7 +77,7 @@ while(true) { if(in_array($socket,$read)) { // Accepter la connection entrante - if($client = socket_accept($socket) === false || $client===null) + if($client = socket_accept($socket) === false) { echo "N'a pas pu accepter la connection entrante ERROR : ".socket_strerror(socket_last_error())."\n"; return; From 5a9f8fde49d1acc7f753d5638ad92dbb0ea9fe45 Mon Sep 17 00:00:00 2001 From: johan Date: Sat, 7 Jan 2023 09:49:46 +0100 Subject: [PATCH 06/32] test --- WEB/server.php | 1 - 1 file changed, 1 deletion(-) diff --git a/WEB/server.php b/WEB/server.php index b8a8665a..3dc77e87 100644 --- a/WEB/server.php +++ b/WEB/server.php @@ -80,7 +80,6 @@ while(true) { if($client = socket_accept($socket) === false) { echo "N'a pas pu accepter la connection entrante ERROR : ".socket_strerror(socket_last_error())."\n"; - return; } else { From 421275d2a4f742b60a71b3192b69d8e0909a07d6 Mon Sep 17 00:00:00 2001 From: johan Date: Sat, 7 Jan 2023 09:57:23 +0100 Subject: [PATCH 07/32] test --- WEB/server.php | 31 +++++++++++++------------------ 1 file changed, 13 insertions(+), 18 deletions(-) diff --git a/WEB/server.php b/WEB/server.php index 3dc77e87..3132adaa 100644 --- a/WEB/server.php +++ b/WEB/server.php @@ -94,26 +94,21 @@ while(true) { //Met la requête du client dans $request et verifie si la requête est valide //Si la requête est valide, éxécute la méthode du requestHandler correspondante //Sinon, envoie un message d'erreur au client - if(in_array($client,$read)) - { - $request=socket_read($client,$BUFFER_SIZE); - if($request!=false) - { - $requestHandler = new RequestHandler($request); - if(method_exists($requestHandler,$request)) - { - $response=$requestHandler->explode(' ',$request)[0]($client,$request); - } - else - { - $response="Invalid request"; + if ($client != false) { + if (in_array($client, $read)) { + $request = socket_read($client, $BUFFER_SIZE); + if ($request != false) { + $requestHandler = new RequestHandler($request); + if (method_exists($requestHandler, $request)) { + $response = $requestHandler->explode(' ', $request)[0]($client, $request); + } else { + $response = "Invalid request"; + // socket_write($client,$response,strlen($response)); + } + } else { + $response = "Response is false"; // socket_write($client,$response,strlen($response)); } } - else - { - $response="Response is false"; - // socket_write($client,$response,strlen($response)); - } } } \ No newline at end of file From b86b4a56c646292c2ab5ba651835fca2022b3308 Mon Sep 17 00:00:00 2001 From: johan Date: Sat, 7 Jan 2023 10:03:28 +0100 Subject: [PATCH 08/32] test --- WEB/Client/Client.php | 30 ++++++++++++++++++++++++++++++ 1 file changed, 30 insertions(+) diff --git a/WEB/Client/Client.php b/WEB/Client/Client.php index 42f4992e..a39e1705 100644 --- a/WEB/Client/Client.php +++ b/WEB/Client/Client.php @@ -18,6 +18,36 @@ class Client{ $socket = socket_create(AF_INET, SOCK_STREAM, 0) or die("la socket n'a pas pu être créée ERROR : ".socket_strerror(socket_last_error())."\n"); // connecter la socket à l'adresse ip et au port du serveur $result = socket_connect($socket, $serverAdress, $port) or die("Impossible de se connecter au serveur ERROR : ".socket_strerror(socket_last_error())."\n"); + if ($result === false) { + // La connexion de la socket à l'adresse et au port a échoué + echo "socket_connect a échoué : " . socket_strerror(socket_last_error()) . "\n"; + } else { + echo "socket_connect a réussi.\n"; + $request="Queuing"; + $result=socket_write($socket,$request,strlen($request)); + if($result === false) { + echo "socket_write a échoué : " . socket_strerror(socket_last_error()) . "\n"; + } else { + echo "socket_write a réussi.\n"; + } + $response=""; + while(strcmp($response,"launchGame")!=0){ + $response=socket_read($socket, $BUFFER_SIZE); + if($response!=false) + { + echo "socket_read a réussi.\n"; + if(strcmp($response,"refreshQueue")==0) + { + $userGroup = $userModel->findUsersInQueue(); + $numberOfPlayer=count($userGroup); + header('Location : '.$rep.$vues['Queue']); + } + } + else{ + echo "socket_read a échoué : " . socket_strerror(socket_last_error()) . "\n"; + } + } + } $request="Queuing"; socket_write($socket,$request,strlen($request)); $response=""; From 9f8139de756aac1d330662682e3171ebcc749fc3 Mon Sep 17 00:00:00 2001 From: johan Date: Sat, 7 Jan 2023 10:06:45 +0100 Subject: [PATCH 09/32] test --- WEB/Client/Client.php | 16 ---------------- 1 file changed, 16 deletions(-) diff --git a/WEB/Client/Client.php b/WEB/Client/Client.php index a39e1705..2a7c5216 100644 --- a/WEB/Client/Client.php +++ b/WEB/Client/Client.php @@ -48,21 +48,5 @@ class Client{ } } } - $request="Queuing"; - socket_write($socket,$request,strlen($request)); - $response=""; - while(strcmp($response,"launchGame")!=0){ - $response=socket_read($socket, $BUFFER_SIZE); - if($response!=false) - { - if(strcmp($response,"refreshQueue")==0) - { - $userGroup = $userModel->findUsersInQueue(); - $numberOfPlayer=count($userGroup); - header('Location : '.$rep.$vues['Queue']); - } - } - } - socket_close($socket); } } \ No newline at end of file From aeb4a29b58a76b3aa7c966152099ae4cf998f3d4 Mon Sep 17 00:00:00 2001 From: johan Date: Sat, 7 Jan 2023 10:14:58 +0100 Subject: [PATCH 10/32] test --- WEB/Client/Client.php | 1 + 1 file changed, 1 insertion(+) diff --git a/WEB/Client/Client.php b/WEB/Client/Client.php index 2a7c5216..8f9aaffa 100644 --- a/WEB/Client/Client.php +++ b/WEB/Client/Client.php @@ -45,6 +45,7 @@ class Client{ } else{ echo "socket_read a échoué : " . socket_strerror(socket_last_error()) . "\n"; + break; } } } From 938b3302ee02f0e90863b294e103ff4962f839ef Mon Sep 17 00:00:00 2001 From: johan Date: Sat, 7 Jan 2023 10:23:09 +0100 Subject: [PATCH 11/32] test --- WEB/Controller/UserController.php | 1 - 1 file changed, 1 deletion(-) diff --git a/WEB/Controller/UserController.php b/WEB/Controller/UserController.php index 3eecc8e1..b0f05b48 100644 --- a/WEB/Controller/UserController.php +++ b/WEB/Controller/UserController.php @@ -176,7 +176,6 @@ class UserController $model->addToQueue(); $client = Client::getInstance(); $client->Queuing(); - header('Location: index.php?action=launchGame'); } catch (Exception $e) { $error = $e->getMessage(); require($rep . $vues['erreur']); From 27457f946ed9f5c40e3d41278f2ed3f50f3090ce Mon Sep 17 00:00:00 2001 From: johan Date: Sat, 7 Jan 2023 10:26:00 +0100 Subject: [PATCH 12/32] test --- WEB/server.php | 1 + 1 file changed, 1 insertion(+) diff --git a/WEB/server.php b/WEB/server.php index 3132adaa..ecd999d6 100644 --- a/WEB/server.php +++ b/WEB/server.php @@ -89,6 +89,7 @@ while(true) { } var_dump($client); + echo "socket_strerror(socket_last_error()) : ".socket_strerror(socket_last_error())."\n"; //si $client est dans le tableau des sockets à surveiller en lecture //Met la requête du client dans $request et verifie si la requête est valide From 718b43e5a511612eb8eace6e10d22821d364f5bc Mon Sep 17 00:00:00 2001 From: johan Date: Sat, 7 Jan 2023 10:27:16 +0100 Subject: [PATCH 13/32] test --- WEB/server.php | 2 ++ 1 file changed, 2 insertions(+) diff --git a/WEB/server.php b/WEB/server.php index ecd999d6..0e40f31a 100644 --- a/WEB/server.php +++ b/WEB/server.php @@ -61,6 +61,8 @@ $response=''; $request=''; +$client=false; + while(true) { // Commencer à écouter sur le port From 108b94f7d05c4926fc065c55c5e508f075199072 Mon Sep 17 00:00:00 2001 From: johan Date: Sat, 7 Jan 2023 10:28:34 +0100 Subject: [PATCH 14/32] test --- WEB/server.php | 3 ++- 1 file changed, 2 insertions(+), 1 deletion(-) diff --git a/WEB/server.php b/WEB/server.php index 0e40f31a..620a67ad 100644 --- a/WEB/server.php +++ b/WEB/server.php @@ -79,7 +79,8 @@ while(true) { if(in_array($socket,$read)) { // Accepter la connection entrante - if($client = socket_accept($socket) === false) + $client=socket_accept($socket); + if($client === false) { echo "N'a pas pu accepter la connection entrante ERROR : ".socket_strerror(socket_last_error())."\n"; } From 88863ad7ba943aa71d29a6e0af2bedfb157ddadb Mon Sep 17 00:00:00 2001 From: johan Date: Sat, 7 Jan 2023 10:29:44 +0100 Subject: [PATCH 15/32] test --- WEB/server.php | 1 + 1 file changed, 1 insertion(+) diff --git a/WEB/server.php b/WEB/server.php index 620a67ad..a231d0a7 100644 --- a/WEB/server.php +++ b/WEB/server.php @@ -4,6 +4,7 @@ require_once('./Config/Autoload.php'); Autoload::charger(); global $serverAdress,$port,$playerNumberPerGame; +$requestHandler = new RequestHandler(); // pas d'arrêt d'éxécution du script (No timeout) From c0234e82b1773c6fee30ad915501012b5977cf96 Mon Sep 17 00:00:00 2001 From: johan Date: Sat, 7 Jan 2023 10:31:37 +0100 Subject: [PATCH 16/32] test --- WEB/server.php | 1 + 1 file changed, 1 insertion(+) diff --git a/WEB/server.php b/WEB/server.php index a231d0a7..30ca2233 100644 --- a/WEB/server.php +++ b/WEB/server.php @@ -1,6 +1,7 @@ Date: Sat, 7 Jan 2023 10:33:16 +0100 Subject: [PATCH 17/32] test --- WEB/Model/requestHandler.php | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/WEB/Model/requestHandler.php b/WEB/Model/requestHandler.php index ee6de61b..8c1db4a0 100644 --- a/WEB/Model/requestHandler.php +++ b/WEB/Model/requestHandler.php @@ -1,5 +1,5 @@ Date: Sat, 7 Jan 2023 10:39:48 +0100 Subject: [PATCH 18/32] test --- WEB/server.php | 3 ++- 1 file changed, 2 insertions(+), 1 deletion(-) diff --git a/WEB/server.php b/WEB/server.php index 30ca2233..d7445915 100644 --- a/WEB/server.php +++ b/WEB/server.php @@ -106,7 +106,8 @@ while(true) { if ($request != false) { $requestHandler = new RequestHandler($request); if (method_exists($requestHandler, $request)) { - $response = $requestHandler->explode(' ', $request)[0]($client, $request); + $function=explode(' ',$request)[0]; + $response = $requestHandler->$function($client, $request); } else { $response = "Invalid request"; // socket_write($client,$response,strlen($response)); From dfcc1aeda040ab05b63674b2e0d83fc8be32ca36 Mon Sep 17 00:00:00 2001 From: johan Date: Sat, 7 Jan 2023 10:44:04 +0100 Subject: [PATCH 19/32] test --- WEB/server.php | 1 + 1 file changed, 1 insertion(+) diff --git a/WEB/server.php b/WEB/server.php index d7445915..23554276 100644 --- a/WEB/server.php +++ b/WEB/server.php @@ -107,6 +107,7 @@ while(true) { $requestHandler = new RequestHandler($request); if (method_exists($requestHandler, $request)) { $function=explode(' ',$request)[0]; + echo ($function); $response = $requestHandler->$function($client, $request); } else { $response = "Invalid request"; From d803db0833a4a059a6f521b4a7ac581fa031b892 Mon Sep 17 00:00:00 2001 From: johan Date: Sat, 7 Jan 2023 10:48:10 +0100 Subject: [PATCH 20/32] test --- WEB/server.php | 3 +-- 1 file changed, 1 insertion(+), 2 deletions(-) diff --git a/WEB/server.php b/WEB/server.php index 23554276..8a119045 100644 --- a/WEB/server.php +++ b/WEB/server.php @@ -5,7 +5,6 @@ require_once('./Model/RequestHandler.php'); Autoload::charger(); global $serverAdress,$port,$playerNumberPerGame; -$requestHandler = new RequestHandler(); // pas d'arrêt d'éxécution du script (No timeout) @@ -104,7 +103,7 @@ while(true) { if (in_array($client, $read)) { $request = socket_read($client, $BUFFER_SIZE); if ($request != false) { - $requestHandler = new RequestHandler($request); + $requestHandler = new RequestHandler(); if (method_exists($requestHandler, $request)) { $function=explode(' ',$request)[0]; echo ($function); From 641aa0e4c86d7dced14cafcd49b95778f08690a5 Mon Sep 17 00:00:00 2001 From: johan Date: Sat, 7 Jan 2023 10:52:06 +0100 Subject: [PATCH 21/32] test --- WEB/Model/requestHandler.php | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/WEB/Model/requestHandler.php b/WEB/Model/requestHandler.php index 8c1db4a0..d63941c2 100644 --- a/WEB/Model/requestHandler.php +++ b/WEB/Model/requestHandler.php @@ -10,7 +10,7 @@ class RequestHandler{ $this->socketsFromQueue=array(); } - public function Queuing(Socket $socket,string $request){ + public function Queuing($socket,string $request){ global $playerNumberPerGame; // Ajoute la connection à un tableau de connection des joueurs en attente From 68fd36639fa92d8f515fe1ec85241d60491c6ec2 Mon Sep 17 00:00:00 2001 From: Johan LACHENAL Date: Sat, 7 Jan 2023 10:52:48 +0100 Subject: [PATCH 22/32] =?UTF-8?q?Mise=20=C3=A0=20jour=20de=20'WEB/Model/Re?= =?UTF-8?q?questHandler.php'?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- WEB/Model/{requestHandler.php => RequestHandler.php} | 0 1 file changed, 0 insertions(+), 0 deletions(-) rename WEB/Model/{requestHandler.php => RequestHandler.php} (100%) diff --git a/WEB/Model/requestHandler.php b/WEB/Model/RequestHandler.php similarity index 100% rename from WEB/Model/requestHandler.php rename to WEB/Model/RequestHandler.php From 7c2921541abc490ba800e0d39f93b65ef45ab958 Mon Sep 17 00:00:00 2001 From: Johan LACHENAL Date: Sat, 7 Jan 2023 11:04:37 +0100 Subject: [PATCH 23/32] =?UTF-8?q?Mise=20=C3=A0=20jour=20de=20'WEB/Model/Re?= =?UTF-8?q?questHandler.php'?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- WEB/Model/RequestHandler.php | 9 +++++++-- 1 file changed, 7 insertions(+), 2 deletions(-) diff --git a/WEB/Model/RequestHandler.php b/WEB/Model/RequestHandler.php index d63941c2..da6b00f5 100644 --- a/WEB/Model/RequestHandler.php +++ b/WEB/Model/RequestHandler.php @@ -17,20 +17,25 @@ class RequestHandler{ $socketsFromQueue[]=$socket; + echo 'ajout de la connecion au tableau des connections en attente'.count($socketsFromQueue).'\n'; + // si le nombre de joueur par partie nécessaire est égal au nombre de connection encore dans la file d'attente // alors envoie à l'utilisateur de lancer la partie et ajoute l'ensemble de connection à un tableau de groupe de sockets avec comme paire clés valeurs // l'identifiant de la partie et l'ensemble de connections sinon envoie à tout les utilisateurs en file d'attente qu'il faut rafraichir la page de la file d'attente + echo 'nombre de joueurs en attente : '.count($socketsFromQueue).' nombre de joueurs par partie : '.$playerNumberPerGame.'\n'; if(count($socketsFromQueue)==$playerNumberPerGame) { + echo 'lancement de la partie\n'; $response="launchGame"; $idPartie=$this->partie_gateway->findPartieInQueue(); - $arraySocketGroup[$idPartie]= $socketsFromQueue; - $arraySocketGroup[$this->partie_gateway->findPartieInQueue()]=$socketsFromQueue; + echo 'id de la partie : '.$idPartie; + $arraySocketGroup[$idPartie]=$socketsFromQueue; $socketsFromQueue=array(); } else { + echo "rafraichissement de la file d'attente\n"; $response="refreshQueue"; } foreach($socketsFromQueue as $sock) From d3b7beedeeb7f3d79e9cda19c7c238dffe7e69f8 Mon Sep 17 00:00:00 2001 From: johan Date: Sat, 7 Jan 2023 11:07:48 +0100 Subject: [PATCH 24/32] test --- WEB/server.php | 3 ++- 1 file changed, 2 insertions(+), 1 deletion(-) diff --git a/WEB/server.php b/WEB/server.php index 8a119045..be57e5fe 100644 --- a/WEB/server.php +++ b/WEB/server.php @@ -106,8 +106,9 @@ while(true) { $requestHandler = new RequestHandler(); if (method_exists($requestHandler, $request)) { $function=explode(' ',$request)[0]; - echo ($function); + echo ($function."\n"); $response = $requestHandler->$function($client, $request); + echo 'response : '.$response."\n"; } else { $response = "Invalid request"; // socket_write($client,$response,strlen($response)); From 85a53db264b0727a2d8474b6e48b0d288f3de6c2 Mon Sep 17 00:00:00 2001 From: johan Date: Sat, 7 Jan 2023 11:13:32 +0100 Subject: [PATCH 25/32] test --- WEB/Client/Client.php | 1 + 1 file changed, 1 insertion(+) diff --git a/WEB/Client/Client.php b/WEB/Client/Client.php index 8f9aaffa..5f52acc0 100644 --- a/WEB/Client/Client.php +++ b/WEB/Client/Client.php @@ -15,6 +15,7 @@ class Client{ $userModel = new UserModel(); // pas d'arrêt d'éxécution du script (No timeout) set_time_limit(0); + sleep(1); $socket = socket_create(AF_INET, SOCK_STREAM, 0) or die("la socket n'a pas pu être créée ERROR : ".socket_strerror(socket_last_error())."\n"); // connecter la socket à l'adresse ip et au port du serveur $result = socket_connect($socket, $serverAdress, $port) or die("Impossible de se connecter au serveur ERROR : ".socket_strerror(socket_last_error())."\n"); From 6d534294813ce37a6a9a716cf8acab077ce30a18 Mon Sep 17 00:00:00 2001 From: johan Date: Sat, 7 Jan 2023 11:18:29 +0100 Subject: [PATCH 26/32] test --- WEB/Model/RequestHandler.php | 8 +++++++- 1 file changed, 7 insertions(+), 1 deletion(-) diff --git a/WEB/Model/RequestHandler.php b/WEB/Model/RequestHandler.php index da6b00f5..df6e9e50 100644 --- a/WEB/Model/RequestHandler.php +++ b/WEB/Model/RequestHandler.php @@ -38,9 +38,15 @@ class RequestHandler{ echo "rafraichissement de la file d'attente\n"; $response="refreshQueue"; } + var_dump($socketsFromQueue); foreach($socketsFromQueue as $sock) { - socket_write($sock,$response,strlen($response)) or die("N'a pas pu écrire à la socket\n"); + var_dump($sock); + $result=socket_write($sock,$response,strlen($response)) or die("N'a pas pu écrire à la socket\n"); + if($result===false) + { + echo "erreur d'écriture\n"; + } } } public function quitQueue(Socket $client,String $request){ From d1589e69a52156ac6fce2706ebcd7f1e509925bf Mon Sep 17 00:00:00 2001 From: johan Date: Sat, 7 Jan 2023 11:21:02 +0100 Subject: [PATCH 27/32] test --- WEB/Model/RequestHandler.php | 1 + 1 file changed, 1 insertion(+) diff --git a/WEB/Model/RequestHandler.php b/WEB/Model/RequestHandler.php index df6e9e50..058d32ed 100644 --- a/WEB/Model/RequestHandler.php +++ b/WEB/Model/RequestHandler.php @@ -39,6 +39,7 @@ class RequestHandler{ $response="refreshQueue"; } var_dump($socketsFromQueue); + var_dump($response); foreach($socketsFromQueue as $sock) { var_dump($sock); From 83852b8d96ac9647f5cf7615b98f97e3f4a4dca4 Mon Sep 17 00:00:00 2001 From: johan Date: Sat, 7 Jan 2023 11:31:21 +0100 Subject: [PATCH 28/32] test --- WEB/Client/Client.php | 2 +- WEB/Model/RequestHandler.php | 3 ++- 2 files changed, 3 insertions(+), 2 deletions(-) diff --git a/WEB/Client/Client.php b/WEB/Client/Client.php index 5f52acc0..33e28b99 100644 --- a/WEB/Client/Client.php +++ b/WEB/Client/Client.php @@ -13,9 +13,9 @@ class Client{ public function Queuing(){ global $port,$serverAdress,$rep,$vues, $BUFFER_SIZE; $userModel = new UserModel(); + sleep(5); // pas d'arrêt d'éxécution du script (No timeout) set_time_limit(0); - sleep(1); $socket = socket_create(AF_INET, SOCK_STREAM, 0) or die("la socket n'a pas pu être créée ERROR : ".socket_strerror(socket_last_error())."\n"); // connecter la socket à l'adresse ip et au port du serveur $result = socket_connect($socket, $serverAdress, $port) or die("Impossible de se connecter au serveur ERROR : ".socket_strerror(socket_last_error())."\n"); diff --git a/WEB/Model/RequestHandler.php b/WEB/Model/RequestHandler.php index 058d32ed..0a8cc1bc 100644 --- a/WEB/Model/RequestHandler.php +++ b/WEB/Model/RequestHandler.php @@ -44,7 +44,8 @@ class RequestHandler{ { var_dump($sock); $result=socket_write($sock,$response,strlen($response)) or die("N'a pas pu écrire à la socket\n"); - if($result===false) + var_dump($result); + if($result==false) { echo "erreur d'écriture\n"; } From 8d34f14a8577fa030acdc208644b8d45a34b173f Mon Sep 17 00:00:00 2001 From: johan Date: Sat, 7 Jan 2023 11:43:23 +0100 Subject: [PATCH 29/32] test --- WEB/Client.php | 51 +++++++++++++++++++++++++++++++++++++++++++ WEB/Client/Client.php | 6 +++++ 2 files changed, 57 insertions(+) create mode 100644 WEB/Client.php diff --git a/WEB/Client.php b/WEB/Client.php new file mode 100644 index 00000000..d4175fca --- /dev/null +++ b/WEB/Client.php @@ -0,0 +1,51 @@ +findUsersInQueue(); + $numberOfPlayer=count($userGroup); + header('Location : '.$rep.$vues['Queue']); + } + } + else{ + echo "socket_read a échoué : " . socket_strerror(socket_last_error()) . "\n"; + break; + } + } + } \ No newline at end of file diff --git a/WEB/Client/Client.php b/WEB/Client/Client.php index 33e28b99..7e20f665 100644 --- a/WEB/Client/Client.php +++ b/WEB/Client/Client.php @@ -18,6 +18,12 @@ class Client{ set_time_limit(0); $socket = socket_create(AF_INET, SOCK_STREAM, 0) or die("la socket n'a pas pu être créée ERROR : ".socket_strerror(socket_last_error())."\n"); // connecter la socket à l'adresse ip et au port du serveur + $result = socket_set_block($socket); + if($result === false) { + echo "socket_set_block a échoué : " . socket_strerror(socket_last_error()) . "\n"; + } else { + echo "socket_set_block a réussi.\n"; + } $result = socket_connect($socket, $serverAdress, $port) or die("Impossible de se connecter au serveur ERROR : ".socket_strerror(socket_last_error())."\n"); if ($result === false) { // La connexion de la socket à l'adresse et au port a échoué From dacb103455f15406e82afaf0156944bf039d3d01 Mon Sep 17 00:00:00 2001 From: johan Date: Sat, 7 Jan 2023 11:49:31 +0100 Subject: [PATCH 30/32] test --- WEB/Client.php | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/WEB/Client.php b/WEB/Client.php index d4175fca..683b4384 100644 --- a/WEB/Client.php +++ b/WEB/Client.php @@ -40,7 +40,7 @@ Autoload::charger(); { $userGroup = $userModel->findUsersInQueue(); $numberOfPlayer=count($userGroup); - header('Location : '.$rep.$vues['Queue']); + header('Location : '.$rep.$vues['queue']); } } else{ From ffe2ae9b073b6c54cd8973ac96dc33c3a69afacb Mon Sep 17 00:00:00 2001 From: johan Date: Sat, 7 Jan 2023 11:52:44 +0100 Subject: [PATCH 31/32] test --- WEB/server.php | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/WEB/server.php b/WEB/server.php index be57e5fe..8e2ba21a 100644 --- a/WEB/server.php +++ b/WEB/server.php @@ -25,7 +25,7 @@ if($socket===false) // Attacher la socket à unde adresse ip et un port -$result = socket_bind($socket, $serverAdress, $port) or die("la socket n'a pas pu être attachée à l'adresse ip et au port ERROR : ".socket_strerror(socket_last_error())."\n"); +$result = socket_bind($socket, $serverAdress, $port) or die("la socket n'a pas pu être attachée à l'adresse ip :".$serverAdress." et au port".$port." ERROR : ".socket_strerror(socket_last_error())."\n"); if ($result === false) { // L'attachement de la socket à l'adresse et au port a échoué echo "socket_bind a échoué : " . socket_strerror(socket_last_error()) . "\n"; From 37ed796b9c7f92a662adc7c6cb73ae2f8000b5d7 Mon Sep 17 00:00:00 2001 From: johan Date: Sat, 7 Jan 2023 11:56:14 +0100 Subject: [PATCH 32/32] test --- WEB/Client/Client.php | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/WEB/Client/Client.php b/WEB/Client/Client.php index 7e20f665..7b044828 100644 --- a/WEB/Client/Client.php +++ b/WEB/Client/Client.php @@ -47,7 +47,7 @@ class Client{ { $userGroup = $userModel->findUsersInQueue(); $numberOfPlayer=count($userGroup); - header('Location : '.$rep.$vues['Queue']); + header('Location : '.$rep.$vues['queue']); } } else{