src/base/cp_annotate.cc

351         if (userApp.count(app))
432     int32_t count = args[2];
443     if (count == 0) {
449             q, id, qSize[qi-1], qData[qi-1].size(), qBytes[qi-1], count);
450     doQ(sys, FL_NONE, tc->contextId(), smi, q, qi, count);
463     int32_t count = args[2];
476             q, id, qSize[qi-1], qData[qi-1].size(), qBytes[qi-1], count);
477     assert(count != 0);
479     doDq(sys, FL_NONE, tc->contextId(), smi, q, qi, count);
493     int32_t count = args[2];
505             q, id, qSize[qi-1], qData[qi-1].size(), qBytes[qi-1], count);
507     assert(count != 0);
508     if (qBytes[qi-1] < count) {
514     add(OP_PEEK, FL_NONE, tc->contextId(), smi, qi, count);
528     int32_t count = args[2];
540             q, id, qSize[qi-1], qData[qi-1].size(), qBytes[qi-1], count);
542     assert(count != 0);
544     add(OP_RESERVE, FL_NONE, tc->contextId(), smi, qi, count);
559     int32_t count = args[3];
567     add(OP_WAIT_FULL, FL_NONE, tc->contextId(), smi, qi, count);
587     int32_t count = args[3];
595     add(OP_WAIT_EMPTY, FL_NONE, tc->contextId(), smi, qi, count);
981               string q, int qi, int count)
984     qBytes[qi-1] += count;
990         qData[qi-1].push_front(add(OP_QUEUE, flags, cpuid, sm, qi, count));
992         qData[qi-1].push_back(add(OP_QUEUE, flags, cpuid, sm, qi, count));
1002                string q, int qi, int count)
1006     if (count == -1) {
1007         add(OP_DEQUEUE, flags, cpuid, sm, qi, count);
1016     assert(count > 0);
1027     int32_t need = count;
1028     qBytes[qi-1] -= count;
1059     add(OP_DEQUEUE, flags, cpuid, sm, qi, count);
1154         paramOut(os, csprintf("smStackId%d.count", x), si->second.size());
1303         int count;
1306         paramIn(cp, csprintf("smStackId%d.count", x), count);
1308         for (int y = 0; y < count; y++) {