fileio_asyncio.h File Reference

#include "../lib/common/mem.h"
#include "fileio_types.h"
#include "platform.h"
#include "util.h"
#include "../lib/common/pool.h"
#include "../lib/common/threading.h"

Go to the source code of this file.

Data Structures
struct	IOPoolCtx_t
struct	ReadPoolCtx_t
struct	WritePoolCtx_t
struct	IOJob_t

Macros
#define	MAX_IO_JOBS   (10)

Functions
int	AIO_supported (void)
void	AIO_WritePool_releaseIoJob (IOJob_t *job)
IOJob_t *	AIO_WritePool_acquireJob (WritePoolCtx_t *ctx)
void	AIO_WritePool_enqueueAndReacquireWriteJob (IOJob_t **job)
void	AIO_WritePool_sparseWriteEnd (WritePoolCtx_t *ctx)
void	AIO_WritePool_setFile (WritePoolCtx_t *ctx, FILE *file)
FILE *	AIO_WritePool_getFile (const WritePoolCtx_t *ctx)
int	AIO_WritePool_closeFile (WritePoolCtx_t *ctx)
WritePoolCtx_t *	AIO_WritePool_create (const FIO_prefs_t *prefs, size_t bufferSize)
void	AIO_WritePool_free (WritePoolCtx_t *ctx)
void	AIO_WritePool_setAsync (WritePoolCtx_t *ctx, int async)
ReadPoolCtx_t *	AIO_ReadPool_create (const FIO_prefs_t *prefs, size_t bufferSize)
void	AIO_ReadPool_free (ReadPoolCtx_t *ctx)
void	AIO_ReadPool_setAsync (ReadPoolCtx_t *ctx, int async)
void	AIO_ReadPool_consumeBytes (ReadPoolCtx_t *ctx, size_t n)
size_t	AIO_ReadPool_fillBuffer (ReadPoolCtx_t *ctx, size_t n)
size_t	AIO_ReadPool_consumeAndRefill (ReadPoolCtx_t *ctx)
void	AIO_ReadPool_setFile (ReadPoolCtx_t *ctx, FILE *file)
FILE *	AIO_ReadPool_getFile (const ReadPoolCtx_t *ctx)
int	AIO_ReadPool_closeFile (ReadPoolCtx_t *ctx)

Macro Definition Documentation

MAX_IO_JOBS

#define MAX_IO_JOBS   (10)

Function Documentation

AIO_ReadPool_closeFile()

int AIO_ReadPool_closeFile

(

ReadPoolCtx_t *

ctx

)

AIO_ReadPool_consumeAndRefill()

size_t AIO_ReadPool_consumeAndRefill

(

ReadPoolCtx_t *

ctx

)

AIO_ReadPool_consumeBytes()

void AIO_ReadPool_consumeBytes	(	ReadPoolCtx_t *	ctx,
		size_t	n )

AIO_ReadPool_create()

ReadPoolCtx_t * AIO_ReadPool_create	(	const FIO_prefs_t *	prefs,
		size_t	bufferSize )

AIO_ReadPool_fillBuffer()

size_t AIO_ReadPool_fillBuffer	(	ReadPoolCtx_t *	ctx,
		size_t	n )

AIO_ReadPool_free()

void AIO_ReadPool_free

(

ReadPoolCtx_t *

ctx

)

AIO_ReadPool_getFile()

FILE * AIO_ReadPool_getFile

(

const ReadPoolCtx_t *

ctx

)

AIO_ReadPool_setAsync()

void AIO_ReadPool_setAsync	(	ReadPoolCtx_t *	ctx,
		int	async )

AIO_ReadPool_setFile()

void AIO_ReadPool_setFile	(	ReadPoolCtx_t *	ctx,
		FILE *	file )

AIO_supported()

int AIO_supported

(

void

)

AIO_WritePool_acquireJob()

IOJob_t * AIO_WritePool_acquireJob

(

WritePoolCtx_t *

ctx

)

AIO_WritePool_closeFile()

int AIO_WritePool_closeFile

(

WritePoolCtx_t *

ctx

)

AIO_WritePool_create()

WritePoolCtx_t * AIO_WritePool_create	(	const FIO_prefs_t *	prefs,
		size_t	bufferSize )

AIO_WritePool_enqueueAndReacquireWriteJob()

void AIO_WritePool_enqueueAndReacquireWriteJob

(

IOJob_t **

job

)

AIO_WritePool_free()

void AIO_WritePool_free

(

WritePoolCtx_t *

ctx

)

AIO_WritePool_getFile()

FILE * AIO_WritePool_getFile

(

const WritePoolCtx_t *

ctx

)

AIO_WritePool_releaseIoJob()

void AIO_WritePool_releaseIoJob

(

IOJob_t *

job

)

AIO_WritePool_setAsync()

void AIO_WritePool_setAsync	(	WritePoolCtx_t *	ctx,
		int	async )

AIO_WritePool_setFile()

void AIO_WritePool_setFile	(	WritePoolCtx_t *	ctx,
		FILE *	file )

AIO_WritePool_sparseWriteEnd()

void AIO_WritePool_sparseWriteEnd

(

WritePoolCtx_t *

ctx

)