2 * Copyright (c) 2010 Broadcom Corporation
4 * Permission to use, copy, modify, and/or distribute this software for any
5 * purpose with or without fee is hereby granted, provided that the above
6 * copyright notice and this permission notice appear in all copies.
8 * THE SOFTWARE IS PROVIDED "AS IS" AND THE AUTHOR DISCLAIMS ALL WARRANTIES
9 * WITH REGARD TO THIS SOFTWARE INCLUDING ALL IMPLIED WARRANTIES OF
10 * MERCHANTABILITY AND FITNESS. IN NO EVENT SHALL THE AUTHOR BE LIABLE FOR ANY
11 * SPECIAL, DIRECT, INDIRECT, OR CONSEQUENTIAL DAMAGES OR ANY DAMAGES
12 * WHATSOEVER RESULTING FROM LOSS OF USE, DATA OR PROFITS, WHETHER IN AN ACTION
13 * OF CONTRACT, NEGLIGENCE OR OTHER TORTIOUS ACTION, ARISING OUT OF OR IN
14 * CONNECTION WITH THE USE OR PERFORMANCE OF THIS SOFTWARE.
20 #include <bcmendian.h>
26 #include <wl_export.h>
27 #include <wlc_event.h>
31 #include <wlc_mac80211.h>
36 /* Local prototypes */
37 static void wlc_timer_cb(void *arg
);
39 /* Private data structures */
48 struct wl_timer
*timer
;
50 uint8 event_inds_mask
[ROUNDUP(WLC_E_LAST
, NBBY
) / NBBY
];
56 wlc_eventq_t
*BCMATTACHFN(wlc_eventq_attach
) (wlc_pub_t
*pub
,
57 struct wlc_info
*wlc
, void *wl
,
61 eq
= (wlc_eventq_t
*) MALLOC(pub
->osh
, sizeof(wlc_eventq_t
));
65 bzero(eq
, sizeof(wlc_eventq_t
));
72 if (!(eq
->timer
= wl_init_timer(eq
->wl
, wlc_timer_cb
, eq
, "eventq"))) {
73 WL_ERROR(("wl%d: wlc_eventq_attach: timer failed\n",
75 MFREE(eq
->pub
->osh
, eq
, sizeof(wlc_eventq_t
));
82 int BCMATTACHFN(wlc_eventq_detach
) (wlc_eventq_t
*eq
) {
83 /* Clean up pending events */
88 wl_del_timer(eq
->wl
, eq
->timer
);
91 wl_free_timer(eq
->wl
, eq
->timer
);
95 ASSERT(wlc_eventq_avail(eq
) == FALSE
);
96 MFREE(eq
->pub
->osh
, eq
, sizeof(wlc_eventq_t
));
100 int BCMUNINITFN(wlc_eventq_down
) (wlc_eventq_t
*eq
) {
102 if (eq
->tpending
&& !eq
->workpending
) {
103 if (!wl_del_timer(eq
->wl
, eq
->timer
))
106 ASSERT(wlc_eventq_avail(eq
) == TRUE
);
107 ASSERT(eq
->workpending
== FALSE
);
108 eq
->workpending
= TRUE
;
112 ASSERT(eq
->workpending
== TRUE
);
113 eq
->workpending
= FALSE
;
114 eq
->tpending
= FALSE
;
116 ASSERT(eq
->workpending
|| wlc_eventq_avail(eq
) == FALSE
);
121 wlc_event_t
*wlc_event_alloc(wlc_eventq_t
*eq
)
125 e
= MALLOC(eq
->pub
->osh
, sizeof(wlc_event_t
));
130 bzero(e
, sizeof(wlc_event_t
));
134 void wlc_event_free(wlc_eventq_t
*eq
, wlc_event_t
*e
)
136 ASSERT(e
->data
== NULL
);
137 ASSERT(e
->next
== NULL
);
138 MFREE(eq
->pub
->osh
, e
, sizeof(wlc_event_t
));
141 void wlc_eventq_enq(wlc_eventq_t
*eq
, wlc_event_t
*e
)
143 ASSERT(e
->next
== NULL
);
150 eq
->head
= eq
->tail
= e
;
154 /* Use a zero-delay timer to trigger
155 * delayed processing of the event.
157 wl_add_timer(eq
->wl
, eq
->timer
, 0, 0);
161 wlc_event_t
*wlc_eventq_deq(wlc_eventq_t
*eq
)
170 if (eq
->head
== NULL
)
176 wlc_event_t
*wlc_eventq_next(wlc_eventq_t
*eq
, wlc_event_t
*e
)
181 for (etmp
= eq
->head
; etmp
; etmp
= etmp
->next
) {
185 ASSERT(etmp
!= NULL
);
191 int wlc_eventq_cnt(wlc_eventq_t
*eq
)
196 for (etmp
= eq
->head
; etmp
; etmp
= etmp
->next
)
202 bool wlc_eventq_avail(wlc_eventq_t
*eq
)
204 return (eq
->head
!= NULL
);
210 static void wlc_timer_cb(void *arg
)
212 struct wlc_eventq
*eq
= (struct wlc_eventq
*)arg
;
214 ASSERT(eq
->tpending
== TRUE
);
215 ASSERT(wlc_eventq_avail(eq
) == TRUE
);
216 ASSERT(eq
->workpending
== FALSE
);
217 eq
->workpending
= TRUE
;
222 ASSERT(wlc_eventq_avail(eq
) == FALSE
);
223 ASSERT(eq
->tpending
== TRUE
);
224 eq
->workpending
= FALSE
;
225 eq
->tpending
= FALSE
;