| /ohos5.0/foundation/distributeddatamgr/datamgr_service/services/distributeddataservice/app/src/session_manager/ |
| H A D | route_head_handler_impl.cpp | 73 DistributedDB::DBStatus RouteHeadHandlerImpl::GetHeadDataSize(uint32_t &headSize) in GetHeadDataSize() argument
76 headSize = 0; in GetHeadDataSize()
106 headSize = GET_ALIGNED_SIZE(expectSize, ALIGN_WIDTH); in GetHeadDataSize()
109 ZLOGI("packed size:%{public}u times %{public}" PRIu64 ".", headSize, time); in GetHeadDataSize()
110 headSize_ = headSize; in GetHeadDataSize()
117 if (headSize != headSize_) { in FillHeadData()
125 auto packRet = PackData(data, headSize); in FillHeadData()
198 const uint8_t *data, uint32_t len, uint32_t &headSize, std::vector<std::string> &users) in ParseHeadData() argument
200 auto ret = UnPackData(data, len, headSize); in ParseHeadData()
202 headSize = 0; in ParseHeadData()
[all …]
|
| H A D | route_head_handler_impl.h | 62 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>…
|
| /ohos5.0/foundation/multimedia/audio_framework/services/audio_service/common/src/ |
| H A D | audio_ring_cache.cpp | 207 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) != EOK) { in HandleCrossDequeue()
|
| /ohos5.0/base/security/huks/frameworks/huks_standard/main/core/src/ |
| H A D | hks_verifier.c | 299 *headSize = buf - in; in ExtractTlvLength()
300 if (*headSize > inLen) { in ExtractTlvLength()
305 if (length > (inLen - *headSize)) { in ExtractTlvLength()
326 uint32_t headSize = buf - in; in ExtractTlvData()
327 if (headSize > inLen) { in ExtractTlvData()
332 if (length > (inLen - headSize)) { in ExtractTlvData()
462 uint32_t headSize = 0; in GetClaimDataParamSet() local
502 uint32_t headSize; in FillAttestExtendParamSet() local
506 for (headSize = 0; leftSize >= ASN_1_MIN_HEADER_LEN;) { in FillAttestExtendParamSet()
530 tmp += (valueLength + headSize); in FillAttestExtendParamSet()
[all …]
|
| /ohos5.0/base/sensors/sensor/utils/ipc/src/ |
| H A D | stream_socket.cpp | 43 constexpr size_t headSize = sizeof(PackHead); in OnReadPackets() local
46 if (unreadSize < headSize) { in OnReadPackets()
49 size_t dataSize = unreadSize - headSize; in OnReadPackets()
64 if ((head->size > 0) && (!pkt.Write(&buf[headSize], head->size))) { in OnReadPackets()
|
| /ohos5.0/base/msdp/device_status/utils/ipc/src/ |
| H A D | stream_socket.cpp | 74 constexpr int32_t headSize = static_cast<int32_t>(sizeof(PackHead)); in OnReadPackets() local
77 if (residualSize < headSize) { in OnReadPackets()
80 int32_t dataSize = residualSize - headSize; in OnReadPackets()
95 if ((head->size > 0) && (!pkt.Write(&buf[headSize], head->size))) { in OnReadPackets()
|
| /ohos5.0/foundation/multimodalinput/input/util/socket/src/ |
| H A D | uds_socket.cpp | 92 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()
|
| /ohos5.0/foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/interfaces/include/ |
| H A D | iprocess_communicator.h | 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
|
| /ohos5.0/foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/communicator/src/ |
| H A D | protocol_proto.cpp | 113 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()
1081 DBStatus status = extendHandle->GetHeadDataSize(headSize); in GetExtendHeadDataSize()
1086 if (headSize > SerialBuffer::MAX_EXTEND_HEAD_LENGTH || headSize != BYTE_8_ALIGN(headSize)) { in GetExtendHeadDataSize()
1096 uint32_t headSize) in FillExtendHeadDataIfNeed() argument
1098 if (extendHandle != nullptr && headSize > 0) { in FillExtendHeadDataIfNeed()
1102 DBStatus status = extendHandle->FillHeadData(buffer->GetOringinalAddr(), headSize, in FillExtendHeadDataIfNeed()
[all …]
|
| H A D | protocol_proto.h | 131 …c int GetExtendHeadDataSize(std::shared_ptr<ExtendHeaderHandle> &extendHandle, uint32_t &headSize);
133 uint32_t headSize);
|
| /ohos5.0/foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/test/unittest/common/communicator/ |
| H A D | distributeddb_communicator_common.h | 89 DistributedDB::DBStatus GetHeadDataSize(uint32_t &headSize) override in GetHeadDataSize() argument
93 headSize = headSize_; in GetHeadDataSize()
97 … DistributedDB::DBStatus FillHeadData(uint8_t *data, uint32_t headSize, uint32_t totalLen) override in FillHeadData() argument
|
| /ohos5.0/foundation/communication/bluetooth_service/services/bluetooth/stack/include/ |
| H A D | packet.h | 50 BTSTACK_API Packet *PacketMalloc(uint16_t headSize, uint16_t tailSize, uint32_t payloadSize);
74 BTSTACK_API Packet *PacketInheritMalloc(const Packet *pkt, uint16_t headSize, uint16_t tailSize);
|
| /ohos5.0/foundation/communication/bluetooth_service/services/bluetooth/stack/src/rfcomm/ |
| H A D | rfcomm_l2cap_if.c | 538 int RfcommSendData(uint16_t lcid, const uint8_t *header, uint8_t headSize, uint8_t tail, Packet *pk… 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 D | rfcomm_defs.h | 522 int RfcommSendData(uint16_t lcid, const uint8_t *header, uint8_t headSize, uint8_t tail, Packet *pk…
|
| /ohos5.0/foundation/communication/dsoftbus/core/connection/tcp/src/ |
| H A D | softbus_tcp_connect_manager.c | 271 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()
|
| /ohos5.0/foundation/communication/dsoftbus/core/connection/br/src/ |
| H A D | softbus_conn_br_trans.c | 212 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()
|
| /ohos5.0/foundation/distributeddatamgr/datamgr_service/services/distributeddataservice/adapter/include/communicator/ |
| H A D | route_head_handler.h | 29 … const uint8_t *data, uint32_t totalLen, uint32_t &headSize, std::vector<std::string> &users) = 0;
|
| /ohos5.0/base/hiviewdfx/faultloggerd/frameworks/allocator/ |
| H A D | dfx_allocator.c | 280 const size_t headSize = AlignRoundUp(PAGE_INFO_SIZE, align); in AllocMmap() local
284 if (__builtin_add_overflow(headSize, size, &allocSize) || in AllocMmap()
296 void* result = (void*)((char*)(mptr) + headSize); in AllocMmap()
|
| /ohos5.0/foundation/arkui/ace_engine/frameworks/core/image/apng/ |
| H A D | apng_image_decoder.cpp | 598 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()
|
| /ohos5.0/foundation/communication/bluetooth_service/services/bluetooth/stack/platform/src/ |
| H A D | packet.c | 68 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()
|
| /ohos5.0/foundation/communication/dsoftbus/core/connection/ble/src/ |
| H A D | softbus_conn_ble_trans.c | 469 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()
|
| /ohos5.0/foundation/graphic/graphic_2d/frameworks/opengl_wrapper/src/EGL/ |
| H A D | egl_blob_cache.cpp | 276 size_t headSize = sizeof(CacheHeader); in GetCacheSize() local
279 size_t innerSize = headSize + item->first->dataSize + item->second->dataSize; in GetCacheSize()
|
| /ohos5.0/foundation/graphic/graphic_2d/rosen/modules/2d_graphics/src/render_context/ |
| H A D | cache_data.cpp | 296 size_t headSize = sizeof(ShaderData); in Serialize() local
314 size_t sizeLeft = size - byteOffset - headSize; in Serialize()
|
| /ohos5.0/foundation/communication/dsoftbus/core/transmission/trans_channel/tcp_direct/src/ |
| H A D | trans_tcp_direct_message.c | 1343 const uint32_t headSize = sizeof(TdcPacketHead); in TransReadDataLen() local
1345 const uint32_t maxDataLen = dataBuf->size - headSize; in TransReadDataLen()
1349 if (bufDataLen >= headSize) { in TransReadDataLen()
1350 bufDataLen -= headSize; in TransReadDataLen()
1361 int32_t ret = TransRecvTdcSocketData(channelId, (char *)&pktHead, headSize); in TransReadDataLen()
|