Home
last modified time | relevance | path

Searched refs:circBuf (Results 1 - 2 of 2) sorted by relevance

/base/sensors/sensor/utils/ipc/src/
H A Dstream_socket.cpp41 void StreamSocket::OnReadPackets(CircleStreamBuffer &circBuf, StreamSocket::PacketCallBackFun callbackFun) in OnReadPackets() argument
45 const size_t unreadSize = circBuf.UnreadSize(); in OnReadPackets()
50 char *buf = const_cast<char *>(circBuf.ReadBuf()); in OnReadPackets()
57 circBuf.Reset(); in OnReadPackets()
69 if (!circBuf.SeekReadPos(pkt.GetPacketLength())) { in OnReadPackets()
72 circBuf.Reset(); in OnReadPackets()
76 if (circBuf.IsEmpty()) { in OnReadPackets()
77 circBuf.Reset(); in OnReadPackets()
/base/msdp/device_status/utils/ipc/src/
H A Dstream_socket.cpp72 void StreamSocket::OnReadPackets(CircleStreamBuffer &circBuf, StreamSocket::PacketCallBackFun callbackFun) in OnReadPackets() argument
76 const int32_t residualSize = circBuf.ResidualSize(); in OnReadPackets()
81 char *buf = const_cast<char *>(circBuf.ReadBuf()); in OnReadPackets()
88 circBuf.Reset(); in OnReadPackets()
100 if (!circBuf.SeekReadPos(pkt.GetPacketLength())) { in OnReadPackets()
103 circBuf.Reset(); in OnReadPackets()
107 if (circBuf.empty()) { in OnReadPackets()
108 circBuf.Reset(); in OnReadPackets()

Completed in 2 milliseconds