Skip to content
Snippets Groups Projects
Commit 828223bf authored by Brad Kittenbrink's avatar Brad Kittenbrink Committed by Nat Goodspeed
Browse files

Implemented some code review suggested cleanups.

parent 6ffbed48
No related branches found
No related tags found
No related merge requests found
......@@ -112,7 +112,6 @@ class LLCoprocedurePool: private boost::noncopyable
// we use a deque here rather than std::queue since we want to be able to
// iterate through the queue and potentially erase an entry from the middle.
// TODO - make this queue be backed by an unbuffered_channel
typedef boost::fibers::unbuffered_channel<QueuedCoproc::ptr_t> CoprocQueue_t;
typedef std::map<LLUUID, LLCoreHttpUtil::HttpCoroutineAdapter::ptr_t> ActiveCoproc_t;
......@@ -152,7 +151,7 @@ LLCoprocedureManager::poolPtr_t LLCoprocedureManager::initializePool(const std::
LL_ERRS_IF(poolName.empty(), "CoprocedureManager") << "Poolname must not be empty" << LL_ENDL;
if (mPropertyQueryFn && !mPropertyQueryFn.empty())
if (mPropertyQueryFn)
{
size = mPropertyQueryFn(keyName);
}
......@@ -164,7 +163,7 @@ LLCoprocedureManager::poolPtr_t LLCoprocedureManager::initializePool(const std::
auto it = DefaultPoolSizes.find(poolName);
size = (it != DefaultPoolSizes.end()) ? it->second : DEFAULT_POOL_SIZE;
if (mPropertyDefineFn && !mPropertyDefineFn.empty())
if (mPropertyDefineFn)
{
mPropertyDefineFn(keyName, size, "Coroutine Pool size for " + poolName);
}
......@@ -352,7 +351,7 @@ void LLCoprocedurePool::coprocedureInvokerCoro(LLCoreHttpUtil::HttpCoroutineAdap
{
if(status == boost::fibers::channel_op_status::timeout)
{
LL_INFOS() << "pool '" << mPoolName << "' stalled." << LL_ENDL;
LL_INFOS_ONCE() << "pool '" << mPoolName << "' stalled." << LL_ENDL;
continue;
}
......
0% Loading or .
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment