src/base/cp_annotate.cc

442     int qi = getQ(sysi, q, id);
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);
471     int qi = getQ(sysi, q, id);
476             q, id, qSize[qi-1], qData[qi-1].size(), qBytes[qi-1], count);
479     doDq(sys, FL_NONE, tc->contextId(), smi, q, qi, count);
500     int qi = getQ(sysi, q, id);
505             q, id, qSize[qi-1], qData[qi-1].size(), qBytes[qi-1], count);
508     if (qBytes[qi-1] < count) {
514     add(OP_PEEK, FL_NONE, tc->contextId(), smi, qi, count);
535     int qi = getQ(sysi, q, id);
540             q, id, qSize[qi-1], qData[qi-1].size(), qBytes[qi-1], count);
544     add(OP_RESERVE, FL_NONE, tc->contextId(), smi, qi, count);
566     int qi = getQ(sysi, q, id);
567     add(OP_WAIT_FULL, FL_NONE, tc->contextId(), smi, qi, count);
594     int qi = getQ(sysi, q, id);
595     add(OP_WAIT_EMPTY, FL_NONE, tc->contextId(), smi, qi, count);
624     int qi = getQ(sysi, q, id);
626              q, id, qSize[qi-1], qBytes[qi-1], size);
630         add(OP_SIZE_QUEUE, FL_NONE, tc->contextId(), smi, qi, 0);
631         qData[qi-1].clear();
632         qSize[qi-1] = 0;
633         qBytes[qi-1] = 0;
636     if (qBytes[qi-1] < size)
637         doQ(sys, FL_NONE, tc->contextId(), smi, q, qi, size - qBytes[qi-1]);
638     else if (qBytes[qi-1] > size) {
640         add(OP_SIZE_QUEUE, FL_NONE, tc->contextId(), smi, qi, size);
642             qData[qi-1].clear();
643             qSize[qi-1] = 0;
644             qBytes[qi-1] = 0;
647         int need = qBytes[qi-1] - size;
648         qBytes[qi-1] = size;
650             int32_t tail_bytes = qData[qi-1].back()->data;
651             if (qSize[qi-1] <= 0 || qBytes[qi-1] < 0) {
657                 qData[qi-1].back()->data -= need;
660                 qData[qi-1].pop_back();
661                 qSize[qi-1]--;
664                 qData[qi-1].pop_back();
665                 qSize[qi-1]--;
687     int qi = getQ(sysi, q, id);
688     if (qBytes[qi-1] != size) {
692         std::list<AnnDataPtr>::iterator ai = qData[qi-1].begin();
694         while (ai != qData[qi-1].end()) {
702             curTick(), size, q, qBytes[qi-1]);
705             curTick(), size, q, qBytes[qi-1]);
981               string q, int qi, int count)
983     qSize[qi-1]++;
984     qBytes[qi-1] += count;
985     if (qSize[qi-1] > 2501 || qBytes[qi-1] > 2000000000)
988                 q, qSize[qi-1], qBytes[qi-1]);
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));
994             q, qSize[qi-1], qBytes[qi-1]);
995     assert(qSize[qi-1] >= 0);
996     assert(qBytes[qi-1] >= 0);
1002                string q, int qi, int count)
1007         add(OP_DEQUEUE, flags, cpuid, sm, qi, count);
1008         qData[qi-1].clear();
1009         qSize[qi-1] = 0;
1010         qBytes[qi-1] = 0;
1012                 q, qSize[qi-1], qBytes[qi-1]);
1017     if (qSize[qi-1] <= 0 || qBytes[qi-1] <= 0 || !qData[qi-1].size()) {
1023     assert(qSize[qi-1] >= 0);
1024     assert(qBytes[qi-1] >= 0);
1025     assert(qData[qi-1].size());
1028     qBytes[qi-1] -= count;
1029     if (qBytes[qi-1] < 0) {
1037         int32_t head_bytes = qData[qi-1].front()->data;
1038         if (qSize[qi-1] <= 0 || qBytes[qi-1] < 0) {
1046             qData[qi-1].front()->data -= need;
1049             qData[qi-1].pop_front();
1050             qSize[qi-1]--;
1053             qData[qi-1].pop_front();
1054             qSize[qi-1]--;
1059     add(OP_DEQUEUE, flags, cpuid, sm, qi, count);
1061             q, qSize[qi-1], qBytes[qi-1]);