Function handleControlStream

lambda/main.go:264–300

(stream quic.Stream, done chan<- error)

}

func handleControlStream(stream quic.Stream, done chan<- error) {
	defer stream.Close()
	shared.LogNetwork("Control stream established")
	
	for {
		opcode, nonce, err := shared.ReadControlMessage(stream)
		if err != nil {
			// EOF is expected when client disconnects - treat as normal shutdown
			if err == io.EOF || errors.Is(err, io.EOF) {
				shared.LogNetwork("Control stream EOF - client disconnected normally")
				done <- nil
				return
			}
			shared.LogError("Failed to read control message", err)
			// Signal completion on control stream error
			done <- err
			return
		}
		
		switch opcode {
		case shared.OpPing:
			// Respond with pong
			if err := shared.WritePong(stream, nonce); err != nil {
				shared.LogError("Failed to send pong", err)
				return
			}
			
		case shared.OpShutdown:
			shared.LogNetwork("Received shutdown signal, exiting immediately")
			done <- nil
			return
			
		default:
			shared.LogErrorf("Unknown control opcode: %02x", opcode)
		}
	}
}

func handleSOCKS5Stream(stream quic.Stream) {
	defer stream.Close()