Method BlockServiceFileTracker

cpp/registry/BlockServiceFileTracker.cpp:11–20

#include <unistd.h>

BlockServiceFileTracker::BlockServiceFileTracker(Logger& logger, std::shared_ptr<XmonAgent>& xmon, const RegistryOptions& options, RegistryDB& db, RegistryServer& server, RegistryWriter& writer) :
    Loop(logger, xmon, "file_tracker"),
    _registryDB(db),
    _server(server),
    _writer(writer),
    _queue(MAX_SHARD_RESPONSES),
    _nextRequestId(RandomGenerator().generate64())
{
    _responses.reserve(MAX_SHARD_RESPONSES);
}

void BlockServiceFileTracker::step() {
    _processResponses();