|
 |
4ee10e |
From 7fbd79cab2e548eb388bc782dd39f1cde027173b Mon Sep 17 00:00:00 2001
|
|
|
4ee10e |
From: Ming-Hung Tsai <mtsai@redhat.com>
|
|
|
4ee10e |
Date: Tue, 1 Jun 2021 23:37:36 +0800
|
|
|
4ee10e |
Subject: [PATCH 04/10] [thin_dump] Fix leaked shared object handle
|
|
|
4ee10e |
|
|
|
4ee10e |
---
|
|
|
4ee10e |
thin-provisioning/shared_library_emitter.cc | 113 ++++++++++++++++++++++++----
|
|
|
4ee10e |
1 file changed, 100 insertions(+), 13 deletions(-)
|
|
|
4ee10e |
|
|
|
4ee10e |
diff --git a/thin-provisioning/shared_library_emitter.cc b/thin-provisioning/shared_library_emitter.cc
|
|
|
4ee10e |
index 58f12d2..2e845f3 100644
|
|
|
4ee10e |
--- a/thin-provisioning/shared_library_emitter.cc
|
|
|
4ee10e |
+++ b/thin-provisioning/shared_library_emitter.cc
|
|
|
4ee10e |
@@ -8,22 +8,109 @@ using namespace thin_provisioning;
|
|
|
4ee10e |
|
|
|
4ee10e |
//----------------------------------------------------------------
|
|
|
4ee10e |
|
|
|
4ee10e |
-emitter::ptr
|
|
|
4ee10e |
-thin_provisioning::create_custom_emitter(string const &shared_lib, ostream &out)
|
|
|
4ee10e |
-{
|
|
|
4ee10e |
- emitter::ptr (*create_fn)(ostream &out;;
|
|
|
4ee10e |
- void *handle = dlopen(shared_lib.c_str(), RTLD_LAZY);
|
|
|
4ee10e |
- if (!handle)
|
|
|
4ee10e |
- throw runtime_error(dlerror());
|
|
|
4ee10e |
+struct shared_object {
|
|
|
4ee10e |
+public:
|
|
|
4ee10e |
+ shared_object(const char *shared_lib) {
|
|
|
4ee10e |
+ handle_ = dlopen(shared_lib, RTLD_LAZY);
|
|
|
4ee10e |
+ if (!handle_)
|
|
|
4ee10e |
+ throw runtime_error(dlerror());
|
|
|
4ee10e |
+
|
|
|
4ee10e |
+ dlerror(); // Clear any existing error
|
|
|
4ee10e |
+ }
|
|
|
4ee10e |
+
|
|
|
4ee10e |
+ virtual ~shared_object() {
|
|
|
4ee10e |
+ dlclose(handle_);
|
|
|
4ee10e |
+ }
|
|
|
4ee10e |
+
|
|
|
4ee10e |
+ void *get_symbol(const char *symbol) {
|
|
|
4ee10e |
+ void *sym = dlsym(handle_, symbol);
|
|
|
4ee10e |
+
|
|
|
4ee10e |
+ char *error = dlerror();
|
|
|
4ee10e |
+ if (error)
|
|
|
4ee10e |
+ throw runtime_error(error);
|
|
|
4ee10e |
+
|
|
|
4ee10e |
+ return sym;
|
|
|
4ee10e |
+ }
|
|
|
4ee10e |
+
|
|
|
4ee10e |
+ void *handle_;
|
|
|
4ee10e |
+};
|
|
|
4ee10e |
+
|
|
|
4ee10e |
+class shared_emitter : public emitter {
|
|
|
4ee10e |
+public:
|
|
|
4ee10e |
+ shared_emitter(const char *shared_lib, ostream &out): sobj_(shared_lib) {
|
|
|
4ee10e |
+ emitter::ptr (*create_fn)(ostream &out;;
|
|
|
4ee10e |
+ create_fn = reinterpret_cast<emitter::ptr (*)(ostream &)>(
|
|
|
4ee10e |
+ sobj_.get_symbol("create_emitter"));
|
|
|
4ee10e |
+ inner_ = create_fn(out);
|
|
|
4ee10e |
+ }
|
|
|
4ee10e |
+
|
|
|
4ee10e |
+ virtual ~shared_emitter() {
|
|
|
4ee10e |
+ }
|
|
|
4ee10e |
+
|
|
|
4ee10e |
+ void begin_superblock(std::string const &uuid,
|
|
|
4ee10e |
+ uint64_t time,
|
|
|
4ee10e |
+ uint64_t trans_id,
|
|
|
4ee10e |
+ boost::optional<uint32_t> flags,
|
|
|
4ee10e |
+ boost::optional<uint32_t> version,
|
|
|
4ee10e |
+ uint32_t data_block_size,
|
|
|
4ee10e |
+ uint64_t nr_data_blocks,
|
|
|
4ee10e |
+ boost::optional<uint64_t> metadata_snap) {
|
|
|
4ee10e |
+ inner_->begin_superblock(uuid,
|
|
|
4ee10e |
+ time,
|
|
|
4ee10e |
+ trans_id,
|
|
|
4ee10e |
+ flags,
|
|
|
4ee10e |
+ version,
|
|
|
4ee10e |
+ data_block_size,
|
|
|
4ee10e |
+ nr_data_blocks,
|
|
|
4ee10e |
+ metadata_snap);
|
|
|
4ee10e |
+ }
|
|
|
4ee10e |
|
|
|
4ee10e |
- dlerror(); // Clear any existing error
|
|
|
4ee10e |
- create_fn = reinterpret_cast<emitter::ptr (*)(ostream &)>(dlsym(handle, "create_emitter"));
|
|
|
4ee10e |
+ void end_superblock() {
|
|
|
4ee10e |
+ inner_->end_superblock();
|
|
|
4ee10e |
+ }
|
|
|
4ee10e |
|
|
|
4ee10e |
- char *error = dlerror();
|
|
|
4ee10e |
- if (error)
|
|
|
4ee10e |
- throw runtime_error(error);
|
|
|
4ee10e |
+ void begin_device(uint32_t dev_id,
|
|
|
4ee10e |
+ uint64_t mapped_blocks,
|
|
|
4ee10e |
+ uint64_t trans_id,
|
|
|
4ee10e |
+ uint64_t creation_time,
|
|
|
4ee10e |
+ uint64_t snap_time) {
|
|
|
4ee10e |
+ inner_->begin_device(dev_id, mapped_blocks, trans_id, creation_time, snap_time);
|
|
|
4ee10e |
+ }
|
|
|
4ee10e |
|
|
|
4ee10e |
- return create_fn(out);
|
|
|
4ee10e |
+ void end_device() {
|
|
|
4ee10e |
+ inner_->end_device();
|
|
|
4ee10e |
+ }
|
|
|
4ee10e |
+
|
|
|
4ee10e |
+ void begin_named_mapping(std::string const &name) {
|
|
|
4ee10e |
+ inner_->begin_named_mapping(name);
|
|
|
4ee10e |
+ }
|
|
|
4ee10e |
+
|
|
|
4ee10e |
+ void end_named_mapping() {
|
|
|
4ee10e |
+ inner_->end_named_mapping();
|
|
|
4ee10e |
+ }
|
|
|
4ee10e |
+
|
|
|
4ee10e |
+ void identifier(std::string const &name) {
|
|
|
4ee10e |
+ inner_->identifier(name);
|
|
|
4ee10e |
+ }
|
|
|
4ee10e |
+
|
|
|
4ee10e |
+ void range_map(uint64_t origin_begin, uint64_t data_begin, uint32_t time, uint64_t len) {
|
|
|
4ee10e |
+ inner_->range_map(origin_begin, data_begin, time, len);
|
|
|
4ee10e |
+ }
|
|
|
4ee10e |
+
|
|
|
4ee10e |
+ void single_map(uint64_t origin_block, uint64_t data_block, uint32_t time) {
|
|
|
4ee10e |
+ inner_->single_map(origin_block, data_block, time);
|
|
|
4ee10e |
+ }
|
|
|
4ee10e |
+
|
|
|
4ee10e |
+ shared_object sobj_;
|
|
|
4ee10e |
+ emitter::ptr inner_;
|
|
|
4ee10e |
+};
|
|
|
4ee10e |
+
|
|
|
4ee10e |
+//----------------------------------------------------------------
|
|
|
4ee10e |
+
|
|
|
4ee10e |
+emitter::ptr
|
|
|
4ee10e |
+thin_provisioning::create_custom_emitter(string const &shared_lib, ostream &out)
|
|
|
4ee10e |
+{
|
|
|
4ee10e |
+ return emitter::ptr(new shared_emitter(shared_lib.c_str(), out));
|
|
|
4ee10e |
}
|
|
|
4ee10e |
|
|
|
4ee10e |
//----------------------------------------------------------------
|
|
|
4ee10e |
--
|
|
|
4ee10e |
1.8.3.1
|
|
|
4ee10e |
|