Bluetooth: Use kthread API in cmtp
authorSzymon Janc <szymon.janc@tieto.com>
Mon, 21 Mar 2011 13:20:06 +0000 (14:20 +0100)
committerGustavo F. Padovan <padovan@profusion.mobi>
Tue, 5 Apr 2011 15:40:47 +0000 (12:40 -0300)
kernel_thread() is a low-level implementation detail and
EXPORT_SYMBOL(kernel_thread) is scheduled for removal.
Use the <linux/kthread.h> API instead.

Signed-off-by: Szymon Janc <szymon.janc@tieto.com>
Signed-off-by: Gustavo F. Padovan <padovan@profusion.mobi>
net/bluetooth/cmtp/capi.c
net/bluetooth/cmtp/cmtp.h
net/bluetooth/cmtp/core.c

index 67cff810c77d19c4755634d7cf4f3093a68f0d9a..744233cba244bc8c1f89f71a0102e1d69dc1d856 100644 (file)
@@ -35,6 +35,7 @@
 #include <linux/ioctl.h>
 #include <linux/file.h>
 #include <linux/wait.h>
+#include <linux/kthread.h>
 #include <net/sock.h>
 
 #include <linux/isdn/capilli.h>
@@ -143,7 +144,7 @@ static void cmtp_send_capimsg(struct cmtp_session *session, struct sk_buff *skb)
 
        skb_queue_tail(&session->transmit, skb);
 
-       cmtp_schedule(session);
+       wake_up_interruptible(sk_sleep(session->sock->sk));
 }
 
 static void cmtp_send_interopmsg(struct cmtp_session *session,
@@ -386,8 +387,7 @@ static void cmtp_reset_ctr(struct capi_ctr *ctrl)
 
        capi_ctr_down(ctrl);
 
-       atomic_inc(&session->terminate);
-       cmtp_schedule(session);
+       kthread_stop(session->task);
 }
 
 static void cmtp_register_appl(struct capi_ctr *ctrl, __u16 appl, capi_register_params *rp)
index c6f78f89415cb1aabe86e71a1bc5d54140fb2a5c..db43b54ac9afb91cfc78f911f8a15c05104fe7ed 100644 (file)
@@ -81,7 +81,7 @@ struct cmtp_session {
 
        char name[BTNAMSIZ];
 
-       atomic_t terminate;
+       struct task_struct *task;
 
        wait_queue_head_t wait;
 
@@ -121,13 +121,6 @@ void cmtp_detach_device(struct cmtp_session *session);
 
 void cmtp_recv_capimsg(struct cmtp_session *session, struct sk_buff *skb);
 
-static inline void cmtp_schedule(struct cmtp_session *session)
-{
-       struct sock *sk = session->sock->sk;
-
-       wake_up_interruptible(sk_sleep(sk));
-}
-
 /* CMTP init defines */
 int cmtp_init_sockets(void);
 void cmtp_cleanup_sockets(void);
index 16aa6bd039ba085b34488718469ea3c668413daf..cce99b0919f50ec39b1a0029dc21fdb57ba29d09 100644 (file)
@@ -35,6 +35,7 @@
 #include <linux/ioctl.h>
 #include <linux/file.h>
 #include <linux/init.h>
+#include <linux/kthread.h>
 #include <net/sock.h>
 
 #include <linux/isdn/capilli.h>
@@ -287,12 +288,11 @@ static int cmtp_session(void *arg)
 
        BT_DBG("session %p", session);
 
-       daemonize("kcmtpd_ctr_%d", session->num);
        set_user_nice(current, -15);
 
        init_waitqueue_entry(&wait, current);
        add_wait_queue(sk_sleep(sk), &wait);
-       while (!atomic_read(&session->terminate)) {
+       while (!kthread_should_stop()) {
                set_current_state(TASK_INTERRUPTIBLE);
 
                if (sk->sk_state != BT_CONNECTED)
@@ -370,9 +370,12 @@ int cmtp_add_connection(struct cmtp_connadd_req *req, struct socket *sock)
 
        __cmtp_link_session(session);
 
-       err = kernel_thread(cmtp_session, session, CLONE_KERNEL);
-       if (err < 0)
+       session->task = kthread_run(cmtp_session, session, "kcmtpd_ctr_%d",
+                                                               session->num);
+       if (IS_ERR(session->task)) {
+               err = PTR_ERR(session->task);
                goto unlink;
+       }
 
        if (!(session->flags & (1 << CMTP_LOOPBACK))) {
                err = cmtp_attach_device(session);
@@ -409,9 +412,8 @@ int cmtp_del_connection(struct cmtp_conndel_req *req)
                /* Flush the transmit queue */
                skb_queue_purge(&session->transmit);
 
-               /* Kill session thread */
-               atomic_inc(&session->terminate);
-               cmtp_schedule(session);
+               /* Stop session thread */
+               kthread_stop(session->task);
        } else
                err = -ENOENT;