| /ohos5.0/foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/communicator/src/ |
| H A D | protocol_proto.cpp | 116 outErrorNo = errCode; in ToSerialBuffer()
146 outErrorNo = E_OK; in ToSerialBuffer()
149 outErrorNo = errCode; in ToSerialBuffer()
169 outErrorNo = errCode; in ToMessage()
175 outErrorNo = errCode; in ToMessage()
191 outErrorNo = errCode; in BuildEmptyFrameForVersionNegotiate()
196 outErrorNo = E_OK; in BuildEmptyFrameForVersionNegotiate()
201 int &outErrorNo) in BuildFeedbackMessageFrame() argument
217 outErrorNo = E_OK; in BuildFeedbackMessageFrame()
264 outErrorNo = E_OK; in BuildLabelExchange()
[all …]
|
| H A D | protocol_proto.h | 61 std::shared_ptr<ExtendHeaderHandle> &extendHandle, bool onlyMsgHeader, int &outErrorNo);
62 …static Message *ToMessage(const SerialBuffer *inBuff, int &outErrorNo, bool onlyMsgHeader = false);
65 static SerialBuffer *BuildEmptyFrameForVersionNegotiate(int &outErrorNo);
66 …Buffer *BuildFeedbackMessageFrame(const Message *inMsg, const LabelType &inLabel, int &outErrorNo);
68 const std::set<LabelType> &inLabels, int &outErrorNo);
69 …ialBuffer *BuildLabelExchangeAck(uint64_t inDistinctValue, uint64_t inSequenceId, int &outErrorNo);
|
| H A D | serial_buffer.cpp | 108 SerialBuffer *SerialBuffer::Clone(int &outErrorNo) in Clone() argument
111 outErrorNo = -E_INVALID_ARGS; in Clone()
116 outErrorNo = -E_OUT_OF_MEMORY; in Clone()
124 outErrorNo = -E_OUT_OF_MEMORY; in Clone()
131 outErrorNo = -E_SECUREC_ERROR; in Clone()
147 outErrorNo = E_OK; in Clone()
|
| H A D | frame_combiner.cpp | 62 const ParseResult &inPacketInfo, ParseResult &outFrameInfo, int &outErrorNo) in AssembleFrameFragment() argument
72 outErrorNo = errCode; in AssembleFrameFragment()
81 outErrorNo = E_OK; in AssembleFrameFragment()
90 outErrorNo = errCode; in AssembleFrameFragment()
99 outErrorNo = E_OK; in AssembleFrameFragment()
|
| H A D | serial_buffer.h | 45 SerialBuffer *Clone(int &outErrorNo);
|
| H A D | communicator_aggregator.cpp | 137 ICommunicator *CommunicatorAggregator::AllocCommunicator(uint64_t commLabel, int &outErrorNo) in AllocCommunicator() argument
145 return AllocCommunicator(realLabel, outErrorNo); in AllocCommunicator()
148 … *CommunicatorAggregator::AllocCommunicator(const std::vector<uint8_t> &commLabel, int &outErrorNo) in AllocCommunicator() argument
153 outErrorNo = -E_INVALID_ARGS; in AllocCommunicator()
158 outErrorNo = -E_ALREADY_ALLOC; in AllocCommunicator()
164 outErrorNo = -E_OUT_OF_MEMORY; in AllocCommunicator()
|
| /ohos5.0/foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/test/unittest/common/syncer/ |
| H A D | virtual_communicator_aggregator.cpp | 38 ICommunicator *VirtualCommunicatorAggregator::AllocCommunicator(uint64_t commLabel, int &outErrorNo) in AllocCommunicator() argument
41 return AllocCommunicator(remoteDeviceId_, outErrorNo); in AllocCommunicator()
46 …ator *VirtualCommunicatorAggregator::AllocCommunicator(const LabelType &commLabel, int &outErrorNo) in AllocCommunicator() argument
50 outErrorNo = -E_INVALID_ARGS; in AllocCommunicator()
55 return AllocCommunicator(remoteDeviceId_, outErrorNo); in AllocCommunicator()
142 …tor *VirtualCommunicatorAggregator::AllocCommunicator(const std::string &deviceId, int &outErrorNo) in AllocCommunicator() argument
147 outErrorNo = -E_OUT_OF_MEMORY; in AllocCommunicator()
|
| H A D | virtual_communicator_aggregator.h | 36 ICommunicator *AllocCommunicator(uint64_t commLabel, int &outErrorNo) override;
37 ICommunicator *AllocCommunicator(const LabelType &commLabel, int &outErrorNo) override;
58 ICommunicator *AllocCommunicator(const std::string &deviceId, int &outErrorNo);
|
| /ohos5.0/foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/communicator/include/ |
| H A D | icommunicator_aggregator.h | 45 virtual ICommunicator *AllocCommunicator(uint64_t commLabel, int &outErrorNo) = 0;
46 virtual ICommunicator *AllocCommunicator(const LabelType &commLabel, int &outErrorNo) = 0;
|
| H A D | frame_combiner.h | 54 ParseResult &outFrameInfo, int &outErrorNo);
|
| H A D | communicator_aggregator.h | 62 ICommunicator *AllocCommunicator(uint64_t commLabel, int &outErrorNo) override;
63 ICommunicator *AllocCommunicator(const LabelType &commLabel, int &outErrorNo) override;
|
| /ohos5.0/foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/test/unittest/common/interfaces/ |
| H A D | distributeddb_interfaces_auto_launch_test.cpp | 77 ICommunicator *AllocCommunicator(uint64_t commLabel, int &outErrorNo) override in AllocCommunicator() argument
79 outErrorNo = -E_OUT_OF_MEMORY; in AllocCommunicator()
82 ICommunicator *AllocCommunicator(const LabelType &commLabel, int &outErrorNo) override in AllocCommunicator() argument
84 outErrorNo = -E_OUT_OF_MEMORY; in AllocCommunicator()
|