fork.c 40 KB

12345678910111213141516171819202122232425262728293031323334353637383940414243444546474849505152535455565758596061626364656667686970717273747576777879808182838485868788899091929394959697989910010110210310410510610710810911011111211311411511611711811912012112212312412512612712812913013113213313413513613713813914014114214314414514614714814915015115215315415515615715815916016116216316416516616716816917017117217317417517617717817918018118218318418518618718818919019119219319419519619719819920020120220320420520620720820921021121221321421521621721821922022122222322422522622722822923023123223323423523623723823924024124224324424524624724824925025125225325425525625725825926026126226326426526626726826927027127227327427527627727827928028128228328428528628728828929029129229329429529629729829930030130230330430530630730830931031131231331431531631731831932032132232332432532632732832933033133233333433533633733833934034134234334434534634734834935035135235335435535635735835936036136236336436536636736836937037137237337437537637737837938038138238338438538638738838939039139239339439539639739839940040140240340440540640740840941041141241341441541641741841942042142242342442542642742842943043143243343443543643743843944044144244344444544644744844945045145245345445545645745845946046146246346446546646746846947047147247347447547647747847948048148248348448548648748848949049149249349449549649749849950050150250350450550650750850951051151251351451551651751851952052152252352452552652752852953053153253353453553653753853954054154254354454554654754854955055155255355455555655755855956056156256356456556656756856957057157257357457557657757857958058158258358458558658758858959059159259359459559659759859960060160260360460560660760860961061161261361461561661761861962062162262362462562662762862963063163263363463563663763863964064164264364464564664764864965065165265365465565665765865966066166266366466566666766866967067167267367467567667767867968068168268368468568668768868969069169269369469569669769869970070170270370470570670770870971071171271371471571671771871972072172272372472572672772872973073173273373473573673773873974074174274374474574674774874975075175275375475575675775875976076176276376476576676776876977077177277377477577677777877978078178278378478578678778878979079179279379479579679779879980080180280380480580680780880981081181281381481581681781881982082182282382482582682782882983083183283383483583683783883984084184284384484584684784884985085185285385485585685785885986086186286386486586686786886987087187287387487587687787887988088188288388488588688788888989089189289389489589689789889990090190290390490590690790890991091191291391491591691791891992092192292392492592692792892993093193293393493593693793893994094194294394494594694794894995095195295395495595695795895996096196296396496596696796896997097197297397497597697797897998098198298398498598698798898999099199299399499599699799899910001001100210031004100510061007100810091010101110121013101410151016101710181019102010211022102310241025102610271028102910301031103210331034103510361037103810391040104110421043104410451046104710481049105010511052105310541055105610571058105910601061106210631064106510661067106810691070107110721073107410751076107710781079108010811082108310841085108610871088108910901091109210931094109510961097109810991100110111021103110411051106110711081109111011111112111311141115111611171118111911201121112211231124112511261127112811291130113111321133113411351136113711381139114011411142114311441145114611471148114911501151115211531154115511561157115811591160116111621163116411651166116711681169117011711172117311741175117611771178117911801181118211831184118511861187118811891190119111921193119411951196119711981199120012011202120312041205120612071208120912101211121212131214121512161217121812191220122112221223122412251226122712281229123012311232123312341235123612371238123912401241124212431244124512461247124812491250125112521253125412551256125712581259126012611262126312641265126612671268126912701271127212731274127512761277127812791280128112821283128412851286128712881289129012911292129312941295129612971298129913001301130213031304130513061307130813091310131113121313131413151316131713181319132013211322132313241325132613271328132913301331133213331334133513361337133813391340134113421343134413451346134713481349135013511352135313541355135613571358135913601361136213631364136513661367136813691370137113721373137413751376137713781379138013811382138313841385138613871388138913901391139213931394139513961397139813991400140114021403140414051406140714081409141014111412141314141415141614171418141914201421142214231424142514261427142814291430143114321433143414351436143714381439144014411442144314441445144614471448144914501451145214531454145514561457145814591460146114621463146414651466146714681469147014711472147314741475147614771478147914801481148214831484148514861487148814891490149114921493149414951496149714981499150015011502150315041505150615071508150915101511151215131514151515161517151815191520152115221523152415251526152715281529153015311532153315341535153615371538153915401541154215431544154515461547154815491550155115521553155415551556155715581559156015611562156315641565156615671568156915701571157215731574157515761577157815791580158115821583158415851586158715881589159015911592159315941595159615971598159916001601160216031604160516061607160816091610161116121613161416151616161716181619162016211622162316241625162616271628162916301631163216331634163516361637163816391640164116421643164416451646164716481649165016511652165316541655165616571658165916601661166216631664166516661667166816691670167116721673167416751676167716781679168016811682
  1. /*
  2. * linux/kernel/fork.c
  3. *
  4. * Copyright (C) 1991, 1992 Linus Torvalds
  5. */
  6. /*
  7. * 'fork.c' contains the help-routines for the 'fork' system call
  8. * (see also entry.S and others).
  9. * Fork is rather simple, once you get the hang of it, but the memory
  10. * management can be a bitch. See 'mm/memory.c': 'copy_page_range()'
  11. */
  12. #include <linux/slab.h>
  13. #include <linux/init.h>
  14. #include <linux/unistd.h>
  15. #include <linux/module.h>
  16. #include <linux/vmalloc.h>
  17. #include <linux/completion.h>
  18. #include <linux/mnt_namespace.h>
  19. #include <linux/personality.h>
  20. #include <linux/mempolicy.h>
  21. #include <linux/sem.h>
  22. #include <linux/file.h>
  23. #include <linux/fdtable.h>
  24. #include <linux/iocontext.h>
  25. #include <linux/key.h>
  26. #include <linux/binfmts.h>
  27. #include <linux/mman.h>
  28. #include <linux/mmu_notifier.h>
  29. #include <linux/fs.h>
  30. #include <linux/nsproxy.h>
  31. #include <linux/capability.h>
  32. #include <linux/cpu.h>
  33. #include <linux/cgroup.h>
  34. #include <linux/security.h>
  35. #include <linux/hugetlb.h>
  36. #include <linux/swap.h>
  37. #include <linux/syscalls.h>
  38. #include <linux/jiffies.h>
  39. #include <linux/tracehook.h>
  40. #include <linux/futex.h>
  41. #include <linux/task_io_accounting_ops.h>
  42. #include <linux/rcupdate.h>
  43. #include <linux/ptrace.h>
  44. #include <linux/mount.h>
  45. #include <linux/audit.h>
  46. #include <linux/memcontrol.h>
  47. #include <linux/profile.h>
  48. #include <linux/rmap.h>
  49. #include <linux/acct.h>
  50. #include <linux/tsacct_kern.h>
  51. #include <linux/cn_proc.h>
  52. #include <linux/freezer.h>
  53. #include <linux/delayacct.h>
  54. #include <linux/taskstats_kern.h>
  55. #include <linux/random.h>
  56. #include <linux/tty.h>
  57. #include <linux/proc_fs.h>
  58. #include <linux/blkdev.h>
  59. #include <trace/sched.h>
  60. #include <asm/pgtable.h>
  61. #include <asm/pgalloc.h>
  62. #include <asm/uaccess.h>
  63. #include <asm/mmu_context.h>
  64. #include <asm/cacheflush.h>
  65. #include <asm/tlbflush.h>
  66. /*
  67. * Protected counters by write_lock_irq(&tasklist_lock)
  68. */
  69. unsigned long total_forks; /* Handle normal Linux uptimes. */
  70. int nr_threads; /* The idle threads do not count.. */
  71. int max_threads; /* tunable limit on nr_threads */
  72. DEFINE_PER_CPU(unsigned long, process_counts) = 0;
  73. __cacheline_aligned DEFINE_RWLOCK(tasklist_lock); /* outer */
  74. int nr_processes(void)
  75. {
  76. int cpu;
  77. int total = 0;
  78. for_each_online_cpu(cpu)
  79. total += per_cpu(process_counts, cpu);
  80. return total;
  81. }
  82. #ifndef __HAVE_ARCH_TASK_STRUCT_ALLOCATOR
  83. # define alloc_task_struct() kmem_cache_alloc(task_struct_cachep, GFP_KERNEL)
  84. # define free_task_struct(tsk) kmem_cache_free(task_struct_cachep, (tsk))
  85. static struct kmem_cache *task_struct_cachep;
  86. #endif
  87. #ifndef __HAVE_ARCH_THREAD_INFO_ALLOCATOR
  88. static inline struct thread_info *alloc_thread_info(struct task_struct *tsk)
  89. {
  90. #ifdef CONFIG_DEBUG_STACK_USAGE
  91. gfp_t mask = GFP_KERNEL | __GFP_ZERO;
  92. #else
  93. gfp_t mask = GFP_KERNEL;
  94. #endif
  95. return (struct thread_info *)__get_free_pages(mask, THREAD_SIZE_ORDER);
  96. }
  97. static inline void free_thread_info(struct thread_info *ti)
  98. {
  99. free_pages((unsigned long)ti, THREAD_SIZE_ORDER);
  100. }
  101. #endif
  102. /* SLAB cache for signal_struct structures (tsk->signal) */
  103. static struct kmem_cache *signal_cachep;
  104. /* SLAB cache for sighand_struct structures (tsk->sighand) */
  105. struct kmem_cache *sighand_cachep;
  106. /* SLAB cache for files_struct structures (tsk->files) */
  107. struct kmem_cache *files_cachep;
  108. /* SLAB cache for fs_struct structures (tsk->fs) */
  109. struct kmem_cache *fs_cachep;
  110. /* SLAB cache for vm_area_struct structures */
  111. struct kmem_cache *vm_area_cachep;
  112. /* SLAB cache for mm_struct structures (tsk->mm) */
  113. static struct kmem_cache *mm_cachep;
  114. void free_task(struct task_struct *tsk)
  115. {
  116. prop_local_destroy_single(&tsk->dirties);
  117. free_thread_info(tsk->stack);
  118. rt_mutex_debug_task_free(tsk);
  119. free_task_struct(tsk);
  120. }
  121. EXPORT_SYMBOL(free_task);
  122. void __put_task_struct(struct task_struct *tsk)
  123. {
  124. WARN_ON(!tsk->exit_state);
  125. WARN_ON(atomic_read(&tsk->usage));
  126. WARN_ON(tsk == current);
  127. put_cred(tsk->cred);
  128. delayacct_tsk_free(tsk);
  129. if (!profile_handoff_task(tsk))
  130. free_task(tsk);
  131. }
  132. /*
  133. * macro override instead of weak attribute alias, to workaround
  134. * gcc 4.1.0 and 4.1.1 bugs with weak attribute and empty functions.
  135. */
  136. #ifndef arch_task_cache_init
  137. #define arch_task_cache_init()
  138. #endif
  139. void __init fork_init(unsigned long mempages)
  140. {
  141. #ifndef __HAVE_ARCH_TASK_STRUCT_ALLOCATOR
  142. #ifndef ARCH_MIN_TASKALIGN
  143. #define ARCH_MIN_TASKALIGN L1_CACHE_BYTES
  144. #endif
  145. /* create a slab on which task_structs can be allocated */
  146. task_struct_cachep =
  147. kmem_cache_create("task_struct", sizeof(struct task_struct),
  148. ARCH_MIN_TASKALIGN, SLAB_PANIC, NULL);
  149. #endif
  150. /* do the arch specific task caches init */
  151. arch_task_cache_init();
  152. /*
  153. * The default maximum number of threads is set to a safe
  154. * value: the thread structures can take up at most half
  155. * of memory.
  156. */
  157. max_threads = mempages / (8 * THREAD_SIZE / PAGE_SIZE);
  158. /*
  159. * we need to allow at least 20 threads to boot a system
  160. */
  161. if(max_threads < 20)
  162. max_threads = 20;
  163. init_task.signal->rlim[RLIMIT_NPROC].rlim_cur = max_threads/2;
  164. init_task.signal->rlim[RLIMIT_NPROC].rlim_max = max_threads/2;
  165. init_task.signal->rlim[RLIMIT_SIGPENDING] =
  166. init_task.signal->rlim[RLIMIT_NPROC];
  167. }
  168. int __attribute__((weak)) arch_dup_task_struct(struct task_struct *dst,
  169. struct task_struct *src)
  170. {
  171. *dst = *src;
  172. return 0;
  173. }
  174. static struct task_struct *dup_task_struct(struct task_struct *orig)
  175. {
  176. struct task_struct *tsk;
  177. struct thread_info *ti;
  178. int err;
  179. prepare_to_copy(orig);
  180. tsk = alloc_task_struct();
  181. if (!tsk)
  182. return NULL;
  183. ti = alloc_thread_info(tsk);
  184. if (!ti) {
  185. free_task_struct(tsk);
  186. return NULL;
  187. }
  188. err = arch_dup_task_struct(tsk, orig);
  189. if (err)
  190. goto out;
  191. tsk->stack = ti;
  192. err = prop_local_init_single(&tsk->dirties);
  193. if (err)
  194. goto out;
  195. setup_thread_stack(tsk, orig);
  196. #ifdef CONFIG_CC_STACKPROTECTOR
  197. tsk->stack_canary = get_random_int();
  198. #endif
  199. /* One for us, one for whoever does the "release_task()" (usually parent) */
  200. atomic_set(&tsk->usage,2);
  201. atomic_set(&tsk->fs_excl, 0);
  202. #ifdef CONFIG_BLK_DEV_IO_TRACE
  203. tsk->btrace_seq = 0;
  204. #endif
  205. tsk->splice_pipe = NULL;
  206. return tsk;
  207. out:
  208. free_thread_info(ti);
  209. free_task_struct(tsk);
  210. return NULL;
  211. }
  212. #ifdef CONFIG_MMU
  213. static int dup_mmap(struct mm_struct *mm, struct mm_struct *oldmm)
  214. {
  215. struct vm_area_struct *mpnt, *tmp, **pprev;
  216. struct rb_node **rb_link, *rb_parent;
  217. int retval;
  218. unsigned long charge;
  219. struct mempolicy *pol;
  220. down_write(&oldmm->mmap_sem);
  221. flush_cache_dup_mm(oldmm);
  222. /*
  223. * Not linked in yet - no deadlock potential:
  224. */
  225. down_write_nested(&mm->mmap_sem, SINGLE_DEPTH_NESTING);
  226. mm->locked_vm = 0;
  227. mm->mmap = NULL;
  228. mm->mmap_cache = NULL;
  229. mm->free_area_cache = oldmm->mmap_base;
  230. mm->cached_hole_size = ~0UL;
  231. mm->map_count = 0;
  232. cpus_clear(mm->cpu_vm_mask);
  233. mm->mm_rb = RB_ROOT;
  234. rb_link = &mm->mm_rb.rb_node;
  235. rb_parent = NULL;
  236. pprev = &mm->mmap;
  237. for (mpnt = oldmm->mmap; mpnt; mpnt = mpnt->vm_next) {
  238. struct file *file;
  239. if (mpnt->vm_flags & VM_DONTCOPY) {
  240. long pages = vma_pages(mpnt);
  241. mm->total_vm -= pages;
  242. vm_stat_account(mm, mpnt->vm_flags, mpnt->vm_file,
  243. -pages);
  244. continue;
  245. }
  246. charge = 0;
  247. if (mpnt->vm_flags & VM_ACCOUNT) {
  248. unsigned int len = (mpnt->vm_end - mpnt->vm_start) >> PAGE_SHIFT;
  249. if (security_vm_enough_memory(len))
  250. goto fail_nomem;
  251. charge = len;
  252. }
  253. tmp = kmem_cache_alloc(vm_area_cachep, GFP_KERNEL);
  254. if (!tmp)
  255. goto fail_nomem;
  256. *tmp = *mpnt;
  257. pol = mpol_dup(vma_policy(mpnt));
  258. retval = PTR_ERR(pol);
  259. if (IS_ERR(pol))
  260. goto fail_nomem_policy;
  261. vma_set_policy(tmp, pol);
  262. tmp->vm_flags &= ~VM_LOCKED;
  263. tmp->vm_mm = mm;
  264. tmp->vm_next = NULL;
  265. anon_vma_link(tmp);
  266. file = tmp->vm_file;
  267. if (file) {
  268. struct inode *inode = file->f_path.dentry->d_inode;
  269. get_file(file);
  270. if (tmp->vm_flags & VM_DENYWRITE)
  271. atomic_dec(&inode->i_writecount);
  272. /* insert tmp into the share list, just after mpnt */
  273. spin_lock(&file->f_mapping->i_mmap_lock);
  274. tmp->vm_truncate_count = mpnt->vm_truncate_count;
  275. flush_dcache_mmap_lock(file->f_mapping);
  276. vma_prio_tree_add(tmp, mpnt);
  277. flush_dcache_mmap_unlock(file->f_mapping);
  278. spin_unlock(&file->f_mapping->i_mmap_lock);
  279. }
  280. /*
  281. * Clear hugetlb-related page reserves for children. This only
  282. * affects MAP_PRIVATE mappings. Faults generated by the child
  283. * are not guaranteed to succeed, even if read-only
  284. */
  285. if (is_vm_hugetlb_page(tmp))
  286. reset_vma_resv_huge_pages(tmp);
  287. /*
  288. * Link in the new vma and copy the page table entries.
  289. */
  290. *pprev = tmp;
  291. pprev = &tmp->vm_next;
  292. __vma_link_rb(mm, tmp, rb_link, rb_parent);
  293. rb_link = &tmp->vm_rb.rb_right;
  294. rb_parent = &tmp->vm_rb;
  295. mm->map_count++;
  296. retval = copy_page_range(mm, oldmm, mpnt);
  297. if (tmp->vm_ops && tmp->vm_ops->open)
  298. tmp->vm_ops->open(tmp);
  299. if (retval)
  300. goto out;
  301. }
  302. /* a new mm has just been created */
  303. arch_dup_mmap(oldmm, mm);
  304. retval = 0;
  305. out:
  306. up_write(&mm->mmap_sem);
  307. flush_tlb_mm(oldmm);
  308. up_write(&oldmm->mmap_sem);
  309. return retval;
  310. fail_nomem_policy:
  311. kmem_cache_free(vm_area_cachep, tmp);
  312. fail_nomem:
  313. retval = -ENOMEM;
  314. vm_unacct_memory(charge);
  315. goto out;
  316. }
  317. static inline int mm_alloc_pgd(struct mm_struct * mm)
  318. {
  319. mm->pgd = pgd_alloc(mm);
  320. if (unlikely(!mm->pgd))
  321. return -ENOMEM;
  322. return 0;
  323. }
  324. static inline void mm_free_pgd(struct mm_struct * mm)
  325. {
  326. pgd_free(mm, mm->pgd);
  327. }
  328. #else
  329. #define dup_mmap(mm, oldmm) (0)
  330. #define mm_alloc_pgd(mm) (0)
  331. #define mm_free_pgd(mm)
  332. #endif /* CONFIG_MMU */
  333. __cacheline_aligned_in_smp DEFINE_SPINLOCK(mmlist_lock);
  334. #define allocate_mm() (kmem_cache_alloc(mm_cachep, GFP_KERNEL))
  335. #define free_mm(mm) (kmem_cache_free(mm_cachep, (mm)))
  336. #include <linux/init_task.h>
  337. static struct mm_struct * mm_init(struct mm_struct * mm, struct task_struct *p)
  338. {
  339. atomic_set(&mm->mm_users, 1);
  340. atomic_set(&mm->mm_count, 1);
  341. init_rwsem(&mm->mmap_sem);
  342. INIT_LIST_HEAD(&mm->mmlist);
  343. mm->flags = (current->mm) ? current->mm->flags
  344. : MMF_DUMP_FILTER_DEFAULT;
  345. mm->core_state = NULL;
  346. mm->nr_ptes = 0;
  347. set_mm_counter(mm, file_rss, 0);
  348. set_mm_counter(mm, anon_rss, 0);
  349. spin_lock_init(&mm->page_table_lock);
  350. rwlock_init(&mm->ioctx_list_lock);
  351. mm->ioctx_list = NULL;
  352. mm->free_area_cache = TASK_UNMAPPED_BASE;
  353. mm->cached_hole_size = ~0UL;
  354. mm_init_owner(mm, p);
  355. if (likely(!mm_alloc_pgd(mm))) {
  356. mm->def_flags = 0;
  357. mmu_notifier_mm_init(mm);
  358. return mm;
  359. }
  360. free_mm(mm);
  361. return NULL;
  362. }
  363. /*
  364. * Allocate and initialize an mm_struct.
  365. */
  366. struct mm_struct * mm_alloc(void)
  367. {
  368. struct mm_struct * mm;
  369. mm = allocate_mm();
  370. if (mm) {
  371. memset(mm, 0, sizeof(*mm));
  372. mm = mm_init(mm, current);
  373. }
  374. return mm;
  375. }
  376. /*
  377. * Called when the last reference to the mm
  378. * is dropped: either by a lazy thread or by
  379. * mmput. Free the page directory and the mm.
  380. */
  381. void __mmdrop(struct mm_struct *mm)
  382. {
  383. BUG_ON(mm == &init_mm);
  384. mm_free_pgd(mm);
  385. destroy_context(mm);
  386. mmu_notifier_mm_destroy(mm);
  387. free_mm(mm);
  388. }
  389. EXPORT_SYMBOL_GPL(__mmdrop);
  390. /*
  391. * Decrement the use count and release all resources for an mm.
  392. */
  393. void mmput(struct mm_struct *mm)
  394. {
  395. might_sleep();
  396. if (atomic_dec_and_test(&mm->mm_users)) {
  397. exit_aio(mm);
  398. exit_mmap(mm);
  399. set_mm_exe_file(mm, NULL);
  400. if (!list_empty(&mm->mmlist)) {
  401. spin_lock(&mmlist_lock);
  402. list_del(&mm->mmlist);
  403. spin_unlock(&mmlist_lock);
  404. }
  405. put_swap_token(mm);
  406. mmdrop(mm);
  407. }
  408. }
  409. EXPORT_SYMBOL_GPL(mmput);
  410. /**
  411. * get_task_mm - acquire a reference to the task's mm
  412. *
  413. * Returns %NULL if the task has no mm. Checks PF_KTHREAD (meaning
  414. * this kernel workthread has transiently adopted a user mm with use_mm,
  415. * to do its AIO) is not set and if so returns a reference to it, after
  416. * bumping up the use count. User must release the mm via mmput()
  417. * after use. Typically used by /proc and ptrace.
  418. */
  419. struct mm_struct *get_task_mm(struct task_struct *task)
  420. {
  421. struct mm_struct *mm;
  422. task_lock(task);
  423. mm = task->mm;
  424. if (mm) {
  425. if (task->flags & PF_KTHREAD)
  426. mm = NULL;
  427. else
  428. atomic_inc(&mm->mm_users);
  429. }
  430. task_unlock(task);
  431. return mm;
  432. }
  433. EXPORT_SYMBOL_GPL(get_task_mm);
  434. /* Please note the differences between mmput and mm_release.
  435. * mmput is called whenever we stop holding onto a mm_struct,
  436. * error success whatever.
  437. *
  438. * mm_release is called after a mm_struct has been removed
  439. * from the current process.
  440. *
  441. * This difference is important for error handling, when we
  442. * only half set up a mm_struct for a new process and need to restore
  443. * the old one. Because we mmput the new mm_struct before
  444. * restoring the old one. . .
  445. * Eric Biederman 10 January 1998
  446. */
  447. void mm_release(struct task_struct *tsk, struct mm_struct *mm)
  448. {
  449. struct completion *vfork_done = tsk->vfork_done;
  450. /* Get rid of any cached register state */
  451. deactivate_mm(tsk, mm);
  452. /* notify parent sleeping on vfork() */
  453. if (vfork_done) {
  454. tsk->vfork_done = NULL;
  455. complete(vfork_done);
  456. }
  457. /*
  458. * If we're exiting normally, clear a user-space tid field if
  459. * requested. We leave this alone when dying by signal, to leave
  460. * the value intact in a core dump, and to save the unnecessary
  461. * trouble otherwise. Userland only wants this done for a sys_exit.
  462. */
  463. if (tsk->clear_child_tid
  464. && !(tsk->flags & PF_SIGNALED)
  465. && atomic_read(&mm->mm_users) > 1) {
  466. u32 __user * tidptr = tsk->clear_child_tid;
  467. tsk->clear_child_tid = NULL;
  468. /*
  469. * We don't check the error code - if userspace has
  470. * not set up a proper pointer then tough luck.
  471. */
  472. put_user(0, tidptr);
  473. sys_futex(tidptr, FUTEX_WAKE, 1, NULL, NULL, 0);
  474. }
  475. }
  476. /*
  477. * Allocate a new mm structure and copy contents from the
  478. * mm structure of the passed in task structure.
  479. */
  480. struct mm_struct *dup_mm(struct task_struct *tsk)
  481. {
  482. struct mm_struct *mm, *oldmm = current->mm;
  483. int err;
  484. if (!oldmm)
  485. return NULL;
  486. mm = allocate_mm();
  487. if (!mm)
  488. goto fail_nomem;
  489. memcpy(mm, oldmm, sizeof(*mm));
  490. /* Initializing for Swap token stuff */
  491. mm->token_priority = 0;
  492. mm->last_interval = 0;
  493. if (!mm_init(mm, tsk))
  494. goto fail_nomem;
  495. if (init_new_context(tsk, mm))
  496. goto fail_nocontext;
  497. dup_mm_exe_file(oldmm, mm);
  498. err = dup_mmap(mm, oldmm);
  499. if (err)
  500. goto free_pt;
  501. mm->hiwater_rss = get_mm_rss(mm);
  502. mm->hiwater_vm = mm->total_vm;
  503. return mm;
  504. free_pt:
  505. mmput(mm);
  506. fail_nomem:
  507. return NULL;
  508. fail_nocontext:
  509. /*
  510. * If init_new_context() failed, we cannot use mmput() to free the mm
  511. * because it calls destroy_context()
  512. */
  513. mm_free_pgd(mm);
  514. free_mm(mm);
  515. return NULL;
  516. }
  517. static int copy_mm(unsigned long clone_flags, struct task_struct * tsk)
  518. {
  519. struct mm_struct * mm, *oldmm;
  520. int retval;
  521. tsk->min_flt = tsk->maj_flt = 0;
  522. tsk->nvcsw = tsk->nivcsw = 0;
  523. tsk->mm = NULL;
  524. tsk->active_mm = NULL;
  525. /*
  526. * Are we cloning a kernel thread?
  527. *
  528. * We need to steal a active VM for that..
  529. */
  530. oldmm = current->mm;
  531. if (!oldmm)
  532. return 0;
  533. if (clone_flags & CLONE_VM) {
  534. atomic_inc(&oldmm->mm_users);
  535. mm = oldmm;
  536. goto good_mm;
  537. }
  538. retval = -ENOMEM;
  539. mm = dup_mm(tsk);
  540. if (!mm)
  541. goto fail_nomem;
  542. good_mm:
  543. /* Initializing for Swap token stuff */
  544. mm->token_priority = 0;
  545. mm->last_interval = 0;
  546. tsk->mm = mm;
  547. tsk->active_mm = mm;
  548. return 0;
  549. fail_nomem:
  550. return retval;
  551. }
  552. static struct fs_struct *__copy_fs_struct(struct fs_struct *old)
  553. {
  554. struct fs_struct *fs = kmem_cache_alloc(fs_cachep, GFP_KERNEL);
  555. /* We don't need to lock fs - think why ;-) */
  556. if (fs) {
  557. atomic_set(&fs->count, 1);
  558. rwlock_init(&fs->lock);
  559. fs->umask = old->umask;
  560. read_lock(&old->lock);
  561. fs->root = old->root;
  562. path_get(&old->root);
  563. fs->pwd = old->pwd;
  564. path_get(&old->pwd);
  565. read_unlock(&old->lock);
  566. }
  567. return fs;
  568. }
  569. struct fs_struct *copy_fs_struct(struct fs_struct *old)
  570. {
  571. return __copy_fs_struct(old);
  572. }
  573. EXPORT_SYMBOL_GPL(copy_fs_struct);
  574. static int copy_fs(unsigned long clone_flags, struct task_struct *tsk)
  575. {
  576. if (clone_flags & CLONE_FS) {
  577. atomic_inc(&current->fs->count);
  578. return 0;
  579. }
  580. tsk->fs = __copy_fs_struct(current->fs);
  581. if (!tsk->fs)
  582. return -ENOMEM;
  583. return 0;
  584. }
  585. static int copy_files(unsigned long clone_flags, struct task_struct * tsk)
  586. {
  587. struct files_struct *oldf, *newf;
  588. int error = 0;
  589. /*
  590. * A background process may not have any files ...
  591. */
  592. oldf = current->files;
  593. if (!oldf)
  594. goto out;
  595. if (clone_flags & CLONE_FILES) {
  596. atomic_inc(&oldf->count);
  597. goto out;
  598. }
  599. newf = dup_fd(oldf, &error);
  600. if (!newf)
  601. goto out;
  602. tsk->files = newf;
  603. error = 0;
  604. out:
  605. return error;
  606. }
  607. static int copy_io(unsigned long clone_flags, struct task_struct *tsk)
  608. {
  609. #ifdef CONFIG_BLOCK
  610. struct io_context *ioc = current->io_context;
  611. if (!ioc)
  612. return 0;
  613. /*
  614. * Share io context with parent, if CLONE_IO is set
  615. */
  616. if (clone_flags & CLONE_IO) {
  617. tsk->io_context = ioc_task_link(ioc);
  618. if (unlikely(!tsk->io_context))
  619. return -ENOMEM;
  620. } else if (ioprio_valid(ioc->ioprio)) {
  621. tsk->io_context = alloc_io_context(GFP_KERNEL, -1);
  622. if (unlikely(!tsk->io_context))
  623. return -ENOMEM;
  624. tsk->io_context->ioprio = ioc->ioprio;
  625. }
  626. #endif
  627. return 0;
  628. }
  629. static int copy_sighand(unsigned long clone_flags, struct task_struct *tsk)
  630. {
  631. struct sighand_struct *sig;
  632. if (clone_flags & (CLONE_SIGHAND | CLONE_THREAD)) {
  633. atomic_inc(&current->sighand->count);
  634. return 0;
  635. }
  636. sig = kmem_cache_alloc(sighand_cachep, GFP_KERNEL);
  637. rcu_assign_pointer(tsk->sighand, sig);
  638. if (!sig)
  639. return -ENOMEM;
  640. atomic_set(&sig->count, 1);
  641. memcpy(sig->action, current->sighand->action, sizeof(sig->action));
  642. return 0;
  643. }
  644. void __cleanup_sighand(struct sighand_struct *sighand)
  645. {
  646. if (atomic_dec_and_test(&sighand->count))
  647. kmem_cache_free(sighand_cachep, sighand);
  648. }
  649. /*
  650. * Initialize POSIX timer handling for a thread group.
  651. */
  652. static void posix_cpu_timers_init_group(struct signal_struct *sig)
  653. {
  654. /* Thread group counters. */
  655. thread_group_cputime_init(sig);
  656. /* Expiration times and increments. */
  657. sig->it_virt_expires = cputime_zero;
  658. sig->it_virt_incr = cputime_zero;
  659. sig->it_prof_expires = cputime_zero;
  660. sig->it_prof_incr = cputime_zero;
  661. /* Cached expiration times. */
  662. sig->cputime_expires.prof_exp = cputime_zero;
  663. sig->cputime_expires.virt_exp = cputime_zero;
  664. sig->cputime_expires.sched_exp = 0;
  665. /* The timer lists. */
  666. INIT_LIST_HEAD(&sig->cpu_timers[0]);
  667. INIT_LIST_HEAD(&sig->cpu_timers[1]);
  668. INIT_LIST_HEAD(&sig->cpu_timers[2]);
  669. }
  670. static int copy_signal(unsigned long clone_flags, struct task_struct *tsk)
  671. {
  672. struct signal_struct *sig;
  673. int ret;
  674. if (clone_flags & CLONE_THREAD) {
  675. ret = thread_group_cputime_clone_thread(current);
  676. if (likely(!ret)) {
  677. atomic_inc(&current->signal->count);
  678. atomic_inc(&current->signal->live);
  679. }
  680. return ret;
  681. }
  682. sig = kmem_cache_alloc(signal_cachep, GFP_KERNEL);
  683. tsk->signal = sig;
  684. if (!sig)
  685. return -ENOMEM;
  686. atomic_set(&sig->count, 1);
  687. atomic_set(&sig->live, 1);
  688. init_waitqueue_head(&sig->wait_chldexit);
  689. sig->flags = 0;
  690. sig->group_exit_code = 0;
  691. sig->group_exit_task = NULL;
  692. sig->group_stop_count = 0;
  693. sig->curr_target = tsk;
  694. init_sigpending(&sig->shared_pending);
  695. INIT_LIST_HEAD(&sig->posix_timers);
  696. hrtimer_init(&sig->real_timer, CLOCK_MONOTONIC, HRTIMER_MODE_REL);
  697. sig->it_real_incr.tv64 = 0;
  698. sig->real_timer.function = it_real_fn;
  699. sig->leader = 0; /* session leadership doesn't inherit */
  700. sig->tty_old_pgrp = NULL;
  701. sig->tty = NULL;
  702. sig->cutime = sig->cstime = cputime_zero;
  703. sig->gtime = cputime_zero;
  704. sig->cgtime = cputime_zero;
  705. sig->nvcsw = sig->nivcsw = sig->cnvcsw = sig->cnivcsw = 0;
  706. sig->min_flt = sig->maj_flt = sig->cmin_flt = sig->cmaj_flt = 0;
  707. sig->inblock = sig->oublock = sig->cinblock = sig->coublock = 0;
  708. task_io_accounting_init(&sig->ioac);
  709. taskstats_tgid_init(sig);
  710. task_lock(current->group_leader);
  711. memcpy(sig->rlim, current->signal->rlim, sizeof sig->rlim);
  712. task_unlock(current->group_leader);
  713. posix_cpu_timers_init_group(sig);
  714. acct_init_pacct(&sig->pacct);
  715. tty_audit_fork(sig);
  716. return 0;
  717. }
  718. void __cleanup_signal(struct signal_struct *sig)
  719. {
  720. thread_group_cputime_free(sig);
  721. tty_kref_put(sig->tty);
  722. kmem_cache_free(signal_cachep, sig);
  723. }
  724. static void cleanup_signal(struct task_struct *tsk)
  725. {
  726. struct signal_struct *sig = tsk->signal;
  727. atomic_dec(&sig->live);
  728. if (atomic_dec_and_test(&sig->count))
  729. __cleanup_signal(sig);
  730. }
  731. static void copy_flags(unsigned long clone_flags, struct task_struct *p)
  732. {
  733. unsigned long new_flags = p->flags;
  734. new_flags &= ~PF_SUPERPRIV;
  735. new_flags |= PF_FORKNOEXEC;
  736. new_flags |= PF_STARTING;
  737. p->flags = new_flags;
  738. clear_freeze_flag(p);
  739. }
  740. asmlinkage long sys_set_tid_address(int __user *tidptr)
  741. {
  742. current->clear_child_tid = tidptr;
  743. return task_pid_vnr(current);
  744. }
  745. static void rt_mutex_init_task(struct task_struct *p)
  746. {
  747. spin_lock_init(&p->pi_lock);
  748. #ifdef CONFIG_RT_MUTEXES
  749. plist_head_init(&p->pi_waiters, &p->pi_lock);
  750. p->pi_blocked_on = NULL;
  751. #endif
  752. }
  753. #ifdef CONFIG_MM_OWNER
  754. void mm_init_owner(struct mm_struct *mm, struct task_struct *p)
  755. {
  756. mm->owner = p;
  757. }
  758. #endif /* CONFIG_MM_OWNER */
  759. /*
  760. * Initialize POSIX timer handling for a single task.
  761. */
  762. static void posix_cpu_timers_init(struct task_struct *tsk)
  763. {
  764. tsk->cputime_expires.prof_exp = cputime_zero;
  765. tsk->cputime_expires.virt_exp = cputime_zero;
  766. tsk->cputime_expires.sched_exp = 0;
  767. INIT_LIST_HEAD(&tsk->cpu_timers[0]);
  768. INIT_LIST_HEAD(&tsk->cpu_timers[1]);
  769. INIT_LIST_HEAD(&tsk->cpu_timers[2]);
  770. }
  771. /*
  772. * This creates a new process as a copy of the old one,
  773. * but does not actually start it yet.
  774. *
  775. * It copies the registers, and all the appropriate
  776. * parts of the process environment (as per the clone
  777. * flags). The actual kick-off is left to the caller.
  778. */
  779. static struct task_struct *copy_process(unsigned long clone_flags,
  780. unsigned long stack_start,
  781. struct pt_regs *regs,
  782. unsigned long stack_size,
  783. int __user *child_tidptr,
  784. struct pid *pid,
  785. int trace)
  786. {
  787. int retval;
  788. struct task_struct *p;
  789. int cgroup_callbacks_done = 0;
  790. if ((clone_flags & (CLONE_NEWNS|CLONE_FS)) == (CLONE_NEWNS|CLONE_FS))
  791. return ERR_PTR(-EINVAL);
  792. /*
  793. * Thread groups must share signals as well, and detached threads
  794. * can only be started up within the thread group.
  795. */
  796. if ((clone_flags & CLONE_THREAD) && !(clone_flags & CLONE_SIGHAND))
  797. return ERR_PTR(-EINVAL);
  798. /*
  799. * Shared signal handlers imply shared VM. By way of the above,
  800. * thread groups also imply shared VM. Blocking this case allows
  801. * for various simplifications in other code.
  802. */
  803. if ((clone_flags & CLONE_SIGHAND) && !(clone_flags & CLONE_VM))
  804. return ERR_PTR(-EINVAL);
  805. retval = security_task_create(clone_flags);
  806. if (retval)
  807. goto fork_out;
  808. retval = -ENOMEM;
  809. p = dup_task_struct(current);
  810. if (!p)
  811. goto fork_out;
  812. rt_mutex_init_task(p);
  813. #ifdef CONFIG_PROVE_LOCKING
  814. DEBUG_LOCKS_WARN_ON(!p->hardirqs_enabled);
  815. DEBUG_LOCKS_WARN_ON(!p->softirqs_enabled);
  816. #endif
  817. retval = -EAGAIN;
  818. if (atomic_read(&p->cred->user->processes) >=
  819. p->signal->rlim[RLIMIT_NPROC].rlim_cur) {
  820. if (!capable(CAP_SYS_ADMIN) && !capable(CAP_SYS_RESOURCE) &&
  821. p->cred->user != current->nsproxy->user_ns->root_user)
  822. goto bad_fork_free;
  823. }
  824. retval = copy_creds(p, clone_flags);
  825. if (retval < 0)
  826. goto bad_fork_free;
  827. /*
  828. * If multiple threads are within copy_process(), then this check
  829. * triggers too late. This doesn't hurt, the check is only there
  830. * to stop root fork bombs.
  831. */
  832. if (nr_threads >= max_threads)
  833. goto bad_fork_cleanup_count;
  834. if (!try_module_get(task_thread_info(p)->exec_domain->module))
  835. goto bad_fork_cleanup_count;
  836. if (p->binfmt && !try_module_get(p->binfmt->module))
  837. goto bad_fork_cleanup_put_domain;
  838. p->did_exec = 0;
  839. delayacct_tsk_init(p); /* Must remain after dup_task_struct() */
  840. copy_flags(clone_flags, p);
  841. INIT_LIST_HEAD(&p->children);
  842. INIT_LIST_HEAD(&p->sibling);
  843. #ifdef CONFIG_PREEMPT_RCU
  844. p->rcu_read_lock_nesting = 0;
  845. p->rcu_flipctr_idx = 0;
  846. #endif /* #ifdef CONFIG_PREEMPT_RCU */
  847. p->vfork_done = NULL;
  848. spin_lock_init(&p->alloc_lock);
  849. clear_tsk_thread_flag(p, TIF_SIGPENDING);
  850. init_sigpending(&p->pending);
  851. p->utime = cputime_zero;
  852. p->stime = cputime_zero;
  853. p->gtime = cputime_zero;
  854. p->utimescaled = cputime_zero;
  855. p->stimescaled = cputime_zero;
  856. p->prev_utime = cputime_zero;
  857. p->prev_stime = cputime_zero;
  858. p->default_timer_slack_ns = current->timer_slack_ns;
  859. #ifdef CONFIG_DETECT_SOFTLOCKUP
  860. p->last_switch_count = 0;
  861. p->last_switch_timestamp = 0;
  862. #endif
  863. task_io_accounting_init(&p->ioac);
  864. acct_clear_integrals(p);
  865. posix_cpu_timers_init(p);
  866. p->lock_depth = -1; /* -1 = no lock */
  867. do_posix_clock_monotonic_gettime(&p->start_time);
  868. p->real_start_time = p->start_time;
  869. monotonic_to_bootbased(&p->real_start_time);
  870. p->io_context = NULL;
  871. p->audit_context = NULL;
  872. cgroup_fork(p);
  873. #ifdef CONFIG_NUMA
  874. p->mempolicy = mpol_dup(p->mempolicy);
  875. if (IS_ERR(p->mempolicy)) {
  876. retval = PTR_ERR(p->mempolicy);
  877. p->mempolicy = NULL;
  878. goto bad_fork_cleanup_cgroup;
  879. }
  880. mpol_fix_fork_child_flag(p);
  881. #endif
  882. #ifdef CONFIG_TRACE_IRQFLAGS
  883. p->irq_events = 0;
  884. #ifdef __ARCH_WANT_INTERRUPTS_ON_CTXSW
  885. p->hardirqs_enabled = 1;
  886. #else
  887. p->hardirqs_enabled = 0;
  888. #endif
  889. p->hardirq_enable_ip = 0;
  890. p->hardirq_enable_event = 0;
  891. p->hardirq_disable_ip = _THIS_IP_;
  892. p->hardirq_disable_event = 0;
  893. p->softirqs_enabled = 1;
  894. p->softirq_enable_ip = _THIS_IP_;
  895. p->softirq_enable_event = 0;
  896. p->softirq_disable_ip = 0;
  897. p->softirq_disable_event = 0;
  898. p->hardirq_context = 0;
  899. p->softirq_context = 0;
  900. #endif
  901. #ifdef CONFIG_LOCKDEP
  902. p->lockdep_depth = 0; /* no locks held yet */
  903. p->curr_chain_key = 0;
  904. p->lockdep_recursion = 0;
  905. #endif
  906. #ifdef CONFIG_DEBUG_MUTEXES
  907. p->blocked_on = NULL; /* not blocked yet */
  908. #endif
  909. /* Perform scheduler related setup. Assign this task to a CPU. */
  910. sched_fork(p, clone_flags);
  911. if ((retval = audit_alloc(p)))
  912. goto bad_fork_cleanup_policy;
  913. /* copy all the process information */
  914. if ((retval = copy_semundo(clone_flags, p)))
  915. goto bad_fork_cleanup_audit;
  916. if ((retval = copy_files(clone_flags, p)))
  917. goto bad_fork_cleanup_semundo;
  918. if ((retval = copy_fs(clone_flags, p)))
  919. goto bad_fork_cleanup_files;
  920. if ((retval = copy_sighand(clone_flags, p)))
  921. goto bad_fork_cleanup_fs;
  922. if ((retval = copy_signal(clone_flags, p)))
  923. goto bad_fork_cleanup_sighand;
  924. if ((retval = copy_mm(clone_flags, p)))
  925. goto bad_fork_cleanup_signal;
  926. if ((retval = copy_namespaces(clone_flags, p)))
  927. goto bad_fork_cleanup_mm;
  928. if ((retval = copy_io(clone_flags, p)))
  929. goto bad_fork_cleanup_namespaces;
  930. retval = copy_thread(0, clone_flags, stack_start, stack_size, p, regs);
  931. if (retval)
  932. goto bad_fork_cleanup_io;
  933. if (pid != &init_struct_pid) {
  934. retval = -ENOMEM;
  935. pid = alloc_pid(task_active_pid_ns(p));
  936. if (!pid)
  937. goto bad_fork_cleanup_io;
  938. if (clone_flags & CLONE_NEWPID) {
  939. retval = pid_ns_prepare_proc(task_active_pid_ns(p));
  940. if (retval < 0)
  941. goto bad_fork_free_pid;
  942. }
  943. }
  944. p->pid = pid_nr(pid);
  945. p->tgid = p->pid;
  946. if (clone_flags & CLONE_THREAD)
  947. p->tgid = current->tgid;
  948. if (current->nsproxy != p->nsproxy) {
  949. retval = ns_cgroup_clone(p, pid);
  950. if (retval)
  951. goto bad_fork_free_pid;
  952. }
  953. p->set_child_tid = (clone_flags & CLONE_CHILD_SETTID) ? child_tidptr : NULL;
  954. /*
  955. * Clear TID on mm_release()?
  956. */
  957. p->clear_child_tid = (clone_flags & CLONE_CHILD_CLEARTID) ? child_tidptr: NULL;
  958. #ifdef CONFIG_FUTEX
  959. p->robust_list = NULL;
  960. #ifdef CONFIG_COMPAT
  961. p->compat_robust_list = NULL;
  962. #endif
  963. INIT_LIST_HEAD(&p->pi_state_list);
  964. p->pi_state_cache = NULL;
  965. #endif
  966. /*
  967. * sigaltstack should be cleared when sharing the same VM
  968. */
  969. if ((clone_flags & (CLONE_VM|CLONE_VFORK)) == CLONE_VM)
  970. p->sas_ss_sp = p->sas_ss_size = 0;
  971. /*
  972. * Syscall tracing should be turned off in the child regardless
  973. * of CLONE_PTRACE.
  974. */
  975. clear_tsk_thread_flag(p, TIF_SYSCALL_TRACE);
  976. #ifdef TIF_SYSCALL_EMU
  977. clear_tsk_thread_flag(p, TIF_SYSCALL_EMU);
  978. #endif
  979. clear_all_latency_tracing(p);
  980. /* Our parent execution domain becomes current domain
  981. These must match for thread signalling to apply */
  982. p->parent_exec_id = p->self_exec_id;
  983. /* ok, now we should be set up.. */
  984. p->exit_signal = (clone_flags & CLONE_THREAD) ? -1 : (clone_flags & CSIGNAL);
  985. p->pdeath_signal = 0;
  986. p->exit_state = 0;
  987. /*
  988. * Ok, make it visible to the rest of the system.
  989. * We dont wake it up yet.
  990. */
  991. p->group_leader = p;
  992. INIT_LIST_HEAD(&p->thread_group);
  993. /* Now that the task is set up, run cgroup callbacks if
  994. * necessary. We need to run them before the task is visible
  995. * on the tasklist. */
  996. cgroup_fork_callbacks(p);
  997. cgroup_callbacks_done = 1;
  998. /* Need tasklist lock for parent etc handling! */
  999. write_lock_irq(&tasklist_lock);
  1000. /*
  1001. * The task hasn't been attached yet, so its cpus_allowed mask will
  1002. * not be changed, nor will its assigned CPU.
  1003. *
  1004. * The cpus_allowed mask of the parent may have changed after it was
  1005. * copied first time - so re-copy it here, then check the child's CPU
  1006. * to ensure it is on a valid CPU (and if not, just force it back to
  1007. * parent's CPU). This avoids alot of nasty races.
  1008. */
  1009. p->cpus_allowed = current->cpus_allowed;
  1010. p->rt.nr_cpus_allowed = current->rt.nr_cpus_allowed;
  1011. if (unlikely(!cpu_isset(task_cpu(p), p->cpus_allowed) ||
  1012. !cpu_online(task_cpu(p))))
  1013. set_task_cpu(p, smp_processor_id());
  1014. /* CLONE_PARENT re-uses the old parent */
  1015. if (clone_flags & (CLONE_PARENT|CLONE_THREAD))
  1016. p->real_parent = current->real_parent;
  1017. else
  1018. p->real_parent = current;
  1019. spin_lock(&current->sighand->siglock);
  1020. /*
  1021. * Process group and session signals need to be delivered to just the
  1022. * parent before the fork or both the parent and the child after the
  1023. * fork. Restart if a signal comes in before we add the new process to
  1024. * it's process group.
  1025. * A fatal signal pending means that current will exit, so the new
  1026. * thread can't slip out of an OOM kill (or normal SIGKILL).
  1027. */
  1028. recalc_sigpending();
  1029. if (signal_pending(current)) {
  1030. spin_unlock(&current->sighand->siglock);
  1031. write_unlock_irq(&tasklist_lock);
  1032. retval = -ERESTARTNOINTR;
  1033. goto bad_fork_free_pid;
  1034. }
  1035. if (clone_flags & CLONE_THREAD) {
  1036. p->group_leader = current->group_leader;
  1037. list_add_tail_rcu(&p->thread_group, &p->group_leader->thread_group);
  1038. }
  1039. if (likely(p->pid)) {
  1040. list_add_tail(&p->sibling, &p->real_parent->children);
  1041. tracehook_finish_clone(p, clone_flags, trace);
  1042. if (thread_group_leader(p)) {
  1043. if (clone_flags & CLONE_NEWPID)
  1044. p->nsproxy->pid_ns->child_reaper = p;
  1045. p->signal->leader_pid = pid;
  1046. tty_kref_put(p->signal->tty);
  1047. p->signal->tty = tty_kref_get(current->signal->tty);
  1048. set_task_pgrp(p, task_pgrp_nr(current));
  1049. set_task_session(p, task_session_nr(current));
  1050. attach_pid(p, PIDTYPE_PGID, task_pgrp(current));
  1051. attach_pid(p, PIDTYPE_SID, task_session(current));
  1052. list_add_tail_rcu(&p->tasks, &init_task.tasks);
  1053. __get_cpu_var(process_counts)++;
  1054. }
  1055. attach_pid(p, PIDTYPE_PID, pid);
  1056. nr_threads++;
  1057. }
  1058. total_forks++;
  1059. spin_unlock(&current->sighand->siglock);
  1060. write_unlock_irq(&tasklist_lock);
  1061. proc_fork_connector(p);
  1062. cgroup_post_fork(p);
  1063. return p;
  1064. bad_fork_free_pid:
  1065. if (pid != &init_struct_pid)
  1066. free_pid(pid);
  1067. bad_fork_cleanup_io:
  1068. put_io_context(p->io_context);
  1069. bad_fork_cleanup_namespaces:
  1070. exit_task_namespaces(p);
  1071. bad_fork_cleanup_mm:
  1072. if (p->mm)
  1073. mmput(p->mm);
  1074. bad_fork_cleanup_signal:
  1075. cleanup_signal(p);
  1076. bad_fork_cleanup_sighand:
  1077. __cleanup_sighand(p->sighand);
  1078. bad_fork_cleanup_fs:
  1079. exit_fs(p); /* blocking */
  1080. bad_fork_cleanup_files:
  1081. exit_files(p); /* blocking */
  1082. bad_fork_cleanup_semundo:
  1083. exit_sem(p);
  1084. bad_fork_cleanup_audit:
  1085. audit_free(p);
  1086. bad_fork_cleanup_policy:
  1087. #ifdef CONFIG_NUMA
  1088. mpol_put(p->mempolicy);
  1089. bad_fork_cleanup_cgroup:
  1090. #endif
  1091. cgroup_exit(p, cgroup_callbacks_done);
  1092. delayacct_tsk_free(p);
  1093. if (p->binfmt)
  1094. module_put(p->binfmt->module);
  1095. bad_fork_cleanup_put_domain:
  1096. module_put(task_thread_info(p)->exec_domain->module);
  1097. bad_fork_cleanup_count:
  1098. atomic_dec(&p->cred->user->processes);
  1099. put_cred(p->cred);
  1100. bad_fork_free:
  1101. free_task(p);
  1102. fork_out:
  1103. return ERR_PTR(retval);
  1104. }
  1105. noinline struct pt_regs * __cpuinit __attribute__((weak)) idle_regs(struct pt_regs *regs)
  1106. {
  1107. memset(regs, 0, sizeof(struct pt_regs));
  1108. return regs;
  1109. }
  1110. struct task_struct * __cpuinit fork_idle(int cpu)
  1111. {
  1112. struct task_struct *task;
  1113. struct pt_regs regs;
  1114. task = copy_process(CLONE_VM, 0, idle_regs(&regs), 0, NULL,
  1115. &init_struct_pid, 0);
  1116. if (!IS_ERR(task))
  1117. init_idle(task, cpu);
  1118. return task;
  1119. }
  1120. /*
  1121. * Ok, this is the main fork-routine.
  1122. *
  1123. * It copies the process, and if successful kick-starts
  1124. * it and waits for it to finish using the VM if required.
  1125. */
  1126. long do_fork(unsigned long clone_flags,
  1127. unsigned long stack_start,
  1128. struct pt_regs *regs,
  1129. unsigned long stack_size,
  1130. int __user *parent_tidptr,
  1131. int __user *child_tidptr)
  1132. {
  1133. struct task_struct *p;
  1134. int trace = 0;
  1135. long nr;
  1136. /*
  1137. * We hope to recycle these flags after 2.6.26
  1138. */
  1139. if (unlikely(clone_flags & CLONE_STOPPED)) {
  1140. static int __read_mostly count = 100;
  1141. if (count > 0 && printk_ratelimit()) {
  1142. char comm[TASK_COMM_LEN];
  1143. count--;
  1144. printk(KERN_INFO "fork(): process `%s' used deprecated "
  1145. "clone flags 0x%lx\n",
  1146. get_task_comm(comm, current),
  1147. clone_flags & CLONE_STOPPED);
  1148. }
  1149. }
  1150. /*
  1151. * When called from kernel_thread, don't do user tracing stuff.
  1152. */
  1153. if (likely(user_mode(regs)))
  1154. trace = tracehook_prepare_clone(clone_flags);
  1155. p = copy_process(clone_flags, stack_start, regs, stack_size,
  1156. child_tidptr, NULL, trace);
  1157. /*
  1158. * Do this prior waking up the new thread - the thread pointer
  1159. * might get invalid after that point, if the thread exits quickly.
  1160. */
  1161. if (!IS_ERR(p)) {
  1162. struct completion vfork;
  1163. trace_sched_process_fork(current, p);
  1164. nr = task_pid_vnr(p);
  1165. if (clone_flags & CLONE_PARENT_SETTID)
  1166. put_user(nr, parent_tidptr);
  1167. if (clone_flags & CLONE_VFORK) {
  1168. p->vfork_done = &vfork;
  1169. init_completion(&vfork);
  1170. }
  1171. tracehook_report_clone(trace, regs, clone_flags, nr, p);
  1172. /*
  1173. * We set PF_STARTING at creation in case tracing wants to
  1174. * use this to distinguish a fully live task from one that
  1175. * hasn't gotten to tracehook_report_clone() yet. Now we
  1176. * clear it and set the child going.
  1177. */
  1178. p->flags &= ~PF_STARTING;
  1179. if (unlikely(clone_flags & CLONE_STOPPED)) {
  1180. /*
  1181. * We'll start up with an immediate SIGSTOP.
  1182. */
  1183. sigaddset(&p->pending.signal, SIGSTOP);
  1184. set_tsk_thread_flag(p, TIF_SIGPENDING);
  1185. __set_task_state(p, TASK_STOPPED);
  1186. } else {
  1187. wake_up_new_task(p, clone_flags);
  1188. }
  1189. tracehook_report_clone_complete(trace, regs,
  1190. clone_flags, nr, p);
  1191. if (clone_flags & CLONE_VFORK) {
  1192. freezer_do_not_count();
  1193. wait_for_completion(&vfork);
  1194. freezer_count();
  1195. tracehook_report_vfork_done(p, nr);
  1196. }
  1197. } else {
  1198. nr = PTR_ERR(p);
  1199. }
  1200. return nr;
  1201. }
  1202. #ifndef ARCH_MIN_MMSTRUCT_ALIGN
  1203. #define ARCH_MIN_MMSTRUCT_ALIGN 0
  1204. #endif
  1205. static void sighand_ctor(void *data)
  1206. {
  1207. struct sighand_struct *sighand = data;
  1208. spin_lock_init(&sighand->siglock);
  1209. init_waitqueue_head(&sighand->signalfd_wqh);
  1210. }
  1211. void __init proc_caches_init(void)
  1212. {
  1213. sighand_cachep = kmem_cache_create("sighand_cache",
  1214. sizeof(struct sighand_struct), 0,
  1215. SLAB_HWCACHE_ALIGN|SLAB_PANIC|SLAB_DESTROY_BY_RCU,
  1216. sighand_ctor);
  1217. signal_cachep = kmem_cache_create("signal_cache",
  1218. sizeof(struct signal_struct), 0,
  1219. SLAB_HWCACHE_ALIGN|SLAB_PANIC, NULL);
  1220. files_cachep = kmem_cache_create("files_cache",
  1221. sizeof(struct files_struct), 0,
  1222. SLAB_HWCACHE_ALIGN|SLAB_PANIC, NULL);
  1223. fs_cachep = kmem_cache_create("fs_cache",
  1224. sizeof(struct fs_struct), 0,
  1225. SLAB_HWCACHE_ALIGN|SLAB_PANIC, NULL);
  1226. vm_area_cachep = kmem_cache_create("vm_area_struct",
  1227. sizeof(struct vm_area_struct), 0,
  1228. SLAB_PANIC, NULL);
  1229. mm_cachep = kmem_cache_create("mm_struct",
  1230. sizeof(struct mm_struct), ARCH_MIN_MMSTRUCT_ALIGN,
  1231. SLAB_HWCACHE_ALIGN|SLAB_PANIC, NULL);
  1232. }
  1233. /*
  1234. * Check constraints on flags passed to the unshare system call and
  1235. * force unsharing of additional process context as appropriate.
  1236. */
  1237. static void check_unshare_flags(unsigned long *flags_ptr)
  1238. {
  1239. /*
  1240. * If unsharing a thread from a thread group, must also
  1241. * unshare vm.
  1242. */
  1243. if (*flags_ptr & CLONE_THREAD)
  1244. *flags_ptr |= CLONE_VM;
  1245. /*
  1246. * If unsharing vm, must also unshare signal handlers.
  1247. */
  1248. if (*flags_ptr & CLONE_VM)
  1249. *flags_ptr |= CLONE_SIGHAND;
  1250. /*
  1251. * If unsharing signal handlers and the task was created
  1252. * using CLONE_THREAD, then must unshare the thread
  1253. */
  1254. if ((*flags_ptr & CLONE_SIGHAND) &&
  1255. (atomic_read(&current->signal->count) > 1))
  1256. *flags_ptr |= CLONE_THREAD;
  1257. /*
  1258. * If unsharing namespace, must also unshare filesystem information.
  1259. */
  1260. if (*flags_ptr & CLONE_NEWNS)
  1261. *flags_ptr |= CLONE_FS;
  1262. }
  1263. /*
  1264. * Unsharing of tasks created with CLONE_THREAD is not supported yet
  1265. */
  1266. static int unshare_thread(unsigned long unshare_flags)
  1267. {
  1268. if (unshare_flags & CLONE_THREAD)
  1269. return -EINVAL;
  1270. return 0;
  1271. }
  1272. /*
  1273. * Unshare the filesystem structure if it is being shared
  1274. */
  1275. static int unshare_fs(unsigned long unshare_flags, struct fs_struct **new_fsp)
  1276. {
  1277. struct fs_struct *fs = current->fs;
  1278. if ((unshare_flags & CLONE_FS) &&
  1279. (fs && atomic_read(&fs->count) > 1)) {
  1280. *new_fsp = __copy_fs_struct(current->fs);
  1281. if (!*new_fsp)
  1282. return -ENOMEM;
  1283. }
  1284. return 0;
  1285. }
  1286. /*
  1287. * Unsharing of sighand is not supported yet
  1288. */
  1289. static int unshare_sighand(unsigned long unshare_flags, struct sighand_struct **new_sighp)
  1290. {
  1291. struct sighand_struct *sigh = current->sighand;
  1292. if ((unshare_flags & CLONE_SIGHAND) && atomic_read(&sigh->count) > 1)
  1293. return -EINVAL;
  1294. else
  1295. return 0;
  1296. }
  1297. /*
  1298. * Unshare vm if it is being shared
  1299. */
  1300. static int unshare_vm(unsigned long unshare_flags, struct mm_struct **new_mmp)
  1301. {
  1302. struct mm_struct *mm = current->mm;
  1303. if ((unshare_flags & CLONE_VM) &&
  1304. (mm && atomic_read(&mm->mm_users) > 1)) {
  1305. return -EINVAL;
  1306. }
  1307. return 0;
  1308. }
  1309. /*
  1310. * Unshare file descriptor table if it is being shared
  1311. */
  1312. static int unshare_fd(unsigned long unshare_flags, struct files_struct **new_fdp)
  1313. {
  1314. struct files_struct *fd = current->files;
  1315. int error = 0;
  1316. if ((unshare_flags & CLONE_FILES) &&
  1317. (fd && atomic_read(&fd->count) > 1)) {
  1318. *new_fdp = dup_fd(fd, &error);
  1319. if (!*new_fdp)
  1320. return error;
  1321. }
  1322. return 0;
  1323. }
  1324. /*
  1325. * unshare allows a process to 'unshare' part of the process
  1326. * context which was originally shared using clone. copy_*
  1327. * functions used by do_fork() cannot be used here directly
  1328. * because they modify an inactive task_struct that is being
  1329. * constructed. Here we are modifying the current, active,
  1330. * task_struct.
  1331. */
  1332. asmlinkage long sys_unshare(unsigned long unshare_flags)
  1333. {
  1334. int err = 0;
  1335. struct fs_struct *fs, *new_fs = NULL;
  1336. struct sighand_struct *new_sigh = NULL;
  1337. struct mm_struct *mm, *new_mm = NULL, *active_mm = NULL;
  1338. struct files_struct *fd, *new_fd = NULL;
  1339. struct nsproxy *new_nsproxy = NULL;
  1340. int do_sysvsem = 0;
  1341. check_unshare_flags(&unshare_flags);
  1342. /* Return -EINVAL for all unsupported flags */
  1343. err = -EINVAL;
  1344. if (unshare_flags & ~(CLONE_THREAD|CLONE_FS|CLONE_NEWNS|CLONE_SIGHAND|
  1345. CLONE_VM|CLONE_FILES|CLONE_SYSVSEM|
  1346. CLONE_NEWUTS|CLONE_NEWIPC|CLONE_NEWUSER|
  1347. CLONE_NEWNET))
  1348. goto bad_unshare_out;
  1349. /*
  1350. * CLONE_NEWIPC must also detach from the undolist: after switching
  1351. * to a new ipc namespace, the semaphore arrays from the old
  1352. * namespace are unreachable.
  1353. */
  1354. if (unshare_flags & (CLONE_NEWIPC|CLONE_SYSVSEM))
  1355. do_sysvsem = 1;
  1356. if ((err = unshare_thread(unshare_flags)))
  1357. goto bad_unshare_out;
  1358. if ((err = unshare_fs(unshare_flags, &new_fs)))
  1359. goto bad_unshare_cleanup_thread;
  1360. if ((err = unshare_sighand(unshare_flags, &new_sigh)))
  1361. goto bad_unshare_cleanup_fs;
  1362. if ((err = unshare_vm(unshare_flags, &new_mm)))
  1363. goto bad_unshare_cleanup_sigh;
  1364. if ((err = unshare_fd(unshare_flags, &new_fd)))
  1365. goto bad_unshare_cleanup_vm;
  1366. if ((err = unshare_nsproxy_namespaces(unshare_flags, &new_nsproxy,
  1367. new_fs)))
  1368. goto bad_unshare_cleanup_fd;
  1369. if (new_fs || new_mm || new_fd || do_sysvsem || new_nsproxy) {
  1370. if (do_sysvsem) {
  1371. /*
  1372. * CLONE_SYSVSEM is equivalent to sys_exit().
  1373. */
  1374. exit_sem(current);
  1375. }
  1376. if (new_nsproxy) {
  1377. switch_task_namespaces(current, new_nsproxy);
  1378. new_nsproxy = NULL;
  1379. }
  1380. task_lock(current);
  1381. if (new_fs) {
  1382. fs = current->fs;
  1383. current->fs = new_fs;
  1384. new_fs = fs;
  1385. }
  1386. if (new_mm) {
  1387. mm = current->mm;
  1388. active_mm = current->active_mm;
  1389. current->mm = new_mm;
  1390. current->active_mm = new_mm;
  1391. activate_mm(active_mm, new_mm);
  1392. new_mm = mm;
  1393. }
  1394. if (new_fd) {
  1395. fd = current->files;
  1396. current->files = new_fd;
  1397. new_fd = fd;
  1398. }
  1399. task_unlock(current);
  1400. }
  1401. if (new_nsproxy)
  1402. put_nsproxy(new_nsproxy);
  1403. bad_unshare_cleanup_fd:
  1404. if (new_fd)
  1405. put_files_struct(new_fd);
  1406. bad_unshare_cleanup_vm:
  1407. if (new_mm)
  1408. mmput(new_mm);
  1409. bad_unshare_cleanup_sigh:
  1410. if (new_sigh)
  1411. if (atomic_dec_and_test(&new_sigh->count))
  1412. kmem_cache_free(sighand_cachep, new_sigh);
  1413. bad_unshare_cleanup_fs:
  1414. if (new_fs)
  1415. put_fs_struct(new_fs);
  1416. bad_unshare_cleanup_thread:
  1417. bad_unshare_out:
  1418. return err;
  1419. }
  1420. /*
  1421. * Helper to unshare the files of the current task.
  1422. * We don't want to expose copy_files internals to
  1423. * the exec layer of the kernel.
  1424. */
  1425. int unshare_files(struct files_struct **displaced)
  1426. {
  1427. struct task_struct *task = current;
  1428. struct files_struct *copy = NULL;
  1429. int error;
  1430. error = unshare_fd(CLONE_FILES, &copy);
  1431. if (error || !copy) {
  1432. *displaced = NULL;
  1433. return error;
  1434. }
  1435. *displaced = task->files;
  1436. task_lock(task);
  1437. task->files = copy;
  1438. task_unlock(task);
  1439. return 0;
  1440. }