exit.c 47 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213214215216217218219220221222223224225226227228229230231232233234235236237238239240241242243244245246247248249250251252253254255256257258259260261262263264265266267268269270271272273274275276277278279280281282283284285286287288289290291292293294295296297298299300301302303304305306307308309310311312313314315316317318319320321322323324325326327328329330331332333334335336337338339340341342343344345346347348349350351352353354355356357358359360361362363364365366367368369370371372373374375376377378379380381382383384385386387388389390391392393394395396397398399400401402403404405406407408409410411412413414415416417418419420421422423424425426427428429430431432433434435436437438439440441442443444445446447448449450451452453454455456457458459460461462463464465466467468469470471472473474475476477478479480481482483484485486487488489490491492493494495496497498499500501502503504505506507508509510511512513514515516517518519520521522523524525526527528529530531532533534535536537538539540541542543544545546547548549550551552553554555556557558559560561562563564565566567568569570571572573574575576577578579580581582583584585586587588589590591592593594595596597598599600601602603604605606607608609610611612613614615616617618619620621622623624625626627628629630631632633634635636637638639640641642643644645646647648649650651652653654655656657658659660661662663664665666667668669670671672673674675676677678679680681682683684685686687688689690691692693694695696697698699700701702703704705706707708709710711712713714715716717718719720721722723724725726727728729730731732733734735736737738739740741742743744745746747748749750751752753754755756757758759760761762763764765766767768769770771772773774775776777778779780781782783784785786787788789790791792793794795796797798799800801802803804805806807808809810811812813814815816817818819820821822823824825826827828829830831832833834835836837838839840841842843844845846847848849850851852853854855856857858859860861862863864865866867868869870871872873874875876877878879880881882883884885886887888889890891892893894895896897898899900901902903904905906907908909910911912913914915916917918919920921922923924925926927928929930931932933934935936937938939940941942943944945946947948949950951952953954955956957958959960961962963964965966967968969970971972973974975976977978979980981982983984985986987988989990991992993994995996997998999100010011002100310041005100610071008100910101011101210131014101510161017101810191020102110221023102410251026102710281029103010311032103310341035103610371038103910401041104210431044104510461047104810491050105110521053105410551056105710581059106010611062106310641065106610671068106910701071107210731074107510761077107810791080108110821083108410851086108710881089109010911092109310941095109610971098109911001101110211031104110511061107110811091110111111121113111411151116111711181119112011211122112311241125112611271128112911301131113211331134113511361137113811391140114111421143114411451146114711481149115011511152115311541155115611571158115911601161116211631164116511661167116811691170117111721173117411751176117711781179118011811182118311841185118611871188118911901191119211931194119511961197119811991200120112021203120412051206120712081209121012111212121312141215121612171218121912201221122212231224122512261227122812291230123112321233123412351236123712381239124012411242124312441245124612471248124912501251125212531254125512561257125812591260126112621263126412651266126712681269127012711272127312741275127612771278127912801281128212831284128512861287128812891290129112921293129412951296129712981299130013011302130313041305130613071308130913101311131213131314131513161317131813191320132113221323132413251326132713281329133013311332133313341335133613371338133913401341134213431344134513461347134813491350135113521353135413551356135713581359136013611362136313641365136613671368136913701371137213731374137513761377137813791380138113821383138413851386138713881389139013911392139313941395139613971398139914001401140214031404140514061407140814091410141114121413141414151416141714181419142014211422142314241425142614271428142914301431143214331434143514361437143814391440144114421443144414451446144714481449145014511452145314541455145614571458145914601461146214631464146514661467146814691470147114721473147414751476147714781479148014811482148314841485148614871488148914901491149214931494149514961497149814991500150115021503150415051506150715081509151015111512151315141515151615171518151915201521152215231524152515261527152815291530153115321533153415351536153715381539154015411542154315441545154615471548154915501551155215531554155515561557155815591560156115621563156415651566156715681569157015711572157315741575157615771578157915801581158215831584158515861587158815891590159115921593159415951596159715981599160016011602160316041605160616071608160916101611161216131614161516161617161816191620162116221623162416251626162716281629163016311632163316341635163616371638163916401641164216431644164516461647164816491650165116521653165416551656165716581659166016611662166316641665166616671668166916701671167216731674167516761677167816791680168116821683168416851686168716881689169016911692169316941695169616971698169917001701170217031704170517061707170817091710171117121713171417151716171717181719172017211722172317241725172617271728172917301731173217331734173517361737173817391740174117421743174417451746174717481749175017511752175317541755175617571758175917601761176217631764176517661767176817691770177117721773177417751776177717781779178017811782178317841785178617871788178917901791179217931794179517961797179817991800180118021803180418051806180718081809181018111812181318141815181618171818181918201821182218231824182518261827182818291830183118321833183418351836183718381839184018411842184318441845184618471848184918501851185218531854185518561857185818591860186118621863186418651866186718681869
  1. /*
  2. * linux/kernel/exit.c
  3. *
  4. * Copyright (C) 1991, 1992 Linus Torvalds
  5. */
  6. #include <linux/mm.h>
  7. #include <linux/slab.h>
  8. #include <linux/interrupt.h>
  9. #include <linux/module.h>
  10. #include <linux/capability.h>
  11. #include <linux/completion.h>
  12. #include <linux/personality.h>
  13. #include <linux/tty.h>
  14. #include <linux/iocontext.h>
  15. #include <linux/key.h>
  16. #include <linux/security.h>
  17. #include <linux/cpu.h>
  18. #include <linux/acct.h>
  19. #include <linux/tsacct_kern.h>
  20. #include <linux/file.h>
  21. #include <linux/fdtable.h>
  22. #include <linux/binfmts.h>
  23. #include <linux/nsproxy.h>
  24. #include <linux/pid_namespace.h>
  25. #include <linux/ptrace.h>
  26. #include <linux/profile.h>
  27. #include <linux/mount.h>
  28. #include <linux/proc_fs.h>
  29. #include <linux/kthread.h>
  30. #include <linux/mempolicy.h>
  31. #include <linux/taskstats_kern.h>
  32. #include <linux/delayacct.h>
  33. #include <linux/freezer.h>
  34. #include <linux/cgroup.h>
  35. #include <linux/syscalls.h>
  36. #include <linux/signal.h>
  37. #include <linux/posix-timers.h>
  38. #include <linux/cn_proc.h>
  39. #include <linux/mutex.h>
  40. #include <linux/futex.h>
  41. #include <linux/pipe_fs_i.h>
  42. #include <linux/audit.h> /* for audit_free() */
  43. #include <linux/resource.h>
  44. #include <linux/blkdev.h>
  45. #include <linux/task_io_accounting_ops.h>
  46. #include <linux/tracehook.h>
  47. #include <linux/fs_struct.h>
  48. #include <linux/init_task.h>
  49. #include <linux/perf_event.h>
  50. #include <trace/events/sched.h>
  51. #include <linux/hw_breakpoint.h>
  52. #include <linux/oom.h>
  53. #include <asm/uaccess.h>
  54. #include <asm/unistd.h>
  55. #include <asm/pgtable.h>
  56. #include <asm/mmu_context.h>
  57. static void exit_mm(struct task_struct * tsk);
  58. static void __unhash_process(struct task_struct *p, bool group_dead)
  59. {
  60. nr_threads--;
  61. detach_pid(p, PIDTYPE_PID);
  62. if (group_dead) {
  63. detach_pid(p, PIDTYPE_PGID);
  64. detach_pid(p, PIDTYPE_SID);
  65. list_del_rcu(&p->tasks);
  66. list_del_init(&p->sibling);
  67. __this_cpu_dec(process_counts);
  68. }
  69. list_del_rcu(&p->thread_group);
  70. }
  71. /*
  72. * This function expects the tasklist_lock write-locked.
  73. */
  74. static void __exit_signal(struct task_struct *tsk)
  75. {
  76. struct signal_struct *sig = tsk->signal;
  77. bool group_dead = thread_group_leader(tsk);
  78. struct sighand_struct *sighand;
  79. struct tty_struct *uninitialized_var(tty);
  80. sighand = rcu_dereference_check(tsk->sighand,
  81. rcu_read_lock_held() ||
  82. lockdep_tasklist_lock_is_held());
  83. spin_lock(&sighand->siglock);
  84. posix_cpu_timers_exit(tsk);
  85. if (group_dead) {
  86. posix_cpu_timers_exit_group(tsk);
  87. tty = sig->tty;
  88. sig->tty = NULL;
  89. } else {
  90. /*
  91. * This can only happen if the caller is de_thread().
  92. * FIXME: this is the temporary hack, we should teach
  93. * posix-cpu-timers to handle this case correctly.
  94. */
  95. if (unlikely(has_group_leader_pid(tsk)))
  96. posix_cpu_timers_exit_group(tsk);
  97. /*
  98. * If there is any task waiting for the group exit
  99. * then notify it:
  100. */
  101. if (sig->notify_count > 0 && !--sig->notify_count)
  102. wake_up_process(sig->group_exit_task);
  103. if (tsk == sig->curr_target)
  104. sig->curr_target = next_thread(tsk);
  105. /*
  106. * Accumulate here the counters for all threads but the
  107. * group leader as they die, so they can be added into
  108. * the process-wide totals when those are taken.
  109. * The group leader stays around as a zombie as long
  110. * as there are other threads. When it gets reaped,
  111. * the exit.c code will add its counts into these totals.
  112. * We won't ever get here for the group leader, since it
  113. * will have been the last reference on the signal_struct.
  114. */
  115. sig->utime = cputime_add(sig->utime, tsk->utime);
  116. sig->stime = cputime_add(sig->stime, tsk->stime);
  117. sig->gtime = cputime_add(sig->gtime, tsk->gtime);
  118. sig->min_flt += tsk->min_flt;
  119. sig->maj_flt += tsk->maj_flt;
  120. sig->nvcsw += tsk->nvcsw;
  121. sig->nivcsw += tsk->nivcsw;
  122. sig->inblock += task_io_get_inblock(tsk);
  123. sig->oublock += task_io_get_oublock(tsk);
  124. task_io_accounting_add(&sig->ioac, &tsk->ioac);
  125. sig->sum_sched_runtime += tsk->se.sum_exec_runtime;
  126. }
  127. sig->nr_threads--;
  128. __unhash_process(tsk, group_dead);
  129. /*
  130. * Do this under ->siglock, we can race with another thread
  131. * doing sigqueue_free() if we have SIGQUEUE_PREALLOC signals.
  132. */
  133. flush_sigqueue(&tsk->pending);
  134. tsk->sighand = NULL;
  135. spin_unlock(&sighand->siglock);
  136. __cleanup_sighand(sighand);
  137. clear_tsk_thread_flag(tsk,TIF_SIGPENDING);
  138. if (group_dead) {
  139. flush_sigqueue(&sig->shared_pending);
  140. tty_kref_put(tty);
  141. }
  142. }
  143. static void delayed_put_task_struct(struct rcu_head *rhp)
  144. {
  145. struct task_struct *tsk = container_of(rhp, struct task_struct, rcu);
  146. perf_event_delayed_put(tsk);
  147. trace_sched_process_free(tsk);
  148. put_task_struct(tsk);
  149. }
  150. void release_task(struct task_struct * p)
  151. {
  152. struct task_struct *leader;
  153. int zap_leader;
  154. repeat:
  155. tracehook_prepare_release_task(p);
  156. /* don't need to get the RCU readlock here - the process is dead and
  157. * can't be modifying its own credentials. But shut RCU-lockdep up */
  158. rcu_read_lock();
  159. atomic_dec(&__task_cred(p)->user->processes);
  160. rcu_read_unlock();
  161. proc_flush_task(p);
  162. write_lock_irq(&tasklist_lock);
  163. tracehook_finish_release_task(p);
  164. __exit_signal(p);
  165. /*
  166. * If we are the last non-leader member of the thread
  167. * group, and the leader is zombie, then notify the
  168. * group leader's parent process. (if it wants notification.)
  169. */
  170. zap_leader = 0;
  171. leader = p->group_leader;
  172. if (leader != p && thread_group_empty(leader) && leader->exit_state == EXIT_ZOMBIE) {
  173. BUG_ON(task_detached(leader));
  174. do_notify_parent(leader, leader->exit_signal);
  175. /*
  176. * If we were the last child thread and the leader has
  177. * exited already, and the leader's parent ignores SIGCHLD,
  178. * then we are the one who should release the leader.
  179. *
  180. * do_notify_parent() will have marked it self-reaping in
  181. * that case.
  182. */
  183. zap_leader = task_detached(leader);
  184. /*
  185. * This maintains the invariant that release_task()
  186. * only runs on a task in EXIT_DEAD, just for sanity.
  187. */
  188. if (zap_leader)
  189. leader->exit_state = EXIT_DEAD;
  190. }
  191. write_unlock_irq(&tasklist_lock);
  192. release_thread(p);
  193. call_rcu(&p->rcu, delayed_put_task_struct);
  194. p = leader;
  195. if (unlikely(zap_leader))
  196. goto repeat;
  197. }
  198. /*
  199. * This checks not only the pgrp, but falls back on the pid if no
  200. * satisfactory pgrp is found. I dunno - gdb doesn't work correctly
  201. * without this...
  202. *
  203. * The caller must hold rcu lock or the tasklist lock.
  204. */
  205. struct pid *session_of_pgrp(struct pid *pgrp)
  206. {
  207. struct task_struct *p;
  208. struct pid *sid = NULL;
  209. p = pid_task(pgrp, PIDTYPE_PGID);
  210. if (p == NULL)
  211. p = pid_task(pgrp, PIDTYPE_PID);
  212. if (p != NULL)
  213. sid = task_session(p);
  214. return sid;
  215. }
  216. /*
  217. * Determine if a process group is "orphaned", according to the POSIX
  218. * definition in 2.2.2.52. Orphaned process groups are not to be affected
  219. * by terminal-generated stop signals. Newly orphaned process groups are
  220. * to receive a SIGHUP and a SIGCONT.
  221. *
  222. * "I ask you, have you ever known what it is to be an orphan?"
  223. */
  224. static int will_become_orphaned_pgrp(struct pid *pgrp, struct task_struct *ignored_task)
  225. {
  226. struct task_struct *p;
  227. do_each_pid_task(pgrp, PIDTYPE_PGID, p) {
  228. if ((p == ignored_task) ||
  229. (p->exit_state && thread_group_empty(p)) ||
  230. is_global_init(p->real_parent))
  231. continue;
  232. if (task_pgrp(p->real_parent) != pgrp &&
  233. task_session(p->real_parent) == task_session(p))
  234. return 0;
  235. } while_each_pid_task(pgrp, PIDTYPE_PGID, p);
  236. return 1;
  237. }
  238. int is_current_pgrp_orphaned(void)
  239. {
  240. int retval;
  241. read_lock(&tasklist_lock);
  242. retval = will_become_orphaned_pgrp(task_pgrp(current), NULL);
  243. read_unlock(&tasklist_lock);
  244. return retval;
  245. }
  246. static int has_stopped_jobs(struct pid *pgrp)
  247. {
  248. int retval = 0;
  249. struct task_struct *p;
  250. do_each_pid_task(pgrp, PIDTYPE_PGID, p) {
  251. if (!task_is_stopped(p))
  252. continue;
  253. retval = 1;
  254. break;
  255. } while_each_pid_task(pgrp, PIDTYPE_PGID, p);
  256. return retval;
  257. }
  258. /*
  259. * Check to see if any process groups have become orphaned as
  260. * a result of our exiting, and if they have any stopped jobs,
  261. * send them a SIGHUP and then a SIGCONT. (POSIX 3.2.2.2)
  262. */
  263. static void
  264. kill_orphaned_pgrp(struct task_struct *tsk, struct task_struct *parent)
  265. {
  266. struct pid *pgrp = task_pgrp(tsk);
  267. struct task_struct *ignored_task = tsk;
  268. if (!parent)
  269. /* exit: our father is in a different pgrp than
  270. * we are and we were the only connection outside.
  271. */
  272. parent = tsk->real_parent;
  273. else
  274. /* reparent: our child is in a different pgrp than
  275. * we are, and it was the only connection outside.
  276. */
  277. ignored_task = NULL;
  278. if (task_pgrp(parent) != pgrp &&
  279. task_session(parent) == task_session(tsk) &&
  280. will_become_orphaned_pgrp(pgrp, ignored_task) &&
  281. has_stopped_jobs(pgrp)) {
  282. __kill_pgrp_info(SIGHUP, SEND_SIG_PRIV, pgrp);
  283. __kill_pgrp_info(SIGCONT, SEND_SIG_PRIV, pgrp);
  284. }
  285. }
  286. /**
  287. * reparent_to_kthreadd - Reparent the calling kernel thread to kthreadd
  288. *
  289. * If a kernel thread is launched as a result of a system call, or if
  290. * it ever exits, it should generally reparent itself to kthreadd so it
  291. * isn't in the way of other processes and is correctly cleaned up on exit.
  292. *
  293. * The various task state such as scheduling policy and priority may have
  294. * been inherited from a user process, so we reset them to sane values here.
  295. *
  296. * NOTE that reparent_to_kthreadd() gives the caller full capabilities.
  297. */
  298. static void reparent_to_kthreadd(void)
  299. {
  300. write_lock_irq(&tasklist_lock);
  301. ptrace_unlink(current);
  302. /* Reparent to init */
  303. current->real_parent = current->parent = kthreadd_task;
  304. list_move_tail(&current->sibling, &current->real_parent->children);
  305. /* Set the exit signal to SIGCHLD so we signal init on exit */
  306. current->exit_signal = SIGCHLD;
  307. if (task_nice(current) < 0)
  308. set_user_nice(current, 0);
  309. /* cpus_allowed? */
  310. /* rt_priority? */
  311. /* signals? */
  312. memcpy(current->signal->rlim, init_task.signal->rlim,
  313. sizeof(current->signal->rlim));
  314. atomic_inc(&init_cred.usage);
  315. commit_creds(&init_cred);
  316. write_unlock_irq(&tasklist_lock);
  317. }
  318. void __set_special_pids(struct pid *pid)
  319. {
  320. struct task_struct *curr = current->group_leader;
  321. if (task_session(curr) != pid)
  322. change_pid(curr, PIDTYPE_SID, pid);
  323. if (task_pgrp(curr) != pid)
  324. change_pid(curr, PIDTYPE_PGID, pid);
  325. }
  326. static void set_special_pids(struct pid *pid)
  327. {
  328. write_lock_irq(&tasklist_lock);
  329. __set_special_pids(pid);
  330. write_unlock_irq(&tasklist_lock);
  331. }
  332. /*
  333. * Let kernel threads use this to say that they allow a certain signal.
  334. * Must not be used if kthread was cloned with CLONE_SIGHAND.
  335. */
  336. int allow_signal(int sig)
  337. {
  338. if (!valid_signal(sig) || sig < 1)
  339. return -EINVAL;
  340. spin_lock_irq(&current->sighand->siglock);
  341. /* This is only needed for daemonize()'ed kthreads */
  342. sigdelset(&current->blocked, sig);
  343. /*
  344. * Kernel threads handle their own signals. Let the signal code
  345. * know it'll be handled, so that they don't get converted to
  346. * SIGKILL or just silently dropped.
  347. */
  348. current->sighand->action[(sig)-1].sa.sa_handler = (void __user *)2;
  349. recalc_sigpending();
  350. spin_unlock_irq(&current->sighand->siglock);
  351. return 0;
  352. }
  353. EXPORT_SYMBOL(allow_signal);
  354. int disallow_signal(int sig)
  355. {
  356. if (!valid_signal(sig) || sig < 1)
  357. return -EINVAL;
  358. spin_lock_irq(&current->sighand->siglock);
  359. current->sighand->action[(sig)-1].sa.sa_handler = SIG_IGN;
  360. recalc_sigpending();
  361. spin_unlock_irq(&current->sighand->siglock);
  362. return 0;
  363. }
  364. EXPORT_SYMBOL(disallow_signal);
  365. /*
  366. * Put all the gunge required to become a kernel thread without
  367. * attached user resources in one place where it belongs.
  368. */
  369. void daemonize(const char *name, ...)
  370. {
  371. va_list args;
  372. sigset_t blocked;
  373. va_start(args, name);
  374. vsnprintf(current->comm, sizeof(current->comm), name, args);
  375. va_end(args);
  376. /*
  377. * If we were started as result of loading a module, close all of the
  378. * user space pages. We don't need them, and if we didn't close them
  379. * they would be locked into memory.
  380. */
  381. exit_mm(current);
  382. /*
  383. * We don't want to have TIF_FREEZE set if the system-wide hibernation
  384. * or suspend transition begins right now.
  385. */
  386. current->flags |= (PF_NOFREEZE | PF_KTHREAD);
  387. if (current->nsproxy != &init_nsproxy) {
  388. get_nsproxy(&init_nsproxy);
  389. switch_task_namespaces(current, &init_nsproxy);
  390. }
  391. set_special_pids(&init_struct_pid);
  392. proc_clear_tty(current);
  393. /* Block and flush all signals */
  394. sigfillset(&blocked);
  395. sigprocmask(SIG_BLOCK, &blocked, NULL);
  396. flush_signals(current);
  397. /* Become as one with the init task */
  398. daemonize_fs_struct();
  399. exit_files(current);
  400. current->files = init_task.files;
  401. atomic_inc(&current->files->count);
  402. reparent_to_kthreadd();
  403. }
  404. EXPORT_SYMBOL(daemonize);
  405. static void close_files(struct files_struct * files)
  406. {
  407. int i, j;
  408. struct fdtable *fdt;
  409. j = 0;
  410. /*
  411. * It is safe to dereference the fd table without RCU or
  412. * ->file_lock because this is the last reference to the
  413. * files structure. But use RCU to shut RCU-lockdep up.
  414. */
  415. rcu_read_lock();
  416. fdt = files_fdtable(files);
  417. rcu_read_unlock();
  418. for (;;) {
  419. unsigned long set;
  420. i = j * __NFDBITS;
  421. if (i >= fdt->max_fds)
  422. break;
  423. set = fdt->open_fds->fds_bits[j++];
  424. while (set) {
  425. if (set & 1) {
  426. struct file * file = xchg(&fdt->fd[i], NULL);
  427. if (file) {
  428. filp_close(file, files);
  429. cond_resched();
  430. }
  431. }
  432. i++;
  433. set >>= 1;
  434. }
  435. }
  436. }
  437. struct files_struct *get_files_struct(struct task_struct *task)
  438. {
  439. struct files_struct *files;
  440. task_lock(task);
  441. files = task->files;
  442. if (files)
  443. atomic_inc(&files->count);
  444. task_unlock(task);
  445. return files;
  446. }
  447. void put_files_struct(struct files_struct *files)
  448. {
  449. struct fdtable *fdt;
  450. if (atomic_dec_and_test(&files->count)) {
  451. close_files(files);
  452. /*
  453. * Free the fd and fdset arrays if we expanded them.
  454. * If the fdtable was embedded, pass files for freeing
  455. * at the end of the RCU grace period. Otherwise,
  456. * you can free files immediately.
  457. */
  458. rcu_read_lock();
  459. fdt = files_fdtable(files);
  460. if (fdt != &files->fdtab)
  461. kmem_cache_free(files_cachep, files);
  462. free_fdtable(fdt);
  463. rcu_read_unlock();
  464. }
  465. }
  466. void reset_files_struct(struct files_struct *files)
  467. {
  468. struct task_struct *tsk = current;
  469. struct files_struct *old;
  470. old = tsk->files;
  471. task_lock(tsk);
  472. tsk->files = files;
  473. task_unlock(tsk);
  474. put_files_struct(old);
  475. }
  476. void exit_files(struct task_struct *tsk)
  477. {
  478. struct files_struct * files = tsk->files;
  479. if (files) {
  480. task_lock(tsk);
  481. tsk->files = NULL;
  482. task_unlock(tsk);
  483. put_files_struct(files);
  484. }
  485. }
  486. #ifdef CONFIG_MM_OWNER
  487. /*
  488. * Task p is exiting and it owned mm, lets find a new owner for it
  489. */
  490. static inline int
  491. mm_need_new_owner(struct mm_struct *mm, struct task_struct *p)
  492. {
  493. /*
  494. * If there are other users of the mm and the owner (us) is exiting
  495. * we need to find a new owner to take on the responsibility.
  496. */
  497. if (atomic_read(&mm->mm_users) <= 1)
  498. return 0;
  499. if (mm->owner != p)
  500. return 0;
  501. return 1;
  502. }
  503. void mm_update_next_owner(struct mm_struct *mm)
  504. {
  505. struct task_struct *c, *g, *p = current;
  506. retry:
  507. if (!mm_need_new_owner(mm, p))
  508. return;
  509. read_lock(&tasklist_lock);
  510. /*
  511. * Search in the children
  512. */
  513. list_for_each_entry(c, &p->children, sibling) {
  514. if (c->mm == mm)
  515. goto assign_new_owner;
  516. }
  517. /*
  518. * Search in the siblings
  519. */
  520. list_for_each_entry(c, &p->real_parent->children, sibling) {
  521. if (c->mm == mm)
  522. goto assign_new_owner;
  523. }
  524. /*
  525. * Search through everything else. We should not get
  526. * here often
  527. */
  528. do_each_thread(g, c) {
  529. if (c->mm == mm)
  530. goto assign_new_owner;
  531. } while_each_thread(g, c);
  532. read_unlock(&tasklist_lock);
  533. /*
  534. * We found no owner yet mm_users > 1: this implies that we are
  535. * most likely racing with swapoff (try_to_unuse()) or /proc or
  536. * ptrace or page migration (get_task_mm()). Mark owner as NULL.
  537. */
  538. mm->owner = NULL;
  539. return;
  540. assign_new_owner:
  541. BUG_ON(c == p);
  542. get_task_struct(c);
  543. /*
  544. * The task_lock protects c->mm from changing.
  545. * We always want mm->owner->mm == mm
  546. */
  547. task_lock(c);
  548. /*
  549. * Delay read_unlock() till we have the task_lock()
  550. * to ensure that c does not slip away underneath us
  551. */
  552. read_unlock(&tasklist_lock);
  553. if (c->mm != mm) {
  554. task_unlock(c);
  555. put_task_struct(c);
  556. goto retry;
  557. }
  558. mm->owner = c;
  559. task_unlock(c);
  560. put_task_struct(c);
  561. }
  562. #endif /* CONFIG_MM_OWNER */
  563. /*
  564. * Turn us into a lazy TLB process if we
  565. * aren't already..
  566. */
  567. static void exit_mm(struct task_struct * tsk)
  568. {
  569. struct mm_struct *mm = tsk->mm;
  570. struct core_state *core_state;
  571. mm_release(tsk, mm);
  572. if (!mm)
  573. return;
  574. /*
  575. * Serialize with any possible pending coredump.
  576. * We must hold mmap_sem around checking core_state
  577. * and clearing tsk->mm. The core-inducing thread
  578. * will increment ->nr_threads for each thread in the
  579. * group with ->mm != NULL.
  580. */
  581. down_read(&mm->mmap_sem);
  582. core_state = mm->core_state;
  583. if (core_state) {
  584. struct core_thread self;
  585. up_read(&mm->mmap_sem);
  586. self.task = tsk;
  587. self.next = xchg(&core_state->dumper.next, &self);
  588. /*
  589. * Implies mb(), the result of xchg() must be visible
  590. * to core_state->dumper.
  591. */
  592. if (atomic_dec_and_test(&core_state->nr_threads))
  593. complete(&core_state->startup);
  594. for (;;) {
  595. set_task_state(tsk, TASK_UNINTERRUPTIBLE);
  596. if (!self.task) /* see coredump_finish() */
  597. break;
  598. schedule();
  599. }
  600. __set_task_state(tsk, TASK_RUNNING);
  601. down_read(&mm->mmap_sem);
  602. }
  603. atomic_inc(&mm->mm_count);
  604. BUG_ON(mm != tsk->active_mm);
  605. /* more a memory barrier than a real lock */
  606. task_lock(tsk);
  607. tsk->mm = NULL;
  608. up_read(&mm->mmap_sem);
  609. enter_lazy_tlb(mm, current);
  610. /* We don't want this task to be frozen prematurely */
  611. clear_freeze_flag(tsk);
  612. if (tsk->signal->oom_score_adj == OOM_SCORE_ADJ_MIN)
  613. atomic_dec(&mm->oom_disable_count);
  614. task_unlock(tsk);
  615. mm_update_next_owner(mm);
  616. mmput(mm);
  617. }
  618. /*
  619. * When we die, we re-parent all our children.
  620. * Try to give them to another thread in our thread
  621. * group, and if no such member exists, give it to
  622. * the child reaper process (ie "init") in our pid
  623. * space.
  624. */
  625. static struct task_struct *find_new_reaper(struct task_struct *father)
  626. __releases(&tasklist_lock)
  627. __acquires(&tasklist_lock)
  628. {
  629. struct pid_namespace *pid_ns = task_active_pid_ns(father);
  630. struct task_struct *thread;
  631. thread = father;
  632. while_each_thread(father, thread) {
  633. if (thread->flags & PF_EXITING)
  634. continue;
  635. if (unlikely(pid_ns->child_reaper == father))
  636. pid_ns->child_reaper = thread;
  637. return thread;
  638. }
  639. if (unlikely(pid_ns->child_reaper == father)) {
  640. write_unlock_irq(&tasklist_lock);
  641. if (unlikely(pid_ns == &init_pid_ns))
  642. panic("Attempted to kill init!");
  643. zap_pid_ns_processes(pid_ns);
  644. write_lock_irq(&tasklist_lock);
  645. /*
  646. * We can not clear ->child_reaper or leave it alone.
  647. * There may by stealth EXIT_DEAD tasks on ->children,
  648. * forget_original_parent() must move them somewhere.
  649. */
  650. pid_ns->child_reaper = init_pid_ns.child_reaper;
  651. }
  652. return pid_ns->child_reaper;
  653. }
  654. /*
  655. * Any that need to be release_task'd are put on the @dead list.
  656. */
  657. static void reparent_leader(struct task_struct *father, struct task_struct *p,
  658. struct list_head *dead)
  659. {
  660. list_move_tail(&p->sibling, &p->real_parent->children);
  661. if (task_detached(p))
  662. return;
  663. /*
  664. * If this is a threaded reparent there is no need to
  665. * notify anyone anything has happened.
  666. */
  667. if (same_thread_group(p->real_parent, father))
  668. return;
  669. /* We don't want people slaying init. */
  670. p->exit_signal = SIGCHLD;
  671. /* If it has exited notify the new parent about this child's death. */
  672. if (!task_ptrace(p) &&
  673. p->exit_state == EXIT_ZOMBIE && thread_group_empty(p)) {
  674. do_notify_parent(p, p->exit_signal);
  675. if (task_detached(p)) {
  676. p->exit_state = EXIT_DEAD;
  677. list_move_tail(&p->sibling, dead);
  678. }
  679. }
  680. kill_orphaned_pgrp(p, father);
  681. }
  682. static void forget_original_parent(struct task_struct *father)
  683. {
  684. struct task_struct *p, *n, *reaper;
  685. LIST_HEAD(dead_children);
  686. write_lock_irq(&tasklist_lock);
  687. /*
  688. * Note that exit_ptrace() and find_new_reaper() might
  689. * drop tasklist_lock and reacquire it.
  690. */
  691. exit_ptrace(father);
  692. reaper = find_new_reaper(father);
  693. list_for_each_entry_safe(p, n, &father->children, sibling) {
  694. struct task_struct *t = p;
  695. do {
  696. t->real_parent = reaper;
  697. if (t->parent == father) {
  698. BUG_ON(task_ptrace(t));
  699. t->parent = t->real_parent;
  700. }
  701. if (t->pdeath_signal)
  702. group_send_sig_info(t->pdeath_signal,
  703. SEND_SIG_NOINFO, t);
  704. } while_each_thread(p, t);
  705. reparent_leader(father, p, &dead_children);
  706. }
  707. write_unlock_irq(&tasklist_lock);
  708. BUG_ON(!list_empty(&father->children));
  709. list_for_each_entry_safe(p, n, &dead_children, sibling) {
  710. list_del_init(&p->sibling);
  711. release_task(p);
  712. }
  713. }
  714. /*
  715. * Send signals to all our closest relatives so that they know
  716. * to properly mourn us..
  717. */
  718. static void exit_notify(struct task_struct *tsk, int group_dead)
  719. {
  720. int signal;
  721. void *cookie;
  722. /*
  723. * This does two things:
  724. *
  725. * A. Make init inherit all the child processes
  726. * B. Check to see if any process groups have become orphaned
  727. * as a result of our exiting, and if they have any stopped
  728. * jobs, send them a SIGHUP and then a SIGCONT. (POSIX 3.2.2.2)
  729. */
  730. forget_original_parent(tsk);
  731. exit_task_namespaces(tsk);
  732. write_lock_irq(&tasklist_lock);
  733. if (group_dead)
  734. kill_orphaned_pgrp(tsk->group_leader, NULL);
  735. /* Let father know we died
  736. *
  737. * Thread signals are configurable, but you aren't going to use
  738. * that to send signals to arbitary processes.
  739. * That stops right now.
  740. *
  741. * If the parent exec id doesn't match the exec id we saved
  742. * when we started then we know the parent has changed security
  743. * domain.
  744. *
  745. * If our self_exec id doesn't match our parent_exec_id then
  746. * we have changed execution domain as these two values started
  747. * the same after a fork.
  748. */
  749. if (tsk->exit_signal != SIGCHLD && !task_detached(tsk) &&
  750. (tsk->parent_exec_id != tsk->real_parent->self_exec_id ||
  751. tsk->self_exec_id != tsk->parent_exec_id))
  752. tsk->exit_signal = SIGCHLD;
  753. signal = tracehook_notify_death(tsk, &cookie, group_dead);
  754. if (signal >= 0)
  755. signal = do_notify_parent(tsk, signal);
  756. tsk->exit_state = signal == DEATH_REAP ? EXIT_DEAD : EXIT_ZOMBIE;
  757. /* mt-exec, de_thread() is waiting for group leader */
  758. if (unlikely(tsk->signal->notify_count < 0))
  759. wake_up_process(tsk->signal->group_exit_task);
  760. write_unlock_irq(&tasklist_lock);
  761. tracehook_report_death(tsk, signal, cookie, group_dead);
  762. /* If the process is dead, release it - nobody will wait for it */
  763. if (signal == DEATH_REAP)
  764. release_task(tsk);
  765. }
  766. #ifdef CONFIG_DEBUG_STACK_USAGE
  767. static void check_stack_usage(void)
  768. {
  769. static DEFINE_SPINLOCK(low_water_lock);
  770. static int lowest_to_date = THREAD_SIZE;
  771. unsigned long free;
  772. free = stack_not_used(current);
  773. if (free >= lowest_to_date)
  774. return;
  775. spin_lock(&low_water_lock);
  776. if (free < lowest_to_date) {
  777. printk(KERN_WARNING "%s used greatest stack depth: %lu bytes "
  778. "left\n",
  779. current->comm, free);
  780. lowest_to_date = free;
  781. }
  782. spin_unlock(&low_water_lock);
  783. }
  784. #else
  785. static inline void check_stack_usage(void) {}
  786. #endif
  787. NORET_TYPE void do_exit(long code)
  788. {
  789. struct task_struct *tsk = current;
  790. int group_dead;
  791. profile_task_exit(tsk);
  792. WARN_ON(atomic_read(&tsk->fs_excl));
  793. WARN_ON(blk_needs_flush_plug(tsk));
  794. if (unlikely(in_interrupt()))
  795. panic("Aiee, killing interrupt handler!");
  796. if (unlikely(!tsk->pid))
  797. panic("Attempted to kill the idle task!");
  798. /*
  799. * If do_exit is called because this processes oopsed, it's possible
  800. * that get_fs() was left as KERNEL_DS, so reset it to USER_DS before
  801. * continuing. Amongst other possible reasons, this is to prevent
  802. * mm_release()->clear_child_tid() from writing to a user-controlled
  803. * kernel address.
  804. */
  805. set_fs(USER_DS);
  806. tracehook_report_exit(&code);
  807. validate_creds_for_do_exit(tsk);
  808. /*
  809. * We're taking recursive faults here in do_exit. Safest is to just
  810. * leave this task alone and wait for reboot.
  811. */
  812. if (unlikely(tsk->flags & PF_EXITING)) {
  813. printk(KERN_ALERT
  814. "Fixing recursive fault but reboot is needed!\n");
  815. /*
  816. * We can do this unlocked here. The futex code uses
  817. * this flag just to verify whether the pi state
  818. * cleanup has been done or not. In the worst case it
  819. * loops once more. We pretend that the cleanup was
  820. * done as there is no way to return. Either the
  821. * OWNER_DIED bit is set by now or we push the blocked
  822. * task into the wait for ever nirwana as well.
  823. */
  824. tsk->flags |= PF_EXITPIDONE;
  825. set_current_state(TASK_UNINTERRUPTIBLE);
  826. schedule();
  827. }
  828. exit_irq_thread();
  829. exit_signals(tsk); /* sets PF_EXITING */
  830. /*
  831. * tsk->flags are checked in the futex code to protect against
  832. * an exiting task cleaning up the robust pi futexes.
  833. */
  834. smp_mb();
  835. raw_spin_unlock_wait(&tsk->pi_lock);
  836. if (unlikely(in_atomic()))
  837. printk(KERN_INFO "note: %s[%d] exited with preempt_count %d\n",
  838. current->comm, task_pid_nr(current),
  839. preempt_count());
  840. acct_update_integrals(tsk);
  841. /* sync mm's RSS info before statistics gathering */
  842. if (tsk->mm)
  843. sync_mm_rss(tsk, tsk->mm);
  844. group_dead = atomic_dec_and_test(&tsk->signal->live);
  845. if (group_dead) {
  846. hrtimer_cancel(&tsk->signal->real_timer);
  847. exit_itimers(tsk->signal);
  848. if (tsk->mm)
  849. setmax_mm_hiwater_rss(&tsk->signal->maxrss, tsk->mm);
  850. }
  851. acct_collect(code, group_dead);
  852. if (group_dead)
  853. tty_audit_exit();
  854. if (unlikely(tsk->audit_context))
  855. audit_free(tsk);
  856. tsk->exit_code = code;
  857. taskstats_exit(tsk, group_dead);
  858. exit_mm(tsk);
  859. if (group_dead)
  860. acct_process();
  861. trace_sched_process_exit(tsk);
  862. exit_sem(tsk);
  863. exit_files(tsk);
  864. exit_fs(tsk);
  865. check_stack_usage();
  866. exit_thread();
  867. /*
  868. * Flush inherited counters to the parent - before the parent
  869. * gets woken up by child-exit notifications.
  870. *
  871. * because of cgroup mode, must be called before cgroup_exit()
  872. */
  873. perf_event_exit_task(tsk);
  874. cgroup_exit(tsk, 1);
  875. if (group_dead)
  876. disassociate_ctty(1);
  877. module_put(task_thread_info(tsk)->exec_domain->module);
  878. proc_exit_connector(tsk);
  879. /*
  880. * FIXME: do that only when needed, using sched_exit tracepoint
  881. */
  882. flush_ptrace_hw_breakpoint(tsk);
  883. exit_notify(tsk, group_dead);
  884. #ifdef CONFIG_NUMA
  885. task_lock(tsk);
  886. mpol_put(tsk->mempolicy);
  887. tsk->mempolicy = NULL;
  888. task_unlock(tsk);
  889. #endif
  890. #ifdef CONFIG_FUTEX
  891. if (unlikely(current->pi_state_cache))
  892. kfree(current->pi_state_cache);
  893. #endif
  894. /*
  895. * Make sure we are holding no locks:
  896. */
  897. debug_check_no_locks_held(tsk);
  898. /*
  899. * We can do this unlocked here. The futex code uses this flag
  900. * just to verify whether the pi state cleanup has been done
  901. * or not. In the worst case it loops once more.
  902. */
  903. tsk->flags |= PF_EXITPIDONE;
  904. if (tsk->io_context)
  905. exit_io_context(tsk);
  906. if (tsk->splice_pipe)
  907. __free_pipe_info(tsk->splice_pipe);
  908. validate_creds_for_do_exit(tsk);
  909. preempt_disable();
  910. exit_rcu();
  911. /* causes final put_task_struct in finish_task_switch(). */
  912. tsk->state = TASK_DEAD;
  913. schedule();
  914. BUG();
  915. /* Avoid "noreturn function does return". */
  916. for (;;)
  917. cpu_relax(); /* For when BUG is null */
  918. }
  919. EXPORT_SYMBOL_GPL(do_exit);
  920. NORET_TYPE void complete_and_exit(struct completion *comp, long code)
  921. {
  922. if (comp)
  923. complete(comp);
  924. do_exit(code);
  925. }
  926. EXPORT_SYMBOL(complete_and_exit);
  927. SYSCALL_DEFINE1(exit, int, error_code)
  928. {
  929. do_exit((error_code&0xff)<<8);
  930. }
  931. /*
  932. * Take down every thread in the group. This is called by fatal signals
  933. * as well as by sys_exit_group (below).
  934. */
  935. NORET_TYPE void
  936. do_group_exit(int exit_code)
  937. {
  938. struct signal_struct *sig = current->signal;
  939. BUG_ON(exit_code & 0x80); /* core dumps don't get here */
  940. if (signal_group_exit(sig))
  941. exit_code = sig->group_exit_code;
  942. else if (!thread_group_empty(current)) {
  943. struct sighand_struct *const sighand = current->sighand;
  944. spin_lock_irq(&sighand->siglock);
  945. if (signal_group_exit(sig))
  946. /* Another thread got here before we took the lock. */
  947. exit_code = sig->group_exit_code;
  948. else {
  949. sig->group_exit_code = exit_code;
  950. sig->flags = SIGNAL_GROUP_EXIT;
  951. zap_other_threads(current);
  952. }
  953. spin_unlock_irq(&sighand->siglock);
  954. }
  955. do_exit(exit_code);
  956. /* NOTREACHED */
  957. }
  958. /*
  959. * this kills every thread in the thread group. Note that any externally
  960. * wait4()-ing process will get the correct exit code - even if this
  961. * thread is not the thread group leader.
  962. */
  963. SYSCALL_DEFINE1(exit_group, int, error_code)
  964. {
  965. do_group_exit((error_code & 0xff) << 8);
  966. /* NOTREACHED */
  967. return 0;
  968. }
  969. struct wait_opts {
  970. enum pid_type wo_type;
  971. int wo_flags;
  972. struct pid *wo_pid;
  973. struct siginfo __user *wo_info;
  974. int __user *wo_stat;
  975. struct rusage __user *wo_rusage;
  976. wait_queue_t child_wait;
  977. int notask_error;
  978. };
  979. static inline
  980. struct pid *task_pid_type(struct task_struct *task, enum pid_type type)
  981. {
  982. if (type != PIDTYPE_PID)
  983. task = task->group_leader;
  984. return task->pids[type].pid;
  985. }
  986. static int eligible_pid(struct wait_opts *wo, struct task_struct *p)
  987. {
  988. return wo->wo_type == PIDTYPE_MAX ||
  989. task_pid_type(p, wo->wo_type) == wo->wo_pid;
  990. }
  991. static int eligible_child(struct wait_opts *wo, struct task_struct *p)
  992. {
  993. if (!eligible_pid(wo, p))
  994. return 0;
  995. /* Wait for all children (clone and not) if __WALL is set;
  996. * otherwise, wait for clone children *only* if __WCLONE is
  997. * set; otherwise, wait for non-clone children *only*. (Note:
  998. * A "clone" child here is one that reports to its parent
  999. * using a signal other than SIGCHLD.) */
  1000. if (((p->exit_signal != SIGCHLD) ^ !!(wo->wo_flags & __WCLONE))
  1001. && !(wo->wo_flags & __WALL))
  1002. return 0;
  1003. return 1;
  1004. }
  1005. static int wait_noreap_copyout(struct wait_opts *wo, struct task_struct *p,
  1006. pid_t pid, uid_t uid, int why, int status)
  1007. {
  1008. struct siginfo __user *infop;
  1009. int retval = wo->wo_rusage
  1010. ? getrusage(p, RUSAGE_BOTH, wo->wo_rusage) : 0;
  1011. put_task_struct(p);
  1012. infop = wo->wo_info;
  1013. if (infop) {
  1014. if (!retval)
  1015. retval = put_user(SIGCHLD, &infop->si_signo);
  1016. if (!retval)
  1017. retval = put_user(0, &infop->si_errno);
  1018. if (!retval)
  1019. retval = put_user((short)why, &infop->si_code);
  1020. if (!retval)
  1021. retval = put_user(pid, &infop->si_pid);
  1022. if (!retval)
  1023. retval = put_user(uid, &infop->si_uid);
  1024. if (!retval)
  1025. retval = put_user(status, &infop->si_status);
  1026. }
  1027. if (!retval)
  1028. retval = pid;
  1029. return retval;
  1030. }
  1031. /*
  1032. * Handle sys_wait4 work for one task in state EXIT_ZOMBIE. We hold
  1033. * read_lock(&tasklist_lock) on entry. If we return zero, we still hold
  1034. * the lock and this task is uninteresting. If we return nonzero, we have
  1035. * released the lock and the system call should return.
  1036. */
  1037. static int wait_task_zombie(struct wait_opts *wo, struct task_struct *p)
  1038. {
  1039. unsigned long state;
  1040. int retval, status, traced;
  1041. pid_t pid = task_pid_vnr(p);
  1042. uid_t uid = __task_cred(p)->uid;
  1043. struct siginfo __user *infop;
  1044. if (!likely(wo->wo_flags & WEXITED))
  1045. return 0;
  1046. if (unlikely(wo->wo_flags & WNOWAIT)) {
  1047. int exit_code = p->exit_code;
  1048. int why;
  1049. get_task_struct(p);
  1050. read_unlock(&tasklist_lock);
  1051. if ((exit_code & 0x7f) == 0) {
  1052. why = CLD_EXITED;
  1053. status = exit_code >> 8;
  1054. } else {
  1055. why = (exit_code & 0x80) ? CLD_DUMPED : CLD_KILLED;
  1056. status = exit_code & 0x7f;
  1057. }
  1058. return wait_noreap_copyout(wo, p, pid, uid, why, status);
  1059. }
  1060. /*
  1061. * Try to move the task's state to DEAD
  1062. * only one thread is allowed to do this:
  1063. */
  1064. state = xchg(&p->exit_state, EXIT_DEAD);
  1065. if (state != EXIT_ZOMBIE) {
  1066. BUG_ON(state != EXIT_DEAD);
  1067. return 0;
  1068. }
  1069. traced = ptrace_reparented(p);
  1070. /*
  1071. * It can be ptraced but not reparented, check
  1072. * !task_detached() to filter out sub-threads.
  1073. */
  1074. if (likely(!traced) && likely(!task_detached(p))) {
  1075. struct signal_struct *psig;
  1076. struct signal_struct *sig;
  1077. unsigned long maxrss;
  1078. cputime_t tgutime, tgstime;
  1079. /*
  1080. * The resource counters for the group leader are in its
  1081. * own task_struct. Those for dead threads in the group
  1082. * are in its signal_struct, as are those for the child
  1083. * processes it has previously reaped. All these
  1084. * accumulate in the parent's signal_struct c* fields.
  1085. *
  1086. * We don't bother to take a lock here to protect these
  1087. * p->signal fields, because they are only touched by
  1088. * __exit_signal, which runs with tasklist_lock
  1089. * write-locked anyway, and so is excluded here. We do
  1090. * need to protect the access to parent->signal fields,
  1091. * as other threads in the parent group can be right
  1092. * here reaping other children at the same time.
  1093. *
  1094. * We use thread_group_times() to get times for the thread
  1095. * group, which consolidates times for all threads in the
  1096. * group including the group leader.
  1097. */
  1098. thread_group_times(p, &tgutime, &tgstime);
  1099. spin_lock_irq(&p->real_parent->sighand->siglock);
  1100. psig = p->real_parent->signal;
  1101. sig = p->signal;
  1102. psig->cutime =
  1103. cputime_add(psig->cutime,
  1104. cputime_add(tgutime,
  1105. sig->cutime));
  1106. psig->cstime =
  1107. cputime_add(psig->cstime,
  1108. cputime_add(tgstime,
  1109. sig->cstime));
  1110. psig->cgtime =
  1111. cputime_add(psig->cgtime,
  1112. cputime_add(p->gtime,
  1113. cputime_add(sig->gtime,
  1114. sig->cgtime)));
  1115. psig->cmin_flt +=
  1116. p->min_flt + sig->min_flt + sig->cmin_flt;
  1117. psig->cmaj_flt +=
  1118. p->maj_flt + sig->maj_flt + sig->cmaj_flt;
  1119. psig->cnvcsw +=
  1120. p->nvcsw + sig->nvcsw + sig->cnvcsw;
  1121. psig->cnivcsw +=
  1122. p->nivcsw + sig->nivcsw + sig->cnivcsw;
  1123. psig->cinblock +=
  1124. task_io_get_inblock(p) +
  1125. sig->inblock + sig->cinblock;
  1126. psig->coublock +=
  1127. task_io_get_oublock(p) +
  1128. sig->oublock + sig->coublock;
  1129. maxrss = max(sig->maxrss, sig->cmaxrss);
  1130. if (psig->cmaxrss < maxrss)
  1131. psig->cmaxrss = maxrss;
  1132. task_io_accounting_add(&psig->ioac, &p->ioac);
  1133. task_io_accounting_add(&psig->ioac, &sig->ioac);
  1134. spin_unlock_irq(&p->real_parent->sighand->siglock);
  1135. }
  1136. /*
  1137. * Now we are sure this task is interesting, and no other
  1138. * thread can reap it because we set its state to EXIT_DEAD.
  1139. */
  1140. read_unlock(&tasklist_lock);
  1141. retval = wo->wo_rusage
  1142. ? getrusage(p, RUSAGE_BOTH, wo->wo_rusage) : 0;
  1143. status = (p->signal->flags & SIGNAL_GROUP_EXIT)
  1144. ? p->signal->group_exit_code : p->exit_code;
  1145. if (!retval && wo->wo_stat)
  1146. retval = put_user(status, wo->wo_stat);
  1147. infop = wo->wo_info;
  1148. if (!retval && infop)
  1149. retval = put_user(SIGCHLD, &infop->si_signo);
  1150. if (!retval && infop)
  1151. retval = put_user(0, &infop->si_errno);
  1152. if (!retval && infop) {
  1153. int why;
  1154. if ((status & 0x7f) == 0) {
  1155. why = CLD_EXITED;
  1156. status >>= 8;
  1157. } else {
  1158. why = (status & 0x80) ? CLD_DUMPED : CLD_KILLED;
  1159. status &= 0x7f;
  1160. }
  1161. retval = put_user((short)why, &infop->si_code);
  1162. if (!retval)
  1163. retval = put_user(status, &infop->si_status);
  1164. }
  1165. if (!retval && infop)
  1166. retval = put_user(pid, &infop->si_pid);
  1167. if (!retval && infop)
  1168. retval = put_user(uid, &infop->si_uid);
  1169. if (!retval)
  1170. retval = pid;
  1171. if (traced) {
  1172. write_lock_irq(&tasklist_lock);
  1173. /* We dropped tasklist, ptracer could die and untrace */
  1174. ptrace_unlink(p);
  1175. /*
  1176. * If this is not a detached task, notify the parent.
  1177. * If it's still not detached after that, don't release
  1178. * it now.
  1179. */
  1180. if (!task_detached(p)) {
  1181. do_notify_parent(p, p->exit_signal);
  1182. if (!task_detached(p)) {
  1183. p->exit_state = EXIT_ZOMBIE;
  1184. p = NULL;
  1185. }
  1186. }
  1187. write_unlock_irq(&tasklist_lock);
  1188. }
  1189. if (p != NULL)
  1190. release_task(p);
  1191. return retval;
  1192. }
  1193. static int *task_stopped_code(struct task_struct *p, bool ptrace)
  1194. {
  1195. if (ptrace) {
  1196. if (task_is_stopped_or_traced(p))
  1197. return &p->exit_code;
  1198. } else {
  1199. if (p->signal->flags & SIGNAL_STOP_STOPPED)
  1200. return &p->signal->group_exit_code;
  1201. }
  1202. return NULL;
  1203. }
  1204. /**
  1205. * wait_task_stopped - Wait for %TASK_STOPPED or %TASK_TRACED
  1206. * @wo: wait options
  1207. * @ptrace: is the wait for ptrace
  1208. * @p: task to wait for
  1209. *
  1210. * Handle sys_wait4() work for %p in state %TASK_STOPPED or %TASK_TRACED.
  1211. *
  1212. * CONTEXT:
  1213. * read_lock(&tasklist_lock), which is released if return value is
  1214. * non-zero. Also, grabs and releases @p->sighand->siglock.
  1215. *
  1216. * RETURNS:
  1217. * 0 if wait condition didn't exist and search for other wait conditions
  1218. * should continue. Non-zero return, -errno on failure and @p's pid on
  1219. * success, implies that tasklist_lock is released and wait condition
  1220. * search should terminate.
  1221. */
  1222. static int wait_task_stopped(struct wait_opts *wo,
  1223. int ptrace, struct task_struct *p)
  1224. {
  1225. struct siginfo __user *infop;
  1226. int retval, exit_code, *p_code, why;
  1227. uid_t uid = 0; /* unneeded, required by compiler */
  1228. pid_t pid;
  1229. /*
  1230. * Traditionally we see ptrace'd stopped tasks regardless of options.
  1231. */
  1232. if (!ptrace && !(wo->wo_flags & WUNTRACED))
  1233. return 0;
  1234. if (!task_stopped_code(p, ptrace))
  1235. return 0;
  1236. exit_code = 0;
  1237. spin_lock_irq(&p->sighand->siglock);
  1238. p_code = task_stopped_code(p, ptrace);
  1239. if (unlikely(!p_code))
  1240. goto unlock_sig;
  1241. exit_code = *p_code;
  1242. if (!exit_code)
  1243. goto unlock_sig;
  1244. if (!unlikely(wo->wo_flags & WNOWAIT))
  1245. *p_code = 0;
  1246. uid = task_uid(p);
  1247. unlock_sig:
  1248. spin_unlock_irq(&p->sighand->siglock);
  1249. if (!exit_code)
  1250. return 0;
  1251. /*
  1252. * Now we are pretty sure this task is interesting.
  1253. * Make sure it doesn't get reaped out from under us while we
  1254. * give up the lock and then examine it below. We don't want to
  1255. * keep holding onto the tasklist_lock while we call getrusage and
  1256. * possibly take page faults for user memory.
  1257. */
  1258. get_task_struct(p);
  1259. pid = task_pid_vnr(p);
  1260. why = ptrace ? CLD_TRAPPED : CLD_STOPPED;
  1261. read_unlock(&tasklist_lock);
  1262. if (unlikely(wo->wo_flags & WNOWAIT))
  1263. return wait_noreap_copyout(wo, p, pid, uid, why, exit_code);
  1264. retval = wo->wo_rusage
  1265. ? getrusage(p, RUSAGE_BOTH, wo->wo_rusage) : 0;
  1266. if (!retval && wo->wo_stat)
  1267. retval = put_user((exit_code << 8) | 0x7f, wo->wo_stat);
  1268. infop = wo->wo_info;
  1269. if (!retval && infop)
  1270. retval = put_user(SIGCHLD, &infop->si_signo);
  1271. if (!retval && infop)
  1272. retval = put_user(0, &infop->si_errno);
  1273. if (!retval && infop)
  1274. retval = put_user((short)why, &infop->si_code);
  1275. if (!retval && infop)
  1276. retval = put_user(exit_code, &infop->si_status);
  1277. if (!retval && infop)
  1278. retval = put_user(pid, &infop->si_pid);
  1279. if (!retval && infop)
  1280. retval = put_user(uid, &infop->si_uid);
  1281. if (!retval)
  1282. retval = pid;
  1283. put_task_struct(p);
  1284. BUG_ON(!retval);
  1285. return retval;
  1286. }
  1287. /*
  1288. * Handle do_wait work for one task in a live, non-stopped state.
  1289. * read_lock(&tasklist_lock) on entry. If we return zero, we still hold
  1290. * the lock and this task is uninteresting. If we return nonzero, we have
  1291. * released the lock and the system call should return.
  1292. */
  1293. static int wait_task_continued(struct wait_opts *wo, struct task_struct *p)
  1294. {
  1295. int retval;
  1296. pid_t pid;
  1297. uid_t uid;
  1298. if (!unlikely(wo->wo_flags & WCONTINUED))
  1299. return 0;
  1300. if (!(p->signal->flags & SIGNAL_STOP_CONTINUED))
  1301. return 0;
  1302. spin_lock_irq(&p->sighand->siglock);
  1303. /* Re-check with the lock held. */
  1304. if (!(p->signal->flags & SIGNAL_STOP_CONTINUED)) {
  1305. spin_unlock_irq(&p->sighand->siglock);
  1306. return 0;
  1307. }
  1308. if (!unlikely(wo->wo_flags & WNOWAIT))
  1309. p->signal->flags &= ~SIGNAL_STOP_CONTINUED;
  1310. uid = task_uid(p);
  1311. spin_unlock_irq(&p->sighand->siglock);
  1312. pid = task_pid_vnr(p);
  1313. get_task_struct(p);
  1314. read_unlock(&tasklist_lock);
  1315. if (!wo->wo_info) {
  1316. retval = wo->wo_rusage
  1317. ? getrusage(p, RUSAGE_BOTH, wo->wo_rusage) : 0;
  1318. put_task_struct(p);
  1319. if (!retval && wo->wo_stat)
  1320. retval = put_user(0xffff, wo->wo_stat);
  1321. if (!retval)
  1322. retval = pid;
  1323. } else {
  1324. retval = wait_noreap_copyout(wo, p, pid, uid,
  1325. CLD_CONTINUED, SIGCONT);
  1326. BUG_ON(retval == 0);
  1327. }
  1328. return retval;
  1329. }
  1330. /*
  1331. * Consider @p for a wait by @parent.
  1332. *
  1333. * -ECHILD should be in ->notask_error before the first call.
  1334. * Returns nonzero for a final return, when we have unlocked tasklist_lock.
  1335. * Returns zero if the search for a child should continue;
  1336. * then ->notask_error is 0 if @p is an eligible child,
  1337. * or another error from security_task_wait(), or still -ECHILD.
  1338. */
  1339. static int wait_consider_task(struct wait_opts *wo, int ptrace,
  1340. struct task_struct *p)
  1341. {
  1342. int ret = eligible_child(wo, p);
  1343. if (!ret)
  1344. return ret;
  1345. ret = security_task_wait(p);
  1346. if (unlikely(ret < 0)) {
  1347. /*
  1348. * If we have not yet seen any eligible child,
  1349. * then let this error code replace -ECHILD.
  1350. * A permission error will give the user a clue
  1351. * to look for security policy problems, rather
  1352. * than for mysterious wait bugs.
  1353. */
  1354. if (wo->notask_error)
  1355. wo->notask_error = ret;
  1356. return 0;
  1357. }
  1358. /* dead body doesn't have much to contribute */
  1359. if (p->exit_state == EXIT_DEAD)
  1360. return 0;
  1361. /* slay zombie? */
  1362. if (p->exit_state == EXIT_ZOMBIE) {
  1363. /*
  1364. * A zombie ptracee is only visible to its ptracer.
  1365. * Notification and reaping will be cascaded to the real
  1366. * parent when the ptracer detaches.
  1367. */
  1368. if (likely(!ptrace) && unlikely(task_ptrace(p))) {
  1369. /* it will become visible, clear notask_error */
  1370. wo->notask_error = 0;
  1371. return 0;
  1372. }
  1373. /* we don't reap group leaders with subthreads */
  1374. if (!delay_group_leader(p))
  1375. return wait_task_zombie(wo, p);
  1376. /*
  1377. * Allow access to stopped/continued state via zombie by
  1378. * falling through. Clearing of notask_error is complex.
  1379. *
  1380. * When !@ptrace:
  1381. *
  1382. * If WEXITED is set, notask_error should naturally be
  1383. * cleared. If not, subset of WSTOPPED|WCONTINUED is set,
  1384. * so, if there are live subthreads, there are events to
  1385. * wait for. If all subthreads are dead, it's still safe
  1386. * to clear - this function will be called again in finite
  1387. * amount time once all the subthreads are released and
  1388. * will then return without clearing.
  1389. *
  1390. * When @ptrace:
  1391. *
  1392. * Stopped state is per-task and thus can't change once the
  1393. * target task dies. Only continued and exited can happen.
  1394. * Clear notask_error if WCONTINUED | WEXITED.
  1395. */
  1396. if (likely(!ptrace) || (wo->wo_flags & (WCONTINUED | WEXITED)))
  1397. wo->notask_error = 0;
  1398. } else {
  1399. /*
  1400. * If @p is ptraced by a task in its real parent's group,
  1401. * hide group stop/continued state when looking at @p as
  1402. * the real parent; otherwise, a single stop can be
  1403. * reported twice as group and ptrace stops.
  1404. *
  1405. * If a ptracer wants to distinguish the two events for its
  1406. * own children, it should create a separate process which
  1407. * takes the role of real parent.
  1408. */
  1409. if (likely(!ptrace) && task_ptrace(p) &&
  1410. same_thread_group(p->parent, p->real_parent))
  1411. return 0;
  1412. /*
  1413. * @p is alive and it's gonna stop, continue or exit, so
  1414. * there always is something to wait for.
  1415. */
  1416. wo->notask_error = 0;
  1417. }
  1418. /*
  1419. * Wait for stopped. Depending on @ptrace, different stopped state
  1420. * is used and the two don't interact with each other.
  1421. */
  1422. ret = wait_task_stopped(wo, ptrace, p);
  1423. if (ret)
  1424. return ret;
  1425. /*
  1426. * Wait for continued. There's only one continued state and the
  1427. * ptracer can consume it which can confuse the real parent. Don't
  1428. * use WCONTINUED from ptracer. You don't need or want it.
  1429. */
  1430. return wait_task_continued(wo, p);
  1431. }
  1432. /*
  1433. * Do the work of do_wait() for one thread in the group, @tsk.
  1434. *
  1435. * -ECHILD should be in ->notask_error before the first call.
  1436. * Returns nonzero for a final return, when we have unlocked tasklist_lock.
  1437. * Returns zero if the search for a child should continue; then
  1438. * ->notask_error is 0 if there were any eligible children,
  1439. * or another error from security_task_wait(), or still -ECHILD.
  1440. */
  1441. static int do_wait_thread(struct wait_opts *wo, struct task_struct *tsk)
  1442. {
  1443. struct task_struct *p;
  1444. list_for_each_entry(p, &tsk->children, sibling) {
  1445. int ret = wait_consider_task(wo, 0, p);
  1446. if (ret)
  1447. return ret;
  1448. }
  1449. return 0;
  1450. }
  1451. static int ptrace_do_wait(struct wait_opts *wo, struct task_struct *tsk)
  1452. {
  1453. struct task_struct *p;
  1454. list_for_each_entry(p, &tsk->ptraced, ptrace_entry) {
  1455. int ret = wait_consider_task(wo, 1, p);
  1456. if (ret)
  1457. return ret;
  1458. }
  1459. return 0;
  1460. }
  1461. static int child_wait_callback(wait_queue_t *wait, unsigned mode,
  1462. int sync, void *key)
  1463. {
  1464. struct wait_opts *wo = container_of(wait, struct wait_opts,
  1465. child_wait);
  1466. struct task_struct *p = key;
  1467. if (!eligible_pid(wo, p))
  1468. return 0;
  1469. if ((wo->wo_flags & __WNOTHREAD) && wait->private != p->parent)
  1470. return 0;
  1471. return default_wake_function(wait, mode, sync, key);
  1472. }
  1473. void __wake_up_parent(struct task_struct *p, struct task_struct *parent)
  1474. {
  1475. __wake_up_sync_key(&parent->signal->wait_chldexit,
  1476. TASK_INTERRUPTIBLE, 1, p);
  1477. }
  1478. static long do_wait(struct wait_opts *wo)
  1479. {
  1480. struct task_struct *tsk;
  1481. int retval;
  1482. trace_sched_process_wait(wo->wo_pid);
  1483. init_waitqueue_func_entry(&wo->child_wait, child_wait_callback);
  1484. wo->child_wait.private = current;
  1485. add_wait_queue(&current->signal->wait_chldexit, &wo->child_wait);
  1486. repeat:
  1487. /*
  1488. * If there is nothing that can match our critiera just get out.
  1489. * We will clear ->notask_error to zero if we see any child that
  1490. * might later match our criteria, even if we are not able to reap
  1491. * it yet.
  1492. */
  1493. wo->notask_error = -ECHILD;
  1494. if ((wo->wo_type < PIDTYPE_MAX) &&
  1495. (!wo->wo_pid || hlist_empty(&wo->wo_pid->tasks[wo->wo_type])))
  1496. goto notask;
  1497. set_current_state(TASK_INTERRUPTIBLE);
  1498. read_lock(&tasklist_lock);
  1499. tsk = current;
  1500. do {
  1501. retval = do_wait_thread(wo, tsk);
  1502. if (retval)
  1503. goto end;
  1504. retval = ptrace_do_wait(wo, tsk);
  1505. if (retval)
  1506. goto end;
  1507. if (wo->wo_flags & __WNOTHREAD)
  1508. break;
  1509. } while_each_thread(current, tsk);
  1510. read_unlock(&tasklist_lock);
  1511. notask:
  1512. retval = wo->notask_error;
  1513. if (!retval && !(wo->wo_flags & WNOHANG)) {
  1514. retval = -ERESTARTSYS;
  1515. if (!signal_pending(current)) {
  1516. schedule();
  1517. goto repeat;
  1518. }
  1519. }
  1520. end:
  1521. __set_current_state(TASK_RUNNING);
  1522. remove_wait_queue(&current->signal->wait_chldexit, &wo->child_wait);
  1523. return retval;
  1524. }
  1525. SYSCALL_DEFINE5(waitid, int, which, pid_t, upid, struct siginfo __user *,
  1526. infop, int, options, struct rusage __user *, ru)
  1527. {
  1528. struct wait_opts wo;
  1529. struct pid *pid = NULL;
  1530. enum pid_type type;
  1531. long ret;
  1532. if (options & ~(WNOHANG|WNOWAIT|WEXITED|WSTOPPED|WCONTINUED))
  1533. return -EINVAL;
  1534. if (!(options & (WEXITED|WSTOPPED|WCONTINUED)))
  1535. return -EINVAL;
  1536. switch (which) {
  1537. case P_ALL:
  1538. type = PIDTYPE_MAX;
  1539. break;
  1540. case P_PID:
  1541. type = PIDTYPE_PID;
  1542. if (upid <= 0)
  1543. return -EINVAL;
  1544. break;
  1545. case P_PGID:
  1546. type = PIDTYPE_PGID;
  1547. if (upid <= 0)
  1548. return -EINVAL;
  1549. break;
  1550. default:
  1551. return -EINVAL;
  1552. }
  1553. if (type < PIDTYPE_MAX)
  1554. pid = find_get_pid(upid);
  1555. wo.wo_type = type;
  1556. wo.wo_pid = pid;
  1557. wo.wo_flags = options;
  1558. wo.wo_info = infop;
  1559. wo.wo_stat = NULL;
  1560. wo.wo_rusage = ru;
  1561. ret = do_wait(&wo);
  1562. if (ret > 0) {
  1563. ret = 0;
  1564. } else if (infop) {
  1565. /*
  1566. * For a WNOHANG return, clear out all the fields
  1567. * we would set so the user can easily tell the
  1568. * difference.
  1569. */
  1570. if (!ret)
  1571. ret = put_user(0, &infop->si_signo);
  1572. if (!ret)
  1573. ret = put_user(0, &infop->si_errno);
  1574. if (!ret)
  1575. ret = put_user(0, &infop->si_code);
  1576. if (!ret)
  1577. ret = put_user(0, &infop->si_pid);
  1578. if (!ret)
  1579. ret = put_user(0, &infop->si_uid);
  1580. if (!ret)
  1581. ret = put_user(0, &infop->si_status);
  1582. }
  1583. put_pid(pid);
  1584. /* avoid REGPARM breakage on x86: */
  1585. asmlinkage_protect(5, ret, which, upid, infop, options, ru);
  1586. return ret;
  1587. }
  1588. SYSCALL_DEFINE4(wait4, pid_t, upid, int __user *, stat_addr,
  1589. int, options, struct rusage __user *, ru)
  1590. {
  1591. struct wait_opts wo;
  1592. struct pid *pid = NULL;
  1593. enum pid_type type;
  1594. long ret;
  1595. if (options & ~(WNOHANG|WUNTRACED|WCONTINUED|
  1596. __WNOTHREAD|__WCLONE|__WALL))
  1597. return -EINVAL;
  1598. if (upid == -1)
  1599. type = PIDTYPE_MAX;
  1600. else if (upid < 0) {
  1601. type = PIDTYPE_PGID;
  1602. pid = find_get_pid(-upid);
  1603. } else if (upid == 0) {
  1604. type = PIDTYPE_PGID;
  1605. pid = get_task_pid(current, PIDTYPE_PGID);
  1606. } else /* upid > 0 */ {
  1607. type = PIDTYPE_PID;
  1608. pid = find_get_pid(upid);
  1609. }
  1610. wo.wo_type = type;
  1611. wo.wo_pid = pid;
  1612. wo.wo_flags = options | WEXITED;
  1613. wo.wo_info = NULL;
  1614. wo.wo_stat = stat_addr;
  1615. wo.wo_rusage = ru;
  1616. ret = do_wait(&wo);
  1617. put_pid(pid);
  1618. /* avoid REGPARM breakage on x86: */
  1619. asmlinkage_protect(4, ret, upid, stat_addr, options, ru);
  1620. return ret;
  1621. }
  1622. #ifdef __ARCH_WANT_SYS_WAITPID
  1623. /*
  1624. * sys_waitpid() remains for compatibility. waitpid() should be
  1625. * implemented by calling sys_wait4() from libc.a.
  1626. */
  1627. SYSCALL_DEFINE3(waitpid, pid_t, pid, int __user *, stat_addr, int, options)
  1628. {
  1629. return sys_wait4(pid, stat_addr, options, NULL);
  1630. }
  1631. #endif