xref: /wlan-dirver/qca-wifi-host-cmn/dp/wifi3.0/dp_tx_flow_control.c (revision 11f5a63a6cbdda84849a730de22f0a71e635d58c)
1 /*
2  * Copyright (c) 2015-2019 The Linux Foundation. All rights reserved.
3  *
4  * Permission to use, copy, modify, and/or distribute this software for
5  * any purpose with or without fee is hereby granted, provided that the
6  * above copyright notice and this permission notice appear in all
7  * copies.
8  *
9  * THE SOFTWARE IS PROVIDED "AS IS" AND THE AUTHOR DISCLAIMS ALL
10  * WARRANTIES WITH REGARD TO THIS SOFTWARE INCLUDING ALL IMPLIED
11  * WARRANTIES OF MERCHANTABILITY AND FITNESS. IN NO EVENT SHALL THE
12  * AUTHOR BE LIABLE FOR ANY SPECIAL, DIRECT, INDIRECT, OR CONSEQUENTIAL
13  * DAMAGES OR ANY DAMAGES WHATSOEVER RESULTING FROM LOSS OF USE, DATA OR
14  * PROFITS, WHETHER IN AN ACTION OF CONTRACT, NEGLIGENCE OR OTHER
15  * TORTIOUS ACTION, ARISING OUT OF OR IN CONNECTION WITH THE USE OR
16  * PERFORMANCE OF THIS SOFTWARE.
17  */
18 
19 #include <cds_api.h>
20 
21 /* OS abstraction libraries */
22 #include <qdf_nbuf.h>           /* qdf_nbuf_t, etc. */
23 #include <qdf_atomic.h>         /* qdf_atomic_read, etc. */
24 #include <qdf_util.h>           /* qdf_unlikely */
25 #include "dp_types.h"
26 #include "dp_tx_desc.h"
27 
28 #include <cdp_txrx_handle.h>
29 #include "dp_internal.h"
30 #define INVALID_FLOW_ID 0xFF
31 #define MAX_INVALID_BIN 3
32 
33 #ifdef QCA_AC_BASED_FLOW_CONTROL
34 /**
35  * dp_tx_initialize_threshold() - Threshold of flow Pool initialization
36  * @pool: flow_pool
37  * @stop_threshold: stop threshold of certian AC
38  * @start_threshold: start threshold of certian AC
39  * @flow_pool_size: flow pool size
40  *
41  * Return: none
42  */
43 static inline void
44 dp_tx_initialize_threshold(struct dp_tx_desc_pool_s *pool,
45 			   uint32_t start_threshold,
46 			   uint32_t stop_threshold,
47 			   uint16_t flow_pool_size)
48 {
49 	/* BE_BK threshold is same as previous threahold */
50 	pool->start_th[DP_TH_BE_BK] = (start_threshold
51 					* flow_pool_size) / 100;
52 	pool->stop_th[DP_TH_BE_BK] = (stop_threshold
53 					* flow_pool_size) / 100;
54 
55 	/* Update VI threshold based on BE_BK threashold */
56 	pool->start_th[DP_TH_VI] = (pool->start_th[DP_TH_BE_BK]
57 					* FL_TH_VI_PERCENTAGE) / 100;
58 	pool->stop_th[DP_TH_VI] = (pool->stop_th[DP_TH_BE_BK]
59 					* FL_TH_VI_PERCENTAGE) / 100;
60 
61 	/* Update VO threshold based on BE_BK threashold */
62 	pool->start_th[DP_TH_VO] = (pool->start_th[DP_TH_BE_BK]
63 					* FL_TH_VO_PERCENTAGE) / 100;
64 	pool->stop_th[DP_TH_VO] = (pool->stop_th[DP_TH_BE_BK]
65 					* FL_TH_VO_PERCENTAGE) / 100;
66 
67 	/* Update High Priority threshold based on BE_BK threashold */
68 	pool->start_th[DP_TH_HI] = (pool->start_th[DP_TH_BE_BK]
69 					* FL_TH_HI_PERCENTAGE) / 100;
70 	pool->stop_th[DP_TH_HI] = (pool->stop_th[DP_TH_BE_BK]
71 					* FL_TH_HI_PERCENTAGE) / 100;
72 
73 	QDF_TRACE(QDF_MODULE_ID_DP, QDF_TRACE_LEVEL_ERROR,
74 		  "%s: tx flow control threshold is set, pool size is %d",
75 		  __func__, flow_pool_size);
76 }
77 
78 /**
79  * dp_tx_flow_pool_reattach() - Reattach flow_pool
80  * @pool: flow_pool
81  *
82  * Return: none
83  */
84 static inline void
85 dp_tx_flow_pool_reattach(struct dp_tx_desc_pool_s *pool)
86 {
87 	QDF_TRACE(QDF_MODULE_ID_DP, QDF_TRACE_LEVEL_ERROR,
88 		  "%s: flow pool already allocated, attached %d times",
89 		  __func__, pool->pool_create_cnt);
90 
91 	if (pool->avail_desc > pool->start_th[DP_TH_BE_BK])
92 		pool->status = FLOW_POOL_ACTIVE_UNPAUSED;
93 	if (pool->avail_desc <= pool->start_th[DP_TH_BE_BK] &&
94 	    pool->avail_desc > pool->start_th[DP_TH_VI])
95 		pool->status = FLOW_POOL_BE_BK_PAUSED;
96 	else if (pool->avail_desc <= pool->start_th[DP_TH_VI] &&
97 		 pool->avail_desc > pool->start_th[DP_TH_VO])
98 		pool->status = FLOW_POOL_VI_PAUSED;
99 	else if (pool->avail_desc <= pool->start_th[DP_TH_VO] &&
100 		 pool->avail_desc > pool->start_th[DP_TH_HI])
101 		pool->status = FLOW_POOL_VO_PAUSED;
102 	else
103 		pool->status = FLOW_POOL_ACTIVE_PAUSED;
104 
105 	pool->pool_create_cnt++;
106 }
107 
108 /**
109  * dp_tx_flow_pool_dump_threshold() - Dump threshold of the flow_pool
110  * @pool: flow_pool
111  *
112  * Return: none
113  */
114 static inline void
115 dp_tx_flow_pool_dump_threshold(struct dp_tx_desc_pool_s *pool)
116 {
117 	int i;
118 
119 	for (i = 0; i < FL_TH_MAX; i++) {
120 		QDF_TRACE(QDF_MODULE_ID_DP, QDF_TRACE_LEVEL_ERROR,
121 			  "Level %d :: Start threshold %d :: Stop threshold %d",
122 			  i, pool->start_th[i], pool->stop_th[i]);
123 		QDF_TRACE(QDF_MODULE_ID_DP, QDF_TRACE_LEVEL_ERROR,
124 			  "Level %d :: Maximun pause time %lu ms",
125 			  i, pool->max_pause_time[i]);
126 		QDF_TRACE(QDF_MODULE_ID_DP, QDF_TRACE_LEVEL_ERROR,
127 			  "Level %d :: Latest pause timestamp %lu",
128 			  i, pool->latest_pause_time[i]);
129 	}
130 }
131 
132 #else
133 static inline void
134 dp_tx_initialize_threshold(struct dp_tx_desc_pool_s *pool,
135 			   uint32_t start_threshold,
136 			   uint32_t stop_threshold,
137 			   uint16_t flow_pool_size)
138 
139 {
140 	/* INI is in percentage so divide by 100 */
141 	pool->start_th = (start_threshold * flow_pool_size) / 100;
142 	pool->stop_th = (stop_threshold * flow_pool_size) / 100;
143 }
144 
145 static inline void
146 dp_tx_flow_pool_reattach(struct dp_tx_desc_pool_s *pool)
147 {
148 	QDF_TRACE(QDF_MODULE_ID_DP, QDF_TRACE_LEVEL_ERROR,
149 		  "%s: flow pool already allocated, attached %d times",
150 		  __func__, pool->pool_create_cnt);
151 	if (pool->avail_desc > pool->start_th)
152 		pool->status = FLOW_POOL_ACTIVE_UNPAUSED;
153 	else
154 		pool->status = FLOW_POOL_ACTIVE_PAUSED;
155 
156 	pool->pool_create_cnt++;
157 }
158 
159 static inline void
160 dp_tx_flow_pool_dump_threshold(struct dp_tx_desc_pool_s *pool)
161 {
162 	QDF_TRACE(QDF_MODULE_ID_DP, QDF_TRACE_LEVEL_ERROR,
163 		  "Start threshold %d :: Stop threshold %d",
164 	pool->start_th, pool->stop_th);
165 }
166 
167 #endif
168 
169 /**
170  * dp_tx_dump_flow_pool_info() - dump global_pool and flow_pool info
171  *
172  * @ctx: Handle to struct dp_soc.
173  *
174  * Return: none
175  */
176 void dp_tx_dump_flow_pool_info(void *ctx)
177 {
178 	struct dp_soc *soc = ctx;
179 	struct dp_txrx_pool_stats *pool_stats = &soc->pool_stats;
180 	struct dp_tx_desc_pool_s *pool = NULL;
181 	struct dp_tx_desc_pool_s tmp_pool;
182 	int i;
183 
184 	QDF_TRACE(QDF_MODULE_ID_DP, QDF_TRACE_LEVEL_ERROR,
185 		"No of pool map received %d", pool_stats->pool_map_count);
186 	QDF_TRACE(QDF_MODULE_ID_DP, QDF_TRACE_LEVEL_ERROR,
187 		"No of pool unmap received %d",	pool_stats->pool_unmap_count);
188 	QDF_TRACE(QDF_MODULE_ID_DP, QDF_TRACE_LEVEL_ERROR,
189 		"Pkt dropped due to unavailablity of pool %d",
190 		pool_stats->pkt_drop_no_pool);
191 
192 	/*
193 	 * Nested spin lock.
194 	 * Always take in below order.
195 	 * flow_pool_array_lock -> flow_pool_lock
196 	 */
197 	qdf_spin_lock_bh(&soc->flow_pool_array_lock);
198 	for (i = 0; i < MAX_TXDESC_POOLS; i++) {
199 		pool = &soc->tx_desc[i];
200 		if (pool->status > FLOW_POOL_INVALID)
201 			continue;
202 		qdf_spin_lock_bh(&pool->flow_pool_lock);
203 		qdf_mem_copy(&tmp_pool, pool, sizeof(tmp_pool));
204 		qdf_spin_unlock_bh(&pool->flow_pool_lock);
205 		qdf_spin_unlock_bh(&soc->flow_pool_array_lock);
206 		QDF_TRACE(QDF_MODULE_ID_DP, QDF_TRACE_LEVEL_ERROR, "\n");
207 		QDF_TRACE(QDF_MODULE_ID_DP, QDF_TRACE_LEVEL_ERROR,
208 			"Flow_pool_id %d :: status %d",
209 			tmp_pool.flow_pool_id, tmp_pool.status);
210 		QDF_TRACE(QDF_MODULE_ID_DP, QDF_TRACE_LEVEL_ERROR,
211 			"Total %d :: Available %d",
212 			tmp_pool.pool_size, tmp_pool.avail_desc);
213 		dp_tx_flow_pool_dump_threshold(&tmp_pool);
214 		QDF_TRACE(QDF_MODULE_ID_DP, QDF_TRACE_LEVEL_ERROR,
215 			"Member flow_id  %d :: flow_type %d",
216 			tmp_pool.flow_pool_id, tmp_pool.flow_type);
217 		QDF_TRACE(QDF_MODULE_ID_DP, QDF_TRACE_LEVEL_ERROR,
218 			"Pkt dropped due to unavailablity of descriptors %d",
219 			tmp_pool.pkt_drop_no_desc);
220 		qdf_spin_lock_bh(&soc->flow_pool_array_lock);
221 	}
222 	qdf_spin_unlock_bh(&soc->flow_pool_array_lock);
223 }
224 
225 /**
226  * dp_tx_clear_flow_pool_stats() - clear flow pool statistics
227  *
228  * @soc: Handle to struct dp_soc.
229  *
230  * Return: None
231  */
232 void dp_tx_clear_flow_pool_stats(struct dp_soc *soc)
233 {
234 
235 	if (!soc) {
236 		QDF_TRACE(QDF_MODULE_ID_DP, QDF_TRACE_LEVEL_ERROR,
237 			"%s: soc is null", __func__);
238 		return;
239 	}
240 	qdf_mem_zero(&soc->pool_stats, sizeof(soc->pool_stats));
241 }
242 
243 /**
244  * dp_tx_create_flow_pool() - create flow pool
245  * @soc: Handle to struct dp_soc
246  * @flow_pool_id: flow pool id
247  * @flow_pool_size: flow pool size
248  *
249  * Return: flow_pool pointer / NULL for error
250  */
251 struct dp_tx_desc_pool_s *dp_tx_create_flow_pool(struct dp_soc *soc,
252 	uint8_t flow_pool_id, uint16_t flow_pool_size)
253 {
254 	struct dp_tx_desc_pool_s *pool;
255 	uint32_t stop_threshold;
256 	uint32_t start_threshold;
257 
258 	if (flow_pool_id >= MAX_TXDESC_POOLS) {
259 		dp_err("invalid flow_pool_id %d", flow_pool_id);
260 		return NULL;
261 	}
262 	pool = &soc->tx_desc[flow_pool_id];
263 	qdf_spin_lock_bh(&pool->flow_pool_lock);
264 	if ((pool->status != FLOW_POOL_INACTIVE) || pool->pool_create_cnt) {
265 		dp_tx_flow_pool_reattach(pool);
266 		qdf_spin_unlock_bh(&pool->flow_pool_lock);
267 		dp_err("cannot alloc desc, status=%d, create_cnt=%d",
268 		       pool->status, pool->pool_create_cnt);
269 		return pool;
270 	}
271 
272 	if (dp_tx_desc_pool_alloc(soc, flow_pool_id, flow_pool_size)) {
273 		qdf_spin_unlock_bh(&pool->flow_pool_lock);
274 		return NULL;
275 	}
276 
277 	stop_threshold = wlan_cfg_get_tx_flow_stop_queue_th(soc->wlan_cfg_ctx);
278 	start_threshold = stop_threshold +
279 		wlan_cfg_get_tx_flow_start_queue_offset(soc->wlan_cfg_ctx);
280 
281 	pool->flow_pool_id = flow_pool_id;
282 	pool->pool_size = flow_pool_size;
283 	pool->avail_desc = flow_pool_size;
284 	pool->status = FLOW_POOL_ACTIVE_UNPAUSED;
285 	dp_tx_initialize_threshold(pool, start_threshold, stop_threshold,
286 				   flow_pool_size);
287 	pool->pool_create_cnt++;
288 
289 	qdf_spin_unlock_bh(&pool->flow_pool_lock);
290 
291 	return pool;
292 }
293 
294 /**
295  * dp_tx_delete_flow_pool() - delete flow pool
296  * @soc: Handle to struct dp_soc
297  * @pool: flow pool pointer
298  * @force: free pool forcefully
299  *
300  * Delete flow_pool if all tx descriptors are available.
301  * Otherwise put it in FLOW_POOL_INVALID state.
302  * If force is set then pull all available descriptors to
303  * global pool.
304  *
305  * Return: 0 for success or error
306  */
307 int dp_tx_delete_flow_pool(struct dp_soc *soc, struct dp_tx_desc_pool_s *pool,
308 	bool force)
309 {
310 	if (!soc || !pool) {
311 		dp_err("pool or soc is NULL");
312 		QDF_ASSERT(0);
313 		return ENOMEM;
314 	}
315 
316 	dp_info("pool create_cnt=%d, avail_desc=%d, size=%d, status=%d",
317 		pool->pool_create_cnt, pool->avail_desc,
318 		pool->pool_size, pool->status);
319 	qdf_spin_lock_bh(&pool->flow_pool_lock);
320 	if (!pool->pool_create_cnt) {
321 		qdf_spin_unlock_bh(&pool->flow_pool_lock);
322 		dp_err("flow pool either not created or alread deleted");
323 		return -ENOENT;
324 	}
325 	pool->pool_create_cnt--;
326 	if (pool->pool_create_cnt) {
327 		qdf_spin_unlock_bh(&pool->flow_pool_lock);
328 		dp_err("pool is still attached, pending detach %d",
329 		       pool->pool_create_cnt);
330 		return -EAGAIN;
331 	}
332 
333 	if (pool->avail_desc < pool->pool_size) {
334 		pool->status = FLOW_POOL_INVALID;
335 		qdf_spin_unlock_bh(&pool->flow_pool_lock);
336 		dp_err("avail desc less than pool size");
337 		return -EAGAIN;
338 	}
339 
340 	/* We have all the descriptors for the pool, we can delete the pool */
341 	dp_tx_desc_pool_free(soc, pool->flow_pool_id);
342 	qdf_spin_unlock_bh(&pool->flow_pool_lock);
343 	return 0;
344 }
345 
346 /**
347  * dp_tx_flow_pool_vdev_map() - Map flow_pool with vdev
348  * @pdev: Handle to struct dp_pdev
349  * @pool: flow_pool
350  * @vdev_id: flow_id /vdev_id
351  *
352  * Return: none
353  */
354 static void dp_tx_flow_pool_vdev_map(struct dp_pdev *pdev,
355 	struct dp_tx_desc_pool_s *pool, uint8_t vdev_id)
356 {
357 	struct dp_vdev *vdev;
358 	struct dp_soc *soc = pdev->soc;
359 
360 	vdev = (struct dp_vdev *)cdp_get_vdev_from_vdev_id((void *)soc,
361 					(struct cdp_pdev *)pdev, vdev_id);
362 	if (!vdev) {
363 		QDF_TRACE(QDF_MODULE_ID_DP, QDF_TRACE_LEVEL_ERROR,
364 		   "%s: invalid vdev_id %d",
365 		   __func__, vdev_id);
366 		return;
367 	}
368 
369 	vdev->pool = pool;
370 	qdf_spin_lock_bh(&pool->flow_pool_lock);
371 	pool->pool_owner_ctx = soc;
372 	pool->flow_pool_id = vdev_id;
373 	qdf_spin_unlock_bh(&pool->flow_pool_lock);
374 }
375 
376 /**
377  * dp_tx_flow_pool_vdev_unmap() - Unmap flow_pool from vdev
378  * @pdev: Handle to struct dp_pdev
379  * @pool: flow_pool
380  * @vdev_id: flow_id /vdev_id
381  *
382  * Return: none
383  */
384 static void dp_tx_flow_pool_vdev_unmap(struct dp_pdev *pdev,
385 		struct dp_tx_desc_pool_s *pool, uint8_t vdev_id)
386 {
387 	struct dp_vdev *vdev;
388 	struct dp_soc *soc = pdev->soc;
389 
390 	vdev = (struct dp_vdev *)cdp_get_vdev_from_vdev_id((void *)soc,
391 					(struct cdp_pdev *)pdev, vdev_id);
392 	if (!vdev) {
393 		QDF_TRACE(QDF_MODULE_ID_DP, QDF_TRACE_LEVEL_ERROR,
394 		   "%s: invalid vdev_id %d",
395 		   __func__, vdev_id);
396 		return;
397 	}
398 
399 	vdev->pool = NULL;
400 }
401 
402 /**
403  * dp_tx_flow_pool_map_handler() - Map flow_id with pool of descriptors
404  * @pdev: Handle to struct dp_pdev
405  * @flow_id: flow id
406  * @flow_type: flow type
407  * @flow_pool_id: pool id
408  * @flow_pool_size: pool size
409  *
410  * Process below target to host message
411  * HTT_T2H_MSG_TYPE_FLOW_POOL_MAP
412  *
413  * Return: none
414  */
415 QDF_STATUS dp_tx_flow_pool_map_handler(struct dp_pdev *pdev, uint8_t flow_id,
416 	uint8_t flow_type, uint8_t flow_pool_id, uint16_t flow_pool_size)
417 {
418 	struct dp_soc *soc = pdev->soc;
419 	struct dp_tx_desc_pool_s *pool;
420 	enum htt_flow_type type = flow_type;
421 
422 
423 	dp_info("flow_id %d flow_type %d flow_pool_id %d flow_pool_size %d",
424 		flow_id, flow_type, flow_pool_id, flow_pool_size);
425 
426 	if (qdf_unlikely(!soc)) {
427 		dp_err("soc is NULL");
428 		return QDF_STATUS_E_FAULT;
429 	}
430 	soc->pool_stats.pool_map_count++;
431 
432 	pool = dp_tx_create_flow_pool(soc, flow_pool_id,
433 			flow_pool_size);
434 	if (!pool) {
435 		dp_err("creation of flow_pool %d size %d failed",
436 		       flow_pool_id, flow_pool_size);
437 		return QDF_STATUS_E_RESOURCES;
438 	}
439 
440 	switch (type) {
441 
442 	case FLOW_TYPE_VDEV:
443 		dp_tx_flow_pool_vdev_map(pdev, pool, flow_id);
444 		break;
445 	default:
446 		dp_err("flow type %d not supported", type);
447 		break;
448 	}
449 
450 	return QDF_STATUS_SUCCESS;
451 }
452 
453 /**
454  * dp_tx_flow_pool_unmap_handler() - Unmap flow_id from pool of descriptors
455  * @pdev: Handle to struct dp_pdev
456  * @flow_id: flow id
457  * @flow_type: flow type
458  * @flow_pool_id: pool id
459  *
460  * Process below target to host message
461  * HTT_T2H_MSG_TYPE_FLOW_POOL_UNMAP
462  *
463  * Return: none
464  */
465 void dp_tx_flow_pool_unmap_handler(struct dp_pdev *pdev, uint8_t flow_id,
466 	uint8_t flow_type, uint8_t flow_pool_id)
467 {
468 	struct dp_soc *soc = pdev->soc;
469 	struct dp_tx_desc_pool_s *pool;
470 	enum htt_flow_type type = flow_type;
471 
472 	QDF_TRACE(QDF_MODULE_ID_DP, QDF_TRACE_LEVEL_INFO,
473 		"%s: flow_id %d flow_type %d flow_pool_id %d",
474 		__func__, flow_id, flow_type, flow_pool_id);
475 
476 	if (qdf_unlikely(!pdev)) {
477 		QDF_TRACE(QDF_MODULE_ID_DP, QDF_TRACE_LEVEL_ERROR,
478 			"%s: pdev is NULL", __func__);
479 		return;
480 	}
481 	soc->pool_stats.pool_unmap_count++;
482 
483 	pool = &soc->tx_desc[flow_pool_id];
484 	if (!pool) {
485 		QDF_TRACE(QDF_MODULE_ID_DP, QDF_TRACE_LEVEL_ERROR,
486 		   "%s: flow_pool not available flow_pool_id %d",
487 		   __func__, type);
488 		return;
489 	}
490 
491 	switch (type) {
492 
493 	case FLOW_TYPE_VDEV:
494 		dp_tx_flow_pool_vdev_unmap(pdev, pool, flow_id);
495 		break;
496 	default:
497 		QDF_TRACE(QDF_MODULE_ID_DP, QDF_TRACE_LEVEL_ERROR,
498 		   "%s: flow type %d not supported !!!",
499 		   __func__, type);
500 		return;
501 	}
502 
503 	/* only delete if all descriptors are available */
504 	dp_tx_delete_flow_pool(soc, pool, false);
505 }
506 
507 /**
508  * dp_tx_flow_control_init() - Initialize tx flow control
509  * @tx_desc_pool: Handle to flow_pool
510  *
511  * Return: none
512  */
513 void dp_tx_flow_control_init(struct dp_soc *soc)
514 {
515 	qdf_spinlock_create(&soc->flow_pool_array_lock);
516 }
517 
518 /**
519  * dp_tx_desc_pool_dealloc() - De-allocate tx desc pool
520  * @tx_desc_pool: Handle to flow_pool
521  *
522  * Return: none
523  */
524 static inline void dp_tx_desc_pool_dealloc(struct dp_soc *soc)
525 {
526 	struct dp_tx_desc_pool_s *tx_desc_pool;
527 	int i;
528 
529 	for (i = 0; i < MAX_TXDESC_POOLS; i++) {
530 		tx_desc_pool = &((soc)->tx_desc[i]);
531 		if (!tx_desc_pool->desc_pages.num_pages)
532 			continue;
533 
534 		if (dp_tx_desc_pool_free(soc, i) != QDF_STATUS_SUCCESS)
535 			dp_err("Tx Desc Pool:%d Free failed", i);
536 	}
537 }
538 
539 /**
540  * dp_tx_flow_control_deinit() - Deregister fw based tx flow control
541  * @tx_desc_pool: Handle to flow_pool
542  *
543  * Return: none
544  */
545 void dp_tx_flow_control_deinit(struct dp_soc *soc)
546 {
547 	dp_tx_desc_pool_dealloc(soc);
548 
549 	qdf_spinlock_destroy(&soc->flow_pool_array_lock);
550 }
551 
552 /**
553  * dp_txrx_register_pause_cb() - Register pause callback
554  * @ctx: Handle to struct dp_soc
555  * @pause_cb: Tx pause_cb
556  *
557  * Return: none
558  */
559 QDF_STATUS dp_txrx_register_pause_cb(struct cdp_soc_t *handle,
560 	tx_pause_callback pause_cb)
561 {
562 	struct dp_soc *soc = (struct dp_soc *)handle;
563 
564 	if (!soc || !pause_cb) {
565 		QDF_TRACE(QDF_MODULE_ID_DP, QDF_TRACE_LEVEL_ERROR,
566 			FL("soc or pause_cb is NULL"));
567 		return QDF_STATUS_E_INVAL;
568 	}
569 	soc->pause_cb = pause_cb;
570 
571 	return QDF_STATUS_SUCCESS;
572 }
573 
574 QDF_STATUS dp_tx_flow_pool_map(struct cdp_soc_t *handle, struct cdp_pdev *pdev,
575 				uint8_t vdev_id)
576 {
577 	struct dp_soc *soc = (struct dp_soc *)handle;
578 	int tx_ring_size = wlan_cfg_tx_ring_size(soc->wlan_cfg_ctx);
579 
580 	return (dp_tx_flow_pool_map_handler((struct dp_pdev *)pdev, vdev_id,
581 				FLOW_TYPE_VDEV,	vdev_id, tx_ring_size));
582 }
583 
584 void dp_tx_flow_pool_unmap(struct cdp_soc_t *soc, struct cdp_pdev *pdev,
585 			   uint8_t vdev_id)
586 {
587 	return(dp_tx_flow_pool_unmap_handler((struct dp_pdev *)pdev, vdev_id,
588 				FLOW_TYPE_VDEV, vdev_id));
589 }
590