feat: knet-dtoe support sleep wake switch interface-knet-AtomGit

已合并

feat: knet-dtoe support sleep wake switch interface #173

xhpintell创建于 6月3日从xhpintell/knet： dtoe 合入到 openeuler/knet： dtoe

feat: knet-dtoe support sleep wake switch interface #173

已合并

xhpintell创建于 6月3日

从xhpintell/knet dtoe合入到openeuler/knet dtoe

共 2 个文件变更+18-3

Msrc/knet/api/dtoe_api/include/knet_dtoe_api.h+5-0

	@@ -45,6 +45,7 @@ struct knet_mr {
45	enum knet_schd_type {	45	enum knet_schd_type {
46	KNET_EPOLL_SCHD = 0,	46	KNET_EPOLL_SCHD = 0,
47	KNET_POLL_SCHD,	47	KNET_POLL_SCHD,
		48	+ KNET_SWITCHABLE_SCHD,
48	KNET_SCHD_MOD_BUTT	49	KNET_SCHD_MOD_BUTT
49	};	50	};
50		51
	@@ -272,4 +273,8 @@ int32_t knet_recv_leaked_packet(int sockfd, void *buffer, int32_t recv_len);
272	*/	273	*/
273	void knet_log(const char function, int line, int level, const char format, ...);	274	void knet_log(const char function, int line, int level, const char format, ...);
274		275
		276	+int32_t knet_flexda_dtoe_channel_epoll_set(struct knet_send_channel send_channel, struct knet_recv_channel recv_channel, uint32_t epoll_enable);
		277	+
		278	+int32_t knet_flexda_dtoe_channel_qpc_create(struct knet_send_channel send_channel, struct knet_recv_channel recv_channel);
		279	+
275	#endif	280	#endif

Msrc/knet/api/dtoe_api/src/dtoe_api.c+13-3

	@@ -173,11 +173,11 @@ offloadFailed:
173	int knet_thrd_cpu_set(struct knet_thrd_cpu_cfg *cfg)	173	int knet_thrd_cpu_set(struct knet_thrd_cpu_cfg *cfg)
174	{	174	{
175	flexda_dtoe_thrd_cpu_cfg_s dtoeCfg = {0};	175	flexda_dtoe_thrd_cpu_cfg_s dtoeCfg = {0};
176	- dtoeCfg.enable = cfg->enable;	176	+ dtoeCfg.cpu_affinity_en = cfg->enable;
177	dtoeCfg.cpu_mask_affinity = cfg->cpu_mask_affinity;	177	dtoeCfg.cpu_mask_affinity = cfg->cpu_mask_affinity;
178	int ret = flexda_dtoe_thrd_cpu_set(&dtoeCfg);	178	int ret = flexda_dtoe_thrd_cpu_set(&dtoeCfg);
179	if (ret != 0) {	179	if (ret != 0) {
180	- KNET_ERR("Dtoe thrd cpu set failed, ret %d, enable %u", ret, dtoeCfg.enable);	180	+ KNET_ERR("Dtoe thrd cpu set failed, ret %d, enable %u", ret, dtoeCfg.cpu_affinity_en);
181	return ret;	181	return ret;
182	}	182	}
183		183
	@@ -379,7 +379,7 @@ int knet_start_chimney_general(int sockfd, struct knet_offload_in *in)
379		379
380	flexda_dtoe_offload_in_s input = {0};	380	flexda_dtoe_offload_in_s input = {0};
381	input.user_data = (void *)KNET_GetFdConnUserData(sockfd);	381	input.user_data = (void *)KNET_GetFdConnUserData(sockfd);
382	- input.rev_channel = (flexda_recv_channel_s *)in->recv_channel;	382	+ input.recv_channel = (flexda_recv_channel_s *)in->recv_channel;
383	input.send_channel = (flexda_send_channel_s *)in->send_channel;	383	input.send_channel = (flexda_send_channel_s *)in->send_channel;
384		384
385	flexda_dtoe_offload_out_s out = {0};	385	flexda_dtoe_offload_out_s out = {0};
	@@ -747,4 +747,14 @@ int32_t knet_recv_leaked_packet(int sockfd, void *buffer, int32_t recv_len)
747	void knet_log(const char function, int line, int level, const char format, ...)	747	void knet_log(const char function, int line, int level, const char format, ...)
748	{	748	{
749	KNET_Log(function, line, level, format);	749	KNET_Log(function, line, level, format);
		750	+}
		751	+
		752	+int32_t knet_flexda_dtoe_channel_epoll_set(struct knet_send_channel send_channel, struct knet_recv_channel recv_channel, uint32_t epoll_enable)
		753	+{
		754	+ return flexda_dtoe_channel_epoll_set(g_dtoeRes.dev.devSn, (flexda_send_channel_s)send_channel, (flexda_recv_channel_s)recv_channel, epoll_enable);
		755	+}
		756	+
		757	+int32_t knet_flexda_dtoe_channel_qpc_create(struct knet_send_channel send_channel, struct knet_recv_channel recv_channel)
		758	+{
		759	+ return flexda_dtoe_channel_qpc_create(g_dtoeRes.dev.devSn, (flexda_send_channel_s)send_channel, (flexda_recv_channel_s)recv_channel);
750	}	760	}