include/linux/vs_memory.h

   1 #ifndef _VX_VS_MEMORY_H
   2 #define _VX_VS_MEMORY_H
   3
   4
   5 #include "vserver/limit.h"
   6 #include "vserver/debug.h"
   7
   8
   9 #define vx_acc_page(m, d, v, r) \
  10         __vx_acc_page(&(m->v), m->mm_vx_info, r, d, __FILE__, __LINE__)
  11
  12 static inline void __vx_acc_page(unsigned long *v, struct vx_info *vxi,
  13                 int res, int dir, char *file, int line)
  14 {
  15         if (VXD_RLIMIT(res, RLIMIT_RSS) ||
  16                 VXD_RLIMIT(res, RLIMIT_AS) ||
  17                 VXD_RLIMIT(res, RLIMIT_MEMLOCK))
  18                 vxlprintk(1, "vx_acc_page[%5d,%s,%2d]: %5d%s",
  19                         (vxi?vxi->vx_id:-1), vlimit_name[res], res,
  20                         (vxi?atomic_read(&vxi->limit.rcur[res]):0),
  21                         (dir?"++":"--"), file, line);
  22         if (v) {
  23                 if (dir > 0)
  24                         ++(*v);
  25                 else
  26                         --(*v);
  27         }
  28         if (vxi) {
  29                 if (dir > 0)
  30                         atomic_inc(&vxi->limit.rcur[res]);
  31                 else
  32                         atomic_dec(&vxi->limit.rcur[res]);
  33         }
  34 }
  35
  36
  37 #define vx_acc_pages(m, p, v, r) \
  38         __vx_acc_pages(&(m->v), m->mm_vx_info, r, p, __FILE__, __LINE__)
  39
  40 static inline void __vx_acc_pages(unsigned long *v, struct vx_info *vxi,
  41                 int res, int pages, char *_file, int _line)
  42 {
  43         if (VXD_RLIMIT(res, RLIMIT_RSS) ||
  44                 VXD_RLIMIT(res, RLIMIT_AS) ||
  45                 VXD_RLIMIT(res, RLIMIT_MEMLOCK))
  46                 vxlprintk(1, "vx_acc_pages[%5d,%s,%2d]: %5d += %5d",
  47                         (vxi?vxi->vx_id:-1), vlimit_name[res], res,
  48                         (vxi?atomic_read(&vxi->limit.rcur[res]):0),
  49                         pages, _file, _line);
  50         if (pages == 0)
  51                 return;
  52         if (v)
  53                 *v += pages;
  54         if (vxi)
  55                 atomic_add(pages, &vxi->limit.rcur[res]);
  56 }
  57
  58
  59
  60 #define vx_acc_vmpage(m,d)      vx_acc_page(m, d, total_vm,  RLIMIT_AS)
  61 #define vx_acc_vmlpage(m,d)     vx_acc_page(m, d, locked_vm, RLIMIT_MEMLOCK)
  62 #define vx_acc_rsspage(m,d)     vx_acc_page(m, d, rss,       RLIMIT_RSS)
  63
  64 #define vx_acc_vmpages(m,p)     vx_acc_pages(m, p, total_vm,  RLIMIT_AS)
  65 #define vx_acc_vmlpages(m,p)    vx_acc_pages(m, p, locked_vm, RLIMIT_MEMLOCK)
  66 #define vx_acc_rsspages(m,p)    vx_acc_pages(m, p, rss,       RLIMIT_RSS)
  67
  68 #define vx_pages_add(s,r,p)     __vx_acc_pages(0, s, r, p, __FILE__, __LINE__)
  69 #define vx_pages_sub(s,r,p)     vx_pages_add(s, r, -(p))
  70
  71 #define vx_vmpages_inc(m)       vx_acc_vmpage(m, 1)
  72 #define vx_vmpages_dec(m)       vx_acc_vmpage(m,-1)
  73 #define vx_vmpages_add(m,p)     vx_acc_vmpages(m, p)
  74 #define vx_vmpages_sub(m,p)     vx_acc_vmpages(m,-(p))
  75
  76 #define vx_vmlocked_inc(m)      vx_acc_vmlpage(m, 1)
  77 #define vx_vmlocked_dec(m)      vx_acc_vmlpage(m,-1)
  78 #define vx_vmlocked_add(m,p)    vx_acc_vmlpages(m, p)
  79 #define vx_vmlocked_sub(m,p)    vx_acc_vmlpages(m,-(p))
  80
  81 #define vx_rsspages_inc(m)      vx_acc_rsspage(m, 1)
  82 #define vx_rsspages_dec(m)      vx_acc_rsspage(m,-1)
  83 #define vx_rsspages_add(m,p)    vx_acc_rsspages(m, p)
  84 #define vx_rsspages_sub(m,p)    vx_acc_rsspages(m,-(p))
  85
  86
  87
  88 #define vx_pages_avail(m, p, r) \
  89         __vx_pages_avail((m)->mm_vx_info, (r), (p), __FILE__, __LINE__)
  90
  91 static inline int __vx_pages_avail(struct vx_info *vxi,
  92                 int res, int pages, char *_file, int _line)
  93 {
  94         unsigned long value;
  95
  96         if (VXD_RLIMIT(res, RLIMIT_RSS) ||
  97                 VXD_RLIMIT(res, RLIMIT_AS) ||
  98                 VXD_RLIMIT(res, RLIMIT_MEMLOCK))
  99                 vxlprintk(1, "vx_pages_avail[%5d,%s,%2d]: %5ld > %5d + %5d",
 100                         (vxi?vxi->vx_id:-1), vlimit_name[res], res,
 101                         (vxi?vxi->limit.rlim[res]:1),
 102                         (vxi?atomic_read(&vxi->limit.rcur[res]):0),
 103                         pages, _file, _line);
 104         if (!vxi)
 105                 return 1;
 106         value = atomic_read(&vxi->limit.rcur[res]);
 107         if (value > vxi->limit.rmax[res])
 108                 vxi->limit.rmax[res] = value;
 109         if (vxi->limit.rlim[res] == RLIM_INFINITY)
 110                 return 1;
 111         if (value + pages <= vxi->limit.rlim[res])
 112                 return 1;
 113         atomic_inc(&vxi->limit.lhit[res]);
 114         return 0;
 115 }
 116
 117 #define vx_vmpages_avail(m,p)   vx_pages_avail(m, p, RLIMIT_AS)
 118 #define vx_vmlocked_avail(m,p)  vx_pages_avail(m, p, RLIMIT_MEMLOCK)
 119 #define vx_rsspages_avail(m,p)  vx_pages_avail(m, p, RLIMIT_RSS)
 120
 121 #else
 122 #warning duplicate inclusion
 123 #endif