From 59de8e1214c5f18df930f9aae3bc8182b78293b1 Mon Sep 17 00:00:00 2001 From: liym27 <33742067+liym27@users.noreply.github.com> Date: Thu, 31 Oct 2019 17:31:45 +0800 Subject: [PATCH] Compatible int32 and int64 for attr in concat/split/unsqueeze. test=develop (#20912) --- paddle/fluid/operators/split_op.h | 4 +- paddle/fluid/operators/unsqueeze_op.h | 34 +--------- paddle/fluid/operators/utils.h | 66 +++++++++++++------ .../fluid/tests/unittests/test_concat_op.py | 11 ++-- .../fluid/tests/unittests/test_split_op.py | 11 +++- .../tests/unittests/test_unsqueeze2_op.py | 22 +++++-- 6 files changed, 79 insertions(+), 69 deletions(-) diff --git a/paddle/fluid/operators/split_op.h b/paddle/fluid/operators/split_op.h index 552b27df1b..7a84e13c66 100644 --- a/paddle/fluid/operators/split_op.h +++ b/paddle/fluid/operators/split_op.h @@ -116,13 +116,13 @@ class SplitOpKernel : public framework::OpKernel { bool need_resize_outs_dims = false; if (ctx.HasInput("AxisTensor")) { auto* axis_tensor = ctx.Input("AxisTensor"); - axis = GetDataFromTensor(axis_tensor)[0]; + axis = GetDataFromTensor(axis_tensor)[0]; need_resize_outs_dims = true; } auto sections_tensor_list = ctx.MultiInput("SectionsTensorList"); if (sections_tensor_list.size() > 0) { - sections = GetDataFromTensorList(sections_tensor_list); + sections = GetDataFromTensorList(sections_tensor_list); need_resize_outs_dims = true; } diff --git a/paddle/fluid/operators/unsqueeze_op.h b/paddle/fluid/operators/unsqueeze_op.h index 75c443da95..22818bf81b 100644 --- a/paddle/fluid/operators/unsqueeze_op.h +++ b/paddle/fluid/operators/unsqueeze_op.h @@ -19,43 +19,11 @@ limitations under the License. */ #include "paddle/fluid/operators/math/blas.h" #include "paddle/fluid/operators/math/math_function.h" #include "paddle/fluid/operators/math/pooling.h" +#include "paddle/fluid/operators/utils.h" #include "paddle/fluid/platform/device_context.h" namespace paddle { namespace operators { -template -inline std::vector GetDataFromTensorList( - const std::vector &list_tensor) { - std::vector vec_new_data; - for (size_t i = 0; i < list_tensor.size(); ++i) { - auto tensor = list_tensor[i]; - PADDLE_ENFORCE_EQ( - tensor->dims(), framework::make_ddim({1}), - "ShapeError: If the element type is Tensor, " - "the element's shape must be [1]. But received the element's shape " - "is [%s]", - tensor->dims()); - if (platform::is_gpu_place(tensor->place())) { - framework::Tensor temp; - TensorCopySync(*tensor, platform::CPUPlace(), &temp); - vec_new_data.push_back((*temp.data())); - } else { - vec_new_data.push_back((*tensor->data())); - } - } - return vec_new_data; -} -template -inline std::vector GetDataFromTensor(const framework::Tensor *x) { - auto *data = x->data(); - framework::Tensor cpu_attr_tensor; - if (platform::is_gpu_place(x->place())) { - TensorCopySync(*x, platform::CPUPlace(), &cpu_attr_tensor); - data = cpu_attr_tensor.data(); - } - auto vec_data = std::vector(data, data + x->numel()); - return vec_data; -} template class UnsqueezeKernel : public framework::OpKernel { diff --git a/paddle/fluid/operators/utils.h b/paddle/fluid/operators/utils.h index fa76335ac5..72fb17a34a 100644 --- a/paddle/fluid/operators/utils.h +++ b/paddle/fluid/operators/utils.h @@ -20,35 +20,61 @@ limitations under the License. */ namespace paddle { namespace operators { -template +template inline std::vector GetDataFromTensor(const framework::Tensor* x) { - auto* data = x->data(); - framework::Tensor cpu_attr_tensor; - if (platform::is_gpu_place(x->place())) { - TensorCopySync(*x, platform::CPUPlace(), &cpu_attr_tensor); - data = cpu_attr_tensor.data(); + std::vector vec_new_data; + if (x->type() == framework::proto::VarType::INT32) { + auto* data = x->data(); + if (platform::is_gpu_place(x->place())) { + framework::Tensor cpu_attr_tensor; + TensorCopySync(*x, platform::CPUPlace(), &cpu_attr_tensor); + data = cpu_attr_tensor.data(); + } + vec_new_data = std::vector(data, data + x->numel()); + } else if (x->type() == framework::proto::VarType::INT64) { + auto* data = x->data(); + if (platform::is_gpu_place(x->place())) { + framework::Tensor cpu_attr_tensor; + TensorCopySync(*x, platform::CPUPlace(), &cpu_attr_tensor); + data = cpu_attr_tensor.data(); + } + vec_new_data = std::vector(data, data + x->numel()); + } else { + PADDLE_THROW("The dtype of Tensor must be int32 or int64."); } - auto vec_data = std::vector(data, data + x->numel()); - return vec_data; + return vec_new_data; } -template + +template inline std::vector GetDataFromTensorList( const std::vector& list_tensor) { std::vector vec_new_data; for (size_t i = 0; i < list_tensor.size(); ++i) { auto tensor = list_tensor[i]; - PADDLE_ENFORCE_EQ( - tensor->dims(), framework::make_ddim({1}), - "ShapeError: If the element type is Tensor, " - "the element's shape must be [1]. But received the element's shape " - "is [%s]", - tensor->dims()); - if (platform::is_gpu_place(tensor->place())) { - framework::Tensor temp; - TensorCopySync(*tensor, platform::CPUPlace(), &temp); - vec_new_data.push_back((*temp.data())); + PADDLE_ENFORCE_EQ(tensor->dims(), framework::make_ddim({1}), + "ShapeError: The shape of Tensor in list must be [1]. " + "But received the shape " + "is [%s]", + tensor->dims()); + + if (tensor->type() == framework::proto::VarType::INT32) { + if (platform::is_gpu_place(tensor->place())) { + framework::Tensor temp; + TensorCopySync(*tensor, platform::CPUPlace(), &temp); + vec_new_data.push_back(static_cast(*temp.data())); + } else { + vec_new_data.push_back(static_cast(*tensor->data())); + } + } else if (tensor->type() == framework::proto::VarType::INT64) { + if (platform::is_gpu_place(tensor->place())) { + framework::Tensor temp; + TensorCopySync(*tensor, platform::CPUPlace(), &temp); + vec_new_data.push_back(static_cast(*temp.data())); + } else { + vec_new_data.push_back(static_cast(*tensor->data())); + } } else { - vec_new_data.push_back((*tensor->data())); + PADDLE_THROW("The dtype of Tensor in list must be int32 or int64."); } } return vec_new_data; diff --git a/python/paddle/fluid/tests/unittests/test_concat_op.py b/python/paddle/fluid/tests/unittests/test_concat_op.py index 47fca51447..106382a42f 100644 --- a/python/paddle/fluid/tests/unittests/test_concat_op.py +++ b/python/paddle/fluid/tests/unittests/test_concat_op.py @@ -186,19 +186,22 @@ class TestConcatAPI(OpTest): input_3 = np.random.random([2, 2, 4, 5]).astype("int32") x_2 = fluid.data(shape=[2, 1, 4, 5], dtype='int32', name='x_2') x_3 = fluid.data(shape=[2, 2, 4, 5], dtype='int32', name='x_3') - positive_1 = fluid.layers.fill_constant([1], "int32", 1) + positive_1_int32 = fluid.layers.fill_constant([1], "int32", 1) + positive_1_int64 = fluid.layers.fill_constant([1], "int64", 1) out_1 = fluid.layers.concat(input=[x_2, x_3], axis=1) - out_2 = fluid.layers.concat(input=[x_2, x_3], axis=positive_1) + out_2 = fluid.layers.concat(input=[x_2, x_3], axis=positive_1_int32) + out_3 = fluid.layers.concat(input=[x_2, x_3], axis=positive_1_int64) exe = fluid.Executor(place=fluid.CPUPlace()) - [res_1, res_2] = exe.run( + [res_1, res_2, res_3] = exe.run( fluid.default_main_program(), feed={"x_1": input_2, "x_2": input_2, "x_3": input_3}, - fetch_list=[out_1, out_2]) + fetch_list=[out_1, out_2, out_3]) assert np.array_equal(res_1, np.concatenate((input_2, input_3), axis=1)) assert np.array_equal(res_2, np.concatenate((input_2, input_3), axis=1)) + assert np.array_equal(res_3, np.concatenate((input_2, input_3), axis=1)) if __name__ == '__main__': diff --git a/python/paddle/fluid/tests/unittests/test_split_op.py b/python/paddle/fluid/tests/unittests/test_split_op.py index 369bb3f7ce..6464b4e375 100644 --- a/python/paddle/fluid/tests/unittests/test_split_op.py +++ b/python/paddle/fluid/tests/unittests/test_split_op.py @@ -228,14 +228,19 @@ create_test_fp16(TestSplitOp) class TestSplitAPI(OpTest): def test_api(self): input_1 = np.random.random([4, 5, 6]).astype("int32") - positive_1 = fluid.layers.fill_constant([1], "int32", 1) + positive_1_int32 = fluid.layers.fill_constant([1], "int32", 1) + positive_1_int64 = fluid.layers.fill_constant([1], "int64", 1) + positive_2_int64 = fluid.layers.fill_constant([1], "int64", 2) x_1 = fluid.data(shape=[4, 5, 6], dtype='int32', name='x_1') x_2 = fluid.data(shape=[4, 5, None], dtype='int32', name='x_2') out_0, out_1, out_2 = fluid.layers.split( - input=x_1, num_or_sections=[2, positive_1, -1], dim=1) + input=x_1, + num_or_sections=[positive_2_int64, positive_1_int32, -1], + dim=positive_1_int64) + out_3, out_4, out_5 = fluid.layers.split( - input=x_1, num_or_sections=[2, 1, 2], dim=positive_1) + input=x_1, num_or_sections=[2, 1, 2], dim=positive_1_int32) fluid.layers.split(input=x_2, num_or_sections=2, dim=2) exe = fluid.Executor(place=fluid.CPUPlace()) diff --git a/python/paddle/fluid/tests/unittests/test_unsqueeze2_op.py b/python/paddle/fluid/tests/unittests/test_unsqueeze2_op.py index c04fc47f22..0e553287b5 100644 --- a/python/paddle/fluid/tests/unittests/test_unsqueeze2_op.py +++ b/python/paddle/fluid/tests/unittests/test_unsqueeze2_op.py @@ -207,27 +207,35 @@ class TestUnsqueezeAPI(OpTest): def test_api(self): input = np.random.random([3, 2, 5]).astype("float32") x = fluid.data(name='x', shape=[3, 2, 5], dtype="float32") - positive_3 = fluid.layers.fill_constant([1], "int32", 3) - axes_tensor = fluid.data(name='axes_tensor', shape=[3], dtype="int32") + positive_3_int32 = fluid.layers.fill_constant([1], "int32", 3) + positive_1_int64 = fluid.layers.fill_constant([1], "int64", 1) + axes_tensor_int32 = fluid.data( + name='axes_tensor_int32', shape=[3], dtype="int32") + axes_tensor_int64 = fluid.data( + name='axes_tensor_int64', shape=[3], dtype="int64") out_1 = fluid.layers.unsqueeze(x, axes=[3, 1, 1]) - out_2 = fluid.layers.unsqueeze(x, axes=[positive_3, 1, 1]) - out_3 = fluid.layers.unsqueeze(x, axes=axes_tensor) + out_2 = fluid.layers.unsqueeze( + x, axes=[positive_3_int32, positive_1_int64, 1]) + out_3 = fluid.layers.unsqueeze(x, axes=axes_tensor_int32) out_4 = fluid.layers.unsqueeze(x, axes=3) + out_5 = fluid.layers.unsqueeze(x, axes=axes_tensor_int64) exe = fluid.Executor(place=fluid.CPUPlace()) - res_1, res_2, res_3, res_4 = exe.run( + res_1, res_2, res_3, res_4, res_5 = exe.run( fluid.default_main_program(), feed={ "x": input, - "axes_tensor": np.array([3, 1, 1]).astype("int32") + "axes_tensor_int32": np.array([3, 1, 1]).astype("int32"), + "axes_tensor_int64": np.array([3, 1, 1]).astype("int64") }, - fetch_list=[out_1, out_2, out_3, out_4]) + fetch_list=[out_1, out_2, out_3, out_4, out_5]) assert np.array_equal(res_1, input.reshape([3, 1, 1, 2, 5, 1])) assert np.array_equal(res_2, input.reshape([3, 1, 1, 2, 5, 1])) assert np.array_equal(res_3, input.reshape([3, 1, 1, 2, 5, 1])) assert np.array_equal(res_4, input.reshape([3, 2, 5, 1])) + assert np.array_equal(res_5, input.reshape([3, 1, 1, 2, 5, 1])) def test_error(self): def test_axes_type(): -- GitLab