if (crudMode != expectedMode) {
            throwValidationError(messages -> {
                messages.addErrorsCrudInvalidMode(GLOBAL, String.valueOf(expectedMode), String.valueOf(crudMode));
            }, this::asListHtml);
        }
    }

    // ===================================================================================

        if (crudMode != expectedMode) {
            throwValidationError(messages -> {
                messages.addErrorsCrudInvalidMode(GLOBAL, String.valueOf(expectedMode), String.valueOf(crudMode));
            }, this::asListHtml);
        }
    }

    // ===================================================================================

	var wg sync.WaitGroup
	var errOnce sync.Once
	var retError string
	var totalBytesWritten uint64
	var totalBytesRead uint64

	objCountPerThread := make([]uint64, opts.concurrency)

	uploadsCtx, uploadsCancel := context.WithTimeout(ctx, opts.duration)
	defer uploadsCancel()

	objNamePrefix := pathJoin(speedTest, mustGetUUID())

	userMetadata := make(map[string]string)

	_ = x[rebalStopped-3]
	_ = x[rebalFailed-4]
}

const _rebalStatus_name = "NoneStartedCompletedStoppedFailed"

var _rebalStatus_index = [...]uint8{0, 4, 11, 20, 27, 33}

func (i rebalStatus) String() string {
	if i >= rebalStatus(len(_rebalStatus_index)-1) {
		return "rebalStatus(" + strconv.FormatInt(int64(i), 10) + ")"
	}
	return _rebalStatus_name[_rebalStatus_index[i]:_rebalStatus_index[i+1]]

            // For testing purposes, return this instance (allowed by return type)
            return this;
        }

        @Override
        public SSPContext createContext(CIFSContext tc, String targetDomain, String host, byte[] initialToken, boolean doSigning)
                throws SmbException {
            // Not used within these tests
            throw new SmbException("not used in tests");
        }

     * @param message the detailed error message
     * @param cause the cause of the exception
     */
    public InvalidQueryException(final VaMessenger<FessMessages> messageCode, final String message, final Throwable cause) {
        super(message, cause);
        this.messageCode = messageCode;
    }

    /**
     * Creates a new InvalidQueryException with message code and message.
     *

  }

  override fun proxySelectEnd(
    url: HttpUrl,
    proxies: List<Proxy>,
  ) {
  }

  override fun dnsStart(socketHost: String) {
  }

  override fun dnsEnd(
    socketHost: String,
    result: List<InetAddress>,
  ) {
  }

        return 0;
    }

    @Override
    protected int readBytesWireFormat(final byte[] buffer, final int bufferIndex) {
        return 0;
    }

    @Override
    public String toString() {
        return ("SmbComQueryInformation[" + super.toString() + ",filename=" + this.path + "]");
    }

    /**
     * Returns the public ID of the XML
     * @return the public ID, or null if not available
     */
    String getPublicId();

    /**
     * Returns the system ID of the XML
     * @return the system ID, or null if not available
     */
    String getSystemId();

//
// This is a `MetricsLoaderFn`.
func loadBucketAPITTFBMetrics(ctx context.Context, m MetricValues, _ *metricsCache, buckets []string) error {
	renameLabels := map[string]string{"api": "name"}
	labelsFilter := map[string]set.StringSet{}
	m.SetHistogram(apiRequestsTTFBSecondsDistribution, bucketHTTPRequestsDuration, labelsFilter, renameLabels,
		buckets, "type", "s3")
	return nil