diff --git a/tensorflow/core/kernels/resize_nearest_neighbor_op.cc b/tensorflow/core/kernels/resize_nearest_neighbor_op.cc index 998881defe0..71f964dc1f6 100644 --- a/tensorflow/core/kernels/resize_nearest_neighbor_op.cc +++ b/tensorflow/core/kernels/resize_nearest_neighbor_op.cc @@ -69,13 +69,13 @@ class ResizeNearestNeighborOp : public OpKernel { /*half_pixe_centers=*/true, /*align_corners=*/true>()( context->eigen_device(), input_data, st.height_scale, - st.width_scale, output_data, context); + st.width_scale, output_data); } else { status = functor::ResizeNearestNeighbor()( context->eigen_device(), input_data, st.height_scale, - st.width_scale, output_data, context); + st.width_scale, output_data); } } else { if (align_corners_) { @@ -83,13 +83,13 @@ class ResizeNearestNeighborOp : public OpKernel { /*half_pixe_centers=*/false, /*align_corners=*/true>()( context->eigen_device(), input_data, st.height_scale, - st.width_scale, output_data, context); + st.width_scale, output_data); } else { status = functor::ResizeNearestNeighbor()( context->eigen_device(), input_data, st.height_scale, - st.width_scale, output_data, context); + st.width_scale, output_data); } } if (!status) { @@ -131,13 +131,9 @@ struct BoolToScaler { namespace functor { template struct ResizeNearestNeighbor { - bool ParallelExecute(const CPUDevice& d, - typename TTypes::ConstTensor input, - const float height_scale, const float width_scale, - typename TTypes::Tensor output, - OpKernelContext* c) { - const DeviceBase::CpuWorkerThreads& worker_threads = - *(c->device()->tensorflow_cpu_worker_threads()); + bool operator()(const CPUDevice& d, typename TTypes::ConstTensor input, + const float height_scale, const float width_scale, + typename TTypes::Tensor output) { const Eigen::Index batch_size = input.dimension(0); const Eigen::Index in_height = input.dimension(1); const Eigen::Index in_width = input.dimension(2); @@ -170,18 +166,9 @@ struct ResizeNearestNeighbor { } }; Eigen::Index N = batch_size * out_height * out_width; - Shard(worker_threads.num_threads, worker_threads.workers, N, 1000.0, - ParallelResize); // TODO: Come up with a good cost estimate: - // 3500:26~27fps, 1000:27~28fps. + d.parallelFor(N, Eigen::TensorOpCost(0, 0, 1000.0), ParallelResize); return true; } - bool operator()(const CPUDevice& d, typename TTypes::ConstTensor input, - const float height_scale, const float width_scale, - typename TTypes::Tensor output, - OpKernelContext* context) { - return ParallelExecute(d, input, height_scale, width_scale, output, - context); - } }; } // namespace functor diff --git a/tensorflow/core/kernels/resize_nearest_neighbor_op.h b/tensorflow/core/kernels/resize_nearest_neighbor_op.h index 3f564bf23cc..46264790b34 100644 --- a/tensorflow/core/kernels/resize_nearest_neighbor_op.h +++ b/tensorflow/core/kernels/resize_nearest_neighbor_op.h @@ -28,8 +28,7 @@ template ::ConstTensor input, const float height_scale, const float width_scale, - typename TTypes::Tensor output, - OpKernelContext* context = NULL); + typename TTypes::Tensor output); }; template