Lines Matching refs:rate_limiter

317                           bool sync, RateLimiter* rate_limiter,
344 RateLimiter* rate_limiter; member
357 rate_limiter(nullptr), in CopyOrCreateWorkItem()
375 rate_limiter = o.rate_limiter; in operator =()
394 rate_limiter(_rate_limiter),
491 const EnvOptions& src_env_options, RateLimiter* rate_limiter,
765 work_item.sync, work_item.rate_limiter, &result.size, in Initialize()
831 RateLimiter* rate_limiter = options_.backup_rate_limiter.get(); in CreateNewBackupWithMetadata() local
832 if (rate_limiter) { in CreateNewBackupWithMetadata()
833 copy_file_buffer_size_ = static_cast<size_t>(rate_limiter->GetSingleBurstBytes()); in CreateNewBackupWithMetadata()
894 fname, src_env_options, rate_limiter, size_bytes, in CreateNewBackupWithMetadata()
906 EnvOptions() /* src_env_options */, rate_limiter, contents.size(), in CreateNewBackupWithMetadata()
1189 RateLimiter* rate_limiter = options_.restore_rate_limiter.get(); in RestoreDBFromBackup() local
1190 if (rate_limiter) { in RestoreDBFromBackup()
1191 copy_file_buffer_size_ = static_cast<size_t>(rate_limiter->GetSingleBurstBytes()); in RestoreDBFromBackup()
1227 EnvOptions() /* src_env_options */, false, rate_limiter, in RestoreDBFromBackup()
1298 RateLimiter* rate_limiter, uint64_t* size, uint32_t* checksum_value, in CopyOrCreateFile() argument
1366 if (rate_limiter != nullptr) { in CopyOrCreateFile()
1367 rate_limiter->Request(data.size(), Env::IO_LOW, nullptr /* stats */, in CopyOrCreateFile()
1392 RateLimiter* rate_limiter, uint64_t size_bytes, uint64_t size_limit, in AddBackupFileWorkItem() argument
1492 db_env_, backup_env_, src_env_options, options_.sync, rate_limiter, in AddBackupFileWorkItem()