Lines Matching defs:msgfp
524 __rep_fileinfo_args *msgfp;
535 &msgfp, rec->data, rec->size, &next)) != 0)
540 msgfp->filenum, (u_long)msgfp->pgno, (u_long)msgfp->max_pgno));
547 (env, "page_req: Open %d via mpf_open", msgfp->filenum));
548 if ((ret = __rep_mpf_open(env, &mpf, msgfp, 0)) != 0) {
550 (env, "page_req: Open %d failed", msgfp->filenum));
559 ret = __rep_page_sendpages(env, ip, eid, rp, msgfp, mpf, NULL);
564 __os_free(env, msgfp);
569 __rep_page_sendpages(env, ip, eid, rp, msgfp, mpf, dbp)
574 __rep_fileinfo_args *msgfp;
608 if (msgfp->type == (u_int32_t)DB_QUEUE) {
618 FLD_ISSET(msgfp->db_flags, DB_AM_INMEM) ?
619 NULL : msgfp->info.data,
620 FLD_ISSET(msgfp->db_flags, DB_AM_INMEM) ?
621 msgfp->info.data : NULL,
632 msgsz = __REP_FILEINFO_SIZE + DB_FILE_ID_LEN + msgfp->pgsize;
638 msgfp->filenum, (u_long)msgfp->pgno, (u_long)msgfp->max_pgno));
673 for (p = msgfp->pgno; p <= msgfp->max_pgno; p++) {
694 if (msgfp->type == (u_int32_t)DB_QUEUE && p != 0)
703 msgfp->pgno = p;
719 DB_SET_DBT(msgfp->info, pagep, msgfp->pgsize);
732 FLD_SET(msgfp->finfo_flags, REPINFO_PG_LITTLEENDIAN);
734 FLD_CLR(msgfp->finfo_flags, REPINFO_PG_LITTLEENDIAN);
739 msgfp, buf, msgsz, &len);
740 if (msgfp->type != (u_int32_t)DB_QUEUE || p == 0)
1329 __rep_fileinfo_args *msgfp;
1355 &msgfp, rec->data, rec->size, NULL)) != 0)
1367 (u_long)msgfp->pgno, msgfp->filenum));
1377 if (msgfp->filenum != rep->curfile) {
1380 msgfp->filenum, rep->curfile));
1396 recno = (db_recno_t)(msgfp->pgno + 1);
1410 (u_long)msgfp->pgno, msgfp->filenum));
1419 "PAGE: Write page %lu into mpool", (u_long)msgfp->pgno));
1423 ret = __rep_write_page(env, ip, rep, msgfp);
1453 ret = __rep_filedone(env, ip, eid, rep, msgfp, rp->rectype);
1458 __os_free(env, msgfp);
1480 __rep_fileinfo_args *msgfp, *rfp;
1490 &msgfp, rec->data, rec->size, NULL)) != 0)
1509 if (msgfp->filenum != rep->curfile) {
1512 msgfp->filenum, rep->curfile));
1521 * may disappear, as well as at the end. Use msgfp->pgno
1526 (u_long)msgfp->pgno, (u_long)rep->ready_pg,
1528 if (msgfp->pgno == rfp->max_pgno)
1530 if (msgfp->pgno >= rep->ready_pg) {
1531 rep->ready_pg = msgfp->pgno + 1;
1536 (u_long)msgfp->pgno, (u_long)rep->ready_pg,
1547 ret = __rep_filedone(env, ip, eid, rep, msgfp, REP_PAGE_FAIL);
1551 __os_free(env, msgfp);
1560 __rep_write_page(env, ip, rep, msgfp)
1564 __rep_fileinfo_args *msgfp;
1614 if (msgfp->type == (u_int32_t)DB_QUEUE && msgfp->pgno != 0) {
1616 ret = __qam_fget(rep->queue_dbc, &msgfp->pgno,
1625 ret = __memp_fget(rep->file_mpf, &msgfp->pgno, ip, NULL,
1638 !FLD_ISSET(msgfp->finfo_flags, REPINFO_PG_LITTLEENDIAN)) ||
1640 FLD_ISSET(msgfp->finfo_flags, REPINFO_PG_LITTLEENDIAN))) {
1642 "write_page: Page %d needs to be swapped", msgfp->pgno));
1653 db.type = (DBTYPE)msgfp->type;
1654 db.pgsize = msgfp->pgsize;
1660 if ((ret = __db_pageswap(&db, msgfp->info.data, msgfp->pgsize,
1665 memcpy(dst, msgfp->info.data, msgfp->pgsize);
1667 if (msgfp->type == (u_int32_t)DB_QUEUE && msgfp->pgno != 0)
1669 msgfp->pgno, dst, rep->queue_dbc->priority);
1684 __rep_page_gap(env, rep, msgfp, type)
1687 __rep_fileinfo_args *msgfp;
1718 if (rfp->filenum != msgfp->filenum) {
1738 if (msgfp->pgno < rep->ready_pg) {
1741 (u_long)msgfp->pgno, (u_long)rep->ready_pg,
1754 (u_long)msgfp->pgno, (u_long)rfp->max_pgno, (u_long)rep->ready_pg,
1756 if (msgfp->pgno > rep->ready_pg) {
1758 msgfp->pgno < rep->waiting_pg)
1759 rep->waiting_pg = msgfp->pgno;
1851 rfp->pgno = msgfp->pgno;
1996 __rep_filedone(env, ip, eid, rep, msgfp, type)
2001 __rep_fileinfo_args *msgfp;
2011 ret = __rep_page_gap(env, rep, msgfp, type);