test

WEB/Client/Queing.php

@@ -41,7 +41,9 @@ class Queuing extends Threaded
                 echo "socket_write a réussi.\n";
             }
             $response = "";
-            while (strcmp($response, "launchGame") != 0) {
+            // while (strcmp($response, "launchGame") != 0) {
+            $i = 0;
+            while ($i != 2) {
                 $response = socket_read($socket, $BUFFER_SIZE);
                 echo $response;
                 if ($response != false) {
@@ -55,6 +57,8 @@ class Queuing extends Threaded
                     echo "socket_read a échoué : " . socket_strerror(socket_last_error()) . "\n";
                     break;
                 }
+                sleep(5);
+                $i++;
             }
         }
     }

WEB/Controller/UserController.php

@@ -172,29 +172,10 @@ class UserController
             global $rep, $vues, $error; //$serverAdress,$port;
             $model = new UserModel();
             // $model->addToQueue();
-            // $client = Client::getInstance();
-            if (! function_exists('pcntl_fork')) die('PCNTL functions not available on this PHP installation');
-            switch ($pid = pcntl_fork()) {
-                case -1:
-                   // @fail
-                   die('Fork failed');
-                   break;
-          
-                case 0:
-                    // @child: Include() misbehaving code here
-                    sleep(20);
-                   break;
-          
-                default:
-                   // @parent
-                   require($rep . $vues['queue']);
-                   $ret=pcntl_wait($status); //Protect against Zombie children
-                    if ($ret == -1 || !pcntl_wifexited($status)) {
-                        $error = "Erreur Inconnue";
-                        require($rep . $vues['erreur']);
-                    }
-                   break;
-            }
+            $client = Client::getInstance();
+            require($rep . $vues['queue']);
+            // new Queuing();
+            $client->Queuing();
         } catch (Exception $e) {
             $error = $e->getMessage();
             require($rep . $vues['erreur']);