Add std::err mmap logging messages (temp).

Author: evoskuil

include/bitcoin/database/memory/map.hpp

@@ -136,6 +136,9 @@ class BCD_API map
     bool resize_(size_t size) NOEXCEPT;
     bool finalize_(size_t size) NOEXCEPT;
 
+    void log(auto kind) NOEXCEPT;
+    void log(auto kind, size_t size) NOEXCEPT;
+
     // Constants.
     const std::filesystem::path filename_;
     const size_t minimum_;

src/memory/map.cpp

@@ -37,34 +37,50 @@
 #include <bitcoin/database/error.hpp>
 #include <bitcoin/database/file/file.hpp>
 
+namespace libbitcoin {
+namespace database {
+
+BC_PUSH_WARNING(NO_THROW_IN_NOEXCEPT)
+
+using namespace system;
+
 // ~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~
-#include <chrono>
-#include <iostream>
+constexpr auto sp = " ";
 
 enum logger
 {
-    xopen = 0
+    xopen,
+    xmap,
+    xexpand,
+    xreserve,
+    xallocate,
+    xset,
+    xremap,
+    xflush,
+    xunmap,
+    xclose
 };
 
-constexpr auto sp = " ";
-
 size_t ticks() NOEXCEPT
 {
     using clock = std::chrono::high_resolution_clock;
     static const auto start = clock::now();
 
     using namespace std::chrono;
-    const auto span = duration_cast<milliseconds>(clock::now() - start);
-    return bc::system::to_unsigned(span.count());
+    const auto span = duration_cast<microseconds>(clock::now() - start);
+    return to_unsigned(span.count());
 }
-// ~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~
 
-namespace libbitcoin {
-namespace database {
-
-BC_PUSH_WARNING(NO_THROW_IN_NOEXCEPT)
+void map::log(auto kind) NOEXCEPT
+{
+    std::cerr << ticks() << sp << kind << sp << opened_ << std::endl;
+}
 
-using namespace system;
+void map::log(auto kind, size_t size) NOEXCEPT
+{
+    std::cerr << ticks() << sp << kind << sp << opened_ << sp << size << std::endl;
+}
+// ~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~
 
 map::map(const path& filename, size_t minimum, size_t expansion,
     bool random) NOEXCEPT
@@ -100,10 +116,9 @@ code map::open() NOEXCEPT
     if (const auto ec = file::open_ex(opened_, filename_, random_))
         return ec;
 
-    // ~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~
-    // 42 0 confirmed.data 19303540
+    // ~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~
     std::cerr << ticks() << sp << logger::xopen << sp << filename_ << sp << opened_ << std::endl;
-    // ~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~
+    // ~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~
 
     return file::size_ex(logical_, opened_);
 }
@@ -119,10 +134,12 @@ code map::close() NOEXCEPT
     if (opened_ == file::invalid)
         return error::success;
 
+    // ~~~~~~~~~~~~~~~~~~
+    log(logger::xclose);
+    // ~~~~~~~~~~~~~~~~~~
     const auto descriptor = opened_;
     opened_ = file::invalid;
     logical_ = zero;
-
     return file::close_ex(descriptor);
 }
 
@@ -280,6 +297,9 @@ bool map::expand(size_t size) NOEXCEPT
             return false;
     }
 
+    // ~~~~~~~~~~~~~~~~~~
+    log(logger::xexpand, size - logical_);
+    // ~~~~~~~~~~~~~~~~~~
     logical_ = size;
     return true;
 }
@@ -300,6 +320,9 @@ bool map::reserve(size_t chunk) NOEXCEPT
             return false;
     }
 
+    // ~~~~~~~~~~~~~~~~~~
+    log(logger::xreserve, chunk);
+    // ~~~~~~~~~~~~~~~~~~
     // Same as allocate except logical does not change.
     return true;
 }
@@ -327,6 +350,9 @@ size_t map::allocate(size_t chunk) NOEXCEPT
             return storage::eof;
     }
 
+    // ~~~~~~~~~~~~~~~~~~
+    log(logger::xallocate, chunk);
+    // ~~~~~~~~~~~~~~~~~~
     std::swap(logical_, end);
     return end;
 }
@@ -360,6 +386,9 @@ memory_ptr map::set(size_t offset, size_t size, uint8_t backfill) NOEXCEPT
         logical_ = end;
     }
 
+    // ~~~~~~~~~~~~~~~~~~
+    log(logger::xset, size);
+    // ~~~~~~~~~~~~~~~~~~
     return get(offset);
 }
 
@@ -488,6 +517,9 @@ bool map::flush_() NOEXCEPT
     if (!success)
         set_first_code(error::fsync_failure);
 
+    // ~~~~~~~~~~~~~~~~~~
+    log(logger::xflush);
+    // ~~~~~~~~~~~~~~~~~~
     return success;
 }
 
@@ -516,6 +548,10 @@ bool map::unmap_() NOEXCEPT
     loaded_ = false;
     capacity_ = zero;
     memory_map_ = {};
+
+    // ~~~~~~~~~~~~~~~~~~
+    log(logger::xunmap);
+    // ~~~~~~~~~~~~~~~~~~
     return success;
 }
 
@@ -533,6 +569,9 @@ bool map::map_() NOEXCEPT
     memory_map_ = pointer_cast<uint8_t>(::mmap(nullptr, size,
         PROT_READ | PROT_WRITE, MAP_SHARED, opened_, 0));
 
+    // ~~~~~~~~~~~~~~~~~~
+    log(logger::xmap);
+    // ~~~~~~~~~~~~~~~~~~
     return finalize_(size);
 }
 
@@ -578,6 +617,9 @@ bool map::remap_(size_t size) NOEXCEPT
         PROT_READ | PROT_WRITE, MAP_SHARED, opened_, 0));
 #endif
 
+    // ~~~~~~~~~~~~~~~~~~
+    log(logger::xremap);
+    // ~~~~~~~~~~~~~~~~~~
     return finalize_(size);
 }