res_counter.c 4.3 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201
  1. /*
  2. * resource cgroups
  3. *
  4. * Copyright 2007 OpenVZ SWsoft Inc
  5. *
  6. * Author: Pavel Emelianov <xemul@openvz.org>
  7. *
  8. */
  9. #include <linux/types.h>
  10. #include <linux/parser.h>
  11. #include <linux/fs.h>
  12. #include <linux/res_counter.h>
  13. #include <linux/uaccess.h>
  14. #include <linux/mm.h>
  15. void res_counter_init(struct res_counter *counter, struct res_counter *parent)
  16. {
  17. spin_lock_init(&counter->lock);
  18. counter->limit = RESOURCE_MAX;
  19. counter->soft_limit = RESOURCE_MAX;
  20. counter->parent = parent;
  21. }
  22. int res_counter_charge_locked(struct res_counter *counter, unsigned long val,
  23. bool force)
  24. {
  25. int ret = 0;
  26. if (counter->usage + val > counter->limit) {
  27. counter->failcnt++;
  28. ret = -ENOMEM;
  29. if (!force)
  30. return ret;
  31. }
  32. counter->usage += val;
  33. if (!force && counter->usage > counter->max_usage)
  34. counter->max_usage = counter->usage;
  35. return ret;
  36. }
  37. static int __res_counter_charge(struct res_counter *counter, unsigned long val,
  38. struct res_counter **limit_fail_at, bool force)
  39. {
  40. int ret, r;
  41. unsigned long flags;
  42. struct res_counter *c, *u;
  43. r = ret = 0;
  44. *limit_fail_at = NULL;
  45. local_irq_save(flags);
  46. for (c = counter; c != NULL; c = c->parent) {
  47. spin_lock(&c->lock);
  48. r = res_counter_charge_locked(c, val, force);
  49. spin_unlock(&c->lock);
  50. if (r < 0 && !ret) {
  51. ret = r;
  52. *limit_fail_at = c;
  53. if (!force)
  54. break;
  55. }
  56. }
  57. if (ret < 0 && !force) {
  58. for (u = counter; u != c; u = u->parent) {
  59. spin_lock(&u->lock);
  60. res_counter_uncharge_locked(u, val);
  61. spin_unlock(&u->lock);
  62. }
  63. }
  64. local_irq_restore(flags);
  65. return ret;
  66. }
  67. int res_counter_charge(struct res_counter *counter, unsigned long val,
  68. struct res_counter **limit_fail_at)
  69. {
  70. return __res_counter_charge(counter, val, limit_fail_at, false);
  71. }
  72. int res_counter_charge_nofail(struct res_counter *counter, unsigned long val,
  73. struct res_counter **limit_fail_at)
  74. {
  75. return __res_counter_charge(counter, val, limit_fail_at, true);
  76. }
  77. u64 res_counter_uncharge_locked(struct res_counter *counter, unsigned long val)
  78. {
  79. if (WARN_ON(counter->usage < val))
  80. val = counter->usage;
  81. counter->usage -= val;
  82. return counter->usage;
  83. }
  84. u64 res_counter_uncharge_until(struct res_counter *counter,
  85. struct res_counter *top,
  86. unsigned long val)
  87. {
  88. unsigned long flags;
  89. struct res_counter *c;
  90. u64 ret = 0;
  91. local_irq_save(flags);
  92. for (c = counter; c != top; c = c->parent) {
  93. u64 r;
  94. spin_lock(&c->lock);
  95. r = res_counter_uncharge_locked(c, val);
  96. if (c == counter)
  97. ret = r;
  98. spin_unlock(&c->lock);
  99. }
  100. local_irq_restore(flags);
  101. return ret;
  102. }
  103. u64 res_counter_uncharge(struct res_counter *counter, unsigned long val)
  104. {
  105. return res_counter_uncharge_until(counter, NULL, val);
  106. }
  107. static inline unsigned long long *
  108. res_counter_member(struct res_counter *counter, int member)
  109. {
  110. switch (member) {
  111. case RES_USAGE:
  112. return &counter->usage;
  113. case RES_MAX_USAGE:
  114. return &counter->max_usage;
  115. case RES_LIMIT:
  116. return &counter->limit;
  117. case RES_FAILCNT:
  118. return &counter->failcnt;
  119. case RES_SOFT_LIMIT:
  120. return &counter->soft_limit;
  121. };
  122. BUG();
  123. return NULL;
  124. }
  125. ssize_t res_counter_read(struct res_counter *counter, int member,
  126. const char __user *userbuf, size_t nbytes, loff_t *pos,
  127. int (*read_strategy)(unsigned long long val, char *st_buf))
  128. {
  129. unsigned long long *val;
  130. char buf[64], *s;
  131. s = buf;
  132. val = res_counter_member(counter, member);
  133. if (read_strategy)
  134. s += read_strategy(*val, s);
  135. else
  136. s += sprintf(s, "%llu\n", *val);
  137. return simple_read_from_buffer((void __user *)userbuf, nbytes,
  138. pos, buf, s - buf);
  139. }
  140. #if BITS_PER_LONG == 32
  141. u64 res_counter_read_u64(struct res_counter *counter, int member)
  142. {
  143. unsigned long flags;
  144. u64 ret;
  145. spin_lock_irqsave(&counter->lock, flags);
  146. ret = *res_counter_member(counter, member);
  147. spin_unlock_irqrestore(&counter->lock, flags);
  148. return ret;
  149. }
  150. #else
  151. u64 res_counter_read_u64(struct res_counter *counter, int member)
  152. {
  153. return *res_counter_member(counter, member);
  154. }
  155. #endif
  156. int res_counter_memparse_write_strategy(const char *buf,
  157. unsigned long long *res)
  158. {
  159. char *end;
  160. /* return RESOURCE_MAX(unlimited) if "-1" is specified */
  161. if (*buf == '-') {
  162. *res = simple_strtoull(buf + 1, &end, 10);
  163. if (*res != 1 || *end != '\0')
  164. return -EINVAL;
  165. *res = RESOURCE_MAX;
  166. return 0;
  167. }
  168. *res = memparse(buf, &end);
  169. if (*end != '\0')
  170. return -EINVAL;
  171. *res = PAGE_ALIGN(*res);
  172. return 0;
  173. }