Lines Matching refs:regbuf

215 	registered_buffer *regbuf;  in XLogRegisterBuffer()  local
228 regbuf = &registered_buffers[block_id]; in XLogRegisterBuffer()
230 BufferGetTag(buffer, &regbuf->rnode, &regbuf->forkno, &regbuf->block); in XLogRegisterBuffer()
231 regbuf->page = BufferGetPage(buffer); in XLogRegisterBuffer()
232 regbuf->flags = flags; in XLogRegisterBuffer()
233 regbuf->rdata_tail = (XLogRecData *) &regbuf->rdata_head; in XLogRegisterBuffer()
234 regbuf->rdata_len = 0; in XLogRegisterBuffer()
251 Assert(!RelFileNodeEquals(regbuf_old->rnode, regbuf->rnode) || in XLogRegisterBuffer()
252 regbuf_old->forkno != regbuf->forkno || in XLogRegisterBuffer()
253 regbuf_old->block != regbuf->block); in XLogRegisterBuffer()
258 regbuf->in_use = true; in XLogRegisterBuffer()
269 registered_buffer *regbuf; in XLogRegisterBlock() local
281 regbuf = &registered_buffers[block_id]; in XLogRegisterBlock()
283 regbuf->rnode = *rnode; in XLogRegisterBlock()
284 regbuf->forkno = forknum; in XLogRegisterBlock()
285 regbuf->block = blknum; in XLogRegisterBlock()
286 regbuf->page = page; in XLogRegisterBlock()
287 regbuf->flags = flags; in XLogRegisterBlock()
288 regbuf->rdata_tail = (XLogRecData *) &regbuf->rdata_head; in XLogRegisterBlock()
289 regbuf->rdata_len = 0; in XLogRegisterBlock()
306 Assert(!RelFileNodeEquals(regbuf_old->rnode, regbuf->rnode) || in XLogRegisterBlock()
307 regbuf_old->forkno != regbuf->forkno || in XLogRegisterBlock()
308 regbuf_old->block != regbuf->block); in XLogRegisterBlock()
313 regbuf->in_use = true; in XLogRegisterBlock()
363 registered_buffer *regbuf; in XLogRegisterBufData() local
369 regbuf = &registered_buffers[block_id]; in XLogRegisterBufData()
370 if (!regbuf->in_use) in XLogRegisterBufData()
381 regbuf->rdata_tail->next = rdata; in XLogRegisterBufData()
382 regbuf->rdata_tail = rdata; in XLogRegisterBufData()
383 regbuf->rdata_len += len; in XLogRegisterBufData()
526 registered_buffer *regbuf = &registered_buffers[block_id]; in XLogRecordAssemble() local
536 if (!regbuf->in_use) in XLogRecordAssemble()
540 if (regbuf->flags & REGBUF_FORCE_IMAGE) in XLogRecordAssemble()
542 else if (regbuf->flags & REGBUF_NO_IMAGE) in XLogRecordAssemble()
553 XLogRecPtr page_lsn = PageGetLSN(regbuf->page); in XLogRecordAssemble()
564 if (regbuf->rdata_len == 0) in XLogRecordAssemble()
566 else if ((regbuf->flags & REGBUF_KEEP_DATA) != 0) in XLogRecordAssemble()
572 bkpb.fork_flags = regbuf->forkno; in XLogRecordAssemble()
575 if ((regbuf->flags & REGBUF_WILL_INIT) == REGBUF_WILL_INIT) in XLogRecordAssemble()
586 Page page = regbuf->page; in XLogRecordAssemble()
593 if (regbuf->flags & REGBUF_STANDARD) in XLogRecordAssemble()
628 regbuf->compressed_page, in XLogRecordAssemble()
641 rdt_datas_last->next = &regbuf->bkp_rdatas[0]; in XLogRecordAssemble()
660 rdt_datas_last->data = regbuf->compressed_page; in XLogRecordAssemble()
678 rdt_datas_last->next = &regbuf->bkp_rdatas[1]; in XLogRecordAssemble()
698 bkpb.data_length = regbuf->rdata_len; in XLogRecordAssemble()
699 total_len += regbuf->rdata_len; in XLogRecordAssemble()
701 rdt_datas_last->next = regbuf->rdata_head; in XLogRecordAssemble()
702 rdt_datas_last = regbuf->rdata_tail; in XLogRecordAssemble()
705 if (prev_regbuf && RelFileNodeEquals(regbuf->rnode, prev_regbuf->rnode)) in XLogRecordAssemble()
712 prev_regbuf = regbuf; in XLogRecordAssemble()
730 memcpy(scratch, &regbuf->rnode, sizeof(RelFileNode)); in XLogRecordAssemble()
733 memcpy(scratch, &regbuf->block, sizeof(BlockNumber)); in XLogRecordAssemble()