mirror of
https://github.com/curl/curl.git
synced 2026-04-14 21:51:41 +03:00
e0dd6eb4a4
- examples: sync debug output printf masks. - INSTALL-CMAKE.md: tidy up section for some options. - curl_sha512_256: delete comment suggesting an optimization. - vtls/keylog: scope a variable. - vtls/openssl: make a source code URL a permalink. - vtls/schannel: drop redundant parentheses. - test1119.pl: robustify `$1` -> `$s`. - sync arg names in comments to match the code. - tidy up and minor fixes to comments. - fix formatting/indenting/comment/newline/include nits. - move `UNITTEST` protos next to definitions, sync their argument names. - make variables static. - add parentheses to Perl `open()` calls. - drop unnecessary double quotes in Perl. - clang-format. Closes #21000
103 lines
4.3 KiB
C
103 lines
4.3 KiB
C
/***************************************************************************
|
|
* _ _ ____ _
|
|
* Project ___| | | | _ \| |
|
|
* / __| | | | |_) | |
|
|
* | (__| |_| | _ <| |___
|
|
* \___|\___/|_| \_\_____|
|
|
*
|
|
* Copyright (C) Daniel Stenberg, <daniel@haxx.se>, et al.
|
|
*
|
|
* This software is licensed as described in the file COPYING, which
|
|
* you should have received as part of this distribution. The terms
|
|
* are also available at https://curl.se/docs/copyright.html.
|
|
*
|
|
* You may opt to use, copy, modify, merge, publish, distribute and/or sell
|
|
* copies of the Software, and permit persons to whom the Software is
|
|
* furnished to do so, under the terms of the COPYING file.
|
|
*
|
|
* This software is distributed on an "AS IS" basis, WITHOUT WARRANTY OF ANY
|
|
* KIND, either express or implied.
|
|
*
|
|
* SPDX-License-Identifier: curl
|
|
*
|
|
***************************************************************************/
|
|
#include "unitcheck.h"
|
|
#include "ratelimit.h"
|
|
|
|
static CURLcode test_unit3216(const char *arg)
|
|
{
|
|
UNITTEST_BEGIN_SIMPLE
|
|
struct Curl_rlimit r;
|
|
struct curltime ts;
|
|
|
|
/* A ratelimit that is unlimited */
|
|
ts = curlx_now();
|
|
Curl_rlimit_init(&r, 0, 0, &ts);
|
|
fail_unless(Curl_rlimit_avail(&r, &ts) == CURL_OFF_T_MAX, "inf");
|
|
Curl_rlimit_drain(&r, 1000000, &ts);
|
|
fail_unless(Curl_rlimit_avail(&r, &ts) == CURL_OFF_T_MAX, "drain keep inf");
|
|
fail_unless(Curl_rlimit_wait_ms(&r, &ts) == 0, "inf never waits");
|
|
|
|
Curl_rlimit_block(&r, TRUE, &ts);
|
|
fail_unless(Curl_rlimit_avail(&r, &ts) == 0, "inf blocked to 0");
|
|
Curl_rlimit_drain(&r, 1000000, &ts);
|
|
fail_unless(Curl_rlimit_avail(&r, &ts) == 0, "blocked inf");
|
|
Curl_rlimit_block(&r, FALSE, &ts);
|
|
fail_unless(Curl_rlimit_avail(&r, &ts) == CURL_OFF_T_MAX,
|
|
"unblocked unlimited");
|
|
|
|
/* A ratelimit that give 10 tokens per second */
|
|
ts = curlx_now();
|
|
Curl_rlimit_init(&r, 10, 0, &ts);
|
|
fail_unless(Curl_rlimit_avail(&r, &ts) == 10, "initial 10");
|
|
Curl_rlimit_drain(&r, 5, &ts);
|
|
fail_unless(Curl_rlimit_avail(&r, &ts) == 5, "drain to 5");
|
|
Curl_rlimit_drain(&r, 3, &ts);
|
|
fail_unless(Curl_rlimit_avail(&r, &ts) == 2, "drain to 2");
|
|
ts.tv_usec += 1000; /* 1ms */
|
|
Curl_rlimit_drain(&r, 3, &ts);
|
|
fail_unless(Curl_rlimit_avail(&r, &ts) == -1, "drain to -1");
|
|
fail_unless(Curl_rlimit_wait_ms(&r, &ts) == 1099, "wait 1099ms");
|
|
ts.tv_usec += 1000; /* 1ms */
|
|
fail_unless(Curl_rlimit_wait_ms(&r, &ts) == 1098, "wait 1098ms");
|
|
ts.tv_sec += 1;
|
|
fail_unless(Curl_rlimit_avail(&r, &ts) == 9, "10 inc per sec");
|
|
ts.tv_sec += 1;
|
|
fail_unless(Curl_rlimit_avail(&r, &ts) == 19, "10 inc per sec(2)");
|
|
|
|
ts = curlx_now();
|
|
Curl_rlimit_block(&r, TRUE, &ts);
|
|
fail_unless(Curl_rlimit_avail(&r, &ts) == 0, "10 blocked to 0");
|
|
Curl_rlimit_block(&r, FALSE, &ts);
|
|
fail_unless(Curl_rlimit_avail(&r, &ts) == 10, "unblocked 10");
|
|
|
|
/* A ratelimit that give 10 tokens per second, max burst 15/s */
|
|
ts = curlx_now();
|
|
Curl_rlimit_init(&r, 10, 15, &ts);
|
|
fail_unless(Curl_rlimit_avail(&r, &ts) == 10, "initial 10");
|
|
Curl_rlimit_drain(&r, 5, &ts);
|
|
fail_unless(Curl_rlimit_avail(&r, &ts) == 5, "drain to 5");
|
|
Curl_rlimit_drain(&r, 3, &ts);
|
|
fail_unless(Curl_rlimit_avail(&r, &ts) == 2, "drain to 2");
|
|
Curl_rlimit_drain(&r, 3, &ts);
|
|
fail_unless(Curl_rlimit_avail(&r, &ts) == -1, "drain to -1");
|
|
ts.tv_sec += 1;
|
|
fail_unless(Curl_rlimit_avail(&r, &ts) == 9, "10 inc per sec");
|
|
ts.tv_sec += 1;
|
|
fail_unless(Curl_rlimit_avail(&r, &ts) == 15, "10/15 burst limit");
|
|
ts.tv_sec += 1;
|
|
fail_unless(Curl_rlimit_avail(&r, &ts) == 15, "10/15 burst limit(2)");
|
|
Curl_rlimit_drain(&r, 15, &ts);
|
|
fail_unless(Curl_rlimit_avail(&r, &ts) == 0, "drain to 0");
|
|
fail_unless(Curl_rlimit_wait_ms(&r, &ts) == 1000, "wait 1 sec");
|
|
ts.tv_usec += 500000; /* half a sec, cheating on second carry */
|
|
fail_unless(Curl_rlimit_avail(&r, &ts) == 0, "0 after 0.5 sec");
|
|
fail_unless(Curl_rlimit_wait_ms(&r, &ts) == 500, "wait 0.5 sec");
|
|
ts.tv_sec += 1;
|
|
fail_unless(Curl_rlimit_avail(&r, &ts) == 10, "10 after 1.5 sec");
|
|
fail_unless(Curl_rlimit_wait_ms(&r, &ts) == 0, "wait 0");
|
|
ts.tv_usec += 500000; /* half a sec, cheating on second carry */
|
|
fail_unless(Curl_rlimit_avail(&r, &ts) == 15, "10 after 2 sec");
|
|
|
|
UNITTEST_END_SIMPLE
|
|
}
|