Lines Matching refs:rfp
255 u_int8_t *rfp, uid[DB_FILE_ID_LEN];
269 rfp = NULL;
271 rfp = *fp;
312 tmpfp.filenum, *filecntp, names[i], P_TO_ULONG(rfp),
324 if (rfp != origfp &&
343 &tmpfp, rfp, *fileszp, &len);
345 offset = (size_t)(rfp - *fp);
355 rfp = *fp + offset;
362 rfp += len;
363 *fp = rfp;
384 __rep_fileinfo_args *rfp;
391 rfp = NULL;
399 &rfp, fp, filesz, &new_fp)) != 0) {
405 fuid = (u_int8_t *)rfp->uid.data;
412 __os_free(env, rfp);
413 rfp = NULL;
416 if (rfp != NULL)
417 __os_free(env, rfp);
423 __rep_get_fileinfo(env, file, subdb, rfp, uid, filecntp)
426 __rep_fileinfo_args *rfp;
466 rfp->pgno = 0;
472 rfp->max_pgno = 0;
474 rfp->max_pgno = dbmeta->last_pgno;
475 rfp->pgsize = dbp->pgsize;
477 rfp->filenum = (*filecntp)++;
478 rfp->type = (u_int32_t)dbp->type;
479 rfp->db_flags = dbp->flags;
480 rfp->finfo_flags = 0;
486 FLD_SET(rfp->finfo_flags, REPINFO_DB_LITTLEENDIAN);
488 FLD_CLR(rfp->finfo_flags, REPINFO_DB_LITTLEENDIAN);
1480 __rep_fileinfo_args *msgfp, *rfp;
1515 rfp = rep->curinfo;
1516 if (rfp->type != (u_int32_t)DB_QUEUE)
1517 --rfp->max_pgno;
1527 (u_long)rfp->max_pgno, rep->npages));
1528 if (msgfp->pgno == rfp->max_pgno)
1529 --rfp->max_pgno;
1537 (u_long)rfp->max_pgno, rep->npages));
1570 __rep_fileinfo_args *rfp;
1574 rfp = NULL;
1585 rfp = rep->curinfo;
1587 if (!FLD_ISSET(rfp->db_flags, DB_AM_INMEM)) {
1594 (char *)rfp->info.data));
1596 rfp->info.data, DB_APP_DATA,
1603 FLD_ISSET(rfp->db_flags, DB_AM_INMEM) ? DB_CREATE : 0)) != 0)
1695 __rep_fileinfo_args *rfp;
1712 rfp = rep->curinfo;
1718 if (rfp->filenum != msgfp->filenum) {
1754 (u_long)msgfp->pgno, (u_long)rfp->max_pgno, (u_long)rep->ready_pg,
1836 if (rep->ready_pg > rfp->max_pgno)
1847 * We need to set rfp->pgno to the current page number
1851 rfp->pgno = msgfp->pgno;
1853 ((ret = __rep_pggap_req(env, rep, rfp,
2004 __rep_fileinfo_args *rfp;
2019 rfp = rep->curinfo;
2026 (u_long)rep->npages, (u_long)rfp->max_pgno + 1));
2027 if (rep->npages <= rfp->max_pgno)
2035 if (rfp->type == (u_int32_t)DB_QUEUE &&
2036 ((ret = __rep_queue_filedone(env, ip, rep, rfp)) !=
2157 __rep_mpf_open(env, mpfp, rfp, flags)
2160 __rep_fileinfo_args *rfp;
2174 db.type = (DBTYPE)rfp->type;
2175 db.pgsize = rfp->pgsize;
2176 memcpy(db.fileid, rfp->uid.data, DB_FILE_ID_LEN);
2177 db.flags = rfp->db_flags;
2186 !FLD_ISSET(rfp->finfo_flags, REPINFO_DB_LITTLEENDIAN)) ||
2188 FLD_ISSET(rfp->finfo_flags, REPINFO_DB_LITTLEENDIAN))) {
2198 if ((ret = __env_mpool(&db, rfp->info.data, flags)) != 0) {
2348 __rep_fileinfo_args *rfp;
2358 if ((ret = __os_malloc(env, size, &rfp)) != 0)
2365 memcpy(rfp, rfpsrc, sizeof(__rep_fileinfo_args));
2366 uidp = (u_int8_t *)rfp + sizeof(__rep_fileinfo_args);
2367 rfp->uid.data = uidp;
2371 rfp->info.data = infop;
2373 *rfpp = rfp;
2446 __rep_queue_filedone(env, ip, rep, rfp)
2450 __rep_fileinfo_args *rfp;
2455 COMPQUIET(rfp, NULL);
2483 FLD_ISSET(rfp->db_flags, DB_AM_INMEM) ? NULL :
2484 rfp->info.data,
2485 FLD_ISSET(rfp->db_flags, DB_AM_INMEM) ? rfp->info.data :
2510 if (rfp->max_pgno == 0) {
2518 rfp->max_pgno =
2521 rfp->max_pgno = last;
2524 (u_long)first, (u_long)rfp->max_pgno));
2526 } else if (rfp->max_pgno != last) {
2534 rfp->max_pgno = last;
2546 rep->waiting_pg = rfp->max_pgno + 1;
2548 ret = __rep_pggap_req(env, rep, rfp, 0);
2850 __rep_fileinfo_args *rfp;
2857 rfp = NULL;
2860 &rfp, filelist, filesz, &new_fp)) != 0)
2865 DB_APP_DATA, rfp->info.data, 0, NULL, &namep)) != 0)
2869 __os_free(env, rfp);
2870 rfp = NULL;
2893 if (rfp != NULL)
2894 __os_free(env, rfp);