fix(remoteFDB): cleanup remote/client

Author: mcakircali

src/fdb5/remote/client/Client.cc

@@ -90,7 +90,7 @@ eckit::Buffer Client::controlWriteReadResponse(const Message     msg,
     return eckit::Buffer{f.get()};
 }
 
-void Client::dataWrite(remote::Message msg, uint32_t requestID, PayloadList payloads) {
+void Client::dataWrite(Message msg, uint32_t requestID, PayloadList payloads) {
     connection_.dataWrite(*this, msg, requestID, std::move(payloads));
 }
 

src/fdb5/remote/client/Client.h

@@ -34,9 +34,10 @@ class RemoteFDBException : public eckit::RemoteException {
 //----------------------------------------------------------------------------------------------------------------------
 
 class Client : eckit::NonCopyable {
+public:  // types
     using PayloadList = Connection::PayloadList;
 
-public:
+public:  // methods
     Client(const eckit::net::Endpoint& endpoint, const std::string& defaultEndpoint);
 
     Client(const std::vector<std::pair<eckit::net::Endpoint, std::string>>& endpoints);

src/fdb5/remote/client/RemoteCatalogue.cc

@@ -30,9 +30,8 @@ namespace fdb5::remote {
 
 namespace {
 
-constexpr size_t archivePayloadSize = 8192;
-constexpr size_t keyPayloadSize     = 4096;
-
+constexpr size_t archiveBufferSize = 8192;
+constexpr size_t keyBufferSize     = 4096;
 }
 
 //----------------------------------------------------------------------------------------------------------------------
@@ -66,13 +65,13 @@ void RemoteCatalogue::archive(const Key& idxKey, const Key& datumKey, std::share
         numLocations_++;
     }
 
-    Buffer       buffer(archivePayloadSize);
+    Buffer       buffer(archiveBufferSize);
     MemoryStream stream(buffer);
     stream << idxKey;
     stream << datumKey;
     stream << *fieldLocation;
 
-    std::vector<Payload> payloads;
+    PayloadList payloads;
     payloads.emplace_back(stream.position(), buffer.data());
 
     dataWrite(Message::Blob, id, payloads);
@@ -141,7 +140,7 @@ void RemoteCatalogue::loadSchema() {
         LOG_DEBUG_LIB(LibFdb5) << "RemoteCatalogue::loadSchema()" << std::endl;
 
         // send dbkey to remote.
-        eckit::Buffer       keyBuffer(keyPayloadSize);
+        eckit::Buffer       keyBuffer(keyBufferSize);
         eckit::MemoryStream keyStream(keyBuffer);
         keyStream << dbKey_;
 
@@ -180,18 +179,14 @@ void RemoteCatalogue::print( std::ostream &out ) const {
     out << "RemoteCatalogue(endpoint=" << controlEndpoint() << ",clientID=" << clientId() << ")";
 }
 
-std::string RemoteCatalogue::type() const {
-    return "remote";
-}
-
 bool RemoteCatalogue::open() {
     return true;
 }
 
 //----------------------------------------------------------------------------------------------------------------------
 
-static CatalogueReaderBuilder<RemoteCatalogue> reader("remote");
-static CatalogueWriterBuilder<RemoteCatalogue> writer("remote");
+static CatalogueReaderBuilder<RemoteCatalogue> reader(RemoteCatalogue::typeName());
+static CatalogueWriterBuilder<RemoteCatalogue> writer(RemoteCatalogue::typeName());
 
 //----------------------------------------------------------------------------------------------------------------------
 

src/fdb5/remote/client/RemoteCatalogue.h

@@ -24,13 +24,13 @@ namespace fdb5::remote {
 
 class RemoteCatalogue : public CatalogueReader, public CatalogueWriter, public CatalogueImpl, public Client {
 
-public:
+public:  // types
+    static const char* typeName() { return "remote"; }
 
+public:  // methods
     RemoteCatalogue(const Key& key, const Config& config);
     RemoteCatalogue(const eckit::URI& uri, const Config& config);
 
-    ~RemoteCatalogue() override = default;
-
     // From CatalogueWriter
     const Index& currentIndex() override;
     void archive(const Key& idxKey, const Key& datumKey, std::shared_ptr<const FieldLocation> fieldLocation) override;
@@ -59,8 +59,10 @@ class RemoteCatalogue : public CatalogueReader, public CatalogueWriter, public C
     std::vector<fdb5::Index> indexes(bool sorted=false) const override;
     void maskIndexEntry(const Index& index) const override;
     void allMasked(std::set<std::pair<eckit::URI, eckit::Offset>>& metadata, std::set<eckit::URI>& data) const override;
-    void print( std::ostream &out ) const override;
-    std::string type() const override;
+    void print(std::ostream& out) const override;
+
+    std::string type() const override { return typeName(); }
+
     bool open() override;
     void flush(size_t archivedFields) override;
     void clean() override;

src/fdb5/remote/client/RemoteStore.cc

@@ -270,7 +270,7 @@ void RemoteStore::archive(const Key& key, const void *data, eckit::Length length
     keyStream << dbKey_;
     keyStream << key;
 
-    std::vector<Payload> payloads;
+    PayloadList payloads;
     payloads.emplace_back(keyStream.position(), keyBuffer.data());
     payloads.emplace_back(length, data);