Skip to content

Commit

Permalink
cleanup
Browse files Browse the repository at this point in the history
  • Loading branch information
danovaro committed Dec 8, 2023
1 parent de5d324 commit e094c0f
Show file tree
Hide file tree
Showing 3 changed files with 4 additions and 4 deletions.
2 changes: 1 addition & 1 deletion src/fdb5/remote/RemoteStore.cc
Original file line number Diff line number Diff line change
Expand Up @@ -474,7 +474,7 @@ void RemoteStore::remove(const Key& key) const {
}

void RemoteStore::print(std::ostream &out) const {
out << "RemoteStore(host=" << /*controlEndpoint() << ", data=" << dataEndpoint() << */ ")";
out << "RemoteStore(host=" << controlEndpoint() /* << ", data=" << dataEndpoint() */ << ")";
}

bool RemoteStore::handle(Message message, uint32_t requestID) {
Expand Down
4 changes: 2 additions & 2 deletions src/fdb5/remote/client/ClientConnection.cc
Original file line number Diff line number Diff line change
Expand Up @@ -133,7 +133,7 @@ eckit::LocalConfiguration ClientConnection::availableFunctionality() const {

// -----------------------------------------------------------------------------------------------------

void ClientConnection::controlWrite(Client& client, Message msg, uint32_t requestID, uint32_t clientID, std::vector<std::pair<const void*, uint32_t>> data) {
void ClientConnection::controlWrite(Client& client, Message msg, uint32_t requestID, uint32_t archiverID, std::vector<std::pair<const void*, uint32_t>> data) {

{
std::lock_guard<std::mutex> lock(requestMutex_);
Expand All @@ -143,7 +143,7 @@ void ClientConnection::controlWrite(Client& client, Message msg, uint32_t reques
}
}

controlWrite(msg, clientID ? clientID : client.id(), requestID, data);
controlWrite(msg, archiverID ? archiverID : client.id(), requestID, data);
}

void ClientConnection::controlWrite(Message msg, uint32_t clientID, uint32_t requestID, std::vector<std::pair<const void*, uint32_t>> data) {
Expand Down
2 changes: 1 addition & 1 deletion src/fdb5/remote/client/ClientConnection.h
Original file line number Diff line number Diff line change
Expand Up @@ -44,7 +44,7 @@ class ClientConnection : eckit::NonCopyable {
ClientConnection(const FdbEndpoint& controlEndpoint);
virtual ~ClientConnection();

void controlWrite(Client& client, remote::Message msg, uint32_t requestID, uint32_t clientID=0, std::vector<std::pair<const void*, uint32_t>> data={});
void controlWrite(Client& client, remote::Message msg, uint32_t requestID, uint32_t archiverID=0, std::vector<std::pair<const void*, uint32_t>> data={});
void dataWrite (Client& client, remote::Message msg, uint32_t requestID, std::vector<std::pair<const void*, uint32_t>> data={});

bool connect(bool singleAttempt = false);
Expand Down

0 comments on commit e094c0f

Please sign in to comment.