Lines Matching refs:logp

69 __log_register_recover(logp, dbtp, lsnp, redo, info)
70 DB_LOG *logp;
81 __log_register_print(logp, dbtp, lsnp, redo, info);
86 F_SET(logp, DBC_RECOVER);
101 ret = __log_open_file(logp, argp);
104 __db_err(logp->dbenv, "warning: %s: %s",
125 LOCK_LOGTHREAD(logp);
126 if (argp->id < logp->dbentry_cnt) {
127 dbe = &logp->dbentry[argp->id];
134 (void)__log_rem_logid(logp, argp->id);
137 UNLOCK_LOGTHREAD(logp);
139 (argp->id >= logp->dbentry_cnt ||
140 (!logp->dbentry[argp->id].deleted &&
141 logp->dbentry[argp->id].dbp == NULL))) {
149 ret = __log_open_file(logp, argp);
151 __db_err(logp->dbenv, "warning: %s: %s",
157 out: F_CLR(logp, DBC_RECOVER);
258 __log_add_logid(logp, dbp, name, ndx)
259 DB_LOG *logp;
269 LOCK_LOGTHREAD(logp);
276 if (logp->dbentry_cnt <= ndx) {
277 if ((ret = __os_realloc(&logp->dbentry,
282 for (i = logp->dbentry_cnt; i < ndx + DB_GROW_SIZE; i++) {
283 logp->dbentry[i].dbp = NULL;
284 logp->dbentry[i].deleted = 0;
285 logp->dbentry[i].name = NULL;
288 logp->dbentry_cnt = i;
294 NULL, &logp->dbentry[ndx].name)) != 0)
296 strcpy(logp->dbentry[ndx].name, name);
299 if (logp->dbentry[ndx].deleted == 0 && logp->dbentry[ndx].dbp == NULL) {
300 logp->dbentry[ndx].dbp = dbp;
301 logp->dbentry[ndx].refcount = 1;
302 logp->dbentry[ndx].deleted = dbp == NULL;
304 logp->dbentry[ndx].refcount++;
307 err: UNLOCK_LOGTHREAD(logp);
319 __db_fileid_to_db(logp, dbpp, ndx)
320 DB_LOG *logp;
329 LOCK_LOGTHREAD(logp);
338 if (ndx >= logp->dbentry_cnt ||
339 (!logp->dbentry[ndx].deleted && logp->dbentry[ndx].dbp == NULL)) {
340 if (__log_lid_to_fname(logp, ndx, &fname) != 0) {
345 name = R_ADDR(logp, fname->name_off);
350 UNLOCK_LOGTHREAD(logp);
358 if ((ret = __log_do_open(logp,
361 *dbpp = logp->dbentry[ndx].dbp;
369 if (logp->dbentry[ndx].deleted) {
378 if ((*dbpp = logp->dbentry[ndx].dbp) == NULL)
381 err: UNLOCK_LOGTHREAD(logp);
391 __log_close_files(logp)
392 DB_LOG *logp;
396 LOCK_LOGTHREAD(logp);
397 for (i = 0; i < logp->dbentry_cnt; i++)
398 if (logp->dbentry[i].dbp) {
399 logp->dbentry[i].dbp->close(logp->dbentry[i].dbp, 0);
400 logp->dbentry[i].dbp = NULL;
401 logp->dbentry[i].deleted = 0;
403 F_CLR(logp, DBC_RECOVER);
404 UNLOCK_LOGTHREAD(logp);
411 __log_rem_logid(logp, ndx)
412 DB_LOG *logp;
415 LOCK_LOGTHREAD(logp);
416 if (--logp->dbentry[ndx].refcount == 0) {
417 logp->dbentry[ndx].dbp = NULL;
418 logp->dbentry[ndx].deleted = 0;
420 UNLOCK_LOGTHREAD(logp);