Merge branch 'iwlwifi-fixes' into iwlwifi-next
[firefly-linux-kernel-4.4.55.git] / drivers / net / wireless / iwlwifi / mvm / time-event.c
1 /******************************************************************************
2  *
3  * This file is provided under a dual BSD/GPLv2 license.  When using or
4  * redistributing this file, you may do so under either license.
5  *
6  * GPL LICENSE SUMMARY
7  *
8  * Copyright(c) 2012 - 2014 Intel Corporation. All rights reserved.
9  * Copyright(c) 2013 - 2014 Intel Mobile Communications GmbH
10  *
11  * This program is free software; you can redistribute it and/or modify
12  * it under the terms of version 2 of the GNU General Public License as
13  * published by the Free Software Foundation.
14  *
15  * This program is distributed in the hope that it will be useful, but
16  * WITHOUT ANY WARRANTY; without even the implied warranty of
17  * MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.  See the GNU
18  * General Public License for more details.
19  *
20  * You should have received a copy of the GNU General Public License
21  * along with this program; if not, write to the Free Software
22  * Foundation, Inc., 51 Franklin Street, Fifth Floor, Boston, MA 02110,
23  * USA
24  *
25  * The full GNU General Public License is included in this distribution
26  * in the file called COPYING.
27  *
28  * Contact Information:
29  *  Intel Linux Wireless <ilw@linux.intel.com>
30  * Intel Corporation, 5200 N.E. Elam Young Parkway, Hillsboro, OR 97124-6497
31  *
32  * BSD LICENSE
33  *
34  * Copyright(c) 2012 - 2014 Intel Corporation. All rights reserved.
35  * Copyright(c) 2013 - 2014 Intel Mobile Communications GmbH
36  * All rights reserved.
37  *
38  * Redistribution and use in source and binary forms, with or without
39  * modification, are permitted provided that the following conditions
40  * are met:
41  *
42  *  * Redistributions of source code must retain the above copyright
43  *    notice, this list of conditions and the following disclaimer.
44  *  * Redistributions in binary form must reproduce the above copyright
45  *    notice, this list of conditions and the following disclaimer in
46  *    the documentation and/or other materials provided with the
47  *    distribution.
48  *  * Neither the name Intel Corporation nor the names of its
49  *    contributors may be used to endorse or promote products derived
50  *    from this software without specific prior written permission.
51  *
52  * THIS SOFTWARE IS PROVIDED BY THE COPYRIGHT HOLDERS AND CONTRIBUTORS
53  * "AS IS" AND ANY EXPRESS OR IMPLIED WARRANTIES, INCLUDING, BUT NOT
54  * LIMITED TO, THE IMPLIED WARRANTIES OF MERCHANTABILITY AND FITNESS FOR
55  * A PARTICULAR PURPOSE ARE DISCLAIMED. IN NO EVENT SHALL THE COPYRIGHT
56  * OWNER OR CONTRIBUTORS BE LIABLE FOR ANY DIRECT, INDIRECT, INCIDENTAL,
57  * SPECIAL, EXEMPLARY, OR CONSEQUENTIAL DAMAGES (INCLUDING, BUT NOT
58  * LIMITED TO, PROCUREMENT OF SUBSTITUTE GOODS OR SERVICES; LOSS OF USE,
59  * DATA, OR PROFITS; OR BUSINESS INTERRUPTION) HOWEVER CAUSED AND ON ANY
60  * THEORY OF LIABILITY, WHETHER IN CONTRACT, STRICT LIABILITY, OR TORT
61  * (INCLUDING NEGLIGENCE OR OTHERWISE) ARISING IN ANY WAY OUT OF THE USE
62  * OF THIS SOFTWARE, EVEN IF ADVISED OF THE POSSIBILITY OF SUCH DAMAGE.
63  *
64  *****************************************************************************/
65
66 #include <linux/jiffies.h>
67 #include <net/mac80211.h>
68
69 #include "iwl-notif-wait.h"
70 #include "iwl-trans.h"
71 #include "fw-api.h"
72 #include "time-event.h"
73 #include "mvm.h"
74 #include "iwl-io.h"
75 #include "iwl-prph.h"
76
77 /*
78  * For the high priority TE use a time event type that has similar priority to
79  * the FW's action scan priority.
80  */
81 #define IWL_MVM_ROC_TE_TYPE_NORMAL TE_P2P_DEVICE_DISCOVERABLE
82 #define IWL_MVM_ROC_TE_TYPE_MGMT_TX TE_P2P_CLIENT_ASSOC
83
84 void iwl_mvm_te_clear_data(struct iwl_mvm *mvm,
85                            struct iwl_mvm_time_event_data *te_data)
86 {
87         lockdep_assert_held(&mvm->time_event_lock);
88
89         if (te_data->id == TE_MAX)
90                 return;
91
92         list_del(&te_data->list);
93         te_data->running = false;
94         te_data->uid = 0;
95         te_data->id = TE_MAX;
96         te_data->vif = NULL;
97 }
98
99 void iwl_mvm_roc_done_wk(struct work_struct *wk)
100 {
101         struct iwl_mvm *mvm = container_of(wk, struct iwl_mvm, roc_done_wk);
102         u32 queues = 0;
103
104         /*
105          * Clear the ROC_RUNNING /ROC_AUX_RUNNING status bit.
106          * This will cause the TX path to drop offchannel transmissions.
107          * That would also be done by mac80211, but it is racy, in particular
108          * in the case that the time event actually completed in the firmware
109          * (which is handled in iwl_mvm_te_handle_notif).
110          */
111         if (test_and_clear_bit(IWL_MVM_STATUS_ROC_RUNNING, &mvm->status))
112                 queues |= BIT(IWL_MVM_OFFCHANNEL_QUEUE);
113         if (test_and_clear_bit(IWL_MVM_STATUS_ROC_AUX_RUNNING, &mvm->status))
114                 queues |= BIT(mvm->aux_queue);
115
116         iwl_mvm_unref(mvm, IWL_MVM_REF_ROC);
117
118         synchronize_net();
119
120         /*
121          * Flush the offchannel queue -- this is called when the time
122          * event finishes or is cancelled, so that frames queued for it
123          * won't get stuck on the queue and be transmitted in the next
124          * time event.
125          * We have to send the command asynchronously since this cannot
126          * be under the mutex for locking reasons, but that's not an
127          * issue as it will have to complete before the next command is
128          * executed, and a new time event means a new command.
129          */
130         iwl_mvm_flush_tx_path(mvm, queues, false);
131 }
132
133 static void iwl_mvm_roc_finished(struct iwl_mvm *mvm)
134 {
135         /*
136          * Of course, our status bit is just as racy as mac80211, so in
137          * addition, fire off the work struct which will drop all frames
138          * from the hardware queues that made it through the race. First
139          * it will of course synchronize the TX path to make sure that
140          * any *new* TX will be rejected.
141          */
142         schedule_work(&mvm->roc_done_wk);
143 }
144
145 static void iwl_mvm_csa_noa_start(struct iwl_mvm *mvm)
146 {
147         struct ieee80211_vif *csa_vif;
148
149         rcu_read_lock();
150
151         csa_vif = rcu_dereference(mvm->csa_vif);
152         if (!csa_vif || !csa_vif->csa_active)
153                 goto out_unlock;
154
155         IWL_DEBUG_TE(mvm, "CSA NOA started\n");
156
157         /*
158          * CSA NoA is started but we still have beacons to
159          * transmit on the current channel.
160          * So we just do nothing here and the switch
161          * will be performed on the last TBTT.
162          */
163         if (!ieee80211_csa_is_complete(csa_vif)) {
164                 IWL_WARN(mvm, "CSA NOA started too early\n");
165                 goto out_unlock;
166         }
167
168         ieee80211_csa_finish(csa_vif);
169
170         rcu_read_unlock();
171
172         RCU_INIT_POINTER(mvm->csa_vif, NULL);
173
174         return;
175
176 out_unlock:
177         rcu_read_unlock();
178 }
179
180 static bool iwl_mvm_te_check_disconnect(struct iwl_mvm *mvm,
181                                         struct ieee80211_vif *vif,
182                                         const char *errmsg)
183 {
184         if (vif->type != NL80211_IFTYPE_STATION)
185                 return false;
186         if (vif->bss_conf.assoc && vif->bss_conf.dtim_period)
187                 return false;
188         if (errmsg)
189                 IWL_ERR(mvm, "%s\n", errmsg);
190         ieee80211_connection_loss(vif);
191         return true;
192 }
193
194 static void
195 iwl_mvm_te_handle_notify_csa(struct iwl_mvm *mvm,
196                              struct iwl_mvm_time_event_data *te_data,
197                              struct iwl_time_event_notif *notif)
198 {
199         if (!le32_to_cpu(notif->status)) {
200                 if (te_data->vif->type == NL80211_IFTYPE_STATION)
201                         ieee80211_connection_loss(te_data->vif);
202                 IWL_DEBUG_TE(mvm, "CSA time event failed to start\n");
203                 iwl_mvm_te_clear_data(mvm, te_data);
204                 return;
205         }
206
207         switch (te_data->vif->type) {
208         case NL80211_IFTYPE_AP:
209                 iwl_mvm_csa_noa_start(mvm);
210                 break;
211         case NL80211_IFTYPE_STATION:
212                 iwl_mvm_csa_client_absent(mvm, te_data->vif);
213                 ieee80211_chswitch_done(te_data->vif, true);
214                 break;
215         default:
216                 /* should never happen */
217                 WARN_ON_ONCE(1);
218                 break;
219         }
220
221         /* we don't need it anymore */
222         iwl_mvm_te_clear_data(mvm, te_data);
223 }
224
225 /*
226  * Handles a FW notification for an event that is known to the driver.
227  *
228  * @mvm: the mvm component
229  * @te_data: the time event data
230  * @notif: the notification data corresponding the time event data.
231  */
232 static void iwl_mvm_te_handle_notif(struct iwl_mvm *mvm,
233                                     struct iwl_mvm_time_event_data *te_data,
234                                     struct iwl_time_event_notif *notif)
235 {
236         lockdep_assert_held(&mvm->time_event_lock);
237
238         IWL_DEBUG_TE(mvm, "Handle time event notif - UID = 0x%x action %d\n",
239                      le32_to_cpu(notif->unique_id),
240                      le32_to_cpu(notif->action));
241
242         /*
243          * The FW sends the start/end time event notifications even for events
244          * that it fails to schedule. This is indicated in the status field of
245          * the notification. This happens in cases that the scheduler cannot
246          * find a schedule that can handle the event (for example requesting a
247          * P2P Device discoveribility, while there are other higher priority
248          * events in the system).
249          */
250         if (!le32_to_cpu(notif->status)) {
251                 bool start = le32_to_cpu(notif->action) &
252                                 TE_V2_NOTIF_HOST_EVENT_START;
253                 IWL_WARN(mvm, "Time Event %s notification failure\n",
254                          start ? "start" : "end");
255                 if (iwl_mvm_te_check_disconnect(mvm, te_data->vif, NULL)) {
256                         iwl_mvm_te_clear_data(mvm, te_data);
257                         return;
258                 }
259         }
260
261         if (le32_to_cpu(notif->action) & TE_V2_NOTIF_HOST_EVENT_END) {
262                 IWL_DEBUG_TE(mvm,
263                              "TE ended - current time %lu, estimated end %lu\n",
264                              jiffies, te_data->end_jiffies);
265
266                 switch (te_data->vif->type) {
267                 case NL80211_IFTYPE_P2P_DEVICE:
268                         ieee80211_remain_on_channel_expired(mvm->hw);
269                         iwl_mvm_roc_finished(mvm);
270                         break;
271                 case NL80211_IFTYPE_STATION:
272                         /*
273                          * By now, we should have finished association
274                          * and know the dtim period.
275                          */
276                         iwl_mvm_te_check_disconnect(mvm, te_data->vif,
277                                 "No association and the time event is over already...");
278                         break;
279                 default:
280                         break;
281                 }
282
283                 iwl_mvm_te_clear_data(mvm, te_data);
284         } else if (le32_to_cpu(notif->action) & TE_V2_NOTIF_HOST_EVENT_START) {
285                 te_data->running = true;
286                 te_data->end_jiffies = TU_TO_EXP_TIME(te_data->duration);
287
288                 if (te_data->vif->type == NL80211_IFTYPE_P2P_DEVICE) {
289                         set_bit(IWL_MVM_STATUS_ROC_RUNNING, &mvm->status);
290                         iwl_mvm_ref(mvm, IWL_MVM_REF_ROC);
291                         ieee80211_ready_on_channel(mvm->hw);
292                 } else if (te_data->id == TE_CHANNEL_SWITCH_PERIOD) {
293                         iwl_mvm_te_handle_notify_csa(mvm, te_data, notif);
294                 }
295         } else {
296                 IWL_WARN(mvm, "Got TE with unknown action\n");
297         }
298 }
299
300 /*
301  * Handle A Aux ROC time event
302  */
303 static int iwl_mvm_aux_roc_te_handle_notif(struct iwl_mvm *mvm,
304                                            struct iwl_time_event_notif *notif)
305 {
306         struct iwl_mvm_time_event_data *te_data, *tmp;
307         bool aux_roc_te = false;
308
309         list_for_each_entry_safe(te_data, tmp, &mvm->aux_roc_te_list, list) {
310                 if (le32_to_cpu(notif->unique_id) == te_data->uid) {
311                         aux_roc_te = true;
312                         break;
313                 }
314         }
315         if (!aux_roc_te) /* Not a Aux ROC time event */
316                 return -EINVAL;
317
318         if (!le32_to_cpu(notif->status)) {
319                 IWL_DEBUG_TE(mvm,
320                              "ERROR: Aux ROC Time Event %s notification failure\n",
321                              (le32_to_cpu(notif->action) &
322                               TE_V2_NOTIF_HOST_EVENT_START) ? "start" : "end");
323                 return -EINVAL;
324         }
325
326         IWL_DEBUG_TE(mvm,
327                      "Aux ROC time event notification  - UID = 0x%x action %d\n",
328                      le32_to_cpu(notif->unique_id),
329                      le32_to_cpu(notif->action));
330
331         if (le32_to_cpu(notif->action) == TE_V2_NOTIF_HOST_EVENT_END) {
332                 /* End TE, notify mac80211 */
333                 ieee80211_remain_on_channel_expired(mvm->hw);
334                 iwl_mvm_roc_finished(mvm); /* flush aux queue */
335                 list_del(&te_data->list); /* remove from list */
336                 te_data->running = false;
337                 te_data->vif = NULL;
338                 te_data->uid = 0;
339                 te_data->id = TE_MAX;
340         } else if (le32_to_cpu(notif->action) == TE_V2_NOTIF_HOST_EVENT_START) {
341                 set_bit(IWL_MVM_STATUS_ROC_AUX_RUNNING, &mvm->status);
342                 te_data->running = true;
343                 ieee80211_ready_on_channel(mvm->hw); /* Start TE */
344         } else {
345                 IWL_DEBUG_TE(mvm,
346                              "ERROR: Unknown Aux ROC Time Event (action = %d)\n",
347                              le32_to_cpu(notif->action));
348                 return -EINVAL;
349         }
350
351         return 0;
352 }
353
354 /*
355  * The Rx handler for time event notifications
356  */
357 int iwl_mvm_rx_time_event_notif(struct iwl_mvm *mvm,
358                                 struct iwl_rx_cmd_buffer *rxb,
359                                 struct iwl_device_cmd *cmd)
360 {
361         struct iwl_rx_packet *pkt = rxb_addr(rxb);
362         struct iwl_time_event_notif *notif = (void *)pkt->data;
363         struct iwl_mvm_time_event_data *te_data, *tmp;
364
365         IWL_DEBUG_TE(mvm, "Time event notification - UID = 0x%x action %d\n",
366                      le32_to_cpu(notif->unique_id),
367                      le32_to_cpu(notif->action));
368
369         spin_lock_bh(&mvm->time_event_lock);
370         /* This time event is triggered for Aux ROC request */
371         if (!iwl_mvm_aux_roc_te_handle_notif(mvm, notif))
372                 goto unlock;
373
374         list_for_each_entry_safe(te_data, tmp, &mvm->time_event_list, list) {
375                 if (le32_to_cpu(notif->unique_id) == te_data->uid)
376                         iwl_mvm_te_handle_notif(mvm, te_data, notif);
377         }
378 unlock:
379         spin_unlock_bh(&mvm->time_event_lock);
380
381         return 0;
382 }
383
384 static bool iwl_mvm_te_notif(struct iwl_notif_wait_data *notif_wait,
385                              struct iwl_rx_packet *pkt, void *data)
386 {
387         struct iwl_mvm *mvm =
388                 container_of(notif_wait, struct iwl_mvm, notif_wait);
389         struct iwl_mvm_time_event_data *te_data = data;
390         struct iwl_time_event_notif *resp;
391         int resp_len = iwl_rx_packet_payload_len(pkt);
392
393         if (WARN_ON(pkt->hdr.cmd != TIME_EVENT_NOTIFICATION))
394                 return true;
395
396         if (WARN_ON_ONCE(resp_len != sizeof(*resp))) {
397                 IWL_ERR(mvm, "Invalid TIME_EVENT_NOTIFICATION response\n");
398                 return true;
399         }
400
401         resp = (void *)pkt->data;
402
403         /* te_data->uid is already set in the TIME_EVENT_CMD response */
404         if (le32_to_cpu(resp->unique_id) != te_data->uid)
405                 return false;
406
407         IWL_DEBUG_TE(mvm, "TIME_EVENT_NOTIFICATION response - UID = 0x%x\n",
408                      te_data->uid);
409         if (!resp->status)
410                 IWL_ERR(mvm,
411                         "TIME_EVENT_NOTIFICATION received but not executed\n");
412
413         return true;
414 }
415
416 static bool iwl_mvm_time_event_response(struct iwl_notif_wait_data *notif_wait,
417                                         struct iwl_rx_packet *pkt, void *data)
418 {
419         struct iwl_mvm *mvm =
420                 container_of(notif_wait, struct iwl_mvm, notif_wait);
421         struct iwl_mvm_time_event_data *te_data = data;
422         struct iwl_time_event_resp *resp;
423         int resp_len = iwl_rx_packet_payload_len(pkt);
424
425         if (WARN_ON(pkt->hdr.cmd != TIME_EVENT_CMD))
426                 return true;
427
428         if (WARN_ON_ONCE(resp_len != sizeof(*resp))) {
429                 IWL_ERR(mvm, "Invalid TIME_EVENT_CMD response\n");
430                 return true;
431         }
432
433         resp = (void *)pkt->data;
434
435         /* we should never get a response to another TIME_EVENT_CMD here */
436         if (WARN_ON_ONCE(le32_to_cpu(resp->id) != te_data->id))
437                 return false;
438
439         te_data->uid = le32_to_cpu(resp->unique_id);
440         IWL_DEBUG_TE(mvm, "TIME_EVENT_CMD response - UID = 0x%x\n",
441                      te_data->uid);
442         return true;
443 }
444
445 static int iwl_mvm_time_event_send_add(struct iwl_mvm *mvm,
446                                        struct ieee80211_vif *vif,
447                                        struct iwl_mvm_time_event_data *te_data,
448                                        struct iwl_time_event_cmd *te_cmd)
449 {
450         static const u8 time_event_response[] = { TIME_EVENT_CMD };
451         struct iwl_notification_wait wait_time_event;
452         int ret;
453
454         lockdep_assert_held(&mvm->mutex);
455
456         IWL_DEBUG_TE(mvm, "Add new TE, duration %d TU\n",
457                      le32_to_cpu(te_cmd->duration));
458
459         spin_lock_bh(&mvm->time_event_lock);
460         if (WARN_ON(te_data->id != TE_MAX)) {
461                 spin_unlock_bh(&mvm->time_event_lock);
462                 return -EIO;
463         }
464         te_data->vif = vif;
465         te_data->duration = le32_to_cpu(te_cmd->duration);
466         te_data->id = le32_to_cpu(te_cmd->id);
467         list_add_tail(&te_data->list, &mvm->time_event_list);
468         spin_unlock_bh(&mvm->time_event_lock);
469
470         /*
471          * Use a notification wait, which really just processes the
472          * command response and doesn't wait for anything, in order
473          * to be able to process the response and get the UID inside
474          * the RX path. Using CMD_WANT_SKB doesn't work because it
475          * stores the buffer and then wakes up this thread, by which
476          * time another notification (that the time event started)
477          * might already be processed unsuccessfully.
478          */
479         iwl_init_notification_wait(&mvm->notif_wait, &wait_time_event,
480                                    time_event_response,
481                                    ARRAY_SIZE(time_event_response),
482                                    iwl_mvm_time_event_response, te_data);
483
484         ret = iwl_mvm_send_cmd_pdu(mvm, TIME_EVENT_CMD, 0,
485                                             sizeof(*te_cmd), te_cmd);
486         if (ret) {
487                 IWL_ERR(mvm, "Couldn't send TIME_EVENT_CMD: %d\n", ret);
488                 iwl_remove_notification(&mvm->notif_wait, &wait_time_event);
489                 goto out_clear_te;
490         }
491
492         /* No need to wait for anything, so just pass 1 (0 isn't valid) */
493         ret = iwl_wait_notification(&mvm->notif_wait, &wait_time_event, 1);
494         /* should never fail */
495         WARN_ON_ONCE(ret);
496
497         if (ret) {
498  out_clear_te:
499                 spin_lock_bh(&mvm->time_event_lock);
500                 iwl_mvm_te_clear_data(mvm, te_data);
501                 spin_unlock_bh(&mvm->time_event_lock);
502         }
503         return ret;
504 }
505
506 void iwl_mvm_protect_session(struct iwl_mvm *mvm,
507                              struct ieee80211_vif *vif,
508                              u32 duration, u32 min_duration,
509                              u32 max_delay, bool wait_for_notif)
510 {
511         struct iwl_mvm_vif *mvmvif = iwl_mvm_vif_from_mac80211(vif);
512         struct iwl_mvm_time_event_data *te_data = &mvmvif->time_event_data;
513         const u8 te_notif_response[] = { TIME_EVENT_NOTIFICATION };
514         struct iwl_notification_wait wait_te_notif;
515         struct iwl_time_event_cmd time_cmd = {};
516
517         lockdep_assert_held(&mvm->mutex);
518
519         if (te_data->running &&
520             time_after(te_data->end_jiffies, TU_TO_EXP_TIME(min_duration))) {
521                 IWL_DEBUG_TE(mvm, "We have enough time in the current TE: %u\n",
522                              jiffies_to_msecs(te_data->end_jiffies - jiffies));
523                 return;
524         }
525
526         if (te_data->running) {
527                 IWL_DEBUG_TE(mvm, "extend 0x%x: only %u ms left\n",
528                              te_data->uid,
529                              jiffies_to_msecs(te_data->end_jiffies - jiffies));
530                 /*
531                  * we don't have enough time
532                  * cancel the current TE and issue a new one
533                  * Of course it would be better to remove the old one only
534                  * when the new one is added, but we don't care if we are off
535                  * channel for a bit. All we need to do, is not to return
536                  * before we actually begin to be on the channel.
537                  */
538                 iwl_mvm_stop_session_protection(mvm, vif);
539         }
540
541         time_cmd.action = cpu_to_le32(FW_CTXT_ACTION_ADD);
542         time_cmd.id_and_color =
543                 cpu_to_le32(FW_CMD_ID_AND_COLOR(mvmvif->id, mvmvif->color));
544         time_cmd.id = cpu_to_le32(TE_BSS_STA_AGGRESSIVE_ASSOC);
545
546         time_cmd.apply_time =
547                 cpu_to_le32(iwl_read_prph(mvm->trans, DEVICE_SYSTEM_TIME_REG));
548
549         time_cmd.max_frags = TE_V2_FRAG_NONE;
550         time_cmd.max_delay = cpu_to_le32(max_delay);
551         /* TODO: why do we need to interval = bi if it is not periodic? */
552         time_cmd.interval = cpu_to_le32(1);
553         time_cmd.duration = cpu_to_le32(duration);
554         time_cmd.repeat = 1;
555         time_cmd.policy = cpu_to_le16(TE_V2_NOTIF_HOST_EVENT_START |
556                                       TE_V2_NOTIF_HOST_EVENT_END |
557                                       T2_V2_START_IMMEDIATELY);
558
559         if (!wait_for_notif) {
560                 iwl_mvm_time_event_send_add(mvm, vif, te_data, &time_cmd);
561                 return;
562         }
563
564         /*
565          * Create notification_wait for the TIME_EVENT_NOTIFICATION to use
566          * right after we send the time event
567          */
568         iwl_init_notification_wait(&mvm->notif_wait, &wait_te_notif,
569                                    te_notif_response,
570                                    ARRAY_SIZE(te_notif_response),
571                                    iwl_mvm_te_notif, te_data);
572
573         /* If TE was sent OK - wait for the notification that started */
574         if (iwl_mvm_time_event_send_add(mvm, vif, te_data, &time_cmd)) {
575                 IWL_ERR(mvm, "Failed to add TE to protect session\n");
576                 iwl_remove_notification(&mvm->notif_wait, &wait_te_notif);
577         } else if (iwl_wait_notification(&mvm->notif_wait, &wait_te_notif,
578                                          TU_TO_JIFFIES(max_delay))) {
579                 IWL_ERR(mvm, "Failed to protect session until TE\n");
580         }
581 }
582
583 static bool __iwl_mvm_remove_time_event(struct iwl_mvm *mvm,
584                                         struct iwl_mvm_time_event_data *te_data,
585                                         u32 *uid)
586 {
587         u32 id;
588
589         /*
590          * It is possible that by the time we got to this point the time
591          * event was already removed.
592          */
593         spin_lock_bh(&mvm->time_event_lock);
594
595         /* Save time event uid before clearing its data */
596         *uid = te_data->uid;
597         id = te_data->id;
598
599         /*
600          * The clear_data function handles time events that were already removed
601          */
602         iwl_mvm_te_clear_data(mvm, te_data);
603         spin_unlock_bh(&mvm->time_event_lock);
604
605         /*
606          * It is possible that by the time we try to remove it, the time event
607          * has already ended and removed. In such a case there is no need to
608          * send a removal command.
609          */
610         if (id == TE_MAX) {
611                 IWL_DEBUG_TE(mvm, "TE 0x%x has already ended\n", *uid);
612                 return false;
613         }
614
615         return true;
616 }
617
618 /*
619  * Explicit request to remove a aux roc time event. The removal of a time
620  * event needs to be synchronized with the flow of a time event's end
621  * notification, which also removes the time event from the op mode
622  * data structures.
623  */
624 static void iwl_mvm_remove_aux_roc_te(struct iwl_mvm *mvm,
625                                       struct iwl_mvm_vif *mvmvif,
626                                       struct iwl_mvm_time_event_data *te_data)
627 {
628         struct iwl_hs20_roc_req aux_cmd = {};
629         u32 uid;
630         int ret;
631
632         if (!__iwl_mvm_remove_time_event(mvm, te_data, &uid))
633                 return;
634
635         aux_cmd.event_unique_id = cpu_to_le32(uid);
636         aux_cmd.action = cpu_to_le32(FW_CTXT_ACTION_REMOVE);
637         aux_cmd.id_and_color =
638                 cpu_to_le32(FW_CMD_ID_AND_COLOR(mvmvif->id, mvmvif->color));
639         IWL_DEBUG_TE(mvm, "Removing BSS AUX ROC TE 0x%x\n",
640                      le32_to_cpu(aux_cmd.event_unique_id));
641         ret = iwl_mvm_send_cmd_pdu(mvm, HOT_SPOT_CMD, 0,
642                                    sizeof(aux_cmd), &aux_cmd);
643
644         if (WARN_ON(ret))
645                 return;
646 }
647
648 /*
649  * Explicit request to remove a time event. The removal of a time event needs to
650  * be synchronized with the flow of a time event's end notification, which also
651  * removes the time event from the op mode data structures.
652  */
653 void iwl_mvm_remove_time_event(struct iwl_mvm *mvm,
654                                struct iwl_mvm_vif *mvmvif,
655                                struct iwl_mvm_time_event_data *te_data)
656 {
657         struct iwl_time_event_cmd time_cmd = {};
658         u32 uid;
659         int ret;
660
661         if (!__iwl_mvm_remove_time_event(mvm, te_data, &uid))
662                 return;
663
664         /* When we remove a TE, the UID is to be set in the id field */
665         time_cmd.id = cpu_to_le32(uid);
666         time_cmd.action = cpu_to_le32(FW_CTXT_ACTION_REMOVE);
667         time_cmd.id_and_color =
668                 cpu_to_le32(FW_CMD_ID_AND_COLOR(mvmvif->id, mvmvif->color));
669
670         IWL_DEBUG_TE(mvm, "Removing TE 0x%x\n", le32_to_cpu(time_cmd.id));
671         ret = iwl_mvm_send_cmd_pdu(mvm, TIME_EVENT_CMD, 0,
672                                    sizeof(time_cmd), &time_cmd);
673         if (WARN_ON(ret))
674                 return;
675 }
676
677 void iwl_mvm_stop_session_protection(struct iwl_mvm *mvm,
678                                      struct ieee80211_vif *vif)
679 {
680         struct iwl_mvm_vif *mvmvif = iwl_mvm_vif_from_mac80211(vif);
681         struct iwl_mvm_time_event_data *te_data = &mvmvif->time_event_data;
682
683         lockdep_assert_held(&mvm->mutex);
684         iwl_mvm_remove_time_event(mvm, mvmvif, te_data);
685 }
686
687 int iwl_mvm_start_p2p_roc(struct iwl_mvm *mvm, struct ieee80211_vif *vif,
688                           int duration, enum ieee80211_roc_type type)
689 {
690         struct iwl_mvm_vif *mvmvif = iwl_mvm_vif_from_mac80211(vif);
691         struct iwl_mvm_time_event_data *te_data = &mvmvif->time_event_data;
692         struct iwl_time_event_cmd time_cmd = {};
693
694         lockdep_assert_held(&mvm->mutex);
695         if (te_data->running) {
696                 IWL_WARN(mvm, "P2P_DEVICE remain on channel already running\n");
697                 return -EBUSY;
698         }
699
700         /*
701          * Flush the done work, just in case it's still pending, so that
702          * the work it does can complete and we can accept new frames.
703          */
704         flush_work(&mvm->roc_done_wk);
705
706         time_cmd.action = cpu_to_le32(FW_CTXT_ACTION_ADD);
707         time_cmd.id_and_color =
708                 cpu_to_le32(FW_CMD_ID_AND_COLOR(mvmvif->id, mvmvif->color));
709
710         switch (type) {
711         case IEEE80211_ROC_TYPE_NORMAL:
712                 time_cmd.id = cpu_to_le32(IWL_MVM_ROC_TE_TYPE_NORMAL);
713                 break;
714         case IEEE80211_ROC_TYPE_MGMT_TX:
715                 time_cmd.id = cpu_to_le32(IWL_MVM_ROC_TE_TYPE_MGMT_TX);
716                 break;
717         default:
718                 WARN_ONCE(1, "Got an invalid ROC type\n");
719                 return -EINVAL;
720         }
721
722         time_cmd.apply_time = cpu_to_le32(0);
723         time_cmd.interval = cpu_to_le32(1);
724
725         /*
726          * The P2P Device TEs can have lower priority than other events
727          * that are being scheduled by the driver/fw, and thus it might not be
728          * scheduled. To improve the chances of it being scheduled, allow them
729          * to be fragmented, and in addition allow them to be delayed.
730          */
731         time_cmd.max_frags = min(MSEC_TO_TU(duration)/50, TE_V2_FRAG_ENDLESS);
732         time_cmd.max_delay = cpu_to_le32(MSEC_TO_TU(duration/2));
733         time_cmd.duration = cpu_to_le32(MSEC_TO_TU(duration));
734         time_cmd.repeat = 1;
735         time_cmd.policy = cpu_to_le16(TE_V2_NOTIF_HOST_EVENT_START |
736                                       TE_V2_NOTIF_HOST_EVENT_END |
737                                       T2_V2_START_IMMEDIATELY);
738
739         return iwl_mvm_time_event_send_add(mvm, vif, te_data, &time_cmd);
740 }
741
742 void iwl_mvm_stop_roc(struct iwl_mvm *mvm)
743 {
744         struct iwl_mvm_vif *mvmvif;
745         struct iwl_mvm_time_event_data *te_data;
746         bool is_p2p = false;
747
748         lockdep_assert_held(&mvm->mutex);
749
750         mvmvif = NULL;
751         spin_lock_bh(&mvm->time_event_lock);
752
753         /*
754          * Iterate over the list of time events and find the time event that is
755          * associated with a P2P_DEVICE interface.
756          * This assumes that a P2P_DEVICE interface can have only a single time
757          * event at any given time and this time event coresponds to a ROC
758          * request
759          */
760         list_for_each_entry(te_data, &mvm->time_event_list, list) {
761                 if (te_data->vif->type == NL80211_IFTYPE_P2P_DEVICE) {
762                         mvmvif = iwl_mvm_vif_from_mac80211(te_data->vif);
763                         is_p2p = true;
764                         goto remove_te;
765                 }
766         }
767
768         /*
769          * Iterate over the list of aux roc time events and find the time
770          * event that is associated with a BSS interface.
771          * This assumes that a BSS interface can have only a single time
772          * event at any given time and this time event coresponds to a ROC
773          * request
774          */
775         list_for_each_entry(te_data, &mvm->aux_roc_te_list, list) {
776                 mvmvif = iwl_mvm_vif_from_mac80211(te_data->vif);
777                 goto remove_te;
778         }
779
780 remove_te:
781         spin_unlock_bh(&mvm->time_event_lock);
782
783         if (!mvmvif) {
784                 IWL_WARN(mvm, "No remain on channel event\n");
785                 return;
786         }
787
788         if (is_p2p)
789                 iwl_mvm_remove_time_event(mvm, mvmvif, te_data);
790         else
791                 iwl_mvm_remove_aux_roc_te(mvm, mvmvif, te_data);
792
793         iwl_mvm_roc_finished(mvm);
794 }
795
796 int iwl_mvm_schedule_csa_period(struct iwl_mvm *mvm,
797                                 struct ieee80211_vif *vif,
798                                 u32 duration, u32 apply_time)
799 {
800         struct iwl_mvm_vif *mvmvif = iwl_mvm_vif_from_mac80211(vif);
801         struct iwl_mvm_time_event_data *te_data = &mvmvif->time_event_data;
802         struct iwl_time_event_cmd time_cmd = {};
803
804         lockdep_assert_held(&mvm->mutex);
805
806         if (te_data->running) {
807                 IWL_DEBUG_TE(mvm, "CS period is already scheduled\n");
808                 return -EBUSY;
809         }
810
811         time_cmd.action = cpu_to_le32(FW_CTXT_ACTION_ADD);
812         time_cmd.id_and_color =
813                 cpu_to_le32(FW_CMD_ID_AND_COLOR(mvmvif->id, mvmvif->color));
814         time_cmd.id = cpu_to_le32(TE_CHANNEL_SWITCH_PERIOD);
815         time_cmd.apply_time = cpu_to_le32(apply_time);
816         time_cmd.max_frags = TE_V2_FRAG_NONE;
817         time_cmd.duration = cpu_to_le32(duration);
818         time_cmd.repeat = 1;
819         time_cmd.interval = cpu_to_le32(1);
820         time_cmd.policy = cpu_to_le16(TE_V2_NOTIF_HOST_EVENT_START |
821                                       TE_V2_ABSENCE);
822
823         return iwl_mvm_time_event_send_add(mvm, vif, te_data, &time_cmd);
824 }