Lines Matching refs:lp
79 LOG *lp; local
83 lp = dblp->lp;
91 lsn->file = lp->lsn.file;
92 lsn->offset = lp->lsn.offset;
97 if (lp->lsn.offset + sizeof(HDR) + dbt->size > lp->persist.lg_max) {
99 sizeof(LOGP) + dbt->size > lp->persist.lg_max) {
113 lastoff = lp->lsn.offset;
116 ++lp->lsn.file;
117 lp->lsn.offset = 0;
120 lp->w_off = 0;
125 lsn->file = lp->lsn.file;
126 lsn->offset = lp->lsn.offset;
133 if (lp->lsn.offset == 0) {
134 t.data = &lp->persist;
137 &t, lastoff == 0 ? 0 : lastoff - lp->len)) != 0)
141 lsn->file = lp->lsn.file;
142 lsn->offset = lp->lsn.offset;
146 if ((ret = __log_putr(dblp, lsn, dbt, lp->lsn.offset - lp->len)) != 0)
156 lp->chkpt_lsn = *lsn;
158 for (fnp = SH_TAILQ_FIRST(&dblp->lp->fq, __fname);
190 (void)time(&lp->chkpt);
191 lp->stat.st_wc_bytes = lp->stat.st_wc_mbytes = 0;
208 LOG *lp; local
211 lp = dblp->lp;
224 lp->len = sizeof(HDR);
225 lp->lsn.offset += sizeof(HDR);
229 lp->len += dbt->size;
230 lp->lsn.offset += dbt->size;
264 LOG *lp; local
268 lp = dblp->lp;
276 t_lsn.file = lp->lsn.file;
277 t_lsn.offset = lp->lsn.offset - lp->len;
280 if (lsn->file > lp->lsn.file ||
281 (lsn->file == lp->lsn.file &&
282 lsn->offset > lp->lsn.offset - lp->len)) {
293 if (lsn->file < lp->s_lsn.file ||
294 (lsn->file == lp->s_lsn.file && lsn->offset <= lp->s_lsn.offset))
303 if (lp->b_off != 0 && log_compare(lsn, &lp->f_lsn) >= 0) {
304 if ((ret = __log_write(dblp, lp->buf, lp->b_off)) != 0)
307 lp->b_off = 0;
315 if (dblp->lfname != dblp->lp->lsn.file)
324 ++lp->stat.st_scount;
339 lp->s_lsn = lp->f_lsn;
340 if (!current && lp->s_lsn.file != 0)
341 if (lp->s_lsn.offset == 0) {
342 --lp->s_lsn.file;
343 lp->s_lsn.offset = lp->persist.lg_max;
345 --lp->s_lsn.offset;
361 LOG *lp; local
367 for (lp = dblp->lp; len > 0;) {
374 if (lp->b_off == 0)
375 lp->f_lsn = *lsn;
381 if (lp->b_off == 0 && len >= sizeof(lp->buf)) {
382 nrec = len / sizeof(lp->buf);
384 addr, nrec * sizeof(lp->buf))) != 0)
386 addr = (u_int8_t *)addr + nrec * sizeof(lp->buf);
387 len -= nrec * sizeof(lp->buf);
392 remain = sizeof(lp->buf) - lp->b_off;
394 memcpy(lp->buf + lp->b_off, addr, nw);
397 lp->b_off += nw;
400 if (lp->b_off == sizeof(lp->buf)) {
402 __log_write(dblp, lp->buf, sizeof(lp->buf))) != 0)
404 lp->b_off = 0;
420 LOG *lp; local
428 lp = dblp->lp;
429 if (dblp->lfd == -1 || dblp->lfname != lp->lsn.file)
437 if ((ret = __os_seek(dblp->lfd, 0, 0, lp->w_off, 0, SEEK_SET)) != 0 ||
446 lp->w_off += len;
449 if ((lp->stat.st_w_bytes += len) >= MEGABYTE) {
450 lp->stat.st_w_bytes -= MEGABYTE;
451 ++lp->stat.st_w_mbytes;
453 if ((lp->stat.st_wc_bytes += len) >= MEGABYTE) {
454 lp->stat.st_wc_bytes -= MEGABYTE;
455 ++lp->stat.st_wc_mbytes;
457 ++lp->stat.st_wcount;
513 dblp->lfname = dblp->lp->lsn.file;
564 flags, flags, dblp->lp->persist.mode, fdp)) == 0)
586 flags, flags, dblp->lp->persist.mode, fdp)) == 0) {