| /foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/syncer/src/device/multiver/ |
| H A D | value_slice_sync.cpp | 237 const ValueSliceHashPacket *packet = message->GetObject<ValueSliceHashPacket>(); in RequestRecvCallback() local
273 const ValueSlicePacket *packet = message->GetObject<ValueSlicePacket>(); in AckRecvCallback() local
306 ValueSliceHashPacket *packet = new (std::nothrow) ValueSliceHashPacket(); SendFinishedRequest() local
343 const ValueSliceHashPacket *packet = inMsg->GetObject<ValueSliceHashPacket>(); RequestPacketCalculateLen() local
354 const ValueSliceHashPacket *packet = inMsg->GetObject<ValueSliceHashPacket>(); RequestPacketSerialization() local
397 ValueSliceHashPacket *packet = new (std::nothrow) ValueSliceHashPacket(); RequestPacketDeSerialization() local
414 const ValueSlicePacket *packet = inMsg->GetObject<ValueSlicePacket>(); AckPacketCalculateLen() local
427 const ValueSlicePacket *packet = inMsg->GetObject<ValueSlicePacket>(); AckPacketSerialization() local
474 ValueSlicePacket *packet = new (std::nothrow) ValueSlicePacket(); AckPacketDeSerialization() local
540 ValueSliceHashPacket *packet = new (std::nothrow) ValueSliceHashPacket(); SendRequestPacket() local
583 ValueSlicePacket *packet = new (std::nothrow) ValueSlicePacket(); SendAckPacket() local
[all...] |
| H A D | multi_ver_data_sync.cpp | 220 const MultiVerRequestPacket *packet = message->GetObject<MultiVerRequestPacket>(); in RequestRecvCallback() local
261 const MultiVerAckPacket *packet = message->GetObject<MultiVerAckPacket>(); in AckRecvCallback() local
323 MultiVerRequestPacket *packet = new (std::nothrow) MultiVerRequestPacket(); in SendFinishedRequest() local
364 const MultiVerRequestPacket *packet = inMsg->GetObject<MultiVerRequestPacket>(); RequestPacketCalculateLen() local
378 const MultiVerRequestPacket *packet = inMsg->GetObject<MultiVerRequestPacket>(); RequestPacketSerialization() local
423 MultiVerRequestPacket *packet = new (std::nothrow) MultiVerRequestPacket(); RequestPacketDeSerialization() local
444 const MultiVerAckPacket *packet = inMsg->GetObject<MultiVerAckPacket>(); AckPacketCalculateLen() local
457 const MultiVerAckPacket *packet = inMsg->GetObject<MultiVerAckPacket>(); AckPacketSerialization() local
514 MultiVerAckPacket *packet = new (std::nothrow) MultiVerAckPacket(); AckPacketDeSerialization() local
591 MultiVerRequestPacket *packet = new (std::nothrow) MultiVerRequestPacket(); SendRequestPacket() local
639 MultiVerAckPacket *packet = new (std::nothrow) MultiVerAckPacket(); SendAckPacket() local
[all...] |
| /foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/syncer/src/device/ |
| H A D | commit_history_sync.cpp | 256 const CommitHistorySyncRequestPacket *packet = message->GetObject<CommitHistorySyncRequestPacket>(); in RequestRecvCallback() local
303 const CommitHistorySyncAckPacket *packet = message->GetObject<CommitHistorySyncAckPacket>(); in AckRecvCallback() local
327 const CommitHistorySyncRequestPacket *packet in RequestPacketCalculateLen() local
344 const CommitHistorySyncRequestPacket *packet = inMsg->GetObject<CommitHistorySyncRequestPacket>(); RequestPacketSerialization() local
420 CommitHistorySyncRequestPacket *packet = new (std::nothrow) CommitHistorySyncRequestPacket(); RequestPacketDeSerialization() local
441 const CommitHistorySyncAckPacket *packet = inMsg->GetObject<CommitHistorySyncAckPacket>(); AckPacketCalculateLen() local
458 const CommitHistorySyncAckPacket *packet = inMsg->GetObject<CommitHistorySyncAckPacket>(); AckPacketSerialization() local
518 CommitHistorySyncAckPacket *packet = new (std::nothrow) CommitHistorySyncAckPacket(); AckPacketDeSerialization() local
619 CommitHistorySyncRequestPacket *packet = new (std::nothrow) CommitHistorySyncRequestPacket(); SendRequestPacket() local
667 CommitHistorySyncAckPacket *packet = new (std::nothrow) CommitHistorySyncAckPacket(); SendAckPacket() local
[all...] |
| H A D | time_sync.cpp | 231 TimeSyncPacket packet; in SyncStart() local
267 const TimeSyncPacket *packet = const_cast<TimeSyncPacket *>(inMsg->GetObject<TimeSyncPacket>()); in CalculateLen() local
280 const TimeSyncPacket *packet = inMsg->GetObject<TimeSyncPacket>(); in Serialization() local
325 TimeSyncPacket packet; DeSerialization() local
380 const TimeSyncPacket *packet = message->GetObject<TimeSyncPacket>(); AckRecv() local
413 const TimeSyncPacket *packet = message->GetObject<TimeSyncPacket>(); RequestRecv() local
[all...] |
| H A D | remote_executor.cpp | 35 void ReleaseMessageAndPacket(Message *message, ISyncPacket *packet) in ReleaseMessageAndPacket() argument
236 const auto *packet = inMsg->GetObject<ISyncPacket>(); in CheckPermissions() local
262 const auto *packet = inMsg->GetObject<ISyncPacket>(); in SendRemoteExecutorData() local
280 const auto *packet = static_cast<const RemoteExecutorAckPacket *>(ack); ReceiveRemoteExecutorAck() local
485 auto *packet = new (std::nothrow) RemoteExecutorRequestPacket(); RequestStart() local
540 RemoteExecutorAckPacket *packet = new (std::nothrow) RemoteExecutorAckPacket(); ResponseFailed() local
553 RemoteExecutorAckPacket *packet = new (std::nothrow) RemoteExecutorAckPacket(); ResponseData() local
567 ResponseStart(RemoteExecutorAckPacket *packet, uint32_t sessionId, uint32_t sequenceId, const std::string &device) ResponseStart() argument
740 FillRequestPacket(RemoteExecutorRequestPacket *packet, uint32_t sessionId, std::string &target) FillRequestPacket() argument
808 ReceiveDataWithValidSession(const std::string &targetDev, uint32_t sessionId, uint32_t sequenceId, const RemoteExecutorAckPacket *packet) ReceiveDataWithValidSession() argument
[all...] |
| /foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/test/unittest/common/syncer/ |
| H A D | distributeddb_single_ver_p2p_subscribe_sync_test.cpp | 273 auto packet = new (std::nothrow) SubscribeRequest; in HWTEST_F() local
330 ControlAckPacket packet; in HWTEST_F() local
|
| H A D | distributeddb_single_ver_p2p_complex_sync_test.cpp | 1079 ControlRequestPacket packet; in HWTEST_F() local
|
| H A D | distributeddb_single_ver_p2p_query_sync_test.cpp | 616 auto packet = new (std::nothrow) DataRequestPacket; in HWTEST_F() local
724 DataAckPacket packet; HWTEST_F() local
[all...] |
| /foundation/communication/bluetooth_service/services/bluetooth/service/src/hid_host/ |
| H A D | hid_host_l2cap_connection.cpp | 256 Packet *packet = nullptr; in SendGetReport() local
308 Packet *packet = nullptr; in SendSetReport() local
[all...] |
| /foundation/communication/bluetooth_service/services/bluetooth/stack/src/avdtp/ |
| H A D | avdtp_l2cap.c | 716 void AVDT_L2capReadDataIndCallback(uint16_t lcid, Packet *packet, void *ctx) in AVDT_L2capReadDataIndCallback() argument
745 void AvdtL2capReadDataIndCallback(uint16_t lcid, Packet *packet, void *ctx) in AvdtL2capReadDataIndCallback() argument
804 AvdtStreamDataProc(AvdtStreamCtrl *streamCtrl, Packet *packet) AvdtStreamDataProc() argument
[all...] |
| /foundation/communication/dhcp/test/unittest/services/dhcp_server/unittest/ |
| H A D | system_func_mock.cpp | 286 int ParseMockOptions(DhcpMessage *packet) in ParseMockOptions() argument
|
| /third_party/ffmpeg/libavcodec/ |
| H A D | libopenjpegenc.c | 66 AVPacket *packet; member
72 AVPacket *packet = writer->packet; in stream_write() local
92 AVPacket *packet = writer->packet; in stream_skip() local
120 AVPacket *packet = writer->packet; stream_seek() local
[all...] |
| H A D | ffwavesynth.c | 416 wavesynth_decode(AVCodecContext *avc, AVFrame *frame, int *rgot_frame, AVPacket *packet) wavesynth_decode() argument
|
| /third_party/ffmpeg/libavdevice/ |
| H A D | iec61883.c | 104 DVPacket *packet; in iec61883_callback() local
192 DVPacket *packet; iec61883_parse_queue_dv() local
226 DVPacket *packet; iec61883_parse_queue_hdv() local
472 DVPacket *packet = dv->queue_first; iec61883_close() local
[all...] |
| /third_party/ffmpeg/libavformat/ |
| H A D | xmv.c | 183 XMVAudioPacket *packet = &xmv->audio[audio_track]; xmv_read_header() local
324 XMVAudioPacket *packet = &xmv->audio[audio_track]; xmv_process_packet_header() local
[all...] |
| /third_party/ltp/testcases/network/sockets/ |
| H A D | ltpClient.c | 59 struct packet { struct
370 unsigned char packet[PACKET_LEN]; in network_listener() local
|
| /third_party/node/deps/openssl/openssl/ssl/record/ |
| H A D | record.h | 86 unsigned char *packet; member
150 unsigned char *packet; member
|
| /third_party/openssl/ssl/record/ |
| H A D | record.h | 86 unsigned char *packet; member
150 unsigned char *packet; member
|
| /third_party/toybox/toys/pending/ |
| H A D | tftp.c | 181 static inline int check_data( uint8_t *packet, uint16_t *opcode, in check_data() argument
193 mkpkt_data(int fd, off_t offset, uint8_t *packet, uint16_t blockno) mkpkt_data() argument
213 read_ack(int sd, uint8_t *packet, struct sockaddr_storage *server, uint16_t *port, uint16_t *blockno) read_ack() argument
270 uint8_t *packet; file_get() local
385 uint8_t *packet; file_put() local
[all...] |
| /third_party/pulseaudio/src/modules/raop/ |
| H A D | raop-sink.c | 481 uint8_t packet[32]; in thread_func() local
|
| /third_party/vk-gl-cts/modules/egl/ |
| H A D | teglColorClearCase.cpp | 371 ClearPacket& packet = packets[threadNdx][packetNdx]; in executeForContexts() local
422 const ClearPacket& packet = packets[threadNdx][packetNdx]; in executeForContexts() local
[all...] |
| /base/security/device_security_level/test/dslm_unit_test/ |
| H A D | dslm_test.cpp | 569 MessagePacket *packet = ParseMessage(&msg); in HWTEST_F() local
585 MessagePacket *packet = ParseMessage(&msg); in HWTEST_F() local
597 MessagePacket *packet = ParseMessage(&msg); in HWTEST_F() local
645 MessagePacket *packet = ParseMessage(&msg); HWTEST_F() local
1915 MessagePacket *packet = (MessagePacket *)MALLOC(sizeof(MessagePacket)); HWTEST_F() local
[all...] |
| /foundation/multimedia/media_foundation/services/media_monitor/server/src/ |
| H A D | media_audio_encoder.cpp | 399 AVPacket *packet = apiWrap_->PacketAlloc(); in InitPacket() local
[all...] |
| /foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/syncer/src/device/singlever/ |
| H A D | single_ver_serialize_manager.cpp | 202 int SingleVerSerializeManager::DataPacketSyncerPartSerialization(Parcel &parcel, const DataRequestPacket *packet) in DataPacketSyncerPartSerialization() argument
226 auto packet = inMsg->GetObject<DataRequestPacket>(); DataPacketSerialization() local
270 DataPacketQuerySyncSerialization(Parcel &parcel, const DataRequestPacket *packet) DataPacketQuerySyncSerialization() argument
295 const DataRequestPacket *packet = inMsg->GetObject<DataRequestPacket>(); DataPacketCalculateLen() local
306 const DataAckPacket *packet = inMsg->GetObject<DataAckPacket>(); AckPacketCalculateLen() local
331 const DataAckPacket *packet = inMsg->GetObject<DataAckPacket>(); AckPacketSerialization() local
345 AckPacketSyncerPartSerializationV1(Parcel &parcel, const DataAckPacket *packet) AckPacketSyncerPartSerializationV1() argument
376 auto packet = new (std::nothrow) DataRequestPacket(); DataPacketDeSerialization() local
408 DataPacketQuerySyncDeSerialization(Parcel &parcel, DataRequestPacket *packet) DataPacketQuerySyncDeSerialization() argument
437 DataPacketCompressDataDeSerialization(Parcel &parcel, DataRequestPacket *packet) DataPacketCompressDataDeSerialization() argument
449 DataPacketSyncerPartDeSerialization(Parcel &parcel, DataRequestPacket *packet, uint32_t packLen, uint32_t length, uint32_t version) DataPacketSyncerPartDeSerialization() argument
497 DataAckPacket packet; AckPacketDeSerialization() local
520 AckPacketSyncerPartDeSerializationV1(Parcel &parcel, DataAckPacket &packet) AckPacketSyncerPartDeSerializationV1() argument
541 auto packet = inMsg->GetObject<ControlRequestPacket>(); ControlPacketCalculateLen() local
554 auto packet = inMsg->GetObject<ControlRequestPacket>(); ControlPacketSerialization() local
568 ControlRequestPacket packet; ControlPacketDeSerialization() local
581 auto packet = inMsg->GetObject<ControlAckPacket>(); AckControlPacketCalculateLen() local
592 auto packet = inMsg->GetObject<ControlAckPacket>(); AckControlPacketSerialization() local
611 auto packet = new (std::nothrow) ControlAckPacket(); AckControlPacketDeSerialization() local
644 auto packet = inMsg->GetObject<ControlRequestPacket>(); ControlRequestSerialization() local
660 ControlRequestDeSerialization(Parcel &parcel, ControlRequestPacket &packet) ControlRequestDeSerialization() argument
683 auto packet = inMsg->GetObject<SubscribeRequest>(); SubscribeCalculateLen() local
693 auto packet = inMsg->GetObject<SubscribeRequest>(); SubscribeSerialization() local
715 auto packet = new (std::nothrow) SubscribeRequest(); SubscribeDeSerialization() local
784 const auto packet = inMsg->GetObject<ISyncPacket>(); ISyncPacketCalculateLen() local
799 auto packet = inMsg->GetObject<ISyncPacket>(); ISyncPacketSerialization() local
812 ISyncPacket *packet = nullptr; ISyncPacketDeSerialization() local
832 BuildISyncPacket(Message *inMsg, ISyncPacket *&packet) BuildISyncPacket() argument
855 DataPacketExtraConditionsSerialization(Parcel &parcel, const DataRequestPacket *packet) DataPacketExtraConditionsSerialization() argument
877 DataPacketExtraConditionsDeserialization(Parcel &parcel, DataRequestPacket *packet) DataPacketExtraConditionsDeserialization() argument
907 DataPacketInnerDeSerialization(DataRequestPacket *packet, Parcel &parcel) DataPacketInnerDeSerialization() argument
951 DataPacketInnerSerialization(const DataRequestPacket *packet, Parcel &parcel) DataPacketInnerSerialization() argument
[all...] |
| H A D | single_ver_data_sync_utils.cpp | 93 int SingleVerDataSyncUtils::RequestQueryCheck(const DataRequestPacket *packet, SyncGenericInterface *storage) in RequestQueryCheck() argument
267 void SingleVerDataSyncUtils::SetPacketId(DataRequestPacket *packet, SingleVerSyncTaskContext *context, uint32_t version) in SetPacketId() argument
200 RunPermissionCheck(SingleVerSyncTaskContext *context, const SyncGenericInterface* storage, const std::string &label, const DataRequestPacket *packet) RunPermissionCheck() argument
312 FillControlRequestPacket(ControlRequestPacket *packet, SingleVerSyncTaskContext *context) FillControlRequestPacket() argument
351 const ControlRequestPacket *packet = inMsg->GetObject<ControlRequestPacket>(); IsNeedTriggerQueryAutoSync() local
489 RunPermissionCheckInner(const SingleVerSyncTaskContext *context, const SyncGenericInterface* storage, const std::string &label, const DataRequestPacket *packet, int mode) RunPermissionCheckInner() argument
511 const DataRequestPacket *packet = message->GetObject<DataRequestPacket>(); GetTimeOffsetFromRequestMsg() local
539 SetDataRequestCommonInfo(const SingleVerSyncTaskContext &context, const SyncGenericInterface &storage, DataRequestPacket &packet, std::shared_ptr<Metadata> &metadata) SetDataRequestCommonInfo() argument
565 SchemaVersionMatchCheck(const SingleVerSyncTaskContext &context, const DataRequestPacket &packet, std::shared_ptr<Metadata> &metadata) SchemaVersionMatchCheck() argument
616 UpdateSyncProcess(SingleVerSyncTaskContext *context, const DataRequestPacket *packet) UpdateSyncProcess() argument
[all...] |