Home
last modified time | relevance | path

Searched refs:readCursor (Results 1 – 7 of 7) sorted by relevance

/ohos5.0/drivers/hdf_core/framework/core/adapter/vnode/src/
H A Dhdf_vnode_adapter.c45 volatile uint32_t readCursor; member
285 if (client->readCursor == client->writeCursor) { in ReadDeviceEventInRingBuffer()
292 cursor = client->readCursor; in ReadDeviceEventInRingBuffer()
294 …} while (!__sync_bool_compare_and_swap(&(client->readCursor), cursor, (cursor + 1) % EVENT_RINGBUF… in ReadDeviceEventInRingBuffer()
303 …if (!__sync_bool_compare_and_swap(&(client->readCursor), (cursor + 1) % EVENT_RINGBUFFER_MAX, curs… in ReadDeviceEventInRingBuffer()
422 cursor = vnodeClient->readCursor; in DropOldEventInRingBuffer()
424 if ((vnodeClient->writeCursor + 1) % EVENT_RINGBUFFER_MAX != vnodeClient->readCursor) { in DropOldEventInRingBuffer()
428 …} while (!__sync_bool_compare_and_swap(&(vnodeClient->readCursor), cursor, (cursor + 1) % EVENT_RI… in DropOldEventInRingBuffer()
443 if (vnodeClient->writeCursor == vnodeClient->readCursor) { in AddEventToRingBuffer()
616 client->readCursor = 0; in HdfNewVNodeAdapterClient()
[all …]
/ohos5.0/base/hiviewdfx/hiview_lite/
H A Dhiview_cache.c213 uint16 readCursor; in GetReadCursor() local
216 readCursor = cache->wCursor - cache->usedSize; in GetReadCursor()
218 readCursor = cache->size - (cache->usedSize - cache->wCursor); in GetReadCursor()
221 return readCursor; in GetReadCursor()
/ohos5.0/foundation/communication/ipc/ipc/native/src/mock/source/
H A Ddbinder_databus_invoker.cpp363 ssize_t readCursor = sessionBuff->GetSendBufferReadCursor(); 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()
379 socketId, static_cast<const void *>(sendBuffer + readCursor), size); in SendData()
388 readCursor += size; in SendData()
389 sessionBuff->SetSendBufferReadCursor(readCursor); in SendData()
1004 uint32_t DBinderDatabusInvoker::HasCompletePackage(const char *data, uint32_t readCursor, ssize_t l… in HasCompletePackage() argument
[all …]
/ohos5.0/foundation/communication/ipc/ipc/native/src/mock/include/
H A Ddbinder_base_invoker_object.h314 ssize_t readCursor = sessionBuff->GetSendBufferReadCursor(); in MoveTransData2Buffer() local
315 …if (writeCursor < 0 || readCursor < 0 || static_cast<uint32_t>(writeCursor) > sessionBuff->GetSend… in MoveTransData2Buffer()
320 writeCursor, readCursor, sendSize, sessionBuff->GetSendBufferSize()); in MoveTransData2Buffer()
331 sessionBuff->SetSendBufferReadCursor(readCursor); in MoveTransData2Buffer()
H A Ddbinder_databus_invoker.h97 uint32_t HasCompletePackage(const char *data, uint32_t readCursor, ssize_t len);
/ohos5.0/foundation/communication/ipc/ipc/native/test/unittest/common/
H A Dipc_binder_databus_invoker_unittest.cpp663 uint32_t readCursor = 0; variable
670 uint32_t res = testInvoker.HasCompletePackage(data, readCursor, size);
671 EXPECT_EQ(res, readCursor);
675 res = testInvoker.HasCompletePackage(data, readCursor, size);
676 EXPECT_EQ(res, readCursor);
681 res = testInvoker.HasCompletePackage(data, readCursor, size);
682 EXPECT_EQ(res, readCursor);
687 res = testInvoker.HasCompletePackage(data, readCursor, size);
/ohos5.0/foundation/communication/ipc/ipc/native/c/rpc/src/
H A Ddbinder_invoker.c596 static uint32_t HasCompletePackage(const char *data, uint32_t readCursor, uint32_t len) in HasCompletePackage() argument
598 const dbinder_transaction_data *tr = (const dbinder_transaction_data *)(data + readCursor); in HasCompletePackage()
601 (readCursor + tr->sizeOfSelf <= len)) { in HasCompletePackage()