| /* |
| * Copyright (C) 2000-2010, Parallels, Inc. 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 |
| */ |
| #ifndef _GNU_SOURCE |
| #define _GNU_SOURCE |
| #endif |
| #include <stdlib.h> |
| #include <string.h> |
| #include <ctype.h> |
| #include <stdio.h> |
| #include <errno.h> |
| #include <sys/socket.h> |
| #include <netinet/in.h> |
| #include <arpa/inet.h> |
| #include <getopt.h> |
| #include <sys/types.h> |
| #include <sys/stat.h> |
| #include <linux/vzcalluser.h> |
| #include <unistd.h> |
| #include <fcntl.h> |
| #include <limits.h> |
| |
| #include "logger.h" |
| #include "list.h" |
| #include "bitmap.h" |
| #include "config.h" |
| #include "vzctl_param.h" |
| #include "vzerror.h" |
| #include "util.h" |
| #include "ub.h" |
| #include "vzctl.h" |
| #include "res.h" |
| #include "iptables.h" |
| #include "meminfo.h" |
| #include "vzfeatures.h" |
| #include "io.h" |
| |
| static int _page_size; |
| static int check_name(char *name); |
| |
| static vps_config config[] = { |
| /* Op */ |
| {"LOCKDIR", NULL, PARAM_LOCKDIR}, |
| {"DUMPDIR", NULL, PARAM_DUMPDIR}, |
| /* Log */ |
| {"LOGGING", NULL, PARAM_LOGGING}, |
| {"LOG_LEVEL", NULL, PARAM_LOGLEVEL}, |
| {"LOGFILE", NULL, PARAM_LOGFILE}, |
| {"VERBOSE", NULL, PARAM_VERBOSE}, |
| |
| {"IPTABLES", NULL, PARAM_IPTABLES}, |
| /* UB */ |
| {"KMEMSIZE", NULL, PARAM_KMEMSIZE}, |
| {"LOCKEDPAGES", NULL, PARAM_LOCKEDPAGES}, |
| {"PRIVVMPAGES", NULL, PARAM_PRIVVMPAGES}, |
| {"SHMPAGES", NULL, PARAM_SHMPAGES}, |
| {"NUMPROC", NULL, PARAM_NUMPROC}, |
| {"PHYSPAGES", NULL, PARAM_PHYSPAGES}, |
| {"VMGUARPAGES", NULL, PARAM_VMGUARPAGES}, |
| {"OOMGUARPAGES",NULL, PARAM_OOMGUARPAGES}, |
| {"NUMTCPSOCK", NULL, PARAM_NUMTCPSOCK}, |
| {"NUMFLOCK", NULL, PARAM_NUMFLOCK}, |
| {"NUMPTY", NULL, PARAM_NUMPTY}, |
| {"NUMSIGINFO", NULL, PARAM_NUMSIGINFO}, |
| {"TCPSNDBUF", NULL, PARAM_TCPSNDBUF}, |
| {"TCPRCVBUF", NULL, PARAM_TCPRCVBUF}, |
| {"OTHERSOCKBUF",NULL, PARAM_OTHERSOCKBUF}, |
| {"DGRAMRCVBUF", NULL, PARAM_DGRAMRCVBUF}, |
| {"NUMOTHERSOCK",NULL, PARAM_NUMOTHERSOCK}, |
| {"NUMFILE", NULL, PARAM_NUMFILE}, |
| {"DCACHESIZE", NULL, PARAM_DCACHESIZE}, |
| {"DCACHE", "DCACHESIZE", -1}, |
| {"NUMIPTENT", NULL, PARAM_NUMIPTENT}, |
| {"IPTENTRIES", "NUMIPTENT", -1}, |
| {"AVNUMPROC", NULL, PARAM_AVNUMPROC}, |
| {"SWAPPAGES", NULL, PARAM_SWAPPAGES}, |
| /* Capability */ |
| {"CAPABILITY", NULL, PARAM_CAP}, |
| /* Network */ |
| {"IP_ADDRESS", NULL, PARAM_IP_ADD}, |
| {"", NULL, PARAM_IP_DEL}, |
| {"NETDEV", NULL, PARAM_NETDEV_ADD}, |
| {"", NULL, PARAM_NETDEV_DEL}, |
| {"HOSTNAME", NULL, PARAM_HOSTNAME}, |
| {"DESCRIPTION", NULL, PARAM_DESCRIPTION}, |
| {"NAMESERVER", NULL, PARAM_NAMESERVER}, |
| {"IPV6", NULL, PARAM_IPV6NET}, |
| {"SEARCHDOMAIN",NULL, PARAM_SEARCHDOMAIN}, |
| {"", NULL, PARAM_USERPW}, |
| /* Devices */ |
| {"DEVICES", NULL, PARAM_DEVICES}, |
| {"DEVNODES", NULL, PARAM_DEVNODES}, |
| {"PCI", NULL, PARAM_PCI_ADD}, |
| {"", NULL, PARAM_PCI_DEL}, |
| /* fs param */ |
| {"VE_ROOT", NULL, PARAM_ROOT}, |
| {"VE_PRIVATE", NULL, PARAM_PRIVATE}, |
| {"TEMPLATE", NULL, PARAM_TEMPLATE}, |
| {"NOATIME", NULL, PARAM_NOATIME}, |
| /* template */ |
| {"OSTEMPLATE", NULL, PARAM_OSTEMPLATE}, |
| {"DEF_OSTEMPLATE", NULL, PARAM_DEF_OSTEMPLATE}, |
| /* CPU */ |
| {"CPUUNITS", NULL, PARAM_CPUUNITS}, |
| {"CPUUWEIGHT", NULL, PARAM_CPUWEIGHT}, |
| {"CPULIMIT", NULL, PARAM_CPULIMIT}, |
| {"CPUS", NULL, PARAM_VCPUS}, |
| {"CPUMASK", NULL, PARAM_CPUMASK}, |
| /* create param */ |
| {"ONBOOT", NULL, PARAM_ONBOOT}, |
| {"CONFIGFILE", NULL, PARAM_CONFIG}, |
| {"ORIGIN_SAMPLE",NULL,PARAM_CONFIG_SAMPLE}, |
| {"DISABLED", NULL, PARAM_DISABLED}, |
| /* quota */ |
| {"DISK_QUOTA", NULL, PARAM_DISK_QUOTA}, |
| {"DISKSPACE", NULL, PARAM_DISKSPACE}, |
| {"DISKINODES", NULL, PARAM_DISKINODES}, |
| {"QUOTATIME", NULL, PARAM_QUOTATIME}, |
| {"QUOTAUGIDLIMIT",NULL, PARAM_QUOTAUGIDLIMIT}, |
| {"MEMINFO", NULL, PARAM_MEMINFO}, |
| {"VETH", NULL, PARAM_VETH_ADD}, |
| {"NETIF", NULL, PARAM_NETIF_ADD}, |
| {"VEID", NULL, PARAM_VEID}, |
| {"NAME", NULL, PARAM_NAME}, |
| |
| {"FEATURES", NULL, PARAM_FEATURES}, |
| {"IOPRIO", NULL, PARAM_IOPRIO}, |
| {"BOOTORDER", NULL, PARAM_BOOTORDER}, |
| |
| {NULL, NULL, -1} |
| }; |
| |
| static const vps_config *conf_get_by_name(const vps_config *conf, |
| const char *name) |
| { |
| const vps_config *p; |
| |
| if (conf == NULL) |
| return NULL; |
| for (p = conf; p->name != NULL; p++) { |
| if (!strcmp(p->name, name)) { |
| if (p->alias != NULL) |
| return conf_get_by_name(conf, p->alias); |
| return p; |
| } |
| } |
| return NULL; |
| } |
| |
| static const vps_config *conf_get_by_id(const vps_config *conf, int id) |
| { |
| const vps_config *p; |
| |
| if (conf == NULL) |
| return NULL; |
| for (p = conf; p->name != NULL; p++) |
| if (p->id == id) |
| return p; |
| return NULL; |
| } |
| |
| static int opt_get_by_id(struct option *opt, int id) |
| { |
| struct option *p; |
| |
| for (p = opt; p->name != NULL; p++) |
| if (p->val == id) |
| return p->val; |
| return -1; |
| } |
| |
| static conf_struct *find_conf_line(list_head_t *head, char *name, |
| char delim) |
| { |
| conf_struct *conf; |
| char *p; |
| int len; |
| |
| len = strlen(name); |
| list_for_each(conf, head, list) { |
| if (strncmp(conf->val, name, len)) |
| continue; |
| p = conf->val + len; |
| if (*p == delim) |
| return conf; |
| } |
| return NULL; |
| } |
| |
| static int parse_setmode(vps_param *vps_p, const char *val) |
| { |
| if (!strcmp(val, "ignore")) |
| vps_p->opt.setmode = SET_IGNORE; |
| else if (!strcmp(val, "restart")) |
| vps_p->opt.setmode = SET_RESTART; |
| else |
| return ERR_INVAL; |
| return 0; |
| } |
| |
| static int conf_parse_strlist(list_head_t *list, const char *val) |
| { |
| if (add_str2list(list, val)) |
| return ERR_NOMEM; |
| return 0; |
| } |
| |
| static int conf_parse_str(char **dst, const char *val) |
| { |
| if (*dst) |
| return ERR_DUP; |
| *dst = strdup(val); |
| if (*dst == NULL) |
| return ERR_NOMEM; |
| return 0; |
| } |
| |
| static int conf_parse_yesno(int *dst, const char *val) |
| { |
| int ret; |
| |
| if (*dst) |
| return ERR_DUP; |
| if ((ret = yesno2id(val)) < 0) |
| return ERR_INVAL; |
| *dst = ret; |
| return 0; |
| } |
| |
| static int conf_parse_ulong(unsigned long **dst, const char *valstr) |
| { |
| unsigned long val; |
| if (*dst != NULL) |
| return ERR_DUP; |
| if (parse_ul(valstr, &val) != 0) |
| return ERR_INVAL; |
| *dst = malloc(sizeof(unsigned long)); |
| if (*dst == NULL) |
| return ERR_NOMEM; |
| **dst = val; |
| return 0; |
| } |
| |
| static int conf_parse_bitmap(unsigned long **dst, int nmaskbits, |
| const char *valstr) |
| { |
| if (*dst != NULL) |
| return ERR_DUP; |
| |
| *dst = alloc_bitmap(nmaskbits); |
| if (*dst == NULL) |
| return ERR_NOMEM; |
| |
| if (!strcmp(valstr, "all")) { |
| bitmap_set_all(*dst, nmaskbits); |
| return 0; |
| } |
| if (bitmap_parse(valstr, *dst, nmaskbits) != 0) { |
| free(*dst); |
| *dst = NULL; |
| return ERR_INVAL; |
| } |
| return 0; |
| } |
| |
| static int conf_store_strlist(list_head_t *conf, char *name, list_head_t *val, |
| int allow_empty) |
| { |
| char *str; |
| |
| if (list_empty(val) && !allow_empty) |
| return 0; |
| if ((str = list2str_c(name, '"', val)) == NULL) |
| return ERR_NOMEM;; |
| if (add_str_param2(conf, str)) { |
| free(str); |
| return ERR_NOMEM; |
| } |
| return 0; |
| } |
| |
| static int conf_store_str(list_head_t *conf, char *name, const char *val) |
| { |
| char *buf; |
| int len; |
| |
| if (val == NULL) |
| return 0; |
| len = strlen(name) + strlen(val) + 3; |
| buf = malloc(len + 1); |
| if (buf == NULL) |
| return ERR_NOMEM; |
| sprintf(buf, "%s=\"%s\"", name, val); |
| if (add_str_param2(conf, buf)) |
| return ERR_NOMEM; |
| return 0; |
| } |
| |
| static int conf_store_yesno(list_head_t *conf, char *name, int val) |
| { |
| if (!val) |
| return 0; |
| return conf_store_str(conf, name, val == YES ? "yes" : "no"); |
| } |
| |
| static int conf_store_ulong(list_head_t *conf, char *name, unsigned long *val) |
| { |
| char buf[] = "18446744073709551615"; /* ULONG_MAX on 64 bit */ |
| |
| if (val == NULL) |
| return 0; |
| |
| snprintf(buf, sizeof(buf), "%lu", *val); |
| return conf_store_str(conf, name, buf); |
| } |
| |
| static int conf_store_bitmap(list_head_t *conf, char *name, |
| unsigned long *val, int nmaskbits) |
| { |
| int ret; |
| char *buf; |
| unsigned int buflen = nmaskbits * 2; |
| |
| if (val == NULL) |
| return 0; |
| |
| if (bitmap_find_first_zero_bit(val, nmaskbits) == nmaskbits) { |
| conf_store_str(conf, name, "all"); |
| return 0; |
| } |
| |
| buf = malloc(buflen); |
| if (buf == NULL) |
| return ERR_NOMEM; |
| |
| bitmap_snprintf(buf, buflen, val, nmaskbits); |
| ret = conf_store_str(conf, name, buf); |
| |
| free(buf); |
| return ret; |
| } |
| |
| /******************** Features *************************/ |
| static int parse_features(env_param_t *env, char *val) |
| { |
| int ret = 0; |
| char *token; |
| struct feature_s *feat; |
| |
| for_each_strtok(token, val, "\t ") { |
| feat = find_feature(token); |
| if (!feat) { |
| logger(0, 0, "Warning: Unknown feature: %s", token); |
| ret = ERR_INVAL_SKIP; |
| continue; |
| } |
| if (feat->on) |
| env->features_mask |= feat->mask; |
| env->features_known |= feat->mask; |
| } |
| |
| return ret; |
| } |
| |
| static void store_features(unsigned long long mask, unsigned long long known, |
| vps_config *conf, list_head_t *conf_h) |
| { |
| char buf[2 * STR_SIZE]; |
| int r; |
| |
| r = snprintf(buf, sizeof(buf) - 1, "%s=\"", conf->name); |
| features_mask2str(mask, known, buf + r, sizeof(buf) - r - 2); |
| strcat(buf, "\""); |
| add_str_param(conf_h, buf); |
| } |
| |
| static int parse_ioprio(int id, io_param *io, char *val) |
| { |
| if (parse_int(val, &io->ioprio)) |
| return ERR_INVAL; |
| if (io->ioprio < VE_IOPRIO_MIN || io->ioprio > VE_IOPRIO_MAX) { |
| io->ioprio = -1; |
| return ERR_INVAL; |
| } |
| return 0; |
| } |
| |
| static int store_ioprio(vps_param *old_p, vps_param *vps_p, |
| vps_config *conf, list_head_t *conf_h) |
| { |
| io_param *io_param; |
| char buf[20]; |
| |
| io_param = &vps_p->res.io; |
| |
| if (conf->id != PARAM_IOPRIO || io_param->ioprio < 0) |
| return 0; |
| |
| snprintf(buf, sizeof(buf), "%s=\"%d\"", conf->name, io_param->ioprio); |
| add_str_param(conf_h, buf); |
| |
| return 0; |
| } |
| |
| /******************** Iptables *************************/ |
| static int parse_iptables(env_param_t *env, char *val) |
| { |
| char *token; |
| struct iptables_s *ipt; |
| int ret = 0; |
| |
| for_each_strtok(token, val, "\t ") { |
| ipt = find_ipt(token); |
| if (!ipt) { |
| logger(-1, 0, "Warning: Unknown iptable module: %s," |
| " skipped", token); |
| ret = ERR_INVAL_SKIP; |
| continue; |
| } |
| env->ipt_mask |= ipt->mask; |
| } |
| |
| return ret; |
| } |
| |
| static void store_iptables(unsigned long long ipt_mask, vps_config *conf, |
| list_head_t *conf_h) |
| { |
| char buf[STR_SIZE]; |
| int r; |
| |
| r = snprintf(buf, sizeof(buf), "%s=\"", conf->name); |
| ipt_mask2str(ipt_mask, buf + r, sizeof(buf) - r - 1); |
| strcat(buf, "\""); |
| add_str_param(conf_h, buf); |
| } |
| |
| static int store_env(vps_param *old_p, vps_param *vps_p, vps_config *conf, |
| list_head_t *conf_h) |
| { |
| env_param_t *env = &vps_p->res.env; |
| |
| switch (conf->id) { |
| case PARAM_IPTABLES: |
| if (!env->ipt_mask) |
| break; |
| store_iptables(env->ipt_mask, conf, conf_h); |
| break; |
| case PARAM_FEATURES: |
| if (!env->features_known) |
| break; |
| store_features((env->features_mask & env->features_known) | |
| (old_p->res.env.features_mask & ~env->features_known), |
| old_p->res.env.features_known | env->features_known, |
| conf, conf_h); |
| break; |
| } |
| return 0; |
| } |
| |
| /********************** UB **************************************/ |
| static int get_mul(char c) |
| { |
| switch (c) { |
| case 'G': |
| case 'g': |
| return 1024 * 1024 * 1024; |
| case 'M': |
| case 'm': |
| return 1024 * 1024; |
| case 'K': |
| case 'k': |
| return 1024; |
| case 'P': |
| case 'p': |
| return _page_size; |
| case 'B': |
| case 'b': |
| return 1; |
| } |
| return -1; |
| } |
| |
| /* This function parses string in form xxx[GMKPB] |
| */ |
| static const char *parse_ul_sfx(const char *str, unsigned long long *val, int divisor) |
| { |
| int n; |
| char *tail; |
| |
| if (!str || !val) |
| return NULL; |
| if (!strncmp(str, "unlimited", 9)) { |
| *val = LONG_MAX; |
| return str + 9; |
| } |
| errno = 0; |
| *val = strtoull(str, &tail, 10); |
| if (errno == ERANGE) |
| return NULL; |
| if (*tail != ':' && *tail != '\0') { |
| if (!divisor) |
| return NULL; |
| if ((n = get_mul(*tail)) < 0) |
| return NULL; |
| *val = (*val) * n / divisor; |
| ++tail; |
| } |
| return tail; |
| } |
| |
| /* This function parses string in form xxx[GMKPB]:yyy[GMKPB] |
| * If :yyy is omitted, it is set to xxx. |
| */ |
| static int parse_twoul_sfx(const char *str, unsigned long *val, int divisor) |
| { |
| unsigned long long tmp; |
| int ret = 0; |
| |
| if (!(str = parse_ul_sfx(str, &tmp, divisor))) |
| return ERR_INVAL; |
| if (tmp > LONG_MAX) { |
| tmp = LONG_MAX; |
| ret = ERR_LONG_TRUNC; |
| } |
| val[0] = tmp; |
| if (*str == ':') { |
| str = parse_ul_sfx(++str, &tmp, divisor); |
| if (!str || *str != '\0') |
| return ERR_INVAL; |
| if (tmp > LONG_MAX) { |
| tmp = LONG_MAX; |
| ret = ERR_LONG_TRUNC; |
| } |
| val[1] = tmp; |
| } else if (*str == '\0') { |
| val[1] = val[0]; |
| } else |
| return ERR_INVAL; |
| return ret; |
| } |
| |
| /******************** totalmem *************************/ |
| static int parse_meminfo(meminfo_param *param, const char *val) |
| { |
| int mode; |
| char mode_nm[32]; |
| unsigned long meminfo_val; |
| int ret; |
| |
| if (*val == 0) |
| return 0; |
| meminfo_val = 0; |
| ret = sscanf(val, "%31[^:]:%lu", mode_nm, &meminfo_val); |
| if (ret != 2 && ret != 1) |
| return ERR_INVAL; |
| if ((mode = get_meminfo_mode(mode_nm)) < 0) |
| return ERR_INVAL; |
| if ((mode != VE_MEMINFO_NONE && ret !=2) || |
| (mode == VE_MEMINFO_NONE && ret == 2)) |
| return ERR_INVAL; |
| if((mode != VE_MEMINFO_NONE) && meminfo_val == 0) |
| return ERR_INVAL; |
| param->mode = mode; |
| param->val = meminfo_val; |
| |
| return 0; |
| } |
| |
| static int store_meminfo(vps_param *old_p, vps_param *vps_p, vps_config *conf, |
| list_head_t *conf_h) |
| { |
| char buf[64]; |
| const char *mode_nm; |
| meminfo_param *meminfo = &vps_p->res.meminfo; |
| |
| if (conf->id != PARAM_MEMINFO || meminfo->mode < 0) |
| return 0; |
| mode_nm = get_meminfo_mode_nm(meminfo->mode); |
| if (mode_nm == NULL) |
| return 0; |
| if (meminfo->mode == VE_MEMINFO_NONE) { |
| snprintf(buf, sizeof(buf), "%s=\"%s\"", |
| conf->name, mode_nm); |
| } else { |
| snprintf(buf, sizeof(buf), "%s=\"%s:%lu\"", |
| conf->name, mode_nm, meminfo->val); |
| } |
| add_str_param(conf_h, buf); |
| return 0; |
| } |
| |
| static int parse_ub(vps_param *vps_p, const char *val, int id, int divisor) |
| { |
| int ret; |
| ub_res res; |
| const vps_config *conf; |
| |
| if ((conf = conf_get_by_id(config, id)) == NULL) |
| return ERR_INVAL; |
| ret = parse_twoul_sfx(val, res.limit, divisor); |
| if (ret && ret != ERR_LONG_TRUNC) |
| return ret; |
| res.res_id = id; |
| if (add_ub_param(&vps_p->res.ub, &res)) |
| return ERR_NOMEM; |
| return ret; |
| } |
| |
| static int store_ub(vps_param *old_p, vps_param *vps_p, |
| list_head_t *conf_h) |
| { |
| const vps_config *conf; |
| ub_param *ub = &vps_p->res.ub; |
| char buf[128]; |
| |
| #define ADD_UB_PARAM(res, id) \ |
| if (ub->res != NULL) { \ |
| conf = conf_get_by_id(config, id); \ |
| snprintf(buf, sizeof(buf), "%s=\"%lu:%lu\"", conf->name, \ |
| ub->res[0], ub->res[1]); \ |
| if (add_str_param(conf_h, buf)) \ |
| return ERR_NOMEM; \ |
| } |
| |
| ADD_UB_PARAM(kmemsize, PARAM_KMEMSIZE) |
| ADD_UB_PARAM(lockedpages, PARAM_LOCKEDPAGES) |
| ADD_UB_PARAM(privvmpages, PARAM_PRIVVMPAGES) |
| ADD_UB_PARAM(shmpages, PARAM_SHMPAGES) |
| ADD_UB_PARAM(numproc, PARAM_NUMPROC) |
| ADD_UB_PARAM(physpages, PARAM_PHYSPAGES) |
| ADD_UB_PARAM(vmguarpages, PARAM_VMGUARPAGES) |
| ADD_UB_PARAM(oomguarpages, PARAM_OOMGUARPAGES) |
| ADD_UB_PARAM(numtcpsock, PARAM_NUMTCPSOCK) |
| ADD_UB_PARAM(numflock, PARAM_NUMFLOCK) |
| ADD_UB_PARAM(numpty, PARAM_NUMPTY) |
| ADD_UB_PARAM(numsiginfo, PARAM_NUMSIGINFO) |
| ADD_UB_PARAM(tcpsndbuf, PARAM_TCPSNDBUF) |
| ADD_UB_PARAM(tcprcvbuf, PARAM_TCPRCVBUF) |
| ADD_UB_PARAM(othersockbuf, PARAM_OTHERSOCKBUF) |
| ADD_UB_PARAM(dgramrcvbuf, PARAM_DGRAMRCVBUF) |
| ADD_UB_PARAM(numothersock, PARAM_NUMOTHERSOCK) |
| ADD_UB_PARAM(numfile, PARAM_NUMFILE) |
| ADD_UB_PARAM(dcachesize, PARAM_DCACHESIZE) |
| ADD_UB_PARAM(numiptent, PARAM_NUMIPTENT) |
| ADD_UB_PARAM(avnumproc, PARAM_AVNUMPROC) |
| ADD_UB_PARAM(swappages, PARAM_SWAPPAGES) |
| #undef ADD_UB_PARAM |
| |
| return 0; |
| } |
| |
| /********************** Capability ********************/ |
| |
| static int parse_cap(char *str, cap_param *cap) |
| { |
| unsigned int len; |
| char *p, *token; |
| char cap_nm[128]; |
| unsigned long *mask; |
| |
| for_each_strtok(token, str, "\t ") { |
| if ((p = strrchr(token, ':')) == NULL) { |
| logger(-1, 0, "Invalid syntaxes in %s:" |
| " capname:on|off", token); |
| return ERR_INVAL; |
| } |
| if (!strcmp(p + 1, "off")) |
| mask = &cap->off; |
| else if (!strcmp(p + 1, "on")) |
| mask = &cap->on; |
| else { |
| logger(-1, 0, "Invalid syntaxes in %s:" |
| " capname:on|off", token); |
| return ERR_INVAL; |
| } |
| len = p - token; |
| strncpy(cap_nm, token, |
| len < sizeof(cap_nm) ? len : sizeof(cap_nm)); |
| cap_nm[len] = 0; |
| if (get_cap_mask(cap_nm, mask)) { |
| logger(-1, 0, "Capability %s is unknown", cap_nm); |
| return ERR_INVAL; |
| } |
| } |
| |
| return 0; |
| } |
| |
| static int store_cap(vps_param *old_p, vps_param *vps_p, vps_config *conf, |
| list_head_t *conf_h) |
| { |
| char buf[STR_SIZE]; |
| char *p; |
| int len; |
| cap_param *cap = &vps_p->res.cap; |
| |
| if (conf->id != PARAM_CAP) |
| return 0; |
| if (!cap->on && !cap->off) |
| return 0; |
| p = buf; |
| p += sprintf(buf, "%s=", conf->name); |
| len = buf + sizeof(buf) - p - 1; |
| build_cap_str(cap, &old_p->res.cap, p, len); |
| add_str_param(conf_h, buf); |
| |
| return 0; |
| } |
| /********************** Network ************************/ |
| |
| static int check_ip_dot(char *ip) |
| { |
| int i; |
| char *str = ip; |
| char *p; |
| |
| for (i = 0; i < 5; i++) { |
| if ((p = strchr(str, '.')) == NULL) |
| break; |
| str = p + 1; |
| } |
| if (i != 3) |
| return VZ_BADIP; |
| return 0; |
| } |
| |
| static int parse_ip(vps_param *vps_p, char *val, int id) |
| { |
| char *token; |
| char dst[INET6_ADDRSTRLEN]; |
| unsigned char ip[sizeof(struct in6_addr)]; |
| int family; |
| net_param *net; |
| |
| if (id == PARAM_IP_ADD) |
| net = &vps_p->res.net; |
| else if (id == PARAM_IP_DEL) |
| net = &vps_p->del_res.net; |
| else |
| return 0; |
| |
| for_each_strtok(token, val, "\t ") { |
| if (id == PARAM_IP_DEL && !strcmp(token, "all")) { |
| vps_p->res.net.delall = YES; |
| vps_p->del_res.net.delall = YES; |
| continue; |
| } |
| if (!strcmp(token, "0.0.0.0")) |
| continue; |
| if (!strcmp(token, "::")) |
| continue; |
| if (!strcmp(token, "::0")) |
| continue; |
| if (!strchr(token, ':')) { |
| if (check_ip_dot(token)) |
| return ERR_INVAL; |
| } |
| if ((family = get_netaddr(token, ip)) < 0) |
| return ERR_INVAL; |
| if (inet_ntop(family, ip, dst, sizeof(dst)) == NULL) |
| return ERR_INVAL; |
| if (!find_ip(&net->ip, dst)) |
| add_str_param(&net->ip, dst); |
| } |
| |
| return 0; |
| } |
| |
| static int store_ip(vps_param *old_p, vps_param *vps_p, vps_config *conf, |
| list_head_t *conf_h) |
| { |
| list_head_t ip; |
| int ret; |
| |
| list_head_init(&ip); |
| if (conf->id != PARAM_IP_ADD) |
| return 0; |
| if (!vps_p->res.net.delall && |
| list_empty(&vps_p->res.net.ip) && |
| list_empty(&vps_p->del_res.net.ip)) |
| { |
| return 0; |
| } |
| merge_str_list(vps_p->res.net.delall, &old_p->res.net.ip, |
| &vps_p->res.net.ip, &vps_p->del_res.net.ip, &ip); |
| ret = conf_store_strlist(conf_h, conf->name, &ip, 1); |
| free_str_param(&ip); |
| |
| return ret; |
| } |
| |
| static int check_netdev(const char *devname) |
| { |
| int i, len; |
| const char *name; |
| static char *netdev_strict[] = {"venet", "tun", "tap", "lo", NULL}; |
| |
| for (i = 0; netdev_strict[i] != NULL; i++) { |
| name = netdev_strict[i]; |
| len = strlen(name); |
| if (!strncmp(name, devname, len)) |
| return 1; |
| } |
| return 0; |
| } |
| |
| static int add_netdev(net_param *net, char *val) |
| { |
| char *token; |
| |
| for_each_strtok(token, val, "\t ") { |
| if (check_netdev(token)) |
| return ERR_INVAL; |
| add_str_param(&net->dev, token); |
| } |
| |
| return 0; |
| } |
| |
| static int store_netdev(vps_param *old_p, vps_param *vps_p, vps_config *conf, |
| list_head_t *conf_h) |
| { |
| list_head_t dev; |
| int ret; |
| |
| list_head_init(&dev); |
| if (conf->id != PARAM_NETDEV_ADD) |
| return 0; |
| if (list_empty(&vps_p->res.net.dev) && |
| list_empty(&vps_p->del_res.net.dev)) |
| { |
| return 0; |
| } |
| merge_str_list(0, &old_p->res.net.dev, &vps_p->res.net.dev, |
| &vps_p->del_res.net.dev, &dev); |
| ret = conf_store_strlist(conf_h, conf->name, &dev, 1); |
| free_str_param(&dev); |
| |
| return ret; |
| } |
| |
| /********************* fs *******************************/ |
| |
| static int store_fs(vps_param *old_p, vps_param *vps_p, vps_config *conf, |
| list_head_t *conf_h) |
| { |
| fs_param *fs = &vps_p->res.fs; |
| int ret; |
| |
| ret = 0; |
| switch (conf->id) { |
| case PARAM_ROOT: |
| ret = conf_store_str(conf_h, conf->name, fs->root_orig); |
| break; |
| case PARAM_PRIVATE: |
| ret = conf_store_str(conf_h, conf->name, fs->private_orig); |
| break; |
| case PARAM_NOATIME: |
| ret = conf_store_yesno(conf_h, conf->name, fs->noatime); |
| break; |
| } |
| return ret; |
| } |
| |
| static int store_tmpl(vps_param *old_p, vps_param *vps_p, vps_config *conf, |
| list_head_t *conf_h) |
| { |
| int ret; |
| |
| ret = 0; |
| switch (conf->id) { |
| case PARAM_OSTEMPLATE: |
| ret = conf_store_str(conf_h, conf->name, |
| vps_p->res.tmpl.ostmpl); |
| break; |
| } |
| return ret; |
| } |
| |
| /***********************Quota***************************/ |
| static int parse_dq(unsigned long **param, const char *val, int sfx) |
| { |
| int ret; |
| unsigned long *tmp; |
| |
| tmp = malloc(sizeof(unsigned long) * 2); |
| if (tmp == NULL) |
| return ERR_NOMEM; |
| ret = parse_twoul_sfx(val, tmp, sfx ? 1024 : 0); |
| if (ret && ret != ERR_LONG_TRUNC) { |
| free(tmp); |
| return ret; |
| } |
| *param = tmp; |
| return ret; |
| } |
| |
| static int store_dq(vps_param *old_p, vps_param *vps_p, vps_config *conf, |
| list_head_t *conf_h) |
| { |
| char buf[STR_SIZE]; |
| dq_param *param = &vps_p->res.dq; |
| |
| switch (conf->id) { |
| case PARAM_DISK_QUOTA: |
| conf_store_yesno(conf_h, conf->name, param->enable); |
| break; |
| case PARAM_DISKSPACE: |
| if (param->diskspace == NULL) |
| break; |
| snprintf(buf, sizeof(buf), "%s=\"%lu:%lu\"", conf->name, |
| param->diskspace[0], param->diskspace[1]); |
| add_str_param(conf_h, buf); |
| break; |
| case PARAM_DISKINODES: |
| if (param->diskinodes == NULL) |
| break; |
| snprintf(buf, sizeof(buf), "%s=\"%lu:%lu\"", conf->name, |
| param->diskinodes[0], param->diskinodes[1]); |
| add_str_param(conf_h, buf); |
| break; |
| case PARAM_QUOTATIME: |
| conf_store_ulong(conf_h, conf->name, param->exptime); |
| break; |
| case PARAM_QUOTAUGIDLIMIT: |
| conf_store_ulong(conf_h, conf->name, param->ugidlimit); |
| break; |
| } |
| return 0; |
| } |
| |
| /*********************Devices***************************/ |
| /* |
| * Parse device permission string and set corresponding bits in the permission |
| * mask. The caller is responsible for clearing the mask before the call. |
| */ |
| static int parse_dev_perm(const char *str, unsigned int *perms) |
| { |
| const char *ch; |
| |
| if (strcmp(str, "none")) { |
| for (ch = str; *ch; ch++) { |
| if (*ch == 'r') |
| *perms |= S_IROTH; |
| else if (*ch == 'w') |
| *perms |= S_IWOTH; |
| else if (*ch == 'q') |
| *perms |= S_IXGRP; |
| else |
| return 1; |
| } |
| } |
| return 0; |
| } |
| |
| static int parse_devices_str(const char *str, dev_res *dev) |
| { |
| int ret; |
| unsigned long val, major; |
| char type[2]; |
| char minor[32]; |
| char mode[3]; |
| |
| ret = sscanf(str, "%1[^:]:%lu:%16[^:]:%2s", type, &major, minor, mode); |
| if (ret != 4) |
| return 1; |
| memset(dev, 0, sizeof(*dev)); |
| if (!strcmp(type, "b")) |
| dev->type = S_IFBLK; |
| else if (!strcmp(type, "c")) |
| dev->type = S_IFCHR; |
| else |
| return -1; |
| if (!strcmp(minor, "all")) { |
| dev->use_major = VE_USE_MAJOR; |
| dev->type |= VE_USE_MAJOR; |
| dev->dev = makedev(major, 0); |
| } else { |
| dev->type |= VE_USE_MINOR; |
| if (parse_ul(minor, &val)) |
| return -1; |
| dev->dev = makedev(major, val); |
| } |
| ret = parse_dev_perm(mode, &dev->mask); |
| return 0; |
| } |
| |
| static int parse_dev(vps_param *vps_p, char *val) |
| { |
| char *token; |
| dev_res dev; |
| |
| for_each_strtok(token, val, " ") { |
| if (parse_devices_str(token, &dev)) |
| return ERR_INVAL; |
| if (add_dev_param(&vps_p->res.dev, &dev)) { |
| if (dev.name) |
| free(dev.name); |
| return ERR_NOMEM; |
| } |
| } |
| |
| return 0; |
| } |
| |
| static int store_dev(vps_param *old_p, vps_param *vps_p, vps_config *conf, |
| list_head_t *conf_h) |
| { |
| char buf[STR_SIZE]; |
| dev_param *dev = &vps_p->res.dev; |
| dev_res *res; |
| int r; |
| char *sp, *ep; |
| |
| if (conf->id != PARAM_DEVICES) |
| return 0; |
| if (list_empty(&dev->dev)) |
| return 0; |
| sp = buf; |
| ep = buf + sizeof(buf) - 1; |
| list_for_each(res, &dev->dev, list) { |
| int major, minor, i = 0; |
| char mask[3]; |
| |
| /* Devices with names (--devnodes) are handled by |
| * store_devnodes(), so skip those here */ |
| if (res->name) |
| continue; |
| if (sp == buf) |
| sp += snprintf(buf, sizeof(buf), "%s=\"", conf->name); |
| major = major(res->dev); |
| minor = minor(res->dev); |
| if (res->mask & S_IROTH) |
| mask[i++] = 'r'; |
| if (res->mask & S_IWOTH) |
| mask[i++] = 'w'; |
| mask[i] = 0; |
| if (res->use_major) { |
| r = snprintf(sp, ep - sp,"%c:%d:all:%s ", |
| S_ISBLK(res->type) ? 'b' : 'c', major, mask); |
| } else { |
| r = snprintf(sp, ep - sp,"%c:%d:%d:%s ", |
| S_ISBLK(res->type) ? 'b' : 'c', major, minor, |
| mask); |
| } |
| sp += r; |
| if ((r < 0) || (sp >= ep)) |
| break; |
| } |
| if (sp != buf) |
| strcat(buf, "\""); |
| add_str_param(conf_h, buf); |
| return 0; |
| } |
| |
| static int parse_devnodes_str(const char *str, dev_res *dev) |
| { |
| char *ch; |
| unsigned int len, buf_len; |
| char *buf; |
| struct stat st; |
| int ret = ERR_INVAL; |
| |
| if ((ch = strrchr(str, ':')) == NULL) |
| return ERR_INVAL; |
| ch++; |
| len = ch - str; |
| memset(dev, 0, sizeof(*dev)); |
| |
| dev->name = malloc(len); |
| if (dev->name == NULL) |
| return ERR_NOMEM; |
| snprintf(dev->name, len, "%s", str); |
| |
| buf_len = 5 + len; |
| buf = alloca(buf_len); |
| if (buf == NULL) { |
| ret = ERR_NOMEM; |
| goto err; |
| } |
| snprintf(buf, buf_len, "/dev/%s", dev->name); |
| if (stat(buf, &st)) { |
| logger(-1, errno, "Incorrect device name %s", buf); |
| goto err; |
| } |
| |
| if (S_ISCHR(st.st_mode)) |
| dev->type = S_IFCHR; |
| else if (S_ISBLK(st.st_mode)) |
| dev->type = S_IFBLK; |
| else { |
| logger(-1, 0, "The %s is not block or character device", buf); |
| goto err; |
| } |
| dev->dev = st.st_rdev; |
| dev->type |= VE_USE_MINOR; |
| if (parse_dev_perm(ch, &dev->mask)) |
| goto err; |
| return 0; |
| err: |
| free(dev->name); |
| dev->name = NULL; |
| return ret; |
| } |
| |
| static int parse_devnodes(vps_param *vps_p, char *val) |
| { |
| char *token; |
| dev_res dev; |
| |
| for_each_strtok(token, val, " ") { |
| if (parse_devnodes_str(token, &dev)) |
| return ERR_INVAL; |
| if (add_dev_param(&vps_p->res.dev, &dev)) { |
| if (dev.name) |
| free(dev.name); |
| return ERR_NOMEM; |
| } |
| } |
| |
| return 0; |
| } |
| |
| static int store_devnodes(vps_param *old_p, vps_param *vps_p, vps_config *conf, |
| list_head_t *conf_h) |
| { |
| char buf[STR_SIZE]; |
| dev_param *dev = &vps_p->res.dev; |
| dev_res *res; |
| int r, i; |
| char *sp, *ep; |
| char mask[3]; |
| |
| if (conf->id != PARAM_DEVNODES) |
| return 0; |
| if (list_empty(&dev->dev)) |
| return 0; |
| sp = buf; |
| *sp = 0; |
| ep = buf + sizeof(buf) - 1; |
| list_for_each (res, &dev->dev, list) { |
| i = 0; |
| /* Devices with no names (--devices) are handled by |
| * store_dev(), so skip those here */ |
| if (!res->name) |
| continue; |
| if (sp == buf) |
| sp += snprintf(buf, sizeof(buf), "%s=\"", conf->name); |
| if (res->mask & S_IROTH) |
| mask[i++] = 'r'; |
| if (res->mask & S_IWOTH) |
| mask[i++] = 'w'; |
| mask[i] = 0; |
| r = snprintf(sp, ep - sp,"%s:%s ", res->name, mask); |
| sp += r; |
| if ((r < 0) || (sp >= ep)) |
| break; |
| } |
| if (sp != buf) |
| strcat(buf, "\""); |
| add_str_param(conf_h, buf); |
| return 0; |
| } |
| |
| static int parse_pci(vps_param *vps_p, char *val, int id) |
| { |
| int domain; |
| unsigned int bus; |
| unsigned int slot; |
| unsigned int func; |
| char *token; |
| |
| int ret; |
| pci_param *pci; |
| char buf[64]; |
| |
| if (id == PARAM_PCI_ADD) |
| pci = &vps_p->res.pci; |
| else if (id == PARAM_PCI_DEL) |
| pci = &vps_p->del_res.pci; |
| else |
| return 0; |
| |
| for_each_strtok(token, val, " ") { |
| ret = sscanf(token, "%x:%x:%x.%d", &domain, &bus, &slot, &func); |
| if (ret != 4) { |
| domain = 0; |
| ret = sscanf(token, "%x:%x.%d", &bus, &slot, &func); |
| if (ret != 3) |
| return ERR_INVAL; |
| } |
| snprintf(buf, sizeof(buf), "%04x:%02x:%02x.%d", |
| domain, bus, slot, func); |
| if (!find_str(&pci->list, buf)) |
| add_str_param(&pci->list, buf); |
| } |
| |
| return 0; |
| } |
| |
| static int store_pci(vps_param *old_p, vps_param *vps_p, vps_config *conf, |
| list_head_t *conf_h) |
| { |
| list_head_t pci; |
| int ret; |
| |
| if (conf->id != PARAM_PCI_ADD) |
| return 0; |
| |
| if (list_empty(&vps_p->res.pci.list) && |
| list_empty(&vps_p->del_res.pci.list)) |
| return 0; |
| |
| list_head_init(&pci); |
| merge_str_list(0, &old_p->res.pci.list, &vps_p->res.pci.list, |
| &vps_p->del_res.pci.list, &pci); |
| |
| ret = conf_store_strlist(conf_h, conf->name, &pci, 1); |
| free_str_param(&pci); |
| |
| return ret; |
| } |
| |
| static int store_misc(vps_param *old_p, vps_param *vps_p, vps_config *conf, |
| list_head_t *conf_h) |
| { |
| misc_param *misc = &vps_p->res.misc; |
| int ret; |
| |
| ret = 0; |
| switch (conf->id) { |
| case PARAM_ONBOOT: |
| ret = conf_store_yesno(conf_h, conf->name, misc->onboot); |
| break; |
| case PARAM_BOOTORDER: |
| ret = conf_store_ulong(conf_h, conf->name, |
| misc->bootorder); |
| break; |
| case PARAM_DISABLED: |
| ret = conf_store_yesno(conf_h, conf->name, |
| vps_p->opt.start_disabled); |
| break; |
| case PARAM_CONFIG_SAMPLE: |
| ret = conf_store_str(conf_h, conf->name, |
| vps_p->opt.origin_sample); |
| break; |
| case PARAM_HOSTNAME: |
| ret = conf_store_str(conf_h, conf->name, misc->hostname); |
| break; |
| case PARAM_NAMESERVER: |
| ret = conf_store_strlist(conf_h, conf->name, |
| &misc->nameserver, 0); |
| break; |
| case PARAM_DESCRIPTION: |
| ret = conf_store_str(conf_h, conf->name, misc->description); |
| break; |
| case PARAM_SEARCHDOMAIN: |
| ret = conf_store_strlist(conf_h, conf->name, |
| &misc->searchdomain, 0); |
| break; |
| } |
| return ret; |
| } |
| |
| /****************** CPU**********************************/ |
| |
| static int parse_cpulimit(unsigned long **param, const char *str) |
| { |
| char *tail; |
| int ncpu; |
| unsigned long val; |
| |
| errno = 0; |
| val = (int)strtoul(str, (char **)&tail, 10); |
| if (*tail == '%' && *(tail + 1) == '\0') { |
| if (val > 100) |
| return ERR_INVAL; |
| ncpu = get_num_cpu(); |
| val *= ncpu; |
| } else if (*tail != '\0' || errno == ERANGE) |
| return ERR_INVAL; |
| |
| *param = malloc(sizeof(unsigned long)); |
| if (!*param) |
| return ERR_NOMEM; |
| **param = val; |
| return 0; |
| } |
| |
| static inline int parse_cpumask(cpumask_t **dst, const char *str) |
| { |
| return conf_parse_bitmap((unsigned long **)dst, CPUMASK_NBITS, str); |
| } |
| |
| static inline int store_cpumask(list_head_t *conf, char *name, cpumask_t *val) |
| { |
| return conf_store_bitmap(conf, name, cpumask_bits(val), CPUMASK_NBITS); |
| } |
| |
| static int store_cpu(vps_param *old_p, vps_param *vps_p, vps_config *conf, |
| list_head_t *conf_h) |
| { |
| cpu_param *cpu = &vps_p->res.cpu; |
| |
| switch (conf->id) { |
| case PARAM_CPUUNITS: |
| conf_store_ulong(conf_h, conf->name, cpu->units); |
| break; |
| case PARAM_CPUWEIGHT: |
| conf_store_ulong(conf_h, conf->name, cpu->weight); |
| break; |
| case PARAM_CPULIMIT: |
| conf_store_ulong(conf_h, conf->name, cpu->limit); |
| break; |
| case PARAM_VCPUS: |
| conf_store_ulong(conf_h, conf->name, cpu->vcpus); |
| break; |
| case PARAM_CPUMASK: |
| store_cpumask(conf_h, conf->name, cpu->mask); |
| break; |
| } |
| return 0; |
| } |
| |
| /********************* NETIF **********************************/ |
| |
| static int parse_mac_filter_cmd (veth_dev *dev, char *str) |
| { |
| |
| if (dev == NULL) |
| return ERR_INVAL; |
| |
| if (!strcmp(str, "on")) |
| dev->mac_filter = YES; |
| else if (!strcmp(str, "off")) |
| dev->mac_filter = NO; |
| else |
| return ERR_INVAL; |
| return 0; |
| } |
| |
| static void generate_veth_name(int veid, char *dev_name_ve, |
| char *dev_name, int len) |
| { |
| char *name; |
| int id = 0; |
| |
| name = subst_VEID(veid, DEF_VETHNAME); |
| sscanf(dev_name_ve, "%*[^0-9]%d", &id); |
| snprintf(dev_name, len, "%s.%d", name, id); |
| free(name); |
| } |
| |
| static int add_netif_param(veth_param *veth, int opt, char *str) |
| { |
| veth_dev *dev; |
| int len; |
| int ret; |
| |
| dev = NULL; |
| dev = find_veth_configure(&veth->dev); |
| if (dev == NULL) { |
| dev = calloc(1, sizeof(veth_dev)); |
| dev->configure = 1; |
| list_add_tail(&dev->list, &veth->dev); |
| } |
| len = strlen(str); |
| switch (opt) { |
| case PARAM_NETIF_IFNAME: |
| if (dev->dev_name_ve[0] != 0) { |
| logger(-1, 0,"Multiple use of" |
| " --ifname option not allowed"); |
| return ERR_INVAL; |
| } |
| if (len > IFNAMSIZE) |
| return ERR_INVAL; |
| strcpy(dev->dev_name_ve, str); |
| break; |
| case PARAM_NETIF_MAC: |
| if (parse_hwaddr(str, dev->dev_addr_ve)) |
| return ERR_INVAL; |
| dev->addrlen_ve = ETH_ALEN; |
| break; |
| case PARAM_NETIF_HOST_IFNAME: |
| if (len > IFNAMSIZE) |
| return ERR_INVAL; |
| strcpy(dev->dev_name, str); |
| break; |
| case PARAM_NETIF_HOST_MAC: |
| if (parse_hwaddr(str, dev->dev_addr)) |
| return ERR_INVAL; |
| dev->addrlen = ETH_ALEN; |
| break; |
| case PARAM_NETIF_MAC_FILTER: |
| if ((ret = parse_mac_filter_cmd(dev, str))) |
| return ret; |
| break; |
| case PARAM_NETIF_BRIDGE: |
| if (dev->dev_bridge[0] != 0) { |
| logger(-1, 0,"Multiple use of" |
| " --bridge option not allowed"); |
| return ERR_INVAL; |
| } |
| if (len > IFNAMSIZE) |
| return ERR_INVAL; |
| strcpy(dev->dev_bridge, str); |
| break; |
| } |
| return 0; |
| } |
| |
| static int parse_netif_str(envid_t veid, const char *str, veth_dev *dev) |
| { |
| const char *p, *next, *ep; |
| unsigned int len; |
| int err; |
| char tmp[256]; |
| |
| memset(dev, 0, sizeof(*dev)); |
| next = p = str; |
| ep = p + strlen(str); |
| do { |
| while (*next != '\0' && *next != ',') next++; |
| if (!strncmp("ifname=", p, 7)) { |
| p += 7; |
| len = next - p; |
| if (len > IFNAMSIZE) |
| return ERR_INVAL; |
| if (dev->dev_name_ve[0] == '\0') |
| strncpy(dev->dev_name_ve, p, len); |
| } else if (!strncmp("host_ifname=", p, 12)) { |
| p += 12; |
| len = next - p; |
| if (len > IFNAMSIZE) |
| return ERR_INVAL; |
| if (dev->dev_name[0] == '\0') |
| strncpy(dev->dev_name, p, len); |
| } else if (!strncmp("mac=", p, 4)) { |
| p += 4; |
| len = next - p; |
| if (len >= sizeof(tmp)) |
| return ERR_INVAL; |
| strncpy(tmp, p, len); |
| tmp[len] = 0; |
| err = parse_hwaddr(tmp, dev->dev_addr_ve); |
| if (err) |
| return err; |
| dev->addrlen_ve = ETH_ALEN; |
| } else if (!strncmp("host_mac=", p, 9)) { |
| p += 9; |
| len = next - p; |
| if (len >= sizeof(tmp)) |
| return ERR_INVAL; |
| strncpy(tmp, p, len); |
| tmp[len] = 0; |
| err = parse_hwaddr(tmp, dev->dev_addr); |
| if (err) |
| return err; |
| dev->addrlen = ETH_ALEN; |
| } else if (!strncmp("mac_filter=", p, 11)) { |
| p += 11; |
| len = next - p; |
| if (len == 0) |
| continue; |
| if (len >= sizeof(tmp)) |
| return ERR_INVAL; |
| strncpy(tmp, p, len); |
| tmp[len] = 0; |
| err = parse_mac_filter_cmd(dev, tmp); |
| if (err) |
| return err; |
| } else if (!strncmp("bridge=", p, 7)) { |
| p += 7; |
| len = next - p; |
| if (len > IFNAMSIZE) |
| return ERR_INVAL; |
| if (dev->dev_bridge[0] == '\0') |
| strncpy(dev->dev_bridge, p, len); |
| } |
| p = ++next; |
| } while (p < ep); |
| if (dev->dev_name_ve[0] == 0) |
| return ERR_INVAL; |
| if (dev->dev_name[0] == 0) |
| generate_veth_name(veid, dev->dev_name_ve, dev->dev_name, |
| sizeof(dev->dev_name)); |
| if (dev->addrlen_ve == 0) { |
| generate_mac(veid, dev->dev_name, dev->dev_addr_ve); |
| dev->addrlen_ve = ETH_ALEN; |
| } |
| if (dev->addrlen == 0) { |
| memcpy(dev->dev_addr, dev->dev_addr_ve, sizeof(dev->dev_addr)); |
| dev->addrlen = ETH_ALEN; |
| } |
| return 0; |
| } |
| |
| |
| static int parse_netif(envid_t veid, veth_param *veth, char *val) |
| { |
| int ret; |
| char *token; |
| veth_dev dev; |
| |
| for_each_strtok(token, val, ";") { |
| if (parse_netif_str(veid, token, &dev)) { |
| free_veth_dev(&dev); |
| continue; |
| } |
| if (!find_veth_by_ifname_ve(&veth->dev, dev.dev_name_ve)) |
| ret = add_veth_param(veth, &dev); |
| free_veth_dev(&dev); |
| } |
| |
| return 0; |
| } |
| |
| static int store_netif(vps_param *old_p, vps_param *vps_p, vps_config *conf, |
| list_head_t *conf_h) |
| { |
| char buf[STR_SIZE * 10]; |
| veth_dev *dev; |
| char *sp, *ep, *prev; |
| veth_param merged; |
| veth_param *veth_add = &vps_p->res.veth; |
| veth_param *veth_del = &vps_p->del_res.veth; |
| |
| |
| #define STR2MAC(dev) \ |
| ((unsigned char *)dev)[0], \ |
| ((unsigned char *)dev)[1], \ |
| ((unsigned char *)dev)[2], \ |
| ((unsigned char *)dev)[3], \ |
| ((unsigned char *)dev)[4], \ |
| ((unsigned char *)dev)[5] |
| if (conf->id != PARAM_NETIF_ADD) |
| return 0; |
| if (list_empty(&veth_add->dev) && list_empty(&veth_del->dev) && |
| !veth_add->delall) |
| { |
| return 0; |
| } |
| memset(&merged, 0, sizeof(merged)); |
| list_head_init(&merged.dev); |
| if (old_p != NULL) { |
| if (merge_veth_list(veth_add->delall == YES ? NULL : |
| &old_p->res.veth.dev, |
| &veth_add->dev, &veth_del->dev, &merged)) |
| { |
| return 0; |
| } |
| } else { |
| copy_veth_param(&merged, veth_add); |
| } |
| *buf = 0; |
| sp = buf; |
| ep = buf + sizeof(buf) - 2; |
| sp += snprintf(buf, sizeof(buf), "%s=\"", conf->name); |
| prev = sp; |
| list_for_each(dev, &merged.dev, list) { |
| if (prev != sp) |
| *(sp-1) = ';'; |
| prev = sp; |
| if (dev->dev_name_ve[0] != 0) { |
| sp += snprintf(sp, ep - sp, "ifname=%s,", |
| dev->dev_name_ve); |
| if (sp >= ep) |
| break; |
| } |
| if (dev->dev_bridge[0] != 0) { |
| sp += snprintf(sp, ep - sp, "bridge=%s,", |
| dev->dev_bridge); |
| if (sp >= ep) |
| break; |
| } |
| if (dev->addrlen_ve != 0) { |
| sp += snprintf(sp, ep - sp, |
| "mac=%02X:%02X:%02X:%02X:%02X:%02X,", |
| STR2MAC(dev->dev_addr_ve)); |
| if (sp >= ep) |
| break; |
| } |
| if (dev->dev_name[0] != 0) { |
| sp += snprintf(sp, ep - sp, "host_ifname=%s,", |
| dev->dev_name); |
| if (sp >= ep) |
| break; |
| } |
| if (dev->addrlen != 0) { |
| sp += snprintf(sp, ep - sp, |
| "host_mac=%02X:%02X:%02X:%02X:%02X:%02X,", |
| STR2MAC(dev->dev_addr)); |
| if (sp >= ep) |
| break; |
| } |
| if (dev->mac_filter) { |
| sp += snprintf(sp, ep - sp, "mac_filter=%s,", |
| dev->mac_filter == YES ? "on" : "off"); |
| if (sp >= ep) |
| break; |
| } |
| if (prev != sp) |
| *(sp-1) = 0; |
| if (sp >= ep) |
| break; |
| } |
| free_veth_param(&merged); |
| strcat(buf, "\""); |
| add_str_param(conf_h, buf); |
| return 0; |
| #undef STR2MAC |
| } |
| |
| static int parse_netif_str_cmd(envid_t veid, const char *str, veth_dev *dev) |
| { |
| const char *ch, *tmp, *ep; |
| int len, err; |
| |
| memset(dev, 0, sizeof(*dev)); |
| ep = str + strlen(str); |
| /* Creating veth device */ |
| /* Parsing veth device name in CT */ |
| if ((ch = strchr(str, ',')) == NULL) { |
| ch = ep; |
| len = ep - str; |
| } else { |
| len = ch - str; |
| ch++; |
| } |
| if (len > IFNAMSIZE) |
| return ERR_INVAL; |
| snprintf(dev->dev_name_ve, len + 1, "%s", str); |
| tmp = ch; |
| if (ch == ep) { |
| generate_veth_name(veid, dev->dev_name_ve, dev->dev_name, |
| sizeof(dev->dev_name)); |
| generate_mac(veid, dev->dev_name, dev->dev_addr); |
| dev->addrlen_ve = ETH_ALEN; |
| generate_mac(veid, dev->dev_name_ve, dev->dev_addr_ve); |
| dev->addrlen = ETH_ALEN; |
| return 0; |
| } |
| /* Parsing veth MAC address in CT */ |
| if ((ch = strchr(tmp, ',')) == NULL) { |
| ch = ep; |
| len = ch - tmp; |
| } else { |
| len = ch - tmp; |
| ch++; |
| } |
| |
| if (len) { |
| if (len != MAC_SIZE) { |
| logger(-1, 0, "Invalid container MAC address length"); |
| return ERR_INVAL; |
| } |
| err = parse_hwaddr(tmp, dev->dev_addr_ve); |
| if (err) { |
| logger(-1, 0, "Invalid container MAC address format"); |
| return ERR_INVAL; |
| } |
| } else { |
| generate_mac(veid, dev->dev_name_ve, dev->dev_addr_ve); |
| } |
| dev->addrlen_ve = ETH_ALEN; |
| |
| tmp = ch; |
| |
| if (ch == ep) { |
| generate_veth_name(veid, dev->dev_name_ve, dev->dev_name, |
| sizeof(dev->dev_name)); |
| memcpy(dev->dev_addr, dev->dev_addr_ve, ETH_ALEN); |
| dev->addrlen = ETH_ALEN; |
| return 0; |
| } |
| /* Parsing veth name in CT0 */ |
| if ((ch = strchr(tmp, ',')) == NULL) { |
| ch = ep; |
| len = ch - tmp; |
| } else { |
| len = ch - tmp; |
| ch++; |
| } |
| if (len) { |
| if (len > IFNAMSIZE) |
| return ERR_INVAL; |
| snprintf(dev->dev_name, len + 1, "%s", tmp); |
| if (ch == ep) { |
| memcpy(dev->dev_addr, dev->dev_addr_ve, ETH_ALEN); |
| dev->addrlen = ETH_ALEN; |
| return 0; |
| } |
| } else { |
| generate_veth_name(veid, dev->dev_name_ve, dev->dev_name, |
| sizeof(dev->dev_name)); |
| } |
| |
| tmp = ch; |
| |
| /* Parsing veth MAC address in CT */ |
| if ((ch = strchr(tmp, ',')) == NULL) { |
| ch = ep; |
| len = ch - tmp; |
| } else { |
| len = ch - tmp; |
| ch++; |
| } |
| |
| if (len) { |
| if (len != MAC_SIZE) { |
| logger(-1, 0, "Invalid host MAC address"); |
| return ERR_INVAL; |
| } |
| err = parse_hwaddr(tmp, dev->dev_addr); |
| if (err) { |
| logger(-1, 0, "Invalid host MAC address"); |
| return ERR_INVAL; |
| } |
| dev->addrlen = ETH_ALEN; |
| if (ch == ep) { |
| return 0; |
| } |
| } else { |
| generate_mac(veid, dev->dev_name, dev->dev_addr); |
| dev->addrlen = ETH_ALEN; |
| } |
| |
| /* Parsing bridge name */ |
| len = strlen (ch); |
| |
| if (len > IFNAMSIZE) |
| return ERR_INVAL; |
| |
| snprintf(dev->dev_bridge, len + 1, "%s", ch); |
| |
| return 0; |
| } |
| |
| static int parse_netif_cmd(envid_t veid, veth_param *veth, char *val) |
| { |
| int ret; |
| char *token; |
| veth_dev dev; |
| |
| for_each_strtok(token, val, " ") { |
| if (parse_netif_str_cmd(veid, token, &dev)) |
| return ERR_INVAL; |
| ret = add_veth_param(veth, &dev); |
| } |
| |
| return 0; |
| } |
| |
| static int store_name(vps_param *old_p, vps_param *vps_p, vps_config *conf, |
| list_head_t *conf_h) |
| { |
| char buf[STR_SIZE]; |
| |
| switch (conf->id) { |
| case PARAM_VEID: |
| if (vps_p->res.name.veid <= 0) |
| break; |
| snprintf(buf, sizeof(buf), "%s=\"%d\"", conf->name, |
| vps_p->res.name.veid); |
| add_str_param(conf_h, buf); |
| break; |
| case PARAM_NAME: |
| conf_store_str(conf_h, conf->name, vps_p->res.name.name); |
| break; |
| } |
| return 0; |
| } |
| |
| static int parse(envid_t veid, vps_param *vps_p, char *val, int id) |
| { |
| int ret; |
| int int_id; |
| |
| ret = 0; |
| if (!_page_size) { |
| _page_size = get_pagesize(); |
| if (_page_size < 0) |
| return -1; |
| } |
| switch (id) { |
| case PARAM_CONFIG: |
| ret = conf_parse_str(&vps_p->opt.config, val); |
| break; |
| case PARAM_CONFIG_SAMPLE: |
| ret = conf_parse_str(&vps_p->opt.origin_sample, val); |
| break; |
| case PARAM_SAVE: |
| vps_p->opt.save = YES; |
| break; |
| case PARAM_FORCE: |
| vps_p->opt.save_force = YES; |
| break; |
| case PARAM_RESET_UB: |
| vps_p->opt.reset_ub = YES; |
| break; |
| case PARAM_ONBOOT: |
| ret = conf_parse_yesno(&vps_p->res.misc.onboot, val); |
| break; |
| case PARAM_DISABLED: |
| ret = conf_parse_yesno(&vps_p->opt.start_disabled, val); |
| break; |
| case PARAM_HOSTNAME: |
| ret = conf_parse_str(&vps_p->res.misc.hostname, val); |
| break; |
| case PARAM_DESCRIPTION: |
| ret = conf_parse_str(&vps_p->res.misc.description, val); |
| break; |
| case PARAM_NAMESERVER: |
| ret = conf_parse_strlist(&vps_p->res.misc.nameserver, val); |
| break; |
| case PARAM_SEARCHDOMAIN: |
| ret = conf_parse_strlist(&vps_p->res.misc.searchdomain, val); |
| break; |
| case PARAM_USERPW: |
| ret = conf_parse_strlist(&vps_p->res.misc.userpw, val); |
| break; |
| case PARAM_APPLYCONFIG_MAP: |
| if (!strcmp(val, "name")) |
| vps_p->opt.apply_cfg_map = APPCONF_MAP_NAME; |
| else |
| ret = ERR_INVAL; |
| break; |
| case PARAM_APPLYCONFIG: |
| ret = conf_parse_str(&vps_p->opt.apply_cfg, val); |
| break; |
| case PARAM_SETMODE: |
| ret = parse_setmode(vps_p, val); |
| break; |
| case PARAM_LOGFILE: |
| ret = conf_parse_str(&vps_p->log.log_file, val); |
| break; |
| case PARAM_LOCKDIR: |
| ret = conf_parse_str(&vps_p->opt.lockdir, val); |
| break; |
| case PARAM_DUMPDIR: |
| ret = conf_parse_str(&vps_p->res.cpt.dumpdir, val); |
| break; |
| case PARAM_LOGGING: |
| ret = conf_parse_yesno(&vps_p->log.enable, val); |
| break; |
| case PARAM_LOGLEVEL: |
| if (parse_int(val, &int_id)) |
| break; |
| vps_p->log.level = int_id; |
| break; |
| case PARAM_VERBOSE: |
| if (vps_p->log.verbose != NULL) |
| break; |
| if (parse_int(val, &int_id)) |
| break; |
| vps_p->log.verbose = malloc(sizeof(*vps_p->log.verbose)); |
| if (vps_p->log.verbose == NULL) |
| return VZ_RESOURCE_ERROR; |
| *vps_p->log.verbose = int_id; |
| break; |
| case PARAM_IPTABLES: |
| ret = parse_iptables(&vps_p->res.env, val); |
| break; |
| case PARAM_LOCKEDPAGES: |
| case PARAM_PRIVVMPAGES: |
| case PARAM_SHMPAGES: |
| case PARAM_PHYSPAGES: |
| case PARAM_VMGUARPAGES: |
| case PARAM_OOMGUARPAGES: |
| case PARAM_SWAPPAGES: |
| ret = parse_ub(vps_p, val, id, _page_size); |
| break; |
| case PARAM_NUMPROC: |
| case PARAM_NUMTCPSOCK: |
| case PARAM_NUMFLOCK: |
| case PARAM_NUMPTY: |
| case PARAM_NUMSIGINFO: |
| case PARAM_NUMOTHERSOCK: |
| case PARAM_NUMFILE: |
| case PARAM_NUMIPTENT: |
| case PARAM_AVNUMPROC: |
| ret = parse_ub(vps_p, val, id, 0); |
| break; |
| case PARAM_KMEMSIZE: |
| case PARAM_TCPSNDBUF: |
| case PARAM_TCPRCVBUF: |
| case PARAM_OTHERSOCKBUF: |
| case PARAM_DGRAMRCVBUF: |
| case PARAM_DCACHESIZE: |
| ret = parse_ub(vps_p, val, id, 1); |
| break; |
| case PARAM_CAP: |
| ret = parse_cap(val, &vps_p->res.cap); |
| break; |
| case PARAM_IP_ADD: |
| case PARAM_IP_DEL: |
| ret = parse_ip(vps_p, val, id); |
| break; |
| case PARAM_SKIPARPDETECT: |
| vps_p->res.net.skip_arpdetect = YES; |
| break; |
| case PARAM_IPV6NET: |
| ret = conf_parse_yesno(&vps_p->res.net.ipv6_net, val); |
| vps_p->del_res.net.ipv6_net = vps_p->res.net.ipv6_net; |
| break; |
| case PARAM_NETDEV_ADD: |
| ret = add_netdev(&vps_p->res.net, val); |
| break; |
| case PARAM_NETDEV_DEL: |
| ret = add_netdev(&vps_p->del_res.net, val); |
| break; |
| case PARAM_ROOT: |
| if (!(ret = conf_parse_str(&vps_p->res.fs.root_orig, val))) |
| vps_p->res.fs.root = subst_VEID(veid, val); |
| break; |
| case PARAM_PRIVATE: |
| if (!(ret = conf_parse_str(&vps_p->res.fs.private_orig, val))) |
| vps_p->res.fs.private = subst_VEID(veid, val); |
| break; |
| case PARAM_TEMPLATE: |
| ret = conf_parse_str(&vps_p->res.fs.tmpl, val); |
| break; |
| case PARAM_NOATIME: |
| ret = conf_parse_yesno(&vps_p->res.fs.noatime, val); |
| break; |
| case PARAM_DEF_OSTEMPLATE: |
| ret = conf_parse_str(&vps_p->res.tmpl.def_ostmpl, val); |
| break; |
| case PARAM_OSTEMPLATE: |
| ret = conf_parse_str(&vps_p->res.tmpl.ostmpl, val); |
| break; |
| case PARAM_DISK_QUOTA: |
| ret = conf_parse_yesno(&vps_p->res.dq.enable, val); |
| break; |
| case PARAM_DISKSPACE: |
| if (vps_p->res.dq.diskspace != NULL) |
| break; |
| if (parse_dq(&vps_p->res.dq.diskspace, val, 1)) |
| ret = ERR_INVAL; |
| break; |
| case PARAM_DISKINODES: |
| if (vps_p->res.dq.diskinodes != NULL) |
| break; |
| if (parse_dq(&vps_p->res.dq.diskinodes, val, 0)) |
| ret = ERR_INVAL; |
| break; |
| case PARAM_QUOTATIME: |
| ret = conf_parse_ulong(&vps_p->res.dq.exptime, val); |
| break; |
| case PARAM_QUOTAUGIDLIMIT: |
| ret = conf_parse_ulong(&vps_p->res.dq.ugidlimit, val); |
| break; |
| case PARAM_DEVICES: |
| ret = parse_dev(vps_p, val); |
| break; |
| case PARAM_PCI_ADD: |
| case PARAM_PCI_DEL: |
| ret = parse_pci(vps_p, val, id); |
| break; |
| case PARAM_DEVNODES: |
| ret = parse_devnodes(vps_p, val); |
| break; |
| case PARAM_CPUUNITS: |
| ret = conf_parse_ulong(&vps_p->res.cpu.units, val); |
| if (ret != 0) |
| break; |
| |
| if ((*vps_p->res.cpu.units < MINCPUUNITS || |
| *vps_p->res.cpu.units > MAXCPUUNITS)) |
| { |
| free(vps_p->res.cpu.units); |
| vps_p->res.cpu.units = NULL; |
| ret = ERR_INVAL; |
| } |
| break; |
| case PARAM_CPUWEIGHT: |
| ret = conf_parse_ulong(&vps_p->res.cpu.weight, val); |
| break; |
| case PARAM_CPULIMIT: |
| if (vps_p->res.cpu.limit != NULL) |
| break; |
| ret = parse_cpulimit(&vps_p->res.cpu.limit, val); |
| break; |
| case PARAM_VCPUS: |
| ret = conf_parse_ulong(&vps_p->res.cpu.vcpus, val); |
| break; |
| case PARAM_CPUMASK: |
| ret = parse_cpumask(&vps_p->res.cpu.mask, val); |
| break; |
| case PARAM_MEMINFO: |
| ret = parse_meminfo(&vps_p->res.meminfo, val); |
| break; |
| case PARAM_VETH_ADD: |
| logger(0, 0, "Warning: VETH parameter is deprecated, remove " |
| "it and use --netif_add instead"); |
| break; |
| case PARAM_NETIF_ADD: |
| if (!list_empty(&vps_p->res.veth.dev)) |
| break; |
| ret = parse_netif(veid, &vps_p->res.veth, val); |
| break; |
| case PARAM_NETIF_ADD_CMD: |
| ret = parse_netif_cmd(veid, &vps_p->res.veth, val); |
| break; |
| case PARAM_NETIF_DEL_CMD: { |
| veth_dev dev; |
| |
| memset(&dev, 0, sizeof(dev)); |
| if (strlen(val) > IFNAMSIZE) { |
| ret = ERR_INVAL; |
| break; |
| } |
| if (!strcmp(val, "all")) { |
| vps_p->res.veth.delall = YES; |
| break; |
| } |
| if (find_veth_by_ifname_ve(&vps_p->del_res.veth.dev, val) != NULL) |
| break; |
| strcpy(dev.dev_name_ve, val); |
| add_veth_param(&vps_p->del_res.veth, &dev); |
| |
| break; |
| } |
| case PARAM_NETIF_IFNAME: |
| case PARAM_NETIF_MAC: |
| case PARAM_NETIF_HOST_IFNAME: |
| case PARAM_NETIF_HOST_MAC: |
| case PARAM_NETIF_MAC_FILTER: |
| case PARAM_NETIF_BRIDGE: |
| ret = add_netif_param(&vps_p->res.veth, id, val); |
| break; |
| case PARAM_NAME: |
| if (vps_p->res.name.name != NULL) |
| break; |
| if (check_name(val)) |
| return ERR_INVAL; |
| ret = conf_parse_str(&vps_p->res.name.name, val); |
| break; |
| case PARAM_VEID: |
| if (parse_int(val, &int_id)) |
| return ERR_INVAL; |
| vps_p->res.name.veid = int_id; |
| break; |
| case PARAM_FEATURES: |
| ret = parse_features(&vps_p->res.env, val); |
| break; |
| case PARAM_IOPRIO: |
| if (parse_ioprio(id, &vps_p->res.io, val)) |
| return ERR_INVAL; |
| break; |
| case PARAM_BOOTORDER: |
| ret = conf_parse_ulong(&vps_p->res.misc.bootorder, val); |
| break; |
| default: |
| logger(10, 0, "Not handled parameter %d %s", id, val); |
| break; |
| } |
| return ret; |
| } |
| |
| static int store(vps_param *old_p, vps_param *vps_p, list_head_t *conf_h) |
| { |
| vps_config *conf; |
| |
| store_ub(old_p, vps_p, conf_h); |
| for (conf = config; conf->name != NULL; conf++) { |
| store_env(old_p, vps_p, conf, conf_h); |
| store_cap(old_p, vps_p, conf, conf_h); |
| store_ip(old_p, vps_p, conf, conf_h); |
| store_netdev(old_p, vps_p, conf, conf_h); |
| store_fs(old_p, vps_p, conf, conf_h); |
| store_tmpl(old_p, vps_p, conf, conf_h); |
| store_dq(old_p, vps_p, conf, conf_h); |
| store_dev(old_p, vps_p, conf, conf_h); |
| store_devnodes(old_p, vps_p, conf, conf_h); |
| store_pci(old_p, vps_p, conf, conf_h); |
| store_misc(old_p, vps_p, conf, conf_h); |
| store_cpu(old_p, vps_p, conf, conf_h); |
| store_meminfo(old_p, vps_p, conf, conf_h); |
| store_netif(old_p, vps_p, conf, conf_h); |
| store_name(old_p, vps_p, conf, conf_h); |
| store_ioprio(old_p, vps_p, conf, conf_h); |
| } |
| return 0; |
| } |
| |
| /********************************************************/ |
| /* CT parse config stuff */ |
| /********************************************************/ |
| |
| int vps_parse_config(envid_t veid, char *path, vps_param *vps_p, |
| struct mod_action *action) |
| { |
| char *str; |
| char ltoken[STR_SIZE]; |
| FILE *fp; |
| int line = 0; |
| int ret; |
| char *rtoken; |
| struct stat st; |
| int len = 4096; |
| int err = 0; |
| const vps_config *conf; |
| |
| if ((fp = fopen(path, "r")) == NULL) { |
| logger(-1, errno, "Unable to open %s", path); |
| return 1; |
| } |
| if (!stat(path, &st)) |
| len = st.st_size; |
| if (len > 4096) |
| str = malloc(len); |
| else |
| str = alloca(len); |
| if (str == NULL) { |
| fclose(fp); |
| return VZ_RESOURCE_ERROR; |
| } |
| while (fgets(str, len, fp)) { |
| line++; |
| if ((rtoken = parse_line(str, ltoken, sizeof(ltoken))) == NULL) |
| continue; |
| if ((conf = conf_get_by_name(config, ltoken)) != NULL) { |
| ret = parse(veid, vps_p, rtoken, conf->id); |
| } else if (action != NULL) |
| ret = mod_parse(veid, action, ltoken, -1, rtoken); |
| else |
| continue; |
| if (!ret) { |
| continue; |
| } else if (ret == ERR_INVAL_SKIP) { |
| continue; |
| } else if (ret == ERR_LONG_TRUNC) { |
| logger(-1, 0, "Warning: too large value for %s=%s" |
| " was truncated", ltoken, rtoken); |
| } else if (ret == ERR_DUP) { |
| logger(-1, 0, "Warning: dup for %s=%s in line %d" |
| " is ignored", ltoken, rtoken, line); |
| } else if (ret == ERR_INVAL) { |
| logger(-1, 0, "Invalid value for %s=%s, skipped", |
| ltoken, rtoken); |
| } else if (ret == ERR_UNK) { |
| logger(-1, 0, "Unknown parameter %s, skipped", ltoken); |
| } else if (ret == ERR_NOMEM) { |
| logger(-1, 0, "Not enough memory"); |
| err = VZ_RESOURCE_ERROR; |
| break; |
| } else { |
| logger(-1, 0, "Unknown exit code %d on parse %s", |
| ret, ltoken); |
| } |
| } |
| fclose(fp); |
| if (len > 4096) |
| free(str); |
| return err; |
| } |
| |
| /********************************************************/ |
| /* CT save config stuff */ |
| /********************************************************/ |
| static int read_conf(char *fname, list_head_t *conf_h) |
| { |
| FILE *fp; |
| char str[16384]; |
| |
| if (!stat_file(fname)) |
| return 0; |
| if (!(fp = fopen(fname, "r"))) |
| return -1; |
| while (fgets(str, sizeof(str), fp)) { |
| add_str_param(conf_h, str); |
| } |
| fclose(fp); |
| |
| return 0; |
| } |
| |
| static int write_conf(char *fname, list_head_t *head) |
| { |
| char *tmpfile, *file; |
| conf_struct *conf; |
| FILE * fp; |
| int ret = VZ_CONFIG_SAVE_ERROR; |
| const char *suffix = ".tmp"; |
| char *fmt; |
| |
| file = canonicalize_file_name(fname); |
| if (file == NULL) { |
| if (errno != ENOENT) { |
| logger(-1, errno, "Unable to resolve path %s", fname); |
| return 1; |
| } |
| file = vz_strdup(fname); |
| if (!file) |
| return ret; |
| } |
| tmpfile = vz_malloc(strlen(file) + strlen(suffix) + 1); |
| if (!tmpfile) |
| goto out_file; |
| sprintf(tmpfile, "%s%s", file, suffix); |
| if ((fp = fopen(tmpfile, "w")) == NULL) { |
| logger(-1, errno, "Unable to create configuration" |
| " file %s", tmpfile); |
| goto out; |
| } |
| list_for_each(conf, head, list) { |
| if (conf->val == NULL) |
| continue; |
| if (strchr(conf->val, '\n') == NULL) |
| fmt="%s\n"; |
| else |
| fmt="%s"; |
| if (fprintf(fp, fmt, conf->val) < 0) { |
| logger(-1, errno, "Error writing to %s", |
| tmpfile); |
| fclose(fp); |
| goto out2; |
| } |
| } |
| fclose(fp); |
| if (rename(tmpfile, file)) { |
| logger(-1, errno, "Unable to move %s -> %s", |
| tmpfile, file ); |
| goto out2; |
| } |
| ret = 0; |
| out2: |
| unlink(tmpfile); |
| out: |
| free(tmpfile); |
| out_file: |
| free(file); |
| return ret; |
| } |
| |
| static int vps_merge_conf(list_head_t *dst, list_head_t *src) |
| { |
| unsigned int len; |
| int cnt = 0; |
| conf_struct *conf, *line; |
| char ltoken[STR_SIZE]; |
| char *p; |
| |
| if (list_empty(src)) |
| return 0; |
| list_for_each(conf, src, list) { |
| if ((p = strchr(conf->val, '=')) == NULL) |
| continue; |
| len = p - conf->val + 1; |
| snprintf(ltoken, len < sizeof(ltoken) ? len : sizeof(ltoken), |
| "%s", conf->val); |
| line = find_conf_line(dst, ltoken, '='); |
| if (line != NULL) { |
| free(line->val); |
| line->val = strdup(conf->val); |
| } else |
| add_str_param(dst, conf->val); |
| cnt++; |
| } |
| return cnt; |
| } |
| |
| int vps_save_config(envid_t veid, char *path, vps_param *new_p, |
| vps_param *old_p, struct mod_action *action) |
| { |
| vps_param *tmp_old_p = NULL; |
| list_head_t conf, new_conf; |
| int ret, n; |
| |
| list_head_init(&conf); |
| list_head_init(&new_conf); |
| if (old_p == NULL && stat_file(path)) { |
| tmp_old_p = init_vps_param(); |
| vps_parse_config(veid, path, tmp_old_p, action); |
| old_p = tmp_old_p; |
| } |
| if ((ret = read_conf(path, &conf))) |
| return ret; |
| n = store(old_p, new_p, &new_conf); |
| if (action != NULL) |
| mod_save_config(action, &new_conf); |
| if ((ret = vps_merge_conf(&conf, &new_conf)) > 0) |
| ret = write_conf(path, &conf); |
| free_str_param(&conf); |
| free_str_param(&new_conf); |
| free_vps_param(tmp_old_p); |
| |
| return ret; |
| } |
| |
| /********************************************************************/ |
| int vps_parse_opt(envid_t veid, struct option *opts, vps_param *param, |
| int opt, char *rval, struct mod_action *action) |
| { |
| int id, ret = 0; |
| |
| if (param == NULL) |
| return -1; |
| if ((id = opt_get_by_id(opts, opt)) != -1) { |
| ret = parse(veid, param, rval, id); |
| } else if (action != NULL) { |
| ret = mod_parse(veid, action, NULL, opt, rval); |
| } |
| |
| return ret; |
| } |
| |
| /********************************************************************/ |
| vps_param *init_vps_param() |
| { |
| vps_param *param; |
| |
| param = (vps_param *) calloc(1, sizeof(vps_param)); |
| if (param == NULL) |
| return NULL; |
| list_head_init(¶m->res.net.ip); |
| list_head_init(¶m->res.net.dev); |
| list_head_init(¶m->res.dev.dev); |
| list_head_init(¶m->res.misc.userpw); |
| list_head_init(¶m->res.misc.nameserver); |
| list_head_init(¶m->res.misc.searchdomain); |
| list_head_init(¶m->res.dev.dev); |
| list_head_init(¶m->res.pci.list); |
| list_head_init(¶m->res.veth.dev); |
| |
| list_head_init(¶m->del_res.net.ip); |
| list_head_init(¶m->del_res.net.dev); |
| list_head_init(¶m->del_res.dev.dev); |
| list_head_init(¶m->del_res.misc.userpw); |
| list_head_init(¶m->del_res.misc.nameserver); |
| list_head_init(¶m->del_res.misc.searchdomain); |
| list_head_init(¶m->del_res.dev.dev); |
| list_head_init(¶m->del_res.pci.list); |
| list_head_init(¶m->del_res.veth.dev); |
| param->res.meminfo.mode = -1; |
| param->res.io.ioprio = -1; |
| |
| return param; |
| } |
| |
| int get_veid_by_name(const char *name) |
| { |
| char buf[STR_SIZE]; |
| char content[STR_SIZE]; |
| char *p; |
| int veid, ret; |
| |
| if (name == NULL) |
| return -1; |
| snprintf(buf, sizeof(buf), VENAME_DIR "/%s", name); |
| if (stat_file(buf) != 1) |
| return -1; |
| ret = readlink(buf, content, sizeof(content) - 1); |
| if (ret < 0) |
| return -1; |
| content[ret] = 0; |
| if ((p = strrchr(content, '/')) == NULL) |
| p = content; |
| else |
| p++; |
| if (sscanf(p, "%d.conf", &veid) == 1) |
| return veid; |
| return -1; |
| } |
| |
| static int check_name(char *name) |
| { |
| char *p; |
| const char *validchars = " -+_."; |
| |
| for (p = name; *p != '\0'; p++) { |
| if (!isdigit(*p) && !isalpha(*p) && !strchr(validchars, *p)) |
| return -1; |
| } |
| return 0; |
| } |
| |
| int set_name(int veid, char *new_name, char *old_name) |
| { |
| int veid_old = -1; |
| char buf[STR_SIZE]; |
| char conf[STR_SIZE]; |
| |
| if (new_name == NULL) |
| return 0; |
| if (check_name(new_name)) { |
| logger(-1, 0, "Error: invalid name %s", new_name); |
| return VZ_SET_NAME_ERROR; |
| } |
| veid_old = get_veid_by_name(new_name); |
| if (veid_old >= 0 && veid_old != veid) { |
| logger(-1, 0, "Conflict: name %s already used by container %d", |
| new_name, veid_old); |
| return VZ_SET_NAME_ERROR; |
| } |
| if (old_name != NULL && |
| !strcmp(old_name, new_name) && |
| veid == veid_old) |
| { |
| return 0; |
| } |
| if (new_name[0] != 0) { |
| snprintf(buf, sizeof(buf), VENAME_DIR "/%s", new_name); |
| get_vps_conf_path(veid, conf, sizeof(conf)); |
| unlink(buf); |
| if (symlink(conf, buf)) { |
| logger(-1, errno, "Unable to create link %s", buf); |
| return VZ_SET_NAME_ERROR; |
| } |
| } |
| veid_old = get_veid_by_name(old_name); |
| /* Remove old alias */ |
| if (veid_old == veid && |
| old_name != NULL && strcmp(old_name, new_name)) |
| { |
| snprintf(buf, sizeof(buf), VENAME_DIR "/%s", old_name); |
| unlink(buf); |
| } |
| logger(0, 0, "Name %s assigned", new_name); |
| return 0; |
| } |
| |
| #define FREE_P(x) free(x); x = NULL; |
| |
| static void free_opt(vps_opt *opt) |
| { |
| FREE_P(opt->config) |
| FREE_P(opt->origin_sample) |
| FREE_P(opt->apply_cfg) |
| FREE_P(opt->lockdir) |
| } |
| |
| static void free_log_s(struct log_s *log) |
| { |
| FREE_P(log->log_file) |
| FREE_P(log->verbose) |
| } |
| |
| static void free_fs(fs_param *fs) |
| { |
| FREE_P(fs->root) |
| FREE_P(fs->root_orig) |
| FREE_P(fs->private) |
| FREE_P(fs->private_orig) |
| FREE_P(fs->tmpl) |
| } |
| |
| static void free_tmpl(tmpl_param *tmpl) |
| { |
| FREE_P(tmpl->def_ostmpl) |
| FREE_P(tmpl->ostmpl) |
| FREE_P(tmpl->dist) |
| } |
| |
| static void free_ub(ub_param *ub) |
| { |
| free_ub_param(ub); |
| } |
| |
| static void free_misc(misc_param *misc) |
| { |
| free_str_param(&misc->nameserver); |
| free_str_param(&misc->searchdomain); |
| free_str_param(&misc->userpw); |
| FREE_P(misc->hostname) |
| FREE_P(misc->description) |
| FREE_P(misc->bootorder) |
| } |
| |
| static void free_net(net_param *net) |
| { |
| free_str_param(&net->ip); |
| free_str_param(&net->dev); |
| } |
| |
| static void free_dev(dev_param *dev) |
| { |
| free_dev_param(dev); |
| } |
| |
| static void free_pci(pci_param *pci) |
| { |
| free_str_param(&pci->list); |
| } |
| |
| static void free_cpu(cpu_param *cpu) |
| { |
| FREE_P(cpu->units) |
| FREE_P(cpu->weight) |
| FREE_P(cpu->limit) |
| FREE_P(cpu->vcpus) |
| FREE_P(cpu->mask); |
| } |
| |
| static void free_dq(dq_param *dq) |
| { |
| FREE_P(dq->diskspace) |
| FREE_P(dq->diskinodes) |
| FREE_P(dq->exptime) |
| FREE_P(dq->ugidlimit) |
| } |
| |
| static void free_cpt(cpt_param *cpt) |
| { |
| FREE_P(cpt->dumpdir) |
| FREE_P(cpt->dumpfile) |
| } |
| |
| static void free_name(name_param *name) |
| { |
| FREE_P(name->name) |
| } |
| #undef FREE_P |
| |
| static void free_vps_res(vps_res *res) |
| { |
| free_fs(&res->fs); |
| free_tmpl(&res->tmpl); |
| free_ub(&res->ub); |
| free_net(&res->net); |
| free_misc(&res->misc); |
| free_dev(&res->dev); |
| free_pci(&res->pci); |
| free_cpu(&res->cpu); |
| free_dq(&res->dq); |
| free_cpt(&res->cpt); |
| free_veth_param(&res->veth); |
| free_name(&res->name); |
| } |
| |
| void free_vps_param(vps_param *param) |
| { |
| if (param == NULL) |
| return; |
| |
| free_opt(¶m->opt); |
| free_log_s(¶m->log); |
| free_vps_res(¶m->res); |
| free_vps_res(¶m->del_res); |
| free(param); |
| } |
| |
| #define MERGE_STR(x) \ |
| if ((src->x) != NULL) { \ |
| if ((dst->x) != NULL) \ |
| free(dst->x); \ |
| dst->x = strdup(src->x); \ |
| } |
| |
| #define MERGE_INT(x) if (src->x) dst->x = src->x; |
| |
| #define MERGE_INT2(x) if (src->x >= 0) dst->x = src->x; |
| |
| #define MERGE_P(x) \ |
| if ((src->x) != NULL) { \ |
| if ((dst->x) == NULL) \ |
| dst->x = malloc(sizeof(*(dst->x))); \ |
| *dst->x = *src->x; \ |
| } |
| |
| #define MERGE_P2(x) \ |
| if ((src->x) != NULL) { \ |
| if ((dst->x) == NULL) \ |
| dst->x = malloc(sizeof(*(dst->x)) * 2); \ |
| dst->x[0] = src->x[0]; \ |
| dst->x[1] = src->x[1]; \ |
| } |
| |
| static void merge_opt(vps_opt *dst, vps_opt *src) |
| { |
| MERGE_INT(save) |
| MERGE_INT(fast_kill) |
| MERGE_INT(skip_lock) |
| MERGE_INT(skip_setup) |
| MERGE_INT(start_disabled) |
| MERGE_INT(start_force) |
| MERGE_INT(setmode) |
| MERGE_INT(apply_cfg_map) |
| |
| MERGE_STR(config) |
| MERGE_STR(origin_sample) |
| MERGE_STR(apply_cfg) |
| } |
| |
| static void merge_fs(fs_param *dst, fs_param *src) |
| { |
| MERGE_STR(root) |
| MERGE_STR(root_orig) |
| MERGE_STR(private) |
| MERGE_STR(private_orig) |
| MERGE_STR(tmpl) |
| MERGE_INT(noatime) |
| } |
| |
| static void merge_tmpl(tmpl_param *dst, tmpl_param *src) |
| { |
| MERGE_STR(def_ostmpl) |
| MERGE_STR(ostmpl) |
| MERGE_STR(dist) |
| } |
| |
| static void merge_cpu(cpu_param *dst, cpu_param *src) |
| { |
| MERGE_P(units) |
| MERGE_P(weight) |
| MERGE_P(limit) |
| MERGE_P(vcpus) |
| MERGE_P(mask); |
| } |
| |
| #define MERGE_LIST(x) \ |
| if (!list_empty(&(src->x))) { \ |
| free_str_param(&(dst->x)); \ |
| copy_str_param(&(dst->x), &(src->x)); \ |
| } |
| |
| static void merge_net(net_param *dst, net_param *src) |
| { |
| MERGE_LIST(ip) |
| MERGE_LIST(dev) |
| MERGE_INT(delall) |
| MERGE_INT(skip_arpdetect) |
| } |
| |
| static void merge_misc(misc_param *dst, misc_param *src) |
| { |
| MERGE_LIST(nameserver) |
| MERGE_LIST(searchdomain) |
| MERGE_LIST(userpw) |
| MERGE_STR(hostname) |
| MERGE_STR(description) |
| MERGE_INT(onboot) |
| MERGE_P(bootorder) |
| MERGE_INT(wait) |
| } |
| |
| static void merge_dq(dq_param *dst, dq_param *src) |
| { |
| MERGE_INT(enable) |
| MERGE_P2(diskspace) |
| MERGE_P2(diskinodes) |
| MERGE_P(exptime) |
| MERGE_P(ugidlimit) |
| |
| } |
| |
| static void merge_dev(dev_param *dst, dev_param *src) |
| { |
| dev_res *cur; |
| |
| if (list_empty(&src->dev)) |
| return; |
| free_dev(dst); |
| list_for_each(cur, &src->dev, list) { |
| add_dev_param(dst, cur); |
| } |
| } |
| |
| static void merge_pci(pci_param *dst, pci_param *src) |
| { |
| MERGE_LIST(list) |
| } |
| |
| static void merge_cap(cap_param *dst, cap_param *src) |
| { |
| MERGE_INT(on) |
| MERGE_INT(off) |
| } |
| |
| static void merge_env(env_param_t *dst, env_param_t *src) |
| { |
| MERGE_INT(veid) |
| MERGE_INT(ipt_mask) |
| MERGE_INT(features_mask) |
| MERGE_INT(features_known) |
| } |
| |
| static void merge_cpt(cpt_param *dst, cpt_param *src) |
| { |
| MERGE_STR(dumpdir) |
| MERGE_STR(dumpfile) |
| MERGE_INT(ctx) |
| MERGE_INT(cpu_flags) |
| MERGE_INT(cmd) |
| } |
| |
| static void merge_meminfo(meminfo_param *dst, meminfo_param *src) |
| { |
| MERGE_INT2(mode) |
| MERGE_INT(val) |
| } |
| |
| static void merge_veth(veth_param *dst, veth_param *src) |
| { |
| if (!list_empty(&src->dev)) { |
| free_veth_param(dst); |
| copy_veth_param(dst, src); |
| } |
| } |
| |
| static void merge_name(name_param *dst, name_param *src) |
| { |
| MERGE_STR(name) |
| MERGE_INT(veid) |
| } |
| |
| static void merge_io(io_param *dst, io_param *src) { |
| MERGE_INT2(ioprio) |
| } |
| |
| static int merge_res(vps_res *dst, vps_res *src) |
| { |
| merge_fs(&dst->fs, &src->fs); |
| merge_tmpl(&dst->tmpl, &src->tmpl); |
| merge_ub(&dst->ub, &src->ub); |
| merge_net(&dst->net, &src->net); |
| merge_misc(&dst->misc, &src->misc); |
| merge_cpu(&dst->cpu, &src->cpu); |
| merge_cap(&dst->cap, &src->cap); |
| merge_dq(&dst->dq, &src->dq); |
| merge_dev(&dst->dev, &src->dev); |
| merge_pci(&dst->pci, &src->pci); |
| merge_env(&dst->env, &src->env); |
| merge_cpt(&dst->cpt, &src->cpt); |
| merge_meminfo(&dst->meminfo, &src->meminfo); |
| merge_veth(&dst->veth, &src->veth); |
| merge_name(&dst->name, &src->name); |
| merge_io(&dst->io, &src->io); |
| return 0; |
| } |
| |
| int merge_vps_param(vps_param *dst, vps_param *src) |
| { |
| merge_opt(&dst->opt, &src->opt); |
| merge_res(&dst->res, &src->res); |
| |
| return 0; |
| } |
| |
| int merge_global_param(vps_param *dst, vps_param *src) |
| { |
| MERGE_INT(res.net.ipv6_net) |
| MERGE_INT(del_res.net.ipv6_net) |
| return 0; |
| } |