1d62bc4baSyz /* 2d62bc4baSyz * CDDL HEADER START 3d62bc4baSyz * 4d62bc4baSyz * The contents of this file are subject to the terms of the 5d62bc4baSyz * Common Development and Distribution License (the "License"). 6d62bc4baSyz * You may not use this file except in compliance with the License. 7d62bc4baSyz * 8d62bc4baSyz * You can obtain a copy of the license at usr/src/OPENSOLARIS.LICENSE 9d62bc4baSyz * or http://www.opensolaris.org/os/licensing. 10d62bc4baSyz * See the License for the specific language governing permissions 11d62bc4baSyz * and limitations under the License. 12d62bc4baSyz * 13d62bc4baSyz * When distributing Covered Code, include this CDDL HEADER in each 14d62bc4baSyz * file and include the License file at usr/src/OPENSOLARIS.LICENSE. 15d62bc4baSyz * If applicable, add the following below this CDDL HEADER, with the 16d62bc4baSyz * fields enclosed by brackets "[]" replaced with your own identifying 17d62bc4baSyz * information: Portions Copyright [yyyy] [name of copyright owner] 18d62bc4baSyz * 19d62bc4baSyz * CDDL HEADER END 20d62bc4baSyz */ 21d62bc4baSyz 22d62bc4baSyz /* 236ba597c5SAnurag S. Maskey * Copyright 2010 Sun Microsystems, Inc. All rights reserved. 24d62bc4baSyz * Use is subject to license terms. 25d62bc4baSyz */ 26d62bc4baSyz 27d62bc4baSyz #include <assert.h> 28d62bc4baSyz #include <ctype.h> 29d62bc4baSyz #include <errno.h> 30d62bc4baSyz #include <fcntl.h> 31d62bc4baSyz #include <stdio.h> 32d62bc4baSyz #include <stdlib.h> 332b24ab6bSSebastien Roy #include <string.h> 34d62bc4baSyz #include <strings.h> 35d62bc4baSyz #include <syslog.h> 362b24ab6bSSebastien Roy #include <zone.h> 372b24ab6bSSebastien Roy #include <sys/types.h> 38d62bc4baSyz #include <sys/stat.h> 392b24ab6bSSebastien Roy #include <stropts.h> 402b24ab6bSSebastien Roy #include <sys/conf.h> 41d62bc4baSyz #include <pthread.h> 42d62bc4baSyz #include <unistd.h> 432b24ab6bSSebastien Roy #include <wait.h> 442b24ab6bSSebastien Roy #include <libcontract.h> 45*5b310668SDarren Reed #include <libcontract_priv.h> 462b24ab6bSSebastien Roy #include <sys/contract/process.h> 47d62bc4baSyz #include "dlmgmt_impl.h" 48d62bc4baSyz 49d62bc4baSyz typedef enum dlmgmt_db_op { 50d62bc4baSyz DLMGMT_DB_OP_WRITE, 51d62bc4baSyz DLMGMT_DB_OP_DELETE, 52d62bc4baSyz DLMGMT_DB_OP_READ 53d62bc4baSyz } dlmgmt_db_op_t; 54d62bc4baSyz 55d62bc4baSyz typedef struct dlmgmt_db_req_s { 56d62bc4baSyz struct dlmgmt_db_req_s *ls_next; 57d62bc4baSyz dlmgmt_db_op_t ls_op; 582b24ab6bSSebastien Roy char ls_link[MAXLINKNAMELEN]; 59d62bc4baSyz datalink_id_t ls_linkid; 602b24ab6bSSebastien Roy zoneid_t ls_zoneid; 61d62bc4baSyz uint32_t ls_flags; /* Either DLMGMT_ACTIVE or */ 62d62bc4baSyz /* DLMGMT_PERSIST, not both. */ 63d62bc4baSyz } dlmgmt_db_req_t; 64d62bc4baSyz 65d62bc4baSyz /* 66d62bc4baSyz * List of pending db updates (e.g., because of a read-only filesystem). 67d62bc4baSyz */ 68d62bc4baSyz static dlmgmt_db_req_t *dlmgmt_db_req_head = NULL; 69d62bc4baSyz static dlmgmt_db_req_t *dlmgmt_db_req_tail = NULL; 70d62bc4baSyz 712b24ab6bSSebastien Roy /* 722b24ab6bSSebastien Roy * rewrite_needed is set to B_TRUE by process_link_line() if it encounters a 732b24ab6bSSebastien Roy * line with an old format. This will cause the file being read to be 742b24ab6bSSebastien Roy * re-written with the current format. 752b24ab6bSSebastien Roy */ 762b24ab6bSSebastien Roy static boolean_t rewrite_needed; 772b24ab6bSSebastien Roy 782b24ab6bSSebastien Roy static int dlmgmt_db_update(dlmgmt_db_op_t, const char *, 792b24ab6bSSebastien Roy dlmgmt_link_t *, uint32_t); 80d62bc4baSyz static int dlmgmt_process_db_req(dlmgmt_db_req_t *); 81d62bc4baSyz static int dlmgmt_process_db_onereq(dlmgmt_db_req_t *, boolean_t); 82d62bc4baSyz static void *dlmgmt_db_update_thread(void *); 832b24ab6bSSebastien Roy static boolean_t process_link_line(char *, dlmgmt_link_t *); 84d62bc4baSyz static int process_db_write(dlmgmt_db_req_t *, FILE *, FILE *); 852b24ab6bSSebastien Roy static int process_db_read(dlmgmt_db_req_t *, FILE *); 86d62bc4baSyz static void generate_link_line(dlmgmt_link_t *, boolean_t, char *); 87d62bc4baSyz 88d62bc4baSyz #define BUFLEN(lim, ptr) (((lim) > (ptr)) ? ((lim) - (ptr)) : 0) 89d62bc4baSyz #define MAXLINELEN 1024 90d62bc4baSyz 912b24ab6bSSebastien Roy typedef void db_walk_func_t(dlmgmt_link_t *); 922b24ab6bSSebastien Roy 93d62bc4baSyz /* 94d62bc4baSyz * Translator functions to go from dladm_datatype_t to character strings. 95d62bc4baSyz * Each function takes a pointer to a buffer, the size of the buffer, 96d62bc4baSyz * the name of the attribute, and the value to be written. The functions 97d62bc4baSyz * return the number of bytes written to the buffer. If the buffer is not big 98d62bc4baSyz * enough to hold the string representing the value, then nothing is written 99d62bc4baSyz * and 0 is returned. 100d62bc4baSyz */ 101d62bc4baSyz typedef size_t write_func_t(char *, size_t, char *, void *); 102d62bc4baSyz 103d62bc4baSyz /* 104d62bc4baSyz * Translator functions to read from a NULL terminated string buffer into 105d62bc4baSyz * something of the given DLADM_TYPE_*. The functions each return the number 106d62bc4baSyz * of bytes read from the string buffer. If there is an error reading data 107d62bc4baSyz * from the buffer, then 0 is returned. It is the caller's responsibility 108d62bc4baSyz * to free the data allocated by these functions. 109d62bc4baSyz */ 110d62bc4baSyz typedef size_t read_func_t(char *, void **); 111d62bc4baSyz 112d62bc4baSyz typedef struct translator_s { 113d62bc4baSyz const char *type_name; 114d62bc4baSyz write_func_t *write_func; 115d62bc4baSyz read_func_t *read_func; 116d62bc4baSyz } translator_t; 117d62bc4baSyz 118d62bc4baSyz /* 119d62bc4baSyz * Translator functions, defined later but declared here so that 120d62bc4baSyz * the translator table can be defined. 121d62bc4baSyz */ 122d62bc4baSyz static write_func_t write_str, write_boolean, write_uint64; 123d62bc4baSyz static read_func_t read_str, read_boolean, read_int64; 124d62bc4baSyz 125d62bc4baSyz /* 126d62bc4baSyz * Translator table, indexed by dladm_datatype_t. 127d62bc4baSyz */ 128d62bc4baSyz static translator_t translators[] = { 129d62bc4baSyz { "string", write_str, read_str }, 130d62bc4baSyz { "boolean", write_boolean, read_boolean }, 131d62bc4baSyz { "int", write_uint64, read_int64 } 132d62bc4baSyz }; 133d62bc4baSyz 134d62bc4baSyz static size_t ntranslators = sizeof (translators) / sizeof (translator_t); 135d62bc4baSyz 136d62bc4baSyz #define LINK_PROPERTY_DELIMINATOR ";" 137d62bc4baSyz #define LINK_PROPERTY_TYPE_VALUE_SEP "," 138d62bc4baSyz #define BASE_PROPERTY_LENGTH(t, n) (strlen(translators[(t)].type_name) +\ 139d62bc4baSyz strlen(LINK_PROPERTY_TYPE_VALUE_SEP) +\ 140d62bc4baSyz strlen(LINK_PROPERTY_DELIMINATOR) +\ 141d62bc4baSyz strlen((n))) 142d62bc4baSyz #define GENERATE_PROPERTY_STRING(buf, length, conv, name, type, val) \ 143d62bc4baSyz (snprintf((buf), (length), "%s=%s%s" conv "%s", (name), \ 144d62bc4baSyz translators[(type)].type_name, \ 145d62bc4baSyz LINK_PROPERTY_TYPE_VALUE_SEP, (val), LINK_PROPERTY_DELIMINATOR)) 146d62bc4baSyz 147d62bc4baSyz /* 148d62bc4baSyz * Name of the cache file to keep the active <link name, linkid> mapping 149d62bc4baSyz */ 1502b24ab6bSSebastien Roy char cachefile[MAXPATHLEN]; 151d62bc4baSyz 152d62bc4baSyz #define DLMGMT_PERSISTENT_DB_PATH "/etc/dladm/datalink.conf" 153d62bc4baSyz #define DLMGMT_MAKE_FILE_DB_PATH(buffer, persistent) \ 154d62bc4baSyz (void) snprintf((buffer), MAXPATHLEN, "%s", \ 155d62bc4baSyz (persistent) ? DLMGMT_PERSISTENT_DB_PATH : cachefile); 156d62bc4baSyz 1572b24ab6bSSebastien Roy typedef struct zopen_arg { 1582b24ab6bSSebastien Roy const char *zopen_modestr; 1592b24ab6bSSebastien Roy int *zopen_pipe; 1602b24ab6bSSebastien Roy int zopen_fd; 1612b24ab6bSSebastien Roy } zopen_arg_t; 1622b24ab6bSSebastien Roy 1632b24ab6bSSebastien Roy typedef struct zrename_arg { 1642b24ab6bSSebastien Roy const char *zrename_newname; 1652b24ab6bSSebastien Roy } zrename_arg_t; 1662b24ab6bSSebastien Roy 1672b24ab6bSSebastien Roy typedef union zfoparg { 1682b24ab6bSSebastien Roy zopen_arg_t zfop_openarg; 1692b24ab6bSSebastien Roy zrename_arg_t zfop_renamearg; 1702b24ab6bSSebastien Roy } zfoparg_t; 1712b24ab6bSSebastien Roy 1722b24ab6bSSebastien Roy typedef struct zfcbarg { 1732b24ab6bSSebastien Roy boolean_t zfarg_inglobalzone; /* is callback in global zone? */ 1742b24ab6bSSebastien Roy zoneid_t zfarg_finglobalzone; /* is file in global zone? */ 1752b24ab6bSSebastien Roy const char *zfarg_filename; 1762b24ab6bSSebastien Roy zfoparg_t *zfarg_oparg; 1772b24ab6bSSebastien Roy } zfarg_t; 1782b24ab6bSSebastien Roy #define zfarg_openarg zfarg_oparg->zfop_openarg 1792b24ab6bSSebastien Roy #define zfarg_renamearg zfarg_oparg->zfop_renamearg 1802b24ab6bSSebastien Roy 1812b24ab6bSSebastien Roy /* zone file callback */ 1822b24ab6bSSebastien Roy typedef int zfcb_t(zfarg_t *); 1832b24ab6bSSebastien Roy 1842b24ab6bSSebastien Roy /* 1852b24ab6bSSebastien Roy * Execute an operation on filename relative to zoneid's zone root. If the 1862b24ab6bSSebastien Roy * file is in the global zone, then the zfcb() callback will simply be called 1872b24ab6bSSebastien Roy * directly. If the file is in a non-global zone, then zfcb() will be called 1882b24ab6bSSebastien Roy * both from the global zone's context, and from the non-global zone's context 1892b24ab6bSSebastien Roy * (from a fork()'ed child that has entered the non-global zone). This is 1902b24ab6bSSebastien Roy * done to allow the callback to communicate with itself if needed (e.g. to 1912b24ab6bSSebastien Roy * pass back the file descriptor of an opened file). 1922b24ab6bSSebastien Roy */ 1932b24ab6bSSebastien Roy static int 1942b24ab6bSSebastien Roy dlmgmt_zfop(const char *filename, zoneid_t zoneid, zfcb_t *zfcb, 1952b24ab6bSSebastien Roy zfoparg_t *zfoparg) 1962b24ab6bSSebastien Roy { 1972b24ab6bSSebastien Roy int ctfd; 1982b24ab6bSSebastien Roy int err; 1992b24ab6bSSebastien Roy pid_t childpid; 2002b24ab6bSSebastien Roy siginfo_t info; 2012b24ab6bSSebastien Roy zfarg_t zfarg; 2020572408dSDarren Reed ctid_t ct; 2032b24ab6bSSebastien Roy 2042b24ab6bSSebastien Roy if (zoneid != GLOBAL_ZONEID) { 2052b24ab6bSSebastien Roy /* 2062b24ab6bSSebastien Roy * We need to access a file that isn't in the global zone. 2072b24ab6bSSebastien Roy * Accessing non-global zone files from the global zone is 2082b24ab6bSSebastien Roy * unsafe (due to symlink attacks), we'll need to fork a child 2092b24ab6bSSebastien Roy * that enters the zone in question and executes the callback 2102b24ab6bSSebastien Roy * that will operate on the file. 2112b24ab6bSSebastien Roy * 2122b24ab6bSSebastien Roy * Before we proceed with this zone tango, we need to create a 2132b24ab6bSSebastien Roy * new process contract for the child, as required by 2142b24ab6bSSebastien Roy * zone_enter(). 2152b24ab6bSSebastien Roy */ 2162b24ab6bSSebastien Roy errno = 0; 2172b24ab6bSSebastien Roy ctfd = open64("/system/contract/process/template", O_RDWR); 2182b24ab6bSSebastien Roy if (ctfd == -1) 2192b24ab6bSSebastien Roy return (errno); 2202b24ab6bSSebastien Roy if ((err = ct_tmpl_set_critical(ctfd, 0)) != 0 || 2212b24ab6bSSebastien Roy (err = ct_tmpl_set_informative(ctfd, 0)) != 0 || 2222b24ab6bSSebastien Roy (err = ct_pr_tmpl_set_fatal(ctfd, CT_PR_EV_HWERR)) != 0 || 2232b24ab6bSSebastien Roy (err = ct_pr_tmpl_set_param(ctfd, CT_PR_PGRPONLY)) != 0 || 2242b24ab6bSSebastien Roy (err = ct_tmpl_activate(ctfd)) != 0) { 2250572408dSDarren Reed (void) close(ctfd); 2262b24ab6bSSebastien Roy return (err); 2272b24ab6bSSebastien Roy } 2282b24ab6bSSebastien Roy childpid = fork(); 2292b24ab6bSSebastien Roy switch (childpid) { 2302b24ab6bSSebastien Roy case -1: 2310572408dSDarren Reed (void) ct_tmpl_clear(ctfd); 2320572408dSDarren Reed (void) close(ctfd); 2332b24ab6bSSebastien Roy return (err); 2342b24ab6bSSebastien Roy case 0: 2350572408dSDarren Reed (void) ct_tmpl_clear(ctfd); 2360572408dSDarren Reed (void) close(ctfd); 2372b24ab6bSSebastien Roy /* 2382b24ab6bSSebastien Roy * Elevate our privileges as zone_enter() requires all 2392b24ab6bSSebastien Roy * privileges. 2402b24ab6bSSebastien Roy */ 2412b24ab6bSSebastien Roy if ((err = dlmgmt_elevate_privileges()) != 0) 2422b24ab6bSSebastien Roy _exit(err); 2432b24ab6bSSebastien Roy if (zone_enter(zoneid) == -1) 2442b24ab6bSSebastien Roy _exit(errno); 2452b24ab6bSSebastien Roy if ((err = dlmgmt_drop_privileges()) != 0) 2462b24ab6bSSebastien Roy _exit(err); 2472b24ab6bSSebastien Roy break; 2482b24ab6bSSebastien Roy default: 2490572408dSDarren Reed if (contract_latest(&ct) == -1) 2500572408dSDarren Reed ct = -1; 2510572408dSDarren Reed (void) ct_tmpl_clear(ctfd); 2520572408dSDarren Reed (void) close(ctfd); 2530572408dSDarren Reed if (waitid(P_PID, childpid, &info, WEXITED) == -1) { 2540572408dSDarren Reed (void) contract_abandon_id(ct); 2552b24ab6bSSebastien Roy return (errno); 2560572408dSDarren Reed } 2570572408dSDarren Reed (void) contract_abandon_id(ct); 2582b24ab6bSSebastien Roy if (info.si_status != 0) 2592b24ab6bSSebastien Roy return (info.si_status); 2602b24ab6bSSebastien Roy } 2612b24ab6bSSebastien Roy } 2622b24ab6bSSebastien Roy 2632b24ab6bSSebastien Roy zfarg.zfarg_inglobalzone = (zoneid == GLOBAL_ZONEID || childpid != 0); 2642b24ab6bSSebastien Roy zfarg.zfarg_finglobalzone = (zoneid == GLOBAL_ZONEID); 2652b24ab6bSSebastien Roy zfarg.zfarg_filename = filename; 2662b24ab6bSSebastien Roy zfarg.zfarg_oparg = zfoparg; 2672b24ab6bSSebastien Roy err = zfcb(&zfarg); 2682b24ab6bSSebastien Roy if (!zfarg.zfarg_inglobalzone) 2692b24ab6bSSebastien Roy _exit(err); 2702b24ab6bSSebastien Roy return (err); 2712b24ab6bSSebastien Roy } 2722b24ab6bSSebastien Roy 2732b24ab6bSSebastien Roy static int 2742b24ab6bSSebastien Roy dlmgmt_zopen_cb(zfarg_t *zfarg) 2752b24ab6bSSebastien Roy { 2762b24ab6bSSebastien Roy struct strrecvfd recvfd; 2772b24ab6bSSebastien Roy boolean_t newfile = B_FALSE; 2782b24ab6bSSebastien Roy boolean_t inglobalzone = zfarg->zfarg_inglobalzone; 2792b24ab6bSSebastien Roy zoneid_t finglobalzone = zfarg->zfarg_finglobalzone; 2802b24ab6bSSebastien Roy const char *filename = zfarg->zfarg_filename; 2812b24ab6bSSebastien Roy const char *modestr = zfarg->zfarg_openarg.zopen_modestr; 2822b24ab6bSSebastien Roy int *p = zfarg->zfarg_openarg.zopen_pipe; 2832b24ab6bSSebastien Roy struct stat statbuf; 2842b24ab6bSSebastien Roy int oflags; 2852b24ab6bSSebastien Roy mode_t mode; 2862b24ab6bSSebastien Roy int fd = -1; 2872b24ab6bSSebastien Roy int err; 2882b24ab6bSSebastien Roy 2892b24ab6bSSebastien Roy /* We only ever open a file for reading or writing, not both. */ 2902b24ab6bSSebastien Roy oflags = (modestr[0] == 'r') ? O_RDONLY : O_WRONLY | O_CREAT | O_TRUNC; 2912b24ab6bSSebastien Roy mode = (modestr[0] == 'r') ? 0 : S_IRUSR | S_IWUSR | S_IRGRP | S_IROTH; 2922b24ab6bSSebastien Roy 2932b24ab6bSSebastien Roy /* Open the file if we're in the same zone as the file. */ 2942b24ab6bSSebastien Roy if (inglobalzone == finglobalzone) { 2952b24ab6bSSebastien Roy /* 2962b24ab6bSSebastien Roy * First determine if we will be creating the file as part of 2972b24ab6bSSebastien Roy * opening it. If so, then we'll need to ensure that it has 2982b24ab6bSSebastien Roy * the proper ownership after having opened it. 2992b24ab6bSSebastien Roy */ 3002b24ab6bSSebastien Roy if (oflags & O_CREAT) { 3012b24ab6bSSebastien Roy if (stat(filename, &statbuf) == -1) { 3022b24ab6bSSebastien Roy if (errno == ENOENT) 3032b24ab6bSSebastien Roy newfile = B_TRUE; 3042b24ab6bSSebastien Roy else 3052b24ab6bSSebastien Roy return (errno); 3062b24ab6bSSebastien Roy } 3072b24ab6bSSebastien Roy } 3082b24ab6bSSebastien Roy if ((fd = open(filename, oflags, mode)) == -1) 3092b24ab6bSSebastien Roy return (errno); 3102b24ab6bSSebastien Roy if (newfile) { 3116ba597c5SAnurag S. Maskey if (chown(filename, UID_DLADM, GID_NETADM) == -1) { 3122b24ab6bSSebastien Roy err = errno; 3132b24ab6bSSebastien Roy (void) close(fd); 3142b24ab6bSSebastien Roy return (err); 3152b24ab6bSSebastien Roy } 3162b24ab6bSSebastien Roy } 3172b24ab6bSSebastien Roy } 3182b24ab6bSSebastien Roy 3192b24ab6bSSebastien Roy /* 3202b24ab6bSSebastien Roy * If we're not in the global zone, send the file-descriptor back to 3212b24ab6bSSebastien Roy * our parent in the global zone. 3222b24ab6bSSebastien Roy */ 3232b24ab6bSSebastien Roy if (!inglobalzone) { 3242b24ab6bSSebastien Roy assert(!finglobalzone); 3252b24ab6bSSebastien Roy assert(fd != -1); 3262b24ab6bSSebastien Roy return (ioctl(p[1], I_SENDFD, fd) == -1 ? errno : 0); 3272b24ab6bSSebastien Roy } 3282b24ab6bSSebastien Roy 3292b24ab6bSSebastien Roy /* 3302b24ab6bSSebastien Roy * At this point, we know we're in the global zone. If the file was 3312b24ab6bSSebastien Roy * in a non-global zone, receive the file-descriptor from our child in 3322b24ab6bSSebastien Roy * the non-global zone. 3332b24ab6bSSebastien Roy */ 3342b24ab6bSSebastien Roy if (!finglobalzone) { 3352b24ab6bSSebastien Roy if (ioctl(p[0], I_RECVFD, &recvfd) == -1) 3362b24ab6bSSebastien Roy return (errno); 3372b24ab6bSSebastien Roy fd = recvfd.fd; 3382b24ab6bSSebastien Roy } 3392b24ab6bSSebastien Roy 3402b24ab6bSSebastien Roy zfarg->zfarg_openarg.zopen_fd = fd; 3412b24ab6bSSebastien Roy return (0); 3422b24ab6bSSebastien Roy } 3432b24ab6bSSebastien Roy 3442b24ab6bSSebastien Roy static int 3452b24ab6bSSebastien Roy dlmgmt_zunlink_cb(zfarg_t *zfarg) 3462b24ab6bSSebastien Roy { 3472b24ab6bSSebastien Roy if (zfarg->zfarg_inglobalzone != zfarg->zfarg_finglobalzone) 3482b24ab6bSSebastien Roy return (0); 3492b24ab6bSSebastien Roy return (unlink(zfarg->zfarg_filename) == 0 ? 0 : errno); 3502b24ab6bSSebastien Roy } 3512b24ab6bSSebastien Roy 3522b24ab6bSSebastien Roy static int 3532b24ab6bSSebastien Roy dlmgmt_zrename_cb(zfarg_t *zfarg) 3542b24ab6bSSebastien Roy { 3552b24ab6bSSebastien Roy if (zfarg->zfarg_inglobalzone != zfarg->zfarg_finglobalzone) 3562b24ab6bSSebastien Roy return (0); 3572b24ab6bSSebastien Roy return (rename(zfarg->zfarg_filename, 3582b24ab6bSSebastien Roy zfarg->zfarg_renamearg.zrename_newname) == 0 ? 0 : errno); 3592b24ab6bSSebastien Roy } 3602b24ab6bSSebastien Roy 3612b24ab6bSSebastien Roy /* 3622b24ab6bSSebastien Roy * Same as fopen(3C), except that it opens the file relative to zoneid's zone 3632b24ab6bSSebastien Roy * root. 3642b24ab6bSSebastien Roy */ 3652b24ab6bSSebastien Roy static FILE * 3662b24ab6bSSebastien Roy dlmgmt_zfopen(const char *filename, const char *modestr, zoneid_t zoneid, 3672b24ab6bSSebastien Roy int *err) 3682b24ab6bSSebastien Roy { 3692b24ab6bSSebastien Roy int p[2]; 3702b24ab6bSSebastien Roy zfoparg_t zfoparg; 3712b24ab6bSSebastien Roy FILE *fp = NULL; 3722b24ab6bSSebastien Roy 3732b24ab6bSSebastien Roy if (zoneid != GLOBAL_ZONEID && pipe(p) == -1) { 3742b24ab6bSSebastien Roy *err = errno; 3752b24ab6bSSebastien Roy return (NULL); 3762b24ab6bSSebastien Roy } 3772b24ab6bSSebastien Roy 3782b24ab6bSSebastien Roy zfoparg.zfop_openarg.zopen_modestr = modestr; 3792b24ab6bSSebastien Roy zfoparg.zfop_openarg.zopen_pipe = p; 3802b24ab6bSSebastien Roy *err = dlmgmt_zfop(filename, zoneid, dlmgmt_zopen_cb, &zfoparg); 3812b24ab6bSSebastien Roy if (zoneid != GLOBAL_ZONEID) { 3822b24ab6bSSebastien Roy (void) close(p[0]); 3832b24ab6bSSebastien Roy (void) close(p[1]); 3842b24ab6bSSebastien Roy } 3852b24ab6bSSebastien Roy if (*err == 0) { 3862b24ab6bSSebastien Roy fp = fdopen(zfoparg.zfop_openarg.zopen_fd, modestr); 3872b24ab6bSSebastien Roy if (fp == NULL) { 3882b24ab6bSSebastien Roy *err = errno; 3892b24ab6bSSebastien Roy (void) close(zfoparg.zfop_openarg.zopen_fd); 3902b24ab6bSSebastien Roy } 3912b24ab6bSSebastien Roy } 3922b24ab6bSSebastien Roy return (fp); 3932b24ab6bSSebastien Roy } 3942b24ab6bSSebastien Roy 3952b24ab6bSSebastien Roy /* 3962b24ab6bSSebastien Roy * Same as rename(2), except that old and new are relative to zoneid's zone 3972b24ab6bSSebastien Roy * root. 3982b24ab6bSSebastien Roy */ 3992b24ab6bSSebastien Roy static int 4002b24ab6bSSebastien Roy dlmgmt_zrename(const char *old, const char *new, zoneid_t zoneid) 4012b24ab6bSSebastien Roy { 4022b24ab6bSSebastien Roy zfoparg_t zfoparg; 4032b24ab6bSSebastien Roy 4042b24ab6bSSebastien Roy zfoparg.zfop_renamearg.zrename_newname = new; 4052b24ab6bSSebastien Roy return (dlmgmt_zfop(old, zoneid, dlmgmt_zrename_cb, &zfoparg)); 4062b24ab6bSSebastien Roy } 4072b24ab6bSSebastien Roy 4082b24ab6bSSebastien Roy /* 4092b24ab6bSSebastien Roy * Same as unlink(2), except that filename is relative to zoneid's zone root. 4102b24ab6bSSebastien Roy */ 4112b24ab6bSSebastien Roy static int 4122b24ab6bSSebastien Roy dlmgmt_zunlink(const char *filename, zoneid_t zoneid) 4132b24ab6bSSebastien Roy { 4142b24ab6bSSebastien Roy return (dlmgmt_zfop(filename, zoneid, dlmgmt_zunlink_cb, NULL)); 4152b24ab6bSSebastien Roy } 4162b24ab6bSSebastien Roy 417d62bc4baSyz static size_t 418d62bc4baSyz write_str(char *buffer, size_t buffer_length, char *name, void *value) 419d62bc4baSyz { 420d62bc4baSyz char *ptr = value; 421d62bc4baSyz size_t data_length = strnlen(ptr, buffer_length); 422d62bc4baSyz 423d62bc4baSyz /* 424d62bc4baSyz * Strings are assumed to be NULL terminated. In order to fit in 425d62bc4baSyz * the buffer, the string's length must be less then buffer_length. 426d62bc4baSyz * If the value is empty, there's no point in writing it, in fact, 427d62bc4baSyz * we shouldn't even see that case. 428d62bc4baSyz */ 429d62bc4baSyz if (data_length + BASE_PROPERTY_LENGTH(DLADM_TYPE_STR, name) == 430d62bc4baSyz buffer_length || data_length == 0) 431d62bc4baSyz return (0); 432d62bc4baSyz 433d62bc4baSyz /* 434d62bc4baSyz * Since we know the string will fit in the buffer, snprintf will 435d62bc4baSyz * always return less than buffer_length, so we can just return 436d62bc4baSyz * whatever snprintf returns. 437d62bc4baSyz */ 438d62bc4baSyz return (GENERATE_PROPERTY_STRING(buffer, buffer_length, "%s", 439d62bc4baSyz name, DLADM_TYPE_STR, ptr)); 440d62bc4baSyz } 441d62bc4baSyz 442d62bc4baSyz static size_t 443d62bc4baSyz write_boolean(char *buffer, size_t buffer_length, char *name, void *value) 444d62bc4baSyz { 445d62bc4baSyz boolean_t *ptr = value; 446d62bc4baSyz 447d62bc4baSyz /* 448d62bc4baSyz * Booleans are either zero or one, so we only need room for two 449d62bc4baSyz * characters in the buffer. 450d62bc4baSyz */ 451d62bc4baSyz if (buffer_length <= 1 + BASE_PROPERTY_LENGTH(DLADM_TYPE_BOOLEAN, name)) 452d62bc4baSyz return (0); 453d62bc4baSyz 454d62bc4baSyz return (GENERATE_PROPERTY_STRING(buffer, buffer_length, "%d", 455d62bc4baSyz name, DLADM_TYPE_BOOLEAN, *ptr)); 456d62bc4baSyz } 457d62bc4baSyz 458d62bc4baSyz static size_t 459d62bc4baSyz write_uint64(char *buffer, size_t buffer_length, char *name, void *value) 460d62bc4baSyz { 461d62bc4baSyz uint64_t *ptr = value; 462d62bc4baSyz 463d62bc4baSyz /* 464d62bc4baSyz * Limit checking for uint64_t is a little trickier. 465d62bc4baSyz */ 466d62bc4baSyz if (snprintf(NULL, 0, "%lld", *ptr) + 467d62bc4baSyz BASE_PROPERTY_LENGTH(DLADM_TYPE_UINT64, name) >= buffer_length) 468d62bc4baSyz return (0); 469d62bc4baSyz 470d62bc4baSyz return (GENERATE_PROPERTY_STRING(buffer, buffer_length, "%lld", 471d62bc4baSyz name, DLADM_TYPE_UINT64, *ptr)); 472d62bc4baSyz } 473d62bc4baSyz 474d62bc4baSyz static size_t 475d62bc4baSyz read_str(char *buffer, void **value) 476d62bc4baSyz { 477024b0a25Sseb char *ptr = calloc(MAXLINKATTRVALLEN, sizeof (char)); 478d62bc4baSyz ssize_t len; 479d62bc4baSyz 480024b0a25Sseb if (ptr == NULL || (len = strlcpy(ptr, buffer, MAXLINKATTRVALLEN)) 481024b0a25Sseb >= MAXLINKATTRVALLEN) { 482d62bc4baSyz free(ptr); 483d62bc4baSyz return (0); 484d62bc4baSyz } 485d62bc4baSyz 486d62bc4baSyz *(char **)value = ptr; 487d62bc4baSyz 488d62bc4baSyz /* Account for NULL terminator */ 489d62bc4baSyz return (len + 1); 490d62bc4baSyz } 491d62bc4baSyz 492d62bc4baSyz static size_t 493d62bc4baSyz read_boolean(char *buffer, void **value) 494d62bc4baSyz { 495d62bc4baSyz boolean_t *ptr = calloc(1, sizeof (boolean_t)); 496d62bc4baSyz 497d62bc4baSyz if (ptr == NULL) 498d62bc4baSyz return (0); 499d62bc4baSyz 500d62bc4baSyz *ptr = atoi(buffer); 501d62bc4baSyz *(boolean_t **)value = ptr; 502d62bc4baSyz 503d62bc4baSyz return (sizeof (boolean_t)); 504d62bc4baSyz } 505d62bc4baSyz 506d62bc4baSyz static size_t 507d62bc4baSyz read_int64(char *buffer, void **value) 508d62bc4baSyz { 509d62bc4baSyz int64_t *ptr = calloc(1, sizeof (int64_t)); 510d62bc4baSyz 511d62bc4baSyz if (ptr == NULL) 512d62bc4baSyz return (0); 513d62bc4baSyz 514d62bc4baSyz *ptr = (int64_t)atoll(buffer); 515d62bc4baSyz *(int64_t **)value = ptr; 516d62bc4baSyz 517d62bc4baSyz return (sizeof (int64_t)); 518d62bc4baSyz } 519d62bc4baSyz 5202b24ab6bSSebastien Roy static dlmgmt_db_req_t * 5212b24ab6bSSebastien Roy dlmgmt_db_req_alloc(dlmgmt_db_op_t op, const char *linkname, 5222b24ab6bSSebastien Roy datalink_id_t linkid, zoneid_t zoneid, uint32_t flags, int *err) 5232b24ab6bSSebastien Roy { 5242b24ab6bSSebastien Roy dlmgmt_db_req_t *req; 5252b24ab6bSSebastien Roy 5262b24ab6bSSebastien Roy if ((req = calloc(1, sizeof (dlmgmt_db_req_t))) == NULL) { 5272b24ab6bSSebastien Roy *err = errno; 5282b24ab6bSSebastien Roy } else { 5292b24ab6bSSebastien Roy req->ls_op = op; 5302b24ab6bSSebastien Roy if (linkname != NULL) 5312b24ab6bSSebastien Roy (void) strlcpy(req->ls_link, linkname, MAXLINKNAMELEN); 5322b24ab6bSSebastien Roy req->ls_linkid = linkid; 5332b24ab6bSSebastien Roy req->ls_zoneid = zoneid; 5342b24ab6bSSebastien Roy req->ls_flags = flags; 5352b24ab6bSSebastien Roy } 5362b24ab6bSSebastien Roy return (req); 5372b24ab6bSSebastien Roy } 5382b24ab6bSSebastien Roy 5392b24ab6bSSebastien Roy /* 5402b24ab6bSSebastien Roy * Update the db entry with name "entryname" using information from "linkp". 5412b24ab6bSSebastien Roy */ 542d62bc4baSyz static int 5432b24ab6bSSebastien Roy dlmgmt_db_update(dlmgmt_db_op_t op, const char *entryname, dlmgmt_link_t *linkp, 5442b24ab6bSSebastien Roy uint32_t flags) 545d62bc4baSyz { 546d62bc4baSyz dlmgmt_db_req_t *req; 547d62bc4baSyz int err; 548d62bc4baSyz 5492b24ab6bSSebastien Roy /* It is either a persistent request or an active request, not both. */ 550d62bc4baSyz assert((flags == DLMGMT_PERSIST) || (flags == DLMGMT_ACTIVE)); 551d62bc4baSyz 5522b24ab6bSSebastien Roy if ((req = dlmgmt_db_req_alloc(op, entryname, linkp->ll_linkid, 5532b24ab6bSSebastien Roy linkp->ll_zoneid, flags, &err)) == NULL) 5542b24ab6bSSebastien Roy return (err); 555d62bc4baSyz 556d62bc4baSyz /* 557d62bc4baSyz * If the return error is EINPROGRESS, this request is handled 558d62bc4baSyz * asynchronously; return success. 559d62bc4baSyz */ 560d62bc4baSyz err = dlmgmt_process_db_req(req); 561d62bc4baSyz if (err != EINPROGRESS) 562d62bc4baSyz free(req); 563d62bc4baSyz else 564d62bc4baSyz err = 0; 565d62bc4baSyz return (err); 566d62bc4baSyz } 567d62bc4baSyz 568d62bc4baSyz #define DLMGMT_DB_OP_STR(op) \ 569d62bc4baSyz (((op) == DLMGMT_DB_OP_READ) ? "read" : \ 570d62bc4baSyz (((op) == DLMGMT_DB_OP_WRITE) ? "write" : "delete")) 571d62bc4baSyz 572d62bc4baSyz #define DLMGMT_DB_CONF_STR(flag) \ 573d62bc4baSyz (((flag) == DLMGMT_ACTIVE) ? "active" : \ 574d62bc4baSyz (((flag) == DLMGMT_PERSIST) ? "persistent" : "")) 575d62bc4baSyz 576d62bc4baSyz static int 577d62bc4baSyz dlmgmt_process_db_req(dlmgmt_db_req_t *req) 578d62bc4baSyz { 579d62bc4baSyz pthread_t tid; 580d62bc4baSyz boolean_t writeop; 581d62bc4baSyz int err; 582d62bc4baSyz 583d62bc4baSyz /* 584d62bc4baSyz * If there are already pending "write" requests, queue this request in 585d62bc4baSyz * the pending list. Note that this function is called while the 586d62bc4baSyz * dlmgmt_rw_lock is held, so it is safe to access the global variables. 587d62bc4baSyz */ 588d62bc4baSyz writeop = (req->ls_op != DLMGMT_DB_OP_READ); 589d62bc4baSyz if (writeop && (req->ls_flags == DLMGMT_PERSIST) && 590d62bc4baSyz (dlmgmt_db_req_head != NULL)) { 591d62bc4baSyz dlmgmt_db_req_tail->ls_next = req; 592d62bc4baSyz dlmgmt_db_req_tail = req; 593d62bc4baSyz return (EINPROGRESS); 594d62bc4baSyz } 595d62bc4baSyz 596d62bc4baSyz err = dlmgmt_process_db_onereq(req, writeop); 5972b24ab6bSSebastien Roy if (err != EINPROGRESS && err != 0 && err != ENOENT) { 598d62bc4baSyz /* 5992b24ab6bSSebastien Roy * Log the error unless the request processing is still in 6002b24ab6bSSebastien Roy * progress or if the configuration file hasn't been created 6012b24ab6bSSebastien Roy * yet (ENOENT). 602d62bc4baSyz */ 603d62bc4baSyz dlmgmt_log(LOG_WARNING, "dlmgmt_process_db_onereq() %s " 604d62bc4baSyz "operation on %s configuration failed: %s", 605d62bc4baSyz DLMGMT_DB_OP_STR(req->ls_op), 606d62bc4baSyz DLMGMT_DB_CONF_STR(req->ls_flags), strerror(err)); 607d62bc4baSyz } 608d62bc4baSyz 609d62bc4baSyz if (err == EINPROGRESS) { 610d62bc4baSyz assert(req->ls_flags == DLMGMT_PERSIST); 611d62bc4baSyz assert(writeop && dlmgmt_db_req_head == NULL); 612d62bc4baSyz dlmgmt_db_req_tail = dlmgmt_db_req_head = req; 613d62bc4baSyz err = pthread_create(&tid, NULL, dlmgmt_db_update_thread, NULL); 614d62bc4baSyz if (err == 0) 615d62bc4baSyz return (EINPROGRESS); 616d62bc4baSyz } 617d62bc4baSyz return (err); 618d62bc4baSyz } 619d62bc4baSyz 620d62bc4baSyz static int 621d62bc4baSyz dlmgmt_process_db_onereq(dlmgmt_db_req_t *req, boolean_t writeop) 622d62bc4baSyz { 623d62bc4baSyz int err = 0; 624d62bc4baSyz FILE *fp, *nfp = NULL; 625d62bc4baSyz char file[MAXPATHLEN]; 626d62bc4baSyz char newfile[MAXPATHLEN]; 627d62bc4baSyz 628d62bc4baSyz DLMGMT_MAKE_FILE_DB_PATH(file, (req->ls_flags == DLMGMT_PERSIST)); 6292b24ab6bSSebastien Roy fp = dlmgmt_zfopen(file, "r", req->ls_zoneid, &err); 6302b24ab6bSSebastien Roy /* 6312b24ab6bSSebastien Roy * Note that it is not an error if the file doesn't exist. If we're 6322b24ab6bSSebastien Roy * reading, we treat this case the same way as an empty file. If 6332b24ab6bSSebastien Roy * we're writing, the file will be created when we open the file for 6342b24ab6bSSebastien Roy * writing below. 6352b24ab6bSSebastien Roy */ 6362b24ab6bSSebastien Roy if (fp == NULL && !writeop) 6372b24ab6bSSebastien Roy return (err); 638d62bc4baSyz 639d62bc4baSyz if (writeop) { 640d62bc4baSyz (void) snprintf(newfile, MAXPATHLEN, "%s.new", file); 6412b24ab6bSSebastien Roy nfp = dlmgmt_zfopen(newfile, "w", req->ls_zoneid, &err); 6422b24ab6bSSebastien Roy if (nfp == NULL) { 6432b24ab6bSSebastien Roy /* 6442b24ab6bSSebastien Roy * EROFS can happen at boot when the file system is 6452b24ab6bSSebastien Roy * read-only. Return EINPROGRESS so that the caller 6462b24ab6bSSebastien Roy * can add this request to the pending request list 6472b24ab6bSSebastien Roy * and start a retry thread. 6482b24ab6bSSebastien Roy */ 6492b24ab6bSSebastien Roy err = (errno == EROFS ? EINPROGRESS : errno); 6502b24ab6bSSebastien Roy goto done; 651d62bc4baSyz } 652d62bc4baSyz } 6532b24ab6bSSebastien Roy if (writeop) { 6542b24ab6bSSebastien Roy if ((err = process_db_write(req, fp, nfp)) == 0) 6552b24ab6bSSebastien Roy err = dlmgmt_zrename(newfile, file, req->ls_zoneid); 6562b24ab6bSSebastien Roy } else { 6572b24ab6bSSebastien Roy err = process_db_read(req, fp); 658d62bc4baSyz } 659d62bc4baSyz 660d62bc4baSyz done: 661d62bc4baSyz if (nfp != NULL) { 662d62bc4baSyz (void) fclose(nfp); 663d62bc4baSyz if (err != 0) 6642b24ab6bSSebastien Roy (void) dlmgmt_zunlink(newfile, req->ls_zoneid); 665d62bc4baSyz } 666d62bc4baSyz (void) fclose(fp); 667d62bc4baSyz return (err); 668d62bc4baSyz } 669d62bc4baSyz 670d62bc4baSyz /*ARGSUSED*/ 671d62bc4baSyz static void * 672d62bc4baSyz dlmgmt_db_update_thread(void *arg) 673d62bc4baSyz { 674d62bc4baSyz dlmgmt_db_req_t *req; 675d62bc4baSyz 676d62bc4baSyz dlmgmt_table_lock(B_TRUE); 677d62bc4baSyz 678d62bc4baSyz assert(dlmgmt_db_req_head != NULL); 679d62bc4baSyz while ((req = dlmgmt_db_req_head) != NULL) { 680d62bc4baSyz assert(req->ls_flags == DLMGMT_PERSIST); 6812b24ab6bSSebastien Roy if (dlmgmt_process_db_onereq(req, B_TRUE) == EINPROGRESS) { 682d62bc4baSyz /* 683d62bc4baSyz * The filesystem is still read only. Go to sleep and 684d62bc4baSyz * try again. 685d62bc4baSyz */ 686d62bc4baSyz dlmgmt_table_unlock(); 687d62bc4baSyz (void) sleep(5); 688d62bc4baSyz dlmgmt_table_lock(B_TRUE); 689d62bc4baSyz continue; 690d62bc4baSyz } 691d62bc4baSyz 692d62bc4baSyz /* 693d62bc4baSyz * The filesystem is no longer read only. Continue processing 694d62bc4baSyz * and remove the request from the pending list. 695d62bc4baSyz */ 696d62bc4baSyz dlmgmt_db_req_head = req->ls_next; 697d62bc4baSyz if (dlmgmt_db_req_tail == req) { 698d62bc4baSyz assert(dlmgmt_db_req_head == NULL); 699d62bc4baSyz dlmgmt_db_req_tail = NULL; 700d62bc4baSyz } 701d62bc4baSyz free(req); 702d62bc4baSyz } 703d62bc4baSyz 704d62bc4baSyz dlmgmt_table_unlock(); 705d62bc4baSyz return (NULL); 706d62bc4baSyz } 707d62bc4baSyz 708d62bc4baSyz static int 709d62bc4baSyz parse_linkprops(char *buf, dlmgmt_link_t *linkp) 710d62bc4baSyz { 711d62bc4baSyz boolean_t found_type = B_FALSE; 712d62bc4baSyz dladm_datatype_t type = DLADM_TYPE_STR; 713d62bc4baSyz int i, len; 714d62bc4baSyz int err = 0; 715d62bc4baSyz char *curr; 716d62bc4baSyz char attr_name[MAXLINKATTRLEN]; 717d62bc4baSyz size_t attr_buf_len = 0; 718d62bc4baSyz void *attr_buf = NULL; 719d62bc4baSyz 720d62bc4baSyz curr = buf; 721d62bc4baSyz len = strlen(buf); 722d62bc4baSyz attr_name[0] = '\0'; 723d62bc4baSyz for (i = 0; i < len && err == 0; i++) { 724d62bc4baSyz char c = buf[i]; 725d62bc4baSyz boolean_t match = (c == '=' || 726d62bc4baSyz (c == ',' && !found_type) || c == ';'); 727d62bc4baSyz 728d62bc4baSyz /* 729d62bc4baSyz * Move to the next character if there is no match and 730d62bc4baSyz * if we have not reached the last character. 731d62bc4baSyz */ 732d62bc4baSyz if (!match && i != len - 1) 733d62bc4baSyz continue; 734d62bc4baSyz 735d62bc4baSyz if (match) { 736d62bc4baSyz /* 737d62bc4baSyz * NUL-terminate the string pointed to by 'curr'. 738d62bc4baSyz */ 739d62bc4baSyz buf[i] = '\0'; 740d62bc4baSyz if (*curr == '\0') 741d62bc4baSyz goto parse_fail; 742d62bc4baSyz } 743d62bc4baSyz 744d62bc4baSyz if (attr_name[0] != '\0' && found_type) { 745d62bc4baSyz /* 746d62bc4baSyz * We get here after we have processed the "<prop>=" 747d62bc4baSyz * pattern. The pattern we are now interested in is 748d62bc4baSyz * "<val>;". 749d62bc4baSyz */ 750d62bc4baSyz if (c == '=') 751d62bc4baSyz goto parse_fail; 752d62bc4baSyz 7532b24ab6bSSebastien Roy if (strcmp(attr_name, "linkid") == 0) { 7542b24ab6bSSebastien Roy (void) read_int64(curr, &attr_buf); 7552b24ab6bSSebastien Roy linkp->ll_linkid = 7562b24ab6bSSebastien Roy (datalink_class_t)*(int64_t *)attr_buf; 7572b24ab6bSSebastien Roy } else if (strcmp(attr_name, "name") == 0) { 758d62bc4baSyz (void) read_str(curr, &attr_buf); 759d62bc4baSyz (void) snprintf(linkp->ll_link, 760d62bc4baSyz MAXLINKNAMELEN, "%s", attr_buf); 761d62bc4baSyz } else if (strcmp(attr_name, "class") == 0) { 762d62bc4baSyz (void) read_int64(curr, &attr_buf); 763d62bc4baSyz linkp->ll_class = 764d62bc4baSyz (datalink_class_t)*(int64_t *)attr_buf; 765d62bc4baSyz } else if (strcmp(attr_name, "media") == 0) { 766d62bc4baSyz (void) read_int64(curr, &attr_buf); 767d62bc4baSyz linkp->ll_media = 768d62bc4baSyz (uint32_t)*(int64_t *)attr_buf; 769d62bc4baSyz } else { 770d62bc4baSyz attr_buf_len = translators[type].read_func(curr, 771d62bc4baSyz &attr_buf); 772d62bc4baSyz err = linkattr_set(&(linkp->ll_head), attr_name, 773d62bc4baSyz attr_buf, attr_buf_len, type); 774d62bc4baSyz } 775d62bc4baSyz 776d62bc4baSyz free(attr_buf); 777d62bc4baSyz attr_name[0] = '\0'; 778d62bc4baSyz found_type = B_FALSE; 779d62bc4baSyz } else if (attr_name[0] != '\0') { 780d62bc4baSyz /* 781d62bc4baSyz * Non-zero length attr_name and found_type of false 782d62bc4baSyz * indicates that we have not found the type for this 783d62bc4baSyz * attribute. The pattern now is "<type>,<val>;", we 784d62bc4baSyz * want the <type> part of the pattern. 785d62bc4baSyz */ 786d62bc4baSyz for (type = 0; type < ntranslators; type++) { 787d62bc4baSyz if (strcmp(curr, 788d62bc4baSyz translators[type].type_name) == 0) { 789d62bc4baSyz found_type = B_TRUE; 790d62bc4baSyz break; 791d62bc4baSyz } 792d62bc4baSyz } 793d62bc4baSyz 794d62bc4baSyz if (!found_type) 795d62bc4baSyz goto parse_fail; 796d62bc4baSyz } else { 797d62bc4baSyz /* 798d62bc4baSyz * A zero length attr_name indicates we are looking 799d62bc4baSyz * at the beginning of a link attribute. 800d62bc4baSyz */ 801d62bc4baSyz if (c != '=') 802d62bc4baSyz goto parse_fail; 803d62bc4baSyz 804d62bc4baSyz (void) snprintf(attr_name, MAXLINKATTRLEN, "%s", curr); 805d62bc4baSyz } 806d62bc4baSyz curr = buf + i + 1; 807d62bc4baSyz } 808d62bc4baSyz 809d62bc4baSyz return (err); 810d62bc4baSyz 811d62bc4baSyz parse_fail: 812d62bc4baSyz return (-1); 813d62bc4baSyz } 814d62bc4baSyz 815d62bc4baSyz static boolean_t 8162b24ab6bSSebastien Roy process_link_line(char *buf, dlmgmt_link_t *linkp) 817d62bc4baSyz { 8182b24ab6bSSebastien Roy int i, len, llen; 8192b24ab6bSSebastien Roy char *str, *lasts; 8202b24ab6bSSebastien Roy char tmpbuf[MAXLINELEN]; 8212b24ab6bSSebastien Roy 8222b24ab6bSSebastien Roy bzero(linkp, sizeof (*linkp)); 8232b24ab6bSSebastien Roy linkp->ll_linkid = DATALINK_INVALID_LINKID; 824d62bc4baSyz 825d62bc4baSyz /* 826d62bc4baSyz * Use a copy of buf for parsing so that we can do whatever we want. 827d62bc4baSyz */ 828d62bc4baSyz (void) strlcpy(tmpbuf, buf, MAXLINELEN); 829d62bc4baSyz 830d62bc4baSyz /* 831d62bc4baSyz * Skip leading spaces, blank lines, and comments. 832d62bc4baSyz */ 833d62bc4baSyz len = strlen(tmpbuf); 834d62bc4baSyz for (i = 0; i < len; i++) { 835d62bc4baSyz if (!isspace(tmpbuf[i])) 836d62bc4baSyz break; 837d62bc4baSyz } 8382b24ab6bSSebastien Roy if (i == len || tmpbuf[i] == '#') 839d62bc4baSyz return (B_TRUE); 840d62bc4baSyz 841d62bc4baSyz str = tmpbuf + i; 842d62bc4baSyz /* 8432b24ab6bSSebastien Roy * Find the link name and assign it to the link structure. 844d62bc4baSyz */ 845d62bc4baSyz if (strtok_r(str, " \n\t", &lasts) == NULL) 846d62bc4baSyz goto fail; 847d62bc4baSyz 848d62bc4baSyz llen = strlen(str); 8492b24ab6bSSebastien Roy /* 8502b24ab6bSSebastien Roy * Note that a previous version of the persistent datalink.conf file 8512b24ab6bSSebastien Roy * stored the linkid as the first field. In that case, the name will 8522b24ab6bSSebastien Roy * be obtained through parse_linkprops from a property with the format 8532b24ab6bSSebastien Roy * "name=<linkname>". If we encounter such a format, we set 8542b24ab6bSSebastien Roy * rewrite_needed so that dlmgmt_db_init() can rewrite the file with 8552b24ab6bSSebastien Roy * the new format after it's done reading in the data. 8562b24ab6bSSebastien Roy */ 8572b24ab6bSSebastien Roy if (isdigit(str[0])) { 8582b24ab6bSSebastien Roy linkp->ll_linkid = atoi(str); 8592b24ab6bSSebastien Roy rewrite_needed = B_TRUE; 8602b24ab6bSSebastien Roy } else { 8612b24ab6bSSebastien Roy if (strlcpy(linkp->ll_link, str, sizeof (linkp->ll_link)) >= 8622b24ab6bSSebastien Roy sizeof (linkp->ll_link)) 8632b24ab6bSSebastien Roy goto fail; 8642b24ab6bSSebastien Roy } 865d62bc4baSyz 866d62bc4baSyz str += llen + 1; 867d62bc4baSyz if (str >= tmpbuf + len) 868d62bc4baSyz goto fail; 869d62bc4baSyz 870d62bc4baSyz /* 871d62bc4baSyz * Now find the list of link properties. 872d62bc4baSyz */ 873d62bc4baSyz if ((str = strtok_r(str, " \n\t", &lasts)) == NULL) 874d62bc4baSyz goto fail; 875d62bc4baSyz 876d62bc4baSyz if (parse_linkprops(str, linkp) < 0) 877d62bc4baSyz goto fail; 878d62bc4baSyz 879d62bc4baSyz return (B_TRUE); 880d62bc4baSyz 881d62bc4baSyz fail: 882d62bc4baSyz /* 883d62bc4baSyz * Delete corrupted line. 884d62bc4baSyz */ 885d62bc4baSyz buf[0] = '\0'; 886d62bc4baSyz return (B_FALSE); 887d62bc4baSyz } 888d62bc4baSyz 8892b24ab6bSSebastien Roy /* 8902b24ab6bSSebastien Roy * Find any properties in linkp that refer to "old", and rename to "new". 8912b24ab6bSSebastien Roy * Return B_TRUE if any renaming occurred. 8922b24ab6bSSebastien Roy */ 8932b24ab6bSSebastien Roy static int 8942b24ab6bSSebastien Roy dlmgmt_attr_rename(dlmgmt_link_t *linkp, const char *old, const char *new, 8952b24ab6bSSebastien Roy boolean_t *renamed) 8962b24ab6bSSebastien Roy { 8972b24ab6bSSebastien Roy dlmgmt_linkattr_t *attrp; 8982b24ab6bSSebastien Roy char *newval = NULL, *pname; 8992b24ab6bSSebastien Roy char valcp[MAXLINKATTRVALLEN]; 9002b24ab6bSSebastien Roy size_t newsize; 9012b24ab6bSSebastien Roy 9022b24ab6bSSebastien Roy *renamed = B_FALSE; 9032b24ab6bSSebastien Roy 9042b24ab6bSSebastien Roy if ((attrp = linkattr_find(linkp->ll_head, "linkover")) != NULL || 9052b24ab6bSSebastien Roy (attrp = linkattr_find(linkp->ll_head, "simnetpeer")) != NULL) { 9062b24ab6bSSebastien Roy if (strcmp(old, (char *)attrp->lp_val) == 0) { 9072b24ab6bSSebastien Roy newsize = strlen(new) + 1; 9082b24ab6bSSebastien Roy if ((newval = malloc(newsize)) == NULL) 9092b24ab6bSSebastien Roy return (errno); 9102b24ab6bSSebastien Roy (void) strcpy(newval, new); 9112b24ab6bSSebastien Roy free(attrp->lp_val); 9122b24ab6bSSebastien Roy attrp->lp_val = newval; 9132b24ab6bSSebastien Roy attrp->lp_sz = newsize; 9142b24ab6bSSebastien Roy *renamed = B_TRUE; 9152b24ab6bSSebastien Roy } 9162b24ab6bSSebastien Roy return (0); 9172b24ab6bSSebastien Roy } 9182b24ab6bSSebastien Roy 9192b24ab6bSSebastien Roy if ((attrp = linkattr_find(linkp->ll_head, "portnames")) == NULL) 9202b24ab6bSSebastien Roy return (0); 9212b24ab6bSSebastien Roy 9222b24ab6bSSebastien Roy /* <linkname>:[<linkname>:]... */ 9232b24ab6bSSebastien Roy if ((newval = calloc(MAXLINKATTRVALLEN, sizeof (char))) == NULL) 9242b24ab6bSSebastien Roy return (errno); 9252b24ab6bSSebastien Roy 9262b24ab6bSSebastien Roy bcopy(attrp->lp_val, valcp, sizeof (valcp)); 9272b24ab6bSSebastien Roy pname = strtok(valcp, ":"); 9282b24ab6bSSebastien Roy while (pname != NULL) { 9292b24ab6bSSebastien Roy if (strcmp(pname, old) == 0) { 9302b24ab6bSSebastien Roy (void) strcat(newval, new); 9312b24ab6bSSebastien Roy *renamed = B_TRUE; 9322b24ab6bSSebastien Roy } else { 9332b24ab6bSSebastien Roy (void) strcat(newval, pname); 9342b24ab6bSSebastien Roy } 9352b24ab6bSSebastien Roy (void) strcat(newval, ":"); 9362b24ab6bSSebastien Roy pname = strtok(NULL, ":"); 9372b24ab6bSSebastien Roy } 9382b24ab6bSSebastien Roy if (*renamed) { 9392b24ab6bSSebastien Roy free(attrp->lp_val); 9402b24ab6bSSebastien Roy attrp->lp_val = newval; 9412b24ab6bSSebastien Roy attrp->lp_sz = strlen(newval) + 1; 9422b24ab6bSSebastien Roy } else { 9432b24ab6bSSebastien Roy free(newval); 9442b24ab6bSSebastien Roy } 9452b24ab6bSSebastien Roy return (0); 9462b24ab6bSSebastien Roy } 9472b24ab6bSSebastien Roy 948d62bc4baSyz static int 949d62bc4baSyz process_db_write(dlmgmt_db_req_t *req, FILE *fp, FILE *nfp) 950d62bc4baSyz { 951d62bc4baSyz boolean_t done = B_FALSE; 952d62bc4baSyz int err = 0; 9532b24ab6bSSebastien Roy dlmgmt_link_t link_in_file, *linkp = NULL, *dblinkp; 9542b24ab6bSSebastien Roy boolean_t persist = (req->ls_flags == DLMGMT_PERSIST); 9552b24ab6bSSebastien Roy boolean_t writeall, rename, attr_renamed; 956d62bc4baSyz char buf[MAXLINELEN]; 957d62bc4baSyz 9582b24ab6bSSebastien Roy writeall = (req->ls_linkid == DATALINK_ALL_LINKID); 9592b24ab6bSSebastien Roy 9602b24ab6bSSebastien Roy if (req->ls_op == DLMGMT_DB_OP_WRITE && !writeall) { 961d62bc4baSyz /* 962d62bc4baSyz * find the link in the avl tree with the given linkid. 963d62bc4baSyz */ 9642b24ab6bSSebastien Roy linkp = link_by_id(req->ls_linkid, req->ls_zoneid); 965d62bc4baSyz if (linkp == NULL || (linkp->ll_flags & req->ls_flags) == 0) { 966d62bc4baSyz /* 967d62bc4baSyz * This link has already been changed. This could 968d62bc4baSyz * happen if the request is pending because of 969d62bc4baSyz * read-only file-system. If so, we are done. 970d62bc4baSyz */ 971d62bc4baSyz return (0); 972d62bc4baSyz } 9732b24ab6bSSebastien Roy /* 9742b24ab6bSSebastien Roy * In the case of a rename, linkp's name has been updated to 9752b24ab6bSSebastien Roy * the new name, and req->ls_link is the old link name. 9762b24ab6bSSebastien Roy */ 9772b24ab6bSSebastien Roy rename = (strcmp(req->ls_link, linkp->ll_link) != 0); 978d62bc4baSyz } 979d62bc4baSyz 9802b24ab6bSSebastien Roy /* 9812b24ab6bSSebastien Roy * fp can be NULL if the file didn't initially exist and we're 9822b24ab6bSSebastien Roy * creating it as part of this write operation. 9832b24ab6bSSebastien Roy */ 9842b24ab6bSSebastien Roy if (fp == NULL) 9852b24ab6bSSebastien Roy goto write; 9862b24ab6bSSebastien Roy 987d62bc4baSyz while (err == 0 && fgets(buf, sizeof (buf), fp) != NULL && 988d62bc4baSyz process_link_line(buf, &link_in_file)) { 9892b24ab6bSSebastien Roy if (link_in_file.ll_link[0] == '\0' || done) { 990d62bc4baSyz /* 9910dc974a9SCathy Zhou * this is a comment line or we are done updating the 9922b24ab6bSSebastien Roy * line for the specified link, write the rest of 9932b24ab6bSSebastien Roy * lines out. 994d62bc4baSyz */ 995d62bc4baSyz if (fputs(buf, nfp) == EOF) 996d62bc4baSyz err = errno; 997d62bc4baSyz continue; 998d62bc4baSyz } 999d62bc4baSyz 1000d62bc4baSyz switch (req->ls_op) { 1001d62bc4baSyz case DLMGMT_DB_OP_WRITE: 1002d62bc4baSyz /* 10032b24ab6bSSebastien Roy * For write operations, we generate a new output line 10042b24ab6bSSebastien Roy * if we're either writing all links (writeall) or if 10052b24ab6bSSebastien Roy * the name of the link in the file matches the one 10062b24ab6bSSebastien Roy * we're looking for. Otherwise, we write out the 10072b24ab6bSSebastien Roy * buffer as-is. 10082b24ab6bSSebastien Roy * 10092b24ab6bSSebastien Roy * If we're doing a rename operation, ensure that any 10102b24ab6bSSebastien Roy * references to the link being renamed in link 10112b24ab6bSSebastien Roy * properties are also updated before we write 10122b24ab6bSSebastien Roy * anything. 1013d62bc4baSyz */ 10142b24ab6bSSebastien Roy if (writeall) { 10152b24ab6bSSebastien Roy linkp = link_by_name(link_in_file.ll_link, 10162b24ab6bSSebastien Roy req->ls_zoneid); 1017d62bc4baSyz } 10182b24ab6bSSebastien Roy if (writeall || strcmp(req->ls_link, 10192b24ab6bSSebastien Roy link_in_file.ll_link) == 0) { 10202b24ab6bSSebastien Roy generate_link_line(linkp, persist, buf); 10212b24ab6bSSebastien Roy if (!writeall && !rename) 10222b24ab6bSSebastien Roy done = B_TRUE; 10232b24ab6bSSebastien Roy } else if (rename && persist) { 10242b24ab6bSSebastien Roy dblinkp = link_by_name(link_in_file.ll_link, 10252b24ab6bSSebastien Roy req->ls_zoneid); 10262b24ab6bSSebastien Roy err = dlmgmt_attr_rename(dblinkp, req->ls_link, 10272b24ab6bSSebastien Roy linkp->ll_link, &attr_renamed); 10282b24ab6bSSebastien Roy if (err != 0) 10292b24ab6bSSebastien Roy break; 10302b24ab6bSSebastien Roy if (attr_renamed) { 10312b24ab6bSSebastien Roy generate_link_line(dblinkp, persist, 10322b24ab6bSSebastien Roy buf); 10332b24ab6bSSebastien Roy } 10342b24ab6bSSebastien Roy } 10352b24ab6bSSebastien Roy if (fputs(buf, nfp) == EOF) 10362b24ab6bSSebastien Roy err = errno; 1037d62bc4baSyz break; 1038d62bc4baSyz case DLMGMT_DB_OP_DELETE: 1039d62bc4baSyz /* 1040d62bc4baSyz * Delete is simple. If buf does not represent the 1041d62bc4baSyz * link we're deleting, write it out. 1042d62bc4baSyz */ 10432b24ab6bSSebastien Roy if (strcmp(req->ls_link, link_in_file.ll_link) != 0) { 1044d62bc4baSyz if (fputs(buf, nfp) == EOF) 1045d62bc4baSyz err = errno; 1046d62bc4baSyz } else { 1047d62bc4baSyz done = B_TRUE; 1048d62bc4baSyz } 1049d62bc4baSyz break; 1050d62bc4baSyz case DLMGMT_DB_OP_READ: 1051d62bc4baSyz default: 1052d62bc4baSyz err = EINVAL; 1053d62bc4baSyz break; 1054d62bc4baSyz } 1055d62bc4baSyz } 1056d62bc4baSyz 10572b24ab6bSSebastien Roy write: 1058d62bc4baSyz /* 10592b24ab6bSSebastien Roy * If we get to the end of the file and have not seen what linkid 10602b24ab6bSSebastien Roy * points to, write it out then. 1061d62bc4baSyz */ 10622b24ab6bSSebastien Roy if (req->ls_op == DLMGMT_DB_OP_WRITE && !writeall && !rename && !done) { 10632b24ab6bSSebastien Roy generate_link_line(linkp, persist, buf); 1064d62bc4baSyz done = B_TRUE; 1065d62bc4baSyz if (fputs(buf, nfp) == EOF) 1066d62bc4baSyz err = errno; 1067d62bc4baSyz } 1068d62bc4baSyz 1069d62bc4baSyz return (err); 1070d62bc4baSyz } 1071d62bc4baSyz 1072d62bc4baSyz static int 10732b24ab6bSSebastien Roy process_db_read(dlmgmt_db_req_t *req, FILE *fp) 1074d62bc4baSyz { 1075d62bc4baSyz avl_index_t name_where, id_where; 10762b24ab6bSSebastien Roy dlmgmt_link_t link_in_file, *newlink, *link_in_db; 1077d62bc4baSyz char buf[MAXLINELEN]; 1078d62bc4baSyz int err = 0; 1079d62bc4baSyz 1080d62bc4baSyz /* 1081d62bc4baSyz * This loop processes each line of the configuration file. 1082d62bc4baSyz */ 1083d62bc4baSyz while (fgets(buf, MAXLINELEN, fp) != NULL) { 1084d62bc4baSyz if (!process_link_line(buf, &link_in_file)) { 1085d62bc4baSyz err = EINVAL; 1086d62bc4baSyz break; 1087d62bc4baSyz } 1088d62bc4baSyz 1089d62bc4baSyz /* 1090d62bc4baSyz * Skip the comment line. 1091d62bc4baSyz */ 10922b24ab6bSSebastien Roy if (link_in_file.ll_link[0] == '\0') 10932b24ab6bSSebastien Roy continue; 10942b24ab6bSSebastien Roy 10952b24ab6bSSebastien Roy if ((req->ls_flags & DLMGMT_ACTIVE) && 10962b24ab6bSSebastien Roy link_in_file.ll_linkid == DATALINK_INVALID_LINKID) 1097d62bc4baSyz continue; 1098d62bc4baSyz 10992b24ab6bSSebastien Roy link_in_file.ll_zoneid = req->ls_zoneid; 11002b24ab6bSSebastien Roy link_in_db = avl_find(&dlmgmt_name_avl, &link_in_file, 11012b24ab6bSSebastien Roy &name_where); 11022b24ab6bSSebastien Roy if (link_in_db != NULL) { 1103d62bc4baSyz /* 11042b24ab6bSSebastien Roy * If the link in the database already has the flag 11052b24ab6bSSebastien Roy * for this request set, then the entry is a 11062b24ab6bSSebastien Roy * duplicate. If it's not a duplicate, then simply 11072b24ab6bSSebastien Roy * turn on the appropriate flag on the existing link. 1108d62bc4baSyz */ 11092b24ab6bSSebastien Roy if (link_in_db->ll_flags & req->ls_flags) { 11102b24ab6bSSebastien Roy dlmgmt_log(LOG_WARNING, "Duplicate links " 11112b24ab6bSSebastien Roy "in the repository: %s", 11122b24ab6bSSebastien Roy link_in_file.ll_link); 1113d62bc4baSyz } else { 11142b24ab6bSSebastien Roy if (req->ls_flags & DLMGMT_PERSIST) { 11152b24ab6bSSebastien Roy /* 11162b24ab6bSSebastien Roy * Save the newly read properties into 11172b24ab6bSSebastien Roy * the existing link. 11182b24ab6bSSebastien Roy */ 11192b24ab6bSSebastien Roy assert(link_in_db->ll_head == NULL); 11202b24ab6bSSebastien Roy link_in_db->ll_head = 11212b24ab6bSSebastien Roy link_in_file.ll_head; 11222b24ab6bSSebastien Roy } 11232b24ab6bSSebastien Roy link_in_db->ll_flags |= req->ls_flags; 1124d62bc4baSyz } 1125d62bc4baSyz } else { 11262b24ab6bSSebastien Roy /* 11272b24ab6bSSebastien Roy * This is a new link. Allocate a new dlmgmt_link_t 11282b24ab6bSSebastien Roy * and add it to the trees. 11292b24ab6bSSebastien Roy */ 11302b24ab6bSSebastien Roy newlink = calloc(1, sizeof (*newlink)); 11312b24ab6bSSebastien Roy if (newlink == NULL) { 11322b24ab6bSSebastien Roy dlmgmt_log(LOG_WARNING, "Unable to allocate " 11332b24ab6bSSebastien Roy "memory to create new link %s", 11342b24ab6bSSebastien Roy link_in_file.ll_link); 11352b24ab6bSSebastien Roy continue; 11362b24ab6bSSebastien Roy } 11372b24ab6bSSebastien Roy bcopy(&link_in_file, newlink, sizeof (*newlink)); 11382b24ab6bSSebastien Roy 11392b24ab6bSSebastien Roy if (newlink->ll_linkid == DATALINK_INVALID_LINKID) 11402b24ab6bSSebastien Roy newlink->ll_linkid = dlmgmt_nextlinkid; 11412b24ab6bSSebastien Roy if (avl_find(&dlmgmt_id_avl, newlink, &id_where) != 11422b24ab6bSSebastien Roy NULL) { 11432b24ab6bSSebastien Roy link_destroy(newlink); 11442b24ab6bSSebastien Roy continue; 11452b24ab6bSSebastien Roy } 11462b24ab6bSSebastien Roy if ((req->ls_flags & DLMGMT_ACTIVE) && 11472b24ab6bSSebastien Roy link_activate(newlink) != 0) { 11482b24ab6bSSebastien Roy dlmgmt_log(LOG_WARNING, "Unable to activate %s", 11492b24ab6bSSebastien Roy newlink->ll_link); 11502b24ab6bSSebastien Roy link_destroy(newlink); 11512b24ab6bSSebastien Roy continue; 11522b24ab6bSSebastien Roy } 11532b24ab6bSSebastien Roy avl_insert(&dlmgmt_name_avl, newlink, name_where); 11542b24ab6bSSebastien Roy avl_insert(&dlmgmt_id_avl, newlink, id_where); 11552b24ab6bSSebastien Roy dlmgmt_advance(newlink); 11562b24ab6bSSebastien Roy newlink->ll_flags |= req->ls_flags; 1157d62bc4baSyz } 1158d62bc4baSyz } 1159d62bc4baSyz 1160d62bc4baSyz return (err); 1161d62bc4baSyz } 1162d62bc4baSyz 1163d62bc4baSyz /* 1164d62bc4baSyz * Generate an entry in the link database. 1165d62bc4baSyz * Each entry has this format: 11662b24ab6bSSebastien Roy * <link name> <prop0>=<type>,<val>;...;<propn>=<type>,<val>; 1167d62bc4baSyz */ 1168d62bc4baSyz static void 1169d62bc4baSyz generate_link_line(dlmgmt_link_t *linkp, boolean_t persist, char *buf) 1170d62bc4baSyz { 1171d62bc4baSyz char tmpbuf[MAXLINELEN]; 11722b24ab6bSSebastien Roy char *ptr = tmpbuf; 1173d62bc4baSyz char *lim = tmpbuf + MAXLINELEN; 1174d62bc4baSyz dlmgmt_linkattr_t *cur_p = NULL; 1175d62bc4baSyz uint64_t u64; 1176d62bc4baSyz 11772b24ab6bSSebastien Roy ptr += snprintf(ptr, BUFLEN(lim, ptr), "%s\t", linkp->ll_link); 11782b24ab6bSSebastien Roy if (!persist) { 11792b24ab6bSSebastien Roy /* 11802b24ab6bSSebastien Roy * We store the linkid in the active database so that dlmgmtd 11812b24ab6bSSebastien Roy * can recover in the event that it is restarted. 11822b24ab6bSSebastien Roy */ 11832b24ab6bSSebastien Roy u64 = linkp->ll_linkid; 11842b24ab6bSSebastien Roy ptr += write_uint64(ptr, BUFLEN(lim, ptr), "linkid", &u64); 11852b24ab6bSSebastien Roy } 1186d62bc4baSyz u64 = linkp->ll_class; 1187d62bc4baSyz ptr += write_uint64(ptr, BUFLEN(lim, ptr), "class", &u64); 1188d62bc4baSyz u64 = linkp->ll_media; 1189d62bc4baSyz ptr += write_uint64(ptr, BUFLEN(lim, ptr), "media", &u64); 1190d62bc4baSyz 1191d62bc4baSyz /* 11922b24ab6bSSebastien Roy * The daemon does not keep any active link attribute. Only store the 11932b24ab6bSSebastien Roy * attributes if this request is for persistent configuration, 1194d62bc4baSyz */ 11952b24ab6bSSebastien Roy if (persist) { 11962b24ab6bSSebastien Roy for (cur_p = linkp->ll_head; cur_p != NULL; 11972b24ab6bSSebastien Roy cur_p = cur_p->lp_next) { 11982b24ab6bSSebastien Roy ptr += translators[cur_p->lp_type].write_func(ptr, 11992b24ab6bSSebastien Roy BUFLEN(lim, ptr), cur_p->lp_name, cur_p->lp_val); 12002b24ab6bSSebastien Roy } 1201d62bc4baSyz } 12022b24ab6bSSebastien Roy 12032b24ab6bSSebastien Roy if (ptr <= lim) 12042b24ab6bSSebastien Roy (void) snprintf(buf, MAXLINELEN, "%s\n", tmpbuf); 1205d62bc4baSyz } 1206d62bc4baSyz 1207d62bc4baSyz int 12082b24ab6bSSebastien Roy dlmgmt_delete_db_entry(dlmgmt_link_t *linkp, uint32_t flags) 1209d62bc4baSyz { 12102b24ab6bSSebastien Roy return (dlmgmt_db_update(DLMGMT_DB_OP_DELETE, linkp->ll_link, linkp, 12112b24ab6bSSebastien Roy flags)); 1212d62bc4baSyz } 1213d62bc4baSyz 1214d62bc4baSyz int 12152b24ab6bSSebastien Roy dlmgmt_write_db_entry(const char *entryname, dlmgmt_link_t *linkp, 12162b24ab6bSSebastien Roy uint32_t flags) 1217d62bc4baSyz { 12182b24ab6bSSebastien Roy int err; 1219d62bc4baSyz 1220d62bc4baSyz if (flags & DLMGMT_PERSIST) { 12212b24ab6bSSebastien Roy if ((err = dlmgmt_db_update(DLMGMT_DB_OP_WRITE, entryname, 12222b24ab6bSSebastien Roy linkp, DLMGMT_PERSIST)) != 0) { 1223d62bc4baSyz return (err); 1224d62bc4baSyz } 1225d62bc4baSyz } 1226d62bc4baSyz 1227d62bc4baSyz if (flags & DLMGMT_ACTIVE) { 12282b24ab6bSSebastien Roy if (((err = dlmgmt_db_update(DLMGMT_DB_OP_WRITE, entryname, 12292b24ab6bSSebastien Roy linkp, DLMGMT_ACTIVE)) != 0) && (flags & DLMGMT_PERSIST)) { 12302b24ab6bSSebastien Roy (void) dlmgmt_db_update(DLMGMT_DB_OP_DELETE, entryname, 12312b24ab6bSSebastien Roy linkp, DLMGMT_PERSIST); 1232d62bc4baSyz return (err); 1233d62bc4baSyz } 1234d62bc4baSyz } 1235d62bc4baSyz 1236d62bc4baSyz return (0); 1237d62bc4baSyz } 1238d62bc4baSyz 12392b24ab6bSSebastien Roy /* 12402b24ab6bSSebastien Roy * Upgrade properties that have link IDs as values to link names. Because '.' 12412b24ab6bSSebastien Roy * is a valid linkname character, the port separater for link aggregations 1242d501bbfeSSebastien Roy * must be changed to ':'. 12432b24ab6bSSebastien Roy */ 12442b24ab6bSSebastien Roy static void 12452b24ab6bSSebastien Roy linkattr_upgrade(dlmgmt_linkattr_t *attrp) 12462b24ab6bSSebastien Roy { 12472b24ab6bSSebastien Roy datalink_id_t linkid; 12482b24ab6bSSebastien Roy char *portidstr; 12492b24ab6bSSebastien Roy char portname[MAXLINKNAMELEN + 1]; 12502b24ab6bSSebastien Roy dlmgmt_link_t *linkp; 12512b24ab6bSSebastien Roy char *new_attr_val; 12522b24ab6bSSebastien Roy size_t new_attr_sz; 12532b24ab6bSSebastien Roy boolean_t upgraded = B_FALSE; 12542b24ab6bSSebastien Roy 12552b24ab6bSSebastien Roy if (strcmp(attrp->lp_name, "linkover") == 0 || 12562b24ab6bSSebastien Roy strcmp(attrp->lp_name, "simnetpeer") == 0) { 12572b24ab6bSSebastien Roy if (attrp->lp_type == DLADM_TYPE_UINT64) { 1258d501bbfeSSebastien Roy linkid = (datalink_id_t)*(uint64_t *)attrp->lp_val; 12592b24ab6bSSebastien Roy if ((linkp = link_by_id(linkid, GLOBAL_ZONEID)) == NULL) 12602b24ab6bSSebastien Roy return; 12612b24ab6bSSebastien Roy new_attr_sz = strlen(linkp->ll_link) + 1; 12622b24ab6bSSebastien Roy if ((new_attr_val = malloc(new_attr_sz)) == NULL) 12632b24ab6bSSebastien Roy return; 12642b24ab6bSSebastien Roy (void) strcpy(new_attr_val, linkp->ll_link); 12652b24ab6bSSebastien Roy upgraded = B_TRUE; 12662b24ab6bSSebastien Roy } 12672b24ab6bSSebastien Roy } else if (strcmp(attrp->lp_name, "portnames") == 0) { 12682b24ab6bSSebastien Roy /* 12692b24ab6bSSebastien Roy * The old format for "portnames" was 12702b24ab6bSSebastien Roy * "<linkid>.[<linkid>.]...". The new format is 12712b24ab6bSSebastien Roy * "<linkname>:[<linkname>:]...". 12722b24ab6bSSebastien Roy */ 12732b24ab6bSSebastien Roy if (!isdigit(((char *)attrp->lp_val)[0])) 12742b24ab6bSSebastien Roy return; 12752b24ab6bSSebastien Roy new_attr_val = calloc(MAXLINKATTRVALLEN, sizeof (char)); 12762b24ab6bSSebastien Roy if (new_attr_val == NULL) 12772b24ab6bSSebastien Roy return; 12782b24ab6bSSebastien Roy portidstr = (char *)attrp->lp_val; 12792b24ab6bSSebastien Roy while (*portidstr != '\0') { 12802b24ab6bSSebastien Roy errno = 0; 12812b24ab6bSSebastien Roy linkid = strtol(portidstr, &portidstr, 10); 12822b24ab6bSSebastien Roy if (linkid == 0 || *portidstr != '.' || 12832b24ab6bSSebastien Roy (linkp = link_by_id(linkid, GLOBAL_ZONEID)) == 12842b24ab6bSSebastien Roy NULL) { 12852b24ab6bSSebastien Roy free(new_attr_val); 12862b24ab6bSSebastien Roy return; 12872b24ab6bSSebastien Roy } 12882b24ab6bSSebastien Roy (void) snprintf(portname, sizeof (portname), "%s:", 12892b24ab6bSSebastien Roy linkp->ll_link); 12902b24ab6bSSebastien Roy if (strlcat(new_attr_val, portname, 12912b24ab6bSSebastien Roy MAXLINKATTRVALLEN) >= MAXLINKATTRVALLEN) { 12922b24ab6bSSebastien Roy free(new_attr_val); 12932b24ab6bSSebastien Roy return; 12942b24ab6bSSebastien Roy } 12952b24ab6bSSebastien Roy /* skip the '.' delimiter */ 12962b24ab6bSSebastien Roy portidstr++; 12972b24ab6bSSebastien Roy } 12982b24ab6bSSebastien Roy new_attr_sz = strlen(new_attr_val) + 1; 12992b24ab6bSSebastien Roy upgraded = B_TRUE; 13002b24ab6bSSebastien Roy } 13012b24ab6bSSebastien Roy 13022b24ab6bSSebastien Roy if (upgraded) { 13032b24ab6bSSebastien Roy attrp->lp_type = DLADM_TYPE_STR; 13042b24ab6bSSebastien Roy attrp->lp_sz = new_attr_sz; 13052b24ab6bSSebastien Roy free(attrp->lp_val); 13062b24ab6bSSebastien Roy attrp->lp_val = new_attr_val; 13072b24ab6bSSebastien Roy } 13082b24ab6bSSebastien Roy } 13092b24ab6bSSebastien Roy 13102b24ab6bSSebastien Roy static void 13112b24ab6bSSebastien Roy dlmgmt_db_upgrade(dlmgmt_link_t *linkp) 13122b24ab6bSSebastien Roy { 13132b24ab6bSSebastien Roy dlmgmt_linkattr_t *attrp; 13142b24ab6bSSebastien Roy 13152b24ab6bSSebastien Roy for (attrp = linkp->ll_head; attrp != NULL; attrp = attrp->lp_next) 13162b24ab6bSSebastien Roy linkattr_upgrade(attrp); 13172b24ab6bSSebastien Roy } 13182b24ab6bSSebastien Roy 13192b24ab6bSSebastien Roy static void 13202b24ab6bSSebastien Roy dlmgmt_db_phys_activate(dlmgmt_link_t *linkp) 13212b24ab6bSSebastien Roy { 13222b24ab6bSSebastien Roy linkp->ll_flags |= DLMGMT_ACTIVE; 13232b24ab6bSSebastien Roy (void) dlmgmt_write_db_entry(linkp->ll_link, linkp, DLMGMT_ACTIVE); 13242b24ab6bSSebastien Roy } 13252b24ab6bSSebastien Roy 13262b24ab6bSSebastien Roy static void 13272b24ab6bSSebastien Roy dlmgmt_db_walk(zoneid_t zoneid, datalink_class_t class, db_walk_func_t *func) 13282b24ab6bSSebastien Roy { 13292b24ab6bSSebastien Roy dlmgmt_link_t *linkp; 13302b24ab6bSSebastien Roy 13312b24ab6bSSebastien Roy for (linkp = avl_first(&dlmgmt_id_avl); linkp != NULL; 13322b24ab6bSSebastien Roy linkp = AVL_NEXT(&dlmgmt_id_avl, linkp)) { 13332b24ab6bSSebastien Roy if (linkp->ll_zoneid == zoneid && (linkp->ll_class & class)) 13342b24ab6bSSebastien Roy func(linkp); 13352b24ab6bSSebastien Roy } 13362b24ab6bSSebastien Roy } 13372b24ab6bSSebastien Roy 1338d62bc4baSyz /* 1339d62bc4baSyz * Initialize the datalink <link name, linkid> mapping and the link's 1340d62bc4baSyz * attributes list based on the configuration file /etc/dladm/datalink.conf 1341d62bc4baSyz * and the active configuration cache file 1342b9e076dcSyz * /etc/svc/volatile/dladm/datalink-management:default.cache. 1343d62bc4baSyz */ 1344d62bc4baSyz int 13452b24ab6bSSebastien Roy dlmgmt_db_init(zoneid_t zoneid) 1346d62bc4baSyz { 13472b24ab6bSSebastien Roy dlmgmt_db_req_t *req; 1348d62bc4baSyz int err; 13492b24ab6bSSebastien Roy boolean_t boot = B_FALSE; 1350d62bc4baSyz 13512b24ab6bSSebastien Roy if ((req = dlmgmt_db_req_alloc(DLMGMT_DB_OP_READ, NULL, 13522b24ab6bSSebastien Roy DATALINK_INVALID_LINKID, zoneid, DLMGMT_ACTIVE, &err)) == NULL) 13532b24ab6bSSebastien Roy return (err); 1354d62bc4baSyz 13552b24ab6bSSebastien Roy if ((err = dlmgmt_process_db_req(req)) != 0) { 1356d62bc4baSyz /* 13572b24ab6bSSebastien Roy * If we get back ENOENT, that means that the active 13582b24ab6bSSebastien Roy * configuration file doesn't exist yet, and is not an error. 13592b24ab6bSSebastien Roy * We'll create it down below after we've loaded the 13602b24ab6bSSebastien Roy * persistent configuration. 1361d62bc4baSyz */ 13622b24ab6bSSebastien Roy if (err != ENOENT) 13632b24ab6bSSebastien Roy goto done; 13642b24ab6bSSebastien Roy boot = B_TRUE; 1365d62bc4baSyz } 1366d62bc4baSyz 13672b24ab6bSSebastien Roy req->ls_flags = DLMGMT_PERSIST; 13682b24ab6bSSebastien Roy err = dlmgmt_process_db_req(req); 13692b24ab6bSSebastien Roy if (err != 0 && err != ENOENT) 1370d62bc4baSyz goto done; 13712b24ab6bSSebastien Roy err = 0; 13722b24ab6bSSebastien Roy if (rewrite_needed) { 1373d62bc4baSyz /* 13742b24ab6bSSebastien Roy * First update links in memory, then dump the entire db to 13752b24ab6bSSebastien Roy * disk. 1376d62bc4baSyz */ 13772b24ab6bSSebastien Roy dlmgmt_db_walk(zoneid, DATALINK_CLASS_ALL, dlmgmt_db_upgrade); 13782b24ab6bSSebastien Roy req->ls_op = DLMGMT_DB_OP_WRITE; 13792b24ab6bSSebastien Roy req->ls_linkid = DATALINK_ALL_LINKID; 13802b24ab6bSSebastien Roy if ((err = dlmgmt_process_db_req(req)) != 0 && 13812b24ab6bSSebastien Roy err != EINPROGRESS) 13822b24ab6bSSebastien Roy goto done; 13832b24ab6bSSebastien Roy } 13842b24ab6bSSebastien Roy if (boot) { 13852b24ab6bSSebastien Roy dlmgmt_db_walk(zoneid, DATALINK_CLASS_PHYS, 13862b24ab6bSSebastien Roy dlmgmt_db_phys_activate); 1387d62bc4baSyz } 1388d62bc4baSyz 1389d62bc4baSyz done: 13902b24ab6bSSebastien Roy if (err == EINPROGRESS) 13912b24ab6bSSebastien Roy err = 0; 13922b24ab6bSSebastien Roy else 13932b24ab6bSSebastien Roy free(req); 1394d62bc4baSyz return (err); 1395d62bc4baSyz } 13962b24ab6bSSebastien Roy 13972b24ab6bSSebastien Roy /* 13982b24ab6bSSebastien Roy * Remove all links in the given zoneid. 13992b24ab6bSSebastien Roy */ 14002b24ab6bSSebastien Roy void 14012b24ab6bSSebastien Roy dlmgmt_db_fini(zoneid_t zoneid) 14022b24ab6bSSebastien Roy { 14032b24ab6bSSebastien Roy dlmgmt_link_t *linkp = avl_first(&dlmgmt_name_avl), *next_linkp; 14042b24ab6bSSebastien Roy 14052b24ab6bSSebastien Roy while (linkp != NULL) { 14062b24ab6bSSebastien Roy next_linkp = AVL_NEXT(&dlmgmt_name_avl, linkp); 14072b24ab6bSSebastien Roy if (linkp->ll_zoneid == zoneid) { 14082b24ab6bSSebastien Roy (void) dlmgmt_destroy_common(linkp, 14092b24ab6bSSebastien Roy DLMGMT_ACTIVE | DLMGMT_PERSIST); 14102b24ab6bSSebastien Roy } 14112b24ab6bSSebastien Roy linkp = next_linkp; 14122b24ab6bSSebastien Roy } 14132b24ab6bSSebastien Roy } 1414