[Load Balancer] Direct socket communication to the workers

[ammarfaizi2]

Currently, the master daemon needs to receive full data from client before it forwards the received data to the logger and responder workers.

The problem is that we need to notice the client which communicates with master daemon, whether the data is received successfully by the worker or not.

tea-inside-bot-s8/daemon/telegram/master.php

Lines 36 to 58 in 29b0a1f

	function conn_handler($conn)
	{
	stream_set_timeout($conn, 5);
	$rawData = fread($conn, 4096);
	$dataLen = unpack("S", substr($rawData, 0, 2))[1];
	$receivedLen = strlen($rawData);
	/* Read more if the payload has not been received completely. */
	while ($dataLen > $receivedLen) {
	$rawData .= fread($conn, 4096);
	$receivedLen = strlen($rawData);
	}
	// go(function () use ($conn, $rawData, $receivedLen) {
	// send_to_responder($conn, $rawData, $receivedLen);
	// });
	go(function () use ($conn, $rawData, $receivedLen) {
	send_to_logger($conn, $rawData, $receivedLen);
	});
	fwrite($conn, "ok");
	fclose($conn);
	}