Skip to content

Commit

Permalink
Bluetooth: cmtp: Fix deadlock in session deletion
Browse files Browse the repository at this point in the history
Commit fada4ac introduced the usage of kthread API.
kthread_stop is a blocking function which returns only when
the thread exits. In this case, the thread can't exit because it's
waiting for the write lock, which is being held by cmtp_del_connection()
which is waiting for the thread to exit -- deadlock.

Revert cmtp_reset_ctr to its original behavior: non-blocking signalling
for the session to terminate.

Signed-off-by: Peter Hurley <peter@hurleysoftware.com>
Signed-off-by: Gustavo F. Padovan <padovan@profusion.mobi>
  • Loading branch information
Peter Hurley authored and Gustavo F. Padovan committed Aug 11, 2011
1 parent 751c10a commit 7176522
Show file tree
Hide file tree
Showing 3 changed files with 6 additions and 3 deletions.
3 changes: 2 additions & 1 deletion net/bluetooth/cmtp/capi.c
Original file line number Diff line number Diff line change
Expand Up @@ -386,7 +386,8 @@ static void cmtp_reset_ctr(struct capi_ctr *ctrl)

capi_ctr_down(ctrl);

kthread_stop(session->task);
atomic_inc(&session->terminate);
wake_up_process(session->task);
}

static void cmtp_register_appl(struct capi_ctr *ctrl, __u16 appl, capi_register_params *rp)
Expand Down
1 change: 1 addition & 0 deletions net/bluetooth/cmtp/cmtp.h
Original file line number Diff line number Diff line change
Expand Up @@ -81,6 +81,7 @@ struct cmtp_session {

char name[BTNAMSIZ];

atomic_t terminate;
struct task_struct *task;

wait_queue_head_t wait;
Expand Down
5 changes: 3 additions & 2 deletions net/bluetooth/cmtp/core.c
Original file line number Diff line number Diff line change
Expand Up @@ -295,7 +295,7 @@ static int cmtp_session(void *arg)
while (1) {
set_current_state(TASK_INTERRUPTIBLE);

if (kthread_should_stop())
if (atomic_read(&session->terminate))
break;
if (sk->sk_state != BT_CONNECTED)
break;
Expand Down Expand Up @@ -416,7 +416,8 @@ int cmtp_del_connection(struct cmtp_conndel_req *req)
skb_queue_purge(&session->transmit);

/* Stop session thread */
kthread_stop(session->task);
atomic_inc(&session->terminate);
wake_up_process(session->task);
} else
err = -ENOENT;

Expand Down

0 comments on commit 7176522

Please sign in to comment.