24 const std::vector<size_t>& vecTokensNotDispatched) {
25 size_t numTokensNotDispatched = vecTokensNotDispatched.size();
26 assert(numTokensNotDispatched > 0);
27 size_t numSeqNumToPrint =
28 (numTokensNotDispatched > 10 ? 10 : numTokensNotDispatched);
31 for (
size_t i = 1;
i < numSeqNumToPrint; ++
i) {
34 if (numSeqNumToPrint < numTokensNotDispatched) {
35 strInputsNotFound +=
"...";
38 "{} input tokens (seq nums: {}) destroyed before calling dispatch",
39 numTokensNotDispatched,
44 size_t numExpectedResults,
45 size_t numActualResults) {
47 "Unexpected number of results ({}) returned from dispatch function, "
std::string sformat(StringPiece fmt, Args &&...args)
—— Concurrent Priority Queue Implementation ——
std::string createABDTokenNotDispatchedExMsg(const std::vector< size_t > &vecTokensNotDispatched)
std::string createUnexpectedNumResultsABDUsageExMsg(size_t numExpectedResults, size_t numActualResults)