1
0

pthread_atfork.c 911 B

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748
  1. #include <pthread.h>
  2. #include "libc.h"
  3. static struct atfork_funcs {
  4. void (*prepare)(void);
  5. void (*parent)(void);
  6. void (*child)(void);
  7. struct atfork_funcs *prev, *next;
  8. } *funcs;
  9. static int lock[2];
  10. void __fork_handler(int who)
  11. {
  12. struct atfork_funcs *p;
  13. if (!funcs) return;
  14. if (who < 0) {
  15. LOCK(lock);
  16. for (p=funcs; p; p = p->next) {
  17. if (p->prepare) p->prepare();
  18. funcs = p;
  19. }
  20. } else {
  21. for (p=funcs; p; p = p->prev) {
  22. if (!who && p->parent) p->parent();
  23. else if (who && p->child) p->child();
  24. funcs = p;
  25. }
  26. UNLOCK(lock);
  27. }
  28. }
  29. int pthread_atfork(void (*prepare)(void), void (*parent)(void), void (*child)(void))
  30. {
  31. struct atfork_funcs *new = malloc(sizeof *new);
  32. if (!new) return -1;
  33. LOCK(lock);
  34. new->next = funcs;
  35. new->prev = 0;
  36. new->prepare = prepare;
  37. new->parent = parent;
  38. new->child = child;
  39. if (funcs) funcs->prev = new;
  40. funcs = new;
  41. UNLOCK(lock);
  42. return 0;
  43. }