private function processRequest()

in src/Apache/Ignite/Internal/Connection/ClientSocket.php [144:160]

• 17 lines of code
• 5 McCabe index (conditional complexity)

    private function processRequest(Request $request): void
    {
        $buffer = $request->getMessage();
        $this->logMessage($request->getId(), true, $buffer);
        $data = $buffer->getBuffer();
        while (($length = strlen($data)) > 0) {
            $written = fwrite($this->socket, $data, $this->sendChunkSize);
            if ($length === $written) {
                break;
            }
            if ($written === false || $written === 0) {
                throw new OperationStatusUnknownException('Error while writing data to the server');
            }
            $data = substr($data, $written);
        }
        $this->processResponse($request);
    }