sallsdk/spc/mpi.c

79   memoryMap->region[memoryMap->count].elementSize = sizeof(bit8) * config->mainConfig.eventLogSize;
89   memoryMap->region[memoryMap->count].elementSize = sizeof(bit8) * config->mainConfig.IOPeventLogSize;
98   memoryMap->region[memoryMap->count].elementSize = sizeof(bit32) * config->numInboundQueues;
107   memoryMap->region[memoryMap->count].elementSize = sizeof(bit32) * config->numOutboundQueues;
120         bit32 memSize = config->inboundQueues[qIdx].numElements * config->inboundQueues[qIdx].elementSize;
132             memoryMap->region[memoryMap->count].elementSize = memSize;
139             memoryMap->region[memoryMap->count].elementSize += memSize;
148             SA_DBG2(("mpiRequirementsGet: (inboundQueues) memoryMap->region[%d].elementSize = %d\n",
149                      memoryMap->count, memoryMap->region[memoryMap->count].elementSize));
165         bit32 memSize = config->outboundQueues[qIdx].numElements * config->outboundQueues[qIdx].elementSize;
177             memoryMap->region[memoryMap->count].elementSize = memSize;
184             memoryMap->region[memoryMap->count].elementSize += memSize;
193             SA_DBG2(("mpiRequirementsGet: (outboundQueues) memoryMap->region[%d].elementSize = %d\n",
194                      memoryMap->count, memoryMap->region[memoryMap->count].elementSize));
222  *         AGSA_RC_FAILURE if messageSize larger than the elementSize of queue
245   if(messageSize > circularQ->elementSize)
247     SA_DBG1(("mpiMsgFreeGet: Message Size (%d) is larger than Q element size (%d)\n",messageSize,circularQ->elementSize));
273   offset = circularQ->producerIdx * circularQ->elementSize;
305   if(messageSize > circularQ->elementSize)
324   offset = circularQ->producerIdx * circularQ->elementSize;
404                     (void *)msgHeader, circularQ->elementSize * bc);
409                  (void *)msgHeader, circularQ->elementSize * bc);
415                   circularQ->elementSize);
421               circularQ->elementSize);
530   ossaCachePreFlush(circularQ->agRoot, (void *)circularQ->memoryRegion.appHandle, (void *)msgHeader, circularQ->elementSize * bc);
533   ossaCacheFlush(circularQ->agRoot, (void *)circularQ->memoryRegion.appHandle, (void *)msgHeader, circularQ->elementSize * bc);
539                   circularQ->elementSize);
545               circularQ->elementSize);
548   MPI_IBQ_IOMB_LOG(circularQ->qNumber, (void *)msgHeader, circularQ->elementSize);
554   for (i=0; i<((bit32)bc*(circularQ->elementSize/4)); i++)
684       msgHeader = (mpiMsgHeader_t*) ((bit8 *)(circularQ->memoryRegion.virtPtr) + circularQ->consumerIdx * circularQ->elementSize);
690       ossaCacheInvalidate(circularQ->agRoot, (void *)circularQ->memoryRegion.appHandle, (void *)msgHeader, circularQ->elementSize);
730             ossaCacheInvalidate(circularQ->agRoot, (void *)circularQ->memoryRegion.appHandle, (void *)msgHeader, (*pBC - 1) * circularQ->elementSize);
734           MPI_OBQ_IOMB_LOG(circularQ->qNumber, (void *)msgHeader, circularQ->elementSize);
771                           circularQ->elementSize);
780         MPI_OBQ_IOMB_LOG(circularQ->qNumber, (void *)msgHeader, circularQ->elementSize);
833   if ( ((mpiMsgHeader_t*)((bit8*)circularQ->memoryRegion.virtPtr + circularQ->consumerIdx * circularQ->elementSize)) != msgHeader)
837     SA_DBG1(("mpiMsgFreeSet: msgHeader %p != %p\n", msgHeader,((mpiMsgHeader_t*)((bit8*)circularQ->memoryRegion.virtPtr + circularQ->consumerIdx * circularQ->elementSize))));
956   //                  (void *)msgHeader, circularQ->elementSize * bc);
962   //               (void *)msgHeader, circularQ->elementSize * bc);
968                   circularQ->elementSize);
974               circularQ->elementSize);