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

Improved aggregate init syntax for DefaultPoolSizes map.

parent 8013a81a
No related branches found
No related tags found
No related merge requests found
...@@ -37,12 +37,13 @@ ...@@ -37,12 +37,13 @@
#include "llexception.h" #include "llexception.h"
#include "stringize.h" #include "stringize.h"
using namespace std::literals;
//========================================================================= //=========================================================================
// Map of pool sizes for known pools // Map of pool sizes for known pools
static const std::map<std::string, U32> DefaultPoolSizes = static const std::map<std::string, U32> DefaultPoolSizes{
{ {"Upload"s, 1},
{"Upload", 1}, {"AIS"s, 1},
{"AIS", 1},
// *TODO: Rider for the moment keep AIS calls serialized otherwise the COF will tend to get out of sync. // *TODO: Rider for the moment keep AIS calls serialized otherwise the COF will tend to get out of sync.
}; };
...@@ -347,7 +348,6 @@ void LLCoprocedurePool::coprocedureInvokerCoro(LLCoreHttpUtil::HttpCoroutineAdap ...@@ -347,7 +348,6 @@ void LLCoprocedurePool::coprocedureInvokerCoro(LLCoreHttpUtil::HttpCoroutineAdap
{ {
QueuedCoproc::ptr_t coproc; QueuedCoproc::ptr_t coproc;
boost::fibers::channel_op_status status; boost::fibers::channel_op_status status;
using namespace std::chrono_literals;
while ((status = mPendingCoprocs.pop_wait_for(coproc, 10s)) != boost::fibers::channel_op_status::closed) while ((status = mPendingCoprocs.pop_wait_for(coproc, 10s)) != boost::fibers::channel_op_status::closed)
{ {
if(status == boost::fibers::channel_op_status::timeout) if(status == boost::fibers::channel_op_status::timeout)
......
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