X-Git-Url: https://git.whamcloud.com/?p=fs%2Flustre-release.git;a=blobdiff_plain;f=lustre%2Fosp%2Flwp_dev.c;h=6fdf9506ed52414189acbe14afbf63f79456c012;hp=2c053524386efa05ce011b996b8945c3414c821c;hb=051f0adeb0615da83c819ff74da467bb4117ae63;hpb=ffc843a0aacd78495b1cff51344aaee3e32fc2de

diff --git a/lustre/osp/lwp_dev.c b/lustre/osp/lwp_dev.c
index 2c05352..6fdf950 100644
--- a/lustre/osp/lwp_dev.c
+++ b/lustre/osp/lwp_dev.c
@@ -21,7 +21,7 @@
  * GPL HEADER END
  */
 /*
- * Copyright (c) 2013, 2016, Intel Corporation.
+ * Copyright (c) 2013, 2017, Intel Corporation.
  * Use is subject to license terms.
  *
  * lustre/osp/lwp_dev.c
@@ -49,9 +49,8 @@
 struct lwp_device {
 	struct lu_device	lpd_dev;
 	struct obd_device      *lpd_obd;   /* corresponding OBD device */
-	struct obd_uuid		lpd_cluuid;/* UUID of LWP */
 	struct obd_export      *lpd_exp;   /* export of LWP */
-	struct ptlrpc_thread	lpd_notify_thread; /* notify thread */
+	struct task_struct     *lpd_notify_task; /* notify thread */
 	int			lpd_connects; /* use count, 0 or 1 */
 };
 
@@ -83,14 +82,12 @@ static int lwp_setup(const struct lu_env *env, struct lwp_device *lwp,
 	char			*lwp_name = lwp->lpd_obd->obd_name;
 	char			*server_uuid = NULL;
 	char			*ptr;
-	class_uuid_t		 uuid;
 	struct obd_import	*imp;
 	int			 len = strlen(lwp_name) + 1;
 	int			 rc;
 	ENTRY;
 
-	thread_set_flags(&lwp->lpd_notify_thread, SVC_STOPPED);
-	init_waitqueue_head(&lwp->lpd_notify_thread.t_ctl_waitq);
+	lwp->lpd_notify_task = NULL;
 
 	OBD_ALLOC_PTR(bufs);
 	if (bufs == NULL)
@@ -128,11 +125,6 @@ static int lwp_setup(const struct lu_env *env, struct lwp_device *lwp,
 
 	imp = lwp->lpd_obd->u.cli.cl_import;
 	rc = ptlrpc_init_import(imp);
-	if (rc)
-		GOTO(out, rc);
-
-	ll_generate_random_uuid(uuid);
-	class_uuid_unparse(uuid, &lwp->lpd_cluuid);
 out:
 	if (bufs != NULL)
 		OBD_FREE_PTR(bufs);
@@ -267,18 +259,19 @@ static int lwp_init0(const struct lu_env *env, struct lwp_device *lwp,
 		RETURN(rc);
 	}
 
-	rc = lwp_setup(env, lwp, lustre_cfg_string(cfg, 1));
+	rc = lprocfs_obd_setup(lwp->lpd_obd, true);
 	if (rc) {
-		CERROR("%s: setup lwp failed. %d\n",
+		CERROR("%s: lprocfs_obd_setup failed. %d\n",
 		       lwp->lpd_obd->obd_name, rc);
 		ptlrpcd_decref();
 		RETURN(rc);
 	}
 
-	rc = lprocfs_obd_setup(lwp->lpd_obd, true);
+	rc = lwp_setup(env, lwp, lustre_cfg_string(cfg, 1));
 	if (rc) {
-		CERROR("%s: lprocfs_obd_setup failed. %d\n",
+		CERROR("%s: setup lwp failed. %d\n",
 		       lwp->lpd_obd->obd_name, rc);
+		lprocfs_obd_cleanup(lwp->lpd_obd);
 		ptlrpcd_decref();
 		RETURN(rc);
 	}
@@ -374,24 +367,25 @@ static struct lu_device *lwp_device_fini(const struct lu_env *env,
 					 struct lu_device *ludev)
 {
 	struct lwp_device	*m = lu2lwp_dev(ludev);
-	struct ptlrpc_thread	*thread = &m->lpd_notify_thread;
-	struct l_wait_info	 lwi = { 0 };
+	struct task_struct	*task = NULL;
 	int			 rc;
 	ENTRY;
 
-	if (!thread_is_stopped(thread))
-		l_wait_event(thread->t_ctl_waitq, thread_is_stopped(thread),
-			     &lwi);
+	task = xchg(&m->lpd_notify_task, NULL);
+	if (task) {
+		kthread_stop(task);
+		class_export_put(m->lpd_exp);
+	}
 
 	if (m->lpd_exp != NULL)
 		class_disconnect(m->lpd_exp);
 
 	LASSERT(m->lpd_obd);
-	ptlrpc_lprocfs_unregister_obd(m->lpd_obd);
-
 	rc = client_obd_cleanup(m->lpd_obd);
 	LASSERTF(rc == 0, "error %d\n", rc);
 
+	ptlrpc_lprocfs_unregister_obd(m->lpd_obd);
+
 	ptlrpcd_decref();
 
 	RETURN(NULL);
@@ -414,22 +408,23 @@ static int lwp_notify_main(void *args)
 {
 	struct obd_export	*exp = (struct obd_export *)args;
 	struct lwp_device	*lwp;
-	struct ptlrpc_thread	*thread;
 
 	LASSERT(exp != NULL);
-	class_export_get(exp);
 
 	lwp = lu2lwp_dev(exp->exp_obd->obd_lu_dev);
-	thread = &lwp->lpd_notify_thread;
-
-	thread_set_flags(thread, SVC_RUNNING);
-	wake_up(&thread->t_ctl_waitq);
 
 	lustre_notify_lwp_list(exp);
 
-	class_export_put(exp);
-	thread_set_flags(thread, SVC_STOPPED);
-	wake_up(&thread->t_ctl_waitq);
+	if (xchg(&lwp->lpd_notify_task, NULL) == NULL)
+		/* lwp_device_fini() is waiting for me
+		 * Note that the wakeup comes direct from
+		 * kthread_stop, not from wake_up_var().
+		 * lwp_device_fini() will call class_export_put().
+		 */
+		wait_var_event(lwp, kthread_should_stop());
+	else
+		class_export_put(exp);
+
 	return 0;
 }
 
@@ -441,35 +436,31 @@ static int lwp_notify_main(void *args)
 static void lwp_notify_users(struct obd_export *exp)
 {
 	struct lwp_device	*lwp;
-	struct ptlrpc_thread	*thread;
 	struct task_struct	*task;
-	struct l_wait_info	 lwi = { 0 };
 	char			 name[MTI_NAME_MAXLEN];
 
 	LASSERT(exp != NULL);
 	lwp = lu2lwp_dev(exp->exp_obd->obd_lu_dev);
-	thread = &lwp->lpd_notify_thread;
 
 	snprintf(name, MTI_NAME_MAXLEN, "lwp_notify_%s",
 		 exp->exp_obd->obd_name);
 
 	/* Notify happens only on LWP setup, so there shouldn't
 	 * be notify thread running */
-	if (!thread_is_stopped(thread)) {
+	if (lwp->lpd_notify_task) {
 		CERROR("LWP notify thread: %s wasn't stopped\n", name);
 		return;
 	}
 
-	task = kthread_run(lwp_notify_main, exp, name);
+	task = kthread_create(lwp_notify_main, exp, name);
 	if (IS_ERR(task)) {
-		thread_set_flags(thread, SVC_STOPPED);
 		CERROR("Failed to start LWP notify thread:%s. %lu\n",
 		       name, PTR_ERR(task));
+	} else {
+		lwp->lpd_notify_task = task;
+		class_export_get(exp);
+		wake_up_process(task);
 	}
-
-	l_wait_event(thread->t_ctl_waitq,
-		     thread_is_running(thread) || thread_is_stopped(thread),
-		     &lwi);
 }
 
 /**
@@ -633,7 +624,7 @@ static int lwp_set_info_async(const struct lu_env *env,
 	RETURN(-EINVAL);
 }
 
-struct obd_ops lwp_obd_device_ops = {
+const struct obd_ops lwp_obd_device_ops = {
 	.o_owner	= THIS_MODULE,
 	.o_add_conn	= client_import_add_conn,
 	.o_del_conn	= client_import_del_conn,