43 static void wil_release_reorder_frame(struct wil6210_priv *wil,  in wil_release_reorder_frame()  argument
47 	struct net_device *ndev = wil_to_ndev(wil);  in wil_release_reorder_frame()
62 static void wil_release_reorder_frames(struct wil6210_priv *wil,  in wil_release_reorder_frames()  argument
76 		wil_release_reorder_frame(wil, r, index);  in wil_release_reorder_frames()
81 static void wil_reorder_release(struct wil6210_priv *wil,  in wil_reorder_release()  argument
87 		wil_release_reorder_frame(wil, r, index);  in wil_reorder_release()
93 void wil_rx_reorder(struct wil6210_priv *wil, struct sk_buff *skb)  in wil_rx_reorder()  argument
96 	struct net_device *ndev = wil_to_ndev(wil);  in wil_rx_reorder()
103 	struct wil_sta_info *sta = &wil->sta[cid];  in wil_rx_reorder()
108 	wil_dbg_txrx(wil, "MID %d CID %d TID %d Seq 0x%03x mcast %01x\n",  in wil_rx_reorder()
139 				wil_err(wil,  in wil_rx_reorder()
146 			wil_err(wil,  in wil_rx_reorder()
158 		wil_dbg_txrx(wil, "Rx drop: old seq 0x%03x head 0x%03x\n",  in wil_rx_reorder()
171 		wil_release_reorder_frames(wil, r, hseq);  in wil_rx_reorder()
181 		wil_dbg_txrx(wil, "Rx drop: dup seq 0x%03x\n", seq);  in wil_rx_reorder()
202 	wil_reorder_release(wil, r);  in wil_rx_reorder()
209 void wil_rx_bar(struct wil6210_priv *wil, u8 cid, u8 tid, u16 seq)  in wil_rx_bar()  argument
211 	struct wil_sta_info *sta = &wil->sta[cid];  in wil_rx_bar()
218 		wil_err(wil, "BAR for non-existing CID %d TID %d\n", cid, tid);  in wil_rx_bar()
222 		wil_err(wil, "BAR Seq 0x%03x preceding head 0x%03x\n",  in wil_rx_bar()
226 	wil_dbg_txrx(wil, "BAR: CID %d TID %d Seq 0x%03x head 0x%03x\n",  in wil_rx_bar()
228 	wil_release_reorder_frames(wil, r, seq);  in wil_rx_bar()
234 struct wil_tid_ampdu_rx *wil_tid_ampdu_rx_alloc(struct wil6210_priv *wil,  in wil_tid_ampdu_rx_alloc()  argument
261 void wil_tid_ampdu_rx_free(struct wil6210_priv *wil,  in wil_tid_ampdu_rx_free()  argument
266 	wil_release_reorder_frames(wil, r, r->head_seq_num + r->buf_size);  in wil_tid_ampdu_rx_free()
273 static u16 wil_agg_size(struct wil6210_priv *wil, u16 req_agg_wsize)  in wil_agg_size()  argument
285 int wil_addba_rx_request(struct wil6210_priv *wil, u8 cidxtid,  in wil_addba_rx_request()  argument
300 	mutex_lock(&wil->back_rx_mutex);  in wil_addba_rx_request()
301 	list_add_tail(&req->list, &wil->back_rx_pending);  in wil_addba_rx_request()
302 	mutex_unlock(&wil->back_rx_mutex);  in wil_addba_rx_request()
304 	queue_work(wil->wq_service, &wil->back_rx_worker);  in wil_addba_rx_request()
309 static void wil_back_rx_handle(struct wil6210_priv *wil,  in wil_back_rx_handle()  argument
335 		wil_err(wil, "BACK: invalid CID %d\n", cid);  in wil_back_rx_handle()
339 	sta = &wil->sta[cid];  in wil_back_rx_handle()
341 		wil_err(wil, "BACK: CID %d not connected\n", cid);  in wil_back_rx_handle()
345 	wil_dbg_wmi(wil,  in wil_back_rx_handle()
352 		wil_err(wil, "BACK requested unsupported ba_policy == 1\n");  in wil_back_rx_handle()
356 		agg_wsize = wil_agg_size(wil, req_agg_wsize);  in wil_back_rx_handle()
358 	rc = wmi_addba_rx_resp(wil, cid, tid, req->dialog_token, status,  in wil_back_rx_handle()
364 	r = wil_tid_ampdu_rx_alloc(wil, agg_wsize, ssn);  in wil_back_rx_handle()
366 	wil_tid_ampdu_rx_free(wil, sta->tid_rx[tid]);  in wil_back_rx_handle()
371 void wil_back_rx_flush(struct wil6210_priv *wil)  in wil_back_rx_flush()  argument
375 	wil_dbg_misc(wil, "%s()\n", __func__);  in wil_back_rx_flush()
377 	mutex_lock(&wil->back_rx_mutex);  in wil_back_rx_flush()
379 	list_for_each_entry_safe(evt, t, &wil->back_rx_pending, list) {  in wil_back_rx_flush()
384 	mutex_unlock(&wil->back_rx_mutex);  in wil_back_rx_flush()
388 static struct list_head *next_back_rx(struct wil6210_priv *wil)  in next_back_rx()  argument
392 	mutex_lock(&wil->back_rx_mutex);  in next_back_rx()
394 	if (!list_empty(&wil->back_rx_pending)) {  in next_back_rx()
395 		ret = wil->back_rx_pending.next;  in next_back_rx()
399 	mutex_unlock(&wil->back_rx_mutex);  in next_back_rx()
406 	struct wil6210_priv *wil = container_of(work, struct wil6210_priv,  in wil_back_rx_worker()  local
411 	while ((lh = next_back_rx(wil)) != NULL) {  in wil_back_rx_worker()
414 		wil_back_rx_handle(wil, evt);  in wil_back_rx_worker()
420 static void wil_back_tx_handle(struct wil6210_priv *wil,  in wil_back_tx_handle()  argument
423 	struct vring_tx_data *txdata = &wil->vring_tx_data[req->ringid];  in wil_back_tx_handle()
427 		wil_dbg_misc(wil, "ADDBA for vring[%d] already in progress\n",  in wil_back_tx_handle()
432 		wil_dbg_misc(wil,  in wil_back_tx_handle()
438 	rc = wmi_addba(wil, req->ringid, req->agg_wsize, req->agg_timeout);  in wil_back_tx_handle()
443 static struct list_head *next_back_tx(struct wil6210_priv *wil)  in next_back_tx()  argument
447 	mutex_lock(&wil->back_tx_mutex);  in next_back_tx()
449 	if (!list_empty(&wil->back_tx_pending)) {  in next_back_tx()
450 		ret = wil->back_tx_pending.next;  in next_back_tx()
454 	mutex_unlock(&wil->back_tx_mutex);  in next_back_tx()
461 	struct wil6210_priv *wil = container_of(work, struct wil6210_priv,  in wil_back_tx_worker()  local
466 	while ((lh = next_back_tx(wil)) != NULL) {  in wil_back_tx_worker()
469 		wil_back_tx_handle(wil, evt);  in wil_back_tx_worker()
474 void wil_back_tx_flush(struct wil6210_priv *wil)  in wil_back_tx_flush()  argument
478 	wil_dbg_misc(wil, "%s()\n", __func__);  in wil_back_tx_flush()
480 	mutex_lock(&wil->back_tx_mutex);  in wil_back_tx_flush()
482 	list_for_each_entry_safe(evt, t, &wil->back_tx_pending, list) {  in wil_back_tx_flush()
487 	mutex_unlock(&wil->back_tx_mutex);  in wil_back_tx_flush()
490 int wil_addba_tx_request(struct wil6210_priv *wil, u8 ringid, u16 wsize)  in wil_addba_tx_request()  argument
498 	req->agg_wsize = wil_agg_size(wil, wsize);  in wil_addba_tx_request()
501 	mutex_lock(&wil->back_tx_mutex);  in wil_addba_tx_request()
502 	list_add_tail(&req->list, &wil->back_tx_pending);  in wil_addba_tx_request()
503 	mutex_unlock(&wil->back_tx_mutex);  in wil_addba_tx_request()
505 	queue_work(wil->wq_service, &wil->back_tx_worker);  in wil_addba_tx_request()