#53: + add logger for http server

Author: EdmondDantes

benchmarks/http_server_keepalive.php

@@ -2,10 +2,10 @@
 /**
  * HTTP Server with Keep-Alive Support
  * High-performance HTTP server implementation with connection pooling
- * 
+ *
  * Usage:
  *   php http_server_keepalive.php [host] [port]
- *   
+ *
  * Test with wrk:
  *   wrk -t12 -c400 -d30s --http1.1 http://127.0.0.1:8080/
  */
@@ -15,12 +15,19 @@
 
 use function Async\spawn;
 use function Async\await;
+use function Async\delay;
 
 // Configuration
 $host = $argv[1] ?? '127.0.0.1';
 $port = (int)($argv[2] ?? 8080);
 $keepaliveTimeout = 30; // seconds
 
+$socketCoroutines = 0;
+$socketCoroutinesRun = 0;
+$socketCoroutinesFinished = 0;
+$requestCount = 0;
+$requestHandled = 0;
+
 echo "=== Async HTTP Server with Keep-Alive ===\n";
 echo "Starting server on http://$host:$port\n";
 echo "Keep-Alive timeout: {$keepaliveTimeout}s\n";
@@ -43,15 +50,15 @@ function parseHttpRequest($request)
     // Fast path: find first space and second space to extract URI
     $firstSpace = strpos($request, ' ');
     if ($firstSpace === false) return '/';
-    
+
     $secondSpace = strpos($request, ' ', $firstSpace + 1);
     if ($secondSpace === false) return '/';
-    
+
     $uri = substr($request, $firstSpace + 1, $secondSpace - $firstSpace - 1);
-    
+
     // Check for Connection: close header (simple search)
     $connectionClose = stripos($request, 'connection: close') !== false;
-    
+
     return [
         'uri' => $uri,
         'connection_close' => $connectionClose
@@ -64,11 +71,11 @@ function parseHttpRequest($request)
 function processHttpRequest($client, $rawRequest)
 {
     global $cachedResponses;
-    
+
     $parsedRequest = parseHttpRequest($rawRequest);
     $uri = $parsedRequest['uri'];
     $shouldKeepAlive = !$parsedRequest['connection_close'];
-    
+
     // Use cached responses for static content
     if (isset($cachedResponses[$uri])) {
         $responseBody = $cachedResponses[$uri];
@@ -78,11 +85,11 @@ function processHttpRequest($client, $rawRequest)
         $responseBody = json_encode(['error' => 'Not Found', 'uri' => $uri], JSON_UNESCAPED_SLASHES);
         $statusCode = 404;
     }
-    
+
     // Build and send response directly
     $contentLength = strlen($responseBody);
     $statusText = $statusCode === 200 ? 'OK' : 'Not Found';
-    
+
     if ($shouldKeepAlive) {
         $response = 'HTTP/1.1 ' . $statusCode . ' ' . $statusText . "\r\n" .
                    'Content-Type: application/json' . "\r\n" .
@@ -97,13 +104,13 @@ function processHttpRequest($client, $rawRequest)
                    'Server: AsyncKeepAlive/1.0' . "\r\n" .
                    'Connection: close' . "\r\n\r\n" . $responseBody;
     }
-    
+
     $written = fwrite($client, $response);
-    
+
     if ($written === false) {
         return false; // Write failed
     }
-    
+
     return $shouldKeepAlive;
 }
 
@@ -113,53 +120,65 @@ function processHttpRequest($client, $rawRequest)
  */
 function handleSocket($client)
 {
+    global $socketCoroutinesRun, $socketCoroutinesFinished;
+    global $requestCount, $requestHandled;
+
+    $socketCoroutinesRun++;
+
     try {
         while (true) {
             $request = '';
             $totalBytes = 0;
-            
+
             // Read HTTP request with byte counting
             while (true) {
                 $chunk = fread($client, 1024);
-                
+
                 if ($chunk === false || $chunk === '') {
                     // Connection closed by client or read error
                     return;
                 }
-                
+
                 $request .= $chunk;
                 $totalBytes += strlen($chunk);
-                
+
                 // Check for request size limit
                 if ($totalBytes > 8192) {
                     // Request too large, close connection immediately
                     fclose($client);
+                    $requestCount++;
+                    $requestHandled++;
                     return;
                 }
-                
+
                 // Check if we have complete HTTP request (ends with \r\n\r\n)
                 if (strpos($request, "\r\n\r\n") !== false) {
                     break;
                 }
             }
-            
+
             if (empty(trim($request))) {
                 // Empty request, skip to next iteration
                 continue;
             }
-            
+
+            $requestCount++;
+
             // Process request and send response
             $shouldKeepAlive = processHttpRequest($client, $request);
-            
+
+            $requestHandled++;
+
             if ($shouldKeepAlive === false) {
                 // Write failed or connection should be closed
                 return;
             }
-            
+
             // Continue to next request in keep-alive connection
         }
-        
+
     } finally {
+        $socketCoroutinesFinished++;
         // Always clean up the socket
         if (is_resource($client)) {
             fclose($client);
@@ -173,37 +192,59 @@ function handleSocket($client)
  */
 function startHttpServer($host, $port) {
     return spawn(function() use ($host, $port) {
+
+        global $socketCoroutines;
+
         // Create server socket
         $server = stream_socket_server("tcp://$host:$port", $errno, $errstr, STREAM_SERVER_BIND | STREAM_SERVER_LISTEN);
         if (!$server) {
             throw new Exception("Could not create server: $errstr ($errno)");
         }
-        
+
+	stream_context_set_option($server, 'socket', 'tcp_nodelay', true);
+
         echo "Server listening on $host:$port\n";
         echo "Try: curl http://$host:$port/\n";
         echo "Benchmark: wrk -t12 -c400 -d30s http://$host:$port/\n\n";
-        
+
         // Simple accept loop - much cleaner!
         while (true) {
             // Accept new connections
             $client = stream_socket_accept($server, 0);
             if ($client) {
+                $socketCoroutines++;
                 // Spawn a coroutine to handle this client's entire lifecycle
                 spawn(handleSocket(...), $client);
             }
         }
-        
+
         fclose($server);
     });
 }
 
+spawn(function() {
+
+    global $socketCoroutines, $socketCoroutinesRun, $socketCoroutinesFinished, $requestCount, $requestHandled;
+
+    while(true) {
+        delay(2000);
+        echo "Sockets: $socketCoroutines\n";
+        echo "Coroutines: $socketCoroutinesRun\n";
+        echo "Finished: $socketCoroutinesFinished\n";
+        echo "Request: $requestCount\n";
+        echo "Handled: $requestHandled\n\n";
+    }
+});
 
 // Start server
 try {
     $serverTask = startHttpServer($host, $port);
     await($serverTask);
-    
+
 } catch (Exception $e) {
     echo "Server error: " . $e->getMessage() . "\n";
-    exit(1);
-}
+} finally {
+    echo "Sockets: $socketCoroutines\n";
+    echo "Coroutines: $socketCoroutinesRun\n";
+    echo "Finished: $socketCoroutinesFinished\n";
+}