servicetalk-client-api-internal/src/main/java/io/servicetalk/client/api/internal/RequestConcurrencyControllerMulti.java [37:51]:
- - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - -
    public Result tryRequest() {
        final int maxConcurrency = lastSeenMaxValue(maxRequests);
        for (;;) {
            final int currentPending = pendingRequests();
            if (currentPending < 0) {
                return RejectedPermanently;
            }
            if (currentPending >= maxConcurrency) {
                return RejectedTemporary;
            }
            if (casPendingRequests(currentPending, currentPending + 1)) {
                return Accepted;
            }
        }
    }
- - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - -



servicetalk-client-api-internal/src/main/java/io/servicetalk/client/api/internal/ReservableRequestConcurrencyControllerMulti.java [37:51]:
- - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - -
    public Result tryRequest() {
        final int maxConcurrency = lastSeenMaxValue(maxRequests);
        for (;;) {
            final int currentPending = pendingRequests();
            if (currentPending < 0) {
                return RejectedPermanently;
            }
            if (currentPending >= maxConcurrency) {
                return RejectedTemporary;
            }
            if (casPendingRequests(currentPending, currentPending + 1)) {
                return Accepted;
            }
        }
    }
- - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - -