<commit_before>#pragma once
#include <dariadb.h>
#include <atomic>

namespace dariadb_bench 
{
    const size_t total_threads_count = 1;
    const size_t iteration_count = 100000;

	void thread_writer_rnd_stor(
		dariadb::Id id, 
		dariadb::Time sleep_time, 
		std::atomic_long *append_count,
		dariadb::storage::BaseStorage_ptr ms)
	{
		auto m = dariadb::Meas::empty();
		m.time = 0;
		for (size_t i = 0; i < dariadb_bench::iteration_count; i++) {
			m.id = id;
			m.flag = dariadb::Flag(id);
			m.time += sleep_time;
			m.value = dariadb::Value(i);
			ms->append(m);
			(*append_count)++;
			//std::this_thread::sleep_for(sleep_duration);
		}
	}
}<commit_msg>verbose.<commit_after>#pragma once
#include <dariadb.h>
#include <atomic>

namespace dariadb_bench 
{
    const size_t total_threads_count = 1;
    const size_t iteration_count = 100000;

	void thread_writer_rnd_stor(
		dariadb::Id id, 
		dariadb::Time sleep_time, 
		std::atomic_long *append_count,
		dariadb::storage::BaseStorage_ptr ms)
	{
		auto m = dariadb::Meas::empty();
		m.time = 0;
		for (size_t i = 0; i < dariadb_bench::iteration_count; i++) {
			
			m.id = id;
			m.flag = dariadb::Flag(id);
			m.src = dariadb::Flag(id);
			m.time += sleep_time;
			m.value = dariadb::Value(i);
			if (m.time == dariadb::Time(59818)) {
				std::cout << "bug\n";
			}
			ms->append(m);
			(*append_count)++;
			//std::this_thread::sleep_for(sleep_duration);
		}
	}
}
{'fraction_non_alphanumeric': 0.15811665495432187, 'fraction_numerical': 0.016163035839775124, 'mean_word_length': 3.979020979020979, 'pattern_counts': {'":': 0, '<': 11, '<?xml version=': 0, '>': 9, 'https://': 0, 'lorem ipsum': 0, 'www.': 0, 'xml': 0}, 'pii_count': 0, 'substrings_counts': 0, 'word_list_counts': {'cursed_substrings.json': 0, 'profanity_word_list.json': 0, 'sexual_word_list.json': 0, 'zh_pornsignals.json': 0}}
{'dir': 'git-commits-cleaned', 'id': '2727263', 'n_tokens_mistral': 675, 'n_tokens_neox': 590, 'n_words': 105}