xref: /wlan-dirver/qca-wifi-host-cmn/dp/wifi3.0/dp_tx_flow_control.c (revision dae10a5fbc53d54c53c4ba24fa018ad8b1e7c008)
1 /*
2  * Copyright (c) 2015-2018 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 		QDF_TRACE(QDF_MODULE_ID_DP, QDF_TRACE_LEVEL_ERROR,
260 		   "%s: invalid flow_pool_id %d", __func__, flow_pool_id);
261 		return NULL;
262 	}
263 	pool = &soc->tx_desc[flow_pool_id];
264 	qdf_spin_lock_bh(&pool->flow_pool_lock);
265 	if ((pool->status != FLOW_POOL_INACTIVE) || pool->pool_create_cnt) {
266 		dp_tx_flow_pool_reattach(pool);
267 		qdf_spin_unlock_bh(&pool->flow_pool_lock);
268 		return pool;
269 	}
270 
271 	if (dp_tx_desc_pool_alloc(soc, flow_pool_id, flow_pool_size)) {
272 		qdf_spin_unlock_bh(&pool->flow_pool_lock);
273 		return NULL;
274 	}
275 
276 	stop_threshold = wlan_cfg_get_tx_flow_stop_queue_th(soc->wlan_cfg_ctx);
277 	start_threshold = stop_threshold +
278 		wlan_cfg_get_tx_flow_start_queue_offset(soc->wlan_cfg_ctx);
279 
280 	pool->flow_pool_id = flow_pool_id;
281 	pool->pool_size = flow_pool_size;
282 	pool->avail_desc = flow_pool_size;
283 	pool->status = FLOW_POOL_ACTIVE_UNPAUSED;
284 	dp_tx_initialize_threshold(pool, start_threshold, stop_threshold,
285 				   flow_pool_size);
286 	pool->pool_create_cnt++;
287 
288 	qdf_spin_unlock_bh(&pool->flow_pool_lock);
289 
290 	return pool;
291 }
292 
293 /**
294  * dp_tx_delete_flow_pool() - delete flow pool
295  * @soc: Handle to struct dp_soc
296  * @pool: flow pool pointer
297  * @force: free pool forcefully
298  *
299  * Delete flow_pool if all tx descriptors are available.
300  * Otherwise put it in FLOW_POOL_INVALID state.
301  * If force is set then pull all available descriptors to
302  * global pool.
303  *
304  * Return: 0 for success or error
305  */
306 int dp_tx_delete_flow_pool(struct dp_soc *soc, struct dp_tx_desc_pool_s *pool,
307 	bool force)
308 {
309 	if (!soc || !pool) {
310 		QDF_TRACE(QDF_MODULE_ID_DP, QDF_TRACE_LEVEL_ERROR,
311 		   "%s: pool or soc is NULL", __func__);
312 		QDF_ASSERT(0);
313 		return ENOMEM;
314 	}
315 
316 	qdf_spin_lock_bh(&pool->flow_pool_lock);
317 	if (!pool->pool_create_cnt) {
318 		QDF_TRACE(QDF_MODULE_ID_DP, QDF_TRACE_LEVEL_ERROR,
319 			  "flow pool either not created or alread deleted");
320 		qdf_spin_unlock_bh(&pool->flow_pool_lock);
321 		return -ENOENT;
322 	}
323 	pool->pool_create_cnt--;
324 	if (pool->pool_create_cnt) {
325 		QDF_TRACE(QDF_MODULE_ID_DP, QDF_TRACE_LEVEL_ERROR,
326 			  "%s: pool is still attached, pending detach %d",
327 			  __func__, pool->pool_create_cnt);
328 		qdf_spin_unlock_bh(&pool->flow_pool_lock);
329 		return -EAGAIN;
330 	}
331 
332 	if (pool->avail_desc < pool->pool_size) {
333 		pool->status = FLOW_POOL_INVALID;
334 		qdf_spin_unlock_bh(&pool->flow_pool_lock);
335 		return -EAGAIN;
336 	}
337 
338 	/* We have all the descriptors for the pool, we can delete the pool */
339 	dp_tx_desc_pool_free(soc, pool->flow_pool_id);
340 	qdf_spin_unlock_bh(&pool->flow_pool_lock);
341 	return 0;
342 }
343 
344 /**
345  * dp_tx_flow_pool_vdev_map() - Map flow_pool with vdev
346  * @pdev: Handle to struct dp_pdev
347  * @pool: flow_pool
348  * @vdev_id: flow_id /vdev_id
349  *
350  * Return: none
351  */
352 static void dp_tx_flow_pool_vdev_map(struct dp_pdev *pdev,
353 	struct dp_tx_desc_pool_s *pool, uint8_t vdev_id)
354 {
355 	struct dp_vdev *vdev;
356 	struct dp_soc *soc = pdev->soc;
357 
358 	vdev = (struct dp_vdev *)cdp_get_vdev_from_vdev_id((void *)soc,
359 					(struct cdp_pdev *)pdev, vdev_id);
360 	if (!vdev) {
361 		QDF_TRACE(QDF_MODULE_ID_DP, QDF_TRACE_LEVEL_ERROR,
362 		   "%s: invalid vdev_id %d",
363 		   __func__, vdev_id);
364 		return;
365 	}
366 
367 	vdev->pool = pool;
368 	qdf_spin_lock_bh(&pool->flow_pool_lock);
369 	pool->pool_owner_ctx = soc;
370 	pool->flow_pool_id = vdev_id;
371 	qdf_spin_unlock_bh(&pool->flow_pool_lock);
372 }
373 
374 /**
375  * dp_tx_flow_pool_vdev_unmap() - Unmap flow_pool from vdev
376  * @pdev: Handle to struct dp_pdev
377  * @pool: flow_pool
378  * @vdev_id: flow_id /vdev_id
379  *
380  * Return: none
381  */
382 static void dp_tx_flow_pool_vdev_unmap(struct dp_pdev *pdev,
383 		struct dp_tx_desc_pool_s *pool, uint8_t vdev_id)
384 {
385 	struct dp_vdev *vdev;
386 	struct dp_soc *soc = pdev->soc;
387 
388 	vdev = (struct dp_vdev *)cdp_get_vdev_from_vdev_id((void *)soc,
389 					(struct cdp_pdev *)pdev, vdev_id);
390 	if (!vdev) {
391 		QDF_TRACE(QDF_MODULE_ID_DP, QDF_TRACE_LEVEL_ERROR,
392 		   "%s: invalid vdev_id %d",
393 		   __func__, vdev_id);
394 		return;
395 	}
396 
397 	vdev->pool = NULL;
398 }
399 
400 /**
401  * dp_tx_flow_pool_map_handler() - Map flow_id with pool of descriptors
402  * @pdev: Handle to struct dp_pdev
403  * @flow_id: flow id
404  * @flow_type: flow type
405  * @flow_pool_id: pool id
406  * @flow_pool_size: pool size
407  *
408  * Process below target to host message
409  * HTT_T2H_MSG_TYPE_FLOW_POOL_MAP
410  *
411  * Return: none
412  */
413 QDF_STATUS dp_tx_flow_pool_map_handler(struct dp_pdev *pdev, uint8_t flow_id,
414 	uint8_t flow_type, uint8_t flow_pool_id, uint16_t flow_pool_size)
415 {
416 	struct dp_soc *soc = pdev->soc;
417 	struct dp_tx_desc_pool_s *pool;
418 	enum htt_flow_type type = flow_type;
419 
420 
421 	QDF_TRACE(QDF_MODULE_ID_DP, QDF_TRACE_LEVEL_INFO,
422 		"%s: flow_id %d flow_type %d flow_pool_id %d flow_pool_size %d",
423 		__func__, flow_id, flow_type, flow_pool_id, flow_pool_size);
424 
425 	if (qdf_unlikely(!soc)) {
426 		QDF_TRACE(QDF_MODULE_ID_DP, QDF_TRACE_LEVEL_ERROR,
427 			"%s: soc is NULL", __func__);
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 == NULL) {
435 		QDF_TRACE(QDF_MODULE_ID_DP, QDF_TRACE_LEVEL_ERROR,
436 			   "%s: creation of flow_pool %d size %d failed",
437 			   __func__, flow_pool_id, flow_pool_size);
438 		return QDF_STATUS_E_RESOURCES;
439 	}
440 
441 	switch (type) {
442 
443 	case FLOW_TYPE_VDEV:
444 		dp_tx_flow_pool_vdev_map(pdev, pool, flow_id);
445 		break;
446 	default:
447 		QDF_TRACE(QDF_MODULE_ID_DP, QDF_TRACE_LEVEL_ERROR,
448 		   "%s: flow type %d not supported !!!",
449 		   __func__, type);
450 		break;
451 	}
452 
453 	return QDF_STATUS_SUCCESS;
454 }
455 
456 /**
457  * dp_tx_flow_pool_unmap_handler() - Unmap flow_id from pool of descriptors
458  * @pdev: Handle to struct dp_pdev
459  * @flow_id: flow id
460  * @flow_type: flow type
461  * @flow_pool_id: pool id
462  *
463  * Process below target to host message
464  * HTT_T2H_MSG_TYPE_FLOW_POOL_UNMAP
465  *
466  * Return: none
467  */
468 void dp_tx_flow_pool_unmap_handler(struct dp_pdev *pdev, uint8_t flow_id,
469 	uint8_t flow_type, uint8_t flow_pool_id)
470 {
471 	struct dp_soc *soc = pdev->soc;
472 	struct dp_tx_desc_pool_s *pool;
473 	enum htt_flow_type type = flow_type;
474 
475 	QDF_TRACE(QDF_MODULE_ID_DP, QDF_TRACE_LEVEL_INFO,
476 		"%s: flow_id %d flow_type %d flow_pool_id %d",
477 		__func__, flow_id, flow_type, flow_pool_id);
478 
479 	if (qdf_unlikely(!pdev)) {
480 		QDF_TRACE(QDF_MODULE_ID_DP, QDF_TRACE_LEVEL_ERROR,
481 			"%s: pdev is NULL", __func__);
482 		return;
483 	}
484 	soc->pool_stats.pool_unmap_count++;
485 
486 	pool = &soc->tx_desc[flow_pool_id];
487 	if (!pool) {
488 		QDF_TRACE(QDF_MODULE_ID_DP, QDF_TRACE_LEVEL_ERROR,
489 		   "%s: flow_pool not available flow_pool_id %d",
490 		   __func__, type);
491 		return;
492 	}
493 
494 	switch (type) {
495 
496 	case FLOW_TYPE_VDEV:
497 		dp_tx_flow_pool_vdev_unmap(pdev, pool, flow_id);
498 		break;
499 	default:
500 		QDF_TRACE(QDF_MODULE_ID_DP, QDF_TRACE_LEVEL_ERROR,
501 		   "%s: flow type %d not supported !!!",
502 		   __func__, type);
503 		return;
504 	}
505 
506 	/* only delete if all descriptors are available */
507 	dp_tx_delete_flow_pool(soc, pool, false);
508 }
509 
510 /**
511  * dp_tx_flow_control_init() - Initialize tx flow control
512  * @tx_desc_pool: Handle to flow_pool
513  *
514  * Return: none
515  */
516 void dp_tx_flow_control_init(struct dp_soc *soc)
517 {
518 	qdf_spinlock_create(&soc->flow_pool_array_lock);
519 }
520 
521 /**
522  * dp_tx_flow_control_deinit() - Deregister fw based tx flow control
523  * @tx_desc_pool: Handle to flow_pool
524  *
525  * Return: none
526  */
527 void dp_tx_flow_control_deinit(struct dp_soc *soc)
528 {
529 	qdf_spinlock_destroy(&soc->flow_pool_array_lock);
530 }
531 
532 /**
533  * dp_txrx_register_pause_cb() - Register pause callback
534  * @ctx: Handle to struct dp_soc
535  * @pause_cb: Tx pause_cb
536  *
537  * Return: none
538  */
539 QDF_STATUS dp_txrx_register_pause_cb(struct cdp_soc_t *handle,
540 	tx_pause_callback pause_cb)
541 {
542 	struct dp_soc *soc = (struct dp_soc *)handle;
543 
544 	if (!soc || !pause_cb) {
545 		QDF_TRACE(QDF_MODULE_ID_DP, QDF_TRACE_LEVEL_ERROR,
546 			FL("soc or pause_cb is NULL"));
547 		return QDF_STATUS_E_INVAL;
548 	}
549 	soc->pause_cb = pause_cb;
550 
551 	return QDF_STATUS_SUCCESS;
552 }
553 
554 QDF_STATUS dp_tx_flow_pool_map(struct cdp_soc_t *handle, struct cdp_pdev *pdev,
555 				uint8_t vdev_id)
556 {
557 	struct dp_soc *soc = (struct dp_soc *)handle;
558 	int tx_ring_size = wlan_cfg_tx_ring_size(soc->wlan_cfg_ctx);
559 
560 	return (dp_tx_flow_pool_map_handler((struct dp_pdev *)pdev, vdev_id,
561 				FLOW_TYPE_VDEV,	vdev_id, tx_ring_size));
562 }
563 
564 void dp_tx_flow_pool_unmap(struct cdp_soc_t *soc, struct cdp_pdev *pdev,
565 			   uint8_t vdev_id)
566 {
567 	return(dp_tx_flow_pool_unmap_handler((struct dp_pdev *)pdev, vdev_id,
568 				FLOW_TYPE_VDEV, vdev_id));
569 }
570