#include <cstdint>
#include <initializer_list>
#include <optional>
#include <utility>
#include "base/containers/flat_map.h"
#include "base/files/file_path.h"
#include "base/files/file_util.h"
#include "base/files/scoped_temp_dir.h"
#include "base/memory/raw_ptr.h"
#include "base/strings/strcat.h"
#include "base/strings/string_number_conversions.h"
#include "base/synchronization/waitable_event.h"
#include "base/task/sequenced_task_runner.h"
#include "base/task/thread_pool.h"
#include "base/test/scoped_feature_list.h"
#include "base/test/task_environment.h"
#include "base/thread_annotations.h"
#include "base/types/expected.h"
#include "components/reporting/compression/compression_module.h"
#include "components/reporting/compression/test_compression_module.h"
#include "components/reporting/encryption/test_encryption_module.h"
#include "components/reporting/proto/synced/record.pb.h"
#include "components/reporting/resources/resource_manager.h"
#include "components/reporting/storage/storage_configuration.h"
#include "components/reporting/storage/storage_queue.h"
#include "components/reporting/util/status.h"
#include "components/reporting/util/status_macros.h"
#include "components/reporting/util/statusor.h"
#include "components/reporting/util/test_support_callbacks.h"
#include "crypto/sha2.h"
#include "testing/gmock/include/gmock/gmock.h"
#include "testing/gtest/include/gtest/gtest.h"
Eq;
namespace reporting {
namespace {
constexpr size_t kTotalQueueStarts = …;
constexpr size_t kTotalWritesPerStart = …;
constexpr char kDataPrefix[] = …;
class TestUploadClient : public UploaderInterface { … };
class StorageQueueStressTest : public ::testing::TestWithParam<size_t> { … };
TEST_P(StorageQueueStressTest,
WriteIntoNewStorageQueueReopenWriteMoreAndUpload) { … }
INSTANTIATE_TEST_SUITE_P(…);
}
}