Searched refs:RemoteExecutor (Results 1 – 7 of 7) sorted by relevance
44 RemoteExecutor::RemoteExecutor() in RemoteExecutor() function in DistributedDB::RemoteExecutor132 void RemoteExecutor::NotifyUserChange() in NotifyUserChange()142 void RemoteExecutor::Close() in Close()361 uint32_t RemoteExecutor::GenerateSessionId() in GenerateSessionId()374 uint32_t RemoteExecutor::GenerateTaskId() in GenerateTaskId()448 void RemoteExecutor::DoRollBack(uint32_t sessionId) in DoRollBack()476 int RemoteExecutor::RequestStart(uint32_t sessionId) in RequestStart()635 void RemoteExecutor::RemoveTimer(uint32_t sessionId) in RemoveTimer()665 void RemoteExecutor::DoTimeout(TimerId timerId) in DoTimeout()724 void RemoteExecutor::ClearInnerSource() in ClearInnerSource()[all …]
33 class RemoteExecutor : public RefObject {55 RemoteExecutor();57 ~RemoteExecutor() = default;
209 RemoteExecutor *GetAndIncRemoteExector();211 void SetRemoteExector(RemoteExecutor *executor);251 RemoteExecutor *remoteExecutor_;
147 RemoteExecutor *executor = GetAndIncRemoteExector(); in Close()240 auto executor = new (std::nothrow) RemoteExecutor(); in InitInnerSource()820 RemoteExecutor *executor = GetAndIncRemoteExector(); in OfflineHandleByDevice()1094 RemoteExecutor *executor = GetAndIncRemoteExector(); in RemoteQuery()1106 RemoteExecutor *executor = GetAndIncRemoteExector(); in NotifyConnectionClosed()1117 RemoteExecutor *executor = GetAndIncRemoteExector(); in NotifyUserChange()1126 RemoteExecutor *SyncEngine::GetAndIncRemoteExector() in GetAndIncRemoteExector()1133 void SyncEngine::SetRemoteExector(RemoteExecutor *executor) in SetRemoteExector()1200 RemoteExecutor *executor = GetAndIncRemoteExector(); in HandleRemoteExecutorMsg()
22 class MockRemoteExecutor : public RemoteExecutor {30 return RemoteExecutor::ResponseFailed(errCode, sessionId, sequenceId, device); in CallResponseFailed()
60 RemoteExecutor *executor_;
117 executor_ = new (std::nothrow) RemoteExecutor(); in Initialize()