#include <disk-io-mgr.h>

Collaboration diagram for impala::DiskIoMgr::BufferDescriptor:

Public Member Functions
ScanRange *	scan_range ()

char *	buffer ()

int64_t	buffer_len ()

int64_t	len ()

bool	eosr ()

int64_t	scan_range_offset () const
	Returns the offset within the scan range that this buffer starts at. More...

void	SetMemTracker (MemTracker *tracker)

void	Return ()

Private Member Functions
	BufferDescriptor (DiskIoMgr *io_mgr)

void	Reset (RequestContext reader, ScanRange range, char *buffer, int64_t buffer_len)
	Resets the buffer descriptor state for a new reader, range and data buffer. More...

Private Attributes
DiskIoMgr *	io_mgr_

RequestContext *	reader_
	Reader that this buffer is for. More...

MemTracker *	mem_tracker_
	The current tracker this buffer is associated with. More...

ScanRange *	scan_range_
	Scan range that this buffer is for. More...

char *	buffer_
	buffer with the read contents More...

int64_t	buffer_len_
	length of buffer_. For buffers from cached reads, the length is 0. More...

int64_t	len_
	length of read contents More...

bool	eosr_
	true if the current scan range is complete More...

Status	status_
	Status of the read to this buffer. if status is not ok, 'buffer' is NULL. More...

int64_t	scan_range_offset_

Friends
class	DiskIoMgr

Detailed Description

Buffer struct that is used by the caller and IoMgr to pass read buffers. It is is expected that only one thread has ownership of this object at a time.

Definition at line 196 of file disk-io-mgr.h.

Constructor & Destructor Documentation

DiskIoMgr::BufferDescriptor::BufferDescriptor ( DiskIoMgr * io_mgr )

private

Definition at line 161 of file disk-io-mgr.cc.

Member Function Documentation

char* impala::DiskIoMgr::BufferDescriptor::buffer ( )

inline

Definition at line 199 of file disk-io-mgr.h.

References buffer_.

Referenced by impala::DiskIoMgrStress::ClientThread(), impala::BufferedBlockMgr::PinBlock(), impala::HdfsParquetScanner::ProcessFooter(), impala::TEST_F(), impala::DiskIoMgrTest::ValidateScanRange(), and impala::DiskIoMgrTest::ValidateSyncRead().

int64_t impala::DiskIoMgr::BufferDescriptor::buffer_len ( )

inline

Definition at line 200 of file disk-io-mgr.h.

References buffer_len_.

Referenced by impala::RowBatch::AcquireState(), impala::RowBatch::AddIoBuffer(), and impala::RowBatch::TransferResourceOwnership().

bool impala::DiskIoMgr::BufferDescriptor::eosr ( )

inline

Definition at line 202 of file disk-io-mgr.h.

References eosr_.

Referenced by impala::DiskIoMgr::ScanRange::EnqueueBuffer(), impala::DiskIoMgr::ScanRange::GetNext(), and impala::BufferedBlockMgr::PinBlock().

int64_t impala::DiskIoMgr::BufferDescriptor::len ( )

inline

Definition at line 201 of file disk-io-mgr.h.

References len_.

Referenced by impala::DiskIoMgrStress::ClientThread(), impala::BufferedBlockMgr::PinBlock(), impala::HdfsParquetScanner::ProcessFooter(), impala::TEST_F(), impala::DiskIoMgrTest::ValidateScanRange(), and impala::DiskIoMgrTest::ValidateSyncRead().

void DiskIoMgr::BufferDescriptor::Reset	(	RequestContext *	reader,
		ScanRange *	range,
		char *	buffer,
		int64_t	buffer_len
	)

private

Resets the buffer descriptor state for a new reader, range and data buffer.

Definition at line 165 of file disk-io-mgr.cc.

References impala::Status::OK.

Referenced by impala::DiskIoMgr::GetBufferDesc().

void DiskIoMgr::BufferDescriptor::Return ( )

Returns the buffer to the IoMgr. This must be called for every buffer returned by GetNext()/Read() that did not return an error. This is non-blocking.

Definition at line 182 of file disk-io-mgr.cc.

Referenced by impala::DiskIoMgr::ScanRange::CleanupQueuedBuffers(), impala::DiskIoMgrStress::ClientThread(), impala::DiskIoMgr::ScanRange::EnqueueBuffer(), impala::BufferedBlockMgr::PinBlock(), impala::HdfsParquetScanner::ProcessFooter(), impala::DiskIoMgrTest::ValidateScanRange(), and impala::DiskIoMgrTest::ValidateSyncRead().