Updated benchmark servers.

Author: ioquatix

benchmark/server/async.rb

@@ -5,19 +5,24 @@
 # Copyright, 2021-2024, by Samuel Williams.
 
 require "async"
-require "async/io/tcp_socket"
+require "socket"
+
+RESPONSE = "HTTP/1.1 204 No Content\r\nXonnection: close\r\n\r\n"
 
 port = Integer(ARGV.pop || 9090)
 
 Async do |task|
-	server = Async::IO::TCPServer.new("localhost", port)
+	server = TCPServer.new("localhost", port)
 
 	loop do
 		peer, address = server.accept
 
 		task.async do
-			peer.recv(1024)
-			peer.send("HTTP/1.1 204 No Content\r\nConnection: close\r\n\r\n")
+			while (peer.recv(1024) rescue nil)
+				sleep 0.02
+				peer.send(RESPONSE, 0)
+			end
+		ensure
 			peer.close
 		end
 	end

benchmark/server/event.rb

@@ -7,24 +7,26 @@
 require_relative "scheduler"
 require "io/nonblock"
 
+RESPONSE = "HTTP/1.1 204 No Content\r\nConnection: close\r\n\r\n"
+
 #scheduler = DirectScheduler.new
 scheduler = Scheduler.new
 Fiber.set_scheduler(scheduler)
 
 port = Integer(ARGV.pop || 9090)
 
-RESPONSE = "HTTP/1.1 204 No Content\r\nConnection: close\r\n\r\n"
-
 Fiber.schedule do
 	server = TCPServer.new("localhost", port)
 	server.listen(Socket::SOMAXCONN)
 
 	loop do
 		peer, address = server.accept
-
+		
 		Fiber.schedule do
-			peer.readpartial(1024) rescue nil
-			peer.write(RESPONSE)
+			while (peer.readpartial(1024) rescue nil)
+				peer.write(RESPONSE)
+			end
+			
 			peer.close
 		end
 	end

benchmark/server/gems.locked

@@ -0,0 +1,31 @@
+GEM
+  remote: https://rubygems.org/
+  specs:
+    async (2.23.1)
+      console (~> 1.29)
+      fiber-annotation
+      io-event (~> 1.9)
+      metrics (~> 0.12)
+      traces (~> 0.15)
+    console (1.30.2)
+      fiber-annotation
+      fiber-local (~> 1.1)
+      json
+    fiber-annotation (0.2.0)
+    fiber-local (1.1.0)
+      fiber-storage
+    fiber-storage (1.0.0)
+    io-event (1.10.0)
+    json (2.10.2)
+    metrics (0.12.2)
+    traces (0.15.2)
+
+PLATFORMS
+  arm64-darwin-24
+  ruby
+
+DEPENDENCIES
+  async
+
+BUNDLED WITH
+   2.6.2

benchmark/server/gems.rb

@@ -0,0 +1,3 @@
+source "https://rubygems.org"
+
+gem "async"

benchmark/server/loop.rb

@@ -6,15 +6,18 @@
 
 require "socket"
 
-port = Integer(ARGV.pop || 9090)
+RESPONSE = "HTTP/1.1 204 No Content\r\nConnection: close\r\n\r\n"
 
+port = Integer(ARGV.pop || 9090)
 server = TCPServer.new("localhost", port)
 
 loop do
 	peer, address = server.accept
 
-	peer.recv(1024)
-	peer.send("HTTP/1.1 204 No Content\r\nConnection: close\r\n\r\n", 0)
+	while (peer.recv(1024) rescue nil)
+		peer.send(RESPONSE, 0)
+	end
+	
 	peer.close
 end