tensorflow/tensorflow/tensorflow/core/data/service/ Source Tree

../
auto_shard_rewriter.cc
auto_shard_rewriter.h AutoShardRewriter WorkerIndexResolver
[+] client/
common.cc
common.h DataServiceClientBase
common.pb.cc DatasetDefDefaultTypeInternal IterationKeyDefDefaultTypeInternal TaskDefDefaultTypeInternal TaskInfoDefaultTypeInternal
common.pb.h TableStruct_tensorflow_2fcore_2fdata_2fservice_2fcommon_2eproto is_proto_enum DatasetDef IterationKeyDef TargetWorkers TaskDef TaskInfo
credentials_factory.cc InsecureCredentialsFactory InsecureCredentialsRegistrar
credentials_factory.h CredentialsFactory
cross_trainer_cache.h CachableSequence CrossTrainerCache
data_transfer.cc
data_transfer.h DataTransferClient DataTransferServer GetElementResult
dataset_store.cc
dataset_store.h DatasetStore FileSystemDatasetStore MemoryDatasetStore
dispatcher.grpc.pb.cc
dispatcher.grpc.pb.h DispatcherService
dispatcher.pb.cc ClientHeartbeatRequestDefaultTypeInternal ClientHeartbeatResponseDefaultTypeInternal GetDataServiceConfigRequestDefaultTypeInternal GetDataServiceConfigResponseDefaultTypeInternal GetDataServiceMetadataRequestDefaultTypeInternal GetDataServiceMetadataResponseDefaultTypeInternal GetDatasetDefRequestDefaultTypeInternal GetDatasetDefResponseDefaultTypeInternal GetOrCreateIterationRequestDefaultTypeInternal GetOrCreateIterationResponseDefaultTypeInternal GetOrCreateJobRequestDefaultTypeInternal GetOrCreateJobResponseDefaultTypeInternal GetOrRegisterDatasetRequestDefaultTypeInternal GetOrRegisterDatasetResponseDefaultTypeInternal GetSplitRequestDefaultTypeInternal GetSplitResponseDefaultTypeInternal GetVersionRequestDefaultTypeInternal GetVersionResponseDefaultTypeInternal GetWorkersRequestDefaultTypeInternal GetWorkersResponseDefaultTypeInternal MaybeRemoveTaskRequestDefaultTypeInternal MaybeRemoveTaskResponseDefaultTypeInternal ReleaseIterationClientRequestDefaultTypeInternal ReleaseIterationClientResponseDefaultTypeInternal TaskProgressDefaultTypeInternal WorkerHeartbeatRequestDefaultTypeInternal WorkerHeartbeatResponseDefaultTypeInternal WorkerInfoDefaultTypeInternal WorkerUpdateRequestDefaultTypeInternal WorkerUpdateResponseDefaultTypeInternal
dispatcher.pb.h TableStruct_tensorflow_2fcore_2fdata_2fservice_2fdispatcher_2eproto ClientHeartbeatRequest ClientHeartbeatResponse GetDataServiceConfigRequest GetDataServiceConfigResponse GetDataServiceMetadataRequest GetDataServiceMetadataResponse GetDatasetDefRequest GetDatasetDefResponse GetOrCreateIterationRequest GetOrCreateIterationResponse GetOrCreateJobRequest GetOrCreateJobResponse GetOrRegisterDatasetRequest GetOrRegisterDatasetResponse GetSplitRequest GetSplitResponse GetVersionRequest GetVersionResponse GetWorkersRequest GetWorkersResponse MaybeRemoveTaskRequest MaybeRemoveTaskResponse ReleaseIterationClientRequest ReleaseIterationClientResponse TaskProgress WorkerHeartbeatRequest WorkerHeartbeatResponse WorkerInfo WorkerUpdateRequest WorkerUpdateResponse
dispatcher_client.cc
dispatcher_client.h DataServiceDispatcherClient
dispatcher_impl.cc
dispatcher_impl.h DataServiceDispatcherImpl
dispatcher_state.cc
dispatcher_state.h DispatcherState
export.pb.cc DispatcherStateExportDefaultTypeInternal DispatcherStateExport_IterationDefaultTypeInternal ServerStateExportDefaultTypeInternal WorkerStateExportDefaultTypeInternal
export.pb.h TableStruct_tensorflow_2fcore_2fdata_2fservice_2fexport_2eproto DispatcherStateExport DispatcherStateExport_Iteration ServerStateExport WorkerStateExport
grpc_dispatcher_impl.cc
grpc_dispatcher_impl.h GrpcDispatcherImpl
grpc_util.cc
grpc_util.h
grpc_worker_impl.cc
grpc_worker_impl.h GrpcWorkerImpl
journal.cc
journal.h FileJournalReader FileJournalWriter JournalReader JournalWriter
journal.pb.cc AcquireIterationClientUpdateDefaultTypeInternal ClientHeartbeatUpdateDefaultTypeInternal CreateIterationUpdateDefaultTypeInternal CreateJobUpdateDefaultTypeInternal CreatePendingTaskUpdateDefaultTypeInternal CreateTaskUpdateDefaultTypeInternal FinishTaskUpdateDefaultTypeInternal GarbageCollectIterationUpdateDefaultTypeInternal ProduceSplitUpdateDefaultTypeInternal RegisterDatasetUpdateDefaultTypeInternal RegisterWorkerUpdateDefaultTypeInternal ReleaseIterationClientUpdateDefaultTypeInternal RemoveTaskUpdateDefaultTypeInternal TaskRejectedDefaultTypeInternal UpdateDefaultTypeInternal
journal.pb.h TableStruct_tensorflow_2fcore_2fdata_2fservice_2fjournal_2eproto AcquireIterationClientUpdate ClientHeartbeatUpdate CreateIterationUpdate CreateJobUpdate CreatePendingTaskUpdate CreateTaskUpdate FinishTaskUpdate GarbageCollectIterationUpdate ProduceSplitUpdate RegisterDatasetUpdate RegisterWorkerUpdate ReleaseIterationClientUpdate RemoveTaskUpdate TaskRejected Update
logging_utils.cc
logging_utils.h
py_utils.cc
py_utils.h
server_lib.cc
server_lib.h DispatchGrpcDataServer GrpcDataServerBase WorkerGrpcDataServer
split_provider.cc
split_provider.h DataServiceSplitProvider
task_remover.cc
task_remover.h TaskRemover
task_runner.cc
task_runner.h CachingTaskRunner Element FirstComeFirstServedTaskRunner PrefetchThread RoundRobinTaskRunner StandaloneTaskIterator TaskIterator TaskRunner
thread_safe_buffer.h ThreadSafeBuffer
url.cc
url.h URL
utils.cc
utils.h
validate_utils.cc
validate_utils.h
worker.grpc.pb.cc
worker.grpc.pb.h WorkerService
worker.pb.cc GetElementRequestDefaultTypeInternal GetElementResponseDefaultTypeInternal GetWorkerTasksRequestDefaultTypeInternal GetWorkerTasksResponseDefaultTypeInternal ProcessTaskRequestDefaultTypeInternal ProcessTaskResponseDefaultTypeInternal
worker.pb.h TableStruct_tensorflow_2fcore_2fdata_2fservice_2fworker_2eproto GetElementRequest GetElementResponse GetWorkerTasksRequest GetWorkerTasksResponse ProcessTaskRequest ProcessTaskResponse
worker_client.cc GrpcDataTransferClient GrpcTransferClientRegistrar LocalDataTransferClient LocalTransferClientRegistrar
worker_client.h DataServiceWorkerClient
worker_impl.cc
worker_impl.h DataServiceWorkerImpl LocalWorkers

Browse the source code of tensorflow/tensorflow/tensorflow/core/data/service/ online