Home
last modified time | relevance | path

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

/foundation/multimodalinput/input/intention/adapters/dsoftbus_adapter/src/
H A Ddsoftbus_adapter_impl.cpp342 CircleStreamBuffer &circleBuffer = iter->second.buffer_; in OnBytes() local
344 if (!circleBuffer.Write(reinterpret_cast<const char*>(data), dataLen)) { in OnBytes()
347 HandleSessionData(networkId, circleBuffer); in OnBytes()
535 void DSoftbusAdapterImpl::HandleSessionData(const std::string &networkId, CircleStreamBuffer &circleBuffer) in HandleSessionData() argument
538 while (circleBuffer.ResidualSize() >= static_cast<int32_t>(sizeof(PackHead))) { in HandleSessionData()
539 const char *buf = circleBuffer.ReadBuf(); in HandleSessionData()
546 if ((head->size + static_cast<int32_t>(sizeof(PackHead))) > circleBuffer.ResidualSize()) { in HandleSessionData()
548 (head->size + static_cast<int32_t>(sizeof(PackHead))), circleBuffer.ResidualSize()); in HandleSessionData()
557 circleBuffer.SeekReadPos(packet.GetPacketLength()); in HandleSessionData()
/foundation/multimodalinput/input/intention/adapters/dsoftbus_adapter/include/
H A Ddsoftbus_adapter_impl.h102 void HandleSessionData(const std::string &networkId, CircleStreamBuffer &circleBuffer);
/foundation/multimodalinput/input/intention/adapters/test/unittest/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 2 milliseconds