| /base/msdp/device_status/services/interaction/coordination/src/ |
| D | coordination.cpp | 41 int32_t Coordination::ActivateCoordination(SessionPtr sess, int32_t userData, in ActivateCoordination() argument
47 event->sess = sess; in ActivateCoordination()
59 int32_t Coordination::DeactivateCoordination(SessionPtr sess, int32_t userData, bool isUnchained) in DeactivateCoordination() argument
64 event->sess = sess; in DeactivateCoordination()
76 int32_t Coordination::GetCoordinationState(SessionPtr sess, int32_t userData, const std::string &de… in GetCoordinationState() argument
81 event->sess = sess; in GetCoordinationState()
92 int32_t Coordination::RegisterCoordinationListener(SessionPtr sess) in RegisterCoordinationListener() argument
97 event->sess = sess; in RegisterCoordinationListener()
103 int32_t Coordination::UnregisterCoordinationListener(SessionPtr sess) in UnregisterCoordinationListener() argument
108 event->sess = sess; in UnregisterCoordinationListener()
|
| D | coordination_event_manager.cpp | 37 return (*info).sess == event->sess; in AddCoordinationEvent()
57 if ((*it)->sess == event->sess) { in RemoveCoordinationEvent()
75 NotifyCoordinationMessage(info->sess, info->msgId, info->userData, deviceId, msg); in OnCoordinationMessage()
86 NotifyCoordinationMessage(info->sess, info->msgId, info->userData, deviceId, msg); in OnEnable()
96 NotifyCoordinationMessage(info->sess, info->msgId, info->userData, deviceId, msg); in OnStart()
106 NotifyCoordinationMessage(info->sess, info->msgId, info->userData, deviceId, msg); in OnStop()
116 NotifyCoordinationState(info->sess, info->msgId, info->userData, state); in OnGetCrossingSwitchState()
125 NotifyCoordinationMessage(info->sess, info->msgId, info->userData, "", msg); in OnErrorMessage()
140 …SessionPtr sess, MessageId msgId, int32_t userData, const std::string &deviceId, CoordinationMessa… in NotifyCoordinationMessage() argument
143 CHKPV(sess); in NotifyCoordinationMessage()
[all …]
|
| D | coordination_sm.cpp | 99 event->sess = session; in OnSessionLost()
|
| /base/msdp/device_status/services/interaction/coordination/include/ |
| D | coordination.h | 31 int32_t ActivateCoordination(SessionPtr sess, int32_t userData,
33 int32_t DeactivateCoordination(SessionPtr sess, int32_t userData, bool isUnchained);
34 int32_t GetCoordinationState(SessionPtr sess, int32_t userData, const std::string &deviceId);
35 int32_t RegisterCoordinationListener(SessionPtr sess);
36 int32_t UnregisterCoordinationListener(SessionPtr sess);
|
| D | i_coordination.h | 34 virtual int32_t ActivateCoordination(SessionPtr sess, int32_t userData,
36 virtual int32_t DeactivateCoordination(SessionPtr sess, int32_t userData, bool isUnchained) = 0;
37 …virtual int32_t GetCoordinationState(SessionPtr sess, int32_t userData, const std::string &deviceI…
38 virtual int32_t RegisterCoordinationListener(SessionPtr sess) = 0;
39 virtual int32_t UnregisterCoordinationListener(SessionPtr sess) = 0;
|
| D | coordination_event_manager.h | 41 SessionPtr sess { nullptr };
63 void NotifyCoordinationMessage(SessionPtr sess, MessageId msgId, int32_t userData,
65 void NotifyCoordinationState(SessionPtr sess, MessageId msgId, int32_t userData, bool state);
|
| /base/update/updateservice/frameworks/js/napi/base/src/ |
| D | iupdater.cpp | 41 …std::shared_ptr<UpdateSession> sess = std::make_shared<UpdateListener>(this, sessionParams, argc, … in On() local
42 PARAM_CHECK_NAPI_CALL(env, sess != nullptr, return nullptr, "Failed to create listener"); in On()
44 sessionsMgr_->AddSession(sess); in On()
45 napi_value retValue = sess->StartWork(env, args, in On()
49 …PARAM_CHECK(retValue != nullptr, sessionsMgr_->RemoveSession(sess->GetSessionId()); return nullptr, in On()
100 std::shared_ptr<IUpdateSession> sess = nullptr; in StartSession() local
102 sess = std::make_shared<UpdateAsyncession>(this, sessionParams, argc); in StartSession()
104 sess = std::make_shared<UpdatePromiseSession>(this, sessionParams, argc); in StartSession()
106 PARAM_CHECK_NAPI_CALL(env, sess != nullptr, return nullptr, "Failed to create update session"); in StartSession()
107 sessionsMgr_->AddSession(sess); in StartSession()
[all …]
|
| /base/sensors/sensor/services/sensor/src/ |
| D | stream_server.cpp | 95 SessionPtr sess = nullptr; in AddSocketPairInfo() local
112 sess = std::make_shared<StreamSession>("", serverFd, uid, pid); in AddSocketPairInfo()
113 sess->SetTokenType(tokenType); in AddSocketPairInfo()
114 if (!AddSession(sess)) { in AddSocketPairInfo()
126 bool StreamServer::AddSession(SessionPtr sess) in AddSession() argument
129 CHKPF(sess); in AddSession()
130 auto fd = sess->GetFd(); in AddSession()
135 auto pid = sess->GetPid(); in AddSession()
146 sessionsMap_[fd] = sess; in AddSession()
|
| D | sensor_power_policy.cpp | 248 for (const auto &sess : sessionList) { in ReportActiveInfo() local
249 if (!sess->SendMsg(pkt)) { in ReportActiveInfo()
|
| D | sensor_service.cpp | 533 auto sess = GetSessionByPid(pid); in ReportActiveInfo() local
534 if (sess != nullptr) { in ReportActiveInfo()
535 sessionList.push_back(sess); in ReportActiveInfo()
|
| /base/msdp/device_status/services/native/src/ |
| D | devicestatus_service.cpp | 767 auto sess = GetSession(GetClientFd(pid)); in OnRegisterCoordinationListener() local
768 CHKPR(sess, RET_ERR); in OnRegisterCoordinationListener()
772 event->sess = sess; in OnRegisterCoordinationListener()
781 auto sess = GetSession(GetClientFd(pid)); in OnUnregisterCoordinationListener() local
785 event->sess = sess; in OnUnregisterCoordinationListener()
802 auto sess = GetSession(GetClientFd(pid)); in OnPrepareCoordination() local
803 CHKPR(sess, RET_ERR); in OnPrepareCoordination()
804 if (!sess->SendMsg(pkt)) { in OnPrepareCoordination()
826 auto sess = GetSession(GetClientFd(pid)); in OnUnprepareCoordination() local
827 CHKPR(sess, RET_ERR); in OnUnprepareCoordination()
[all …]
|
| D | stream_server.cpp | 112 SessionPtr sess = nullptr; in AddSocketPairInfo() local
140 sess = std::make_shared<StreamSession>(programName, moduleType, serverFd, uid, pid); in AddSocketPairInfo()
141 sess->SetTokenType(tokenType); in AddSocketPairInfo()
142 if (!AddSession(sess)) { in AddSocketPairInfo()
150 OnConnected(sess); in AddSocketPairInfo()
193 auto sess = GetSession(fd); in OnPacket() local
194 CHKPV(sess); in OnPacket()
195 recvFun_(sess, pkt); in OnPacket()
|
| /base/update/updateservice/frameworks/js/napi/client/ |
| D | update_session.cpp | 85 auto sess = reinterpret_cast<UpdateSession*>(data); in CompleteWork() local
86 …PARAM_CHECK(sess != nullptr && sess->GetUpdateClient() != nullptr, return, "Session is null pointe… in CompleteWork()
87 sess->CompleteWork(env, status); in CompleteWork()
89 IUpdater *client = sess->GetUpdateClient(); in CompleteWork()
91 client->RemoveSession(sess->GetSessionId()); in CompleteWork()
99 auto sess = reinterpret_cast<UpdateSession*>(data); in ExecuteWork() local
100 PARAM_CHECK(sess != nullptr, return, "sess is null"); in ExecuteWork()
101 sess->ExecuteWork(env); in ExecuteWork()
|
| D | update_client.cpp | 122 std::shared_ptr<UpdateSession> sess = nullptr; in CancelUpgrade() local
123 sess = std::make_shared<UpdateAsyncessionNoCallback>(this, sessionParams, argc); in CancelUpgrade()
124 PARAM_CHECK_NAPI_CALL(env, sess != nullptr, return nullptr, "Failed to create update session"); in CancelUpgrade()
125 sessionsMgr_->AddSession(sess); in CancelUpgrade()
126 napi_value retValue = sess->StartWork( in CancelUpgrade()
135 PARAM_CHECK(retValue != nullptr, sessionsMgr_->RemoveSession(sess->GetSessionId()); in CancelUpgrade()
|
| /base/sensors/sensor/services/sensor/include/ |
| D | stream_server.h | 38 bool AddSession(SessionPtr sess);
|
| /base/msdp/device_status/services/context/include/ |
| D | i_drag_manager.h | 37 virtual int32_t StartDrag(const DragData &dragData, SessionPtr sess) = 0;
|
| /base/msdp/device_status/services/interaction/drag/include/ |
| D | drag_manager.h | 46 int32_t StartDrag(const DragData &dragData, SessionPtr sess) override;
|
| /base/msdp/device_status/services/interaction/drag/src/ |
| D | drag_manager.cpp | 81 int32_t DragManager::StartDrag(const DragData &dragData, SessionPtr sess) in StartDrag() argument
98 dragOutSession_ = sess; in StartDrag()
|