Searched refs:DataServiceWorkerImpl (Results 1 – 3 of 3) sorted by relevance
54 DataServiceWorkerImpl::DataServiceWorkerImpl( in DataServiceWorkerImpl() function in tensorflow::data::DataServiceWorkerImpl60 DataServiceWorkerImpl::~DataServiceWorkerImpl() { in ~DataServiceWorkerImpl()67 Status DataServiceWorkerImpl::Start(const std::string& worker_address, in Start()100 Status DataServiceWorkerImpl::ProcessTask(const ProcessTaskRequest* request, in ProcessTask()108 Status DataServiceWorkerImpl::ProcessTaskInternal(const TaskDef& task_def) in ProcessTaskInternal()122 Status DataServiceWorkerImpl::EnsureTaskInitialized( in EnsureTaskInitialized()123 DataServiceWorkerImpl::Task& task) { in EnsureTaskInitialized()180 Status DataServiceWorkerImpl::GetElement(const GetElementRequest* request, in GetElement()221 Status DataServiceWorkerImpl::GetWorkerTasks( in GetWorkerTasks()234 void DataServiceWorkerImpl::TaskCompletionThread() TF_LOCKS_EXCLUDED(mu_) { in TaskCompletionThread()[all …]
34 class DataServiceWorkerImpl {36 explicit DataServiceWorkerImpl(const experimental::WorkerConfig& config);37 ~DataServiceWorkerImpl();105 TF_DISALLOW_COPY_AND_ASSIGN(DataServiceWorkerImpl);
57 DataServiceWorkerImpl impl_;