Nigel
/
mindspore
forked from mindspore-Ecosystem/mindspore
1
0
Fork 0
Code Issues Pull Requests Projects Releases Wiki Activity

Correct rpc recv abs.

This commit is contained in:
ZPaC 2023-03-07 21:10:33 +08:00
parent f6fa8a0da5
commit 81895a3f14
1 changed files with 11 additions and 3 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

14
mindspore/core/ops/rpc_recv.cc
View File

@ -20,6 +20,7 @@
#include "abstract/ops/primitive_infer_map.h"
#include "ir/anf.h"
#include "ops/core_ops.h"
#include "ops/op_name.h"
#include "ops/primitive_c.h"
#include "utils/log_adapter.h"
#include "mindapi/src/helper.h"
@ -29,9 +30,16 @@ namespace ops {
MIND_API_OPERATOR_IMPL(RpcRecv, BaseOperator);
AbstractBasePtr RpcRecvInfer(const abstract::AnalysisEnginePtr &, const PrimitivePtr &,
const std::vector<AbstractBasePtr> &input_args) {
abstract::AbstractTuplePtr rpc_send_abs = std::make_shared<abstract::AbstractTuple>(input_args);
MS_EXCEPTION_IF_NULL(rpc_send_abs);
return rpc_send_abs;
if (input_args.empty()) {
MS_LOG(EXCEPTION) << "The input size of RpcRecv is 0.";
}
if (input_args.size() == static_cast<size_t>(kDim1)) {
return input_args[kInputIndex0];
} else {
abstract::AbstractTuplePtr rpc_recv_abs = std::make_shared<abstract::AbstractTuple>(input_args);
MS_EXCEPTION_IF_NULL(rpc_recv_abs);
return rpc_recv_abs;
}
}
REGISTER_PRIMITIVE_EVAL_IMPL(RpcRecv, prim::kPrimRpcRecv, RpcRecvInfer, nullptr, true);
} // namespace ops