Lines Matching refs:lp
34 LOG *lp;
69 lp = dblp->reginfo.primary =
71 dblp->bufp = R_ADDR(&dblp->reginfo, lp->buffer_off);
99 if (lp->log_size == 0)
100 lp->log_size =
111 if (lp->log_nsize == 0)
112 lp->log_nsize = lp->log_size;
118 if (IS_INIT_LSN(lp->lsn) &&
129 lp->ready_lsn = lp->lsn;
134 lp->bulk_buf = R_OFFSET(&dblp->reginfo, bulk);
135 lp->bulk_len = MEGABYTE;
136 lp->bulk_off = 0;
137 lp->wait_ts = env->rep_handle->request_gap;
138 __os_gettime(env, &lp->rcvd_ts, 1);
140 lp->bulk_buf = INVALID_ROFF;
141 lp->bulk_len = 0;
142 lp->bulk_off = 0;
159 lp->log_nsize = dbenv->lg_size;
191 LOG *lp;
207 sizeof(*lp), &dblp->reginfo.primary)) != 0)
211 lp = dblp->reginfo.primary;
212 memset(lp, 0, sizeof(*lp));
215 __mutex_alloc(env, MTX_LOG_REGION, 0, &lp->mtx_region)) != 0)
218 lp->fid_max = 0;
219 SH_TAILQ_INIT(&lp->fq);
220 lp->free_fid_stack = INVALID_ROFF;
221 lp->free_fids = lp->free_fids_alloced = 0;
224 INIT_LSN(lp->lsn);
225 INIT_LSN(lp->t_lsn);
232 ZERO_LSN(lp->waiting_lsn);
239 ZERO_LSN(lp->cached_ckp_lsn);
242 __mutex_alloc(env, MTX_LOG_FILENAME, 0, &lp->mtx_filelist)) != 0)
244 if ((ret = __mutex_alloc(env, MTX_LOG_FLUSH, 0, &lp->mtx_flush)) != 0)
252 lp->regionmax = dbenv->lg_regionmax;
253 lp->buffer_off = R_OFFSET(&dblp->reginfo, p);
254 lp->buffer_size = dbenv->lg_bsize;
255 lp->filemode = dbenv->lg_filemode;
256 lp->log_size = lp->log_nsize = dbenv->lg_size;
259 SH_TAILQ_INIT(&lp->free_commits);
260 SH_TAILQ_INIT(&lp->commits);
261 lp->ncommit = 0;
264 SH_TAILQ_INIT(&lp->logfiles);
265 SH_TAILQ_INIT(&lp->free_logfiles);
272 lp->persist.magic = DB_LOGMAGIC;
276 lp->persist.version = DB_LOGVERSION;
277 lp->persist.notused = 0;
285 (void)time(&lp->timestamp);
302 LOG *lp;
310 lp = dblp->reginfo.primary;
328 lp->lsn.file = lp->s_lsn.file = cnt + 1;
329 lp->lsn.offset = lp->s_lsn.offset = 0;
341 lp->lsn.file = cnt + 1;
342 lp->lsn.offset = 0;
372 lp->cached_ckp_lsn = lsn;
381 lp->lsn = lsn;
382 lp->s_lsn = lsn;
383 lp->lsn.offset += logc->len;
384 lp->s_lsn.offset += logc->len;
387 lp->len = logc->len;
388 lp->a_off = 0;
389 lp->b_off = 0;
390 lp->w_off = lp->lsn.offset;
396 (u_long)lp->lsn.file, (u_long)lp->lsn.offset);
420 LOG *lp;
429 lp = dblp->reginfo.primary;
435 if (lp->db_log_inmemory) {
437 SH_TAILQ_FIRST(&lp->logfiles, __db_filestart) :
438 SH_TAILQ_LAST(&lp->logfiles, links, __db_filestart);
589 LOG *lp;
766 lp = dblp->reginfo.primary;
767 lp->log_size = persist->log_size;
768 lp->persist.version = persist->version;
800 LOG *lp;
809 lp = reginfo->primary;
831 MUTEX_LOCK(env, lp->mtx_filelist);
832 SH_TAILQ_FOREACH(fnp, &lp->fq, q, __fname)
837 MUTEX_UNLOCK(env, lp->mtx_filelist);
847 __mutex_free(env, &lp->mtx_flush)) != 0 && ret == 0)
851 __env_alloc_free(reginfo, R_ADDR(reginfo, lp->buffer_off));
854 if (lp->free_fid_stack != INVALID_ROFF)
856 R_ADDR(reginfo, lp->free_fid_stack));
859 while ((filestart = SH_TAILQ_FIRST(&lp->logfiles,
861 SH_TAILQ_REMOVE(&lp->logfiles, filestart, links,
866 while ((filestart = SH_TAILQ_FIRST(&lp->free_logfiles,
868 SH_TAILQ_REMOVE(&lp->free_logfiles, filestart, links,
874 while ((commit = SH_TAILQ_FIRST(&lp->free_commits,
876 SH_TAILQ_REMOVE(&lp->free_commits, commit, links,
882 if (lp->bulk_buf != INVALID_ROFF) {
884 R_ADDR(reginfo, lp->bulk_buf));
885 lp->bulk_buf = INVALID_ROFF;
925 LOG *lp;
928 lp = (LOG *)dblp->reginfo.primary;
931 *ckp_lsnp = lp->cached_ckp_lsn;
1002 LOG *lp;
1019 lp = (LOG *)dblp->reginfo.primary;
1030 lp->lsn = *lsn;
1031 lp->len = len;
1032 lp->lsn.offset += lp->len;
1034 if (lp->db_log_inmemory &&
1035 (ret = __log_inmem_lsnoff(dblp, &lp->lsn, &lp->b_off)) != 0)
1042 DB_ASSERT(env, lp->lsn.file >= ckplsn->file);
1044 if (ckplsn->file != lp->lsn.file) {
1045 bytes = lp->log_size - ckplsn->offset;
1046 if (lp->lsn.file > ckplsn->file + 1)
1047 bytes += lp->log_size *
1048 ((lp->lsn.file - ckplsn->file) - 1);
1049 bytes += lp->lsn.offset;
1051 bytes = lp->lsn.offset - ckplsn->offset;
1053 lp->stat.st_wc_mbytes += bytes / MEGABYTE;
1054 lp->stat.st_wc_bytes += bytes % MEGABYTE;
1060 MUTEX_LOCK(env, lp->mtx_flush);
1061 if (LOG_COMPARE(&lp->s_lsn, lsn) > 0)
1062 lp->s_lsn = lp->lsn;
1063 MUTEX_UNLOCK(env, lp->mtx_flush);
1066 ZERO_LSN(lp->f_lsn);
1067 lp->w_off = lp->lsn.offset;
1070 *trunclsn = lp->lsn;
1073 if ((ret = __log_zero(env, &lp->lsn)) != 0)
1094 LOG *lp;
1109 lp = (LOG *)dblp->reginfo.primary;
1110 filestart = SH_TAILQ_FIRST(&lp->logfiles, __db_filestart);
1132 lp = (LOG *)dblp->reginfo.primary;
1133 cfile = lp->lsn.file;
1155 LOG *lp;
1164 lp = (LOG *)dblp->reginfo.primary;
1165 DB_ASSERT(env, LOG_COMPARE(from_lsn, &lp->lsn) <= 0);
1166 if (LOG_COMPARE(from_lsn, &lp->lsn) > 0) {
1172 if (lp->db_log_inmemory) {
1176 for (filestart = SH_TAILQ_FIRST(&lp->logfiles, __db_filestart);
1181 SH_TAILQ_REMOVE(&lp->logfiles,
1183 SH_TAILQ_INSERT_HEAD(&lp->free_logfiles,
1204 (void)time(&lp->timestamp);
1256 LOG *lp;
1259 lp = (LOG *)dblp->reginfo.primary;
1261 SH_TAILQ_FOREACH(filestart, &lp->logfiles, links, __db_filestart)
1264 (filestart->b_off + lsnp->offset) % lp->buffer_size;
1284 LOG *lp;
1291 lp = (LOG *)dblp->reginfo.primary;
1296 filestart = SH_TAILQ_FIRST(&lp->logfiles, __db_filestart);
1298 RINGBUF_LEN(lp, filestart->b_off, lp->b_off) <=
1301 filestart->b_off = lp->b_off;
1312 __log_inmem_copyin(dblp, lp->b_off, &hdr, sizeof(HDR));
1313 lp->b_off = (lp->b_off + sizeof(HDR)) % lp->buffer_size;
1316 filestart = SH_TAILQ_FIRST(&lp->free_logfiles, __db_filestart);
1323 SH_TAILQ_REMOVE(&lp->free_logfiles, filestart,
1327 filestart->b_off = lp->b_off;
1330 first = SH_TAILQ_FIRST(&lp->logfiles, __db_filestart);
1331 last = SH_TAILQ_LAST(&(lp)->logfiles, links, __db_filestart);
1335 RINGBUF_LEN(lp, first->b_off, lp->b_off) ==
1336 RINGBUF_LEN(lp, first->b_off, last->b_off) +
1337 RINGBUF_LEN(lp, last->b_off, lp->b_off));
1340 SH_TAILQ_INSERT_TAIL(&lp->logfiles, filestart, links);
1359 LOG *lp;
1364 lp = dblp->reginfo.primary;
1366 DB_ASSERT(env, lp->db_log_inmemory);
1381 RINGBUF_LEN(lp, lp->b_off, lp->a_off) <= len) {
1382 old_active_lsn = lp->active_lsn;
1383 active_lsn = lp->lsn;
1404 if (LOG_COMPARE(&active_lsn, &lp->active_lsn) > 0) {
1405 lp->active_lsn = active_lsn;
1407 &lp->a_off);
1416 filestart = SH_TAILQ_FIRST(&lp->logfiles, __db_filestart);
1418 RINGBUF_LEN(lp, lp->b_off, filestart->b_off) <= len) {
1419 SH_TAILQ_REMOVE(&lp->logfiles, filestart,
1421 SH_TAILQ_INSERT_HEAD(&lp->free_logfiles, filestart,
1423 lp->f_lsn.file = filestart->file + 1;
1443 LOG *lp;
1446 lp = (LOG *)dblp->reginfo.primary;
1447 nbytes = (offset + size < lp->buffer_size) ?
1448 size : lp->buffer_size - offset;
1468 LOG *lp;
1471 lp = (LOG *)dblp->reginfo.primary;
1472 nbytes = (offset + size < lp->buffer_size) ?
1473 size : lp->buffer_size - offset;
1482 * Essentially this modifies the lp->persist.version field in the
1494 LOG *lp;
1497 lp = (LOG *)dblp->reginfo.primary;
1501 lp->persist.version = newver;
1525 LOG *lp;
1530 lp = dblp->reginfo.primary;
1538 if (lp->db_log_inmemory) {