Searched refs:source_config (Results 1 – 5 of 5) sorted by relevance
68 const DataSourceConfig& source_config) { in StartDataSource() argument71 static_cast<BufferID>(source_config.target_buffer())); in StartDataSource()72 rnd_engine_ = std::minstd_rand0(source_config.for_testing().seed()); in StartDataSource()73 message_count_ = source_config.for_testing().message_count(); in StartDataSource()74 message_size_ = source_config.for_testing().message_size(); in StartDataSource()76 source_config.for_testing().max_messages_per_second(); in StartDataSource()77 if (source_config.for_testing().send_batch_on_register()) { in StartDataSource()
51 const DataSourceConfig& source_config) override;53 const DataSourceConfig& source_config) override;
83 const DataSourceConfig& source_config) override { in StartDataSource() argument85 static_cast<BufferID>(source_config.target_buffer())); in StartDataSource()
57 const DataSourceConfig& source_config) { in BuildMountpointMapping() argument60 source_config.inode_file_config().mount_point_mapping()) in BuildMountpointMapping()113 DataSourceConfig source_config, in InodeFileDataSource() argument121 source_config_(std::move(source_config)), in InodeFileDataSource()
258 DataSourceConfig source_config) { in CreateInodeFileDataSource() argument260 source_config.target_buffer()); in CreateInodeFileDataSource()261 auto buffer_id = static_cast<BufferID>(source_config.target_buffer()); in CreateInodeFileDataSource()265 std::move(source_config), task_runner_, session_id, &system_inodes_, in CreateInodeFileDataSource()