/base/msdp/device_status/utils/ipc/include/ |
H A D | stream_client.h | 41 bool SendMsg(const char *buf, size_t size) const;
42 bool SendMsg(const NetPacket &pkt) const;
|
H A D | stream_session.h | 42 bool SendMsg(const char *buf, size_t size) const;
43 bool SendMsg(NetPacket &pkt) const;
|
/base/msdp/device_status/utils/ipc/src/ |
H A D | stream_client.cpp | 48 bool StreamClient::SendMsg(const char *buf, size_t size) const
in SendMsg() function in OHOS::Msdp::DeviceStatus::StreamClient 89 bool StreamClient::SendMsg(const NetPacket &pkt) const
in SendMsg() function in OHOS::Msdp::DeviceStatus::StreamClient 100 return SendMsg(buf.Data(), buf.Size());
in SendMsg()
|
H A D | stream_session.cpp | 43 bool StreamSession::SendMsg(const char *buf, size_t size) const
in SendMsg() function in OHOS::Msdp::DeviceStatus::StreamSession 97 bool StreamSession::SendMsg(NetPacket &pkt) const
in SendMsg() function in OHOS::Msdp::DeviceStatus::StreamSession 108 return SendMsg(buf.Data(), buf.Size());
in SendMsg()
|
/base/startup/init/services/param/watcher/agent/ |
H A D | watcher_manager_proxy.cpp | 51 int32_t WatcherManagerProxy::SendMsg(int op, const std::string &keyPrefix, uint32_t remoteWatcherId) in SendMsg() function in OHOS::init_param::WatcherManagerProxy 66 return SendMsg(static_cast<uint32_t>(ParamWatcherInterfaceCode::ADD_WATCHER), keyPrefix, remoteWatcherId); in AddWatcher() 71 return SendMsg(static_cast<uint32_t>(ParamWatcherInterfaceCode::DEL_WATCHER), keyPrefix, remoteWatcherId); in DelWatcher() 76 return SendMsg(static_cast<uint32_t>(ParamWatcherInterfaceCode::REFRESH_WATCHER), keyPrefix, remoteWatcherId); in RefreshWatcher()
|
H A D | watcher_manager_proxy.h | 35 int32_t SendMsg(int op, const std::string &keyPrefix, uint32_t remoteWatcherId);
|
/base/msdp/device_status/intention/ipc/socket/include/ |
H A D | socket_session.h | 34 bool SendMsg(NetPacket &pkt) const override; 46 bool SendMsg(const char *buf, size_t size) const;
|
/base/sensors/sensor/utils/ipc/include/ |
H A D | stream_session.h | 40 bool SendMsg(const char *buf, size_t size) const; 41 bool SendMsg(const NetPacket &pkt) const;
|
/base/sensors/sensor/utils/ipc/src/ |
H A D | stream_session.cpp | 51 bool StreamSession::SendMsg(const char *buf, size_t size) const in SendMsg() function in OHOS::Sensors::StreamSession 143 bool StreamSession::SendMsg(const NetPacket &pkt) const in SendMsg() function in OHOS::Sensors::StreamSession 152 return SendMsg(StreamBufferData(buf.streamBufferPtr_.get()), StreamBufferSize(buf.streamBufferPtr_.get())); in SendMsg() 160 return SendMsg(buf.Data(), buf.Size()); in SendMsg()
|
/base/msdp/device_status/intention/ipc/socket/src/ |
H A D | socket_session.cpp | 44 bool SocketSession::SendMsg(NetPacket &pkt) const
in SendMsg() function in OHOS::Msdp::DeviceStatus::SocketSession 55 return SendMsg(buf.Data(), buf.Size());
in SendMsg() 58 bool SocketSession::SendMsg(const char *buf, size_t size) const
in SendMsg() function in OHOS::Msdp::DeviceStatus::SocketSession
|
/base/msdp/device_status/intention/prototype/include/ |
H A D | i_socket_session.h | 40 virtual bool SendMsg(NetPacket &pkt) const = 0;
|
/base/telephony/call_manager/test/unittest/distributed_communication_test/src/ |
H A D | distributed_transmission_test.cpp | 109 session->SendMsg(nullptr, 0); in HWTEST_F() 111 session->SendMsg(nullptr, 0); in HWTEST_F()
|
/base/telephony/call_manager/services/distributed_call/src/distributed_communication/ |
H A D | distributed_data_controller.cpp | 64 session_->SendMsg(data.c_str(), static_cast<uint32_t>(data.length())); in SetMuted() 77 session_->SendMsg(data.c_str(), static_cast<uint32_t>(data.length())); in MuteRinger()
|
H A D | distributed_data_sink_controller.cpp | 174 session_->SendMsg(data.c_str(), static_cast<uint32_t>(data.length())); in SendDataQueryReq() 287 session_->SendMsg(data.c_str(), static_cast<uint32_t>(data.length())); in SendCurrentDataQueryReq()
|
H A D | distributed_data_source_controller.cpp | 222 session_->SendMsg(data.c_str(), static_cast<uint32_t>(data.length())); in SendLocalDataRsp() 282 session_->SendMsg(data.c_str(), static_cast<uint32_t>(data.length())); in HandleCurrentDataQueryMsg()
|
/base/msdp/device_status/test/unittest/intention/ipc/src/ |
H A D | socket_session_test.cpp | 473 bool ret = g_session->SendMsg(pkt); in HWTEST_F() 488 ASSERT_NO_FATAL_FAILURE(g_session->SendMsg(buf, size)); in HWTEST_F() 512 bool ret = g_session->SendMsg(buf, size); in HWTEST_F() 562 bool ret = g_session->SendMsg(buf, size); in HWTEST_F() 613 bool ret = g_sessionOne->SendMsg(buf, size); in HWTEST_F()
|
/base/msdp/device_status/services/native/src/ |
H A D | stream_server.cpp | 72 bool StreamServer::SendMsg(int32_t fd, NetPacket &pkt)
in SendMsg() function in OHOS::Msdp::DeviceStatus::StreamServer 84 return ses->SendMsg(pkt);
in SendMsg() 90 SendMsg(item, pkt);
in Multicast()
|
/base/telephony/call_manager/services/distributed_call/include/transmission/ |
H A D | session_adapter.h | 52 void SendMsg(const void *data, uint32_t len);
|
/base/msdp/device_status/services/interaction/drag/src/ |
H A D | state_change_notify.cpp | 98 if (!session->SendMsg(pkt)) { in OnDragInfoNotify()
|
/base/msdp/device_status/test/fuzztest/ipcsocket_fuzzer/ |
H A D | ipcsocket_fuzzer.cpp | 136 socketSession.SendMsg(packet); in SocketSessionFuzzTest()
|
/base/msdp/device_status/services/native/include/ |
H A D | stream_server.h | 50 bool SendMsg(int32_t fd, NetPacket &pkt);
|
/base/startup/appspawn/test/moduletest/ |
H A D | appspawn_test_cmder.h | 74 int SendMsg();
|
/base/telephony/call_manager/services/distributed_call/src/transmission/ |
H A D | session_adapter.cpp | 41 void SessionAdapter::SendMsg(const void *data, uint32_t len) in SendMsg() function in OHOS::Telephony::SessionAdapter
|
/base/msdp/device_status/intention/cooperate/plugin/src/ |
H A D | event_manager.cpp | 249 if (!session->SendMsg(pkt)) { in NotifyCooperateMessage() 266 if (!session->SendMsg(pkt)) { in NotifyCooperateState()
|
H A D | hot_area.cpp | 155 if (!session->SendMsg(pkt)) { in NotifyHotAreaMessage()
|