1*0Sstevel@tonic-gate /*- 2*0Sstevel@tonic-gate * See the file LICENSE for redistribution information. 3*0Sstevel@tonic-gate * 4*0Sstevel@tonic-gate * Copyright (c) 1996, 1997, 1998 5*0Sstevel@tonic-gate * Sleepycat Software. All rights reserved. 6*0Sstevel@tonic-gate */ 7*0Sstevel@tonic-gate #include "config.h" 8*0Sstevel@tonic-gate 9*0Sstevel@tonic-gate #ifndef lint 10*0Sstevel@tonic-gate static const char sccsid[] = "@(#)log_register.c 10.22 (Sleepycat) 9/27/98"; 11*0Sstevel@tonic-gate #endif /* not lint */ 12*0Sstevel@tonic-gate 13*0Sstevel@tonic-gate #ifndef NO_SYSTEM_INCLUDES 14*0Sstevel@tonic-gate #include <sys/types.h> 15*0Sstevel@tonic-gate 16*0Sstevel@tonic-gate #include <errno.h> 17*0Sstevel@tonic-gate #include <string.h> 18*0Sstevel@tonic-gate #endif 19*0Sstevel@tonic-gate 20*0Sstevel@tonic-gate #include "db_int.h" 21*0Sstevel@tonic-gate #include "shqueue.h" 22*0Sstevel@tonic-gate #include "log.h" 23*0Sstevel@tonic-gate #include "common_ext.h" 24*0Sstevel@tonic-gate 25*0Sstevel@tonic-gate /* 26*0Sstevel@tonic-gate * log_register -- 27*0Sstevel@tonic-gate * Register a file name. 28*0Sstevel@tonic-gate */ 29*0Sstevel@tonic-gate int 30*0Sstevel@tonic-gate log_register(dblp, dbp, name, type, idp) 31*0Sstevel@tonic-gate DB_LOG *dblp; 32*0Sstevel@tonic-gate DB *dbp; 33*0Sstevel@tonic-gate const char *name; 34*0Sstevel@tonic-gate DBTYPE type; 35*0Sstevel@tonic-gate u_int32_t *idp; 36*0Sstevel@tonic-gate { 37*0Sstevel@tonic-gate DBT fid_dbt, r_name; 38*0Sstevel@tonic-gate DB_LSN r_unused; 39*0Sstevel@tonic-gate FNAME *fnp, *reuse_fnp; 40*0Sstevel@tonic-gate size_t len; 41*0Sstevel@tonic-gate u_int32_t maxid; 42*0Sstevel@tonic-gate int inserted, ret; 43*0Sstevel@tonic-gate char *fullname; 44*0Sstevel@tonic-gate void *namep; 45*0Sstevel@tonic-gate 46*0Sstevel@tonic-gate inserted = 0; 47*0Sstevel@tonic-gate fullname = NULL; 48*0Sstevel@tonic-gate fnp = namep = reuse_fnp = NULL; 49*0Sstevel@tonic-gate 50*0Sstevel@tonic-gate LOG_PANIC_CHECK(dblp); 51*0Sstevel@tonic-gate 52*0Sstevel@tonic-gate /* Check the arguments. */ 53*0Sstevel@tonic-gate if (type != DB_BTREE && type != DB_HASH && type != DB_RECNO) { 54*0Sstevel@tonic-gate __db_err(dblp->dbenv, "log_register: unknown DB file type"); 55*0Sstevel@tonic-gate return (EINVAL); 56*0Sstevel@tonic-gate } 57*0Sstevel@tonic-gate 58*0Sstevel@tonic-gate /* Get the log file id. */ 59*0Sstevel@tonic-gate if ((ret = __db_appname(dblp->dbenv, 60*0Sstevel@tonic-gate DB_APP_DATA, NULL, name, 0, NULL, &fullname)) != 0) 61*0Sstevel@tonic-gate return (ret); 62*0Sstevel@tonic-gate 63*0Sstevel@tonic-gate LOCK_LOGREGION(dblp); 64*0Sstevel@tonic-gate 65*0Sstevel@tonic-gate /* 66*0Sstevel@tonic-gate * See if we've already got this file in the log, finding the 67*0Sstevel@tonic-gate * (maximum+1) in-use file id and some available file id (if we 68*0Sstevel@tonic-gate * find an available fid, we'll use it, else we'll have to allocate 69*0Sstevel@tonic-gate * one after the maximum that we found). 70*0Sstevel@tonic-gate */ 71*0Sstevel@tonic-gate for (maxid = 0, fnp = SH_TAILQ_FIRST(&dblp->lp->fq, __fname); 72*0Sstevel@tonic-gate fnp != NULL; fnp = SH_TAILQ_NEXT(fnp, q, __fname)) { 73*0Sstevel@tonic-gate if (fnp->ref == 0) { /* Entry is not in use. */ 74*0Sstevel@tonic-gate if (reuse_fnp == NULL) 75*0Sstevel@tonic-gate reuse_fnp = fnp; 76*0Sstevel@tonic-gate continue; 77*0Sstevel@tonic-gate } 78*0Sstevel@tonic-gate if (!memcmp(dbp->fileid, fnp->ufid, DB_FILE_ID_LEN)) { 79*0Sstevel@tonic-gate ++fnp->ref; 80*0Sstevel@tonic-gate goto found; 81*0Sstevel@tonic-gate } 82*0Sstevel@tonic-gate if (maxid <= fnp->id) 83*0Sstevel@tonic-gate maxid = fnp->id + 1; 84*0Sstevel@tonic-gate } 85*0Sstevel@tonic-gate 86*0Sstevel@tonic-gate /* Fill in fnp structure. */ 87*0Sstevel@tonic-gate 88*0Sstevel@tonic-gate if (reuse_fnp != NULL) /* Reuse existing one. */ 89*0Sstevel@tonic-gate fnp = reuse_fnp; 90*0Sstevel@tonic-gate else if ((ret = __db_shalloc(dblp->addr, sizeof(FNAME), 0, &fnp)) != 0) 91*0Sstevel@tonic-gate goto err; 92*0Sstevel@tonic-gate else /* Allocate a new one. */ 93*0Sstevel@tonic-gate fnp->id = maxid; 94*0Sstevel@tonic-gate 95*0Sstevel@tonic-gate fnp->ref = 1; 96*0Sstevel@tonic-gate fnp->s_type = type; 97*0Sstevel@tonic-gate memcpy(fnp->ufid, dbp->fileid, DB_FILE_ID_LEN); 98*0Sstevel@tonic-gate 99*0Sstevel@tonic-gate len = strlen(name) + 1; 100*0Sstevel@tonic-gate if ((ret = __db_shalloc(dblp->addr, len, 0, &namep)) != 0) 101*0Sstevel@tonic-gate goto err; 102*0Sstevel@tonic-gate fnp->name_off = R_OFFSET(dblp, namep); 103*0Sstevel@tonic-gate memcpy(namep, name, len); 104*0Sstevel@tonic-gate 105*0Sstevel@tonic-gate /* Only do the insert if we allocated a new fnp. */ 106*0Sstevel@tonic-gate if (reuse_fnp == NULL) 107*0Sstevel@tonic-gate SH_TAILQ_INSERT_HEAD(&dblp->lp->fq, fnp, q, __fname); 108*0Sstevel@tonic-gate inserted = 1; 109*0Sstevel@tonic-gate 110*0Sstevel@tonic-gate found: /* Log the registry. */ 111*0Sstevel@tonic-gate if (!F_ISSET(dblp, DBC_RECOVER)) { 112*0Sstevel@tonic-gate r_name.data = (void *)name; /* XXX: Yuck! */ 113*0Sstevel@tonic-gate r_name.size = strlen(name) + 1; 114*0Sstevel@tonic-gate memset(&fid_dbt, 0, sizeof(fid_dbt)); 115*0Sstevel@tonic-gate fid_dbt.data = dbp->fileid; 116*0Sstevel@tonic-gate fid_dbt.size = DB_FILE_ID_LEN; 117*0Sstevel@tonic-gate if ((ret = __log_register_log(dblp, NULL, &r_unused, 118*0Sstevel@tonic-gate 0, LOG_OPEN, &r_name, &fid_dbt, fnp->id, type)) != 0) 119*0Sstevel@tonic-gate goto err; 120*0Sstevel@tonic-gate if ((ret = __log_add_logid(dblp, dbp, name, fnp->id)) != 0) 121*0Sstevel@tonic-gate goto err; 122*0Sstevel@tonic-gate } 123*0Sstevel@tonic-gate 124*0Sstevel@tonic-gate if (0) { 125*0Sstevel@tonic-gate err: /* 126*0Sstevel@tonic-gate * XXX 127*0Sstevel@tonic-gate * We should grow the region. 128*0Sstevel@tonic-gate */ 129*0Sstevel@tonic-gate if (inserted) 130*0Sstevel@tonic-gate SH_TAILQ_REMOVE(&dblp->lp->fq, fnp, q, __fname); 131*0Sstevel@tonic-gate if (namep != NULL) 132*0Sstevel@tonic-gate __db_shalloc_free(dblp->addr, namep); 133*0Sstevel@tonic-gate if (fnp != NULL) 134*0Sstevel@tonic-gate __db_shalloc_free(dblp->addr, fnp); 135*0Sstevel@tonic-gate } 136*0Sstevel@tonic-gate 137*0Sstevel@tonic-gate if (idp != NULL) 138*0Sstevel@tonic-gate *idp = fnp->id; 139*0Sstevel@tonic-gate UNLOCK_LOGREGION(dblp); 140*0Sstevel@tonic-gate 141*0Sstevel@tonic-gate if (fullname != NULL) 142*0Sstevel@tonic-gate __os_freestr(fullname); 143*0Sstevel@tonic-gate 144*0Sstevel@tonic-gate return (ret); 145*0Sstevel@tonic-gate } 146*0Sstevel@tonic-gate 147*0Sstevel@tonic-gate /* 148*0Sstevel@tonic-gate * log_unregister -- 149*0Sstevel@tonic-gate * Discard a registered file name. 150*0Sstevel@tonic-gate */ 151*0Sstevel@tonic-gate int 152*0Sstevel@tonic-gate log_unregister(dblp, fid) 153*0Sstevel@tonic-gate DB_LOG *dblp; 154*0Sstevel@tonic-gate u_int32_t fid; 155*0Sstevel@tonic-gate { 156*0Sstevel@tonic-gate DBT fid_dbt, r_name; 157*0Sstevel@tonic-gate DB_LSN r_unused; 158*0Sstevel@tonic-gate FNAME *fnp; 159*0Sstevel@tonic-gate int ret; 160*0Sstevel@tonic-gate 161*0Sstevel@tonic-gate LOG_PANIC_CHECK(dblp); 162*0Sstevel@tonic-gate 163*0Sstevel@tonic-gate ret = 0; 164*0Sstevel@tonic-gate LOCK_LOGREGION(dblp); 165*0Sstevel@tonic-gate 166*0Sstevel@tonic-gate /* Find the entry in the log. */ 167*0Sstevel@tonic-gate for (fnp = SH_TAILQ_FIRST(&dblp->lp->fq, __fname); 168*0Sstevel@tonic-gate fnp != NULL; fnp = SH_TAILQ_NEXT(fnp, q, __fname)) 169*0Sstevel@tonic-gate if (fid == fnp->id) 170*0Sstevel@tonic-gate break; 171*0Sstevel@tonic-gate if (fnp == NULL) { 172*0Sstevel@tonic-gate __db_err(dblp->dbenv, "log_unregister: non-existent file id"); 173*0Sstevel@tonic-gate ret = EINVAL; 174*0Sstevel@tonic-gate goto ret1; 175*0Sstevel@tonic-gate } 176*0Sstevel@tonic-gate 177*0Sstevel@tonic-gate /* Unlog the registry. */ 178*0Sstevel@tonic-gate if (!F_ISSET(dblp, DBC_RECOVER)) { 179*0Sstevel@tonic-gate memset(&r_name, 0, sizeof(r_name)); 180*0Sstevel@tonic-gate r_name.data = R_ADDR(dblp, fnp->name_off); 181*0Sstevel@tonic-gate r_name.size = strlen(r_name.data) + 1; 182*0Sstevel@tonic-gate memset(&fid_dbt, 0, sizeof(fid_dbt)); 183*0Sstevel@tonic-gate fid_dbt.data = fnp->ufid; 184*0Sstevel@tonic-gate fid_dbt.size = DB_FILE_ID_LEN; 185*0Sstevel@tonic-gate if ((ret = __log_register_log(dblp, NULL, &r_unused, 186*0Sstevel@tonic-gate 0, LOG_CLOSE, &r_name, &fid_dbt, fid, fnp->s_type)) != 0) 187*0Sstevel@tonic-gate goto ret1; 188*0Sstevel@tonic-gate } 189*0Sstevel@tonic-gate 190*0Sstevel@tonic-gate /* 191*0Sstevel@tonic-gate * If more than 1 reference, just decrement the reference and return. 192*0Sstevel@tonic-gate * Otherwise, free the name. 193*0Sstevel@tonic-gate */ 194*0Sstevel@tonic-gate --fnp->ref; 195*0Sstevel@tonic-gate if (fnp->ref == 0) 196*0Sstevel@tonic-gate __db_shalloc_free(dblp->addr, R_ADDR(dblp, fnp->name_off)); 197*0Sstevel@tonic-gate 198*0Sstevel@tonic-gate /* 199*0Sstevel@tonic-gate * Remove from the process local table. If this operation is taking 200*0Sstevel@tonic-gate * place during recovery, then the logid was never added to the table, 201*0Sstevel@tonic-gate * so do not remove it. 202*0Sstevel@tonic-gate */ 203*0Sstevel@tonic-gate if (!F_ISSET(dblp, DBC_RECOVER)) 204*0Sstevel@tonic-gate __log_rem_logid(dblp, fid); 205*0Sstevel@tonic-gate 206*0Sstevel@tonic-gate ret1: UNLOCK_LOGREGION(dblp); 207*0Sstevel@tonic-gate return (ret); 208*0Sstevel@tonic-gate } 209