public function send()

in src/Apache/Ignite/Internal/Connection/ClientFailoverSocket.php [57:74]

• 18 lines of code
• 4 McCabe index (conditional complexity)

    public function send(int $opCode, ?callable $payloadWriter, callable $payloadReader = null): void
    {
        if ($this->reconnectRequired) {
            $this->failoverConnect();
            $this->reconnectRequired = false;
        }
        if ($this->state !== ClientFailoverSocket::STATE_CONNECTED) {
            throw new NoConnectionException();
        }
        try {
            $this->socket->sendRequest($opCode, $payloadWriter, $payloadReader);
        } catch (OperationStatusUnknownException $e) {
            $this->disconnect();
            $this->endpointIndex++;
            $this->reconnectRequired = true;
            throw $e;
        }
    }