490    agsaLLRoot_t *saRoot = agNULL;  in mpiMsgProduce()  local
491   saRoot = agRoot->sdkData;  in mpiMsgProduce()
564   if(saRoot->BunchStarts_Enable)  in mpiMsgProduce()
569           circularQ->BunchStarts_QPendingTick = saRoot->timeTick;  in mpiMsgProduce()
575       saRoot->BunchStarts_Pending++;  in mpiMsgProduce()
577       SA_DBG1(("mpiMsgProduce: BunchStarts - Global Pending %d\n", saRoot->BunchStarts_Pending));  in mpiMsgProduce()
584   saRoot->BunchStarts_Pending     = 0;  in mpiMsgProduce()
600 void mpiMsgProduceBunch(  agsaLLRoot_t  *saRoot)  in mpiMsgProduceBunch()  argument
605   for(inq=0; ((inq < saRoot->QueueConfig.numInboundQueues) && saRoot->BunchStarts_Pending); inq++)  in mpiMsgProduceBunch()
607     circularQ= &saRoot->inboundQueue[inq];  in mpiMsgProduceBunch()
612         ((circularQ->BunchStarts_QPending >= saRoot->BunchStarts_Threshold) ||   in mpiMsgProduceBunch()
613 …    ((saRoot->timeTick - circularQ->BunchStarts_QPendingTick) >= saRoot->BunchStarts_TimeoutTicks))  in mpiMsgProduceBunch()
622 …ceBunch: Qpending=%d, TotPending=%d\n", circularQ->BunchStarts_QPending, saRoot->BunchStarts_Pendi…  in mpiMsgProduceBunch()
630       saRoot->BunchStarts_Pending -= circularQ->BunchStarts_QPending;  in mpiMsgProduceBunch()
634       circularQ->BunchStarts_QPendingTick = saRoot->timeTick;  in mpiMsgProduceBunch()
880   agsaLLRoot_t *saRoot = (agsaLLRoot_t *) (agRoot->sdkData);  in mpiRotateQnumber()  local
885   saRoot->IBQnumber++;  in mpiRotateQnumber()
886   denom = saRoot->QueueConfig.numInboundQueues;  in mpiRotateQnumber()
887   if (saRoot->IBQnumber % denom == 0) /* % Qnumber*/  in mpiRotateQnumber()
889     saRoot->IBQnumber = 0;  in mpiRotateQnumber()
891   SA_DBG3(("mpiRotateQnumber: IBQnumber %d\n", saRoot->IBQnumber));  in mpiRotateQnumber()
894   saRoot->OBQnumber++;  in mpiRotateQnumber()
895   denom = saRoot->QueueConfig.numOutboundQueues;  in mpiRotateQnumber()
896   if (saRoot->OBQnumber % denom == 0) /* % Qnumber*/  in mpiRotateQnumber()
898     saRoot->OBQnumber = 0;  in mpiRotateQnumber()
900   SA_DBG3(("mpiRotateQnumber: OBQnumber %d\n", saRoot->OBQnumber));  in mpiRotateQnumber()
902   ret = (saRoot->OBQnumber << SHIFT16) | saRoot->IBQnumber;  in mpiRotateQnumber()