1c5c4113dSnw141292 /* 2c5c4113dSnw141292 * CDDL HEADER START 3c5c4113dSnw141292 * 4c5c4113dSnw141292 * The contents of this file are subject to the terms of the 5c5c4113dSnw141292 * Common Development and Distribution License (the "License"). 6c5c4113dSnw141292 * You may not use this file except in compliance with the License. 7c5c4113dSnw141292 * 8c5c4113dSnw141292 * You can obtain a copy of the license at usr/src/OPENSOLARIS.LICENSE 9c5c4113dSnw141292 * or http://www.opensolaris.org/os/licensing. 10c5c4113dSnw141292 * See the License for the specific language governing permissions 11c5c4113dSnw141292 * and limitations under the License. 12c5c4113dSnw141292 * 13c5c4113dSnw141292 * When distributing Covered Code, include this CDDL HEADER in each 14c5c4113dSnw141292 * file and include the License file at usr/src/OPENSOLARIS.LICENSE. 15c5c4113dSnw141292 * If applicable, add the following below this CDDL HEADER, with the 16c5c4113dSnw141292 * fields enclosed by brackets "[]" replaced with your own identifying 17c5c4113dSnw141292 * information: Portions Copyright [yyyy] [name of copyright owner] 18c5c4113dSnw141292 * 19c5c4113dSnw141292 * CDDL HEADER END 20c5c4113dSnw141292 */ 21c5c4113dSnw141292 /* 22c5c4113dSnw141292 * Copyright 2007 Sun Microsystems, Inc. All rights reserved. 23c5c4113dSnw141292 * Use is subject to license terms. 24c5c4113dSnw141292 */ 25c5c4113dSnw141292 26c5c4113dSnw141292 #pragma ident "%Z%%M% %I% %E% SMI" 27c5c4113dSnw141292 28c5c4113dSnw141292 /* 29c5c4113dSnw141292 * Service routines 30c5c4113dSnw141292 */ 31c5c4113dSnw141292 32c5c4113dSnw141292 #include "idmapd.h" 33c5c4113dSnw141292 #include "idmap_priv.h" 34c5c4113dSnw141292 #include <signal.h> 35c5c4113dSnw141292 #include <thread.h> 36c5c4113dSnw141292 #include <string.h> 37c5c4113dSnw141292 #include <strings.h> 38c5c4113dSnw141292 #include <errno.h> 39c5c4113dSnw141292 #include <assert.h> 40c5c4113dSnw141292 #include <sys/types.h> 41c5c4113dSnw141292 #include <sys/stat.h> 42c5c4113dSnw141292 #include <ucred.h> 43c5c4113dSnw141292 #include <pwd.h> 44c5c4113dSnw141292 #include <auth_attr.h> 45c5c4113dSnw141292 #include <secdb.h> 46c5c4113dSnw141292 47c5c4113dSnw141292 #define _VALIDATE_LIST_CB_DATA(col, val, siz)\ 48c5c4113dSnw141292 retcode = validate_list_cb_data(cb_data, argc, argv, col,\ 49c5c4113dSnw141292 (uchar_t **)val, siz);\ 50c5c4113dSnw141292 if (retcode == IDMAP_NEXT) {\ 51c5c4113dSnw141292 result->retcode = IDMAP_NEXT;\ 52c5c4113dSnw141292 return (0);\ 53c5c4113dSnw141292 } else if (retcode < 0) {\ 54c5c4113dSnw141292 result->retcode = retcode;\ 55c5c4113dSnw141292 return (1);\ 56c5c4113dSnw141292 } 57c5c4113dSnw141292 58c5c4113dSnw141292 #define PROCESS_LIST_SVC_SQL(rcode, db, sql, limit, cb, res, len)\ 59c5c4113dSnw141292 rcode = process_list_svc_sql(db, sql, limit, cb, res);\ 60c5c4113dSnw141292 if (rcode == IDMAP_ERR_BUSY)\ 61c5c4113dSnw141292 res->retcode = IDMAP_ERR_BUSY;\ 62c5c4113dSnw141292 else if (rcode == IDMAP_SUCCESS && len == 0)\ 63c5c4113dSnw141292 res->retcode = IDMAP_ERR_NOTFOUND; 64c5c4113dSnw141292 65c5c4113dSnw141292 668e228215Sdm199847 #define STRDUP_OR_FAIL(to, from) \ 678e228215Sdm199847 if ((from) == NULL) \ 688e228215Sdm199847 to = NULL; \ 698e228215Sdm199847 else { \ 708e228215Sdm199847 if ((to = strdup(from)) == NULL) \ 718e228215Sdm199847 return (1); \ 728e228215Sdm199847 } 738e228215Sdm199847 74c5c4113dSnw141292 /* ARGSUSED */ 75c5c4113dSnw141292 bool_t 76*cd37da74Snw141292 idmap_null_1_svc(void *result, struct svc_req *rqstp) 77*cd37da74Snw141292 { 78c5c4113dSnw141292 return (TRUE); 79c5c4113dSnw141292 } 80c5c4113dSnw141292 81334e3463Sbaban /* 82334e3463Sbaban * RPC layer allocates empty strings to replace NULL char *. 83334e3463Sbaban * This utility function frees these empty strings. 84334e3463Sbaban */ 85334e3463Sbaban static void 86334e3463Sbaban sanitize_mapping_request(idmap_mapping *req) 87334e3463Sbaban { 88334e3463Sbaban free(req->id1name); 89334e3463Sbaban req->id1name = NULL; 90334e3463Sbaban free(req->id1domain); 91334e3463Sbaban req->id1domain = NULL; 92334e3463Sbaban free(req->id2name); 93334e3463Sbaban req->id2name = NULL; 94334e3463Sbaban free(req->id2domain); 95334e3463Sbaban req->id2domain = NULL; 96334e3463Sbaban } 97334e3463Sbaban 98c5c4113dSnw141292 /* ARGSUSED */ 99c5c4113dSnw141292 bool_t 100c5c4113dSnw141292 idmap_get_mapped_ids_1_svc(idmap_mapping_batch batch, 101*cd37da74Snw141292 idmap_ids_res *result, struct svc_req *rqstp) 102*cd37da74Snw141292 { 103c5c4113dSnw141292 sqlite *cache = NULL, *db = NULL; 104c5c4113dSnw141292 lookup_state_t state; 105c5c4113dSnw141292 idmap_retcode retcode, winrc; 10662c60062Sbaban uint_t i; 107c5c4113dSnw141292 108c5c4113dSnw141292 /* Init */ 109c5c4113dSnw141292 (void) memset(result, 0, sizeof (*result)); 110c5c4113dSnw141292 (void) memset(&state, 0, sizeof (state)); 111c5c4113dSnw141292 112c5c4113dSnw141292 /* Return success if nothing was requested */ 113c5c4113dSnw141292 if (batch.idmap_mapping_batch_len < 1) 114c5c4113dSnw141292 goto out; 115c5c4113dSnw141292 116c5c4113dSnw141292 /* Get cache handle */ 117c5c4113dSnw141292 result->retcode = get_cache_handle(&cache); 118c5c4113dSnw141292 if (result->retcode != IDMAP_SUCCESS) 119c5c4113dSnw141292 goto out; 120c5c4113dSnw141292 121c5c4113dSnw141292 /* Get db handle */ 122c5c4113dSnw141292 result->retcode = get_db_handle(&db); 123c5c4113dSnw141292 if (result->retcode != IDMAP_SUCCESS) 124c5c4113dSnw141292 goto out; 125c5c4113dSnw141292 126c5c4113dSnw141292 /* Allocate result array */ 127c5c4113dSnw141292 result->ids.ids_val = calloc(batch.idmap_mapping_batch_len, 128c5c4113dSnw141292 sizeof (idmap_id_res)); 129c5c4113dSnw141292 if (result->ids.ids_val == NULL) { 130c5c4113dSnw141292 idmapdlog(LOG_ERR, "Out of memory"); 131c5c4113dSnw141292 result->retcode = IDMAP_ERR_MEMORY; 132c5c4113dSnw141292 goto out; 133c5c4113dSnw141292 } 134c5c4113dSnw141292 result->ids.ids_len = batch.idmap_mapping_batch_len; 135c5c4113dSnw141292 13662c60062Sbaban /* Allocate hash table to check for duplicate sids */ 13762c60062Sbaban state.sid_history = calloc(batch.idmap_mapping_batch_len, 13862c60062Sbaban sizeof (*state.sid_history)); 13962c60062Sbaban if (state.sid_history == NULL) { 14062c60062Sbaban idmapdlog(LOG_ERR, "Out of memory"); 14162c60062Sbaban result->retcode = IDMAP_ERR_MEMORY; 14262c60062Sbaban goto out; 14362c60062Sbaban } 14462c60062Sbaban state.sid_history_size = batch.idmap_mapping_batch_len; 14562c60062Sbaban for (i = 0; i < state.sid_history_size; i++) { 14662c60062Sbaban state.sid_history[i].key = state.sid_history_size; 14762c60062Sbaban state.sid_history[i].next = state.sid_history_size; 14862c60062Sbaban } 14962c60062Sbaban state.batch = &batch; 15062c60062Sbaban state.result = result; 15162c60062Sbaban 152c5c4113dSnw141292 /* Init our 'done' flags */ 153c5c4113dSnw141292 state.sid2pid_done = state.pid2sid_done = TRUE; 154c5c4113dSnw141292 155c5c4113dSnw141292 /* First stage */ 156c5c4113dSnw141292 for (i = 0; i < batch.idmap_mapping_batch_len; i++) { 15762c60062Sbaban state.curpos = i; 158334e3463Sbaban (void) sanitize_mapping_request( 159334e3463Sbaban &batch.idmap_mapping_batch_val[i]); 160c5c4113dSnw141292 if (IS_BATCH_SID(batch, i)) { 161c5c4113dSnw141292 retcode = sid2pid_first_pass( 162c5c4113dSnw141292 &state, 163c5c4113dSnw141292 cache, 164c5c4113dSnw141292 &batch.idmap_mapping_batch_val[i], 165c5c4113dSnw141292 &result->ids.ids_val[i]); 166c5c4113dSnw141292 } else if (IS_BATCH_UID(batch, i)) { 167c5c4113dSnw141292 retcode = pid2sid_first_pass( 168c5c4113dSnw141292 &state, 169c5c4113dSnw141292 cache, 170c5c4113dSnw141292 db, 171c5c4113dSnw141292 &batch.idmap_mapping_batch_val[i], 172c5c4113dSnw141292 &result->ids.ids_val[i], 1, 0); 173c5c4113dSnw141292 } else if (IS_BATCH_GID(batch, i)) { 174c5c4113dSnw141292 retcode = pid2sid_first_pass( 175c5c4113dSnw141292 &state, 176c5c4113dSnw141292 cache, 177c5c4113dSnw141292 db, 178c5c4113dSnw141292 &batch.idmap_mapping_batch_val[i], 179c5c4113dSnw141292 &result->ids.ids_val[i], 0, 0); 180c5c4113dSnw141292 } else { 181c5c4113dSnw141292 result->ids.ids_val[i].retcode = IDMAP_ERR_IDTYPE; 182c5c4113dSnw141292 continue; 183c5c4113dSnw141292 } 184c5c4113dSnw141292 if (IDMAP_FATAL_ERROR(retcode)) { 185c5c4113dSnw141292 result->retcode = retcode; 186c5c4113dSnw141292 goto out; 187c5c4113dSnw141292 } 188c5c4113dSnw141292 } 189c5c4113dSnw141292 190c5c4113dSnw141292 /* Check if we are done */ 191c5c4113dSnw141292 if (state.sid2pid_done == TRUE && state.pid2sid_done == TRUE) 192c5c4113dSnw141292 goto out; 193c5c4113dSnw141292 194c5c4113dSnw141292 /* Process Windows server lookups for sid2name */ 195c5c4113dSnw141292 if (state.ad_nqueries) { 196c5c4113dSnw141292 winrc = lookup_win_batch_sid2name(&state, &batch, 197c5c4113dSnw141292 result); 198c5c4113dSnw141292 if (IDMAP_FATAL_ERROR(winrc)) { 199c5c4113dSnw141292 result->retcode = winrc; 200c5c4113dSnw141292 goto out; 201c5c4113dSnw141292 } 202c5c4113dSnw141292 } else 203c5c4113dSnw141292 winrc = IDMAP_SUCCESS; 204c5c4113dSnw141292 205c5c4113dSnw141292 /* Reset sid2pid 'done' flag */ 206c5c4113dSnw141292 state.sid2pid_done = TRUE; 207c5c4113dSnw141292 208c5c4113dSnw141292 /* Second stage */ 209c5c4113dSnw141292 for (i = 0; i < batch.idmap_mapping_batch_len; i++) { 21062c60062Sbaban state.curpos = i; 211c5c4113dSnw141292 /* Process sid to pid ONLY */ 212c5c4113dSnw141292 if (IS_BATCH_SID(batch, i)) { 213c5c4113dSnw141292 if (IDMAP_ERROR(winrc)) 214c5c4113dSnw141292 result->ids.ids_val[i].retcode = winrc; 215c5c4113dSnw141292 retcode = sid2pid_second_pass( 216c5c4113dSnw141292 &state, 217c5c4113dSnw141292 cache, 218c5c4113dSnw141292 db, 219c5c4113dSnw141292 &batch.idmap_mapping_batch_val[i], 220c5c4113dSnw141292 &result->ids.ids_val[i]); 221c5c4113dSnw141292 if (IDMAP_FATAL_ERROR(retcode)) { 222c5c4113dSnw141292 result->retcode = retcode; 223c5c4113dSnw141292 goto out; 224c5c4113dSnw141292 } 225c5c4113dSnw141292 } 226c5c4113dSnw141292 } 227c5c4113dSnw141292 228c5c4113dSnw141292 /* Check if we are done */ 229c5c4113dSnw141292 if (state.sid2pid_done == TRUE && state.pid2sid_done == TRUE) 230c5c4113dSnw141292 goto out; 231c5c4113dSnw141292 232c5c4113dSnw141292 /* Reset our 'done' flags */ 233c5c4113dSnw141292 state.sid2pid_done = state.pid2sid_done = TRUE; 234c5c4113dSnw141292 235c5c4113dSnw141292 /* Update cache in a single transaction */ 236c5c4113dSnw141292 if (sql_exec_no_cb(cache, "BEGIN TRANSACTION;") != IDMAP_SUCCESS) 237c5c4113dSnw141292 goto out; 238c5c4113dSnw141292 239c5c4113dSnw141292 for (i = 0; i < batch.idmap_mapping_batch_len; i++) { 24062c60062Sbaban state.curpos = i; 241c5c4113dSnw141292 if (IS_BATCH_SID(batch, i)) { 242c5c4113dSnw141292 (void) update_cache_sid2pid( 243c5c4113dSnw141292 &state, 244c5c4113dSnw141292 cache, 245c5c4113dSnw141292 &batch.idmap_mapping_batch_val[i], 246c5c4113dSnw141292 &result->ids.ids_val[i]); 247c5c4113dSnw141292 } else if ((IS_BATCH_UID(batch, i)) || 248c5c4113dSnw141292 (IS_BATCH_GID(batch, i))) { 249c5c4113dSnw141292 (void) update_cache_pid2sid( 250c5c4113dSnw141292 &state, 251c5c4113dSnw141292 cache, 252c5c4113dSnw141292 &batch.idmap_mapping_batch_val[i], 253c5c4113dSnw141292 &result->ids.ids_val[i]); 254c5c4113dSnw141292 } 255c5c4113dSnw141292 } 256c5c4113dSnw141292 257c5c4113dSnw141292 /* Commit if we have at least one successful update */ 258c5c4113dSnw141292 if (state.sid2pid_done == FALSE || state.pid2sid_done == FALSE) 259c5c4113dSnw141292 (void) sql_exec_no_cb(cache, "COMMIT TRANSACTION;"); 260c5c4113dSnw141292 else 261c5c4113dSnw141292 (void) sql_exec_no_cb(cache, "END TRANSACTION;"); 262c5c4113dSnw141292 263c5c4113dSnw141292 out: 26462c60062Sbaban if (state.sid_history) 26562c60062Sbaban free(state.sid_history); 266c5c4113dSnw141292 if (IDMAP_ERROR(result->retcode)) { 267c5c4113dSnw141292 xdr_free(xdr_idmap_ids_res, (caddr_t)result); 268c5c4113dSnw141292 result->ids.ids_len = 0; 269c5c4113dSnw141292 result->ids.ids_val = NULL; 270c5c4113dSnw141292 } 271c5c4113dSnw141292 result->retcode = idmap_stat4prot(result->retcode); 272c5c4113dSnw141292 return (TRUE); 273c5c4113dSnw141292 } 274c5c4113dSnw141292 275c5c4113dSnw141292 276c5c4113dSnw141292 /* ARGSUSED */ 277*cd37da74Snw141292 static 278*cd37da74Snw141292 int 279*cd37da74Snw141292 list_mappings_cb(void *parg, int argc, char **argv, char **colnames) 280*cd37da74Snw141292 { 281c5c4113dSnw141292 list_cb_data_t *cb_data; 282c5c4113dSnw141292 char *str; 283c5c4113dSnw141292 idmap_mappings_res *result; 284c5c4113dSnw141292 idmap_retcode retcode; 285c5c4113dSnw141292 int w2u, u2w; 286c5c4113dSnw141292 char *end; 287*cd37da74Snw141292 static int validated_column_names = 0; 288*cd37da74Snw141292 289*cd37da74Snw141292 if (!validated_column_names) { 290*cd37da74Snw141292 assert(strcmp(colnames[0], "rowid") == 0); 291*cd37da74Snw141292 assert(strcmp(colnames[1], "sidprefix") == 0); 292*cd37da74Snw141292 assert(strcmp(colnames[2], "rid") == 0); 293*cd37da74Snw141292 assert(strcmp(colnames[3], "pid") == 0); 294*cd37da74Snw141292 assert(strcmp(colnames[4], "w2u") == 0); 295*cd37da74Snw141292 assert(strcmp(colnames[5], "u2w") == 0); 296*cd37da74Snw141292 assert(strcmp(colnames[6], "windomain") == 0); 297*cd37da74Snw141292 assert(strcmp(colnames[7], "canon_winname") == 0); 298*cd37da74Snw141292 assert(strcmp(colnames[8], "unixname") == 0); 299*cd37da74Snw141292 assert(strcmp(colnames[9], "is_user") == 0); 300*cd37da74Snw141292 assert(strcmp(colnames[10], "is_wuser") == 0); 301*cd37da74Snw141292 validated_column_names = 1; 302*cd37da74Snw141292 } 303*cd37da74Snw141292 304c5c4113dSnw141292 305c5c4113dSnw141292 cb_data = (list_cb_data_t *)parg; 306c5c4113dSnw141292 result = (idmap_mappings_res *)cb_data->result; 307c5c4113dSnw141292 308*cd37da74Snw141292 _VALIDATE_LIST_CB_DATA(11, &result->mappings.mappings_val, 309c5c4113dSnw141292 sizeof (idmap_mapping)); 310c5c4113dSnw141292 311c5c4113dSnw141292 result->mappings.mappings_len++; 312c5c4113dSnw141292 313c5c4113dSnw141292 if ((str = strdup(argv[1])) == NULL) 314c5c4113dSnw141292 return (1); 315c5c4113dSnw141292 result->mappings.mappings_val[cb_data->next].id1.idmap_id_u.sid.prefix = 316c5c4113dSnw141292 str; 317c5c4113dSnw141292 result->mappings.mappings_val[cb_data->next].id1.idmap_id_u.sid.rid = 318c5c4113dSnw141292 strtoul(argv[2], &end, 10); 319*cd37da74Snw141292 result->mappings.mappings_val[cb_data->next].id1.idtype = 320*cd37da74Snw141292 strtol(argv[10], &end, 10) ? IDMAP_USID : IDMAP_GSID; 321c5c4113dSnw141292 322c5c4113dSnw141292 result->mappings.mappings_val[cb_data->next].id2.idmap_id_u.uid = 323c5c4113dSnw141292 strtoul(argv[3], &end, 10); 324*cd37da74Snw141292 result->mappings.mappings_val[cb_data->next].id2.idtype = 325*cd37da74Snw141292 strtol(argv[9], &end, 10) ? IDMAP_UID : IDMAP_GID; 326c5c4113dSnw141292 327c5c4113dSnw141292 w2u = argv[4] ? strtol(argv[4], &end, 10) : 0; 328c5c4113dSnw141292 u2w = argv[5] ? strtol(argv[5], &end, 10) : 0; 329c5c4113dSnw141292 330c5c4113dSnw141292 if (w2u > 0 && u2w == 0) 331651c0131Sbaban result->mappings.mappings_val[cb_data->next].direction = 332651c0131Sbaban IDMAP_DIRECTION_W2U; 333c5c4113dSnw141292 else if (w2u == 0 && u2w > 0) 334651c0131Sbaban result->mappings.mappings_val[cb_data->next].direction = 335651c0131Sbaban IDMAP_DIRECTION_U2W; 336c5c4113dSnw141292 else 337651c0131Sbaban result->mappings.mappings_val[cb_data->next].direction = 338651c0131Sbaban IDMAP_DIRECTION_BI; 339c5c4113dSnw141292 3408e228215Sdm199847 STRDUP_OR_FAIL(result->mappings.mappings_val[cb_data->next].id1domain, 3418e228215Sdm199847 argv[6]); 342c5c4113dSnw141292 3438e228215Sdm199847 STRDUP_OR_FAIL(result->mappings.mappings_val[cb_data->next].id1name, 3448e228215Sdm199847 argv[7]); 345c5c4113dSnw141292 3468e228215Sdm199847 STRDUP_OR_FAIL(result->mappings.mappings_val[cb_data->next].id2name, 3478e228215Sdm199847 argv[8]); 3488e228215Sdm199847 349c5c4113dSnw141292 350c5c4113dSnw141292 result->lastrowid = strtoll(argv[0], &end, 10); 351c5c4113dSnw141292 cb_data->next++; 352c5c4113dSnw141292 result->retcode = IDMAP_SUCCESS; 353c5c4113dSnw141292 return (0); 354c5c4113dSnw141292 } 355c5c4113dSnw141292 356c5c4113dSnw141292 357c5c4113dSnw141292 /* ARGSUSED */ 358c5c4113dSnw141292 bool_t 359*cd37da74Snw141292 idmap_list_mappings_1_svc(int64_t lastrowid, uint64_t limit, 360*cd37da74Snw141292 idmap_mappings_res *result, struct svc_req *rqstp) 361*cd37da74Snw141292 { 362c5c4113dSnw141292 sqlite *cache = NULL; 363c5c4113dSnw141292 char lbuf[30], rbuf[30]; 364c5c4113dSnw141292 uint64_t maxlimit; 365c5c4113dSnw141292 idmap_retcode retcode; 366c5c4113dSnw141292 char *sql = NULL; 367c5c4113dSnw141292 368c5c4113dSnw141292 (void) memset(result, 0, sizeof (*result)); 369c5c4113dSnw141292 lbuf[0] = rbuf[0] = 0; 370c5c4113dSnw141292 371c5c4113dSnw141292 RDLOCK_CONFIG(); 372c5c4113dSnw141292 maxlimit = _idmapdstate.cfg->pgcfg.list_size_limit; 373c5c4113dSnw141292 UNLOCK_CONFIG(); 374c5c4113dSnw141292 375c5c4113dSnw141292 /* Get cache handle */ 376c5c4113dSnw141292 result->retcode = get_cache_handle(&cache); 377c5c4113dSnw141292 if (result->retcode != IDMAP_SUCCESS) 378c5c4113dSnw141292 goto out; 379c5c4113dSnw141292 380c5c4113dSnw141292 result->retcode = IDMAP_ERR_INTERNAL; 381c5c4113dSnw141292 382c5c4113dSnw141292 /* Create LIMIT expression. */ 383c5c4113dSnw141292 if (limit == 0 || (maxlimit > 0 && maxlimit < limit)) 384c5c4113dSnw141292 limit = maxlimit; 385c5c4113dSnw141292 if (limit > 0) 386c5c4113dSnw141292 (void) snprintf(lbuf, sizeof (lbuf), 387c5c4113dSnw141292 "LIMIT %" PRIu64, limit + 1ULL); 388c5c4113dSnw141292 389c5c4113dSnw141292 (void) snprintf(rbuf, sizeof (rbuf), "rowid > %" PRIu64, lastrowid); 390c5c4113dSnw141292 391c5c4113dSnw141292 /* 392c5c4113dSnw141292 * Combine all the above into a giant SELECT statement that 393c5c4113dSnw141292 * will return the requested mappings 394c5c4113dSnw141292 */ 395c5c4113dSnw141292 sql = sqlite_mprintf("SELECT rowid, sidprefix, rid, pid, w2u, u2w, " 396*cd37da74Snw141292 "windomain, canon_winname, unixname, is_user, is_wuser " 397c5c4113dSnw141292 " FROM idmap_cache WHERE " 398*cd37da74Snw141292 " %s %s;", 399*cd37da74Snw141292 rbuf, lbuf); 400c5c4113dSnw141292 if (sql == NULL) { 401c5c4113dSnw141292 idmapdlog(LOG_ERR, "Out of memory"); 402c5c4113dSnw141292 goto out; 403c5c4113dSnw141292 } 404c5c4113dSnw141292 405c5c4113dSnw141292 /* Execute the SQL statement and update the return buffer */ 406c5c4113dSnw141292 PROCESS_LIST_SVC_SQL(retcode, cache, sql, limit, list_mappings_cb, 407c5c4113dSnw141292 result, result->mappings.mappings_len); 408c5c4113dSnw141292 409c5c4113dSnw141292 out: 410c5c4113dSnw141292 if (sql) 411c5c4113dSnw141292 sqlite_freemem(sql); 412c5c4113dSnw141292 if (IDMAP_ERROR(result->retcode)) 413c5c4113dSnw141292 (void) xdr_free(xdr_idmap_mappings_res, (caddr_t)result); 414c5c4113dSnw141292 result->retcode = idmap_stat4prot(result->retcode); 415c5c4113dSnw141292 return (TRUE); 416c5c4113dSnw141292 } 417c5c4113dSnw141292 418c5c4113dSnw141292 419c5c4113dSnw141292 /* ARGSUSED */ 420*cd37da74Snw141292 static 421*cd37da74Snw141292 int 422*cd37da74Snw141292 list_namerules_cb(void *parg, int argc, char **argv, char **colnames) 423*cd37da74Snw141292 { 424c5c4113dSnw141292 list_cb_data_t *cb_data; 425c5c4113dSnw141292 idmap_namerules_res *result; 426c5c4113dSnw141292 idmap_retcode retcode; 427c5c4113dSnw141292 int w2u_order, u2w_order; 428c5c4113dSnw141292 char *end; 429*cd37da74Snw141292 static int validated_column_names = 0; 430*cd37da74Snw141292 431*cd37da74Snw141292 if (!validated_column_names) { 432*cd37da74Snw141292 assert(strcmp(colnames[0], "rowid") == 0); 433*cd37da74Snw141292 assert(strcmp(colnames[1], "is_user") == 0); 434*cd37da74Snw141292 assert(strcmp(colnames[2], "is_wuser") == 0); 435*cd37da74Snw141292 assert(strcmp(colnames[3], "windomain") == 0); 436*cd37da74Snw141292 assert(strcmp(colnames[4], "winname_display") == 0); 437*cd37da74Snw141292 assert(strcmp(colnames[5], "is_nt4") == 0); 438*cd37da74Snw141292 assert(strcmp(colnames[6], "unixname") == 0); 439*cd37da74Snw141292 assert(strcmp(colnames[7], "w2u_order") == 0); 440*cd37da74Snw141292 assert(strcmp(colnames[8], "u2w_order") == 0); 441*cd37da74Snw141292 validated_column_names = 1; 442*cd37da74Snw141292 } 443c5c4113dSnw141292 444c5c4113dSnw141292 cb_data = (list_cb_data_t *)parg; 445c5c4113dSnw141292 result = (idmap_namerules_res *)cb_data->result; 446c5c4113dSnw141292 447*cd37da74Snw141292 _VALIDATE_LIST_CB_DATA(9, &result->rules.rules_val, 448c5c4113dSnw141292 sizeof (idmap_namerule)); 449c5c4113dSnw141292 450c5c4113dSnw141292 result->rules.rules_len++; 451c5c4113dSnw141292 452c5c4113dSnw141292 result->rules.rules_val[cb_data->next].is_user = 453c5c4113dSnw141292 strtol(argv[1], &end, 10); 454c5c4113dSnw141292 455*cd37da74Snw141292 result->rules.rules_val[cb_data->next].is_wuser = 456*cd37da74Snw141292 strtol(argv[2], &end, 10); 457c5c4113dSnw141292 458*cd37da74Snw141292 STRDUP_OR_FAIL(result->rules.rules_val[cb_data->next].windomain, 4598e228215Sdm199847 argv[3]); 460c5c4113dSnw141292 461*cd37da74Snw141292 STRDUP_OR_FAIL(result->rules.rules_val[cb_data->next].winname, 462*cd37da74Snw141292 argv[4]); 463*cd37da74Snw141292 464c5c4113dSnw141292 result->rules.rules_val[cb_data->next].is_nt4 = 465*cd37da74Snw141292 strtol(argv[5], &end, 10); 466c5c4113dSnw141292 4678e228215Sdm199847 STRDUP_OR_FAIL(result->rules.rules_val[cb_data->next].unixname, 468*cd37da74Snw141292 argv[6]); 469c5c4113dSnw141292 470*cd37da74Snw141292 w2u_order = argv[7] ? strtol(argv[7], &end, 10) : 0; 471*cd37da74Snw141292 u2w_order = argv[8] ? strtol(argv[8], &end, 10) : 0; 472c5c4113dSnw141292 473c5c4113dSnw141292 if (w2u_order > 0 && u2w_order == 0) 474651c0131Sbaban result->rules.rules_val[cb_data->next].direction = 475651c0131Sbaban IDMAP_DIRECTION_W2U; 476c5c4113dSnw141292 else if (w2u_order == 0 && u2w_order > 0) 477651c0131Sbaban result->rules.rules_val[cb_data->next].direction = 478651c0131Sbaban IDMAP_DIRECTION_U2W; 479c5c4113dSnw141292 else 480651c0131Sbaban result->rules.rules_val[cb_data->next].direction = 481651c0131Sbaban IDMAP_DIRECTION_BI; 482c5c4113dSnw141292 483c5c4113dSnw141292 result->lastrowid = strtoll(argv[0], &end, 10); 484c5c4113dSnw141292 cb_data->next++; 485c5c4113dSnw141292 result->retcode = IDMAP_SUCCESS; 486c5c4113dSnw141292 return (0); 487c5c4113dSnw141292 } 488c5c4113dSnw141292 489c5c4113dSnw141292 490c5c4113dSnw141292 /* ARGSUSED */ 491c5c4113dSnw141292 bool_t 492c5c4113dSnw141292 idmap_list_namerules_1_svc(idmap_namerule rule, uint64_t lastrowid, 493c5c4113dSnw141292 uint64_t limit, idmap_namerules_res *result, 494*cd37da74Snw141292 struct svc_req *rqstp) 495*cd37da74Snw141292 { 496c5c4113dSnw141292 497c5c4113dSnw141292 sqlite *db = NULL; 498c5c4113dSnw141292 char w2ubuf[15], u2wbuf[15]; 499c5c4113dSnw141292 char lbuf[30], rbuf[30]; 500c5c4113dSnw141292 char *sql = NULL; 501*cd37da74Snw141292 char *expr = NULL; 502c5c4113dSnw141292 uint64_t maxlimit; 503c5c4113dSnw141292 idmap_retcode retcode; 504c5c4113dSnw141292 505c5c4113dSnw141292 (void) memset(result, 0, sizeof (*result)); 506c5c4113dSnw141292 lbuf[0] = rbuf[0] = 0; 507c5c4113dSnw141292 508c5c4113dSnw141292 RDLOCK_CONFIG(); 509c5c4113dSnw141292 maxlimit = _idmapdstate.cfg->pgcfg.list_size_limit; 510c5c4113dSnw141292 UNLOCK_CONFIG(); 511c5c4113dSnw141292 512c5c4113dSnw141292 /* Get db handle */ 513c5c4113dSnw141292 result->retcode = get_db_handle(&db); 514c5c4113dSnw141292 if (result->retcode != IDMAP_SUCCESS) 515c5c4113dSnw141292 goto out; 516c5c4113dSnw141292 517c5c4113dSnw141292 result->retcode = IDMAP_ERR_INTERNAL; 518c5c4113dSnw141292 519c5c4113dSnw141292 w2ubuf[0] = u2wbuf[0] = 0; 520*cd37da74Snw141292 if (rule.direction == IDMAP_DIRECTION_BI) { 521c5c4113dSnw141292 (void) snprintf(w2ubuf, sizeof (w2ubuf), "AND w2u_order > 0"); 522c5c4113dSnw141292 (void) snprintf(u2wbuf, sizeof (u2wbuf), "AND u2w_order > 0"); 523651c0131Sbaban } else if (rule.direction == IDMAP_DIRECTION_W2U) { 524c5c4113dSnw141292 (void) snprintf(w2ubuf, sizeof (w2ubuf), "AND w2u_order > 0"); 525c5c4113dSnw141292 (void) snprintf(u2wbuf, sizeof (u2wbuf), 526c5c4113dSnw141292 "AND (u2w_order = 0 OR u2w_order ISNULL)"); 527651c0131Sbaban } else if (rule.direction == IDMAP_DIRECTION_U2W) { 528c5c4113dSnw141292 (void) snprintf(w2ubuf, sizeof (w2ubuf), 529c5c4113dSnw141292 "AND (w2u_order = 0 OR w2u_order ISNULL)"); 530c5c4113dSnw141292 (void) snprintf(u2wbuf, sizeof (u2wbuf), "AND u2w_order > 0"); 531c5c4113dSnw141292 } 532c5c4113dSnw141292 533*cd37da74Snw141292 retcode = gen_sql_expr_from_rule(&rule, &expr); 534*cd37da74Snw141292 if (retcode != IDMAP_SUCCESS) 535c5c4113dSnw141292 goto out; 536c5c4113dSnw141292 537c5c4113dSnw141292 /* Create LIMIT expression. */ 538c5c4113dSnw141292 if (limit == 0 || (maxlimit > 0 && maxlimit < limit)) 539c5c4113dSnw141292 limit = maxlimit; 540c5c4113dSnw141292 if (limit > 0) 541c5c4113dSnw141292 (void) snprintf(lbuf, sizeof (lbuf), 542c5c4113dSnw141292 "LIMIT %" PRIu64, limit + 1ULL); 543c5c4113dSnw141292 544c5c4113dSnw141292 (void) snprintf(rbuf, sizeof (rbuf), "rowid > %" PRIu64, lastrowid); 545c5c4113dSnw141292 546c5c4113dSnw141292 /* 547c5c4113dSnw141292 * Combine all the above into a giant SELECT statement that 548c5c4113dSnw141292 * will return the requested rules 549c5c4113dSnw141292 */ 550*cd37da74Snw141292 sql = sqlite_mprintf("SELECT rowid, is_user, is_wuser, windomain, " 551*cd37da74Snw141292 "winname_display, is_nt4, unixname, w2u_order, u2w_order " 552c5c4113dSnw141292 "FROM namerules WHERE " 553*cd37da74Snw141292 " %s %s %s %s %s;", 554*cd37da74Snw141292 rbuf, expr, w2ubuf, u2wbuf, lbuf); 555*cd37da74Snw141292 556c5c4113dSnw141292 if (sql == NULL) { 557c5c4113dSnw141292 idmapdlog(LOG_ERR, "Out of memory"); 558c5c4113dSnw141292 goto out; 559c5c4113dSnw141292 } 560c5c4113dSnw141292 561c5c4113dSnw141292 /* Execute the SQL statement and update the return buffer */ 562c5c4113dSnw141292 PROCESS_LIST_SVC_SQL(retcode, db, sql, limit, list_namerules_cb, 563c5c4113dSnw141292 result, result->rules.rules_len); 564c5c4113dSnw141292 565c5c4113dSnw141292 out: 566*cd37da74Snw141292 if (expr) 567*cd37da74Snw141292 sqlite_freemem(expr); 568c5c4113dSnw141292 if (sql) 569c5c4113dSnw141292 sqlite_freemem(sql); 570c5c4113dSnw141292 if (IDMAP_ERROR(result->retcode)) 571c5c4113dSnw141292 (void) xdr_free(xdr_idmap_namerules_res, (caddr_t)result); 572c5c4113dSnw141292 result->retcode = idmap_stat4prot(result->retcode); 573c5c4113dSnw141292 return (TRUE); 574c5c4113dSnw141292 } 575c5c4113dSnw141292 576c5c4113dSnw141292 #define IDMAP_RULES_AUTH "solaris.admin.idmap.rules" 577c5c4113dSnw141292 static int 578*cd37da74Snw141292 verify_rules_auth(struct svc_req *rqstp) 579*cd37da74Snw141292 { 580c5c4113dSnw141292 ucred_t *uc = NULL; 581c5c4113dSnw141292 uid_t uid; 582c5c4113dSnw141292 char buf[1024]; 583c5c4113dSnw141292 struct passwd pwd; 584c5c4113dSnw141292 const char *me = "verify_rules_auth"; 585c5c4113dSnw141292 586c5c4113dSnw141292 if (svc_getcallerucred(rqstp->rq_xprt, &uc) != 0) { 587c5c4113dSnw141292 idmapdlog(LOG_ERR, 588c5c4113dSnw141292 "%s: svc_getcallerucred failed (errno=%d)", 589c5c4113dSnw141292 me, errno); 590c5c4113dSnw141292 return (-1); 591c5c4113dSnw141292 } 592c5c4113dSnw141292 593c5c4113dSnw141292 uid = ucred_geteuid(uc); 594c5c4113dSnw141292 if (uid == (uid_t)-1) { 595c5c4113dSnw141292 idmapdlog(LOG_ERR, 596c5c4113dSnw141292 "%s: ucred_geteuid failed (errno=%d)", 597c5c4113dSnw141292 me, errno); 598c5c4113dSnw141292 ucred_free(uc); 599c5c4113dSnw141292 return (-1); 600c5c4113dSnw141292 } 601c5c4113dSnw141292 602c5c4113dSnw141292 if (getpwuid_r(uid, &pwd, buf, sizeof (buf)) == NULL) { 603c5c4113dSnw141292 idmapdlog(LOG_ERR, 604c5c4113dSnw141292 "%s: getpwuid_r(%u) failed (errno=%d)", 605c5c4113dSnw141292 me, uid, errno); 606c5c4113dSnw141292 ucred_free(uc); 607c5c4113dSnw141292 return (-1); 608c5c4113dSnw141292 } 609c5c4113dSnw141292 610c5c4113dSnw141292 if (chkauthattr(IDMAP_RULES_AUTH, pwd.pw_name) != 1) { 611c5c4113dSnw141292 idmapdlog(LOG_INFO, 612c5c4113dSnw141292 "%s: %s does not have authorization.", 613c5c4113dSnw141292 me, pwd.pw_name); 614c5c4113dSnw141292 ucred_free(uc); 615c5c4113dSnw141292 return (-1); 616c5c4113dSnw141292 } 617c5c4113dSnw141292 618c5c4113dSnw141292 ucred_free(uc); 619c5c4113dSnw141292 return (1); 620c5c4113dSnw141292 } 621c5c4113dSnw141292 6228e228215Sdm199847 /* 6238e228215Sdm199847 * Meaning of the return values is the following: For retcode == 6248e228215Sdm199847 * IDMAP_SUCCESS, everything went OK and error_index is 6258e228215Sdm199847 * undefined. Otherwise, error_index >=0 shows the failed batch 6268e228215Sdm199847 * element. errro_index == -1 indicates failure at the beginning, 6278e228215Sdm199847 * error_index == -2 at the end. 6288e228215Sdm199847 */ 6298e228215Sdm199847 630c5c4113dSnw141292 /* ARGSUSED */ 631c5c4113dSnw141292 bool_t 6328e228215Sdm199847 idmap_update_1_svc(idmap_update_batch batch, idmap_update_res *res, 633*cd37da74Snw141292 struct svc_req *rqstp) 634*cd37da74Snw141292 { 635c5c4113dSnw141292 sqlite *db = NULL; 636c5c4113dSnw141292 idmap_update_op *up; 637c5c4113dSnw141292 int i; 63884decf41Sjp151216 int trans = FALSE; 639c5c4113dSnw141292 6408e228215Sdm199847 res->error_index = -1; 6418e228215Sdm199847 (void) memset(&res->error_rule, 0, sizeof (res->error_rule)); 6428e228215Sdm199847 (void) memset(&res->conflict_rule, 0, sizeof (res->conflict_rule)); 6438e228215Sdm199847 644c5c4113dSnw141292 if (verify_rules_auth(rqstp) < 0) { 6458e228215Sdm199847 res->retcode = IDMAP_ERR_PERMISSION_DENIED; 646c5c4113dSnw141292 goto out; 647c5c4113dSnw141292 } 648c5c4113dSnw141292 649c5c4113dSnw141292 if (batch.idmap_update_batch_len == 0 || 650c5c4113dSnw141292 batch.idmap_update_batch_val == NULL) { 6518e228215Sdm199847 res->retcode = IDMAP_SUCCESS; 652c5c4113dSnw141292 goto out; 653c5c4113dSnw141292 } 654c5c4113dSnw141292 655c5c4113dSnw141292 /* Get db handle */ 6568e228215Sdm199847 res->retcode = get_db_handle(&db); 6578e228215Sdm199847 if (res->retcode != IDMAP_SUCCESS) 658c5c4113dSnw141292 goto out; 659c5c4113dSnw141292 6608e228215Sdm199847 res->retcode = sql_exec_no_cb(db, "BEGIN TRANSACTION;"); 6618e228215Sdm199847 if (res->retcode != IDMAP_SUCCESS) 662c5c4113dSnw141292 goto out; 66384decf41Sjp151216 trans = TRUE; 664c5c4113dSnw141292 665c5c4113dSnw141292 for (i = 0; i < batch.idmap_update_batch_len; i++) { 666c5c4113dSnw141292 up = &batch.idmap_update_batch_val[i]; 667c5c4113dSnw141292 switch (up->opnum) { 668c5c4113dSnw141292 case OP_NONE: 6698e228215Sdm199847 res->retcode = IDMAP_SUCCESS; 670c5c4113dSnw141292 break; 671c5c4113dSnw141292 case OP_ADD_NAMERULE: 6728e228215Sdm199847 res->retcode = add_namerule(db, 673c5c4113dSnw141292 &up->idmap_update_op_u.rule); 674c5c4113dSnw141292 break; 675c5c4113dSnw141292 case OP_RM_NAMERULE: 6768e228215Sdm199847 res->retcode = rm_namerule(db, 677c5c4113dSnw141292 &up->idmap_update_op_u.rule); 678c5c4113dSnw141292 break; 679c5c4113dSnw141292 case OP_FLUSH_NAMERULES: 680*cd37da74Snw141292 res->retcode = flush_namerules(db); 681c5c4113dSnw141292 break; 682c5c4113dSnw141292 default: 6838e228215Sdm199847 res->retcode = IDMAP_ERR_NOTSUPPORTED; 6848e228215Sdm199847 break; 685c5c4113dSnw141292 }; 686c5c4113dSnw141292 6878e228215Sdm199847 if (res->retcode != IDMAP_SUCCESS) { 6888e228215Sdm199847 res->error_index = i; 6898e228215Sdm199847 if (up->opnum == OP_ADD_NAMERULE || 6908e228215Sdm199847 up->opnum == OP_RM_NAMERULE) { 6918e228215Sdm199847 idmap_stat r2 = 6928e228215Sdm199847 idmap_namerule_cpy(&res->error_rule, 6938e228215Sdm199847 &up->idmap_update_op_u.rule); 6948e228215Sdm199847 if (r2 != IDMAP_SUCCESS) 6958e228215Sdm199847 res->retcode = r2; 6968e228215Sdm199847 } 697c5c4113dSnw141292 goto out; 698c5c4113dSnw141292 } 6998e228215Sdm199847 } 700c5c4113dSnw141292 701c5c4113dSnw141292 out: 70284decf41Sjp151216 if (trans) { 7038e228215Sdm199847 if (res->retcode == IDMAP_SUCCESS) { 7048e228215Sdm199847 res->retcode = 7058e228215Sdm199847 sql_exec_no_cb(db, "COMMIT TRANSACTION;"); 7068e228215Sdm199847 if (res->retcode != IDMAP_SUCCESS) 7078e228215Sdm199847 res->error_index = -2; 7088e228215Sdm199847 } 70984decf41Sjp151216 else 71084decf41Sjp151216 (void) sql_exec_no_cb(db, "ROLLBACK TRANSACTION;"); 711c5c4113dSnw141292 } 7128e228215Sdm199847 7138e228215Sdm199847 res->retcode = idmap_stat4prot(res->retcode); 7148e228215Sdm199847 715c5c4113dSnw141292 return (TRUE); 716c5c4113dSnw141292 } 717c5c4113dSnw141292 718c5c4113dSnw141292 719c5c4113dSnw141292 /* ARGSUSED */ 720c5c4113dSnw141292 bool_t 721c5c4113dSnw141292 idmap_get_mapped_id_by_name_1_svc(idmap_mapping request, 722*cd37da74Snw141292 idmap_mappings_res *result, struct svc_req *rqstp) 723*cd37da74Snw141292 { 724c5c4113dSnw141292 sqlite *cache = NULL, *db = NULL; 725c5c4113dSnw141292 726c5c4113dSnw141292 /* Init */ 727c5c4113dSnw141292 (void) memset(result, 0, sizeof (*result)); 728c5c4113dSnw141292 729c5c4113dSnw141292 /* Get cache handle */ 730c5c4113dSnw141292 result->retcode = get_cache_handle(&cache); 731c5c4113dSnw141292 if (result->retcode != IDMAP_SUCCESS) 732c5c4113dSnw141292 goto out; 733c5c4113dSnw141292 734c5c4113dSnw141292 /* Get db handle */ 735c5c4113dSnw141292 result->retcode = get_db_handle(&db); 736c5c4113dSnw141292 if (result->retcode != IDMAP_SUCCESS) 737c5c4113dSnw141292 goto out; 738c5c4113dSnw141292 739c5c4113dSnw141292 /* Allocate result */ 740c5c4113dSnw141292 result->mappings.mappings_val = calloc(1, sizeof (idmap_mapping)); 741c5c4113dSnw141292 if (result->mappings.mappings_val == NULL) { 742c5c4113dSnw141292 idmapdlog(LOG_ERR, "Out of memory"); 743c5c4113dSnw141292 result->retcode = IDMAP_ERR_MEMORY; 744c5c4113dSnw141292 goto out; 745c5c4113dSnw141292 } 746c5c4113dSnw141292 result->mappings.mappings_len = 1; 747c5c4113dSnw141292 748*cd37da74Snw141292 749*cd37da74Snw141292 if (IS_REQUEST_SID(request, 1)) { 750c5c4113dSnw141292 result->retcode = get_w2u_mapping( 751c5c4113dSnw141292 cache, 752c5c4113dSnw141292 db, 753c5c4113dSnw141292 &request, 754c5c4113dSnw141292 result->mappings.mappings_val); 755c5c4113dSnw141292 } else if (IS_REQUEST_UID(request)) { 756c5c4113dSnw141292 result->retcode = get_u2w_mapping( 757c5c4113dSnw141292 cache, 758c5c4113dSnw141292 db, 759c5c4113dSnw141292 &request, 760c5c4113dSnw141292 result->mappings.mappings_val, 761c5c4113dSnw141292 1); 762c5c4113dSnw141292 } else if (IS_REQUEST_GID(request)) { 763c5c4113dSnw141292 result->retcode = get_u2w_mapping( 764c5c4113dSnw141292 cache, 765c5c4113dSnw141292 db, 766c5c4113dSnw141292 &request, 767c5c4113dSnw141292 result->mappings.mappings_val, 768c5c4113dSnw141292 0); 769c5c4113dSnw141292 } else { 770c5c4113dSnw141292 result->retcode = IDMAP_ERR_IDTYPE; 771c5c4113dSnw141292 } 772c5c4113dSnw141292 773c5c4113dSnw141292 out: 774c5c4113dSnw141292 if (IDMAP_FATAL_ERROR(result->retcode)) { 775c5c4113dSnw141292 xdr_free(xdr_idmap_mappings_res, (caddr_t)result); 776c5c4113dSnw141292 result->mappings.mappings_len = 0; 777c5c4113dSnw141292 result->mappings.mappings_val = NULL; 778c5c4113dSnw141292 } 779c5c4113dSnw141292 result->retcode = idmap_stat4prot(result->retcode); 780c5c4113dSnw141292 return (TRUE); 781c5c4113dSnw141292 } 782c5c4113dSnw141292 783c5c4113dSnw141292 784c5c4113dSnw141292 /* ARGSUSED */ 785c5c4113dSnw141292 int 786c5c4113dSnw141292 idmap_prog_1_freeresult(SVCXPRT *transp, xdrproc_t xdr_result, 787*cd37da74Snw141292 caddr_t result) 788*cd37da74Snw141292 { 789c5c4113dSnw141292 (void) xdr_free(xdr_result, result); 790c5c4113dSnw141292 return (TRUE); 791c5c4113dSnw141292 } 792