if (!txc->oncommits.empty()) {
finishers[n]->queue(txc->oncommits);
}
- op_queue_release_throttle(txc);
+ _op_queue_release_throttle(txc);
}
void BlueStore::BSPerfTracker::update_from_perfcounters(
txc->removed_collections.pop_front();
}
- op_queue_release_wal_throttle(txc);
+ _op_queue_release_wal_throttle(txc);
OpSequencerRef osr = txc->osr;
{
if (handle)
handle->suspend_tp_timeout();
- op_queue_reserve_throttle(txc);
- op_queue_reserve_wal_throttle(txc);
+ _op_queue_reserve_throttle(txc);
+ _op_queue_reserve_wal_throttle(txc);
if (handle)
handle->reset_tp_timeout();
return 0;
}
-void BlueStore::op_queue_reserve_throttle(TransContext *txc)
+void BlueStore::_op_queue_reserve_throttle(TransContext *txc)
{
throttle_ops.get(txc->ops);
throttle_bytes.get(txc->bytes);
logger->set(l_bluestore_cur_bytes_in_queue, throttle_bytes.get_current());
}
-void BlueStore::op_queue_release_throttle(TransContext *txc)
+void BlueStore::_op_queue_release_throttle(TransContext *txc)
{
throttle_ops.put(txc->ops);
throttle_bytes.put(txc->bytes);
logger->set(l_bluestore_cur_bytes_in_queue, throttle_bytes.get_current());
}
-void BlueStore::op_queue_reserve_wal_throttle(TransContext *txc)
+void BlueStore::_op_queue_reserve_wal_throttle(TransContext *txc)
{
throttle_wal_ops.get(txc->ops);
throttle_wal_bytes.get(txc->bytes);
logger->set(l_bluestore_cur_bytes_in_wal_queue, throttle_wal_bytes.get_current());
}
-void BlueStore::op_queue_release_wal_throttle(TransContext *txc)
+void BlueStore::_op_queue_release_wal_throttle(TransContext *txc)
{
throttle_wal_ops.put(txc->ops);
throttle_wal_bytes.put(txc->bytes);
CollectionRef& d,
unsigned bits, int rem);
- void op_queue_reserve_throttle(TransContext *txc);
- void op_queue_release_throttle(TransContext *txc);
- void op_queue_reserve_wal_throttle(TransContext *txc);
- void op_queue_release_wal_throttle(TransContext *txc);
+ void _op_queue_reserve_throttle(TransContext *txc);
+ void _op_queue_release_throttle(TransContext *txc);
+ void _op_queue_reserve_wal_throttle(TransContext *txc);
+ void _op_queue_release_wal_throttle(TransContext *txc);
};
inline ostream& operator<<(ostream& out, const BlueStore::OpSequencer& s) {