Skip to content

Commit

Permalink
Merge pull request #13409 from xiexingguo/wip-fix-throttler-name
Browse files Browse the repository at this point in the history
os/bluestore: add "_" prefix for internal methods

Reviewed-by: Sage Weil <sage@redhat.com>
  • Loading branch information
liewegas committed Feb 14, 2017
2 parents a2fb70d + 7cb210d commit 494f05a
Show file tree
Hide file tree
Showing 2 changed files with 12 additions and 12 deletions.
16 changes: 8 additions & 8 deletions src/os/bluestore/BlueStore.cc
Expand Up @@ -7139,7 +7139,7 @@ void BlueStore::_txc_finish_kv(TransContext *txc)
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(
Expand Down Expand Up @@ -7178,7 +7178,7 @@ void BlueStore::_txc_finish(TransContext *txc)
txc->removed_collections.pop_front();
}

op_queue_release_wal_throttle(txc);
_op_queue_release_wal_throttle(txc);

OpSequencerRef osr = txc->osr;
{
Expand Down Expand Up @@ -7627,8 +7627,8 @@ int BlueStore::queue_transactions(
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();
Expand All @@ -7642,7 +7642,7 @@ int BlueStore::queue_transactions(
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);
Expand All @@ -7651,7 +7651,7 @@ void BlueStore::op_queue_reserve_throttle(TransContext *txc)
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);
Expand All @@ -7660,7 +7660,7 @@ void BlueStore::op_queue_release_throttle(TransContext *txc)
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);
Expand All @@ -7669,7 +7669,7 @@ void BlueStore::op_queue_reserve_wal_throttle(TransContext *txc)
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);
Expand Down
8 changes: 4 additions & 4 deletions src/os/bluestore/BlueStore.h
Expand Up @@ -2317,10 +2317,10 @@ class BlueStore : public ObjectStore,
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) {
Expand Down

0 comments on commit 494f05a

Please sign in to comment.