src/validate.c - vzctl - Rivoreo Source Code Repositories

 /*
  *  Copyright (C) 2000-2007 SWsoft. All rights reserved.
  *
  *  This program is free software; you can redistribute it and/or modify
  *  it under the terms of the GNU General Public License as published by
  *  the Free Software Foundation; either version 2 of the License, or
  *  (at your option) any later version.
  *
  *  This program is distributed in the hope that it will be useful,
  *  but WITHOUT ANY WARRANTY; without even the implied warranty of
  *  MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.  See the
  *  GNU General Public License for more details.
  *
  *  You should have received a copy of the GNU General Public License
  *  along with this program; if not, write to the Free Software
  *  Foundation, Inc., 59 Temple Place, Suite 330, Boston, MA  02111-1307  USA
  */

 #include <stdio.h>
 #include <limits.h>
 #include <stdlib.h>
 #include <ctype.h>
 #include <string.h>
 #include <errno.h>

 #include "ub.h"
 #include "res.h"
 #include "validate.h"
 #include "vzctl_param.h"
 #include "vzerror.h"
 #include "logger.h"
 #include "util.h"

 static int page_size = 4096;

 static struct {
 	char *name;
 	int id;
 } validate_act2str[] = {
 	{"none",	ACT_NONE},
 	{"warning",	ACT_WARN},
 	{"error",	ACT_ERROR},
 	{"fix",		ACT_FIX},
 };

 int action2id(char *mode)
 {
 	int i;

 	if (mode == NULL)
 		return ACT_NONE;
 	for (i = 0; i < sizeof(validate_act2str) / sizeof(*validate_act2str);
 		i++)
 	{
 		if (!strcmp(validate_act2str[i].name, mode))
 			return validate_act2str[i].id;
 	}
 	return ACT_NONE;
 }


 static int read_yn()
 {
 	char buf[1024];

 	fprintf(stderr, " (y/n) [y] ");
 	while (fgets(buf, sizeof(buf), stdin) != NULL) {
 		if (buf[0] == 'y' || buf[0] == '\n') {
 			return 1;
 		}
 		else if (buf[0] == 'n')
 			return 	0;
 		fprintf(stderr, " (y/n) [y] ");
 	}
 	return 0;
 }

 static int check_param(struct ub_struct *param, int log)
 {
 	int ret = 0;
 #define CHECKPARAM(name) 						\
 	if (param->name == NULL) {					\
 		if (log)						\
 			logger(-1, 0, "Error: parameter " #name		\
 				" not found");				\
 		ret = 1;						\
 	}								\

 	CHECKPARAM(numproc);
 	CHECKPARAM(numtcpsock);
 	CHECKPARAM(numothersock);
 	CHECKPARAM(oomguarpages)
 	CHECKPARAM(vmguarpages);
 	CHECKPARAM(kmemsize);
 	CHECKPARAM(tcpsndbuf);
 	CHECKPARAM(tcprcvbuf);
 	CHECKPARAM(othersockbuf);
 	CHECKPARAM(dgramrcvbuf);
 	CHECKPARAM(privvmpages);
 	CHECKPARAM(numfile);
 	CHECKPARAM(dcachesize);
 	CHECKPARAM(physpages)
 	CHECKPARAM(numpty)

 	return ret;
 }

 int validate(vps_res *param, int recover, int ask)
 {
 	unsigned long avnumproc;
 	int ret = 0;
 	unsigned long val, val1;
 	unsigned long tmp_val0, tmp_val1;
 	int changed = 0;
 	struct ub_struct *ub;

 #define SET_MES(val)	logger(0, 0, "set to %lu", val);
 #define SET2_MES(val1, val2) logger(0, 0,"set to %lu:%lu", val1, val2);

 #define CHECK_BL(x, name) 						\
 if (x != NULL) { 							\
 	if (x[0] > x[1]) {						\
 		logger(-1, 0, "Error: barrier should be <= limit for " 	\
 			#name " (currently, %lu:%lu)",			\
 			x[0], x[1]);					\
 		if (ask || recover) {					\
 			tmp_val1 = x[0];				\
 			tmp_val0 = x[0];				\
 			SET2_MES(tmp_val0, tmp_val1)			\
 			if (ask) recover = read_yn();			\
 			if (recover) {					\
 				x[1] = tmp_val1;			\
 				changed++;				\
 			}						\
 		}							\
 		if (!recover) ret = 1;					\
 	}								\
 } else {								\
 	logger(-1, 0, "Error: parameter "  #name " not found");		\
 	ret = 1;							\
 }

 #define CHECK_B(name)							\
 if (ub->name != NULL) {							\
 	if ((ub->name[0] != ub->name[1])) {				\
 		logger(-1, 0, "Error: barrier should be equal to limit" \
 			" for " #name " (currently, %lu:%lu)",		\
 			ub->name[0], ub->name[1]);			\
 		if (ask || recover) {					\
 			tmp_val0 = max_ul(ub->name[0], ub->name[1]); 	\
 			tmp_val1 = tmp_val0;				\
 			SET2_MES(tmp_val0, tmp_val1)			\
 			if (ask) recover = read_yn();			\
 			if (recover) {					\
 				ub->name[0] = tmp_val0;			\
 				ub->name[1] = tmp_val1;			\
 				changed++;				\
 			}						\
 		}							\
 		if (!recover) ret = 1;					\
 	}								\
 } else {								\
 	logger(-1, 0, "Error: parameter "  #name " not found");		\
 	ret = 1;							\
 }

 	if (param == NULL)
 		return 1;
 	ub = &param->ub;
 	if (check_param(ub, 1))
 		return 1;
 	if (ub->avnumproc != NULL)
 		avnumproc = ub->avnumproc[0];
 	else
 		avnumproc = ub->numproc[0] / 2;
 /*	1 Check barrier & limit	*/
 	/* Primary */
 	CHECK_B(numproc)
 	CHECK_B(numtcpsock)
 	CHECK_B(numothersock)
 	if (ub->vmguarpages != NULL) {
 		if (ub->vmguarpages[1] != LONG_MAX) {
 			logger(-1, 0, "Error: limit should be = %lu for"
 				" vmguarpages (currently, %lu)", LONG_MAX,
 				ub->vmguarpages[1]);
 			if (ask || recover) {
 				SET_MES((unsigned long) LONG_MAX);
 				if (ask)
 					recover = read_yn();
 				if (recover) {
 					ub->vmguarpages[1] = LONG_MAX;
 					changed++;
 				}
 			}
 			if (!recover) ret = 1;
 //			if (!ask) fprintf(stderr, "\n");
 		}
 	} else {
 		logger(-1, 0, "Error: parameter vmguarpages not found");
 		ret = 1;
 	}
 	/* Secondary */
 	CHECK_BL(ub->kmemsize, kmemsize)
 	CHECK_BL(ub->tcpsndbuf, tcpsndbuf)
 	CHECK_BL(ub->tcprcvbuf, tcprcvbuf)
 	CHECK_BL(ub->othersockbuf, othersockbuf)
 	CHECK_BL(ub->dgramrcvbuf, dgramrcvbuf)
 	if (ub->oomguarpages != NULL) {
 		if (ub->oomguarpages[1] != LONG_MAX) {
 			logger(-1, 0, "Error: limit should be = %lu for"
 				" oomguarpages (currently, %lu)", LONG_MAX,
 				ub->oomguarpages[1]);
 			if (ask || recover) {
 				SET_MES((unsigned long) LONG_MAX);
 				if (ask)
 					recover = read_yn();
 				if (recover) {
 					ub->oomguarpages[1] = LONG_MAX;
 					changed++;
 				}
 			}
 			if (!recover) ret = 1;
 //			if (!ask) fprintf(stderr, "\n");
 		}
 	} else {
 		logger(-1, 0, "Error: parameter oomguarpages not found");
 		ret = 1;
 	}
 	CHECK_BL(ub->privvmpages, privvmpages)
 	/* Auxiliary */
 	CHECK_BL(ub->lockedpages, lockedpages)
 	CHECK_B(shmpages)
 	if (ub->physpages != NULL) {
 		if (ub->physpages[0] != 0) {
 			logger(-1, 0, "Error: barrier should be = 0 for"
 				" physpages (currently, %lu)",
 				ub->physpages[0]);
 			if (ask || recover) {
 				SET_MES((unsigned long) 0);
 				if (ask)
 					recover = read_yn();
 				if (recover) {
 					ub->physpages[0] = 0;
 					changed++;
 				}
 			}
 			if (!recover) ret = 1;
 //			if (!ask) fprintf(stderr, "\n");
 		}
 		if (ub->physpages[1] != LONG_MAX) {
 			logger(-1, 0, "Error: limit should be = %lu for"
 				" physpages (currently, %lu)", LONG_MAX,
 				ub->physpages[1]);
 			if (ask || recover) {
 				SET_MES((unsigned long) LONG_MAX);
 				if (ask)
 					recover = read_yn();
 				if (recover) {
 					ub->physpages[1] = LONG_MAX;
 					changed++;
 				}
 			}
 			if (!recover) ret = 1;
 //			if (!ask) fprintf(stderr, "\n");
 		}
 	} else {
 		logger(-1, 0, "Error: parameter physpages not found");
 		ret = 1;
 	}
 	CHECK_B(numfile)
 	CHECK_BL(ub->numflock, numflock)
 	CHECK_B(numpty)
 	CHECK_B(numsiginfo)
 	CHECK_BL(ub->dcachesize, dcachesize)
 	CHECK_B(numiptent)
 	CHECK_BL(param->dq.diskspace, diskspace)
 	CHECK_BL(param->dq.diskinodes, diskinodes)

 /*	2 Check formulas			*/
 	val = ub->numfile[0] * 384;
 	val &= LONG_MAX;
 	if (ub->dcachesize[1] < val) {
 		logger(-1, 0, "Warning: dcachesize.lim should be > %lu"
 				" (currently, %lu)", val,
 				ub->dcachesize[1]);
 		if (ask || recover) {
 			SET_MES(val);
 			if (ask)
 				recover = read_yn();
 			if (recover) {
 				ub->dcachesize[1] = val;
 				changed++;
 			}
 		}
 		if (!recover) ret = 1;
 //		if (!ask) fprintf(stderr, "\n");
 	}

 	val = (40 * 1024 * avnumproc) + ub->dcachesize[1];
 	val &= LONG_MAX;
 	if (ub->kmemsize[0] < val) {
 		logger(-1, 0, "Error: kmemsize.bar should be > %lu"
 				" (currently, %lu)", val, ub->kmemsize[0]);
 		if (ask || recover) {
 			tmp_val1 = ub->kmemsize[1] + val - ub->kmemsize[0];
 			tmp_val0 = val;
 			SET2_MES(tmp_val0, tmp_val1);
 			if (ask)
 				recover = read_yn();
 			if (recover) {
 				ub->kmemsize[1] = tmp_val1;
 				ub->kmemsize[0] = tmp_val0;
 				changed++;
 			}
 		}
 		if (!recover) ret = 1;
 //		if (!ask) fprintf(stderr, "\n");
 	}
 	if (ub->privvmpages[0] < ub->vmguarpages[0]) {
 		logger(-1, 0, "Warning: privvmpages.bar should be > %lu"
 				" (currently, %lu)", ub->vmguarpages[0],
 				ub->privvmpages[0]);
 		if (ask || recover) {
 			tmp_val0 = ub->vmguarpages[0];
 			tmp_val1 = ub->privvmpages[1] < tmp_val0 ?
 				tmp_val0 : ub->vmguarpages[1];
 			SET_MES(tmp_val0);
 			if (ask)
 				recover = read_yn();
 			if (recover) {
 				ub->privvmpages[0] = tmp_val0;
 				ub->privvmpages[1] = tmp_val1;
 				changed++;
 			}
 		}
 		if (!recover) ret = 1;
 //		if (!ask) fprintf(stderr, "\n");
 	}
 	val = 2.5 * 1024 * ub->numtcpsock[0];
 	val &= LONG_MAX;
 	if (ub->tcpsndbuf[1] - ub->tcpsndbuf[0] < val) {
 		logger(-1, 0, "Error: tcpsndbuf.lim-tcpsndbuf.bar"
 				" should be > %lu (currently, %lu)", val,
 				ub->tcpsndbuf[1]-ub->tcpsndbuf[0]);
 		if (ask || recover) {
 			tmp_val1 = ub->tcpsndbuf[0] + val;
 			tmp_val0 = ub->tcpsndbuf[0];
 			SET2_MES(tmp_val0, tmp_val1);
 			if (ask)
 				recover = read_yn();
 			if (recover) {
 				ub->tcpsndbuf[1] = tmp_val1;
 				changed++;
 			}
 		}
 		if (!recover) ret = 1;
 //		if (!ask) fprintf(stderr, "\n");
 	}
 	val = 2.5 * 1024 * ub->numothersock[0];
 	val &= LONG_MAX;
 	if (ub->othersockbuf[1] - ub->othersockbuf[0] < val) {
 		logger(-1, 0, "Error: othersockbuf.lim-othersockbuf.bar"
 				" should be > %lu (currently, %lu)", val,
 				ub->othersockbuf[1]-ub->othersockbuf[0]);
 		if (ask || recover) {
 			tmp_val1 = ub->othersockbuf[0] + val;
 			tmp_val0 = ub->othersockbuf[0];
 			SET2_MES(tmp_val0, tmp_val1)
 			if (ask)
 				recover = read_yn();
 			if (recover) {
 				ub->othersockbuf[1] = tmp_val1;
 				changed++;
 			}
 		}
 		if (!recover) ret = 1;
 //		if (!ask) fprintf(stderr, "\n");
 	}
 	val =  2.5 * 1024 * ub->numtcpsock[0];
 	val &= LONG_MAX;
 	if (ub->tcprcvbuf[1] - ub->tcprcvbuf[0] < val) {
 		logger(-1, 0, "Warning: tcprcvbuf.lim-tcprcvbuf.bar"
 				" should be > %lu (currently, %lu)", val,
 				ub->tcprcvbuf[1] - ub->tcprcvbuf[0]);
 		if (ask || recover) {
 			tmp_val1 = ub->tcprcvbuf[0] + val;
 			tmp_val0 = ub->tcprcvbuf[0];
 			SET2_MES(tmp_val0, tmp_val1)
 			if (ask)
 				recover = read_yn();
 			if (recover) {
 				ub->tcprcvbuf[1] = tmp_val1;
 				changed++;
 			}
 		}
 		if (!recover) ret = 1;
 //		if (!ask) fprintf(stderr, "\n");
 	}
 	val = 64 * 1024;
 	if (ub->tcprcvbuf[0] < val) {
 		logger(-1, 0, "Warning: tcprcvbuf.bar should be > %lu"
 				" (currently, %lu)", val,
 				ub->tcprcvbuf[0]);
 		if (ask || recover) {
 			tmp_val1 = ub->tcprcvbuf[1]+val-ub->tcprcvbuf[0];
 			tmp_val0 = val;
 			SET2_MES(tmp_val0, tmp_val1)
 			if (ask)
 				recover = read_yn();
 			if (recover) {
 				ub->tcprcvbuf[1] = tmp_val1;
 				ub->tcprcvbuf[0] = tmp_val0;
 				changed++;
 			}
 		}
 		if (!recover) ret = 1;
 //		if (!ask) fprintf(stderr, "\n");
 	}
 	val = 64 * 1024;
 	if (ub->tcpsndbuf[0] <  val) {
 		logger(-1, 0, "Warning: tcpsndbuf.bar should be > %lu"
 				" (currently, %lu)", val,
 				ub->tcpsndbuf[0]);
 		if (ask || recover) {
 			tmp_val1 = ub->tcpsndbuf[1]+val-ub->tcpsndbuf[0];
 			tmp_val0 = val;
 			SET2_MES(tmp_val0, tmp_val1)
 			if (ask)
 				recover = read_yn();
 			if (recover) {
 				ub->tcpsndbuf[1] = tmp_val1;
 				ub->tcpsndbuf[0] = tmp_val0;
 				changed++;
 			}
 		}
 		if (!recover) ret = 1;
 //		if (!ask) fprintf(stderr, "\n");
 	}
 	val = 32 * 1024;
 	val1 = 129 * 1024;
 	if (ub->dgramrcvbuf[0] < val) {
 		logger(-1, 0, "Warning: dgramrcvbuf.bar should be >"
 				" %lu (currently, %lu)", val,
 				ub->dgramrcvbuf[0]);
 		if (ask || recover) {
 			tmp_val1 = ub->dgramrcvbuf[1] + val -
 					ub->dgramrcvbuf[0];
 			tmp_val0 = val;
 			SET2_MES(tmp_val0, tmp_val1)
 			if (ask)
 				recover = read_yn();
 			if (recover) {
 				ub->dgramrcvbuf[1] = tmp_val1;
 				ub->dgramrcvbuf[0] = tmp_val0;
 				changed++;
 			}
 		}
 		if (!recover) ret = 1;
 //		if (!ask) fprintf(stderr, "\n");
 	} else if (ub->dgramrcvbuf[0] < val1) {
 		logger(-1, 0, "Recommendation: dgramrcvbuf.bar should be >"
 				" %lu (currently, %lu)", val1,
 				ub->dgramrcvbuf[0]);
 		if (ask || recover) {
 			tmp_val1 = ub->dgramrcvbuf[1] + val1 -
 					ub->dgramrcvbuf[0];
 			tmp_val0 = val1;
 			SET2_MES(tmp_val0, tmp_val1)
 			if (ask)
 				recover = read_yn();
 			if (recover) {
 				ub->dgramrcvbuf[1] = tmp_val1;
 				ub->dgramrcvbuf[0] = tmp_val0;
 				changed++;
 			}
 		}
 //		if (!ask) fprintf(stderr, "\n");
 	}
 	val =  32 * 1024;
 	val1 = 129 * 1024;
 	if (ub->othersockbuf[0] < val) {
 		logger(-1, 0, "Warning: othersockbuf.bar should be >"
 				" %lu (currently, %lu)", val,
 				ub->othersockbuf[0]);
 		if (ask || recover) {
 			tmp_val1 = ub->othersockbuf[1] + val -
 					ub->othersockbuf[0];
 			tmp_val0 = val;
 			SET2_MES(tmp_val0, tmp_val1)
 			if (ask)
 				recover = read_yn();
 			if (recover) {
 				ub->othersockbuf[1] = tmp_val1;
 				ub->othersockbuf[0] = tmp_val0;
 				changed++;
 			}
 		}
 		if (!recover) ret = 1;
 //		if (!ask) fprintf(stderr, "\n");
 	} else if (ub->othersockbuf[0] < val1) {
 		logger(-1, 0,"Recommendation: othersockbuf.bar should be >"
 				" %lu (currently, %lu)", val1,
 				ub->othersockbuf[0]);
 		if (ask || recover) {
 			tmp_val1 = ub->othersockbuf[1] + val1 -
 					ub->othersockbuf[0];
 			tmp_val0 = val1;
 			SET2_MES(tmp_val0, tmp_val1)
 			if (ask)
 				recover = read_yn();
 			if (recover) {
 				ub->othersockbuf[1] = tmp_val1;
 				ub->othersockbuf[0] = tmp_val0;
 				changed++;
 			}
 		}
 //		if (!ask) fprintf(stderr, "\n");
 	}
 	val = avnumproc * 32;
 	val1 = ub->numtcpsock[0] + ub->numothersock[0] + ub->numpty[0];
 	if (val1 > val)
 		val = val1;
 	val &= LONG_MAX;
 	if (ub->numfile[0] < val) {
 		logger(-1, 0, "Warning: numfile should be > %lu"
 				" (currently, %lu)", val, ub->numfile[0]);
 		if (ask || recover) {
 			tmp_val1 = ub->numfile[1] + val - ub->numfile[0];
 			tmp_val0 = val;
 			SET2_MES(tmp_val0, tmp_val1)
 			if (ask)
 				recover = read_yn();
 			if (recover) {
 				ub->numfile[1] = tmp_val1;
 				ub->numfile[0] = tmp_val0;
 				changed++;
 			}
 		}
 		if (!recover) ret = 1;
 //		if (!ask) fprintf(stderr, "\n");
 	}

 	return ret;
 }

 int vps_validate(vps_res *param, int mode)
 {
 	int ret;

 	if (mode == ACT_NONE)
 		return 0;
 	logger(0, 0, "Validating VE:");
 	ret  = validate(param, mode == ACT_FIX, 0);
 	if (mode == ACT_ERROR && ret)
 		return VZ_VALIDATE_ERROR;
 	return 0;
 }

 int calc_ve_utilization(struct ub_struct *param, struct CRusage *rusage,
 	struct mem_struct *mem, int numerator)
 {
 	double kmem_net;

 	memset(rusage, 0, sizeof(struct CRusage));
 	if (param == NULL)
 		return -1;
 	if (check_param(param, 1))
 		return -1;
 	kmem_net = (double)param->kmemsize[0] +
 		(double)param->tcprcvbuf[0] +
 		(double)param->tcpsndbuf[0] +
 		(double)param->dgramrcvbuf[0] +
 		(double)param->othersockbuf[0];
 	/*	Low memory	*/
 	rusage->low_mem = kmem_net;
 	if (!numerator)
 		rusage->low_mem /= mem->lowmem;
 	/*	Total RAM	*/
 	rusage->total_ram = ((double)param->physpages[0] * page_size +
 		kmem_net);
 	if (!numerator)
 		rusage->total_ram /= mem->ram;
 	/*	Mem + Swap	*/
 	rusage->mem_swap = ((double)param->oomguarpages[0] * page_size +
 		kmem_net);
 	if (!numerator)
 			rusage->mem_swap /= (mem->ram + mem->swap);
 	/*	Allocated memory	*/
 	rusage->alloc_mem = ((double)param->privvmpages[0] * page_size +
 		kmem_net);
 	if (!numerator)
 		rusage->alloc_mem /= (mem->ram + mem->swap);

 	return 0;
 }

 int calc_ve_commitment(struct ub_struct *param, struct CRusage *rusage,
 	struct mem_struct *mem, int numerator)
 {
 	double kmem_net;

 	memset(rusage, 0, sizeof(struct CRusage));
 	if (param == NULL)
 		return -1;
 	if (check_param(param, 1))
 		return -1;
 	kmem_net = (double)param->kmemsize[1] +
 		(double)param->tcprcvbuf[1] +
 		(double)param->tcpsndbuf[1] +
 		(double)param->dgramrcvbuf[1] +
 		(double)param->othersockbuf[1];
 	/*	Low memory	*/
 	rusage->low_mem = kmem_net;
 	if (!numerator)
 		rusage->low_mem /= mem->lowmem;
 	/*	Total RAM	*/
 	rusage->total_ram = ((double)param->physpages[0] * page_size +
 		kmem_net);
 	if (!numerator)
 		rusage->total_ram /= mem->ram;
 	/*	Mem + Swap	*/
 	rusage->mem_swap = ((double)param->oomguarpages[0] * page_size +
 		kmem_net);
 	if (!numerator)
 		rusage->mem_swap /= (mem->ram + mem->swap);
 	/*	Allocated memory	*/
 	rusage->alloc_mem = ((double)param->vmguarpages[0] * page_size +
 		kmem_net);
 	if (!numerator)
 		rusage->alloc_mem /= (mem->ram + mem->swap);
 	/*	Allocated memory limit	*/
 	rusage->alloc_mem_lim = ((double)param->privvmpages[1] * page_size +
 		kmem_net);
 	if (!numerator)
 		rusage->alloc_mem_lim /= (mem->ram + mem->swap);
 	/*	Max Allocated memory limit	*/
 	rusage->alloc_mem_max_lim = ((double)param->privvmpages[1] * page_size +
 		kmem_net);
 	if (!numerator)
 		rusage->alloc_mem_max_lim /= mem->ram;
 	return 0;
 }

 void inc_rusage(struct CRusage *rusagetotal, struct CRusage *rusage)
 {
 	if (rusagetotal == NULL || rusage == NULL)
 		return;
 	rusagetotal->low_mem += rusage->low_mem;
 	rusagetotal->total_ram += rusage->total_ram;
 	rusagetotal->mem_swap += rusage->mem_swap;
 	rusagetotal->alloc_mem += rusage->alloc_mem;
 	rusagetotal->alloc_mem_lim += rusage->alloc_mem_lim;
 	if (rusage->alloc_mem_max_lim > rusagetotal->alloc_mem_max_lim)
 		rusagetotal->alloc_mem_max_lim = rusage->alloc_mem_max_lim;
 }

 void mul_rusage(struct CRusage *rusage, int k)
 {
 	if (rusage == NULL)
 		return;
 	rusage->low_mem *= k;
 	rusage->total_ram *= k;
 	rusage->mem_swap *= k;
 	rusage->alloc_mem *= k;
 	rusage->alloc_mem_lim *= k;
 	rusage->alloc_mem_max_lim *= k;
 }

 void shift_ubs_param(struct ub_struct *param)
 {
 #define SHIFTPARAM(name) 						\
 if (param->name != NULL) {						\
 	param->name[0] = param->name[1];				\
 	param->name[1] = param->name[2];				\
 }
 	SHIFTPARAM(numproc);
 	SHIFTPARAM(numtcpsock);
 	SHIFTPARAM(numothersock);
 	SHIFTPARAM(oomguarpages)
 	SHIFTPARAM(vmguarpages);
 	SHIFTPARAM(kmemsize);
 	SHIFTPARAM(tcpsndbuf);
 	SHIFTPARAM(tcprcvbuf);
 	SHIFTPARAM(othersockbuf);
 	SHIFTPARAM(dgramrcvbuf);
 	SHIFTPARAM(privvmpages);
 	SHIFTPARAM(numfile);
 	SHIFTPARAM(dcachesize);
 	SHIFTPARAM(physpages)
 	SHIFTPARAM(numpty)
 }

 int calc_hn_rusage(struct CRusage *ru_comm, struct CRusage *ru_utl)
 {
 	FILE *fd;
 	struct CRusage utl, comm;
 	char str[STR_SIZE];
 	char name[STR_SIZE];
 	const char *fmt;
 	unsigned long held, maxheld, barrier, limit;
 	int found = 0;
 	int id, res;
 	int veid = 0;
 	ub_param ub;
 	struct ub_struct ub_s;
 	struct mem_struct mem;

 	if ((fd = fopen(PROCUBC, "r")) == NULL) {
 		logger(-1, errno, "Unable open " PROCUBC);
 		return -1;
 	}
 	if (ru_comm != NULL)
 		memset(ru_comm, 0, sizeof(*ru_comm));
 	if (ru_utl != NULL)
 		memset(ru_utl, 0, sizeof(*ru_utl));
 	memset(&ub, 0, sizeof(ub));
 	memset(&ub_s, 0, sizeof(ub_s));
 	while (fgets(str, sizeof(str), fd)) {
 		if ((res = sscanf(str, "%d:", &id)) == 1) {
 			fmt =  "%*lu:%s%lu%lu%lu%lu";
 			found = 1;
 			if (veid) {
 				if (ru_utl != NULL) {
 					calc_ve_utilization(&ub_s, &utl, &mem, 0);
 					inc_rusage(ru_utl, &utl);
 				}
 				if (ru_comm != NULL) {
 					shift_ubs_param(&ub_s);
 					calc_ve_commitment(&ub_s, &comm, &mem, 0);
 					inc_rusage(ru_comm, &comm);
 				}
 			}
 			veid = id;
 			free_ub_param(&ub_s);
 		} else {
 			fmt = "%s%lu%lu%lu%lu";
 		}
 		if (found) {
 			if ((res = sscanf(str, fmt, name, &held, &maxheld,
 				&barrier, &limit)) != 5)
 			{
 				continue;
 			}
 			if ((res = get_ub_resid(name)) >= 0) {
 				unsigned long *par;
 				par = malloc(sizeof(*par) * 3);
 				par[0] = held;
 				par[1] = barrier;
 				par[2] = limit;
 				add_ub_limit(&ub_s, res, par);
 			}
 		}
 	}
 	/* Last VE in /proc/user_beancounters */
 	if (veid) {
 		if (ru_utl != NULL) {
 			calc_ve_utilization(&ub_s, &utl, &mem, 0);
 			inc_rusage(ru_utl, &utl);
 		}
 		if (ru_comm != NULL) {
 			shift_ubs_param(&ub_s);
 			calc_ve_commitment(&ub_s, &comm, &mem, 0);
 			inc_rusage(ru_comm, &comm);
 		}
 		free_ub_param(&ub_s);
 	}
 	fclose(fd);
 	return 0;
 }

 int check_hn_overcommitment(int veid, struct ub_struct *param,
 	struct ovrc *ovrc)
 {
 	struct CRusage ru_comm;
 	struct CRusage rusage_ve;
 	int actid;
 	int ret = 0;
 	struct mem_struct mem;

 	if (param == NULL)
 		return 0;
 	actid = ovrc->action;
 	if (ovrc->action == ACT_NONE)
 		return 0;
 	memset(&ru_comm, 0, sizeof(ru_comm));
 	/* Calculate current HN overcommitment */
 	if (calc_hn_rusage(&ru_comm, NULL))
 		return 0;
 	/* Add VE resource usage */
 	calc_ve_commitment(param, &rusage_ve, &mem, 0);
 	inc_rusage(&ru_comm, &rusage_ve);
 	/* Convert to % */
 	mul_rusage(&ru_comm, 100);
 	if (ovrc->level_low_mem != NULL &&
 		ru_comm.low_mem > *ovrc->level_low_mem)
 	{
 		logger(0, 0, "%s: node is overcommited.",
 				actid == ACT_ERROR ? "Error" : "Warning");
 		logger(0, 0, "\tLow Memory commitment level (%.3f%%)"
 				" exceeds configured (%.3f%%)",
 				ru_comm.low_mem, *ovrc->level_low_mem);
 		ret = 1;
 	}
 	if (ovrc->level_mem_swap != NULL &&
 		ru_comm.mem_swap > *ovrc->level_mem_swap)
 	{
 		if (!ret)
 			logger(0, 0, "%s: node is overcommited.",
 				actid == ACT_ERROR ? "Error" : "Warning");
 		logger(0, 0, "\tMemory and Swap commitment level (%.3f%%)"
 				" exceeds configured (%.3f%%)",
 				ru_comm.mem_swap, *ovrc->level_mem_swap);
 		ret = 1;
 	}
 	if (ovrc->level_alloc_mem != NULL &&
 		ru_comm.alloc_mem > *ovrc->level_alloc_mem)
 	{
 		if (!ret)
 			logger(0, 0, "%s: node is overcommited.",
 				actid == ACT_ERROR ? "Error" : "Warning");
 		logger(0, 0, "\tAllocated Memory commitment level (%.3f%%)"
 				" exceeds configured (%.3f%%)",
 				ru_comm.alloc_mem, *ovrc->level_alloc_mem);
 		ret = 1;
 	}
 	if (ovrc->level_alloc_mem_lim != NULL &&
 		ru_comm.alloc_mem_lim > *ovrc->level_alloc_mem_lim)
 	{
 		if (!ret)
 			logger(0, 0, "%s: node is overcommited.",
 				actid == ACT_ERROR ? "Error" : "Warning");
 		logger(0, 0, "\tTotal Alloc Limit commitment level (%.3f%%)"
 				" exceeds configured (%.3f%%)",
 				ru_comm.alloc_mem_lim,
 				*ovrc->level_alloc_mem_lim);
 		ret = 1;
 	}
 	return actid == ACT_ERROR ? VZ_OVERCOMMIT_ERROR : 0;
 }
	/*
	* Copyright (C) 2000-2007 SWsoft. All rights reserved.
	*
	* This program is free software; you can redistribute it and/or modify
	* it under the terms of the GNU General Public License as published by
	* the Free Software Foundation; either version 2 of the License, or
	* (at your option) any later version.
	*
	* This program is distributed in the hope that it will be useful,
	* but WITHOUT ANY WARRANTY; without even the implied warranty of
	* MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the
	* GNU General Public License for more details.
	*
	* You should have received a copy of the GNU General Public License
	* along with this program; if not, write to the Free Software
	* Foundation, Inc., 59 Temple Place, Suite 330, Boston, MA 02111-1307 USA
	*/

	#include <stdio.h>
	#include <limits.h>
	#include <stdlib.h>
	#include <ctype.h>
	#include <string.h>
	#include <errno.h>

	#include "ub.h"
	#include "res.h"
	#include "validate.h"
	#include "vzctl_param.h"
	#include "vzerror.h"
	#include "logger.h"
	#include "util.h"

	static int page_size = 4096;

	static struct {
	char *name;
	int id;
	} validate_act2str[] = {
	{"none", ACT_NONE},
	{"warning", ACT_WARN},
	{"error", ACT_ERROR},
	{"fix", ACT_FIX},
	};

	int action2id(char *mode)
	{
	int i;

	if (mode == NULL)
	return ACT_NONE;
	for (i = 0; i < sizeof(validate_act2str) / sizeof(*validate_act2str);
	i++)
	{
	if (!strcmp(validate_act2str[i].name, mode))
	return validate_act2str[i].id;
	}
	return ACT_NONE;
	}



	static int read_yn()
	{
	char buf[1024];

	fprintf(stderr, " (y/n) [y] ");
	while (fgets(buf, sizeof(buf), stdin) != NULL) {
	if (buf[0] == 'y' \|\| buf[0] == '\n') {
	return 1;
	}
	else if (buf[0] == 'n')
	return 0;
	fprintf(stderr, " (y/n) [y] ");
	}
	return 0;
	}

	static int check_param(struct ub_struct *param, int log)
	{
	int ret = 0;
	#define CHECKPARAM(name) \
	if (param->name == NULL) { \
	if (log) \
	logger(-1, 0, "Error: parameter " #name \
	" not found"); \
	ret = 1; \
	} \

	CHECKPARAM(numproc);
	CHECKPARAM(numtcpsock);
	CHECKPARAM(numothersock);
	CHECKPARAM(oomguarpages)
	CHECKPARAM(vmguarpages);
	CHECKPARAM(kmemsize);
	CHECKPARAM(tcpsndbuf);
	CHECKPARAM(tcprcvbuf);
	CHECKPARAM(othersockbuf);
	CHECKPARAM(dgramrcvbuf);
	CHECKPARAM(privvmpages);
	CHECKPARAM(numfile);
	CHECKPARAM(dcachesize);
	CHECKPARAM(physpages)
	CHECKPARAM(numpty)

	return ret;
	}

	int validate(vps_res *param, int recover, int ask)
	{
	unsigned long avnumproc;
	int ret = 0;
	unsigned long val, val1;
	unsigned long tmp_val0, tmp_val1;
	int changed = 0;
	struct ub_struct *ub;

	#define SET_MES(val) logger(0, 0, "set to %lu", val);
	#define SET2_MES(val1, val2) logger(0, 0,"set to %lu:%lu", val1, val2);

	#define CHECK_BL(x, name) \
	if (x != NULL) { \
	if (x[0] > x[1]) { \
	logger(-1, 0, "Error: barrier should be <= limit for " \
	#name " (currently, %lu:%lu)", \
	x[0], x[1]); \
	if (ask \|\| recover) { \
	tmp_val1 = x[0]; \
	tmp_val0 = x[0]; \
	SET2_MES(tmp_val0, tmp_val1) \
	if (ask) recover = read_yn(); \
	if (recover) { \
	x[1] = tmp_val1; \
	changed++; \
	} \
	} \
	if (!recover) ret = 1; \
	} \
	} else { \
	logger(-1, 0, "Error: parameter " #name " not found"); \
	ret = 1; \
	}

	#define CHECK_B(name) \
	if (ub->name != NULL) { \
	if ((ub->name[0] != ub->name[1])) { \
	logger(-1, 0, "Error: barrier should be equal to limit" \
	" for " #name " (currently, %lu:%lu)", \
	ub->name[0], ub->name[1]); \
	if (ask \|\| recover) { \
	tmp_val0 = max_ul(ub->name[0], ub->name[1]); \
	tmp_val1 = tmp_val0; \
	SET2_MES(tmp_val0, tmp_val1) \
	if (ask) recover = read_yn(); \
	if (recover) { \
	ub->name[0] = tmp_val0; \
	ub->name[1] = tmp_val1; \
	changed++; \
	} \
	} \
	if (!recover) ret = 1; \
	} \
	} else { \
	logger(-1, 0, "Error: parameter " #name " not found"); \
	ret = 1; \
	}

	if (param == NULL)
	return 1;
	ub = &param->ub;
	if (check_param(ub, 1))
	return 1;
	if (ub->avnumproc != NULL)
	avnumproc = ub->avnumproc[0];
	else
	avnumproc = ub->numproc[0] / 2;
	/* 1 Check barrier & limit */
	/* Primary */
	CHECK_B(numproc)
	CHECK_B(numtcpsock)
	CHECK_B(numothersock)
	if (ub->vmguarpages != NULL) {
	if (ub->vmguarpages[1] != LONG_MAX) {
	logger(-1, 0, "Error: limit should be = %lu for"
	" vmguarpages (currently, %lu)", LONG_MAX,
	ub->vmguarpages[1]);
	if (ask \|\| recover) {
	SET_MES((unsigned long) LONG_MAX);
	if (ask)
	recover = read_yn();
	if (recover) {
	ub->vmguarpages[1] = LONG_MAX;
	changed++;
	}
	}
	if (!recover) ret = 1;
	// if (!ask) fprintf(stderr, "\n");
	}
	} else {
	logger(-1, 0, "Error: parameter vmguarpages not found");
	ret = 1;
	}
	/* Secondary */
	CHECK_BL(ub->kmemsize, kmemsize)
	CHECK_BL(ub->tcpsndbuf, tcpsndbuf)
	CHECK_BL(ub->tcprcvbuf, tcprcvbuf)
	CHECK_BL(ub->othersockbuf, othersockbuf)
	CHECK_BL(ub->dgramrcvbuf, dgramrcvbuf)
	if (ub->oomguarpages != NULL) {
	if (ub->oomguarpages[1] != LONG_MAX) {
	logger(-1, 0, "Error: limit should be = %lu for"
	" oomguarpages (currently, %lu)", LONG_MAX,
	ub->oomguarpages[1]);
	if (ask \|\| recover) {
	SET_MES((unsigned long) LONG_MAX);
	if (ask)
	recover = read_yn();
	if (recover) {
	ub->oomguarpages[1] = LONG_MAX;
	changed++;
	}
	}
	if (!recover) ret = 1;
	// if (!ask) fprintf(stderr, "\n");
	}
	} else {
	logger(-1, 0, "Error: parameter oomguarpages not found");
	ret = 1;
	}
	CHECK_BL(ub->privvmpages, privvmpages)
	/* Auxiliary */
	CHECK_BL(ub->lockedpages, lockedpages)
	CHECK_B(shmpages)
	if (ub->physpages != NULL) {
	if (ub->physpages[0] != 0) {
	logger(-1, 0, "Error: barrier should be = 0 for"
	" physpages (currently, %lu)",
	ub->physpages[0]);
	if (ask \|\| recover) {
	SET_MES((unsigned long) 0);
	if (ask)
	recover = read_yn();
	if (recover) {
	ub->physpages[0] = 0;
	changed++;
	}
	}
	if (!recover) ret = 1;
	// if (!ask) fprintf(stderr, "\n");
	}
	if (ub->physpages[1] != LONG_MAX) {
	logger(-1, 0, "Error: limit should be = %lu for"
	" physpages (currently, %lu)", LONG_MAX,
	ub->physpages[1]);
	if (ask \|\| recover) {
	SET_MES((unsigned long) LONG_MAX);
	if (ask)
	recover = read_yn();
	if (recover) {
	ub->physpages[1] = LONG_MAX;
	changed++;
	}
	}
	if (!recover) ret = 1;
	// if (!ask) fprintf(stderr, "\n");
	}
	} else {
	logger(-1, 0, "Error: parameter physpages not found");
	ret = 1;
	}
	CHECK_B(numfile)
	CHECK_BL(ub->numflock, numflock)
	CHECK_B(numpty)
	CHECK_B(numsiginfo)
	CHECK_BL(ub->dcachesize, dcachesize)
	CHECK_B(numiptent)
	CHECK_BL(param->dq.diskspace, diskspace)
	CHECK_BL(param->dq.diskinodes, diskinodes)

	/* 2 Check formulas */
	val = ub->numfile[0] * 384;
	val &= LONG_MAX;
	if (ub->dcachesize[1] < val) {
	logger(-1, 0, "Warning: dcachesize.lim should be > %lu"
	" (currently, %lu)", val,
	ub->dcachesize[1]);
	if (ask \|\| recover) {
	SET_MES(val);
	if (ask)
	recover = read_yn();
	if (recover) {
	ub->dcachesize[1] = val;
	changed++;
	}
	}
	if (!recover) ret = 1;
	// if (!ask) fprintf(stderr, "\n");
	}

	val = (40 * 1024 * avnumproc) + ub->dcachesize[1];
	val &= LONG_MAX;
	if (ub->kmemsize[0] < val) {
	logger(-1, 0, "Error: kmemsize.bar should be > %lu"
	" (currently, %lu)", val, ub->kmemsize[0]);
	if (ask \|\| recover) {
	tmp_val1 = ub->kmemsize[1] + val - ub->kmemsize[0];
	tmp_val0 = val;
	SET2_MES(tmp_val0, tmp_val1);
	if (ask)
	recover = read_yn();
	if (recover) {
	ub->kmemsize[1] = tmp_val1;
	ub->kmemsize[0] = tmp_val0;
	changed++;
	}
	}
	if (!recover) ret = 1;
	// if (!ask) fprintf(stderr, "\n");
	}
	if (ub->privvmpages[0] < ub->vmguarpages[0]) {
	logger(-1, 0, "Warning: privvmpages.bar should be > %lu"
	" (currently, %lu)", ub->vmguarpages[0],
	ub->privvmpages[0]);
	if (ask \|\| recover) {
	tmp_val0 = ub->vmguarpages[0];
	tmp_val1 = ub->privvmpages[1] < tmp_val0 ?
	tmp_val0 : ub->vmguarpages[1];
	SET_MES(tmp_val0);
	if (ask)
	recover = read_yn();
	if (recover) {
	ub->privvmpages[0] = tmp_val0;
	ub->privvmpages[1] = tmp_val1;
	changed++;
	}
	}
	if (!recover) ret = 1;
	// if (!ask) fprintf(stderr, "\n");
	}
	val = 2.5 * 1024 * ub->numtcpsock[0];
	val &= LONG_MAX;
	if (ub->tcpsndbuf[1] - ub->tcpsndbuf[0] < val) {
	logger(-1, 0, "Error: tcpsndbuf.lim-tcpsndbuf.bar"
	" should be > %lu (currently, %lu)", val,
	ub->tcpsndbuf[1]-ub->tcpsndbuf[0]);
	if (ask \|\| recover) {
	tmp_val1 = ub->tcpsndbuf[0] + val;
	tmp_val0 = ub->tcpsndbuf[0];
	SET2_MES(tmp_val0, tmp_val1);
	if (ask)
	recover = read_yn();
	if (recover) {
	ub->tcpsndbuf[1] = tmp_val1;
	changed++;
	}
	}
	if (!recover) ret = 1;
	// if (!ask) fprintf(stderr, "\n");
	}
	val = 2.5 * 1024 * ub->numothersock[0];
	val &= LONG_MAX;
	if (ub->othersockbuf[1] - ub->othersockbuf[0] < val) {
	logger(-1, 0, "Error: othersockbuf.lim-othersockbuf.bar"
	" should be > %lu (currently, %lu)", val,
	ub->othersockbuf[1]-ub->othersockbuf[0]);
	if (ask \|\| recover) {
	tmp_val1 = ub->othersockbuf[0] + val;
	tmp_val0 = ub->othersockbuf[0];
	SET2_MES(tmp_val0, tmp_val1)
	if (ask)
	recover = read_yn();
	if (recover) {
	ub->othersockbuf[1] = tmp_val1;
	changed++;
	}
	}
	if (!recover) ret = 1;
	// if (!ask) fprintf(stderr, "\n");
	}
	val = 2.5 * 1024 * ub->numtcpsock[0];
	val &= LONG_MAX;
	if (ub->tcprcvbuf[1] - ub->tcprcvbuf[0] < val) {
	logger(-1, 0, "Warning: tcprcvbuf.lim-tcprcvbuf.bar"
	" should be > %lu (currently, %lu)", val,
	ub->tcprcvbuf[1] - ub->tcprcvbuf[0]);
	if (ask \|\| recover) {
	tmp_val1 = ub->tcprcvbuf[0] + val;
	tmp_val0 = ub->tcprcvbuf[0];
	SET2_MES(tmp_val0, tmp_val1)
	if (ask)
	recover = read_yn();
	if (recover) {
	ub->tcprcvbuf[1] = tmp_val1;
	changed++;
	}
	}
	if (!recover) ret = 1;
	// if (!ask) fprintf(stderr, "\n");
	}
	val = 64 * 1024;
	if (ub->tcprcvbuf[0] < val) {
	logger(-1, 0, "Warning: tcprcvbuf.bar should be > %lu"
	" (currently, %lu)", val,
	ub->tcprcvbuf[0]);
	if (ask \|\| recover) {
	tmp_val1 = ub->tcprcvbuf[1]+val-ub->tcprcvbuf[0];
	tmp_val0 = val;
	SET2_MES(tmp_val0, tmp_val1)
	if (ask)
	recover = read_yn();
	if (recover) {
	ub->tcprcvbuf[1] = tmp_val1;
	ub->tcprcvbuf[0] = tmp_val0;
	changed++;
	}
	}
	if (!recover) ret = 1;
	// if (!ask) fprintf(stderr, "\n");
	}
	val = 64 * 1024;
	if (ub->tcpsndbuf[0] < val) {
	logger(-1, 0, "Warning: tcpsndbuf.bar should be > %lu"
	" (currently, %lu)", val,
	ub->tcpsndbuf[0]);
	if (ask \|\| recover) {
	tmp_val1 = ub->tcpsndbuf[1]+val-ub->tcpsndbuf[0];
	tmp_val0 = val;
	SET2_MES(tmp_val0, tmp_val1)
	if (ask)
	recover = read_yn();
	if (recover) {
	ub->tcpsndbuf[1] = tmp_val1;
	ub->tcpsndbuf[0] = tmp_val0;
	changed++;
	}
	}
	if (!recover) ret = 1;
	// if (!ask) fprintf(stderr, "\n");
	}
	val = 32 * 1024;
	val1 = 129 * 1024;
	if (ub->dgramrcvbuf[0] < val) {
	logger(-1, 0, "Warning: dgramrcvbuf.bar should be >"
	" %lu (currently, %lu)", val,
	ub->dgramrcvbuf[0]);
	if (ask \|\| recover) {
	tmp_val1 = ub->dgramrcvbuf[1] + val -
	ub->dgramrcvbuf[0];
	tmp_val0 = val;
	SET2_MES(tmp_val0, tmp_val1)
	if (ask)
	recover = read_yn();
	if (recover) {
	ub->dgramrcvbuf[1] = tmp_val1;
	ub->dgramrcvbuf[0] = tmp_val0;
	changed++;
	}
	}
	if (!recover) ret = 1;
	// if (!ask) fprintf(stderr, "\n");
	} else if (ub->dgramrcvbuf[0] < val1) {
	logger(-1, 0, "Recommendation: dgramrcvbuf.bar should be >"
	" %lu (currently, %lu)", val1,
	ub->dgramrcvbuf[0]);
	if (ask \|\| recover) {
	tmp_val1 = ub->dgramrcvbuf[1] + val1 -
	ub->dgramrcvbuf[0];
	tmp_val0 = val1;
	SET2_MES(tmp_val0, tmp_val1)
	if (ask)
	recover = read_yn();
	if (recover) {
	ub->dgramrcvbuf[1] = tmp_val1;
	ub->dgramrcvbuf[0] = tmp_val0;
	changed++;
	}
	}
	// if (!ask) fprintf(stderr, "\n");
	}
	val = 32 * 1024;
	val1 = 129 * 1024;
	if (ub->othersockbuf[0] < val) {
	logger(-1, 0, "Warning: othersockbuf.bar should be >"
	" %lu (currently, %lu)", val,
	ub->othersockbuf[0]);
	if (ask \|\| recover) {
	tmp_val1 = ub->othersockbuf[1] + val -
	ub->othersockbuf[0];
	tmp_val0 = val;
	SET2_MES(tmp_val0, tmp_val1)
	if (ask)
	recover = read_yn();
	if (recover) {
	ub->othersockbuf[1] = tmp_val1;
	ub->othersockbuf[0] = tmp_val0;
	changed++;
	}
	}
	if (!recover) ret = 1;
	// if (!ask) fprintf(stderr, "\n");
	} else if (ub->othersockbuf[0] < val1) {
	logger(-1, 0,"Recommendation: othersockbuf.bar should be >"
	" %lu (currently, %lu)", val1,
	ub->othersockbuf[0]);
	if (ask \|\| recover) {
	tmp_val1 = ub->othersockbuf[1] + val1 -
	ub->othersockbuf[0];
	tmp_val0 = val1;
	SET2_MES(tmp_val0, tmp_val1)
	if (ask)
	recover = read_yn();
	if (recover) {
	ub->othersockbuf[1] = tmp_val1;
	ub->othersockbuf[0] = tmp_val0;
	changed++;
	}
	}
	// if (!ask) fprintf(stderr, "\n");
	}
	val = avnumproc * 32;
	val1 = ub->numtcpsock[0] + ub->numothersock[0] + ub->numpty[0];
	if (val1 > val)
	val = val1;
	val &= LONG_MAX;
	if (ub->numfile[0] < val) {
	logger(-1, 0, "Warning: numfile should be > %lu"
	" (currently, %lu)", val, ub->numfile[0]);
	if (ask \|\| recover) {
	tmp_val1 = ub->numfile[1] + val - ub->numfile[0];
	tmp_val0 = val;
	SET2_MES(tmp_val0, tmp_val1)
	if (ask)
	recover = read_yn();
	if (recover) {
	ub->numfile[1] = tmp_val1;
	ub->numfile[0] = tmp_val0;
	changed++;
	}
	}
	if (!recover) ret = 1;
	// if (!ask) fprintf(stderr, "\n");
	}

	return ret;
	}

	int vps_validate(vps_res *param, int mode)
	{
	int ret;

	if (mode == ACT_NONE)
	return 0;
	logger(0, 0, "Validating VE:");
	ret = validate(param, mode == ACT_FIX, 0);
	if (mode == ACT_ERROR && ret)
	return VZ_VALIDATE_ERROR;
	return 0;
	}

	int calc_ve_utilization(struct ub_struct param, struct CRusage rusage,
	struct mem_struct *mem, int numerator)
	{
	double kmem_net;

	memset(rusage, 0, sizeof(struct CRusage));
	if (param == NULL)
	return -1;
	if (check_param(param, 1))
	return -1;
	kmem_net = (double)param->kmemsize[0] +
	(double)param->tcprcvbuf[0] +
	(double)param->tcpsndbuf[0] +
	(double)param->dgramrcvbuf[0] +
	(double)param->othersockbuf[0];
	/* Low memory */
	rusage->low_mem = kmem_net;
	if (!numerator)
	rusage->low_mem /= mem->lowmem;
	/* Total RAM */
	rusage->total_ram = ((double)param->physpages[0] * page_size +
	kmem_net);
	if (!numerator)
	rusage->total_ram /= mem->ram;
	/* Mem + Swap */
	rusage->mem_swap = ((double)param->oomguarpages[0] * page_size +
	kmem_net);
	if (!numerator)
	rusage->mem_swap /= (mem->ram + mem->swap);
	/* Allocated memory */
	rusage->alloc_mem = ((double)param->privvmpages[0] * page_size +
	kmem_net);
	if (!numerator)
	rusage->alloc_mem /= (mem->ram + mem->swap);

	return 0;
	}

	int calc_ve_commitment(struct ub_struct param, struct CRusage rusage,
	struct mem_struct *mem, int numerator)
	{
	double kmem_net;

	memset(rusage, 0, sizeof(struct CRusage));
	if (param == NULL)
	return -1;
	if (check_param(param, 1))
	return -1;
	kmem_net = (double)param->kmemsize[1] +
	(double)param->tcprcvbuf[1] +
	(double)param->tcpsndbuf[1] +
	(double)param->dgramrcvbuf[1] +
	(double)param->othersockbuf[1];
	/* Low memory */
	rusage->low_mem = kmem_net;
	if (!numerator)
	rusage->low_mem /= mem->lowmem;
	/* Total RAM */
	rusage->total_ram = ((double)param->physpages[0] * page_size +
	kmem_net);
	if (!numerator)
	rusage->total_ram /= mem->ram;
	/* Mem + Swap */
	rusage->mem_swap = ((double)param->oomguarpages[0] * page_size +
	kmem_net);
	if (!numerator)
	rusage->mem_swap /= (mem->ram + mem->swap);
	/* Allocated memory */
	rusage->alloc_mem = ((double)param->vmguarpages[0] * page_size +
	kmem_net);
	if (!numerator)
	rusage->alloc_mem /= (mem->ram + mem->swap);
	/* Allocated memory limit */
	rusage->alloc_mem_lim = ((double)param->privvmpages[1] * page_size +
	kmem_net);
	if (!numerator)
	rusage->alloc_mem_lim /= (mem->ram + mem->swap);
	/* Max Allocated memory limit */
	rusage->alloc_mem_max_lim = ((double)param->privvmpages[1] * page_size +
	kmem_net);
	if (!numerator)
	rusage->alloc_mem_max_lim /= mem->ram;
	return 0;
	}

	void inc_rusage(struct CRusage rusagetotal, struct CRusage rusage)
	{
	if (rusagetotal == NULL \|\| rusage == NULL)
	return;
	rusagetotal->low_mem += rusage->low_mem;
	rusagetotal->total_ram += rusage->total_ram;
	rusagetotal->mem_swap += rusage->mem_swap;
	rusagetotal->alloc_mem += rusage->alloc_mem;
	rusagetotal->alloc_mem_lim += rusage->alloc_mem_lim;
	if (rusage->alloc_mem_max_lim > rusagetotal->alloc_mem_max_lim)
	rusagetotal->alloc_mem_max_lim = rusage->alloc_mem_max_lim;
	}

	void mul_rusage(struct CRusage *rusage, int k)
	{
	if (rusage == NULL)
	return;
	rusage->low_mem *= k;
	rusage->total_ram *= k;
	rusage->mem_swap *= k;
	rusage->alloc_mem *= k;
	rusage->alloc_mem_lim *= k;
	rusage->alloc_mem_max_lim *= k;
	}

	void shift_ubs_param(struct ub_struct *param)
	{
	#define SHIFTPARAM(name) \
	if (param->name != NULL) { \
	param->name[0] = param->name[1]; \
	param->name[1] = param->name[2]; \
	}
	SHIFTPARAM(numproc);
	SHIFTPARAM(numtcpsock);
	SHIFTPARAM(numothersock);
	SHIFTPARAM(oomguarpages)
	SHIFTPARAM(vmguarpages);
	SHIFTPARAM(kmemsize);
	SHIFTPARAM(tcpsndbuf);
	SHIFTPARAM(tcprcvbuf);
	SHIFTPARAM(othersockbuf);
	SHIFTPARAM(dgramrcvbuf);
	SHIFTPARAM(privvmpages);
	SHIFTPARAM(numfile);
	SHIFTPARAM(dcachesize);
	SHIFTPARAM(physpages)
	SHIFTPARAM(numpty)
	}

	int calc_hn_rusage(struct CRusage ru_comm, struct CRusage ru_utl)
	{
	FILE *fd;
	struct CRusage utl, comm;
	char str[STR_SIZE];
	char name[STR_SIZE];
	const char *fmt;
	unsigned long held, maxheld, barrier, limit;
	int found = 0;
	int id, res;
	int veid = 0;
	ub_param ub;
	struct ub_struct ub_s;
	struct mem_struct mem;

	if ((fd = fopen(PROCUBC, "r")) == NULL) {
	logger(-1, errno, "Unable open " PROCUBC);
	return -1;
	}
	if (ru_comm != NULL)
	memset(ru_comm, 0, sizeof(*ru_comm));
	if (ru_utl != NULL)
	memset(ru_utl, 0, sizeof(*ru_utl));
	memset(&ub, 0, sizeof(ub));
	memset(&ub_s, 0, sizeof(ub_s));
	while (fgets(str, sizeof(str), fd)) {
	if ((res = sscanf(str, "%d:", &id)) == 1) {
	fmt = "%*lu:%s%lu%lu%lu%lu";
	found = 1;
	if (veid) {
	if (ru_utl != NULL) {
	calc_ve_utilization(&ub_s, &utl, &mem, 0);
	inc_rusage(ru_utl, &utl);
	}
	if (ru_comm != NULL) {
	shift_ubs_param(&ub_s);
	calc_ve_commitment(&ub_s, &comm, &mem, 0);
	inc_rusage(ru_comm, &comm);
	}
	}
	veid = id;
	free_ub_param(&ub_s);
	} else {
	fmt = "%s%lu%lu%lu%lu";
	}
	if (found) {
	if ((res = sscanf(str, fmt, name, &held, &maxheld,
	&barrier, &limit)) != 5)
	{
	continue;
	}
	if ((res = get_ub_resid(name)) >= 0) {
	unsigned long *par;
	par = malloc(sizeof(par) 3);
	par[0] = held;
	par[1] = barrier;
	par[2] = limit;
	add_ub_limit(&ub_s, res, par);
	}
	}
	}
	/* Last VE in /proc/user_beancounters */
	if (veid) {
	if (ru_utl != NULL) {
	calc_ve_utilization(&ub_s, &utl, &mem, 0);
	inc_rusage(ru_utl, &utl);
	}
	if (ru_comm != NULL) {
	shift_ubs_param(&ub_s);
	calc_ve_commitment(&ub_s, &comm, &mem, 0);
	inc_rusage(ru_comm, &comm);
	}
	free_ub_param(&ub_s);
	}
	fclose(fd);
	return 0;
	}

	int check_hn_overcommitment(int veid, struct ub_struct *param,
	struct ovrc *ovrc)
	{
	struct CRusage ru_comm;
	struct CRusage rusage_ve;
	int actid;
	int ret = 0;
	struct mem_struct mem;

	if (param == NULL)
	return 0;
	actid = ovrc->action;
	if (ovrc->action == ACT_NONE)
	return 0;
	memset(&ru_comm, 0, sizeof(ru_comm));
	/* Calculate current HN overcommitment */
	if (calc_hn_rusage(&ru_comm, NULL))
	return 0;
	/* Add VE resource usage */
	calc_ve_commitment(param, &rusage_ve, &mem, 0);
	inc_rusage(&ru_comm, &rusage_ve);
	/* Convert to % */
	mul_rusage(&ru_comm, 100);
	if (ovrc->level_low_mem != NULL &&
	ru_comm.low_mem > *ovrc->level_low_mem)
	{
	logger(0, 0, "%s: node is overcommited.",
	actid == ACT_ERROR ? "Error" : "Warning");
	logger(0, 0, "\tLow Memory commitment level (%.3f%%)"
	" exceeds configured (%.3f%%)",
	ru_comm.low_mem, *ovrc->level_low_mem);
	ret = 1;
	}
	if (ovrc->level_mem_swap != NULL &&
	ru_comm.mem_swap > *ovrc->level_mem_swap)
	{
	if (!ret)
	logger(0, 0, "%s: node is overcommited.",
	actid == ACT_ERROR ? "Error" : "Warning");
	logger(0, 0, "\tMemory and Swap commitment level (%.3f%%)"
	" exceeds configured (%.3f%%)",
	ru_comm.mem_swap, *ovrc->level_mem_swap);
	ret = 1;
	}
	if (ovrc->level_alloc_mem != NULL &&
	ru_comm.alloc_mem > *ovrc->level_alloc_mem)
	{
	if (!ret)
	logger(0, 0, "%s: node is overcommited.",
	actid == ACT_ERROR ? "Error" : "Warning");
	logger(0, 0, "\tAllocated Memory commitment level (%.3f%%)"
	" exceeds configured (%.3f%%)",
	ru_comm.alloc_mem, *ovrc->level_alloc_mem);
	ret = 1;
	}
	if (ovrc->level_alloc_mem_lim != NULL &&
	ru_comm.alloc_mem_lim > *ovrc->level_alloc_mem_lim)
	{
	if (!ret)
	logger(0, 0, "%s: node is overcommited.",
	actid == ACT_ERROR ? "Error" : "Warning");
	logger(0, 0, "\tTotal Alloc Limit commitment level (%.3f%%)"
	" exceeds configured (%.3f%%)",
	ru_comm.alloc_mem_lim,
	*ovrc->level_alloc_mem_lim);
	ret = 1;
	}
	return actid == ACT_ERROR ? VZ_OVERCOMMIT_ERROR : 0;
	}