Lines Matching refs:env
17 __db_addrem_read(env, dbpp, td, recbuf, argpp)
18 ENV *env;
29 if ((ret = __os_malloc(env,
37 LOGCOPY_32(env, &argp->type, bp);
40 LOGCOPY_32(env, &argp->txnp->txnid, bp);
43 LOGCOPY_TOLSN(env, &argp->prev_lsn, bp);
46 LOGCOPY_32(env, &argp->opcode, bp);
49 LOGCOPY_32(env, &uinttmp, bp);
55 env, argp->txnp, dbpp, argp->fileid, 1);
58 LOGCOPY_32(env, &uinttmp, bp);
62 LOGCOPY_32(env, &argp->indx, bp);
65 LOGCOPY_32(env, &argp->nbytes, bp);
69 LOGCOPY_32(env,&argp->hdr.size, bp);
75 LOGCOPY_32(env,&argp->dbt.size, bp);
80 LOGCOPY_TOLSN(env, &argp->pagelsn, bp);
111 ENV *env;
119 env = dbp->env;
139 (ret = __txn_activekids(env, rectype, txnp)) != 0)
151 DB_ASSERT(env, dbp->log_filename != NULL);
165 if (CRYPTO_ON(env)) {
166 npad = env->crypto_handle->adj_size(logrec.size);
172 __os_malloc(env, logrec.size, &logrec.data)) != 0)
175 if ((ret = __os_malloc(env,
180 __os_malloc(env, logrec.size, &logrec.data)) != 0) {
181 __os_free(env, lr);
193 LOGCOPY_32(env, bp, &rectype);
196 LOGCOPY_32(env, bp, &txn_num);
199 LOGCOPY_FROMLSN(env, bp, lsnp);
202 LOGCOPY_32(env, bp, &opcode);
206 LOGCOPY_32(env, bp, &uinttmp);
210 LOGCOPY_32(env,bp, &uinttmp);
213 LOGCOPY_32(env, bp, &indx);
216 LOGCOPY_32(env, bp, &nbytes);
221 LOGCOPY_32(env, bp, &zero);
224 LOGCOPY_32(env, bp, &hdr->size);
232 LOGCOPY_32(env, bp, &zero);
235 LOGCOPY_32(env, bp, &dbt->size);
243 LOG *lp = env->lg_handle->reginfo.primary;
245 __log_check_page_lsn(env, dbp, pagelsn) != 0))
248 LOGCOPY_FROMLSN(env, bp, pagelsn);
253 DB_ASSERT(env,
257 if ((ret = __log_put(env, rlsnp,(DBT *)&logrec,
272 LOGCOPY_32(env, logrec.data, &rectype);
274 if (!IS_REP_CLIENT(env))
275 ret = __log_put(env,
285 (void)__db_addrem_print(env,
290 __os_free(env, logrec.data);
293 __os_free(env, logrec.data);
303 __db_big_read(env, dbpp, td, recbuf, argpp)
304 ENV *env;
315 if ((ret = __os_malloc(env,
323 LOGCOPY_32(env, &argp->type, bp);
326 LOGCOPY_32(env, &argp->txnp->txnid, bp);
329 LOGCOPY_TOLSN(env, &argp->prev_lsn, bp);
332 LOGCOPY_32(env, &argp->opcode, bp);
335 LOGCOPY_32(env, &uinttmp, bp);
341 env, argp->txnp, dbpp, argp->fileid, 1);
344 LOGCOPY_32(env, &uinttmp, bp);
348 LOGCOPY_32(env, &uinttmp, bp);
352 LOGCOPY_32(env, &uinttmp, bp);
357 LOGCOPY_32(env,&argp->dbt.size, bp);
362 LOGCOPY_TOLSN(env, &argp->pagelsn, bp);
365 LOGCOPY_TOLSN(env, &argp->prevlsn, bp);
368 LOGCOPY_TOLSN(env, &argp->nextlsn, bp);
400 ENV *env;
408 env = dbp->env;
428 (ret = __txn_activekids(env, rectype, txnp)) != 0)
440 DB_ASSERT(env, dbp->log_filename != NULL);
455 if (CRYPTO_ON(env)) {
456 npad = env->crypto_handle->adj_size(logrec.size);
462 __os_malloc(env, logrec.size, &logrec.data)) != 0)
465 if ((ret = __os_malloc(env,
470 __os_malloc(env, logrec.size, &logrec.data)) != 0) {
471 __os_free(env, lr);
483 LOGCOPY_32(env, bp, &rectype);
486 LOGCOPY_32(env, bp, &txn_num);
489 LOGCOPY_FROMLSN(env, bp, lsnp);
492 LOGCOPY_32(env, bp, &opcode);
496 LOGCOPY_32(env, bp, &uinttmp);
500 LOGCOPY_32(env,bp, &uinttmp);
504 LOGCOPY_32(env,bp, &uinttmp);
508 LOGCOPY_32(env,bp, &uinttmp);
513 LOGCOPY_32(env, bp, &zero);
516 LOGCOPY_32(env, bp, &dbt->size);
524 LOG *lp = env->lg_handle->reginfo.primary;
526 __log_check_page_lsn(env, dbp, pagelsn) != 0))
529 LOGCOPY_FROMLSN(env, bp, pagelsn);
536 LOG *lp = env->lg_handle->reginfo.primary;
538 __log_check_page_lsn(env, dbp, prevlsn) != 0))
541 LOGCOPY_FROMLSN(env, bp, prevlsn);
548 LOG *lp = env->lg_handle->reginfo.primary;
550 __log_check_page_lsn(env, dbp, nextlsn) != 0))
553 LOGCOPY_FROMLSN(env, bp, nextlsn);
558 DB_ASSERT(env,
562 if ((ret = __log_put(env, rlsnp,(DBT *)&logrec,
577 LOGCOPY_32(env, logrec.data, &rectype);
579 if (!IS_REP_CLIENT(env))
580 ret = __log_put(env,
590 (void)__db_big_print(env,
595 __os_free(env, logrec.data);
598 __os_free(env, logrec.data);
608 __db_ovref_read(env, dbpp, td, recbuf, argpp)
609 ENV *env;
620 if ((ret = __os_malloc(env,
628 LOGCOPY_32(env, &argp->type, bp);
631 LOGCOPY_32(env, &argp->txnp->txnid, bp);
634 LOGCOPY_TOLSN(env, &argp->prev_lsn, bp);
637 LOGCOPY_32(env, &uinttmp, bp);
643 env, argp->txnp, dbpp, argp->fileid, 1);
646 LOGCOPY_32(env, &uinttmp, bp);
650 LOGCOPY_32(env, &uinttmp, bp);
654 LOGCOPY_TOLSN(env, &argp->lsn, bp);
678 ENV *env;
686 env = dbp->env;
706 (ret = __txn_activekids(env, rectype, txnp)) != 0)
718 DB_ASSERT(env, dbp->log_filename != NULL);
728 if (CRYPTO_ON(env)) {
729 npad = env->crypto_handle->adj_size(logrec.size);
735 __os_malloc(env, logrec.size, &logrec.data)) != 0)
738 if ((ret = __os_malloc(env,
743 __os_malloc(env, logrec.size, &logrec.data)) != 0) {
744 __os_free(env, lr);
756 LOGCOPY_32(env, bp, &rectype);
759 LOGCOPY_32(env, bp, &txn_num);
762 LOGCOPY_FROMLSN(env, bp, lsnp);
766 LOGCOPY_32(env, bp, &uinttmp);
770 LOGCOPY_32(env,bp, &uinttmp);
774 LOGCOPY_32(env,bp, &uinttmp);
779 LOG *lp = env->lg_handle->reginfo.primary;
781 __log_check_page_lsn(env, dbp, lsn) != 0))
784 LOGCOPY_FROMLSN(env, bp, lsn);
789 DB_ASSERT(env,
793 if ((ret = __log_put(env, rlsnp,(DBT *)&logrec,
808 LOGCOPY_32(env, logrec.data, &rectype);
810 if (!IS_REP_CLIENT(env))
811 ret = __log_put(env,
821 (void)__db_ovref_print(env,
826 __os_free(env, logrec.data);
829 __os_free(env, logrec.data);
839 __db_relink_42_read(env, dbpp, td, recbuf, argpp)
840 ENV *env;
851 if ((ret = __os_malloc(env,
859 LOGCOPY_32(env, &argp->type, bp);
862 LOGCOPY_32(env, &argp->txnp->txnid, bp);
865 LOGCOPY_TOLSN(env, &argp->prev_lsn, bp);
868 LOGCOPY_32(env, &argp->opcode, bp);
871 LOGCOPY_32(env, &uinttmp, bp);
877 env, argp->txnp, dbpp, argp->fileid, 1);
880 LOGCOPY_32(env, &uinttmp, bp);
884 LOGCOPY_TOLSN(env, &argp->lsn, bp);
887 LOGCOPY_32(env, &uinttmp, bp);
891 LOGCOPY_TOLSN(env, &argp->lsn_prev, bp);
894 LOGCOPY_32(env, &uinttmp, bp);
898 LOGCOPY_TOLSN(env, &argp->lsn_next, bp);
909 __db_debug_read(env, recbuf, argpp)
910 ENV *env;
919 if ((ret = __os_malloc(env,
926 LOGCOPY_32(env, &argp->type, bp);
929 LOGCOPY_32(env, &argp->txnp->txnid, bp);
932 LOGCOPY_TOLSN(env, &argp->prev_lsn, bp);
936 LOGCOPY_32(env,&argp->op.size, bp);
941 LOGCOPY_32(env, &uinttmp, bp);
946 LOGCOPY_32(env,&argp->key.size, bp);
952 LOGCOPY_32(env,&argp->data.size, bp);
957 LOGCOPY_32(env, &argp->arg_flags, bp);
970 __db_debug_log(env, txnp, ret_lsnp, flags,
972 ENV *env;
1027 if (CRYPTO_ON(env)) {
1028 npad = env->crypto_handle->adj_size(logrec.size);
1034 __os_malloc(env, logrec.size, &logrec.data)) != 0)
1037 if ((ret = __os_malloc(env,
1042 __os_malloc(env, logrec.size, &logrec.data)) != 0) {
1043 __os_free(env, lr);
1055 LOGCOPY_32(env, bp, &rectype);
1058 LOGCOPY_32(env, bp, &txn_num);
1061 LOGCOPY_FROMLSN(env, bp, lsnp);
1066 LOGCOPY_32(env, bp, &zero);
1069 LOGCOPY_32(env, bp, &op->size);
1076 LOGCOPY_32(env,bp, &uinttmp);
1081 LOGCOPY_32(env, bp, &zero);
1084 LOGCOPY_32(env, bp, &key->size);
1092 LOGCOPY_32(env, bp, &zero);
1095 LOGCOPY_32(env, bp, &data->size);
1101 LOGCOPY_32(env, bp, &arg_flags);
1104 DB_ASSERT(env,
1108 if ((ret = __log_put(env, rlsnp,(DBT *)&logrec,
1123 LOGCOPY_32(env, logrec.data, &rectype);
1125 if (!IS_REP_CLIENT(env))
1126 ret = __log_put(env,
1136 (void)__db_debug_print(env,
1141 __os_free(env, logrec.data);
1144 __os_free(env, logrec.data);
1154 __db_noop_read(env, dbpp, td, recbuf, argpp)
1155 ENV *env;
1166 if ((ret = __os_malloc(env,
1174 LOGCOPY_32(env, &argp->type, bp);
1177 LOGCOPY_32(env, &argp->txnp->txnid, bp);
1180 LOGCOPY_TOLSN(env, &argp->prev_lsn, bp);
1183 LOGCOPY_32(env, &uinttmp, bp);
1189 env, argp->txnp, dbpp, argp->fileid, 1);
1192 LOGCOPY_32(env, &uinttmp, bp);
1196 LOGCOPY_TOLSN(env, &argp->prevlsn, bp);
1219 ENV *env;
1227 env = dbp->env;
1247 (ret = __txn_activekids(env, rectype, txnp)) != 0)
1259 DB_ASSERT(env, dbp->log_filename != NULL);
1268 if (CRYPTO_ON(env)) {
1269 npad = env->crypto_handle->adj_size(logrec.size);
1275 __os_malloc(env, logrec.size, &logrec.data)) != 0)
1278 if ((ret = __os_malloc(env,
1283 __os_malloc(env, logrec.size, &logrec.data)) != 0) {
1284 __os_free(env, lr);
1296 LOGCOPY_32(env, bp, &rectype);
1299 LOGCOPY_32(env, bp, &txn_num);
1302 LOGCOPY_FROMLSN(env, bp, lsnp);
1306 LOGCOPY_32(env, bp, &uinttmp);
1310 LOGCOPY_32(env,bp, &uinttmp);
1315 LOG *lp = env->lg_handle->reginfo.primary;
1317 __log_check_page_lsn(env, dbp, prevlsn) != 0))
1320 LOGCOPY_FROMLSN(env, bp, prevlsn);
1325 DB_ASSERT(env,
1329 if ((ret = __log_put(env, rlsnp,(DBT *)&logrec,
1344 LOGCOPY_32(env, logrec.data, &rectype);
1346 if (!IS_REP_CLIENT(env))
1347 ret = __log_put(env,
1357 (void)__db_noop_print(env,
1362 __os_free(env, logrec.data);
1365 __os_free(env, logrec.data);
1375 __db_pg_alloc_42_read(env, dbpp, td, recbuf, argpp)
1376 ENV *env;
1387 if ((ret = __os_malloc(env,
1395 LOGCOPY_32(env, &argp->type, bp);
1398 LOGCOPY_32(env, &argp->txnp->txnid, bp);
1401 LOGCOPY_TOLSN(env, &argp->prev_lsn, bp);
1404 LOGCOPY_32(env, &uinttmp, bp);
1410 env, argp->txnp, dbpp, argp->fileid, 1);
1413 LOGCOPY_TOLSN(env, &argp->meta_lsn, bp);
1416 LOGCOPY_32(env, &uinttmp, bp);
1420 LOGCOPY_TOLSN(env, &argp->page_lsn, bp);
1423 LOGCOPY_32(env, &uinttmp, bp);
1427 LOGCOPY_32(env, &argp->ptype, bp);
1430 LOGCOPY_32(env, &uinttmp, bp);
1443 __db_pg_alloc_read(env, dbpp, td, recbuf, argpp)
1444 ENV *env;
1455 if ((ret = __os_malloc(env,
1463 LOGCOPY_32(env, &argp->type, bp);
1466 LOGCOPY_32(env, &argp->txnp->txnid, bp);
1469 LOGCOPY_TOLSN(env, &argp->prev_lsn, bp);
1472 LOGCOPY_32(env, &uinttmp, bp);
1478 env, argp->txnp, dbpp, argp->fileid, 1);
1481 LOGCOPY_TOLSN(env, &argp->meta_lsn, bp);
1484 LOGCOPY_32(env, &uinttmp, bp);
1488 LOGCOPY_TOLSN(env, &argp->page_lsn, bp);
1491 LOGCOPY_32(env, &uinttmp, bp);
1495 LOGCOPY_32(env, &argp->ptype, bp);
1498 LOGCOPY_32(env, &uinttmp, bp);
1502 LOGCOPY_32(env, &uinttmp, bp);
1533 ENV *env;
1541 env = dbp->env;
1561 (ret = __txn_activekids(env, rectype, txnp)) != 0)
1573 DB_ASSERT(env, dbp->log_filename != NULL);
1587 if (CRYPTO_ON(env)) {
1588 npad = env->crypto_handle->adj_size(logrec.size);
1594 __os_malloc(env, logrec.size, &logrec.data)) != 0)
1597 if ((ret = __os_malloc(env,
1602 __os_malloc(env, logrec.size, &logrec.data)) != 0) {
1603 __os_free(env, lr);
1615 LOGCOPY_32(env, bp, &rectype);
1618 LOGCOPY_32(env, bp, &txn_num);
1621 LOGCOPY_FROMLSN(env, bp, lsnp);
1625 LOGCOPY_32(env, bp, &uinttmp);
1630 LOG *lp = env->lg_handle->reginfo.primary;
1632 __log_check_page_lsn(env, dbp, meta_lsn) != 0))
1635 LOGCOPY_FROMLSN(env, bp, meta_lsn);
1641 LOGCOPY_32(env,bp, &uinttmp);
1646 LOG *lp = env->lg_handle->reginfo.primary;
1648 __log_check_page_lsn(env, dbp, page_lsn) != 0))
1651 LOGCOPY_FROMLSN(env, bp, page_lsn);
1657 LOGCOPY_32(env,bp, &uinttmp);
1660 LOGCOPY_32(env, bp, &ptype);
1664 LOGCOPY_32(env,bp, &uinttmp);
1668 LOGCOPY_32(env,bp, &uinttmp);
1671 DB_ASSERT(env,
1675 if ((ret = __log_put(env, rlsnp,(DBT *)&logrec,
1690 LOGCOPY_32(env, logrec.data, &rectype);
1692 if (!IS_REP_CLIENT(env))
1693 ret = __log_put(env,
1703 (void)__db_pg_alloc_print(env,
1708 __os_free(env, logrec.data);
1711 __os_free(env, logrec.data);
1721 __db_pg_free_42_read(env, dbpp, td, recbuf, argpp)
1722 ENV *env;
1733 if ((ret = __os_malloc(env,
1741 LOGCOPY_32(env, &argp->type, bp);
1744 LOGCOPY_32(env, &argp->txnp->txnid, bp);
1747 LOGCOPY_TOLSN(env, &argp->prev_lsn, bp);
1750 LOGCOPY_32(env, &uinttmp, bp);
1756 env, argp->txnp, dbpp, argp->fileid, 1);
1759 LOGCOPY_32(env, &uinttmp, bp);
1763 LOGCOPY_TOLSN(env, &argp->meta_lsn, bp);
1766 LOGCOPY_32(env, &uinttmp, bp);
1771 LOGCOPY_32(env,&argp->header.size, bp);
1776 LOGCOPY_32(env, &uinttmp, bp);
1789 __db_pg_free_read(env, dbpp, td, recbuf, argpp)
1790 ENV *env;
1801 if ((ret = __os_malloc(env,
1809 LOGCOPY_32(env, &argp->type, bp);
1812 LOGCOPY_32(env, &argp->txnp->txnid, bp);
1815 LOGCOPY_TOLSN(env, &argp->prev_lsn, bp);
1818 LOGCOPY_32(env, &uinttmp, bp);
1824 env, argp->txnp, dbpp, argp->fileid, 1);
1827 LOGCOPY_32(env, &uinttmp, bp);
1831 LOGCOPY_TOLSN(env, &argp->meta_lsn, bp);
1834 LOGCOPY_32(env, &uinttmp, bp);
1839 LOGCOPY_32(env,&argp->header.size, bp);
1843 if (LOG_SWAPPED(env) && dbpp != NULL && *dbpp != NULL) {
1850 LOGCOPY_32(env, &uinttmp, bp);
1854 LOGCOPY_32(env, &uinttmp, bp);
1884 ENV *env;
1892 env = dbp->env;
1912 (ret = __txn_activekids(env, rectype, txnp)) != 0)
1924 DB_ASSERT(env, dbp->log_filename != NULL);
1937 if (CRYPTO_ON(env)) {
1938 npad = env->crypto_handle->adj_size(logrec.size);
1944 __os_malloc(env, logrec.size, &logrec.data)) != 0)
1947 if ((ret = __os_malloc(env,
1952 __os_malloc(env, logrec.size, &logrec.data)) != 0) {
1953 __os_free(env, lr);
1965 LOGCOPY_32(env, bp, &rectype);
1968 LOGCOPY_32(env, bp, &txn_num);
1971 LOGCOPY_FROMLSN(env, bp, lsnp);
1975 LOGCOPY_32(env, bp, &uinttmp);
1979 LOGCOPY_32(env,bp, &uinttmp);
1984 LOG *lp = env->lg_handle->reginfo.primary;
1986 __log_check_page_lsn(env, dbp, meta_lsn) != 0))
1989 LOGCOPY_FROMLSN(env, bp, meta_lsn);
1995 LOGCOPY_32(env,bp, &uinttmp);
2000 LOGCOPY_32(env, bp, &zero);
2003 LOGCOPY_32(env, bp, &header->size);
2006 if (LOG_SWAPPED(env))
2014 LOGCOPY_32(env,bp, &uinttmp);
2018 LOGCOPY_32(env,bp, &uinttmp);
2021 DB_ASSERT(env,
2025 if ((ret = __log_put(env, rlsnp,(DBT *)&logrec,
2040 LOGCOPY_32(env, logrec.data, &rectype);
2042 if (!IS_REP_CLIENT(env))
2043 ret = __log_put(env,
2053 (void)__db_pg_free_print(env,
2058 __os_free(env, logrec.data);
2061 __os_free(env, logrec.data);
2070 __db_cksum_read(env, recbuf, argpp)
2071 ENV *env;
2079 if ((ret = __os_malloc(env,
2086 LOGCOPY_32(env, &argp->type, bp);
2089 LOGCOPY_32(env, &argp->txnp->txnid, bp);
2092 LOGCOPY_TOLSN(env, &argp->prev_lsn, bp);
2103 __db_cksum_log(env, txnp, ret_lsnp, flags)
2104 ENV *env;
2139 (ret = __txn_activekids(env, rectype, txnp)) != 0)
2152 if (CRYPTO_ON(env)) {
2153 npad = env->crypto_handle->adj_size(logrec.size);
2159 __os_malloc(env, logrec.size, &logrec.data)) != 0)
2162 if ((ret = __os_malloc(env,
2167 __os_malloc(env, logrec.size, &logrec.data)) != 0) {
2168 __os_free(env, lr);
2180 LOGCOPY_32(env, bp, &rectype);
2183 LOGCOPY_32(env, bp, &txn_num);
2186 LOGCOPY_FROMLSN(env, bp, lsnp);
2189 DB_ASSERT(env,
2193 if ((ret = __log_put(env, rlsnp,(DBT *)&logrec,
2208 LOGCOPY_32(env, logrec.data, &rectype);
2210 if (!IS_REP_CLIENT(env))
2211 ret = __log_put(env,
2221 (void)__db_cksum_print(env,
2226 __os_free(env, logrec.data);
2229 __os_free(env, logrec.data);
2239 __db_pg_freedata_42_read(env, dbpp, td, recbuf, argpp)
2240 ENV *env;
2251 if ((ret = __os_malloc(env,
2259 LOGCOPY_32(env, &argp->type, bp);
2262 LOGCOPY_32(env, &argp->txnp->txnid, bp);
2265 LOGCOPY_TOLSN(env, &argp->prev_lsn, bp);
2268 LOGCOPY_32(env, &uinttmp, bp);
2274 env, argp->txnp, dbpp, argp->fileid, 1);
2277 LOGCOPY_32(env, &uinttmp, bp);
2281 LOGCOPY_TOLSN(env, &argp->meta_lsn, bp);
2284 LOGCOPY_32(env, &uinttmp, bp);
2289 LOGCOPY_32(env,&argp->header.size, bp);
2294 LOGCOPY_32(env, &uinttmp, bp);
2299 LOGCOPY_32(env,&argp->data.size, bp);
2313 __db_pg_freedata_read(env, dbpp, td, recbuf, argpp)
2314 ENV *env;
2325 if ((ret = __os_malloc(env,
2333 LOGCOPY_32(env, &argp->type, bp);
2336 LOGCOPY_32(env, &argp->txnp->txnid, bp);
2339 LOGCOPY_TOLSN(env, &argp->prev_lsn, bp);
2342 LOGCOPY_32(env, &uinttmp, bp);
2348 env, argp->txnp, dbpp, argp->fileid, 1);
2351 LOGCOPY_32(env, &uinttmp, bp);
2355 LOGCOPY_TOLSN(env, &argp->meta_lsn, bp);
2358 LOGCOPY_32(env, &uinttmp, bp);
2363 LOGCOPY_32(env,&argp->header.size, bp);
2368 LOGCOPY_32(env, &uinttmp, bp);
2372 LOGCOPY_32(env, &uinttmp, bp);
2377 LOGCOPY_32(env,&argp->data.size, bp);
2381 if (LOG_SWAPPED(env) && dbpp != NULL && *dbpp != NULL) {
2416 ENV *env;
2424 env = dbp->env;
2444 (ret = __txn_activekids(env, rectype, txnp)) != 0)
2456 DB_ASSERT(env, dbp->log_filename != NULL);
2470 if (CRYPTO_ON(env)) {
2471 npad = env->crypto_handle->adj_size(logrec.size);
2477 __os_malloc(env, logrec.size, &logrec.data)) != 0)
2480 if ((ret = __os_malloc(env,
2485 __os_malloc(env, logrec.size, &logrec.data)) != 0) {
2486 __os_free(env, lr);
2498 LOGCOPY_32(env, bp, &rectype);
2501 LOGCOPY_32(env, bp, &txn_num);
2504 LOGCOPY_FROMLSN(env, bp, lsnp);
2508 LOGCOPY_32(env, bp, &uinttmp);
2512 LOGCOPY_32(env,bp, &uinttmp);
2517 LOG *lp = env->lg_handle->reginfo.primary;
2519 __log_check_page_lsn(env, dbp, meta_lsn) != 0))
2522 LOGCOPY_FROMLSN(env, bp, meta_lsn);
2528 LOGCOPY_32(env,bp, &uinttmp);
2533 LOGCOPY_32(env, bp, &zero);
2536 LOGCOPY_32(env, bp, &header->size);
2539 if (LOG_SWAPPED(env))
2547 LOGCOPY_32(env,bp, &uinttmp);
2551 LOGCOPY_32(env,bp, &uinttmp);
2556 LOGCOPY_32(env, bp, &zero);
2559 LOGCOPY_32(env, bp, &data->size);
2562 if (LOG_SWAPPED(env) && F_ISSET(data, DB_DBT_APPMALLOC))
2563 __os_free(env, data->data);
2567 DB_ASSERT(env,
2571 if ((ret = __log_put(env, rlsnp,(DBT *)&logrec,
2586 LOGCOPY_32(env, logrec.data, &rectype);
2588 if (!IS_REP_CLIENT(env))
2589 ret = __log_put(env,
2599 (void)__db_pg_freedata_print(env,
2604 __os_free(env, logrec.data);
2607 __os_free(env, logrec.data);
2617 __db_pg_init_read(env, dbpp, td, recbuf, argpp)
2618 ENV *env;
2629 if ((ret = __os_malloc(env,
2637 LOGCOPY_32(env, &argp->type, bp);
2640 LOGCOPY_32(env, &argp->txnp->txnid, bp);
2643 LOGCOPY_TOLSN(env, &argp->prev_lsn, bp);
2646 LOGCOPY_32(env, &uinttmp, bp);
2652 env, argp->txnp, dbpp, argp->fileid, 1);
2655 LOGCOPY_32(env, &uinttmp, bp);
2660 LOGCOPY_32(env,&argp->header.size, bp);
2666 LOGCOPY_32(env,&argp->data.size, bp);
2670 if (LOG_SWAPPED(env) && dbpp != NULL && *dbpp != NULL) {
2699 ENV *env;
2707 env = dbp->env;
2727 (ret = __txn_activekids(env, rectype, txnp)) != 0)
2739 DB_ASSERT(env, dbp->log_filename != NULL);
2749 if (CRYPTO_ON(env)) {
2750 npad = env->crypto_handle->adj_size(logrec.size);
2756 __os_malloc(env, logrec.size, &logrec.data)) != 0)
2759 if ((ret = __os_malloc(env,
2764 __os_malloc(env, logrec.size, &logrec.data)) != 0) {
2765 __os_free(env, lr);
2777 LOGCOPY_32(env, bp, &rectype);
2780 LOGCOPY_32(env, bp, &txn_num);
2783 LOGCOPY_FROMLSN(env, bp, lsnp);
2787 LOGCOPY_32(env, bp, &uinttmp);
2791 LOGCOPY_32(env,bp, &uinttmp);
2796 LOGCOPY_32(env, bp, &zero);
2799 LOGCOPY_32(env, bp, &header->size);
2802 if (LOG_SWAPPED(env))
2811 LOGCOPY_32(env, bp, &zero);
2814 LOGCOPY_32(env, bp, &data->size);
2817 if (LOG_SWAPPED(env) && F_ISSET(data, DB_DBT_APPMALLOC))
2818 __os_free(env, data->data);
2822 DB_ASSERT(env,
2826 if ((ret = __log_put(env, rlsnp,(DBT *)&logrec,
2841 LOGCOPY_32(env, logrec.data, &rectype);
2843 if (!IS_REP_CLIENT(env))
2844 ret = __log_put(env,
2854 (void)__db_pg_init_print(env,
2859 __os_free(env, logrec.data);
2862 __os_free(env, logrec.data);
2872 __db_pg_sort_read(env, dbpp, td, recbuf, argpp)
2873 ENV *env;
2884 if ((ret = __os_malloc(env,
2892 LOGCOPY_32(env, &argp->type, bp);
2895 LOGCOPY_32(env, &argp->txnp->txnid, bp);
2898 LOGCOPY_TOLSN(env, &argp->prev_lsn, bp);
2901 LOGCOPY_32(env, &uinttmp, bp);
2907 env, argp->txnp, dbpp, argp->fileid, 1);
2910 LOGCOPY_32(env, &uinttmp, bp);
2914 LOGCOPY_TOLSN(env, &argp->meta_lsn, bp);
2917 LOGCOPY_32(env, &uinttmp, bp);
2921 LOGCOPY_TOLSN(env, &argp->last_lsn, bp);
2924 LOGCOPY_32(env, &uinttmp, bp);
2929 LOGCOPY_32(env,&argp->list.size, bp);
2960 ENV *env;
2968 env = dbp->env;
2988 (ret = __txn_activekids(env, rectype, txnp)) != 0)
3000 DB_ASSERT(env, dbp->log_filename != NULL);
3013 if (CRYPTO_ON(env)) {
3014 npad = env->crypto_handle->adj_size(logrec.size);
3020 __os_malloc(env, logrec.size, &logrec.data)) != 0)
3023 if ((ret = __os_malloc(env,
3028 __os_malloc(env, logrec.size, &logrec.data)) != 0) {
3029 __os_free(env, lr);
3041 LOGCOPY_32(env, bp, &rectype);
3044 LOGCOPY_32(env, bp, &txn_num);
3047 LOGCOPY_FROMLSN(env, bp, lsnp);
3051 LOGCOPY_32(env, bp, &uinttmp);
3055 LOGCOPY_32(env,bp, &uinttmp);
3060 LOG *lp = env->lg_handle->reginfo.primary;
3062 __log_check_page_lsn(env, dbp, meta_lsn) != 0))
3065 LOGCOPY_FROMLSN(env, bp, meta_lsn);
3071 LOGCOPY_32(env,bp, &uinttmp);
3076 LOG *lp = env->lg_handle->reginfo.primary;
3078 __log_check_page_lsn(env, dbp, last_lsn) != 0))
3081 LOGCOPY_FROMLSN(env, bp, last_lsn);
3087 LOGCOPY_32(env,bp, &uinttmp);
3092 LOGCOPY_32(env, bp, &zero);
3095 LOGCOPY_32(env, bp, &list->size);
3101 DB_ASSERT(env,
3105 if ((ret = __log_put(env, rlsnp,(DBT *)&logrec,
3120 LOGCOPY_32(env, logrec.data, &rectype);
3122 if (!IS_REP_CLIENT(env))
3123 ret = __log_put(env,
3133 (void)__db_pg_sort_print(env,
3138 __os_free(env, logrec.data);
3141 __os_free(env, logrec.data);
3150 __db_init_recover(env, dtabp)
3151 ENV *env;
3156 if ((ret = __db_add_recovery_int(env, dtabp,
3159 if ((ret = __db_add_recovery_int(env, dtabp,
3162 if ((ret = __db_add_recovery_int(env, dtabp,
3165 if ((ret = __db_add_recovery_int(env, dtabp,
3168 if ((ret = __db_add_recovery_int(env, dtabp,
3171 if ((ret = __db_add_recovery_int(env, dtabp,
3174 if ((ret = __db_add_recovery_int(env, dtabp,
3177 if ((ret = __db_add_recovery_int(env, dtabp,
3180 if ((ret = __db_add_recovery_int(env, dtabp,
3183 if ((ret = __db_add_recovery_int(env, dtabp,
3186 if ((ret = __db_add_recovery_int(env, dtabp,