Searched refs:sess (Results 1 - 8 of 8) sorted by relevance
| /base/update/updateservice/frameworks/js/napi/session/src/ |
| H A D | napi_session.cpp | 82 auto sess = reinterpret_cast<NapiSession *>(data); in CompleteWork() local
83 PARAM_CHECK(sess != nullptr && sess->GetNapiClient() != nullptr, return, "Session is null pointer"); in CompleteWork()
84 sess->CompleteWork(env, status); in CompleteWork()
86 BaseClient *client = sess->GetNapiClient(); in CompleteWork()
88 client->RemoveSession(sess->GetSessionId()); in CompleteWork()
96 auto sess = reinterpret_cast<NapiSession *>(data); in ExecuteWork() local
97 PARAM_CHECK(sess != nullptr, return, "sess is null"); in ExecuteWork()
98 sess in ExecuteWork()
[all...] |
| /base/update/updateservice/frameworks/js/napi/update/common/src/ |
| H A D | iupdater.cpp | 44 std::shared_ptr<BaseSession> sess = std::make_shared<UpdateListener>(this, sessionParams, argc, false); in On() local
45 PARAM_CHECK_NAPI_CALL(env, sess != nullptr, return nullptr, "Failed to create listener"); in On()
47 sessionsMgr_->AddSession(sess); in On()
48 napi_value retValue = sess->StartWork( in On()
55 PARAM_CHECK(retValue != nullptr, sessionsMgr_->RemoveSession(sess->GetSessionId()); return nullptr, in On()
111 std::shared_ptr<BaseSession> sess = nullptr; in StartSession() local
113 sess = std::make_shared<UpdateAsyncession>(this, sessionParams, argc); in StartSession()
115 sess = std::make_shared<UpdatePromiseSession>(this, sessionParams, argc); in StartSession()
117 PARAM_CHECK_NAPI_CALL(env, sess != nullptr, return nullptr, "Failed to create update session"); in StartSession()
118 sessionsMgr_->AddSession(sess); in StartSession()
[all...] |
| /base/sensors/sensor/services/src/ |
| H A D | stream_server.cpp | 97 SessionPtr sess = nullptr; in AddSocketPairInfo() local
114 sess = std::make_shared<StreamSession>("", serverFd, uid, pid); in AddSocketPairInfo()
115 sess->SetTokenType(tokenType); in AddSocketPairInfo()
116 if (!AddSession(sess)) { in AddSocketPairInfo()
128 bool StreamServer::AddSession(SessionPtr sess) in AddSession() argument
131 CHKPF(sess); in AddSession()
132 auto fd = sess->GetFd(); in AddSession()
137 auto pid = sess->GetPid(); in AddSession()
148 sessionsMap_[fd] = sess; in AddSession()
|
| H A D | sensor_power_policy.cpp | 257 for (const auto &sess : sessionList) { in ReportActiveInfo()
258 if (!sess->SendMsg(pkt)) { in ReportActiveInfo()
|
| H A D | sensor_service.cpp | 580 auto sess = GetSessionByPid(pid); in ReportActiveInfo() local
581 if (sess != nullptr) { in ReportActiveInfo()
582 sessionList.push_back(sess); in ReportActiveInfo()
|
| /base/msdp/device_status/services/native/src/ |
| H A D | devicestatus_service.cpp | 1027 SessionPtr sess = GetSession(GetClientFd(pid)); in OnRegisterCoordinationListener() local
1028 CHKPR(sess, RET_ERR); in OnRegisterCoordinationListener()
1032 event->sess = sess; in OnRegisterCoordinationListener()
1040 SessionPtr sess = GetSession(GetClientFd(pid)); in OnUnregisterCoordinationListener() local
1044 event->sess = sess; in OnUnregisterCoordinationListener()
1059 SessionPtr sess = GetSession(GetClientFd(pid)); in OnPrepareCoordination() local
1060 CHKPR(sess, RET_ERR); in OnPrepareCoordination()
1061 if (!sess in OnPrepareCoordination()
1079 SessionPtr sess = GetSession(GetClientFd(pid)); OnUnprepareCoordination() local
1092 SessionPtr sess = GetSession(GetClientFd(pid)); OnActivateCoordination() local
1106 SessionPtr sess = GetSession(GetClientFd(pid)); OnDeactivateCoordination() local
1121 SessionPtr sess = GetSession(GetClientFd(pid)); OnGetCoordinationState() local
1141 auto sess = GetSession(GetClientFd(pid)); OnAddHotAreaListener() local
1154 auto sess = GetSession(GetClientFd(pid)); OnRemoveHotAreaListener() local
[all...] |
| H A D | stream_server.cpp | 114 SessionPtr sess = nullptr;
in AddSocketPairInfo() local
115 sess = std::make_shared<StreamSession>(programName, moduleType, serverFd, uid, pid);
in AddSocketPairInfo()
116 sess->SetTokenType(tokenType);
in AddSocketPairInfo()
117 if (!AddSession(sess)) {
in AddSocketPairInfo()
125 OnConnected(sess);
in AddSocketPairInfo()
206 auto sess = GetSession(fd);
in OnPacket() local
207 CHKPV(sess);
in OnPacket()
208 recvFun_(sess, pkt);
in OnPacket()
|
| /base/sensors/sensor/services/include/ |
| H A D | stream_server.h | 38 bool AddSession(SessionPtr sess);
|
Completed in 10 milliseconds