| /ohos5.0/foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/syncer/src/device/ |
| H A D | commit_history_sync.cpp | 389 uint64_t packLen = 0; in RequestPacketDeSerialization() local
392 packLen += parcel.ReadUInt64(len); in RequestPacketDeSerialization()
402 packLen += parcel.ReadString(key); in RequestPacketDeSerialization()
412 packLen += parcel.ReadUInt32(version); in RequestPacketDeSerialization()
414 packLen = Parcel::GetEightByteAlign(packLen); in RequestPacketDeSerialization()
495 uint32_t packLen = 0; in AckPacketDeSerialization() local
502 packLen += parcel.ReadInt(pktErrCode); in AckPacketDeSerialization()
503 packLen += parcel.ReadUInt32(version); in AckPacketDeSerialization()
508 packLen = Parcel::GetEightByteAlign(packLen); in AckPacketDeSerialization()
512 packLen = Parcel::GetEightByteAlign(packLen); in AckPacketDeSerialization()
[all …]
|
| /ohos5.0/foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/syncer/src/device/multiver/ |
| H A D | value_slice_sync.cpp | 384 uint32_t packLen = parcel.ReadInt(ackCode); in RequestPacketDeSerialization() local
389 packLen = Parcel::GetEightByteAlign(packLen); in RequestPacketDeSerialization()
393 packLen += parcel.ReadVectorChar(valueSliceHash); in RequestPacketDeSerialization()
394 if (packLen != length || parcel.IsError()) { in RequestPacketDeSerialization()
457 uint32_t packLen = 0; in AckPacketDeSerialization() local
461 packLen += parcel.ReadInt(ackCode); in AckPacketDeSerialization()
466 packLen = Parcel::GetEightByteAlign(packLen); in AckPacketDeSerialization()
468 packLen += parcel.ReadVectorChar(valueSlice); in AckPacketDeSerialization()
469 if (packLen != length || parcel.IsError()) { in AckPacketDeSerialization()
471 packLen, length); in AckPacketDeSerialization()
|
| H A D | multi_ver_data_sync.cpp | 412 uint64_t packLen = parcel.ReadInt(pktErrCode); in RequestPacketDeSerialization() local
417 packLen = Parcel::GetEightByteAlign(packLen); in RequestPacketDeSerialization()
419 packLen += parcel.ReadMultiVerCommit(commit); in RequestPacketDeSerialization()
420 if (packLen != length || parcel.IsError()) { in RequestPacketDeSerialization()
496 uint32_t packLen = parcel.ReadInt(pktErrCode); in AckPacketDeSerialization() local
501 packLen = Parcel::GetEightByteAlign(packLen); in AckPacketDeSerialization()
505 while (packLen < length) { in AckPacketDeSerialization()
507 packLen += parcel.ReadVectorChar(data); in AckPacketDeSerialization()
|
| /ohos5.0/foundation/communication/dsoftbus/core/connection/br/src/ |
| H A D | softbus_conn_br_trans.c | 59 uint32_t packLen = head->len + sizeof(ConnPktHead); in BrRecvDataParse() local
60 if (buffer->length < packLen) { in BrRecvDataParse()
64 uint8_t *dataCopy = (uint8_t *)SoftBusCalloc(packLen); in BrRecvDataParse()
67 connectionId, packLen); in BrRecvDataParse()
70 if (memcpy_s(dataCopy, packLen, buffer->buffer, packLen) != EOK) { in BrRecvDataParse()
72 "packLen=%{public}u, bufferLen=%{public}u", connectionId, packLen, buffer->length); in BrRecvDataParse()
76 if (buffer->length > packLen && in BrRecvDataParse()
77 …memmove_s(buffer->buffer, buffer->length, buffer->buffer + packLen, buffer->length - packLen) != E… in BrRecvDataParse()
84 connectionId, buffer->length, packLen, head->flag, head->module, head->seq); in BrRecvDataParse()
85 buffer->length -= packLen; in BrRecvDataParse()
[all …]
|
| /ohos5.0/foundation/communication/dsoftbus/core/connection/ble/src/ |
| H A D | softbus_conn_ble_trans.c | 531 uint32_t packLen = head->len + sizeof(ConnPktHead); in ConnCocTransRecv() local
532 if (buffer->length < packLen) { in ConnCocTransRecv()
536 uint8_t *dataCopy = SoftBusCalloc(packLen); in ConnCocTransRecv()
539 "packLen=%{public}u", connectionId, packLen); in ConnCocTransRecv()
542 if (memcpy_s(dataCopy, packLen, buffer->buffer, packLen) != EOK) { in ConnCocTransRecv()
544 …"connId=%{public}u, packLen=%{public}u, bufferLen=%{public}u", connectionId, packLen, buffer->leng… in ConnCocTransRecv()
549 if (buffer->length > packLen && in ConnCocTransRecv()
550 …memmove_s(buffer->buffer, buffer->length, buffer->buffer + packLen, buffer->length - packLen) != E… in ConnCocTransRecv()
557 buffer->length -= packLen; in ConnCocTransRecv()
561 *outLen = (int32_t)packLen; in ConnCocTransRecv()
|
| /ohos5.0/base/telephony/sms_mms/utils/ |
| H A D | sms_common_utils.cpp | 37 … const uint8_t *userData, uint16_t dataLen, uint8_t fillBits, uint8_t *packData, uint16_t packLen) in Pack7bitChar() argument
50 while (srcIdx < dataLen && dstIdx < packLen) { in Pack7bitChar()
|
| H A D | sms_common_utils.h | 28 … const uint8_t *userData, uint16_t dataLen, uint8_t fillBits, uint8_t *packData, uint16_t packLen);
|
| /ohos5.0/foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/syncer/src/device/singlever/ |
| H A D | single_ver_serialize_manager.cpp | 361 uint32_t packLen = parcel.ReadUInt32(version); in DataPacketDeSerialization() local
370 packLen += static_cast<uint32_t>(GenericSingleVerKvEntry::DeSerializeDatas(dataItems, parcel)); in DataPacketDeSerialization()
382 int errCode = DataPacketSyncerPartDeSerialization(parcel, packet, packLen, length, version); in DataPacketDeSerialization()
449 uint32_t packLen, uint32_t length, uint32_t version) in DataPacketSyncerPartDeSerialization() argument
459 uint64_t totPacketLen = packLen; in DataPacketSyncerPartDeSerialization()
|
| H A D | single_ver_serialize_manager.h | 63 …nt DataPacketSyncerPartDeSerialization(Parcel &parcel, DataRequestPacket *packet, uint32_t packLen,
|