• Home
  • History
  • Annotate
  • Raw
  • Download

Lines Matching refs:nMessages

312         bool copyTo(const T* data, size_t startIdx, size_t nMessages = 1);
328 bool copyFrom(T* data, size_t startIdx, size_t nMessages = 1);
354 size_t nMessages,
376 bool beginWrite(size_t nMessages, MemTransaction* memTx) const;
385 bool commitWrite(size_t nMessages);
400 bool beginRead(size_t nMessages, MemTransaction* memTx) const;
411 bool commitRead(size_t nMessages);
470 size_t nMessages, in getMemRegionInfo() argument
478 if (startIdx + nMessages > firstRegionLength + secondRegionLength) { in getMemRegionInfo()
488 std::min(nMessages, firstRegionLength - startIdx) : 0; in getMemRegionInfo()
491 secondCount = nMessages - firstCount; in getMemRegionInfo()
506 bool MessageQueue<T, flavor>::MemTransaction::copyFrom(T* data, size_t startIdx, size_t nMessages) { in copyFrom() argument
515 nMessages, in copyFrom()
543 size_t nMessages) { in copyTo() argument
552 nMessages, in copyTo()
718 bool MessageQueue<T, flavor>::write(const T* data, size_t nMessages) { in write() argument
720 return beginWrite(nMessages, &tx) && in write()
721 tx.copyTo(data, 0 /* startIdx */, nMessages) && in write()
722 commitWrite(nMessages); in write()
971 bool MessageQueue<T, flavor>::beginWrite(size_t nMessages, MemTransaction* result) const { in beginWrite() argument
977 if ((flavor == kSynchronizedReadWrite && (availableToWrite() < nMessages)) || in beginWrite()
978 nMessages > getQuantumCount()) { in beginWrite()
992 if (contiguousMessages < nMessages) { in beginWrite()
1000 nMessages - contiguousMessages)); in beginWrite()
1006 *result = MemTransaction(MemRegion(reinterpret_cast<T*>(mRing + writeOffset), nMessages), in beginWrite()
1019 bool MessageQueue<T, flavor>::commitWrite(size_t nMessages) { in commitWrite() argument
1020 size_t nBytesWritten = nMessages * sizeof(T); in commitWrite()
1043 bool MessageQueue<T, flavor>::read(T* data, size_t nMessages) { in read() argument
1045 return beginRead(nMessages, &tx) && in read()
1046 tx.copyFrom(data, 0 /* startIdx */, nMessages) && in read()
1047 commitRead(nMessages); in read()
1056 bool MessageQueue<T, flavor>::beginRead(size_t nMessages, MemTransaction* result) const { in beginRead() argument
1077 size_t nBytesDesired = nMessages * sizeof(T); in beginRead()
1092 if (contiguousMessages < nMessages) { in beginRead()
1100 nMessages - contiguousMessages)); in beginRead()
1106 *result = MemTransaction(MemRegion(reinterpret_cast<T*>(mRing + readOffset), nMessages), in beginRead()
1119 bool MessageQueue<T, flavor>::commitRead(size_t nMessages) { in commitRead() argument
1132 size_t nBytesRead = nMessages * sizeof(T); in commitRead()