Searched refs:ProcessTask (Results 1 – 9 of 9) sorted by relevance
145 processFuture = executor.submit(new ProcessTask()); in run()153 private final class ProcessTask implements Runnable { class in ServerEndpoint
147 processFuture = executor.submit(new ProcessTask()); in run()155 private final class ProcessTask implements Runnable { class in ServerEndpoint
150 processFuture = executor.submit(new ProcessTask()); in run()158 private final class ProcessTask implements Runnable { class in ServerEndpoint
60 HANDLER(ProcessTask);
66 HANDLER(ProcessTask);
60 rpc ProcessTask(ProcessTaskRequest) returns (ProcessTaskResponse); rpc
76 Status ProcessTask(const ProcessTaskRequest* request,
284 Status DataServiceWorkerImpl::ProcessTask(const ProcessTaskRequest* request, in ProcessTask() function in tensorflow::data::DataServiceWorkerImpl
916 grpc::Status s = stub->ProcessTask(&client_ctx, req, &resp); in AssignTask()