Signed-off-by: xinxin shu <xinxin.shu@intel.com>
bool should_wait(int64_t c) const {
return _should_wait(c);
}
+ void reset_max(int64_t m) {
+ Mutex::Locker l(lock);
+ _reset_max(m);
+ }
};
m_filestore_sloppy_crc = conf->filestore_sloppy_crc;
m_filestore_sloppy_crc_block_size = conf->filestore_sloppy_crc_block_size;
m_filestore_max_alloc_hint_size = conf->filestore_max_alloc_hint_size;
+ throttle_ops.reset_max(conf->filestore_queue_max_ops);
+ throttle_bytes.reset_max(conf->filestore_queue_max_bytes);
}
if (changed.count("filestore_commit_timeout")) {
Mutex::Locker l(sync_entry_timeo_lock);
m_keyvaluestore_queue_max_ops = conf->keyvaluestore_queue_max_ops;
m_keyvaluestore_queue_max_bytes = conf->keyvaluestore_queue_max_bytes;
m_keyvaluestore_max_expected_write_size = conf->keyvaluestore_max_expected_write_size;
+ throttle_ops.reset_max(conf->keyvaluestore_queue_max_ops);
+ throttle_bytes.reset_max(conf->keyvaluestore_queue_max_bytes);
}
if (changed.count("keyvaluestore_default_strip_size")) {
m_keyvaluestore_strip_size = conf->keyvaluestore_default_strip_size;