RegProcFunc

Product	Supported
Atlas A3 training product/Atlas A3 inference product	√
Atlas A2 training product/Atlas A2 inference product	√
Atlas 200I/500 A2 inference product	x
Atlas inference product	x
Atlas training product	x

Registers the multi-flow func processing function and registers the flow func based on MetaMultiFunc Registration Function Macro.

This function is used when a common FlowFunc is registered, that is, when the input of the FlowFunc is flowMsg.
1
FlowFuncRegistrar &RegProcFunc(const char *flowFuncName, const CUSTOM_PROC_FUNC &func)
This function is used when a streaming input FlowFunc (the function's input parameter is a queue) is registered, that is, when the input of the FlowFunc is flowMsgQueue.
1
FlowFuncRegistrar &RegProcFunc(const char *flowFuncName, const CUSTOM_PROC_FUNC_WITH_Q &func)

Parameter	Input/Output	Description
flowFuncName	Input	Name of Flowfunc. The value cannot be NULL and must end with \0.
func	Input	Processing function of multiple FlowFunc. The prototype of the processing function is as follows: using CUSTOM_PROC_FUNC = std::function<int32_t( *T , const std::shared_ptr<MetaRunContext> &, const std::vector<std::shared_ptr<FlowMsg>> &)>; or using CUSTOM_PROC_FUNC_WITH_Q = std::function<int32_t( T , const std::shared_ptr<MetaRunContext> &, const std::vector<std::shared_ptr<FlowMsgQueue>> &)>;*

Parameter

Input/Output

Description

flowFuncName

Input

Name of Flowfunc. The value cannot be NULL and must end with \0.

func

Input

Processing function of multiple FlowFunc. The prototype of the processing function is as follows:

using CUSTOM_PROC_FUNC = std::function<int32_t(

T *, const std::shared_ptr<MetaRunContext> &, const std::vector<std::shared_ptr<FlowMsg>> &)>;

using CUSTOM_PROC_FUNC_WITH_Q = std::function<int32_t(

T *, const std::shared_ptr<MetaRunContext> &, const std::vector<std::shared_ptr<FlowMsgQueue>> &)>;

A FlowFuncRegistrar object.

None

None

Parent topic: Class FlowFuncRegistrar