Lines Matching refs:lsnp
35 __log_put_pp(dbenv, lsnp, udbt, flags)
37 DB_LSN *lsnp;
68 REPLICATION_WRAP(env, (__log_put(env, lsnp, udbt, flags)), 0, ret);
80 __log_put(env, lsnp, udbt, flags)
82 DB_LSN *lsnp;
170 lsnp->file = lsn.file;
171 lsnp->offset = lsn.offset;
346 __log_current_lsn(env, lsnp, mbytesp, bytesp)
348 DB_LSN *lsnp;
368 *lsnp = lp->lsn;
370 lsnp->offset -= lp->len;
471 __log_flush_commit(env, lsnp, flags)
473 const DB_LSN *lsnp;
483 flush_lsn = *lsnp;
538 __log_newfile(dblp, lsnp, logfile, version)
540 DB_LSN *lsnp;
664 if (lsnp != NULL)
665 *lsnp = lp->lsn;
831 * The sync point can only move forward. The lsnp->file cannot be
837 #define ALREADY_FLUSHED(lp, lsnp) \
838 (((lp)->s_lsn.file > (lsnp)->file) || \
839 ((lp)->s_lsn.file == (lsnp)->file && \
840 (lp)->s_lsn.offset > (lsnp)->offset))
875 __log_flush_int(dblp, lsnp, release)
877 const DB_LSN *lsnp;
904 if (lsnp == NULL) {
907 } else if (lsnp->file > lp->lsn.file ||
908 (lsnp->file == lp->lsn.file &&
909 lsnp->offset > lp->lsn.offset - lp->len)) {
912 (u_long)lsnp->file, (u_long)lsnp->offset,
920 if (ALREADY_FLUSHED(lp, lsnp))
922 flush_lsn = *lsnp;
1483 __log_rep_put(env, lsnp, rec, flags)
1485 DB_LSN *lsnp;
1517 DB_ASSERT(env, LOG_COMPARE(lsnp, &lp->lsn) == 0);
1518 ret = __log_putr(dblp, lsnp, dbt, lp->lsn.offset - lp->len, &hdr);