summaryrefslogtreecommitdiffstats
path: root/searchcore/src/apps/vespa-transactionlog-inspect/vespa-transactionlog-inspect.cpp
diff options
context:
space:
mode:
Diffstat (limited to 'searchcore/src/apps/vespa-transactionlog-inspect/vespa-transactionlog-inspect.cpp')
-rw-r--r--searchcore/src/apps/vespa-transactionlog-inspect/vespa-transactionlog-inspect.cpp16
1 files changed, 8 insertions, 8 deletions
diff --git a/searchcore/src/apps/vespa-transactionlog-inspect/vespa-transactionlog-inspect.cpp b/searchcore/src/apps/vespa-transactionlog-inspect/vespa-transactionlog-inspect.cpp
index 2f34292ad52..a7c53293981 100644
--- a/searchcore/src/apps/vespa-transactionlog-inspect/vespa-transactionlog-inspect.cpp
+++ b/searchcore/src/apps/vespa-transactionlog-inspect/vespa-transactionlog-inspect.cpp
@@ -286,7 +286,7 @@ public:
* and dispatches each packet entry to the ReplayPacketDispatcher that
* transforms them into concrete operations.
*/
-class VisitorCallback : public TransLogClient::Session::Callback
+class VisitorCallback : public client::Callback
{
private:
ReplayPacketDispatcher _dispatcher;
@@ -298,7 +298,7 @@ public:
_eof(false)
{
}
- virtual RPC::Result receive(const Packet &packet) override {
+ client::RPC::Result receive(const Packet &packet) override {
vespalib::nbostream_longlivedbuf handle(packet.getHandle().data(), packet.getHandle().size());
try {
while (handle.size() > 0) {
@@ -309,11 +309,11 @@ public:
} catch (const std::exception &e) {
std::cerr << "Error while handling transaction log packet: '"
<< std::string(e.what()) << "'" << std::endl;
- return RPC::ERROR;
+ return client::RPC::ERROR;
}
- return RPC::OK;
+ return client::RPC::OK;
}
- virtual void eof() override { _eof = true; }
+ void eof() override { _eof = true; }
bool isEof() const { return _eof; }
};
@@ -371,7 +371,7 @@ protected:
const BaseOptions &_bopts;
DummyFileHeaderContext _fileHeader;
TransLogServer _server;
- TransLogClient _client;
+ client::TransLogClient _client;
public:
BaseUtility(const BaseOptions &bopts)
@@ -416,7 +416,7 @@ public:
_client.listDomains(domains);
std::cout << "Listing status for " << domains.size() << " domain(s):" << std::endl;
for (size_t i = 0; i < domains.size(); ++i) {
- TransLogClient::Session::UP session = _client.open(domains[i]);
+ std::unique_ptr<client::Session> session = _client.open(domains[i]);
SerialNum first;
SerialNum last;
size_t count;
@@ -484,7 +484,7 @@ protected:
DocTypeRepo repo(_oopts.configDir);
IReplayPacketHandlerUP handler = createHandler(repo.docTypeRepo);
VisitorCallback callback(*handler);
- TransLogClient::Visitor::UP visitor = _client.createVisitor(_oopts.domainName, callback);
+ std::unique_ptr<client::Visitor> visitor = _client.createVisitor(_oopts.domainName, callback);
bool visitOk = visitor->visit(_oopts.firstSerialNum-1, _oopts.lastSerialNum);
if (!visitOk) {
std::cerr << "Visiting domain '" << _oopts.domainName << "' [" << _oopts.firstSerialNum << ","