private final AtomicLong totalIpsBlocked = new AtomicLong(0);

    /**
     * Create rate limiter with default settings
     */
    public AuthenticationRateLimiter() {
        this(5, 10, 100, Duration.ofMinutes(30), Duration.ofMinutes(5));
    }

    /**
     * Create rate limiter with custom settings
     *
     * @param maxAttemptsPerAccount max failed attempts per account before lockout

    # since we're creating a new limiter for each call, any non-zero limit
    # works (1 is arbitrary)
    exit_limiter = CapacityLimiter(1)
    try:
        yield await run_in_threadpool(cm.__enter__)
    except Exception as e:
        ok = bool(
            await anyio.to_thread.run_sync(
                cm.__exit__, type(e), e, e.__traceback__, limiter=exit_limiter
            )
        )
        if not ok:

    protected NGramSynonymTokenizer(final int n, final String delimiters, final boolean expand, final boolean ignoreCase,
            final SynonymLoader synonymLoader) {
        this.n = n;
        this.delimiters = delimiters;
        this.expand = expand;
        this.ignoreCase = ignoreCase;
        if (synonymLoader != null) {

 * <td>{@link DateFormat#SHORT} format without delimiters</td>
 * <td>{@literal yyMMdd}</td>
 * </tr>
 * <tr>
 * <td>{@link DateFormat#MEDIUM} format without delimiters</td>
 * <td>{@literal yyyyMMdd}</td>
 * </tr>
 * <tr>
 * <td>{@link DateFormat#LONG} format without delimiters</td>
 * <td>{@literal yyyyMMdd}</td>
 * </tr>
 * <tr>
 * <td>{@link DateFormat#FULL} format without delimiters</td>
 * <td>{@literal yyyyMMdd}</td>
 * </tr>

            }
            return Byte.valueOf((byte) 0);
        }
        return o;
    }

    /**
     * Removes delimiters.
     *
     * @param value
     *            String value
     * @param locale
     *            Locale
     * @return String result with delimiters removed
     */
    public static String removeDelimeter(String value, final Locale locale) {

 * <td>{@link DateFormat#SHORT} format without delimiters</td>
 * <td>{@literal HHmm}</td>
 * </tr>
 * <tr>
 * <td>{@link DateFormat#MEDIUM} format without delimiters</td>
 * <td>{@literal HHmmss}</td>
 * </tr>
 * <tr>
 * <td>{@link DateFormat#LONG} format without delimiters</td>
 * <td>{@literal HHmmss z}</td>
 * </tr>
 * <tr>
 * <td>{@link DateFormat#FULL} format without delimiters</td>
 * <td>{@literal HHmmss z}</td>
 * </tr>

            // The rate limiter should still be functional after concurrent access
            assertTrue(concurrentLimiter.checkAttempt("finaluser", "192.168.3.1"),
                    "Rate limiter should still be functional after concurrent operations");

            // Verify that the rate limiter tracked some activity

 * limitations under the License.
 */
package okhttp3.internal.http1

import okhttp3.Headers
import okio.BufferedSource

/**
 * Parse all headers delimited by "\r\n" until an empty line. This throws if headers exceed 256 KiB.
 */
class HeadersReader(
  val source: BufferedSource,
) {
  private var headerLimit = HEADER_LIMIT.toLong()

    private String category;

    /**
     * Indicates whether the video is suitable for family viewing.
     * If omitted, none is assumed.
     */
    private String familyFriendly;

    /**
     * A space-delimited list of countries where the video may or may not be played.
     */
    private String restriction;

    /**
     * The price to download or view the video.
     */
    private String price;

    /**

 * desirable to use in some unit tests. More importantly, attempting to debug a call which is
 * time-limited would be extremely annoying, so this gives you a time-limiter you can easily swap in
 * for your real time-limiter while you're debugging.
 *
 * @author Kevin Bourrillion
 * @author Jens Nyman
 * @since 1.0
 */
@J2ktIncompatible
@GwtIncompatible