staging/rtl8192e/rtl819x_TSProc.c

14 	struct rtllib_device *ieee = container_of(ts, struct rtllib_device,
23 	spin_lock_irqsave(&(ieee->reorder_spinlock), flags);
43 				netdev_dbg(ieee->dev,
46 				ieee->stats_IndicateArray[index] =
51 					      &ieee->RxReorder_Unused_List);
63 			netdev_warn(ieee->dev,
66 			spin_unlock_irqrestore(&(ieee->reorder_spinlock),
70 		rtllib_indicate_packets(ieee, ieee->stats_IndicateArray, index);
77 			  msecs_to_jiffies(ieee->ht_info->rx_reorder_pending_time)
80 	spin_unlock_irqrestore(&(ieee->reorder_spinlock), flags);
87 	struct rtllib_device *ieee = container_of(ts, struct rtllib_device,
90 	rtllib_ts_init_add_ba(ieee, ts, BA_POLICY_IMMEDIATE, false);
91 	netdev_dbg(ieee->dev, "%s(): ADDBA Req is started\n", __func__);
120 void rtllib_ts_init(struct rtllib_device *ieee)
122 	struct tx_ts_record *pTxTS  = ieee->tx_ts_records;
123 	struct rx_ts_record *rxts  = ieee->rx_ts_records;
124 	struct rx_reorder_entry *pRxReorderEntry = ieee->RxReorderEntry;
127 	INIT_LIST_HEAD(&ieee->Tx_TS_Admit_List);
128 	INIT_LIST_HEAD(&ieee->Tx_TS_Pending_List);
129 	INIT_LIST_HEAD(&ieee->Tx_TS_Unused_List);
142 				&ieee->Tx_TS_Unused_List);
146 	INIT_LIST_HEAD(&ieee->Rx_TS_Admit_List);
147 	INIT_LIST_HEAD(&ieee->Rx_TS_Pending_List);
148 	INIT_LIST_HEAD(&ieee->Rx_TS_Unused_List);
159 			      &ieee->Rx_TS_Unused_List);
162 	INIT_LIST_HEAD(&ieee->RxReorder_Unused_List);
165 			      &ieee->RxReorder_Unused_List);
168 		pRxReorderEntry = &ieee->RxReorderEntry[count + 1];
172 static struct ts_common_info *SearchAdmitTRStream(struct rtllib_device *ieee,
192 		psearch_list = &ieee->Tx_TS_Admit_List;
194 		psearch_list = &ieee->Rx_TS_Admit_List;
227 bool rtllib_get_ts(struct rtllib_device *ieee, struct ts_common_info **ppTS,
238 		netdev_warn(ieee->dev, "Get TS for Broadcast or Multicast\n");
241 	if (ieee->current_network.qos_data.supported == 0) {
262 			netdev_warn(ieee->dev, "%s(): TID(%d) is not valid\n",
268 	*ppTS = SearchAdmitTRStream(ieee, addr, UP, tx_rx_select);
273 		netdev_dbg(ieee->dev, "add new TS failed(tid:%d)\n", UP);
278 				(&ieee->Tx_TS_Unused_List) :
279 				(&ieee->Rx_TS_Unused_List);
282 				(&ieee->Tx_TS_Admit_List) :
283 				(&ieee->Rx_TS_Admit_List);
305 		netdev_dbg(ieee->dev,
317 	netdev_warn(ieee->dev,
323 static void RemoveTsEntry(struct rtllib_device *ieee,
326 	rtllib_ts_init_del_ba(ieee, pTs, tx_rx_select);
339 			netdev_dbg(ieee->dev,  "%s(): Delete SeqNum %d!\n",
354 				      &ieee->RxReorder_Unused_List);
363 void remove_peer_ts(struct rtllib_device *ieee, u8 *addr)
367 	netdev_info(ieee->dev, "===========>%s, %pM\n", __func__, addr);
369 	list_for_each_entry_safe(ts, pTmpTS, &ieee->Tx_TS_Pending_List, list) {
371 			RemoveTsEntry(ieee, ts, TX_DIR);
373 			list_add_tail(&ts->list, &ieee->Tx_TS_Unused_List);
377 	list_for_each_entry_safe(ts, pTmpTS, &ieee->Tx_TS_Admit_List, list) {
379 			netdev_info(ieee->dev,
381 			RemoveTsEntry(ieee, ts, TX_DIR);
383 			list_add_tail(&ts->list, &ieee->Tx_TS_Unused_List);
387 	list_for_each_entry_safe(ts, pTmpTS, &ieee->Rx_TS_Pending_List, list) {
389 			RemoveTsEntry(ieee, ts, RX_DIR);
391 			list_add_tail(&ts->list, &ieee->Rx_TS_Unused_List);
395 	list_for_each_entry_safe(ts, pTmpTS, &ieee->Rx_TS_Admit_List, list) {
397 			RemoveTsEntry(ieee, ts, RX_DIR);
399 			list_add_tail(&ts->list, &ieee->Rx_TS_Unused_List);
405 void remove_all_ts(struct rtllib_device *ieee)
409 	list_for_each_entry_safe(ts, pTmpTS, &ieee->Tx_TS_Pending_List, list) {
410 		RemoveTsEntry(ieee, ts, TX_DIR);
412 		list_add_tail(&ts->list, &ieee->Tx_TS_Unused_List);
415 	list_for_each_entry_safe(ts, pTmpTS, &ieee->Tx_TS_Admit_List, list) {
416 		RemoveTsEntry(ieee, ts, TX_DIR);
418 		list_add_tail(&ts->list, &ieee->Tx_TS_Unused_List);
421 	list_for_each_entry_safe(ts, pTmpTS, &ieee->Rx_TS_Pending_List, list) {
422 		RemoveTsEntry(ieee, ts, RX_DIR);
424 		list_add_tail(&ts->list, &ieee->Rx_TS_Unused_List);
427 	list_for_each_entry_safe(ts, pTmpTS, &ieee->Rx_TS_Admit_List, list) {
428 		RemoveTsEntry(ieee, ts, RX_DIR);
430 		list_add_tail(&ts->list, &ieee->Rx_TS_Unused_List);
434 void TsStartAddBaProcess(struct rtllib_device *ieee, struct tx_ts_record *pTxTS)
440 			netdev_dbg(ieee->dev, "Start ADDBA after 60 sec!!\n");
444 			netdev_dbg(ieee->dev, "Immediately Start ADDBA\n");
448 		netdev_dbg(ieee->dev, "BA timer is already added\n");