Differential D613 Diff 14143 ps/trunk/source/lib/file/io/io.h

Changeset View

Standalone View

ps/trunk/source/lib/file/io/io.h

/* Copyright (C) 2018 Wildfire Games.		/* Copyright (C) 2020 Wildfire Games.
*		*
* Permission is hereby granted, free of charge, to any person obtaining		* Permission is hereby granted, free of charge, to any person obtaining
* a copy of this software and associated documentation files (the		* a copy of this software and associated documentation files (the
* "Software"), to deal in the Software without restriction, including		* "Software"), to deal in the Software without restriction, including
* without limitation the rights to use, copy, modify, merge, publish,		* without limitation the rights to use, copy, modify, merge, publish,
* distribute, sublicense, and/or sell copies of the Software, and to		* distribute, sublicense, and/or sell copies of the Software, and to
* permit persons to whom the Software is furnished to do so, subject to		* permit persons to whom the Software is furnished to do so, subject to
* the following conditions:		* the following conditions:
Show All 18 Lines
#ifndef INCLUDED_IO		#ifndef INCLUDED_IO
#define INCLUDED_IO		#define INCLUDED_IO

#include "lib/config2.h"		#include "lib/config2.h"
#include "lib/alignment.h"		#include "lib/alignment.h"
#include "lib/bits.h"		#include "lib/bits.h"
#include "lib/timer.h"		#include "lib/timer.h"
#include "lib/file/file.h"		#include "lib/file/file.h"
		#include "lib/sysdep/rtl.h"
#include "lib/sysdep/filesystem.h" // wtruncate		#include "lib/sysdep/filesystem.h" // wtruncate
#include "lib/posix/posix_aio.h" // LIO_READ, LIO_WRITE		#include "lib/posix/posix_aio.h" // LIO_READ, LIO_WRITE

#include "lib/allocators/unique_range.h"

namespace ERR		namespace ERR
{		{
const Status IO = -110301;		const Status IO = -110301;
}		}

namespace io {		namespace io {

		struct FreeAligned
		{
		void operator()(void* pointer) { rtl_FreeAligned(pointer); }
		};

		using BufferPtr = std::unique_ptr<u8, FreeAligned>;

// @return memory suitable for use as an I/O buffer (address is a		// @return memory suitable for use as an I/O buffer (address is a
// multiple of alignment, size is rounded up to a multiple of alignment)		// multiple of alignment, size is rounded up to a multiple of alignment)
// @param alignment is automatically increased if smaller than the		// @param alignment is automatically increased if required.
// UniqueRange requirement.
//		//
// use this instead of the file cache for write buffers that are		// use this instead of the file cache for write buffers that are
// never reused (avoids displacing other items).		// never reused (avoids displacing other items).
static inline UniqueRange Allocate(size_t size, size_t alignment = maxSectorSize)		static inline io::BufferPtr Allocate(size_t size, size_t alignment = maxSectorSize)
{		{
return AllocateAligned(size, alignment);		ENSURE(is_pow2(alignment));
		alignment = std::max(alignment, allocationAlignment);

		u8* p = static_cast<u8*>(rtl_AllocateAligned(round_up(size, alignment), alignment));

		return {p, FreeAligned{}};
}		}


#pragma pack(push, 1)		#pragma pack(push, 1)

// required information for any I/O (this is basically the same as aiocb,		// required information for any I/O (this is basically the same as aiocb,
// but also applies to synchronous I/O and has shorter/nicer names.)		// but also applies to synchronous I/O and has shorter/nicer names.)
struct Operation		struct Operation
▲ Show 20 Lines • Show All 138 Lines • ▼ Show 20 Lines	public:
}		}

INLINE aiocb& operator[](size_t counter)		INLINE aiocb& operator[](size_t counter)
{		{
return controlBlocks[counter % ARRAY_SIZE(controlBlocks)];		return controlBlocks[counter % ARRAY_SIZE(controlBlocks)];
}		}

private:		private:
UniqueRange buffers;		io::BufferPtr buffers;
aiocb controlBlocks[Parameters::maxQueueDepth];		aiocb controlBlocks[Parameters::maxQueueDepth];
};		};

#pragma pack(pop)		#pragma pack(pop)


LIB_API Status Issue(aiocb& cb, size_t queueDepth);		LIB_API Status Issue(aiocb& cb, size_t queueDepth);
LIB_API Status WaitUntilComplete(aiocb& cb, size_t queueDepth);		LIB_API Status WaitUntilComplete(aiocb& cb, size_t queueDepth);
▲ Show 20 Lines • Show All 141 Lines • Show Last 20 Lines