Discover and fix new typos (#1446)
Upgrade `typos` and fix corresponding typos --------- Signed-off-by: Viktor Szépe <viktor@szepe.net>
This commit is contained in:
parent
ba25b586d5
commit
b66698b887
2
.github/workflows/spell-check.yml
vendored
2
.github/workflows/spell-check.yml
vendored
@ -26,7 +26,7 @@ jobs:
|
||||
uses: actions/checkout@b4ffde65f46336ab88eb53be808477a3936bae11 # v4.1.1
|
||||
|
||||
- name: Install typos
|
||||
uses: taiki-e/install-action@cd5df4de2e75f3b819ba55f780f7bb8cd4a05a41 # v2.32.2
|
||||
uses: taiki-e/install-action@fe9759bf4432218c779595708e80a1aadc85cedc # v2.46.10
|
||||
with:
|
||||
tool: typos
|
||||
|
||||
|
@ -48,7 +48,7 @@
|
||||
|
||||
/// @brief The usual PI/180 constant
|
||||
const double DEG_TO_RAD = 0.017453292519943295769236907684886;
|
||||
/// @brief Earth's quatratic mean radius for WGS-84
|
||||
/// @brief Earth's quadratic mean radius for WGS-84
|
||||
const double EARTH_RADIUS_IN_METERS = 6372797.560856;
|
||||
|
||||
const double MERCATOR_MAX = 20037726.37;
|
||||
|
@ -1702,7 +1702,7 @@ static void sendGetackToReplicas(void) {
|
||||
robj *argv[3];
|
||||
argv[0] = shared.replconf;
|
||||
argv[1] = shared.getack;
|
||||
argv[2] = shared.special_asterick; /* Not used argument. */
|
||||
argv[2] = shared.special_asterisk; /* Not used argument. */
|
||||
replicationFeedReplicas(-1, argv, 3);
|
||||
}
|
||||
|
||||
@ -2088,7 +2088,7 @@ void createSharedObjects(void) {
|
||||
shared.load = createStringObject("LOAD", 4);
|
||||
shared.createconsumer = createStringObject("CREATECONSUMER", 14);
|
||||
shared.getack = createStringObject("GETACK", 6);
|
||||
shared.special_asterick = createStringObject("*", 1);
|
||||
shared.special_asterisk = createStringObject("*", 1);
|
||||
shared.special_equals = createStringObject("=", 1);
|
||||
shared.redacted = makeObjectShared(createStringObject("(redacted)", 10));
|
||||
|
||||
|
@ -1444,7 +1444,7 @@ struct sharedObjectsStruct {
|
||||
*rpoplpush, *lmove, *blmove, *zpopmin, *zpopmax, *emptyscan, *multi, *exec, *left, *right, *hset, *srem,
|
||||
*xgroup, *xclaim, *script, *replconf, *eval, *persist, *set, *pexpireat, *pexpire, *time, *pxat, *absttl,
|
||||
*retrycount, *force, *justid, *entriesread, *lastid, *ping, *setid, *keepttl, *load, *createconsumer, *getack,
|
||||
*special_asterick, *special_equals, *default_username, *redacted, *ssubscribebulk, *sunsubscribebulk,
|
||||
*special_asterisk, *special_equals, *default_username, *redacted, *ssubscribebulk, *sunsubscribebulk,
|
||||
*smessagebulk, *select[PROTO_SHARED_SELECT_CMDS], *integers[OBJ_SHARED_INTEGERS],
|
||||
*mbulkhdr[OBJ_SHARED_BULKHDR_LEN], /* "*<value>\r\n" */
|
||||
*bulkhdr[OBJ_SHARED_BULKHDR_LEN], /* "$<value>\r\n" */
|
||||
|
@ -762,7 +762,7 @@ void zlibc_trim(void) {
|
||||
/* For proc_pidinfo() used later in zmalloc_get_smap_bytes_by_field().
|
||||
* Note that this file cannot be included in zmalloc.h because it includes
|
||||
* a Darwin queue.h file where there is a "LIST_HEAD" macro (!) defined
|
||||
* conficting with user code. */
|
||||
* conflicting with user code. */
|
||||
#include <libproc.h>
|
||||
#endif
|
||||
|
||||
|
@ -4,11 +4,11 @@ set server_path [tmpdir server.multi.aof]
|
||||
set aof_dirname "appendonlydir"
|
||||
set aof_basename "appendonly.aof"
|
||||
set aof_dirpath "$server_path/$aof_dirname"
|
||||
set aof_base1_file "$server_path/$aof_dirname/${aof_basename}.1$::base_aof_sufix$::aof_format_suffix"
|
||||
set aof_base2_file "$server_path/$aof_dirname/${aof_basename}.2$::base_aof_sufix$::aof_format_suffix"
|
||||
set aof_incr1_file "$server_path/$aof_dirname/${aof_basename}.1$::incr_aof_sufix$::aof_format_suffix"
|
||||
set aof_incr2_file "$server_path/$aof_dirname/${aof_basename}.2$::incr_aof_sufix$::aof_format_suffix"
|
||||
set aof_incr3_file "$server_path/$aof_dirname/${aof_basename}.3$::incr_aof_sufix$::aof_format_suffix"
|
||||
set aof_base1_file "$server_path/$aof_dirname/${aof_basename}.1$::base_aof_suffix$::aof_format_suffix"
|
||||
set aof_base2_file "$server_path/$aof_dirname/${aof_basename}.2$::base_aof_suffix$::aof_format_suffix"
|
||||
set aof_incr1_file "$server_path/$aof_dirname/${aof_basename}.1$::incr_aof_suffix$::aof_format_suffix"
|
||||
set aof_incr2_file "$server_path/$aof_dirname/${aof_basename}.2$::incr_aof_suffix$::aof_format_suffix"
|
||||
set aof_incr3_file "$server_path/$aof_dirname/${aof_basename}.3$::incr_aof_suffix$::aof_format_suffix"
|
||||
set aof_manifest_file "$server_path/$aof_dirname/${aof_basename}$::manifest_suffix"
|
||||
set aof_old_name_old_path "$server_path/$aof_basename"
|
||||
set aof_old_name_new_path "$aof_dirpath/$aof_basename"
|
||||
@ -705,7 +705,7 @@ tags {"external:skip"} {
|
||||
set client [valkey [srv host] [srv port] 0 $::tls]
|
||||
wait_done_loading $client
|
||||
|
||||
assert_equal 1 [check_file_exist $aof_dirpath "${aof_basename}.1${::base_aof_sufix}${::rdb_format_suffix}"]
|
||||
assert_equal 1 [check_file_exist $aof_dirpath "${aof_basename}.1${::base_aof_suffix}${::rdb_format_suffix}"]
|
||||
|
||||
assert_aof_manifest_content $aof_manifest_file {
|
||||
{file appendonly.aof.1.base.rdb seq 1 type b}
|
||||
@ -728,7 +728,7 @@ tags {"external:skip"} {
|
||||
set client [valkey [srv host] [srv port] 0 $::tls]
|
||||
wait_done_loading $client
|
||||
|
||||
assert_equal 1 [check_file_exist $aof_dirpath "${aof_basename}.1${::base_aof_sufix}${::aof_format_suffix}"]
|
||||
assert_equal 1 [check_file_exist $aof_dirpath "${aof_basename}.1${::base_aof_suffix}${::aof_format_suffix}"]
|
||||
|
||||
assert_aof_manifest_content $aof_manifest_file {
|
||||
{file appendonly.aof.1.base.aof seq 1 type b}
|
||||
@ -750,7 +750,7 @@ tags {"external:skip"} {
|
||||
start_server_aof [list dir $server_path aof-use-rdb-preamble no] {
|
||||
wait_done_loading r
|
||||
|
||||
assert_equal 1 [check_file_exist $aof_dirpath "${aof_basename}.1${::base_aof_sufix}${::aof_format_suffix}"]
|
||||
assert_equal 1 [check_file_exist $aof_dirpath "${aof_basename}.1${::base_aof_suffix}${::aof_format_suffix}"]
|
||||
|
||||
assert_aof_manifest_content $aof_manifest_file {
|
||||
{file appendonly.aof.1.base.aof seq 1 type b}
|
||||
@ -827,8 +827,8 @@ tags {"external:skip"} {
|
||||
|
||||
# Check we really have these files
|
||||
assert_equal 1 [check_file_exist $aof_dirpath $aof_manifest_name]
|
||||
assert_equal 1 [check_file_exist $aof_dirpath "${aof_basename}.1${::base_aof_sufix}${::rdb_format_suffix}"]
|
||||
assert_equal 1 [check_file_exist $aof_dirpath "${aof_basename}.1${::incr_aof_sufix}${::aof_format_suffix}"]
|
||||
assert_equal 1 [check_file_exist $aof_dirpath "${aof_basename}.1${::base_aof_suffix}${::rdb_format_suffix}"]
|
||||
assert_equal 1 [check_file_exist $aof_dirpath "${aof_basename}.1${::incr_aof_suffix}${::aof_format_suffix}"]
|
||||
|
||||
r bgrewriteaof
|
||||
waitForBgrewriteaof r
|
||||
@ -842,13 +842,13 @@ tags {"external:skip"} {
|
||||
assert_equal 1 [check_file_exist $aof_dirpath $aof_manifest_name]
|
||||
# Wait bio delete history
|
||||
wait_for_condition 1000 10 {
|
||||
[check_file_exist $aof_dirpath "${aof_basename}.1${::base_aof_sufix}${::rdb_format_suffix}"] == 0 &&
|
||||
[check_file_exist $aof_dirpath "${aof_basename}.1${::incr_aof_sufix}${::aof_format_suffix}"] == 0
|
||||
[check_file_exist $aof_dirpath "${aof_basename}.1${::base_aof_suffix}${::rdb_format_suffix}"] == 0 &&
|
||||
[check_file_exist $aof_dirpath "${aof_basename}.1${::incr_aof_suffix}${::aof_format_suffix}"] == 0
|
||||
} else {
|
||||
fail "Failed to delete history AOF"
|
||||
}
|
||||
assert_equal 1 [check_file_exist $aof_dirpath "${aof_basename}.2${::base_aof_sufix}${::rdb_format_suffix}"]
|
||||
assert_equal 1 [check_file_exist $aof_dirpath "${aof_basename}.2${::incr_aof_sufix}${::aof_format_suffix}"]
|
||||
assert_equal 1 [check_file_exist $aof_dirpath "${aof_basename}.2${::base_aof_suffix}${::rdb_format_suffix}"]
|
||||
assert_equal 1 [check_file_exist $aof_dirpath "${aof_basename}.2${::incr_aof_suffix}${::aof_format_suffix}"]
|
||||
|
||||
stop_write_load $load_handle0
|
||||
wait_load_handlers_disconnected
|
||||
@ -901,11 +901,11 @@ tags {"external:skip"} {
|
||||
{file appendonly.aof.5.incr.aof seq 5 type i}
|
||||
}
|
||||
|
||||
assert_equal 1 [check_file_exist $aof_dirpath "${aof_basename}.2${::base_aof_sufix}${::rdb_format_suffix}"]
|
||||
assert_equal 1 [check_file_exist $aof_dirpath "${aof_basename}.2${::incr_aof_sufix}${::aof_format_suffix}"]
|
||||
assert_equal 1 [check_file_exist $aof_dirpath "${aof_basename}.3${::incr_aof_sufix}${::aof_format_suffix}"]
|
||||
assert_equal 1 [check_file_exist $aof_dirpath "${aof_basename}.4${::incr_aof_sufix}${::aof_format_suffix}"]
|
||||
assert_equal 1 [check_file_exist $aof_dirpath "${aof_basename}.5${::incr_aof_sufix}${::aof_format_suffix}"]
|
||||
assert_equal 1 [check_file_exist $aof_dirpath "${aof_basename}.2${::base_aof_suffix}${::rdb_format_suffix}"]
|
||||
assert_equal 1 [check_file_exist $aof_dirpath "${aof_basename}.2${::incr_aof_suffix}${::aof_format_suffix}"]
|
||||
assert_equal 1 [check_file_exist $aof_dirpath "${aof_basename}.3${::incr_aof_suffix}${::aof_format_suffix}"]
|
||||
assert_equal 1 [check_file_exist $aof_dirpath "${aof_basename}.4${::incr_aof_suffix}${::aof_format_suffix}"]
|
||||
assert_equal 1 [check_file_exist $aof_dirpath "${aof_basename}.5${::incr_aof_suffix}${::aof_format_suffix}"]
|
||||
|
||||
stop_write_load $load_handle0
|
||||
wait_load_handlers_disconnected
|
||||
@ -936,17 +936,17 @@ tags {"external:skip"} {
|
||||
|
||||
# Wait bio delete history
|
||||
wait_for_condition 1000 10 {
|
||||
[check_file_exist $aof_dirpath "${aof_basename}.2${::base_aof_sufix}${::rdb_format_suffix}"] == 0 &&
|
||||
[check_file_exist $aof_dirpath "${aof_basename}.2${::incr_aof_sufix}${::aof_format_suffix}"] == 0 &&
|
||||
[check_file_exist $aof_dirpath "${aof_basename}.3${::incr_aof_sufix}${::aof_format_suffix}"] == 0 &&
|
||||
[check_file_exist $aof_dirpath "${aof_basename}.4${::incr_aof_sufix}${::aof_format_suffix}"] == 0 &&
|
||||
[check_file_exist $aof_dirpath "${aof_basename}.5${::incr_aof_sufix}${::aof_format_suffix}"] == 0
|
||||
[check_file_exist $aof_dirpath "${aof_basename}.2${::base_aof_suffix}${::rdb_format_suffix}"] == 0 &&
|
||||
[check_file_exist $aof_dirpath "${aof_basename}.2${::incr_aof_suffix}${::aof_format_suffix}"] == 0 &&
|
||||
[check_file_exist $aof_dirpath "${aof_basename}.3${::incr_aof_suffix}${::aof_format_suffix}"] == 0 &&
|
||||
[check_file_exist $aof_dirpath "${aof_basename}.4${::incr_aof_suffix}${::aof_format_suffix}"] == 0 &&
|
||||
[check_file_exist $aof_dirpath "${aof_basename}.5${::incr_aof_suffix}${::aof_format_suffix}"] == 0
|
||||
} else {
|
||||
fail "Failed to delete history AOF"
|
||||
}
|
||||
|
||||
assert_equal 1 [check_file_exist $aof_dirpath "${aof_basename}.3${::base_aof_sufix}${::rdb_format_suffix}"]
|
||||
assert_equal 1 [check_file_exist $aof_dirpath "${aof_basename}.6${::incr_aof_sufix}${::aof_format_suffix}"]
|
||||
assert_equal 1 [check_file_exist $aof_dirpath "${aof_basename}.3${::base_aof_suffix}${::rdb_format_suffix}"]
|
||||
assert_equal 1 [check_file_exist $aof_dirpath "${aof_basename}.6${::incr_aof_suffix}${::aof_format_suffix}"]
|
||||
|
||||
set d1 [r debug digest]
|
||||
r debug loadaof
|
||||
@ -965,10 +965,10 @@ tags {"external:skip"} {
|
||||
{file appendonly.aof.4.base.rdb seq 4 type b}
|
||||
}
|
||||
|
||||
assert_equal 1 [check_file_exist $aof_dirpath "${aof_basename}.4${::base_aof_sufix}${::rdb_format_suffix}"]
|
||||
assert_equal 1 [check_file_exist $aof_dirpath "${aof_basename}.4${::base_aof_suffix}${::rdb_format_suffix}"]
|
||||
wait_for_condition 1000 10 {
|
||||
[check_file_exist $aof_dirpath "${aof_basename}.6${::incr_aof_sufix}${::aof_format_suffix}"] == 0 &&
|
||||
[check_file_exist $aof_dirpath "${aof_basename}.7${::incr_aof_sufix}${::aof_format_suffix}"] == 0
|
||||
[check_file_exist $aof_dirpath "${aof_basename}.6${::incr_aof_suffix}${::aof_format_suffix}"] == 0 &&
|
||||
[check_file_exist $aof_dirpath "${aof_basename}.7${::incr_aof_suffix}${::aof_format_suffix}"] == 0
|
||||
} else {
|
||||
fail "Failed to delete history AOF"
|
||||
}
|
||||
@ -990,13 +990,13 @@ tags {"external:skip"} {
|
||||
|
||||
# Wait bio delete history
|
||||
wait_for_condition 1000 10 {
|
||||
[check_file_exist $aof_dirpath "${aof_basename}.4${::base_aof_sufix}${::rdb_format_suffix}"] == 0
|
||||
[check_file_exist $aof_dirpath "${aof_basename}.4${::base_aof_suffix}${::rdb_format_suffix}"] == 0
|
||||
} else {
|
||||
fail "Failed to delete history AOF"
|
||||
}
|
||||
|
||||
assert_equal 1 [check_file_exist $aof_dirpath "${aof_basename}.5${::base_aof_sufix}${::rdb_format_suffix}"]
|
||||
assert_equal 1 [check_file_exist $aof_dirpath "${aof_basename}.1${::incr_aof_sufix}${::aof_format_suffix}"]
|
||||
assert_equal 1 [check_file_exist $aof_dirpath "${aof_basename}.5${::base_aof_suffix}${::rdb_format_suffix}"]
|
||||
assert_equal 1 [check_file_exist $aof_dirpath "${aof_basename}.1${::incr_aof_suffix}${::aof_format_suffix}"]
|
||||
}
|
||||
|
||||
test "AOF enable/disable auto gc" {
|
||||
@ -1018,10 +1018,10 @@ tags {"external:skip"} {
|
||||
{file appendonly.aof.3.incr.aof seq 3 type i}
|
||||
}
|
||||
|
||||
assert_equal 1 [check_file_exist $aof_dirpath "${aof_basename}.5${::base_aof_sufix}${::rdb_format_suffix}"]
|
||||
assert_equal 1 [check_file_exist $aof_dirpath "${aof_basename}.6${::base_aof_sufix}${::rdb_format_suffix}"]
|
||||
assert_equal 1 [check_file_exist $aof_dirpath "${aof_basename}.1${::incr_aof_sufix}${::aof_format_suffix}"]
|
||||
assert_equal 1 [check_file_exist $aof_dirpath "${aof_basename}.2${::incr_aof_sufix}${::aof_format_suffix}"]
|
||||
assert_equal 1 [check_file_exist $aof_dirpath "${aof_basename}.5${::base_aof_suffix}${::rdb_format_suffix}"]
|
||||
assert_equal 1 [check_file_exist $aof_dirpath "${aof_basename}.6${::base_aof_suffix}${::rdb_format_suffix}"]
|
||||
assert_equal 1 [check_file_exist $aof_dirpath "${aof_basename}.1${::incr_aof_suffix}${::aof_format_suffix}"]
|
||||
assert_equal 1 [check_file_exist $aof_dirpath "${aof_basename}.2${::incr_aof_suffix}${::aof_format_suffix}"]
|
||||
|
||||
r config set aof-disable-auto-gc no
|
||||
|
||||
@ -1033,10 +1033,10 @@ tags {"external:skip"} {
|
||||
|
||||
# wait bio delete history
|
||||
wait_for_condition 1000 10 {
|
||||
[check_file_exist $aof_dirpath "${aof_basename}.5${::base_aof_sufix}${::rdb_format_suffix}"] == 0 &&
|
||||
[check_file_exist $aof_dirpath "${aof_basename}.6${::base_aof_sufix}${::rdb_format_suffix}"] == 0 &&
|
||||
[check_file_exist $aof_dirpath "${aof_basename}.1${::incr_aof_sufix}${::aof_format_suffix}"] == 0 &&
|
||||
[check_file_exist $aof_dirpath "${aof_basename}.2${::incr_aof_sufix}${::aof_format_suffix}"] == 0
|
||||
[check_file_exist $aof_dirpath "${aof_basename}.5${::base_aof_suffix}${::rdb_format_suffix}"] == 0 &&
|
||||
[check_file_exist $aof_dirpath "${aof_basename}.6${::base_aof_suffix}${::rdb_format_suffix}"] == 0 &&
|
||||
[check_file_exist $aof_dirpath "${aof_basename}.1${::incr_aof_suffix}${::aof_format_suffix}"] == 0 &&
|
||||
[check_file_exist $aof_dirpath "${aof_basename}.2${::incr_aof_suffix}${::aof_format_suffix}"] == 0
|
||||
} else {
|
||||
fail "Failed to delete history AOF"
|
||||
}
|
||||
@ -1192,7 +1192,7 @@ tags {"external:skip"} {
|
||||
waitForBgrewriteaof r
|
||||
|
||||
# Can create New INCR AOF
|
||||
assert_equal 1 [check_file_exist $aof_dirpath "${aof_basename}.10${::incr_aof_sufix}${::aof_format_suffix}"]
|
||||
assert_equal 1 [check_file_exist $aof_dirpath "${aof_basename}.10${::incr_aof_suffix}${::aof_format_suffix}"]
|
||||
|
||||
assert_aof_manifest_content $aof_manifest_file {
|
||||
{file appendonly.aof.11.base.rdb seq 11 type b}
|
||||
@ -1248,7 +1248,7 @@ tags {"external:skip"} {
|
||||
# Make sure manifest file is not created
|
||||
assert_equal 0 [check_file_exist $aof_dirpath $aof_manifest_name]
|
||||
# Make sure BASE AOF is not created
|
||||
assert_equal 0 [check_file_exist $aof_dirpath "${aof_basename}.1${::base_aof_sufix}${::rdb_format_suffix}"]
|
||||
assert_equal 0 [check_file_exist $aof_dirpath "${aof_basename}.1${::base_aof_suffix}${::rdb_format_suffix}"]
|
||||
|
||||
# Make sure the next AOFRW has started
|
||||
wait_for_condition 1000 50 {
|
||||
|
@ -4,8 +4,8 @@ set server_path [tmpdir server.aof]
|
||||
set aof_dirname "appendonlydir"
|
||||
set aof_basename "appendonly.aof"
|
||||
set aof_dirpath "$server_path/$aof_dirname"
|
||||
set aof_base_file "$server_path/$aof_dirname/${aof_basename}.1$::base_aof_sufix$::aof_format_suffix"
|
||||
set aof_file "$server_path/$aof_dirname/${aof_basename}.1$::incr_aof_sufix$::aof_format_suffix"
|
||||
set aof_base_file "$server_path/$aof_dirname/${aof_basename}.1$::base_aof_suffix$::aof_format_suffix"
|
||||
set aof_file "$server_path/$aof_dirname/${aof_basename}.1$::incr_aof_suffix$::aof_format_suffix"
|
||||
set aof_manifest_file "$server_path/$aof_dirname/$aof_basename$::manifest_suffix"
|
||||
|
||||
tags {"aof external:skip"} {
|
||||
|
@ -355,8 +355,8 @@ start_server {tags {"dual-channel-replication external:skip"}} {
|
||||
verify_replica_online $primary 0 500
|
||||
verify_replica_online $primary 1 500
|
||||
|
||||
wait_for_value_to_propegate_to_replica $primary $replica1 "key1"
|
||||
wait_for_value_to_propegate_to_replica $primary $replica2 "key1"
|
||||
wait_for_value_to_propagate_to_replica $primary $replica1 "key1"
|
||||
wait_for_value_to_propagate_to_replica $primary $replica2 "key1"
|
||||
|
||||
assert {[s 0 total_forks] eq "1" }
|
||||
}
|
||||
@ -374,8 +374,8 @@ start_server {tags {"dual-channel-replication external:skip"}} {
|
||||
$replica2 replicaof $primary_host $primary_port
|
||||
verify_replica_online $primary 0 500
|
||||
verify_replica_online $primary 1 500
|
||||
wait_for_value_to_propegate_to_replica $primary $replica1 "key2"
|
||||
wait_for_value_to_propegate_to_replica $primary $replica2 "key2"
|
||||
wait_for_value_to_propagate_to_replica $primary $replica1 "key2"
|
||||
wait_for_value_to_propagate_to_replica $primary $replica2 "key2"
|
||||
wait_for_condition 50 1000 {
|
||||
[status $replica1 master_link_status] == "up"
|
||||
} else {
|
||||
@ -444,7 +444,7 @@ start_server {tags {"dual-channel-replication external:skip"}} {
|
||||
} else {
|
||||
fail "Replica is not synced"
|
||||
}
|
||||
wait_for_value_to_propegate_to_replica $primary $replica1 "key3"
|
||||
wait_for_value_to_propagate_to_replica $primary $replica1 "key3"
|
||||
|
||||
# Verify that we did not use dual-channel-replication sync
|
||||
assert {[status $primary sync_partial_ok] == $cur_psync}
|
||||
@ -483,7 +483,7 @@ start_server {tags {"dual-channel-replication external:skip"}} {
|
||||
} else {
|
||||
fail "Replica is not synced"
|
||||
}
|
||||
wait_for_value_to_propegate_to_replica $primary $replica "key1"
|
||||
wait_for_value_to_propagate_to_replica $primary $replica "key1"
|
||||
# Confirm the occurrence of a race condition.
|
||||
wait_for_log_messages -1 {"*<Dual Channel> Psync established after rdb load*"} 0 2000 1
|
||||
}
|
||||
|
@ -1,5 +1,5 @@
|
||||
set ::base_aof_sufix ".base"
|
||||
set ::incr_aof_sufix ".incr"
|
||||
set ::base_aof_suffix ".base"
|
||||
set ::incr_aof_suffix ".incr"
|
||||
set ::manifest_suffix ".manifest"
|
||||
set ::aof_format_suffix ".aof"
|
||||
set ::rdb_format_suffix ".rdb"
|
||||
|
@ -160,12 +160,12 @@ proc verify_replica_online {master replica_idx max_retry} {
|
||||
}
|
||||
}
|
||||
|
||||
proc wait_for_value_to_propegate_to_replica {master replica key} {
|
||||
proc wait_for_value_to_propagate_to_replica {master replica key} {
|
||||
set val [$master get $key]
|
||||
wait_for_condition 50 500 {
|
||||
([$replica get $key] eq $val)
|
||||
} else {
|
||||
error "Key $key did not propegate. Expected $val but got [$replica get $key]"
|
||||
error "Key $key did not propagate. Expected $val but got [$replica get $key]"
|
||||
}
|
||||
}
|
||||
|
||||
|
Loading…
x
Reference in New Issue
Block a user