316 	struct drbd_thread *thi = (struct drbd_thread *) arg;  in drbd_thread_setup()  local
317 	struct drbd_resource *resource = thi->resource;  in drbd_thread_setup()
322 		 thi->name[0],  in drbd_thread_setup()
328 	retval = thi->function(thi);  in drbd_thread_setup()
330 	spin_lock_irqsave(&thi->t_lock, flags);  in drbd_thread_setup()
342 	if (thi->t_state == RESTARTING) {  in drbd_thread_setup()
343 		drbd_info(resource, "Restarting %s thread\n", thi->name);  in drbd_thread_setup()
344 		thi->t_state = RUNNING;  in drbd_thread_setup()
345 		spin_unlock_irqrestore(&thi->t_lock, flags);  in drbd_thread_setup()
349 	thi->task = NULL;  in drbd_thread_setup()
350 	thi->t_state = NONE;  in drbd_thread_setup()
352 	complete_all(&thi->stop);  in drbd_thread_setup()
353 	spin_unlock_irqrestore(&thi->t_lock, flags);  in drbd_thread_setup()
359 	if (thi->connection)  in drbd_thread_setup()
360 		kref_put(&thi->connection->kref, drbd_destroy_connection);  in drbd_thread_setup()
366 static void drbd_thread_init(struct drbd_resource *resource, struct drbd_thread *thi,  in drbd_thread_init()  argument
369 	spin_lock_init(&thi->t_lock);  in drbd_thread_init()
370 	thi->task    = NULL;  in drbd_thread_init()
371 	thi->t_state = NONE;  in drbd_thread_init()
372 	thi->function = func;  in drbd_thread_init()
373 	thi->resource = resource;  in drbd_thread_init()
374 	thi->connection = NULL;  in drbd_thread_init()
375 	thi->name = name;  in drbd_thread_init()
378 int drbd_thread_start(struct drbd_thread *thi)  in drbd_thread_start()  argument
380 	struct drbd_resource *resource = thi->resource;  in drbd_thread_start()
386 	spin_lock_irqsave(&thi->t_lock, flags);  in drbd_thread_start()
388 	switch (thi->t_state) {  in drbd_thread_start()
391 			 thi->name, current->comm, current->pid);  in drbd_thread_start()
396 			spin_unlock_irqrestore(&thi->t_lock, flags);  in drbd_thread_start()
401 		if (thi->connection)  in drbd_thread_start()
402 			kref_get(&thi->connection->kref);  in drbd_thread_start()
404 		init_completion(&thi->stop);  in drbd_thread_start()
405 		thi->reset_cpu_mask = 1;  in drbd_thread_start()
406 		thi->t_state = RUNNING;  in drbd_thread_start()
407 		spin_unlock_irqrestore(&thi->t_lock, flags);  in drbd_thread_start()
410 		nt = kthread_create(drbd_thread_setup, (void *) thi,  in drbd_thread_start()
411 				    "drbd_%c_%s", thi->name[0], thi->resource->name);  in drbd_thread_start()
416 			if (thi->connection)  in drbd_thread_start()
417 				kref_put(&thi->connection->kref, drbd_destroy_connection);  in drbd_thread_start()
422 		spin_lock_irqsave(&thi->t_lock, flags);  in drbd_thread_start()
423 		thi->task = nt;  in drbd_thread_start()
424 		thi->t_state = RUNNING;  in drbd_thread_start()
425 		spin_unlock_irqrestore(&thi->t_lock, flags);  in drbd_thread_start()
429 		thi->t_state = RESTARTING;  in drbd_thread_start()
431 				thi->name, current->comm, current->pid);  in drbd_thread_start()
436 		spin_unlock_irqrestore(&thi->t_lock, flags);  in drbd_thread_start()
444 void _drbd_thread_stop(struct drbd_thread *thi, int restart, int wait)  in _drbd_thread_stop()  argument
451 	spin_lock_irqsave(&thi->t_lock, flags);  in _drbd_thread_stop()
453 	if (thi->t_state == NONE) {  in _drbd_thread_stop()
454 		spin_unlock_irqrestore(&thi->t_lock, flags);  in _drbd_thread_stop()
456 			drbd_thread_start(thi);  in _drbd_thread_stop()
460 	if (thi->t_state != ns) {  in _drbd_thread_stop()
461 		if (thi->task == NULL) {  in _drbd_thread_stop()
462 			spin_unlock_irqrestore(&thi->t_lock, flags);  in _drbd_thread_stop()
466 		thi->t_state = ns;  in _drbd_thread_stop()
468 		init_completion(&thi->stop);  in _drbd_thread_stop()
469 		if (thi->task != current)  in _drbd_thread_stop()
470 			send_sig(DRBD_SIGKILL, thi->task, 1);  in _drbd_thread_stop()
473 	spin_unlock_irqrestore(&thi->t_lock, flags);  in _drbd_thread_stop()
476 		wait_for_completion(&thi->stop);  in _drbd_thread_stop()
539 void drbd_thread_current_set_cpu(struct drbd_thread *thi)  in drbd_thread_current_set_cpu()  argument
541 	struct drbd_resource *resource = thi->resource;  in drbd_thread_current_set_cpu()
544 	if (!thi->reset_cpu_mask)  in drbd_thread_current_set_cpu()
546 	thi->reset_cpu_mask = 0;  in drbd_thread_current_set_cpu()