private Result processMirroredSolrRequest()

in crossdc-consumer/src/main/java/org/apache/solr/crossdc/messageprocessor/SolrMessageProcessor.java [173:196]

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

    private Result<MirroredSolrRequest> processMirroredSolrRequest(SolrRequest request) throws Exception {
        if (log.isTraceEnabled()) {
            log.trace("Sending request to Solr at ZK address={} with params {}", client.getZkStateReader().getZkClient().getZkServerAddress(), request.getParams());
        }
        Result<MirroredSolrRequest> result;

        SolrResponseBase response = (SolrResponseBase) request.process(client);

        int status = response.getStatus();

        if (log.isTraceEnabled()) {
            log.trace("result status={}", status);
        }

        if (status != 0) {
            metrics.counter("processedErrors").inc();
            throw new SolrException(SolrException.ErrorCode.getErrorCode(status), "response=" + response);
        }

        metrics.counter("processed").inc();

        result = new Result<>(ResultStatus.HANDLED);
        return result;
    }