Searched refs:serializeFunc (Results 1 – 10 of 10) sorted by relevance
| /ohos5.0/foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/test/unittest/common/communicator/ |
| H A D | distributeddb_communicator_common.cpp | 77 funcForTinyMsg.serializeFunc = [](uint8_t *buffer, uint32_t length, const Message *inMsg)->int{ in RegFuncForTinyMsg()
95 funcForHugeMsg.serializeFunc = [](uint8_t *buffer, uint32_t length, const Message *inMsg)->int{ in RegFuncForHugeMsg()
119 funcForGiantMsg.serializeFunc = [](uint8_t *buffer, uint32_t length, const Message *inMsg)->int{ in RegFuncForGiantMsg()
159 …funcForOverSizeMsg.serializeFunc = [](uint8_t *buffer, uint32_t length, const Message *inMsg)->int{ in RegFuncForOverSizeMsg()
|
| /ohos5.0/foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/syncer/src/device/singlever/ |
| H A D | single_ver_serialize_manager.cpp | 36 SerializeFunc serializeFunc = nullptr; in Serialization() local
40 serializeFunc = messageHandles_.at(inMsg->GetMessageId()).serializeFunc; in Serialization()
43 if (serializeFunc != nullptr) { in Serialization()
44 return serializeFunc(buffer, length, inMsg); in Serialization()
741 func.serializeFunc = [](uint8_t *buffer, uint32_t length, const Message *inMsg) { in RegisterCommunicatorTransformFunc()
767 func.serializeFunc = [](uint8_t *buffer, uint32_t length, const Message *inMsg) { in RegisterInnerTransformFunc()
|
| /ohos5.0/foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/communicator/include/ |
| H A D | message_transform.h | 31 SerializeFunc serializeFunc; member
|
| /ohos5.0/foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/syncer/src/device/ |
| H A D | device_manager.cpp | 54 func.serializeFunc = [](uint8_t *buffer, uint32_t length, const Message *inMsg) { in RegisterTransformFunc()
|
| H A D | commit_history_sync.cpp | 203 func.serializeFunc = [](uint8_t *buffer, uint32_t length, const Message *inMsg) { in RegisterTransformFunc()
|
| H A D | time_sync.cpp | 172 func.serializeFunc = [](uint8_t *buffer, uint32_t length, const Message *inMsg) { in RegisterTransformFunc()
|
| H A D | ability_sync.cpp | 618 func.serializeFunc = [](uint8_t *buffer, uint32_t length, const Message *inMsg) { in RegisterTransformFunc()
|
| /ohos5.0/foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/communicator/src/ |
| H A D | protocol_proto.cpp | 388 if (!inFunc.computeFunc || !inFunc.serializeFunc || !inFunc.deserializeFunc) { in RegTransformFunction()
651 … int result = function.serializeFunc(payloadByteLen.first + sizeof(MessageHeader), dataLen, inMsg); in SerializeMessage()
|
| /ohos5.0/foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/syncer/src/device/multiver/ |
| H A D | value_slice_sync.cpp | 160 func.serializeFunc = [](uint8_t *buffer, uint32_t length, const Message *inMsg) { in RegisterTransformFunc()
|
| H A D | multi_ver_data_sync.cpp | 160 func.serializeFunc = [](uint8_t *buffer, uint32_t length, const Message *inMsg) { in RegisterTransformFunc()
|