Function wipeBlockServicePorts

cpp/registry/RegistryDB.cpp:135–164

}

static void wipeBlockServicePorts(rocksdb::WriteBatch& batch, rocksdb::DB* db,
    rocksdb::ColumnFamilyHandle* blockServiceCf, rocksdb::ColumnFamilyHandle* writableBlockServiceCf, rocksdb::ColumnFamilyHandle* lastHeartBeatCf)
{
    auto* it = db->NewIterator(rocksdb::ReadOptions(), blockServiceCf);
    auto now = ternNow();
    for (it->SeekToFirst(); it->Valid(); it->Next()) {
        FullBlockServiceInfo info;
        readBlockServiceInfo(it->key(), it->value(), info);
        if (info.flags == BlockServiceFlags::DECOMMISSIONED) {
            continue;
        }
        for (auto& addr : info.addrs.addrs) {
            addr.port = 0;
        }
        StaticValue<WritableBlockServiceKey> writableKey;
        StaticValue<LastHeartBeatKey> lastHeartBeat;
        bool wasWritable = false;
        if (blockServiceFlagsWritable(info.flags) && info.availableBytes > 0) {
            blockServiceToWritableBlockServiceKey(info, writableKey());
            batch.Delete(writableBlockServiceCf, writableKey.toSlice());
        }
        blockServiceToLastHeartBeat(info, lastHeartBeat());
        batch.Delete(lastHeartBeatCf, lastHeartBeat.toSlice());
        info.flags = info.flags | BlockServiceFlags::STALE;
        info.lastInfoChange = now;
        writeBlockServiceInfo(batch, blockServiceCf, info);
    }
    ROCKS_DB_CHECKED(it->status());
    delete it;
}

void RegistryDB::processLogEntries(std::vector<LogsDBLogEntry>& logEntries, std::vector<RegistryDBWriteResult>& writeResults) {
    auto expectedLogEntry = lastAppliedLogEntry();