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

chore: add password flag to dfly_bench (#5074)

Browse source 
* add password flag to dfly_bench

---------

Signed-off-by: kostas <kostas@dragonflydb.io>
This commit is contained in:
Kostas Kyrimis 2025-05-07 10:32:13 +03:00 • committed by GitHub
parent 3977f0f60a
commit 05d99769e1
No known key found for this signature in database
GPG key ID: B5690EEEBB952194
1 changed files with 18 additions and 9 deletions
Download patch file Download diff file Expand all files Collapse all files

27
src/server/dfly_bench.cc
View file

@ -75,6 +75,7 @@ ABSL_FLAG(bool, ascii, true, "If true, use ascii characters for values");
ABSL_FLAG(bool, connect_only, false, ABSL_FLAG(bool, connect_only, false,
"If true, will only connect to the server, without sending " "If true, will only connect to the server, without sending "
"loadtest commands"); "loadtest commands");
ABSL_FLAG(string, password, "", "password to authenticate the client");
using namespace std; using namespace std;
using namespace util; using namespace util;
@ -423,6 +424,7 @@ class Driver {
void ReceiveFb(); void ReceiveFb();
void ParseRESP(); void ParseRESP();
void ParseMC(); void ParseMC();
void RunCommandAndCheckResultIs(std::string_view cmd, std::string_view expected_res);
struct Req { struct Req {
uint64_t start; uint64_t start;
@ -588,6 +590,16 @@ void KeyGenerator::EnableClusterMode() {
++i; ++i;
} }
} }
void Driver::RunCommandAndCheckResultIs(std::string_view cmd, std::string_view expected_res) {
auto ec = socket_->Write(io::Buffer(cmd));
CHECK(!ec);
uint8_t buf[128];
auto res_sz = socket_->Recv(io::MutableBytes(buf));
CHECK(res_sz) << res_sz.error().message();
string_view resp = io::View(io::Bytes(buf, *res_sz));
CHECK_EQ(resp, expected_res) << resp;
}
void Driver::Connect(unsigned index, const tcp::endpoint& ep) { void Driver::Connect(unsigned index, const tcp::endpoint& ep) {
VLOG(2) << "Connecting " << index << " to " << ep; VLOG(2) << "Connecting " << index << " to " << ep;
@ -598,18 +610,15 @@ void Driver::Connect(unsigned index, const tcp::endpoint& ep) {
CHECK_EQ(0, setsockopt(socket_->native_handle(), IPPROTO_TCP, TCP_NODELAY, &yes, sizeof(yes))); CHECK_EQ(0, setsockopt(socket_->native_handle(), IPPROTO_TCP, TCP_NODELAY, &yes, sizeof(yes)));
} }
if (absl::GetFlag(FLAGS_greet)) { auto password = absl::GetFlag(FLAGS_password);
if (!password.empty()) {
auto command = absl::StrCat("AUTH ", password, "\r\n");
RunCommandAndCheckResultIs(command, "+OK\r\n");
} else if (absl::GetFlag(FLAGS_greet)) {
// TCP Connect does not ensure that the connection was indeed accepted by the server. // TCP Connect does not ensure that the connection was indeed accepted by the server.
// if server backlog is too short the connection will get stuck in the accept queue. // if server backlog is too short the connection will get stuck in the accept queue.
// Therefore, we send a ping command to ensure that every connection got connected. // Therefore, we send a ping command to ensure that every connection got connected.
ec = socket_->Write(io::Buffer("ping\r\n")); RunCommandAndCheckResultIs("PING\r\n", "+PONG\r\n");
CHECK(!ec);
uint8_t buf[128];
auto res_sz = socket_->Recv(io::MutableBytes(buf));
CHECK(res_sz) << res_sz.error().message();
string_view resp = io::View(io::Bytes(buf, *res_sz));
CHECK(absl::EndsWith(resp, "\r\n")) << resp;
} }
ep_ = ep; ep_ = ep;
receive_fb_ = MakeFiber(fb2::Launch::dispatch, [this] { ReceiveFb(); }); receive_fb_ = MakeFiber(fb2::Launch::dispatch, [this] { ReceiveFb(); });