Skip to content

Commit 34f0475

Browse files
authored
Merge pull request ceph#61130 from baum/wip-baum-20241218-00
src/nvmeof/NVMeofGwMonitorClient: remove MDS client, not needed
2 parents 3d072b5 + f806872 commit 34f0475

File tree

2 files changed

+1
-7
lines changed

2 files changed

+1
-7
lines changed

src/nvmeof/NVMeofGwMonitorClient.cc

Lines changed: 1 addition & 5 deletions
Original file line numberDiff line numberDiff line change
@@ -42,7 +42,6 @@ NVMeofGwMonitorClient::NVMeofGwMonitorClient(int argc, const char **argv) :
4242
monc{g_ceph_context, poolctx},
4343
client_messenger(Messenger::create(g_ceph_context, "async", entity_name_t::CLIENT(-1), "client", getpid())),
4444
objecter{g_ceph_context, client_messenger.get(), &monc, poolctx},
45-
client{client_messenger.get(), &monc, &objecter},
4645
timer(g_ceph_context, beacon_lock),
4746
orig_argc(argc),
4847
orig_argv(argv)
@@ -134,7 +133,6 @@ int NVMeofGwMonitorClient::init()
134133
// Initialize Messenger
135134
client_messenger->add_dispatcher_tail(this);
136135
client_messenger->add_dispatcher_head(&objecter);
137-
client_messenger->add_dispatcher_tail(&client);
138136
client_messenger->start();
139137

140138
poolctx.start(2);
@@ -190,7 +188,6 @@ int NVMeofGwMonitorClient::init()
190188
objecter.init();
191189
objecter.enable_blocklist_events();
192190
objecter.start();
193-
client.init();
194191
timer.init();
195192

196193
{
@@ -302,8 +299,7 @@ void NVMeofGwMonitorClient::shutdown()
302299
std::lock_guard bl(beacon_lock);
303300
timer.shutdown();
304301
}
305-
// client uses monc and objecter
306-
client.shutdown();
302+
307303
// Stop asio threads, so leftover events won't call into shut down
308304
// monclient/objecter.
309305
poolctx.finish();

src/nvmeof/NVMeofGwMonitorClient.h

Lines changed: 0 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -21,7 +21,6 @@
2121
#include "common/Timer.h"
2222
#include "common/LogClient.h"
2323

24-
#include "client/Client.h"
2524
#include "mon/MonClient.h"
2625
#include "osdc/Objecter.h"
2726
#include "messages/MNVMeofGwMap.h"
@@ -58,7 +57,6 @@ class NVMeofGwMonitorClient: public Dispatcher,
5857
MonClient monc;
5958
std::unique_ptr<Messenger> client_messenger;
6059
Objecter objecter;
61-
Client client;
6260
std::map<NvmeGroupKey, NvmeGwMonClientStates> map;
6361
ceph::mutex lock = ceph::make_mutex("NVMeofGw::lock");
6462
// allow beacons to be sent independently of handle_nvmeof_gw_map

0 commit comments

Comments
 (0)