/** * Copyright (C) 2018-present MongoDB, Inc. * * This program is free software: you can redistribute it and/or modify * it under the terms of the Server Side Public License, version 1, * as published by MongoDB, Inc. * * This program is distributed in the hope that it will be useful, * but WITHOUT ANY WARRANTY; without even the implied warranty of * MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the * Server Side Public License for more details. * * You should have received a copy of the Server Side Public License * along with this program. If not, see * . * * As a special exception, the copyright holders give permission to link the * code of portions of this program with the OpenSSL library under certain * conditions as described in each individual source file and distribute * linked combinations including the program with the OpenSSL library. You * must comply with the Server Side Public License in all respects for * all of the code used other than as permitted herein. If you modify file(s) * with this exception, you may extend this exception to your version of the * file(s), but you are not obligated to do so. If you do not wish to do so, * delete this exception statement from your version. If you delete this * exception statement from all source files in the program, then also delete * it in the license file. */ #define MONGO_LOGV2_DEFAULT_COMPONENT ::mongo::logv2::LogComponent::kDefault #include "mongo/platform/basic.h" #include "mongo/util/progress_meter.h" #include "mongo/logv2/log.h" namespace mongo { void ProgressMeter::reset(unsigned long long total, int secondsBetween, int checkInterval) { _total = total; _secondsBetween = secondsBetween; _checkInterval = checkInterval; _done = 0; _hits = 0; _lastTime = (int)time(nullptr); _active = true; } bool ProgressMeter::hit(int n) { if (!_active) { LOGV2_WARNING(23370, "hit an inactive ProgressMeter"); return false; } _done += n; _hits++; if (_hits % _checkInterval) return false; int t = (int)time(nullptr); if (t - _lastTime < _secondsBetween) return false; if (_total > 0) { std::string stashedName = getName(); int per = (int)(((double)_done * 100.0) / (double)_total); logv2::DynamicAttributes attrs; attrs.add("name", stashedName); attrs.add("done", _done); if (_showTotal) { attrs.add("total", _total); attrs.add("percent", per); } if (!_units.empty()) { attrs.add("units", _units); } LOGV2(51773, "progress meter", attrs); } _lastTime = t; return true; } std::string ProgressMeter::toString() const { if (!_active) return ""; std::stringstream buf; if (_total) { buf << getName() << ": " << _done << '/' << _total << ' ' << (_done * 100) / _total << '%'; } else { buf << getName() << ": not started"; } if (!_units.empty()) { buf << " (" << _units << ")" << std::endl; } return buf.str(); } } // namespace mongo