172 void *callback_private_data,
173 void *per_buffer_data)
244 if (!suppress_advice &&
256 &stream->
buffers[buffer_index],
288 overflow = (buffer_index + nblocks) - stream->
queue_size;
292 sizeof(stream->
buffers[0]) * overflow);
295 buffer_index += nblocks;
298 Assert(buffer_index >= 0 && buffer_index < stream->queue_size);
314 void *per_buffer_data;
319 suppress_advice =
false;
331 Assert(buffer_index >= 0 && buffer_index < stream->queue_size);
353 suppress_advice =
false;
401 void *callback_private_data,
402 size_t per_buffer_data_size)
408 int strategy_pin_limit;
409 uint32 max_pinned_buffers;
446 max_pinned_buffers =
Min(max_pinned_buffers,
451 max_pinned_buffers =
Min(strategy_pin_limit, max_pinned_buffers);
458 Assert(max_pinned_buffers > 0);
466 queue_size = max_pinned_buffers + 1;
479 size += per_buffer_data_size * queue_size;
480 size += MAXIMUM_ALIGNOF * 2;
482 memset(stream, 0, offsetof(
ReadStream, buffers));
485 if (per_buffer_data_size > 0)
534 for (
int i = 0;
i < max_ios; ++
i)
556 void *callback_private_data,
557 size_t per_buffer_data_size)
563 rel->
rd_rel->relpersistence,
566 callback_private_data,
567 per_buffer_data_size);
578 char smgr_persistence,
581 void *callback_private_data,
582 size_t per_buffer_data_size)
591 callback_private_data,
592 per_buffer_data_size);
608 int16 oldest_buffer_index;
610#ifndef READ_STREAM_DISABLE_FAST_PATH
633 buffer = stream->
buffers[oldest_buffer_index];
648 &stream->
buffers[oldest_buffer_index],
704 Assert(oldest_buffer_index >= 0 &&
705 oldest_buffer_index < stream->queue_size);
706 buffer = stream->
buffers[oldest_buffer_index];
721 &stream->
buffers[oldest_buffer_index]);
754#ifdef CLOBBER_FREED_MEMORY
766 oldest_buffer_index == 0 ?
768 oldest_buffer_index - 1),
784#ifndef READ_STREAM_DISABLE_FAST_PATH
#define InvalidBlockNumber
bool StartReadBuffers(ReadBuffersOperation *operation, Buffer *buffers, BlockNumber blockNum, int *nblocks, int flags)
void ReleaseBuffer(Buffer buffer)
void WaitReadBuffers(ReadBuffersOperation *operation)
void LimitAdditionalPins(uint32 *additional_pins)
int effective_io_concurrency
bool StartReadBuffer(ReadBuffersOperation *operation, Buffer *buffer, BlockNumber blocknum, int flags)
#define READ_BUFFERS_ISSUE_ADVICE
static bool BufferIsValid(Buffer bufnum)
#define Assert(condition)
#define FLEXIBLE_ARRAY_MEMBER
#define OidIsValid(objectId)
bool IsCatalogRelation(Relation relation)
bool IsCatalogRelationOid(Oid relid)
int GetAccessStrategyPinLimit(BufferAccessStrategy strategy)
if(TABLE==NULL||TABLE_index==NULL)
void LimitAdditionalLocalPins(uint32 *additional_pins)
void pfree(void *pointer)
ReadStream * read_stream_begin_smgr_relation(int flags, BufferAccessStrategy strategy, SMgrRelation smgr, char smgr_persistence, ForkNumber forknum, ReadStreamBlockNumberCB callback, void *callback_private_data, size_t per_buffer_data_size)
static void read_stream_look_ahead(ReadStream *stream, bool suppress_advice)
BlockNumber read_stream_next_block(ReadStream *stream, BufferAccessStrategy *strategy)
void read_stream_reset(ReadStream *stream)
Buffer read_stream_next_buffer(ReadStream *stream, void **per_buffer_data)
static void * get_per_buffer_data(ReadStream *stream, int16 buffer_index)
ReadStream * read_stream_begin_relation(int flags, BufferAccessStrategy strategy, Relation rel, ForkNumber forknum, ReadStreamBlockNumberCB callback, void *callback_private_data, size_t per_buffer_data_size)
struct InProgressIO InProgressIO
void read_stream_end(ReadStream *stream)
BlockNumber block_range_read_stream_cb(ReadStream *stream, void *callback_private_data, void *per_buffer_data)
static BlockNumber read_stream_get_block(ReadStream *stream, void *per_buffer_data)
static void read_stream_unget_block(ReadStream *stream, BlockNumber blocknum)
static ReadStream * read_stream_begin_impl(int flags, BufferAccessStrategy strategy, Relation rel, SMgrRelation smgr, char persistence, ForkNumber forknum, ReadStreamBlockNumberCB callback, void *callback_private_data, size_t per_buffer_data_size)
static void read_stream_start_pending_read(ReadStream *stream, bool suppress_advice)
#define READ_STREAM_MAINTENANCE
BlockNumber(* ReadStreamBlockNumberCB)(ReadStream *stream, void *callback_private_data, void *per_buffer_data)
#define READ_STREAM_SEQUENTIAL
static SMgrRelation RelationGetSmgr(Relation rel)
static pg_noinline void Size size
int get_tablespace_io_concurrency(Oid spcid)
int get_tablespace_maintenance_io_concurrency(Oid spcid)
BlockNumber last_exclusive
BlockNumber current_blocknum
BufferAccessStrategy strategy
struct SMgrRelationData * smgr
int16 oldest_buffer_index
BlockNumber pending_read_blocknum
BlockNumber buffered_blocknum
size_t per_buffer_data_size
ReadStreamBlockNumberCB callback
int16 pending_read_nblocks
void * callback_private_data
Buffer buffers[FLEXIBLE_ARRAY_MEMBER]
RelFileLocatorBackend smgr_rlocator
static void callback(struct sockaddr *addr, struct sockaddr *mask, void *unused)