#include <DiskThreadsDiskFile.h>

Inheritance diagram for DiskThreadsDiskFile:

Collaboration diagram for DiskThreadsDiskFile:

Public Types
typedef RefCount< DiskFile >	Pointer

Public Member Functions
	DiskThreadsDiskFile (char const *path)

	~DiskThreadsDiskFile () override

void	open (int flags, mode_t mode, RefCount< IORequestor > callback) override

void	create (int flags, mode_t mode, RefCount< IORequestor > callback) override

void	read (ReadRequest *) override

void	write (WriteRequest *) override

void	close () override

bool	error () const override

int	getFD () const override

bool	canRead () const override

bool	canWrite () const override

bool	ioInProgress () const override

virtual void	configure (const Config &)
	notes supported configuration options; kids must call this first

Private Member Functions
	CBDATA_CLASS (DiskThreadsDiskFile)

void	openDone (int fd, const char *buf, int aio_return, int aio_errno)

void	doClose ()

void	readDone (int fd, const char *buf, int len, int errflag, const RefCount< ReadRequest > &request)

void	writeDone (int fd, int errflag, size_t len, RefCount< WriteRequest > request)

Private Attributes
int	fd = -1

bool	errorOccured = false

char const *	path_ = nullptr

size_t	inProgressIOs = 0

RefCount< IORequestor >	ioRequestor

Static Private Attributes
static DRCB	ReadDone

static DWCB	WriteDone

static AIOCB	OpenDone

Detailed Description

Definition at line 19 of file DiskThreadsDiskFile.h.

Member Typedef Documentation

◆ Pointer

typedef RefCount<DiskFile> DiskFile::Pointer

inherited

Definition at line 39 of file DiskFile.h.

Constructor & Destructor Documentation

◆ DiskThreadsDiskFile()

DiskThreadsDiskFile::DiskThreadsDiskFile ( char const * path )

Definition at line 30 of file DiskThreadsDiskFile.cc.

References assert, debugs, path_, and xstrdup.

◆ ~DiskThreadsDiskFile()

DiskThreadsDiskFile::~DiskThreadsDiskFile ( )

override

Definition at line 37 of file DiskThreadsDiskFile.cc.

References doClose(), path_, and safe_free.

Member Function Documentation

◆ canRead()

bool DiskThreadsDiskFile::canRead ( ) const

overridevirtual

Implements DiskFile.

Definition at line 198 of file DiskThreadsDiskFile.cc.

References debugs, and fd.

◆ canWrite()

bool DiskThreadsDiskFile::canWrite ( ) const

overridevirtual

Reimplemented from DiskFile.

Definition at line 222 of file DiskThreadsDiskFile.cc.

References fd.

◆ CBDATA_CLASS()

DiskThreadsDiskFile::CBDATA_CLASS ( DiskThreadsDiskFile )

private

◆ close()

void DiskThreadsDiskFile::close ( )

overridevirtual

Implements DiskFile.

Definition at line 182 of file DiskThreadsDiskFile.cc.

References assert, IORequestor::closeCompleted(), DBG_CRITICAL, debugs, doClose(), RefCount< C >::getRaw(), ioInProgress(), and ioRequestor.

◆ configure()

virtual void DiskFile::configure ( const Config & )

inlinevirtualinherited

Reimplemented in IpcIoFile.

Definition at line 42 of file DiskFile.h.

Referenced by IpcIoFile::configure().

◆ create()

void DiskThreadsDiskFile::create	(	int	flags,
		mode_t	mode,
		RefCount< IORequestor >	callback
	)

overridevirtual

Implements DiskFile.

Definition at line 93 of file DiskThreadsDiskFile.cc.

References aioOpen(), debugs, StatCounters::disk, errorOccured, fd, file_open(), inProgressIOs, ioRequestor, OpenDone, openDone(), Opening_FD, StatCounters::opens, path_, statCounter, and StatCounters::syscalls.

◆ doClose()

void DiskThreadsDiskFile::doClose ( )

private

Definition at line 162 of file DiskThreadsDiskFile.cc.

References aioCancel(), aioClose(), StatCounters::closes, StatCounters::disk, fd, fd_close(), file_close(), statCounter, store_open_disk_fd, and StatCounters::syscalls.

Referenced by ~DiskThreadsDiskFile(), and close().

◆ error()

bool DiskThreadsDiskFile::error ( ) const

overridevirtual

Implements DiskFile.

Definition at line 125 of file DiskThreadsDiskFile.cc.

References errorOccured.

◆ getFD()

int DiskThreadsDiskFile::getFD ( ) const

inlineoverridevirtual

During migration only

Reimplemented from DiskFile.

Definition at line 32 of file DiskThreadsDiskFile.h.

References fd.

◆ ioInProgress()

bool DiskThreadsDiskFile::ioInProgress ( ) const

overridevirtual

Inform callers if there is IO in progress

Implements DiskFile.

Definition at line 228 of file DiskThreadsDiskFile.cc.

References inProgressIOs.

Referenced by close().

◆ open()

void DiskThreadsDiskFile::open	(	int	flags,
		mode_t	mode,
		RefCount< IORequestor >	callback
	)

overridevirtual

Implements DiskFile.

Definition at line 44 of file DiskThreadsDiskFile.cc.

References aioOpen(), debugs, StatCounters::disk, errorOccured, fd, file_open(), inProgressIOs, ioRequestor, OpenDone, openDone(), Opening_FD, StatCounters::opens, path_, statCounter, and StatCounters::syscalls.

◆ openDone()

void DiskThreadsDiskFile::openDone	(	int	fd,
		const char *	buf,
		int	aio_return,
		int	aio_errno
	)

private

Definition at line 138 of file DiskThreadsDiskFile.cc.

References commSetCloseOnExec(), DBG_CRITICAL, DBG_IMPORTANT, debugs, errorOccured, fd, FD_FILE, fd_open(), inProgressIOs, IORequestor::ioCompletedNotification(), ioRequestor, MYNAME, Opening_FD, path_, store_open_disk_fd, and xstrerr().

Referenced by create(), and open().

◆ read()

void DiskThreadsDiskFile::read ( ReadRequest * request )

overridevirtual

Implements DiskFile.

Definition at line 76 of file DiskThreadsDiskFile.cc.

References aioRead(), assert, ReadRequest::buf, debugs, StatCounters::disk, fd, file_read(), RefCount< C >::getRaw(), inProgressIOs, ioRequestor, ReadRequest::len, ReadRequest::offset, ReadDone, StatCounters::reads, statCounter, and StatCounters::syscalls.

◆ readDone()

void DiskThreadsDiskFile::readDone	(	int	fd,
		const char *	buf,
		int	len,
		int	errflag,
		const RefCount< ReadRequest > &	request
	)

private

Definition at line 250 of file DiskThreadsDiskFile.cc.

References assert, debugs, DISK_EOF, DISK_ERROR, DISK_OK, fd, inProgressIOs, ioRequestor, and IORequestor::readCompleted().

◆ write()

void DiskThreadsDiskFile::write ( WriteRequest * writeRequest )

overridevirtual

Implements DiskFile.

Definition at line 205 of file DiskThreadsDiskFile.cc.

References aioWrite(), WriteRequest::buf, debugs, StatCounters::disk, fd, file_write(), WriteRequest::free_func, inProgressIOs, WriteRequest::len, WriteRequest::offset, statCounter, StatCounters::syscalls, WriteDone, and StatCounters::writes.

◆ writeDone()

void DiskThreadsDiskFile::writeDone	(	int	fd,
		int	errflag,
		size_t	len,
		RefCount< WriteRequest >	request
	)

private

Definition at line 300 of file DiskThreadsDiskFile.cc.

References assert, debugs, DISK_ERROR, DISK_NO_SPACE_LEFT, DISK_OK, fd, inProgressIOs, ioRequestor, and IORequestor::writeCompleted().

Member Data Documentation

◆ errorOccured

bool DiskThreadsDiskFile::errorOccured = false

private

Definition at line 55 of file DiskThreadsDiskFile.h.

Referenced by create(), error(), open(), and openDone().

◆ fd

int DiskThreadsDiskFile::fd = -1

private

Definition at line 54 of file DiskThreadsDiskFile.h.

Referenced by canRead(), canWrite(), create(), doClose(), getFD(), open(), openDone(), read(), readDone(), write(), and writeDone().

◆ inProgressIOs

size_t DiskThreadsDiskFile::inProgressIOs = 0

private

Definition at line 57 of file DiskThreadsDiskFile.h.

Referenced by create(), ioInProgress(), open(), openDone(), read(), readDone(), write(), and writeDone().

◆ ioRequestor

RefCount<IORequestor> DiskThreadsDiskFile::ioRequestor

private

Definition at line 60 of file DiskThreadsDiskFile.h.

Referenced by close(), create(), open(), openDone(), read(), readDone(), and writeDone().

◆ OpenDone

void DiskThreadsDiskFile::OpenDone

staticprivate

Definition at line 58 of file DiskThreadsDiskFile.h.

Referenced by create(), and open().

◆ path_

char const* DiskThreadsDiskFile::path_ = nullptr

private

Definition at line 56 of file DiskThreadsDiskFile.h.

Referenced by DiskThreadsDiskFile(), ~DiskThreadsDiskFile(), create(), open(), and openDone().

◆ ReadDone

void DiskThreadsDiskFile::ReadDone

staticprivate

Definition at line 44 of file DiskThreadsDiskFile.h.

Referenced by read().

◆ WriteDone

void DiskThreadsDiskFile::WriteDone

staticprivate

Definition at line 51 of file DiskThreadsDiskFile.h.

Referenced by write().

The documentation for this class was generated from the following files:

squid/src/DiskIO/DiskThreads/DiskThreadsDiskFile.h
squid/src/DiskIO/DiskThreads/DiskThreadsDiskFile.cc

Public Types

Public Member Functions

Private Member Functions

Private Attributes

Static Private Attributes

Detailed Description

Member Typedef Documentation

◆ Pointer

Constructor & Destructor Documentation

◆ DiskThreadsDiskFile()

◆ ~DiskThreadsDiskFile()

Member Function Documentation

◆ canRead()

◆ canWrite()

◆ CBDATA_CLASS()

◆ close()

◆ configure()

◆ create()

◆ doClose()

◆ error()

◆ getFD()

◆ ioInProgress()

◆ open()

◆ openDone()

◆ read()

◆ readDone()

◆ write()

◆ writeDone()

Member Data Documentation

◆ errorOccured

◆ fd

◆ inProgressIOs

◆ ioRequestor

◆ OpenDone

◆ path_

◆ ReadDone

◆ WriteDone