Lines Matching defs:logc
77 DB_LOGC *logc;
83 if ((ret = __os_calloc(env, 1, sizeof(DB_LOGC), &logc)) != 0)
86 logc->bp_size = LG_CURSOR_BUF_SIZE;
90 logc->bp_maxrec = MEGABYTE;
91 if ((ret = __os_malloc(env, logc->bp_size, &logc->bp)) != 0) {
92 __os_free(env, logc);
96 logc->env = env;
97 logc->close = __logc_close_pp;
98 logc->get = __logc_get_pp;
99 logc->version = __logc_version_pp;
101 *logcp = logc;
110 __logc_close_pp(logc, flags)
111 DB_LOGC *logc;
118 env = logc->env;
124 REPLICATION_WRAP(env, (__logc_close(logc)), 0, ret);
136 __logc_close(logc)
137 DB_LOGC *logc;
141 env = logc->env;
143 if (logc->fhp != NULL) {
144 (void)__os_closehandle(env, logc->fhp);
145 logc->fhp = NULL;
148 if (logc->dbt.data != NULL)
149 __os_free(env, logc->dbt.data);
151 __os_free(env, logc->bp);
152 __os_free(env, logc);
162 __logc_version_pp(logc, versionp, flags)
163 DB_LOGC *logc;
171 env = logc->env;
177 REPLICATION_WRAP(env, (__logc_version(logc, versionp)), 0, ret);
189 __logc_version(logc, versionp)
190 DB_LOGC *logc;
200 env = logc->env;
201 if (IS_ZERO_LSN(logc->lsn)) {
216 if (logc->lsn.file != logc->p_lsn.file) {
219 plsn.file = logc->lsn.file;
228 logc->p_lsn = logc->lsn;
229 logc->p_version = persist->version;
236 *versionp = logc->p_version;
245 __logc_get_pp(logc, alsn, dbt, flags)
246 DB_LOGC *logc;
255 env = logc->env;
277 REPLICATION_WRAP(env, (__logc_get(logc, alsn, dbt, flags)), 0, ret);
289 __logc_get(logc, alsn, dbt, flags)
290 DB_LOGC *logc;
300 env = logc->env;
322 if ((ret = __logc_get_int(logc, alsn, dbt, flags)) != 0) {
347 logc->p_lsn = *alsn;
348 logc->p_version = persist->version;
353 if ((ret = __logc_get_int(logc, alsn, dbt, flags)) != 0) {
367 __logc_get_int(logc, alsn, dbt, flags)
368 DB_LOGC *logc;
385 env = logc->env;
395 rlock = F_ISSET(logc, DB_LOG_LOCKED) ? L_ALREADY : L_NONE;
397 nlsn = logc->lsn;
402 nlsn.offset += logc->len;
468 nlsn.offset = logc->prev;
510 if ((ret = __logc_incursor(logc, &nlsn, &hdr, &rp)) != 0)
531 if (!F_ISSET(logc, DB_LOG_DISK) ||
532 LOG_COMPARE(&nlsn, &logc->lsn) > 0) {
533 F_CLR(logc, DB_LOG_DISK);
535 if ((ret = __logc_inregion(logc,
565 logc, &nlsn, &last_lsn, flags, &hdr, &rp, &eof)) != 0)
605 F_SET(logc, DB_LOG_DISK);
626 if (F_ISSET(logc, DB_LOG_SILENT_ERR)) {
655 &logc->dbt.data, &logc->dbt.ulen)) != 0)
676 logc->lsn = nlsn;
677 logc->len = hdr.len;
678 logc->prev = hdr.prev;
691 __logc_incursor(logc, lsn, hdr, pp)
692 DB_LOGC *logc;
701 env = logc->env;
714 if (logc->bp_lsn.file != lsn->file)
716 if (logc->bp_lsn.offset > lsn->offset)
718 if (logc->bp_lsn.offset + logc->bp_rlen <= lsn->offset + hdr->size)
731 p = logc->bp + (lsn->offset - logc->bp_lsn.offset);
735 if (__logc_hdrchk(logc, lsn, hdr, &eof))
737 if (eof || logc->bp_lsn.offset + logc->bp_rlen < lsn->offset + hdr->len)
750 __logc_inregion(logc, lsn, rlockp, last_lsn, hdr, pp, need_cksump)
751 DB_LOGC *logc;
766 env = logc->env;
832 logc->bp_rlen = 0;
854 if (__logc_hdrchk(logc, lsn, hdr, &eof) != 0)
863 if (logc->bp_size <= hdr->len) {
866 __os_realloc(logc->env, len, &logc->bp)) != 0)
868 logc->bp_size = (u_int32_t)len;
870 __log_inmem_copyout(dblp, b_region, logc->bp, hdr->len);
871 *pp = logc->bp;
914 if (logc->bp_size <= b_region + b_disk) {
916 if ((ret = __os_realloc(logc->env, len, &logc->bp)) != 0)
918 logc->bp_size = (u_int32_t)len;
922 p = (logc->bp + logc->bp_size) - b_region;
939 logc, lsn->file, lsn->offset, p, &nr, NULL)) != 0)
942 return (__logc_shortread(logc, lsn, 0));
996 __logc_ondisk(logc, lsn, last_lsn, flags, hdr, pp, eofp)
997 DB_LOGC *logc;
1009 env = logc->env;
1014 __logc_io(logc, lsn->file, lsn->offset, hdr, &nr, eofp)) != 0)
1035 if ((ret = __logc_hdrchk(logc, lsn, hdr, eofp)) != 0)
1044 logc->bp_rlen = 0;
1051 if (logc->bp_size <= hdr->len) {
1053 if ((ret = __os_realloc(env, len, &logc->bp)) != 0)
1055 logc->bp_size = (u_int32_t)len;
1071 else if (lsn->offset + hdr->len < logc->bp_size)
1074 offset = (lsn->offset + hdr->len) - logc->bp_size;
1076 nr = logc->bp_size;
1081 __logc_io(logc, lsn->file, offset, logc->bp, &nr, eofp)) != 0)
1089 return (__logc_shortread(logc, lsn, 1));
1097 logc->bp_rlen = (u_int32_t)nr;
1098 logc->bp_lsn.offset = offset;
1100 *pp = logc->bp + (lsn->offset - offset);
1126 __logc_hdrchk(logc, lsn, hdr, eofp)
1127 DB_LOGC *logc;
1135 env = logc->env;
1159 if (logc->bp_maxrec != 0 && hdr->len > logc->bp_maxrec) {
1165 if ((ret = __logc_set_maxrec(logc, NULL)) != 0) {
1169 if (logc->bp_maxrec != 0 && hdr->len > logc->bp_maxrec)
1174 err: if (!F_ISSET(logc, DB_LOG_SILENT_ERR))
1186 __logc_io(logc, fnum, offset, p, nrp, eofp)
1187 DB_LOGC *logc;
1199 env = logc->env;
1207 if (logc->fhp != NULL && logc->bp_lsn.file != fnum) {
1208 ret = __os_closehandle(env, logc->fhp);
1209 logc->fhp = NULL;
1210 logc->bp_lsn.file = 0;
1215 if (logc->fhp == NULL) {
1217 &np, &logc->fhp, DB_OSO_RDONLY | DB_OSO_SEQ)) != 0) {
1225 } else if (!F_ISSET(logc, DB_LOG_SILENT_ERR))
1232 if ((ret = __logc_set_maxrec(logc, np)) != 0) {
1239 logc->bp_lsn.file = fnum;
1245 logc->fhp, 0, 0, offset, (u_int32_t)*nrp, p, nrp)) != 0) {
1246 if (!F_ISSET(logc, DB_LOG_SILENT_ERR))
1261 __logc_shortread(logc, lsn, check_silent)
1262 DB_LOGC *logc;
1266 if (!check_silent || !F_ISSET(logc, DB_LOG_SILENT_ERR))
1267 __db_errx(logc->env, "DB_LOGC->get: LSN: %lu/%lu: short read",
1277 __logc_set_maxrec(logc, np)
1278 DB_LOGC *logc;
1287 env = logc->env;
1299 if (logc->fhp != NULL) {
1300 if ((ret = __os_ioinfo(env, np, logc->fhp,
1303 if (logc->bp_maxrec < (mbytes * MEGABYTE + bytes))
1304 logc->bp_maxrec = mbytes * MEGABYTE + bytes;
1320 if (logc->bp_maxrec < lp->buffer_size)
1321 logc->bp_maxrec = lp->buffer_size;