Home
last modified time | relevance | path

Searched refs:headSize (Results 1 - 20 of 20) sorted by relevance

/foundation/multimedia/audio_framework/services/audio_service/common/src/
H A Daudio_ring_cache.cpp207 size_t headSize = baseIndex_ + cacheTotalSize_ - writeIndex_; in Enqueue() local
211 if ((memcpy_s(headPtr, headSize, static_cast<void *>(buffer.dataPtr), headSize)) == EOK && in Enqueue()
212 memcpy_s(tailPtr, tailSize, static_cast<void *>(buffer.dataPtr + headSize), tailSize) == EOK) { in Enqueue()
249 size_t headSize = baseIndex_ + cacheTotalSize_ - readIndex_; in HandleCrossDequeue() local
253 if (memcpy_s(static_cast<void *>(buffer.dataPtr), headSize, headPtr, headSize) != EOK || in HandleCrossDequeue()
254 memcpy_s(static_cast<void *>(buffer.dataPtr + headSize), tailSize, tailPtr, tailSize) != EOK) { in HandleCrossDequeue()
260 if (memset_s(headPtr, headSize, 0, headSize) ! in HandleCrossDequeue()
[all...]
/foundation/distributeddatamgr/datamgr_service/services/distributeddataservice/app/src/session_manager/
H A Droute_head_handler_impl.cpp73 DistributedDB::DBStatus RouteHeadHandlerImpl::GetHeadDataSize(uint32_t &headSize) in GetHeadDataSize() argument
76 headSize = 0; in GetHeadDataSize()
107 headSize = GET_ALIGNED_SIZE(expectSize, ALIGN_WIDTH); in GetHeadDataSize()
110 ZLOGI("packed size:%{public}u times %{public}" PRIu64 ".", headSize, time); in GetHeadDataSize()
111 headSize_ = headSize; in GetHeadDataSize()
115 DistributedDB::DBStatus RouteHeadHandlerImpl::FillHeadData(uint8_t *data, uint32_t headSize, uint32_t totalLen) in FillHeadData() argument
118 if (headSize != headSize_) { in FillHeadData()
126 auto packRet = PackData(data, headSize); in FillHeadData()
134 ZLOGE("the buffer size is not enough, headSize:%{public}d, tatalLen:%{public}d", in PackData()
199 const uint8_t *data, uint32_t len, uint32_t &headSize, st in ParseHeadData()
198 ParseHeadData( const uint8_t *data, uint32_t len, uint32_t &headSize, std::vector<std::string> &users) ParseHeadData() argument
[all...]
H A Droute_head_handler_impl.h62 DBStatus GetHeadDataSize(uint32_t &headSize) override;
63 DBStatus FillHeadData(uint8_t *data, uint32_t headSize, uint32_t totalLen) override;
64 bool ParseHeadData(const uint8_t *data, uint32_t len, uint32_t &headSize, std::vector<std::string> &users) override;
/foundation/multimodalinput/input/util/socket/src/
H A Duds_socket.cpp92 constexpr int32_t headSize = static_cast<int32_t>(sizeof(PackHead)); in OnReadPackets() local
95 if (unreadSize < headSize) { in OnReadPackets()
98 int32_t dataSize = unreadSize - headSize; in OnReadPackets()
113 if ((head->size > 0) && (!pkt.Write(&buf[headSize], head->size))) { in OnReadPackets()
/foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/interfaces/include/
H A Diprocess_communicator.h43 // headSize should be 8 byte align
44 // return OK and headSize = 0 if no need to fill Head Data
45 // return OK and headSize > 0 if permit sync and will call FillHeadData
47 virtual DBStatus GetHeadDataSize(uint32_t &headSize) in GetHeadDataSize() argument
49 headSize = 0; in GetHeadDataSize()
54 virtual DBStatus FillHeadData(uint8_t *data, uint32_t headSize, uint32_t totalLen) in FillHeadData() argument
/foundation/communication/bluetooth_service/services/bluetooth/stack/include/
H A Dpacket.h43 * @param headSize Packet headSize, could be 0 or positive integer.
50 BTSTACK_API Packet *PacketMalloc(uint16_t headSize, uint16_t tailSize, uint32_t payloadSize);
64 * headSize and tailSize are added.
68 * @param headSize Packet headSize, could be 0 or positive integer.
74 BTSTACK_API Packet *PacketInheritMalloc(const Packet *pkt, uint16_t headSize, uint16_t tailSize);
/foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/test/unittest/common/communicator/
H A Ddistributeddb_communicator_common.h85 // headSize should be 8 byte align
86 // return OK and headSize = 0 if no need to fill Head Data
87 // return OK and headSize > 0 if permit sync and will call FillHeadData
89 DistributedDB::DBStatus GetHeadDataSize(uint32_t &headSize) override
93 headSize = headSize_;
97 DistributedDB::DBStatus FillHeadData(uint8_t *data, uint32_t headSize, uint32_t totalLen) override
/foundation/distributeddatamgr/datamgr_service/services/distributeddataservice/adapter/include/communicator/
H A Droute_head_handler.h29 const uint8_t *data, uint32_t totalLen, uint32_t &headSize, std::vector<std::string> &users) = 0;
/foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/communicator/src/
H A Dprotocol_proto.cpp113 uint32_t headSize = 0; in ToSerialBuffer() local
114 int errCode = GetExtendHeadDataSize(extendHandle, headSize); in ToSerialBuffer()
125 if (headSize > 0) { in ToSerialBuffer()
126 buffer->SetExtendHeadLength(headSize); in ToSerialBuffer()
135 errCode = FillExtendHeadDataIfNeed(extendHandle, buffer, headSize); in ToSerialBuffer()
1078 int ProtocolProto::GetExtendHeadDataSize(std::shared_ptr<ExtendHeaderHandle> &extendHandle, uint32_t &headSize) in GetExtendHeadDataSize() argument
1081 DBStatus status = extendHandle->GetHeadDataSize(headSize); in GetExtendHeadDataSize()
1086 if (headSize > SerialBuffer::MAX_EXTEND_HEAD_LENGTH || headSize != BYTE_8_ALIGN(headSize)) { in GetExtendHeadDataSize()
1095 FillExtendHeadDataIfNeed(std::shared_ptr<ExtendHeaderHandle> &extendHandle, SerialBuffer *buffer, uint32_t headSize) FillExtendHeadDataIfNeed() argument
[all...]
H A Dprotocol_proto.h131 static int GetExtendHeadDataSize(std::shared_ptr<ExtendHeaderHandle> &extendHandle, uint32_t &headSize);
133 uint32_t headSize);
/foundation/communication/dsoftbus/core/connection/tcp/src/
H A Dsoftbus_tcp_connect_manager.c271 uint32_t headSize = sizeof(ConnPktHead); in RecvData() local
277 char *data = (char *)SoftBusCalloc(headSize + len); in RecvData()
282 if (memcpy_s(data, headSize, head, headSize) != EOK) { in RecvData()
287 ssize_t n = ConnRecvSocketData(fd, data + headSize + recvLen, len - recvLen, g_tcpTimeOut); in RecvData()
364 uint32_t headSize = sizeof(ConnPktHead); in TcpOnDataEventIn() local
365 ssize_t bytes = ConnRecvSocketData(fd, (char *)&head, headSize, g_tcpTimeOut); in TcpOnDataEventIn()
371 } else if (bytes != (ssize_t)headSize) { in TcpOnDataEventIn()
381 head.seq, data, (int32_t)(headSize + head.len)); in TcpOnDataEventIn()
/foundation/communication/bluetooth_service/services/bluetooth/stack/src/rfcomm/
H A Drfcomm_l2cap_if.c533 * @param headSize RFCOMM frame header length.
538 int RfcommSendData(uint16_t lcid, const uint8_t *header, uint8_t headSize, uint8_t tail, Packet *pkt) in RfcommSendData() argument
547 packet = PacketMalloc(headSize, 1, 0); in RfcommSendData()
549 packet = PacketInheritMalloc(pkt, headSize, 1); in RfcommSendData()
554 (void)memcpy_s(headerBuf, (sizeof(uint8_t) * headSize), header, (sizeof(uint8_t) * headSize)); in RfcommSendData()
H A Drfcomm_defs.h522 int RfcommSendData(uint16_t lcid, const uint8_t *header, uint8_t headSize, uint8_t tail, Packet *pkt);
/foundation/communication/dsoftbus/core/connection/br/src/
H A Dsoftbus_conn_br_trans.c212 uint32_t headSize = sizeof(ConnPktHead); in ConnBrPackCtlMessage() local
213 uint32_t bufLen = dataLen + headSize; in ConnBrPackCtlMessage()
226 if (memcpy_s(buf, bufLen, &head, headSize) != EOK) { in ConnBrPackCtlMessage()
234 if (memcpy_s(buf + headSize, bufLen - headSize, data, dataLen) != EOK) { in ConnBrPackCtlMessage()
/foundation/communication/bluetooth_service/services/bluetooth/stack/platform/src/
H A Dpacket.c68 Packet *PacketMalloc(uint16_t headSize, uint16_t tailSize, uint32_t payloadSize) in PacketMalloc() argument
74 packet->head = PayloadNew(headSize); in PacketMalloc()
120 Packet *PacketInheritMalloc(const Packet *pkt, uint16_t headSize, uint16_t tailSize) in PacketInheritMalloc() argument
127 inheritPacket->head = PayloadNew(headSize); in PacketInheritMalloc()
/foundation/arkui/ace_engine/frameworks/core/image/apng/
H A Dapng_image_decoder.cpp598 const int headSize = PngHeadLength; in isApng() local
600 png_byte buffer[headSize] = {0}; in isApng()
606 memcpy_s(buffer, headSize, byteDatas, headSize); in isApng()
609 if (png_sig_compare((png_bytep) buffer, (png_size_t) 0, headSize)) { in isApng()
/foundation/communication/dsoftbus/core/connection/ble/src/
H A Dsoftbus_conn_ble_trans.c469 uint32_t headSize = sizeof(ConnPktHead); in ConnBlePackCtlMessage() local
470 uint32_t bufLen = dataLen + headSize; in ConnBlePackCtlMessage()
478 if (memcpy_s(buf + headSize, bufLen - headSize, data, dataLen) != EOK) { in ConnBlePackCtlMessage()
/foundation/graphic/graphic_2d/rosen/modules/2d_graphics/src/render_context/
H A Dcache_data.cpp246 size_t headSize = sizeof(ShaderData); in Serialize() local
264 size_t sizeLeft = size - byteOffset - headSize; in Serialize()
/foundation/graphic/graphic_2d/frameworks/opengl_wrapper/src/EGL/
H A Degl_blob_cache.cpp276 size_t headSize = sizeof(CacheHeader); in GetCacheSize() local
279 size_t innerSize = headSize + item->first->dataSize + item->second->dataSize; in GetCacheSize()
/foundation/communication/dsoftbus/core/transmission/trans_channel/tcp_direct/src/
H A Dtrans_tcp_direct_message.c1341 const uint32_t headSize = sizeof(TdcPacketHead); in TransReadDataLen() local
1343 const uint32_t maxDataLen = dataBuf->size - headSize; in TransReadDataLen()
1347 if (bufDataLen >= headSize) { in TransReadDataLen()
1348 bufDataLen -= headSize; in TransReadDataLen()
1359 int32_t ret = TransRecvTdcSocketData(channelId, (char *)&pktHead, headSize); in TransReadDataLen()

Completed in 20 milliseconds