nfp/flower/cmsg.c

22 nfp_flower_cmsg_alloc(struct nfp_app *app, unsigned int size,
30 	skb = nfp_app_ctrl_msg_alloc(app, size, flag);
44 nfp_flower_cmsg_mac_repr_start(struct nfp_app *app, unsigned int num_ports)
49 	skb = nfp_flower_cmsg_alloc(app, struct_size(msg, ports, num_ports),
81 	skb = nfp_flower_cmsg_alloc(repr->app, sizeof(*msg),
96 	nfp_ctrl_tx(repr->app->ctrl, skb);
106 	skb = nfp_flower_cmsg_alloc(repr->app, sizeof(*msg),
117 	nfp_ctrl_tx(repr->app->ctrl, skb);
123 nfp_flower_process_mtu_ack(struct nfp_app *app, struct sk_buff *skb)
125 	struct nfp_flower_priv *app_priv = app->priv;
151 nfp_flower_cmsg_portmod_rx(struct nfp_app *app, struct sk_buff *skb)
162 	netdev = nfp_app_dev_get(app, be32_to_cpu(msg->portnum), NULL);
165 		nfp_flower_cmsg_warn(app, "ctrl msg for unknown port 0x%08x\n",
186 nfp_flower_cmsg_portreify_rx(struct nfp_app *app, struct sk_buff *skb)
188 	struct nfp_flower_priv *priv = app->priv;
195 	exists = !!nfp_app_dev_get(app, be32_to_cpu(msg->portnum), NULL);
198 		nfp_flower_cmsg_warn(app, "ctrl msg for unknown port 0x%08x\n",
208 nfp_flower_cmsg_merge_hint_rx(struct nfp_app *app, struct sk_buff *skb)
221 		nfp_flower_cmsg_warn(app, "Merge hint ctrl msg too short - %d bytes but expect %zd\n",
227 		nfp_flower_cmsg_warn(app, "Merge hint contains %d flows - two are expected\n",
232 	priv = app->priv;
237 		sub_flows[i] = nfp_flower_get_fl_payload_from_ctx(app, ctx);
239 			nfp_flower_cmsg_warn(app, "Invalid flow in merge hint\n");
244 	err = nfp_flower_merge_offloaded_flows(app, sub_flows[0], sub_flows[1]);
247 		nfp_flower_cmsg_warn(app, "Flow merge memory fail.\n");
254 nfp_flower_cmsg_process_one_rx(struct nfp_app *app, struct sk_buff *skb)
256 	struct nfp_flower_priv *app_priv = app->priv;
266 		nfp_flower_cmsg_portmod_rx(app, skb);
270 			nfp_flower_cmsg_merge_hint_rx(app, skb);
275 		nfp_tunnel_request_route_v4(app, skb);
278 		nfp_tunnel_request_route_v6(app, skb);
281 		nfp_tunnel_keep_alive(app, skb);
284 		nfp_tunnel_keep_alive_v6(app, skb);
287 		nfp_flower_stats_rlim_reply(app, skb);
291 			skb_stored = nfp_flower_lag_unprocessed_msg(app, skb);
297 		nfp_flower_cmsg_warn(app, "Cannot handle invalid repr control type %u\n",
327 		nfp_flower_cmsg_process_one_rx(priv->app, skb);
331 nfp_flower_queue_ctl_msg(struct nfp_app *app, struct sk_buff *skb, int type)
333 	struct nfp_flower_priv *priv = app->priv;
342 		nfp_flower_cmsg_warn(app, "Dropping queued control messages\n");
351 void nfp_flower_cmsg_rx(struct nfp_app *app, struct sk_buff *skb)
358 		nfp_flower_cmsg_warn(app, "Cannot handle repr control version %u\n",
366 		nfp_flower_rx_flow_stats(app, skb);
369 		   nfp_flower_process_mtu_ack(app, skb)) {
378 		nfp_flower_cmsg_portreify_rx(app, skb);
381 		nfp_flower_queue_ctl_msg(app, skb, cmsg_hdr->type);