semaphore-helper.h 1.5 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081
  1. /* $Id: semaphore-helper.h,v 1.3 2001/03/26 15:00:33 orjanf Exp $
  2. *
  3. * SMP- and interrupt-safe semaphores helper functions. Generic versions, no
  4. * optimizations whatsoever...
  5. *
  6. */
  7. #ifndef _ASM_SEMAPHORE_HELPER_H
  8. #define _ASM_SEMAPHORE_HELPER_H
  9. #include <asm/atomic.h>
  10. #include <linux/errno.h>
  11. #define read(a) ((a)->counter)
  12. #define inc(a) (((a)->counter)++)
  13. #define dec(a) (((a)->counter)--)
  14. #define count_inc(a) ((*(a))++)
  15. /*
  16. * These two _must_ execute atomically wrt each other.
  17. */
  18. extern inline void wake_one_more(struct semaphore * sem)
  19. {
  20. atomic_inc(&sem->waking);
  21. }
  22. extern inline int waking_non_zero(struct semaphore *sem)
  23. {
  24. unsigned long flags;
  25. int ret = 0;
  26. local_save_flags(flags);
  27. local_irq_disable();
  28. if (read(&sem->waking) > 0) {
  29. dec(&sem->waking);
  30. ret = 1;
  31. }
  32. local_irq_restore(flags);
  33. return ret;
  34. }
  35. extern inline int waking_non_zero_interruptible(struct semaphore *sem,
  36. struct task_struct *tsk)
  37. {
  38. int ret = 0;
  39. unsigned long flags;
  40. local_save_flags(flags);
  41. local_irq_disable();
  42. if (read(&sem->waking) > 0) {
  43. dec(&sem->waking);
  44. ret = 1;
  45. } else if (signal_pending(tsk)) {
  46. inc(&sem->count);
  47. ret = -EINTR;
  48. }
  49. local_irq_restore(flags);
  50. return ret;
  51. }
  52. extern inline int waking_non_zero_trylock(struct semaphore *sem)
  53. {
  54. int ret = 1;
  55. unsigned long flags;
  56. local_save_flags(flags);
  57. local_irq_disable();
  58. if (read(&sem->waking) <= 0)
  59. inc(&sem->count);
  60. else {
  61. dec(&sem->waking);
  62. ret = 0;
  63. }
  64. local_irq_restore(flags);
  65. return ret;
  66. }
  67. #endif /* _ASM_SEMAPHORE_HELPER_H */