Home
last modified time | relevance | path

Searched refs:writeCursor (Results 1 – 3 of 3) sorted by relevance

/ohos5.0/foundation/communication/ipc/ipc/native/src/mock/include/
H A Ddbinder_base_invoker_object.h313 ssize_t writeCursor = sessionBuff->GetSendBufferWriteCursor(); in MoveTransData2Buffer() local
315 …if (writeCursor < 0 || readCursor < 0 || static_cast<uint32_t>(writeCursor) > sessionBuff->GetSend… in MoveTransData2Buffer()
316 sendSize > sessionBuff->GetSendBufferSize() - static_cast<uint32_t>(writeCursor)) { in MoveTransData2Buffer()
320 writeCursor, readCursor, sendSize, sessionBuff->GetSendBufferSize()); in MoveTransData2Buffer()
323 if (memcpy_s(sendBuffer + writeCursor, sendSize, transData.get(), sendSize)) { in MoveTransData2Buffer()
329 writeCursor += static_cast<ssize_t>(sendSize); in MoveTransData2Buffer()
330 sessionBuff->SetSendBufferWriteCursor(writeCursor); in MoveTransData2Buffer()
/ohos5.0/drivers/hdf_core/framework/core/adapter/vnode/src/
H A Dhdf_vnode_adapter.c46 volatile uint32_t writeCursor; member
285 if (client->readCursor == client->writeCursor) { in ReadDeviceEventInRingBuffer()
424 if ((vnodeClient->writeCursor + 1) % EVENT_RINGBUFFER_MAX != vnodeClient->readCursor) { in DropOldEventInRingBuffer()
443 if (vnodeClient->writeCursor == vnodeClient->readCursor) { in AddEventToRingBuffer()
447 cursor = vnodeClient->writeCursor; in AddEventToRingBuffer()
448 …} while (!__sync_bool_compare_and_swap(&(vnodeClient->writeCursor), cursor, (cursor + 1) % EVENT_R… in AddEventToRingBuffer()
617 client->writeCursor = 0; in HdfNewVNodeAdapterClient()
689 } else if (client->readCursor != client->writeCursor) { in HdfVNodeAdapterPoll()
/ohos5.0/foundation/communication/ipc/ipc/native/src/mock/source/
H A Ddbinder_databus_invoker.cpp362 ssize_t writeCursor = sessionBuff->GetSendBufferWriteCursor(); in SendData() local
364 if (writeCursor < readCursor) { in SendData()
366 writeCursor, readCursor); in SendData()
370 if (writeCursor == readCursor) { in SendData()
372 writeCursor, readCursor); in SendData()
376 ssize_t size = writeCursor - readCursor; in SendData()
390 sessionBuff->SetSendBufferWriteCursor(writeCursor); in SendData()