Limit inbound connections.

[ioquatix]

This is a PoC to demonstrate how to limit inbound connections.

Types of Changes

• New feature.

Contribution

• I added tests for my changes.
• I tested my changes locally.
• I agree to the Developer's Certificate of Origin 1.1.

[macournoyer]

Should this be in a loop? For the case when it's readable, but the semaphore can't be acquire.

Suggested change

	server.wait_readable
	# Acquire the semaphore:
	Console.info(self, "Acquiring semaphore...")
	token = semaphore.acquire
	token = loop do
	server.wait_readable
	# Acquire the semaphore:
	Console.info(self, "Acquiring semaphore...")
	break semaphore.try_acquire # acts like a acquire_nonblock, returns nil if not ready
	end

[ioquatix]

Hmm, that's an interesting point. I actually don't know the answer off the top of my head, I'll have to experiment and think about it a bit.