1777 	struct mwl8k_ampdu_stream *stream;  in mwl8k_add_stream()  local
1782 		stream = &priv->ampdu[i];  in mwl8k_add_stream()
1783 		if (stream->state == AMPDU_NO_STREAM) {  in mwl8k_add_stream()
1784 			stream->sta = sta;  in mwl8k_add_stream()
1785 			stream->state = AMPDU_STREAM_NEW;  in mwl8k_add_stream()
1786 			stream->tid = tid;  in mwl8k_add_stream()
1787 			stream->idx = i;  in mwl8k_add_stream()
1790 			return stream;  in mwl8k_add_stream()
1797 mwl8k_start_stream(struct ieee80211_hw *hw, struct mwl8k_ampdu_stream *stream)  in mwl8k_start_stream()  argument
1802 	if (stream->state != AMPDU_STREAM_NEW)  in mwl8k_start_stream()
1804 	ret = ieee80211_start_tx_ba_session(stream->sta, stream->tid, 0);  in mwl8k_start_stream()
1807 			    "%d\n", stream->sta->addr, stream->tid, ret);  in mwl8k_start_stream()
1810 			    stream->sta->addr, stream->tid);  in mwl8k_start_stream()
1815 mwl8k_remove_stream(struct ieee80211_hw *hw, struct mwl8k_ampdu_stream *stream)  in mwl8k_remove_stream()  argument
1817 	wiphy_debug(hw->wiphy, "Remove stream for %pM %d\n", stream->sta->addr,  in mwl8k_remove_stream()
1818 		    stream->tid);  in mwl8k_remove_stream()
1819 	memset(stream, 0, sizeof(*stream));  in mwl8k_remove_stream()
1829 		struct mwl8k_ampdu_stream *stream;  in mwl8k_lookup_stream()  local
1830 		stream = &priv->ampdu[i];  in mwl8k_lookup_stream()
1831 		if (stream->state == AMPDU_NO_STREAM)  in mwl8k_lookup_stream()
1833 		if (!memcmp(stream->sta->addr, addr, ETH_ALEN) &&  in mwl8k_lookup_stream()
1834 		    stream->tid == tid)  in mwl8k_lookup_stream()
1835 			return stream;  in mwl8k_lookup_stream()
1900 	struct mwl8k_ampdu_stream *stream = NULL;  in mwl8k_txq_xmit()  local
1978 		stream = mwl8k_lookup_stream(hw, sta->addr, tid);  in mwl8k_txq_xmit()
1979 		if (stream != NULL) {  in mwl8k_txq_xmit()
1980 			if (stream->state == AMPDU_STREAM_ACTIVE) {  in mwl8k_txq_xmit()
1982 				txpriority = (BA_QUEUE + stream->idx) %  in mwl8k_txq_xmit()
1984 				if (stream->idx <= 1)  in mwl8k_txq_xmit()
1985 					index = stream->idx +  in mwl8k_txq_xmit()
1988 			} else if (stream->state == AMPDU_STREAM_NEW) {  in mwl8k_txq_xmit()
2023 				stream = mwl8k_add_stream(hw, sta, tid);  in mwl8k_txq_xmit()
2024 				if (stream != NULL)  in mwl8k_txq_xmit()
2042 			mwl8k_remove_stream(hw, stream);  in mwl8k_txq_xmit()
2065 				mwl8k_remove_stream(hw, stream);  in mwl8k_txq_xmit()
2115 		if (mwl8k_start_stream(hw, stream))  in mwl8k_txq_xmit()
2116 			mwl8k_remove_stream(hw, stream);  in mwl8k_txq_xmit()
3954 mwl8k_check_ba(struct ieee80211_hw *hw, struct mwl8k_ampdu_stream *stream,  in mwl8k_check_ba()  argument
3969 	cmd->create_params.queue_id = stream->idx;  in mwl8k_check_ba()
3970 	memcpy(&cmd->create_params.peer_mac_addr[0], stream->sta->addr,  in mwl8k_check_ba()
3972 	cmd->create_params.tid = stream->tid;  in mwl8k_check_ba()
3986 mwl8k_create_ba(struct ieee80211_hw *hw, struct mwl8k_ampdu_stream *stream,  in mwl8k_create_ba()  argument
4004 	cmd->create_params.queue_id = stream->idx;  in mwl8k_create_ba()
4006 	memcpy(cmd->create_params.peer_mac_addr, stream->sta->addr, ETH_ALEN);  in mwl8k_create_ba()
4007 	cmd->create_params.tid = stream->tid;  in mwl8k_create_ba()
4012 		(stream->sta->ht_cap.ampdu_factor &  in mwl8k_create_ba()
4014 		((stream->sta->ht_cap.ampdu_density << 2) &  in mwl8k_create_ba()
4024 		stream->sta->addr, stream->tid);  in mwl8k_create_ba()
5430 	struct mwl8k_ampdu_stream *stream;  in mwl8k_ampdu_action()  local
5438 	stream = mwl8k_lookup_stream(hw, addr, tid);  in mwl8k_ampdu_action()
5455 		if (stream == NULL) {  in mwl8k_ampdu_action()
5463 			stream = mwl8k_add_stream(hw, sta, tid);  in mwl8k_ampdu_action()
5465 		if (stream == NULL) {  in mwl8k_ampdu_action()
5470 		stream->state = AMPDU_STREAM_IN_PROGRESS;  in mwl8k_ampdu_action()
5479 				mwl8k_remove_stream(hw, stream);  in mwl8k_ampdu_action()
5484 			rc = mwl8k_check_ba(hw, stream, vif);  in mwl8k_ampdu_action()
5503 			mwl8k_remove_stream(hw, stream);  in mwl8k_ampdu_action()
5512 		if (stream) {  in mwl8k_ampdu_action()
5513 			if (stream->state == AMPDU_STREAM_ACTIVE) {  in mwl8k_ampdu_action()
5514 				idx = stream->idx;  in mwl8k_ampdu_action()
5519 			mwl8k_remove_stream(hw, stream);  in mwl8k_ampdu_action()
5524 		BUG_ON(stream == NULL);  in mwl8k_ampdu_action()
5525 		BUG_ON(stream->state != AMPDU_STREAM_IN_PROGRESS);  in mwl8k_ampdu_action()
5527 		rc = mwl8k_create_ba(hw, stream, buf_size, vif);  in mwl8k_ampdu_action()
5530 			stream->state = AMPDU_STREAM_ACTIVE;  in mwl8k_ampdu_action()
5532 			idx = stream->idx;  in mwl8k_ampdu_action()
5539 			mwl8k_remove_stream(hw, stream);  in mwl8k_ampdu_action()