Home
last modified time | relevance | path

Searched refs:packet (Results 1 - 25 of 26) sorted by relevance

12

/base/msdp/device_status/intention/cooperate/plugin/src/
H A Ddsoftbus_handler.cpp40 [this] (const std::string &networkId, NetPacket &packet) { in DSoftbusHandler()
41 this->OnStartCooperate(networkId, packet);}}, in DSoftbusHandler()
43 [this] (const std::string &networkId, NetPacket &packet) { in DSoftbusHandler()
44 this->OnStopCooperate(networkId, packet);}}, in DSoftbusHandler()
46 [this] (const std::string &networkId, NetPacket &packet) { in DSoftbusHandler()
47 this->OnComeBack(networkId, packet);}}, in DSoftbusHandler()
49 [this] (const std::string &networkId, NetPacket &packet) { in DSoftbusHandler()
50 this->OnRelayCooperate(networkId, packet);}}, in DSoftbusHandler()
52 [this] (const std::string &networkId, NetPacket &packet) { in DSoftbusHandler()
53 this->OnRelayCooperateFinish(networkId, packet);}}, in DSoftbusHandler()
228 OnPacket(const std::string &networkId, NetPacket &packet) OnPacket() argument
262 OnStartCooperate(const std::string &networkId, NetPacket &packet) OnStartCooperate() argument
283 OnStopCooperate(const std::string &networkId, NetPacket &packet) OnStopCooperate() argument
295 OnComeBack(const std::string &networkId, NetPacket &packet) OnComeBack() argument
316 OnRelayCooperate(const std::string &networkId, NetPacket &packet) OnRelayCooperate() argument
333 OnRelayCooperateFinish(const std::string &networkId, NetPacket &packet) OnRelayCooperateFinish() argument
349 OnSubscribeMouseLocation(const std::string &networKId, NetPacket &packet) OnSubscribeMouseLocation() argument
363 OnUnSubscribeMouseLocation(const std::string& networKId, NetPacket &packet) OnUnSubscribeMouseLocation() argument
377 OnReplySubscribeLocation(const std::string& networKId, NetPacket &packet) OnReplySubscribeLocation() argument
391 OnReplyUnSubscribeLocation(const std::string& networKId, NetPacket &packet) OnReplyUnSubscribeLocation() argument
405 OnRemoteMouseLocation(const std::string& networKId, NetPacket &packet) OnRemoteMouseLocation() argument
420 OnRemoteInputDevice(const std::string& networkId, NetPacket &packet) OnRemoteInputDevice() argument
445 OnRemoteHotPlug(const std::string &networkId, NetPacket &packet) OnRemoteHotPlug() argument
462 DeserializeDevice(std::shared_ptr<IDevice> device, NetPacket &packet) DeserializeDevice() argument
[all...]
H A Dmouse_location.cpp246 NetPacket packet(MessageId::DSOFTBUS_REPLY_SUBSCRIBE_MOUSE_LOCATION); in ReplySubscribeMouseLocation()
247 packet << event.networkId << event.remoteNetworkId << event.result; in ReplySubscribeMouseLocation()
248 if (packet.ChkRWError()) { in ReplySubscribeMouseLocation()
249 FI_HILOGE("Failed to write data packet"); in ReplySubscribeMouseLocation()
252 if (SendPacket(event.remoteNetworkId, packet) != RET_OK) { in ReplySubscribeMouseLocation()
262 NetPacket packet(MessageId::DSOFTBUS_REPLY_UNSUBSCRIBE_MOUSE_LOCATION); in ReplyUnSubscribeMouseLocation()
263 packet << event.networkId << event.remoteNetworkId << event.result; in ReplyUnSubscribeMouseLocation()
264 if (packet.ChkRWError()) { in ReplyUnSubscribeMouseLocation()
265 FI_HILOGE("Failed to write data packet"); in ReplyUnSubscribeMouseLocation()
268 if (SendPacket(event.remoteNetworkId, packet) ! in ReplyUnSubscribeMouseLocation()
375 SendPacket(const std::string &remoteNetworkId, NetPacket &packet) SendPacket() argument
[all...]
H A Dinput_device_mgr.cpp130 NetPacket packet(MessageId::DSOFTBUS_INPUT_DEV_SYNC); in NotifyInputDeviceToRemote()
132 packet << keyboardNum; in NotifyInputDeviceToRemote()
134 if (SerializeDevice(keyboard, packet) != RET_OK) { in NotifyInputDeviceToRemote()
140 if (int32_t ret = env_->GetDSoftbus().SendPacket(remoteNetworkId, packet); ret != RET_OK) { in NotifyInputDeviceToRemote()
156 NetPacket packet(MessageId::DSOFTBUS_INPUT_DEV_HOT_PLUG); in BroadcastHotPlugToRemote()
157 packet << static_cast<int32_t>(notice.type); in BroadcastHotPlugToRemote()
162 if (SerializeDevice(device, packet) != RET_OK) { in BroadcastHotPlugToRemote()
168 packet << notice.deviceId; in BroadcastHotPlugToRemote()
169 if (packet.ChkRWError()) { in BroadcastHotPlugToRemote()
170 FI_HILOGE("Write packet faile in BroadcastHotPlugToRemote()
243 SerializeDevice(std::shared_ptr<IDevice> device, NetPacket &packet) SerializeDevice() argument
[all...]
/base/security/device_security_level/services/common/
H A Ddslm_msg_serialize.c73 MessagePacket *packet = NULL; in ParseMessage() local
83 packet = MALLOC(sizeof(MessagePacket)); in ParseMessage()
84 if (packet == NULL) { in ParseMessage()
88 packet->type = (uint32_t)msgType; in ParseMessage()
89 packet->payload = (uint8_t *)payload; in ParseMessage()
90 packet->length = strlen(payload) + 1; // for the end flag '\0' in ParseMessage()
94 return packet; in ParseMessage()
97 void FreeMessagePacket(MessagePacket *packet) in FreeMessagePacket() argument
99 if (packet == NULL) { in FreeMessagePacket()
102 if (packet in FreeMessagePacket()
[all...]
/base/security/device_security_level/services/sa/common/
H A Ddslm_rpc_process.c46 MessagePacket *packet = ParseMessage(&buff); in OnPeerMsgReceived() local
47 if (packet == NULL) { in OnPeerMsgReceived()
48 SECURITY_LOG_ERROR("packet is null"); in OnPeerMsgReceived()
51 if (packet->payload == NULL) { in OnPeerMsgReceived()
52 FreeMessagePacket(packet); in OnPeerMsgReceived()
53 SECURITY_LOG_ERROR("packet->payload is null"); in OnPeerMsgReceived()
57 switch (packet->type) { in OnPeerMsgReceived()
59 ret = OnPeerMsgRequestInfoReceived(devId, packet->payload, packet->length); in OnPeerMsgReceived()
62 ret = OnPeerMsgResponseInfoReceived(devId, packet in OnPeerMsgReceived()
[all...]
/base/msdp/device_status/intention/cooperate/plugin/include/
H A Ddsoftbus_handler.h50 bool OnPacket(const std::string &networkId, NetPacket &packet) override
52 return parent_.OnPacket(networkId, packet);
85 bool OnPacket(const std::string &networkId, NetPacket &packet);
88 void OnStartCooperate(const std::string &networkId, NetPacket &packet);
89 void OnStopCooperate(const std::string &networkId, NetPacket &packet);
90 void OnComeBack(const std::string &networkId, NetPacket &packet);
91 void OnRelayCooperate(const std::string &networkId, NetPacket &packet);
92 void OnRelayCooperateFinish(const std::string &networkId, NetPacket &packet);
93 void OnSubscribeMouseLocation(const std::string& networKId, NetPacket &packet);
94 void OnUnSubscribeMouseLocation(const std::string& networKId, NetPacket &packet);
[all...]
H A Dmouse_location.h63 int32_t SendPacket(const std::string &remoteNetworkId, NetPacket &packet);
H A Dinput_device_mgr.h60 int32_t SerializeDevice(std::shared_ptr<IDevice> device, NetPacket &packet);
/base/msdp/device_status/test/unittest/intention/cooperate/src/
H A Dinput_event_serialization_test.cpp67 NetPacket packet(MessageId::DSOFTBUS_INPUT_KEY_EVENT); in HWTEST_F()
68 int32_t ret = Cooperate::InputEventSerialization::KeyEventToNetPacket(keyEvent, packet); in HWTEST_F()
70 ret = Cooperate::InputEventSerialization::NetPacketToKeyEvent(packet, keyEvent); in HWTEST_F()
93 NetPacket packet(MessageId::DSOFTBUS_INPUT_KEY_EVENT); in HWTEST_F()
94 int32_t ret = Cooperate::InputEventSerialization::SerializeInputEvent(keyEvent, packet); in HWTEST_F()
96 ret = Cooperate::InputEventSerialization::DeserializeInputEvent(packet, keyEvent); in HWTEST_F()
119 NetPacket packet(MessageId::DSOFTBUS_INPUT_KEY_EVENT); in HWTEST_F()
120 Cooperate::InputEventSerialization::ReadFunctionKeys(packet, keyEvent); in HWTEST_F()
134 NetPacket packet(MessageId::DSOFTBUS_INPUT_KEY_EVENT); in HWTEST_F()
135 int32_t ret = Cooperate::InputEventSerialization::SwitchEventToNetPacket(switchEvent, packet); in HWTEST_F()
[all...]
H A Dinput_event_builder_test.cpp152 NetPacket packet(MessageId::DSOFTBUS_INPUT_POINTER_EVENT); in HWTEST_F()
153 bool ret = builder_->OnPacket(networkId_, packet); in HWTEST_F()
166 NetPacket packet(MessageId::DSOFTBUS_INPUT_POINTER_EVENT); in HWTEST_F()
167 bool ret = builder_->OnPacket(networkId_, packet); in HWTEST_F()
186 NetPacket packet(MessageId::DSOFTBUS_INPUT_POINTER_EVENT); in HWTEST_F()
187 int32_t ret1 = InputEventSerialization::Marshalling(builder_->pointerEvent_, packet); in HWTEST_F()
189 bool ret = builder_->OnPacket(networkId_, packet); in HWTEST_F()
549 NetPacket packet(MessageId::DSOFTBUS_INPUT_POINTER_EVENT); in HWTEST_F()
565 int32_t ret1 = InputEventSerialization::Marshalling(pointerEvent, packet); in HWTEST_F()
567 bool ret = builder_->OnPacket(networkId_, packet); in HWTEST_F()
[all...]
H A Dcooperate_plugin_test.cpp474 NetPacket packet(MessageId::DSOFTBUS_START_COOPERATE); in HWTEST_F()
477 g_context->dsoftbus_.OnStartCooperate("test", packet); in HWTEST_F()
478 g_context->dsoftbus_.OnStopCooperate("test", packet); in HWTEST_F()
479 g_context->dsoftbus_.OnComeBack("test", packet); in HWTEST_F()
480 g_context->dsoftbus_.OnRelayCooperate("test", packet); in HWTEST_F()
481 g_context->dsoftbus_.OnRelayCooperateFinish("test", packet); in HWTEST_F()
482 g_context->dsoftbus_.OnSubscribeMouseLocation("test", packet); in HWTEST_F()
483 g_context->dsoftbus_.OnUnSubscribeMouseLocation("test", packet); in HWTEST_F()
484 g_context->dsoftbus_.OnReplySubscribeLocation("test", packet); in HWTEST_F()
485 g_context->dsoftbus_.OnReplyUnSubscribeLocation("test", packet); in HWTEST_F()
[all...]
/base/msdp/device_status/intention/adapters/dsoftbus_adapter/src/
H A Ddsoftbus_adapter.cpp58 int32_t DSoftbusAdapter::SendPacket(const std::string &networkId, NetPacket &packet) in SendPacket() argument
60 return DSoftbusAdapterImpl::GetInstance()->SendPacket(networkId, packet); in SendPacket()
68 int32_t DSoftbusAdapter::BroadcastPacket(NetPacket &packet) in BroadcastPacket() argument
70 return DSoftbusAdapterImpl::GetInstance()->BroadcastPacket(packet); in BroadcastPacket()
H A Ddsoftbus_adapter_impl.cpp190 int32_t DSoftbusAdapterImpl::SendPacket(const std::string &networkId, NetPacket &packet) in SendPacket() argument
200 if (!packet.MakeData(buffer)) { in SendPacket()
201 FI_HILOGE("Failed to buffer packet"); in SendPacket()
233 int32_t DSoftbusAdapterImpl::BroadcastPacket(NetPacket &packet) in BroadcastPacket() argument
242 if (!packet.MakeData(buffer)) { in BroadcastPacket()
243 FI_HILOGE("Failed to buffer packet"); in BroadcastPacket()
557 FI_HILOGE("Corrupted net packet"); in HandleSessionData()
565 NetPacket packet(head->idMsg); in HandleSessionData()
567 if ((head->size > 0) && !packet.Write(&buf[sizeof(PackHead)], head->size)) { in HandleSessionData()
568 FI_HILOGE("Failed to fill packet, PacketSiz in HandleSessionData()
576 HandlePacket(const std::string &networkId, NetPacket &packet) HandlePacket() argument
[all...]
/base/msdp/device_status/intention/prototype/include/
H A Di_dsoftbus_adapter.h36 virtual bool OnPacket(const std::string &networkId, NetPacket &packet) = 0;
55 virtual int32_t SendPacket(const std::string &networkId, NetPacket &packet) = 0;
57 virtual int32_t BroadcastPacket(NetPacket &packet) = 0;
/base/msdp/device_status/test/fuzztest/ipcsocket_fuzzer/
H A Dipcsocket_fuzzer.cpp70 NetPacket packet(MessageId::INVALID); in SocketClientFuzzTest()
74 socketClient.OnMsgHandler(socketClient, packet); in SocketClientFuzzTest()
76 socketClient.OnPacket(packet); in SocketClientFuzzTest()
132 NetPacket packet(MessageId::COORDINATION_ADD_LISTENER); in SocketSessionFuzzTest()
136 socketSession.SendMsg(packet); in SocketSessionFuzzTest()
/base/msdp/device_status/intention/cooperate/plugin/include/input_event_transmission/
H A Dinput_event_builder.h45 bool OnPacket(const std::string &networkId, Msdp::NetPacket &packet) override
47 return parent_.OnPacket(networkId, packet);
87 bool OnPacket(const std::string &networkId, Msdp::NetPacket &packet);
88 void OnPointerEvent(Msdp::NetPacket &packet);
89 void OnKeyEvent(Msdp::NetPacket &packet);
/base/security/device_security_level/services/include/
H A Ddslm_msg_serialize.h48 MessageBuff *SerializeMessage(const MessagePacket *packet);
50 void FreeMessagePacket(MessagePacket *packet);
/base/msdp/device_status/intention/cooperate/plugin/src/input_event_transmission/
H A Dinput_event_builder.cpp148 bool InputEventBuilder::OnPacket(const std::string &networkId, Msdp::NetPacket &packet) in OnPacket() argument
151 FI_HILOGW("Unexpected packet from \'%{public}s\'", Utility::Anonymize(networkId).c_str()); in OnPacket()
154 switch (packet.GetMsgId()) { in OnPacket()
156 OnPointerEvent(packet); in OnPacket()
160 OnKeyEvent(packet); in OnPacket()
165 static_cast<int32_t>(packet.GetMsgId()), Utility::Anonymize(networkId).c_str()); in OnPacket()
172 void InputEventBuilder::OnPointerEvent(Msdp::NetPacket &packet) in OnPointerEvent() argument
183 int32_t ret = InputEventSerialization::Unmarshalling(packet, pointerEvent_); in OnPointerEvent()
220 void InputEventBuilder::OnKeyEvent(Msdp::NetPacket &packet) in OnKeyEvent() argument
224 int32_t ret = InputEventSerialization::NetPacketToKeyEvent(packet, keyEvent in OnKeyEvent()
[all...]
H A Dinput_event_interceptor.cpp119 NetPacket packet(MessageId::DSOFTBUS_INPUT_POINTER_EVENT); in OnPointerEvent()
121 int32_t ret = InputEventSerialization::Marshalling(pointerEvent, packet); in OnPointerEvent()
128 env_->GetDSoftbus().SendPacket(remoteNetworkId_, packet); in OnPointerEvent()
159 NetPacket packet(MessageId::DSOFTBUS_INPUT_KEY_EVENT); in OnKeyEvent()
161 int32_t ret = InputEventSerialization::KeyEventToNetPacket(keyEvent, packet); in OnKeyEvent()
168 env_->GetDSoftbus().SendPacket(remoteNetworkId_, packet); in OnKeyEvent()
/base/msdp/device_status/intention/adapters/dsoftbus_adapter/include/
H A Ddsoftbus_adapter.h42 int32_t SendPacket(const std::string &networkId, NetPacket &packet) override;
44 int32_t BroadcastPacket(NetPacket &packet) override;
H A Ddsoftbus_adapter_impl.h83 int32_t SendPacket(const std::string &networkId, NetPacket &packet) override;
85 int32_t BroadcastPacket(NetPacket &packet) override;
105 void HandlePacket(const std::string &networkId, NetPacket &packet);
/base/msdp/device_status/test/fuzztest/dsoftbusadapter_fuzzer/
H A Ddsoftbusadapter_fuzzer.cpp84 bool OnPacket(const std::string &networkId, NetPacket &packet) in OnPacket() argument
165 NetPacket packet(MessageId::DSOFTBUS_START_COOPERATE); in SendPacketFuzzTest()
167 DSoftbusAdapterImpl::GetInstance()->SendPacket(networkId, packet); in SendPacketFuzzTest()
169 DSoftbusAdapterImpl::GetInstance()->BroadcastPacket(packet); in SendPacketFuzzTest()
170 DSoftbusAdapterImpl::GetInstance()->HandlePacket(networkId, packet); in SendPacketFuzzTest()
/base/msdp/device_status/test/unittest/intention/adapters/src/
H A Ddsoftbus_adapter_test.cpp118 bool OnPacket(const std::string &networkId, NetPacket &packet) in OnPacket() argument
253 NetPacket packet(MessageId::DSOFTBUS_START_COOPERATE); in HWTEST_F()
254 ASSERT_NO_FATAL_FAILURE(dSoftbusAdapter.SendPacket(networkId, packet)); in HWTEST_F()
445 NetPacket packet(MessageId::DSOFTBUS_START_COOPERATE); in HWTEST_F()
446 ASSERT_NO_FATAL_FAILURE(DSoftbusAdapterImpl::GetInstance()->SendPacket(networkId, packet)); in HWTEST_F()
480 NetPacket packet(MessageId::DSOFTBUS_START_COOPERATE); in HWTEST_F()
481 int32_t ret = DSoftbusAdapterImpl::GetInstance()->BroadcastPacket(packet); in HWTEST_F()
487 ret = DSoftbusAdapterImpl::GetInstance()->BroadcastPacket(packet); in HWTEST_F()
579 NetPacket packet(MessageId::DSOFTBUS_START_COOPERATE); in HWTEST_F()
581 ASSERT_NO_FATAL_FAILURE(dSoftbusAdapterImpl.HandlePacket(networkId, packet);); in HWTEST_F()
[all...]
/base/sensors/miscdevice/services/miscdevice_service/hdi_connection/adapter/src/
H A Dhdi_connection.cpp195 HapticPaket packet = {}; in PlayPattern() local
196 packet.time = pattern.startTime; in PlayPattern()
198 packet.eventNum = eventNum; in PlayPattern()
216 packet.events.emplace_back(hapticEvent); in PlayPattern()
218 int32_t ret = vibratorInterface_->PlayHapticPattern(packet); in PlayPattern()
/base/security/device_security_level/test/dslm_unit_test/
H A Ddslm_test.cpp569 MessagePacket *packet = ParseMessage(&msg); in HWTEST_F() local
570 ASSERT_NE(nullptr, packet); in HWTEST_F()
572 EXPECT_EQ(1U, packet->type); in HWTEST_F()
573 EXPECT_STREQ(except, (const char *)packet->payload); in HWTEST_F()
575 FreeMessagePacket(packet); in HWTEST_F()
585 MessagePacket *packet = ParseMessage(&msg); in HWTEST_F() local
586 EXPECT_EQ(nullptr, packet); in HWTEST_F()
587 FreeMessagePacket(packet); in HWTEST_F()
597 MessagePacket *packet = ParseMessage(&msg); in HWTEST_F() local
598 EXPECT_EQ(nullptr, packet); in HWTEST_F()
645 MessagePacket *packet = ParseMessage(&msg); HWTEST_F() local
1915 MessagePacket *packet = (MessagePacket *)MALLOC(sizeof(MessagePacket)); HWTEST_F() local
[all...]

Completed in 15 milliseconds

12