未验证 提交 149a1e31 编写于 作者: W wangchaochaohu 提交者: GitHub

Expand refine (#21063)

* fix the expand op compile time cost long time test=develop

* add tag for just copy  test=develop
上级 af3ff422
...@@ -34,9 +34,7 @@ limitations under the License. */ ...@@ -34,9 +34,7 @@ limitations under the License. */
break; \ break; \
} }
#define REP_EXPAND_TEMPLATE(n) BOOST_PP_REPEAT(n, EXPAND_TEMPLATE, ~) #define REP_EXPAND_TEMPLATE(n) BOOST_PP_REPEAT(n, EXPAND_TEMPLATE, ~)
#define COND(n) \ #define COND(n) BOOST_PP_GREATER_EQUAL(n, BOOST_PP_MOD(n, MAX_RANK_SUPPORTED))
BOOST_PP_GREATER_EQUAL(BOOST_PP_DIV(n, MAX_RANK_SUPPORTED), \
BOOST_PP_MOD(n, MAX_RANK_SUPPORTED))
#define EXPAND_GRAD_CASE(n) \ #define EXPAND_GRAD_CASE(n) \
case n: { \ case n: { \
ExpandBackward<n>(context, reshape_dims_vec, reduce_dims_vec); \ ExpandBackward<n>(context, reshape_dims_vec, reduce_dims_vec); \
...@@ -145,33 +143,29 @@ class ExpandGradKernel : public framework::OpKernel<T> { ...@@ -145,33 +143,29 @@ class ExpandGradKernel : public framework::OpKernel<T> {
// auto& expand_times = context.Attr<std::vector<int>>("expand_times"); // auto& expand_times = context.Attr<std::vector<int>>("expand_times");
auto expand_times = get_expand_times(context); auto expand_times = get_expand_times(context);
auto x_dims = in0->dims(); auto x_dims = in0->dims();
// 1. reshape_dims_vec is the broadcast parameter. For each dimension i, // 1. reshape_dims_vec is the broadcast parameter.
// if expand_times[i] > 1 and x_dims[i] > 1, i will be splitted to two
// dimensions [expand_times[i], x_dims[i]].
// 2. reduce_dims_vec is the dimension parameter to compute gradients. For // 2. reduce_dims_vec is the dimension parameter to compute gradients. For
// each dimension expanded, the gradients should be summed to original // each dimension expanded, the gradients should be summed to original
// size. // size.
std::vector<int> reshape_dims_vec; std::vector<int> reshape_dims_vec;
std::vector<int> reduce_dims_vec; std::vector<int> reduce_dims_vec;
for (size_t i = 0; i < expand_times.size(); ++i) { for (size_t i = 0; i < expand_times.size(); ++i) {
if (expand_times[i] == 1) {
reshape_dims_vec.push_back(x_dims[i]);
} else {
if (x_dims[i] == 1) {
reduce_dims_vec.push_back(reshape_dims_vec.size());
reshape_dims_vec.push_back(expand_times[i]);
} else {
reduce_dims_vec.push_back(reshape_dims_vec.size()); reduce_dims_vec.push_back(reshape_dims_vec.size());
reshape_dims_vec.push_back(expand_times[i]); reshape_dims_vec.push_back(expand_times[i]);
reshape_dims_vec.push_back(x_dims[i]); reshape_dims_vec.push_back(x_dims[i]);
} }
int dims = reduce_dims_vec.size();
bool just_copy = true;
for (size_t i = 0; i < expand_times.size(); i++) {
if (expand_times[i] != 1) {
just_copy = false;
break;
} }
} }
int dims = reshape_dims_vec.size() * MAX_RANK_SUPPORTED +
reduce_dims_vec.size() - MAX_RANK_SUPPORTED - 1;
// no need reduce, just copy // no need reduce, just copy
if (reduce_dims_vec.size() == 0) { if (just_copy) {
auto* in0 = context.Input<Tensor>(framework::GradVarName("Out")); auto* in0 = context.Input<Tensor>(framework::GradVarName("Out"));
auto* out0 = context.Output<Tensor>(framework::GradVarName("X")); auto* out0 = context.Output<Tensor>(framework::GradVarName("X"));
out0->mutable_data<T>(context.GetPlace()); out0->mutable_data<T>(context.GetPlace());
...@@ -179,7 +173,7 @@ class ExpandGradKernel : public framework::OpKernel<T> { ...@@ -179,7 +173,7 @@ class ExpandGradKernel : public framework::OpKernel<T> {
out0); out0);
} else { } else {
switch (dims) { switch (dims) {
REP_EXPAND_GRAD_TEMPLATE(72) REP_EXPAND_GRAD_TEMPLATE(MAX_RANK_SUPPORTED)
default: default:
PADDLE_ENFORCE( PADDLE_ENFORCE(
false, "Only support tensor with rank being between 1 and 6."); false, "Only support tensor with rank being between 1 and 6.");
...@@ -192,8 +186,8 @@ class ExpandGradKernel : public framework::OpKernel<T> { ...@@ -192,8 +186,8 @@ class ExpandGradKernel : public framework::OpKernel<T> {
void ExpandBackward(const framework::ExecutionContext& context, void ExpandBackward(const framework::ExecutionContext& context,
const std::vector<int>& reshape_dims_vec, const std::vector<int>& reshape_dims_vec,
const std::vector<int>& reduce_dims_vec) const { const std::vector<int>& reduce_dims_vec) const {
size_t reshape_size = Dims / MAX_RANK_SUPPORTED + 1; size_t reshape_size = reshape_dims_vec.size();
size_t reduce_size = Dims % MAX_RANK_SUPPORTED + 1; size_t reduce_size = reduce_dims_vec.size();
PADDLE_ENFORCE_EQ(reshape_size, reshape_dims_vec.size(), PADDLE_ENFORCE_EQ(reshape_size, reshape_dims_vec.size(),
"Inconsistent size between template Dims and " "Inconsistent size between template Dims and "
"reshape dimensions."); "reshape dimensions.");
...@@ -204,11 +198,11 @@ class ExpandGradKernel : public framework::OpKernel<T> { ...@@ -204,11 +198,11 @@ class ExpandGradKernel : public framework::OpKernel<T> {
auto* out0 = context.Output<Tensor>(framework::GradVarName("X")); auto* out0 = context.Output<Tensor>(framework::GradVarName("X"));
out0->mutable_data<T>(context.GetPlace()); out0->mutable_data<T>(context.GetPlace());
auto x_grad = EigenVector<T>::Flatten(*out0); auto x_grad = EigenVector<T>::Flatten(*out0);
Eigen::DSizes<int, Dims / MAX_RANK_SUPPORTED + 1> reshape_dims; Eigen::DSizes<int, Dims * 2> reshape_dims;
for (size_t i = 0; i < reshape_size; ++i) { for (size_t i = 0; i < reshape_size; ++i) {
reshape_dims[i] = reshape_dims_vec[i]; reshape_dims[i] = reshape_dims_vec[i];
} }
Eigen::DSizes<int, Dims % MAX_RANK_SUPPORTED + 1> reduce_dims; Eigen::DSizes<int, Dims> reduce_dims;
for (size_t i = 0; i < reduce_size; ++i) { for (size_t i = 0; i < reduce_size; ++i) {
reduce_dims[i] = reduce_dims_vec[i]; reduce_dims[i] = reduce_dims_vec[i];
} }
......
Markdown is supported
0% .
You are about to add 0 people to the discussion. Proceed with caution.
先完成此消息的编辑!
想要评论请 注册