Home
last modified time | relevance | path

Searched refs:circleBuffer (Results 1 - 4 of 4) sorted by relevance

/base/msdp/device_status/intention/adapters/dsoftbus_adapter/src/
H A Ddsoftbus_adapter_impl.cpp355 CircleStreamBuffer &circleBuffer = iter->second.buffer_; in OnBytes() local
357 if (!circleBuffer.Write(reinterpret_cast<const char*>(data), dataLen)) { in OnBytes()
360 HandleSessionData(networkId, circleBuffer); in OnBytes()
549 void DSoftbusAdapterImpl::HandleSessionData(const std::string &networkId, CircleStreamBuffer &circleBuffer) in HandleSessionData() argument
552 while (circleBuffer.ResidualSize() >= static_cast<int32_t>(sizeof(PackHead))) { in HandleSessionData()
553 const char *buf = circleBuffer.ReadBuf(); in HandleSessionData()
560 if ((head->size + static_cast<int32_t>(sizeof(PackHead))) > circleBuffer.ResidualSize()) { in HandleSessionData()
562 (head->size + static_cast<int32_t>(sizeof(PackHead))), circleBuffer.ResidualSize()); in HandleSessionData()
571 circleBuffer.SeekReadPos(packet.GetPacketLength()); in HandleSessionData()
/base/msdp/device_status/test/fuzztest/dsoftbusadapter_fuzzer/
H A Ddsoftbusadapter_fuzzer.cpp131 CircleStreamBuffer circleBuffer; in CheckDeviceOnlineFuzzTest() local
135 DSoftbusAdapterImpl::GetInstance()->HandleSessionData(networkId, circleBuffer); in CheckDeviceOnlineFuzzTest()
/base/msdp/device_status/intention/adapters/dsoftbus_adapter/include/
H A Ddsoftbus_adapter_impl.h104 void HandleSessionData(const std::string &networkId, CircleStreamBuffer &circleBuffer);
/base/msdp/device_status/test/unittest/intention/adapters/src/
H A Ddsoftbus_adapter_test.cpp379 CircleStreamBuffer circleBuffer; in HWTEST_F() local
380 ASSERT_NO_FATAL_FAILURE(DSoftbusAdapterImpl::GetInstance()->HandleSessionData(networkId, circleBuffer)); in HWTEST_F()

Completed in 4 milliseconds