Commit 7716314b authored by Jason Cooper's avatar Jason Cooper Committed by Greg Kroah-Hartman

staging: brcm80211: remove kernel_thread() for wl_iscan_thread and wl_event_thread.

Replace kernel_thread() with kthread_run().  Replace pid with tsk,
and exited with kthread_stop()/kthread_should_stop().

event_tsk, and tsk are NULL when their respective threads are not running.
Signed-off-by: default avatarJason Cooper <jason@lakedaemon.net>
Signed-off-by: default avatarGreg Kroah-Hartman <gregkh@suse.de>
parent 5e2773ea
...@@ -35,6 +35,7 @@ ...@@ -35,6 +35,7 @@
#include <dhd.h> #include <dhd.h>
#include <linux/kernel.h> #include <linux/kernel.h>
#include <linux/kthread.h>
#include <linux/netdevice.h> #include <linux/netdevice.h>
#include <linux/sched.h> #include <linux/sched.h>
#include <linux/etherdevice.h> #include <linux/etherdevice.h>
...@@ -2848,21 +2849,20 @@ static void wl_deinit_priv_mem(struct wl_priv *wl) ...@@ -2848,21 +2849,20 @@ static void wl_deinit_priv_mem(struct wl_priv *wl)
static s32 wl_create_event_handler(struct wl_priv *wl) static s32 wl_create_event_handler(struct wl_priv *wl)
{ {
sema_init(&wl->event_sync, 0); sema_init(&wl->event_sync, 0);
init_completion(&wl->event_exit); wl->event_tsk = kthread_run(wl_event_handler, wl, "wl_event_handler");
wl->event_pid = kernel_thread(wl_event_handler, wl, 0); if (IS_ERR(wl->event_tsk)) {
if (unlikely(wl->event_pid < 0)) { wl->event_tsk = NULL;
WL_ERR(("failed to create event thread\n")); WL_ERR(("failed to create event thread\n"));
return -ENOMEM; return -ENOMEM;
} }
WL_DBG(("pid %d\n", wl->event_pid));
return 0; return 0;
} }
static void wl_destroy_event_handler(struct wl_priv *wl) static void wl_destroy_event_handler(struct wl_priv *wl)
{ {
if (wl->event_pid >= 0) { if (wl->event_tsk) {
KILL_PROC(wl->event_pid, SIGTERM); kthread_stop(wl->event_tsk);
wait_for_completion(&wl->event_exit); wl->event_tsk = NULL;
} }
} }
...@@ -2870,11 +2870,10 @@ static void wl_term_iscan(struct wl_priv *wl) ...@@ -2870,11 +2870,10 @@ static void wl_term_iscan(struct wl_priv *wl)
{ {
struct wl_iscan_ctrl *iscan = wl_to_iscan(wl); struct wl_iscan_ctrl *iscan = wl_to_iscan(wl);
if (wl->iscan_on && iscan->pid >= 0) { if (wl->iscan_on && iscan->tsk) {
iscan->state = WL_ISCAN_STATE_IDLE; iscan->state = WL_ISCAN_STATE_IDLE;
KILL_PROC(iscan->pid, SIGTERM); kthread_stop(iscan->tsk);
wait_for_completion(&iscan->exited); iscan->tsk = NULL;
iscan->pid = -1;
} }
} }
...@@ -3009,6 +3008,8 @@ static s32 wl_iscan_thread(void *data) ...@@ -3009,6 +3008,8 @@ static s32 wl_iscan_thread(void *data)
sched_setscheduler(current, SCHED_FIFO, &param); sched_setscheduler(current, SCHED_FIFO, &param);
status = WL_SCAN_RESULTS_PARTIAL; status = WL_SCAN_RESULTS_PARTIAL;
while (likely(!down_interruptible(&iscan->sync))) { while (likely(!down_interruptible(&iscan->sync))) {
if (kthread_should_stop())
break;
if (iscan->timer_on) { if (iscan->timer_on) {
del_timer_sync(&iscan->timer); del_timer_sync(&iscan->timer);
iscan->timer_on = 0; iscan->timer_on = 0;
...@@ -3026,7 +3027,6 @@ static s32 wl_iscan_thread(void *data) ...@@ -3026,7 +3027,6 @@ static s32 wl_iscan_thread(void *data)
del_timer_sync(&iscan->timer); del_timer_sync(&iscan->timer);
iscan->timer_on = 0; iscan->timer_on = 0;
} }
complete_and_exit(&iscan->exited, 0);
return 0; return 0;
} }
...@@ -3047,13 +3047,13 @@ static s32 wl_invoke_iscan(struct wl_priv *wl) ...@@ -3047,13 +3047,13 @@ static s32 wl_invoke_iscan(struct wl_priv *wl)
struct wl_iscan_ctrl *iscan = wl_to_iscan(wl); struct wl_iscan_ctrl *iscan = wl_to_iscan(wl);
int err = 0; int err = 0;
if (wl->iscan_on && iscan->pid < 0) { if (wl->iscan_on && !iscan->tsk) {
iscan->state = WL_ISCAN_STATE_IDLE; iscan->state = WL_ISCAN_STATE_IDLE;
sema_init(&iscan->sync, 0); sema_init(&iscan->sync, 0);
init_completion(&iscan->exited); iscan->tsk = kthread_run(wl_iscan_thread, iscan, "wl_iscan");
iscan->pid = kernel_thread(wl_iscan_thread, iscan, 0); if (IS_ERR(iscan->tsk)) {
if (unlikely(iscan->pid < 0)) {
WL_ERR(("Could not create iscan thread\n")); WL_ERR(("Could not create iscan thread\n"));
iscan->tsk = NULL;
return -ENOMEM; return -ENOMEM;
} }
} }
...@@ -3085,10 +3085,10 @@ static s32 wl_init_iscan(struct wl_priv *wl) ...@@ -3085,10 +3085,10 @@ static s32 wl_init_iscan(struct wl_priv *wl)
iscan->timer.data = (unsigned long) iscan; iscan->timer.data = (unsigned long) iscan;
iscan->timer.function = wl_iscan_timer; iscan->timer.function = wl_iscan_timer;
sema_init(&iscan->sync, 0); sema_init(&iscan->sync, 0);
init_completion(&iscan->exited); iscan->tsk = kthread_run(wl_iscan_thread, iscan, "wl_iscan");
iscan->pid = kernel_thread(wl_iscan_thread, iscan, 0); if (IS_ERR(iscan->tsk)) {
if (unlikely(iscan->pid < 0)) {
WL_ERR(("Could not create iscan thread\n")); WL_ERR(("Could not create iscan thread\n"));
iscan->tsk = NULL;
return -ENOMEM; return -ENOMEM;
} }
iscan->data = wl; iscan->data = wl;
...@@ -3228,6 +3228,8 @@ static s32 wl_event_handler(void *data) ...@@ -3228,6 +3228,8 @@ static s32 wl_event_handler(void *data)
sched_setscheduler(current, SCHED_FIFO, &param); sched_setscheduler(current, SCHED_FIFO, &param);
while (likely(!down_interruptible(&wl->event_sync))) { while (likely(!down_interruptible(&wl->event_sync))) {
if(kthread_should_stop())
break;
e = wl_deq_event(wl); e = wl_deq_event(wl);
if (unlikely(!e)) { if (unlikely(!e)) {
WL_ERR(("eqeue empty..\n")); WL_ERR(("eqeue empty..\n"));
...@@ -3242,7 +3244,7 @@ static s32 wl_event_handler(void *data) ...@@ -3242,7 +3244,7 @@ static s32 wl_event_handler(void *data)
} }
wl_put_event(e); wl_put_event(e);
} }
complete_and_exit(&wl->event_exit, 0); return 0;
} }
void void
......
...@@ -247,9 +247,8 @@ struct wl_iscan_ctrl { ...@@ -247,9 +247,8 @@ struct wl_iscan_ctrl {
u32 timer_ms; u32 timer_ms;
u32 timer_on; u32 timer_on;
s32 state; s32 state;
s32 pid; struct task_struct *tsk;
struct semaphore sync; struct semaphore sync;
struct completion exited;
struct wl_iscan_eloop el; struct wl_iscan_eloop el;
void *data; void *data;
s8 ioctl_buf[WLC_IOCTL_SMLEN]; s8 ioctl_buf[WLC_IOCTL_SMLEN];
...@@ -307,7 +306,6 @@ struct wl_priv { ...@@ -307,7 +306,6 @@ struct wl_priv {
struct ether_addr bssid; /* bssid of currently engaged network */ struct ether_addr bssid; /* bssid of currently engaged network */
struct semaphore event_sync; /* for synchronization of main event struct semaphore event_sync; /* for synchronization of main event
thread */ thread */
struct completion event_exit;
struct wl_profile *profile; /* holding dongle profile */ struct wl_profile *profile; /* holding dongle profile */
struct wl_iscan_ctrl *iscan; /* iscan controller */ struct wl_iscan_ctrl *iscan; /* iscan controller */
struct wl_connect_info conn_info; /* association information struct wl_connect_info conn_info; /* association information
...@@ -315,7 +313,7 @@ struct wl_priv { ...@@ -315,7 +313,7 @@ struct wl_priv {
struct wl_fw_ctrl *fw; /* control firwmare / nvram paramter struct wl_fw_ctrl *fw; /* control firwmare / nvram paramter
downloading */ downloading */
struct wl_pmk_list *pmk_list; /* wpa2 pmk list */ struct wl_pmk_list *pmk_list; /* wpa2 pmk list */
s32 event_pid; /* pid of main event handler thread */ struct task_struct *event_tsk; /* task of main event handler thread */
unsigned long status; /* current dongle status */ unsigned long status; /* current dongle status */
void *pub; void *pub;
u32 channel; /* current channel */ u32 channel; /* current channel */
......
Markdown is supported
0%
or
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment