Lines Matching defs:dblp
33 DB_LOG *dblp;
42 if ((ret = __os_calloc(env, 1, sizeof(DB_LOG), &dblp)) != 0)
44 dblp->env = env;
52 dblp->reginfo.env = env;
53 dblp->reginfo.type = REGION_TYPE_LOG;
54 dblp->reginfo.id = INVALID_REGION_ID;
55 dblp->reginfo.flags = REGION_JOIN_OK;
58 F_SET(&dblp->reginfo, REGION_CREATE_OK);
60 env, &dblp->reginfo, __log_region_size(env))) != 0)
64 if (F_ISSET(&dblp->reginfo, REGION_CREATE))
65 if ((ret = __log_init(env, dblp)) != 0)
69 lp = dblp->reginfo.primary =
70 R_ADDR(&dblp->reginfo, dblp->reginfo.rp->primary);
71 dblp->bufp = R_ADDR(&dblp->reginfo, lp->buffer_off);
78 MTX_LOG_REGION, DB_MUTEX_PROCESS_ONLY, &dblp->mtx_dbreg)) != 0)
90 env->lg_handle = dblp;
92 if (F_ISSET(&dblp->reginfo, REGION_CREATE)) {
104 if ((ret = __log_recover(dblp)) != 0)
119 (ret = __log_newfile(dblp, NULL, 0, 0)) != 0)
132 __env_alloc(&dblp->reginfo, MEGABYTE, &bulk)) != 0)
134 lp->bulk_buf = R_OFFSET(&dblp->reginfo, bulk);
168 err: if (dblp->reginfo.addr != NULL) {
171 (void)__env_region_detach(env, &dblp->reginfo, 0);
175 (void)__mutex_free(env, &dblp->mtx_dbreg);
176 __os_free(env, dblp);
186 __log_init(env, dblp)
188 DB_LOG *dblp;
206 if ((ret = __env_alloc(&dblp->reginfo,
207 sizeof(*lp), &dblp->reginfo.primary)) != 0)
209 dblp->reginfo.rp->primary =
210 R_OFFSET(&dblp->reginfo, dblp->reginfo.primary);
211 lp = dblp->reginfo.primary;
248 if ((ret = __env_alloc(&dblp->reginfo, dbenv->lg_bsize, &p)) != 0) {
253 lp->buffer_off = R_OFFSET(&dblp->reginfo, p);
274 * Don't use __log_set_version because env->dblp isn't set up yet.
278 env->lg_handle = dblp;
294 __log_recover(dblp)
295 DB_LOG *dblp;
307 env = dblp->env;
310 lp = dblp->reginfo.primary;
316 if ((ret = __log_find(dblp, 0, &cnt, &status)) != 0)
413 __log_find(dblp, find_first, valp, statusp)
414 DB_LOG *dblp;
428 env = dblp->env;
429 lp = dblp->reginfo.primary;
448 if ((ret = __log_name(dblp, 1, &p, NULL, 0)) != 0) {
507 if ((ret = __log_valid(dblp, clv, 1, NULL, 0,
576 __log_valid(dblp, number, set_persist, fhpp, flags, statusp, versionp)
577 DB_LOG *dblp;
597 env = dblp->env;
611 if ((ret = __log_name(dblp, number, &fname, &fhp, flags)) != 0) {
766 lp = dblp->reginfo.primary;
799 DB_LOG *dblp;
807 dblp = env->lg_handle;
808 reginfo = &dblp->reginfo;
890 if ((t_ret = __mutex_free(env, &dblp->mtx_dbreg)) != 0 && ret == 0)
898 if (dblp->lfhp != NULL) {
900 __os_closehandle(env, dblp->lfhp)) != 0 && ret == 0)
902 dblp->lfhp = NULL;
904 if (dblp->dbentry != NULL)
905 __os_free(env, dblp->dbentry);
907 __os_free(env, dblp);
924 DB_LOG *dblp;
927 dblp = env->lg_handle;
928 lp = (LOG *)dblp->reginfo.primary;
1000 DB_LOG *dblp;
1018 dblp = env->lg_handle;
1019 lp = (LOG *)dblp->reginfo.primary;
1027 if ((ret = __log_flush_int(dblp, NULL, 0)) != 0)
1035 (ret = __log_inmem_lsnoff(dblp, &lp->lsn, &lp->b_off)) != 0)
1093 DB_LOG *dblp;
1100 dblp = env->lg_handle;
1109 lp = (LOG *)dblp->reginfo.primary;
1117 if ((ret = __log_name(dblp, fnum, &name, NULL, 0)) != 0) {
1132 lp = (LOG *)dblp->reginfo.primary;
1154 DB_LOG *dblp;
1163 dblp = env->lg_handle;
1164 lp = (LOG *)dblp->reginfo.primary;
1192 if (dblp->lfhp != NULL) {
1193 (void)__os_closehandle(env, dblp->lfhp);
1194 dblp->lfhp = NULL;
1199 if (__log_name(dblp, fn, &fname, &fhp, DB_OSO_RDONLY) != 0) {
1213 __log_name(dblp, from_lsn->file, &fname, &dblp->lfhp, 0)) != 0) {
1219 NULL, dblp->lfhp, &mbytes, &bytes, NULL)) != 0)
1227 if ((ret = __os_seek(env, dblp->lfhp, 0, 0, from_lsn->offset)) != 0)
1233 __os_write(env, dblp->lfhp, buf, nbytes, &nw)) != 0)
1238 err: (void)__os_closehandle(env, dblp->lfhp);
1239 dblp->lfhp = NULL;
1251 __log_inmem_lsnoff(dblp, lsnp, offsetp)
1252 DB_LOG *dblp;
1259 lp = (LOG *)dblp->reginfo.primary;
1279 __log_inmem_newfile(dblp, file)
1280 DB_LOG *dblp;
1291 lp = (LOG *)dblp->reginfo.primary;
1312 __log_inmem_copyin(dblp, lp->b_off, &hdr, sizeof(HDR));
1318 if ((ret = __env_alloc(&dblp->reginfo,
1334 DB_ASSERT(dblp->env, !first || first == last ||
1353 __log_inmem_chkspace(dblp, len)
1354 DB_LOG *dblp;
1363 env = dblp->env;
1364 lp = dblp->reginfo.primary;
1406 (void)__log_inmem_lsnoff(dblp, &active_lsn,
1437 __log_inmem_copyout(dblp, offset, buf, size)
1438 DB_LOG *dblp;
1446 lp = (LOG *)dblp->reginfo.primary;
1449 memcpy(buf, dblp->bufp + offset, nbytes);
1451 memcpy((u_int8_t *)buf + nbytes, dblp->bufp, size - nbytes);
1462 __log_inmem_copyin(dblp, offset, buf, size)
1463 DB_LOG *dblp;
1471 lp = (LOG *)dblp->reginfo.primary;
1474 memcpy(dblp->bufp + offset, buf, nbytes);
1476 memcpy(dblp->bufp, (u_int8_t *)buf + nbytes, size - nbytes);
1493 DB_LOG *dblp;
1496 dblp = env->lg_handle;
1497 lp = (LOG *)dblp->reginfo.primary;
1522 DB_LOG *dblp;
1529 dblp = env->lg_handle;
1530 lp = dblp->reginfo.primary;
1560 if ((ret = __log_valid(dblp, firstfnum, 0, NULL, 0,
1574 if ((ret = __log_valid(dblp, lsn.file, 0, NULL, 0,
1584 if ((ret = __log_valid(dblp, fnum, 0, NULL, 0,