mirrors/dragonfly
1
0
Fork 0
mirror of https://github.com/dragonflydb/dragonfly.git synced 2025-05-11 02:15:45 +02:00
Code Issues Projects Releases Packages Wiki Activity Actions 5

chore: allow skipping cluster probing

Browse source
This commit is contained in:
Roman Gershman 2025-05-08 11:42:18 +03:00
parent 1e40e3aa9b
commit dabc84ba06
No known key found for this signature in database
GPG key ID: F25B77EAF8AEBA7A
1 changed files with 5 additions and 1 deletions
Download patch file Download diff file Expand all files Collapse all files

6
src/server/dfly_bench.cc
View file

@ -65,6 +65,10 @@ ABSL_FLAG(string, P, "", "protocol can be empty (for RESP) or memcache_text");
ABSL_FLAG(bool, tcp_nodelay, false, "If true, set nodelay option on tcp socket"); ABSL_FLAG(bool, tcp_nodelay, false, "If true, set nodelay option on tcp socket");
ABSL_FLAG(bool, noreply, false, "If true, does not wait for replies. Relevant only for memcached."); ABSL_FLAG(bool, noreply, false, "If true, does not wait for replies. Relevant only for memcached.");
ABSL_FLAG(bool, probe_cluster, true,
"If false, skips cluster-mode probing and works only in single node mode");
ABSL_FLAG(bool, greet, true, ABSL_FLAG(bool, greet, true,
"If true, sends a greeting command on each connection, " "If true, sends a greeting command on each connection, "
"to make sure the connection succeeded"); "to make sure the connection succeeded");
@ -1121,7 +1125,7 @@ int main(int argc, char* argv[]) {
tcp::endpoint ep{address, GetFlag(FLAGS_p)}; tcp::endpoint ep{address, GetFlag(FLAGS_p)};
ClusterShards shards; ClusterShards shards;
if (protocol == RESP) { if (protocol == RESP && GetFlag(FLAGS_probe_cluster)) {
shards = proactor->Await([&] { return FetchClusterInfo(ep, proactor); }); shards = proactor->Await([&] { return FetchClusterInfo(ep, proactor); });
} }
CONSOLE_INFO << "Connecting to " CONSOLE_INFO << "Connecting to "