Lines Matching refs:nMessages
326 bool copyTo(const T* data, size_t startIdx, size_t nMessages = 1);
342 bool copyFrom(T* data, size_t startIdx, size_t nMessages = 1);
367 bool inline getMemRegionInfo(size_t idx, size_t nMessages, size_t& firstCount,
387 bool beginWrite(size_t nMessages, MemTransaction* memTx) const;
396 bool commitWrite(size_t nMessages);
411 bool beginRead(size_t nMessages, MemTransaction* memTx) const;
422 bool commitRead(size_t nMessages);
478 size_t startIdx, size_t nMessages, size_t& firstCount, size_t& secondCount, in getMemRegionInfo() argument
483 if (startIdx + nMessages > firstRegionLength + secondRegionLength) { in getMemRegionInfo()
493 startIdx < firstRegionLength ? std::min(nMessages, firstRegionLength - startIdx) : 0; in getMemRegionInfo()
496 secondCount = nMessages - firstCount; in getMemRegionInfo()
513 size_t nMessages) { in copyFrom() argument
521 if (getMemRegionInfo(startIdx, nMessages, firstReadCount, secondReadCount, &firstBaseAddress, in copyFrom()
544 size_t nMessages) { in copyTo() argument
552 if (getMemRegionInfo(startIdx, nMessages, firstWriteCount, secondWriteCount, &firstBaseAddress, in copyTo()
806 bool MessageQueueBase<MQDescriptorType, T, flavor>::write(const T* data, size_t nMessages) { in write() argument
808 return beginWrite(nMessages, &tx) && tx.copyTo(data, 0 /* startIdx */, nMessages) && in write()
809 commitWrite(nMessages); in write()
1060 bool MessageQueueBase<MQDescriptorType, T, flavor>::beginWrite(size_t nMessages, in beginWrite() argument
1067 if ((flavor == kSynchronizedReadWrite && (availableToWrite() < nMessages)) || in beginWrite()
1068 nMessages > getQuantumCount()) { in beginWrite()
1089 if (contiguousMessages < nMessages) { in beginWrite()
1096 MemRegion(reinterpret_cast<T*>(mRing), nMessages - contiguousMessages)); in beginWrite()
1102 *result = MemTransaction(MemRegion(reinterpret_cast<T*>(mRing + writeOffset), nMessages), in beginWrite()
1115 MessageQueueBase<MQDescriptorType, T, flavor>::commitWrite(size_t nMessages) { in commitWrite() argument
1116 size_t nBytesWritten = nMessages * sizeof(T); in commitWrite()
1138 bool MessageQueueBase<MQDescriptorType, T, flavor>::read(T* data, size_t nMessages) { in read() argument
1140 return beginRead(nMessages, &tx) && tx.copyFrom(data, 0 /* startIdx */, nMessages) && in read()
1141 commitRead(nMessages); in read()
1150 MessageQueueBase<MQDescriptorType, T, flavor>::beginRead(size_t nMessages, in beginRead() argument
1179 size_t nBytesDesired = nMessages * sizeof(T); in beginRead()
1194 if (contiguousMessages < nMessages) { in beginRead()
1201 MemRegion(reinterpret_cast<T*>(mRing), nMessages - contiguousMessages)); in beginRead()
1207 *result = MemTransaction(MemRegion(reinterpret_cast<T*>(mRing + readOffset), nMessages), in beginRead()
1220 MessageQueueBase<MQDescriptorType, T, flavor>::commitRead(size_t nMessages) { in commitRead() argument
1233 size_t nBytesRead = nMessages * sizeof(T); in commitRead()