Searched refs:currentReadIndex (Results 1 – 6 of 6) sorted by relevance
76 currentReadIndex := readIndex79 for currentReadIndex < len(byteArray) {81 currentReadIndex++88 leftTrimIndex := currentReadIndex94 for ; currentReadIndex < len(byteArray); currentReadIndex++ {98 rightTrimIndex = currentReadIndex100 } else if (byteArray[currentReadIndex] == '\n') || (currentReadIndex == (len(byteArray) - 1)) {103 return nil, currentReadIndex + 1107 rightTrimIndex = currentReadIndex108 if currentReadIndex == (len(byteArray)-1) && (byteArray[currentReadIndex] != '\n') {[all …]
47 const auto currentReadIndex = mReadIndex.load(std::memory_order_relaxed); in pop() local48 if (currentReadIndex == mWriteIndex.load(std::memory_order_acquire)) in pop()52 item = mData[currentReadIndex]; in pop()53 mReadIndex.store(increment(currentReadIndex), std::memory_order_release); in pop()59 const auto currentReadIndex = mReadIndex.load(std::memory_order_relaxed); in pop() local60 if (currentReadIndex == mWriteIndex.load(std::memory_order_acquire)) in pop()64 Element r = mData[currentReadIndex]; in pop()65 mReadIndex.store(increment(currentReadIndex), std::memory_order_release); in pop()86 const auto currentReadIndex = mReadIndex.load(std::memory_order_relaxed); in peek() local87 return mData[currentReadIndex]; in peek()
185 const auto currentReadIndex = mReadIndex.load(std::memory_order_acquire); in read() local186 DataRegions dr = getDataRegions(currentReadIndex, samples); in read()205 const auto currentReadIndex = mReadIndex.load(std::memory_order_acquire); in read() local206 DataRegions dr = getDataRegions(currentReadIndex, samples); in read()231 const auto currentReadIndex = mReadIndex.load(std::memory_order_acquire); in read() local232 DataRegions dr = getDataRegions(currentReadIndex, samples); in read()256 const auto currentReadIndex = mReadIndex.load(std::memory_order_acquire); in discard() local303 const auto currentReadIndex = mReadIndex.load(std::memory_order_acquire); in readWithOverlap() local304 DataRegions dr = getDataRegions(currentReadIndex, samples); in readWithOverlap()323 const auto currentReadIndex = mReadIndex.load(std::memory_order_acquire); in peekMostRecent() local[all …]
399 const quint16 currentReadIndex = readIndex; in dequeueBuffer() local400 if (currentReadIndex == writeIndex) in dequeueBuffer()403 ComPtr<IMF2DBuffer> buffer = buffers[currentReadIndex]; in dequeueBuffer()405 buffers[currentReadIndex].Reset(); in dequeueBuffer()406 readIndex = (currentReadIndex + 1) % CAMERA_SAMPLE_QUEUE_SIZE; in dequeueBuffer()
118 const BYTE * GetDataPointer() { return data + currentReadIndex; } in GetDataPointer()132 PINDEX GetUnReadBytes() { return data.GetSize() - currentReadIndex; } in GetUnReadBytes()283 PINDEX currentReadIndex; variable
91 currentReadIndex = 0; in ZeroAllValues()138 if (currentReadIndex >= data.GetSize()) in Read1Byte()141 result = data[currentReadIndex]; in Read1Byte()142 currentReadIndex++; in Read1Byte()1272 …elem = IAX2Ie::BuildInformationElement(thisType, thisLength, data.GetPointer() + currentReadIndex); in ReadInformationElements()1273 currentReadIndex += thisLength; in ReadInformationElements()