specializations.cpp 22.1 KB
Newer Older
1
/**
2
 * \file imperative/src/impl/ops/specialzations.cpp
3 4
 * MegEngine is Licensed under the Apache License, Version 2.0 (the "License")
 *
5
 * Copyright (c) 2014-2021 Megvii Inc. All rights reserved.
6 7 8
 *
 * Unless required by applicable law or agreed to in writing,
 * software distributed under the License is distributed on an
M
Megvii Engine Team 已提交
9 10
 * "AS IS" BASIS, WITHOUT ARRANTIES OR CONDITIONS OF ANY KIND, either express or
 * implied.
11 12 13 14 15
 */

// FIXME: split this file into separate files for each specialized op

#include "megbrain/imperative/ops/autogen.h"
M
Megvii Engine Team 已提交
16 17
#include "megbrain/opr/basic_arith.h"
#include "megbrain/opr/blas.h"
18
#include "megbrain/opr/dnn/adaptive_pooling.h"
M
Megvii Engine Team 已提交
19 20
#include "megbrain/opr/dnn/convolution.h"
#include "megbrain/opr/dnn/correlation.h"
21
#include "megbrain/opr/dnn/fake_quant.h"
M
Megvii Engine Team 已提交
22
#include "megbrain/opr/dnn/images2neibs.h"
23
#include "megbrain/opr/dnn/local.h"
24
#include "megbrain/opr/dnn/lrn.h"
M
Megvii Engine Team 已提交
25 26
#include "megbrain/opr/dnn/lsq.h"
#include "megbrain/opr/dnn/pooling.h"
27 28
#include "megbrain/opr/dnn/roi_align.h"
#include "megbrain/opr/dnn/roi_pooling.h"
M
Megvii Engine Team 已提交
29
#include "megbrain/opr/dnn/sliding_window_transpose.h"
M
Megvii Engine Team 已提交
30
#include "megbrain/opr/dnn/tqt.h"
31 32 33 34 35 36 37 38 39 40 41 42 43 44
#include "megbrain/opr/imgproc.h"
#include "megbrain/opr/indexing.h"
#include "megbrain/opr/io.h"
#include "megbrain/opr/misc.h"
#include "megbrain/opr/nn_int.h"
#include "megbrain/opr/rand.h"
#include "megbrain/opr/tensor_gen.h"
#include "megbrain/opr/tensor_manip.h"
#include "megbrain/opr/utility.h"

#include "../op_trait.h"

namespace mgb::imperative {

M
Megvii Engine Team 已提交
45 46
namespace {
namespace dimshuffle {
47 48 49
std::shared_ptr<OpDef> make_from_op_node(cg::OperatorNodeBase* node_) {
    auto* node = &node_->cast_final_safe<opr::Dimshuffle>();
    std::vector<int> pattern(node->param().pattern_len);
M
Megvii Engine Team 已提交
50
    for (size_t i = 0; i < node->param().pattern_len; ++i) {
51 52 53 54 55
        pattern[i] = node->param().pattern[i];
    }
    return Dimshuffle::make(pattern);
}

M
Megvii Engine Team 已提交
56
auto apply_on_var_node(const OpDef& def, const VarNodeArray& inputs) {
57
    auto&& ds = static_cast<const Dimshuffle&>(def);
58 59
    OperatorNodeConfig config{ds.make_name()};
    return opr::Dimshuffle::make(inputs[0], ds.pattern, 0UL, config);
60 61 62
}

OP_TRAIT_REG(Dimshuffle, Dimshuffle, opr::Dimshuffle)
M
Megvii Engine Team 已提交
63 64 65 66 67
        .make_from_op_node(make_from_op_node)
        .apply_on_var_node(apply_on_var_node)
        .fallback();
}  // namespace dimshuffle
}  // namespace
68

M
Megvii Engine Team 已提交
69 70 71
namespace {
namespace add_axis {
auto apply_on_var_node(const OpDef& def, const VarNodeArray& inputs) {
72 73 74 75 76 77
    auto&& add_axis = static_cast<const AddAxis&>(def);
    using Desc = opr::AxisAddRemove::AxisDesc;
    std::vector<Desc> param;
    for (auto&& i : add_axis.axis) {
        param.push_back(Desc::make_add(i));
    }
78 79
    OperatorNodeConfig config{add_axis.make_name()};
    return opr::AxisAddRemove::make(inputs[0], param, config);
80 81
}

M
Megvii Engine Team 已提交
82 83 84
OP_TRAIT_REG(AddAxis, AddAxis).apply_on_var_node(apply_on_var_node).fallback();
}  // namespace add_axis
}  // namespace
85

M
Megvii Engine Team 已提交
86 87 88
namespace {
namespace remove_axis {
auto apply_on_var_node(const OpDef& def, const VarNodeArray& inputs) {
89 90 91 92 93 94
    auto&& remove_axis = static_cast<const RemoveAxis&>(def);
    using Desc = opr::AxisAddRemove::AxisDesc;
    std::vector<Desc> param;
    for (auto&& i : remove_axis.axis) {
        param.push_back(Desc::make_remove(i));
    }
95 96
    OperatorNodeConfig config{remove_axis.make_name()};
    return opr::AxisAddRemove::make(inputs[0], param, config);
97 98
}

M
Megvii Engine Team 已提交
99
OP_TRAIT_REG(RemoveAxis, RemoveAxis).apply_on_var_node(apply_on_var_node).fallback();
M
Megvii Engine Team 已提交
100 101
}  // namespace remove_axis
}  // namespace
102

M
Megvii Engine Team 已提交
103 104 105
namespace {
namespace top_k {
auto apply_on_var_node(const OpDef& def, const VarNodeArray& inputs) {
106
    auto&& topk = static_cast<const TopK&>(def);
107 108
    OperatorNodeConfig config{topk.make_name()};
    return opr::TopK::make(inputs[0], inputs[1], topk.param(), config)[0]
M
Megvii Engine Team 已提交
109 110
            .node()
            ->owner_opr();
111 112
}

M
Megvii Engine Team 已提交
113 114 115
OP_TRAIT_REG(TopK, TopK).apply_on_var_node(apply_on_var_node).fallback();
}  // namespace top_k
}  // namespace
116

M
Megvii Engine Team 已提交
117 118 119
namespace {
namespace adaptive_pooling {
auto apply_on_var_node(const OpDef& def, const VarNodeArray& inputs) {
120
    auto&& pool = static_cast<const AdaptivePooling&>(def);
121
    OperatorNodeConfig config{pool.make_name()};
M
Megvii Engine Team 已提交
122
    return opr::AdaptivePooling::make(inputs[0], inputs[1], pool.param(), config);
123 124 125
}

OP_TRAIT_REG(AdaptivePooling, AdaptivePooling)
M
Megvii Engine Team 已提交
126 127 128 129
        .apply_on_var_node(apply_on_var_node)
        .fallback();
}  // namespace adaptive_pooling
}  // namespace
130

M
Megvii Engine Team 已提交
131 132 133
namespace {
namespace conv_bias {
auto apply_on_var_node(const OpDef& def, const VarNodeArray& inputs) {
134 135
    auto&& conv = static_cast<const ConvBias&>(def);
    cg::OperatorNodeConfig config{conv.dtype};
136
    config.name(conv.make_name());
137
    if (inputs.size() == 2) {
M
Megvii Engine Team 已提交
138 139
        return opr::ConvBias::make(
                inputs[0], inputs[1], conv.param(), conv.policy(), config);
140
    } else if (inputs.size() == 3) {
M
Megvii Engine Team 已提交
141 142
        return opr::ConvBias::make(
                inputs[0], inputs[1], inputs[2], conv.param(), conv.policy(), config);
143
    } else if (inputs.size() == 4) {
M
Megvii Engine Team 已提交
144 145 146
        return opr::ConvBias::make(
                inputs[0], inputs[1], inputs[2], inputs[3], conv.param(), conv.policy(),
                config);
147 148 149 150
    }
    mgb_assert(0);
}

M
Megvii Engine Team 已提交
151
OP_TRAIT_REG(ConvBias, ConvBias).apply_on_var_node(apply_on_var_node).fallback();
M
Megvii Engine Team 已提交
152 153
}  // namespace conv_bias
}  // namespace
154

M
Megvii Engine Team 已提交
155 156 157
namespace {
namespace batch_conv_bias {
auto apply_on_var_node(const OpDef& def, const VarNodeArray& inputs) {
158 159
    auto&& conv = static_cast<const BatchConvBias&>(def);
    cg::OperatorNodeConfig config{conv.dtype};
160
    config.name(conv.make_name());
161
    if (inputs.size() == 2) {
M
Megvii Engine Team 已提交
162 163
        return opr::BatchConvBias::make(
                inputs[0], inputs[1], conv.param(), conv.policy(), config);
164
    } else if (inputs.size() == 3) {
M
Megvii Engine Team 已提交
165 166
        return opr::BatchConvBias::make(
                inputs[0], inputs[1], inputs[2], conv.param(), conv.policy(), config);
167
    } else if (inputs.size() == 4) {
M
Megvii Engine Team 已提交
168 169 170
        return opr::BatchConvBias::make(
                inputs[0], inputs[1], inputs[2], inputs[3], conv.param(), conv.policy(),
                config);
171 172 173 174 175
    }
    mgb_assert(0);
}

OP_TRAIT_REG(BatchConvBias, BatchConvBias)
M
Megvii Engine Team 已提交
176 177 178 179
        .apply_on_var_node(apply_on_var_node)
        .fallback();
}  // namespace batch_conv_bias
}  // namespace
180

M
Megvii Engine Team 已提交
181 182 183
namespace {
namespace pooling {
auto apply_on_var_node(const OpDef& def, const VarNodeArray& inputs) {
184
    auto&& pool = static_cast<const Pooling&>(def);
185
    OperatorNodeConfig config{pool.make_name()};
186
    return opr::Pooling::make(inputs[0], pool.param(), pool.policy(), config);
187
}
M
Megvii Engine Team 已提交
188 189 190
OP_TRAIT_REG(Pooling, Pooling).apply_on_var_node(apply_on_var_node).fallback();
}  // namespace pooling
}  // namespace
191

M
Megvii Engine Team 已提交
192 193 194
namespace {
namespace matrix_mul {
auto apply_on_var_node(const OpDef& def, const VarNodeArray& inputs) {
195 196
    auto&& matmul = static_cast<const MatrixMul&>(def);
    mgb_assert(inputs.size() == 2);
197
    OperatorNodeConfig config{matmul.make_name()};
M
Megvii Engine Team 已提交
198 199
    return opr::MatrixMul::make(
            inputs[0], inputs[1], matmul.param(), matmul.policy(), config);
200
}
M
Megvii Engine Team 已提交
201
OP_TRAIT_REG(MatrixMul, MatrixMul).apply_on_var_node(apply_on_var_node).fallback();
M
Megvii Engine Team 已提交
202 203
}  // namespace matrix_mul
}  // namespace
204

M
Megvii Engine Team 已提交
205 206 207
namespace {
namespace batched_matrix_mul {
auto apply_on_var_node(const OpDef& def, const VarNodeArray& inputs) {
208 209
    auto&& matmul = static_cast<const BatchedMatrixMul&>(def);
    mgb_assert(inputs.size() == 2);
210
    OperatorNodeConfig config{matmul.make_name()};
M
Megvii Engine Team 已提交
211 212
    return opr::BatchedMatrixMul::make(
            inputs[0], inputs[1], matmul.param(), matmul.policy(), config);
213 214
}
OP_TRAIT_REG(BatchedMatrixMul, BatchedMatrixMul)
M
Megvii Engine Team 已提交
215 216 217 218
        .apply_on_var_node(apply_on_var_node)
        .fallback();
}  // namespace batched_matrix_mul
}  // namespace
219

M
Megvii Engine Team 已提交
220 221 222
namespace {
namespace dot {
auto apply_on_var_node(const OpDef& def, const VarNodeArray& inputs) {
223
    auto&& op = def.cast_final_safe<Dot>();
224
    mgb_assert(inputs.size() == 2);
225 226
    OperatorNodeConfig config{op.make_name()};
    return opr::Dot::make(inputs[0], inputs[1], config);
227
}
M
Megvii Engine Team 已提交
228 229 230
OP_TRAIT_REG(Dot, Dot).apply_on_var_node(apply_on_var_node).fallback();
}  // namespace dot
}  // namespace
231

M
Megvii Engine Team 已提交
232 233 234
namespace {
namespace argsort {
auto apply_on_var_node(const OpDef& def, const VarNodeArray& inputs) {
235
    auto&& argsort = static_cast<const Argsort&>(def);
236 237
    OperatorNodeConfig config{argsort.make_name()};
    return opr::Argsort::make(inputs[0], argsort.param(), config);
238
}
M
Megvii Engine Team 已提交
239 240 241
OP_TRAIT_REG(Argsort, Argsort).apply_on_var_node(apply_on_var_node).fallback();
}  // namespace argsort
}  // namespace
242

M
Megvii Engine Team 已提交
243 244 245
namespace {
namespace argmax {
auto apply_on_var_node(const OpDef& def, const VarNodeArray& inputs) {
246
    auto&& argmax = static_cast<const Argmax&>(def);
247 248
    OperatorNodeConfig config{argmax.make_name()};
    return opr::Argmax::make(inputs[0], argmax.param(), config);
249
}
M
Megvii Engine Team 已提交
250 251 252
OP_TRAIT_REG(Argmax, Argmax).apply_on_var_node(apply_on_var_node).fallback();
}  // namespace argmax
}  // namespace
253

M
Megvii Engine Team 已提交
254 255 256
namespace {
namespace argmin {
auto apply_on_var_node(const OpDef& def, const VarNodeArray& inputs) {
257
    auto&& argmin = static_cast<const Argmin&>(def);
258 259
    OperatorNodeConfig config{argmin.make_name()};
    return opr::Argmin::make(inputs[0], argmin.param(), config);
260
}
M
Megvii Engine Team 已提交
261 262 263
OP_TRAIT_REG(Argmin, Argmin).apply_on_var_node(apply_on_var_node).fallback();
}  // namespace argmin
}  // namespace
264

M
Megvii Engine Team 已提交
265 266 267
namespace {
namespace warp_perspective {
auto apply_on_var_node(const OpDef& def, const VarNodeArray& inputs) {
268
    auto&& warp = static_cast<const WarpPerspective&>(def);
269
    OperatorNodeConfig config{warp.make_name()};
270
    if (inputs.size() == 3) {
M
Megvii Engine Team 已提交
271 272
        return opr::WarpPerspective::make(
                inputs[0], inputs[1], inputs[2], warp.param(), config);
273 274
    } else {
        mgb_assert(inputs.size() == 4);
M
Megvii Engine Team 已提交
275 276
        return opr::WarpPerspective::make(
                inputs[0], inputs[1], inputs[2], inputs[3], warp.param(), config);
277 278 279
    }
}
OP_TRAIT_REG(WarpPerspective, WarpPerspective)
M
Megvii Engine Team 已提交
280 281 282 283
        .apply_on_var_node(apply_on_var_node)
        .fallback();
}  // namespace warp_perspective
}  // namespace
284

M
Megvii Engine Team 已提交
285 286 287
namespace {
namespace group_local {
auto apply_on_var_node(const OpDef& def, const VarNodeArray& inputs) {
288 289
    auto&& local = static_cast<const GroupLocal&>(def);
    mgb_assert(inputs.size() == 2);
290 291
    OperatorNodeConfig config{local.make_name()};
    return opr::GroupLocal::make(inputs[0], inputs[1], local.param(), config);
292
}
M
Megvii Engine Team 已提交
293
OP_TRAIT_REG(GroupLocal, GroupLocal).apply_on_var_node(apply_on_var_node).fallback();
M
Megvii Engine Team 已提交
294 295
}  // namespace group_local
}  // namespace
296

M
Megvii Engine Team 已提交
297 298 299
namespace {
namespace indexing_set_one_hot {
auto apply_on_var_node(const OpDef& def, const VarNodeArray& inputs) {
300 301
    auto&& op = static_cast<const IndexingSetOneHot&>(def);
    mgb_assert(inputs.size() == 3);
302
    OperatorNodeConfig config{op.make_name()};
M
Megvii Engine Team 已提交
303 304
    return opr::IndexingSetOneHot::make(
            inputs[0], inputs[1], inputs[2], op.param(), config);
305 306
}
OP_TRAIT_REG(IndexingSetOneHot, IndexingSetOneHot)
M
Megvii Engine Team 已提交
307 308 309 310
        .apply_on_var_node(apply_on_var_node)
        .fallback();
}  // namespace indexing_set_one_hot
}  // namespace
311

M
Megvii Engine Team 已提交
312 313 314
namespace {
namespace typecvt {
auto apply_on_var_node(const OpDef& def, const VarNodeArray& inputs) {
315 316
    auto&& op = static_cast<const TypeCvt&>(def);
    mgb_assert(inputs.size() == 1);
317 318
    OperatorNodeConfig config{op.make_name()};
    return opr::TypeCvt::make(inputs[0], op.dtype, config);
319
}
M
Megvii Engine Team 已提交
320 321 322
OP_TRAIT_REG(TypeCvt, TypeCvt).apply_on_var_node(apply_on_var_node).fallback();
}  // namespace typecvt
}  // namespace
323

M
Megvii Engine Team 已提交
324 325 326
namespace {
namespace concat {
auto apply_on_var_node(const OpDef& def, const VarNodeArray& inputs) {
327 328
    auto&& op = static_cast<const Concat&>(def);
    cg::OperatorNodeConfig config{op.comp_node};
329
    config.name(op.make_name());
330 331
    return opr::Concat::make(inputs, op.axis, config);
}
M
Megvii Engine Team 已提交
332 333 334
OP_TRAIT_REG(Concat, Concat).apply_on_var_node(apply_on_var_node).fallback();
}  // namespace concat
}  // namespace
335

M
Megvii Engine Team 已提交
336 337 338
namespace {
namespace copy {
auto apply_on_var_node(const OpDef& def, const VarNodeArray& inputs) {
339 340 341
    auto&& op = static_cast<const Copy&>(def);
    mgb_assert(inputs.size() == 1);
    cg::OperatorNodeConfig config{op.comp_node};
342
    config.name(op.make_name());
343 344
    return opr::Copy::make(inputs[0], config);
}
M
Megvii Engine Team 已提交
345 346 347
OP_TRAIT_REG(Copy, Copy).apply_on_var_node(apply_on_var_node).fallback();
}  // namespace copy
}  // namespace
348

M
Megvii Engine Team 已提交
349 350 351
namespace {
namespace assert_equal {
auto apply_on_var_node(const OpDef& def, const VarNodeArray& inputs) {
352 353 354 355 356 357
    auto&& op = def.cast_final<AssertEqual>();
    if (inputs.size() == 2) {
        return opr::AssertEqual::make(inputs[0], inputs[1], op.param());
    } else {
        // workaround for MiniGraph, which only allow one opr in the graph
        mgb_assert(inputs.size() == 3);
M
Megvii Engine Team 已提交
358
        return opr::AssertEqual::make(inputs[0], inputs[1], inputs[2], op.param(), {});
359
    }
360
}
361

M
Megvii Engine Team 已提交
362
OP_TRAIT_REG(AssertEqual, AssertEqual).apply_on_var_node(apply_on_var_node).fallback();
M
Megvii Engine Team 已提交
363 364
}  // namespace assert_equal
}  // namespace
365

M
Megvii Engine Team 已提交
366 367 368
namespace {
namespace roi_align {
VarNodeArray apply_on_var_node(const OpDef& def, const VarNodeArray& inputs) {
369 370
    auto&& op = static_cast<const ROIAlign&>(def);
    mgb_assert(inputs.size() == 2);
371
    OperatorNodeConfig config{op.make_name()};
M
Megvii Engine Team 已提交
372 373 374
    auto* opr = opr::ROIAlign::make(inputs[0], inputs[1], op.param(), config)
                        .node()
                        ->owner_opr();
375
    return {opr->output(0), opr->output(1)};
376
}
M
Megvii Engine Team 已提交
377
OP_TRAIT_REG(ROIAlign, ROIAlign).apply_on_var_node(apply_on_var_node).fallback();
M
Megvii Engine Team 已提交
378 379
}  // namespace roi_align
}  // namespace
380

M
Megvii Engine Team 已提交
381 382 383
namespace {
namespace correlation {
auto apply_on_var_node(const OpDef& def, const VarNodeArray& inputs) {
384 385 386
    auto&& op = static_cast<const Correlation&>(def);
    mgb_assert(inputs.size() == 2);
    OperatorNodeConfig config{op.make_name()};
M
Megvii Engine Team 已提交
387
    return opr::Correlation::make(inputs[0], inputs[1], op.param(), config);
388
}
M
Megvii Engine Team 已提交
389
OP_TRAIT_REG(Correlation, Correlation).apply_on_var_node(apply_on_var_node).fallback();
M
Megvii Engine Team 已提交
390 391
}  // namespace correlation
}  // namespace
392

393
#if MGB_CUDA
M
Megvii Engine Team 已提交
394 395 396
namespace {
namespace nvof {
auto apply_on_var_node(const OpDef& def, const VarNodeArray& inputs) {
397 398
    auto&& op = static_cast<const NvOf&>(def);
    mgb_assert(inputs.size() == 1);
399 400
    OperatorNodeConfig config{op.make_name()};
    return opr::NvOf::make(inputs[0], op.param(), config);
401
}
M
Megvii Engine Team 已提交
402 403 404
OP_TRAIT_REG(NvOf, NvOf).apply_on_var_node(apply_on_var_node).fallback();
}  // namespace nvof
}  // namespace
405 406
#endif

M
Megvii Engine Team 已提交
407 408 409
namespace {
namespace linspace {
auto apply_on_var_node(const OpDef& def, const VarNodeArray& inputs) {
410 411 412
    auto&& op = static_cast<const Linspace&>(def);
    mgb_assert(inputs.size() == 3);
    cg::OperatorNodeConfig config{op.comp_node};
413
    config.name(op.make_name());
M
Megvii Engine Team 已提交
414
    return opr::Linspace::make(inputs[0], inputs[1], inputs[2], op.param(), config);
415
}
M
Megvii Engine Team 已提交
416
OP_TRAIT_REG(Linspace, Linspace).apply_on_var_node(apply_on_var_node).fallback();
M
Megvii Engine Team 已提交
417 418
}  // namespace linspace
}  // namespace
419

M
Megvii Engine Team 已提交
420 421 422
namespace {
namespace eye {
auto apply_on_var_node(const OpDef& def, const VarNodeArray& inputs) {
423 424 425
    auto&& op = static_cast<const Eye&>(def);
    mgb_assert(inputs.size() == 1);
    cg::OperatorNodeConfig config{op.comp_node};
426
    config.name(op.make_name());
427 428 429
    opr::Eye::Param param{op.k, op.dtype.enumv()};
    return opr::Eye::make(inputs[0], param, config);
}
M
Megvii Engine Team 已提交
430 431 432
OP_TRAIT_REG(Eye, Eye).apply_on_var_node(apply_on_var_node).fallback();
}  // namespace eye
}  // namespace
433

M
Megvii Engine Team 已提交
434 435 436
namespace {
namespace roi_pooling {
VarNodeArray apply_on_var_node(const OpDef& def, const VarNodeArray& inputs) {
437 438
    auto&& op = static_cast<const ROIPooling&>(def);
    mgb_assert(inputs.size() == 3);
439
    OperatorNodeConfig config{op.make_name()};
M
Megvii Engine Team 已提交
440 441 442 443
    auto* opr =
            opr::ROIPooling::make(inputs[0], inputs[1], inputs[2], op.param(), config)
                    .node()
                    ->owner_opr();
444
    return {opr->output(0), opr->output(1)};
445
}
M
Megvii Engine Team 已提交
446
OP_TRAIT_REG(ROIPooling, ROIPooling).apply_on_var_node(apply_on_var_node).fallback();
M
Megvii Engine Team 已提交
447 448
}  // namespace roi_pooling
}  // namespace
449

M
Megvii Engine Team 已提交
450 451 452
namespace {
namespace remap {
auto apply_on_var_node(const OpDef& def, const VarNodeArray& inputs) {
453 454
    auto&& op = static_cast<const Remap&>(def);
    mgb_assert(inputs.size() == 2);
455 456
    OperatorNodeConfig config{op.make_name()};
    return opr::Remap::make(inputs[0], inputs[1], op.param(), config);
457
}
M
Megvii Engine Team 已提交
458 459 460
OP_TRAIT_REG(Remap, Remap).apply_on_var_node(apply_on_var_node).fallback();
}  // namespace remap
}  // namespace
461 462 463

namespace {
auto get_index(
M
Megvii Engine Team 已提交
464 465
        const VarNodeArray& inputs, size_t vidx,
        const std::vector<std::tuple<int8_t, bool, bool, bool, bool>>& mask) {
466 467
    size_t length = mask.size();
    opr::Subtensor::IndexDesc ret(length);
M
Megvii Engine Team 已提交
468
    for (size_t i = 0; i < length; ++i) {
469 470 471 472 473 474
        auto&& [axis, begin, end, step, idx] = mask[i];
        ret[i].axis = axis;
        if (idx) {
            ret[i].idx = inputs[vidx++];
        } else {
            mgb_assert(begin || end || step);
M
Megvii Engine Team 已提交
475 476 477 478 479 480
            if (begin)
                ret[i].begin = inputs[vidx++];
            if (end)
                ret[i].end = inputs[vidx++];
            if (step)
                ret[i].step = inputs[vidx++];
481 482 483 484 485 486 487 488
        }
    }
    mgb_assert(vidx == inputs.size());
    return ret;
}
#define IN1 inputs[0]
#define IN2 inputs[0], inputs[1]

M
Megvii Engine Team 已提交
489 490 491 492 493 494 495 496 497
#define FANCY_INDEXING_IMPL(NAME, NR_INPUT)                                       \
    namespace NAME##_impl {                                                       \
        auto apply_on_var_node(const OpDef& def, const VarNodeArray& inputs) {    \
            auto&& op = static_cast<const NAME&>(def);                            \
            OperatorNodeConfig config{op.make_name()};                            \
            return opr::NAME::make(                                               \
                    IN##NR_INPUT, get_index(inputs, NR_INPUT, op.items), config); \
        }                                                                         \
        OP_TRAIT_REG(NAME, NAME).apply_on_var_node(apply_on_var_node).fallback(); \
M
Megvii Engine Team 已提交
498
    }
499 500 501 502 503 504 505 506 507 508 509 510 511 512 513 514 515

FANCY_INDEXING_IMPL(Subtensor, 1)
FANCY_INDEXING_IMPL(SetSubtensor, 2)
FANCY_INDEXING_IMPL(IncrSubtensor, 2)
FANCY_INDEXING_IMPL(IndexingMultiAxisVec, 1)
FANCY_INDEXING_IMPL(IndexingSetMultiAxisVec, 2)
FANCY_INDEXING_IMPL(IndexingIncrMultiAxisVec, 2)
FANCY_INDEXING_IMPL(MeshIndexing, 1)
FANCY_INDEXING_IMPL(IncrMeshIndexing, 2)
FANCY_INDEXING_IMPL(SetMeshIndexing, 2)
FANCY_INDEXING_IMPL(BatchedMeshIndexing, 1)
FANCY_INDEXING_IMPL(BatchedIncrMeshIndexing, 2)
FANCY_INDEXING_IMPL(BatchedSetMeshIndexing, 2)

#undef FANCY_INDEXING_IMPL
#undef IN1
#undef IN2
M
Megvii Engine Team 已提交
516
}  // anonymous namespace
517

M
Megvii Engine Team 已提交
518 519 520
namespace {
namespace fake_quant {
auto apply_on_var_node(const OpDef& def, const VarNodeArray& inputs) {
521 522
    auto&& op = static_cast<const FakeQuant&>(def);
    mgb_assert(inputs.size() == 3);
523
    OperatorNodeConfig config{op.make_name()};
M
Megvii Engine Team 已提交
524
    return opr::FakeQuant::make(inputs[0], inputs[1], inputs[2], op.param(), config);
525
}
M
Megvii Engine Team 已提交
526
OP_TRAIT_REG(FakeQuant, FakeQuant).apply_on_var_node(apply_on_var_node).fallback();
M
Megvii Engine Team 已提交
527 528
}  // namespace fake_quant
}  // namespace
529

M
Megvii Engine Team 已提交
530 531 532
namespace {
namespace tqt {
auto apply_on_var_node(const OpDef& def, const VarNodeArray& inputs) {
M
Megvii Engine Team 已提交
533 534
    auto&& op = static_cast<const TQT&>(def);
    mgb_assert(inputs.size() == 2);
535 536
    OperatorNodeConfig config{op.make_name()};
    return opr::TQT::make(inputs[0], inputs[1], op.param(), config);
M
Megvii Engine Team 已提交
537
}
M
Megvii Engine Team 已提交
538 539 540
OP_TRAIT_REG(TQT, TQT).apply_on_var_node(apply_on_var_node).fallback();
}  // namespace tqt
}  // namespace
541

M
Megvii Engine Team 已提交
542 543 544
namespace {
namespace elemwise_multi_type {
auto apply_on_var_node(const OpDef& def, const VarNodeArray& inputs) {
545 546
    auto&& op = static_cast<const ElemwiseMultiType&>(def);
    OperatorNodeConfig config{op.dtype};
547
    config.name(op.make_name());
548 549 550
    return opr::ElemwiseMultiType::make(inputs, op.param(), config);
}
OP_TRAIT_REG(ElemwiseMultiType, ElemwiseMultiType)
M
Megvii Engine Team 已提交
551 552 553 554
        .apply_on_var_node(apply_on_var_node)
        .fallback();
}  // namespace elemwise_multi_type
}  // namespace
555

M
Megvii Engine Team 已提交
556 557 558
namespace {
namespace svd {
auto apply_on_var_node(const OpDef& def, const VarNodeArray& inputs) {
559 560
    auto&& op = static_cast<const SVD&>(def);
    mgb_assert(inputs.size() == 1);
561 562
    OperatorNodeConfig config{op.make_name()};
    return opr::SVD::make(inputs[0], op.param(), config)[0]
M
Megvii Engine Team 已提交
563 564 565
            .node()
            ->owner_opr()
            ->usable_output();
566
}
M
Megvii Engine Team 已提交
567 568 569
OP_TRAIT_REG(SVD, SVD).apply_on_var_node(apply_on_var_node).fallback();
}  // namespace svd
}  // namespace
570

M
Megvii Engine Team 已提交
571 572 573
namespace {
namespace images2neibs {
auto apply_on_var_node(const OpDef& def, const VarNodeArray& inputs) {
574 575 576 577 578
    auto&& op = static_cast<const Images2Neibs&>(def);
    OperatorNodeConfig config{op.make_name()};
    return opr::Images2Neibs::make(inputs[0], op.param(), config);
}
OP_TRAIT_REG(Images2Neibs, Images2Neibs)
M
Megvii Engine Team 已提交
579 580 581 582 583 584 585 586 587 588 589
        .apply_on_var_node(apply_on_var_node)
        .fallback();
}  // namespace images2neibs
}  // namespace

namespace {
namespace lsq {
auto apply_on_var_node(const OpDef& def, const VarNodeArray& inputs) {
    auto&& op = static_cast<const LSQ&>(def);
    mgb_assert(inputs.size() == 4);
    OperatorNodeConfig config{op.make_name()};
M
Megvii Engine Team 已提交
590 591
    return opr::LSQ::make(
            inputs[0], inputs[1], inputs[2], inputs[3], op.param(), config);
M
Megvii Engine Team 已提交
592 593 594 595
}
OP_TRAIT_REG(LSQ, LSQ).apply_on_var_node(apply_on_var_node).fallback();
}  // namespace lsq
}  // namespace
596

M
Megvii Engine Team 已提交
597 598 599
namespace {
namespace sliding_window_transpose {
auto apply_on_var_node(const OpDef& def, const VarNodeArray& inputs) {
600 601 602 603 604
    auto&& op = static_cast<const SlidingWindowTranspose&>(def);
    OperatorNodeConfig config{op.make_name()};
    return opr::SlidingWindowTranspose::make(inputs[0], op.param(), config);
}
OP_TRAIT_REG(SlidingWindowTranspose, SlidingWindowTranspose)
M
Megvii Engine Team 已提交
605 606 607 608
        .apply_on_var_node(apply_on_var_node)
        .fallback();
}  // namespace sliding_window_transpose
}  // namespace
609

M
Megvii Engine Team 已提交
610 611 612 613 614 615 616 617 618 619 620 621
namespace {
namespace cumsum {
auto apply_on_var_node(const OpDef& def, const VarNodeArray& inputs) {
    auto&& op = static_cast<const Cumsum&>(def);
    OperatorNodeConfig config{op.make_name()};
    return opr::Cumsum::make(inputs[0], op.param(), config);
}

OP_TRAIT_REG(Cumsum, Cumsum).apply_on_var_node(apply_on_var_node).fallback();
}  // namespace cumsum
}  // namespace

622 623 624 625 626 627 628
namespace padding {
auto apply_on_var_node(const OpDef& def, const VarNodeArray& inputs) {
    auto&& op = static_cast<const Padding&>(def);
    mgb_assert(inputs.size() == 1);
    return opr::Padding::make(inputs[0], op.param());
}
OP_TRAIT_REG(Padding, Padding).apply_on_var_node(apply_on_var_node).fallback();
M
Megvii Engine Team 已提交
629
}  // namespace padding
630 631 632 633 634 635 636 637

namespace lrn {
auto apply_on_var_node(const OpDef& def, const VarNodeArray& inputs) {
    auto&& op = static_cast<const LRN&>(def);
    mgb_assert(inputs.size() == 1);
    return opr::LRN::make(inputs[0], op.param());
}
OP_TRAIT_REG(LRN, LRN).apply_on_var_node(apply_on_var_node).fallback();
M
Megvii Engine Team 已提交
638 639
}  // namespace lrn
}  // namespace mgb::imperative