Merge pull request #9046 from Robyt3/Base-IO-Functions-Documentation-Order

Minor improvement of I/O functions documentation, consistently order I/O functions declarations and definitions
This commit is contained in:
Dennis Felsing 2024-09-27 10:52:16 +00:00 committed by GitHub
commit 2f72eede2b
No known key found for this signature in database
GPG key ID: B5690EEEBB952194
3 changed files with 183 additions and 135 deletions

View file

@ -84,58 +84,6 @@
#include <sys/filio.h> #include <sys/filio.h>
#endif #endif
IOHANDLE io_stdin()
{
return stdin;
}
IOHANDLE io_stdout()
{
return stdout;
}
IOHANDLE io_stderr()
{
return stderr;
}
IOHANDLE io_current_exe()
{
// From https://stackoverflow.com/a/1024937.
#if defined(CONF_FAMILY_WINDOWS)
wchar_t wide_path[IO_MAX_PATH_LENGTH];
if(GetModuleFileNameW(NULL, wide_path, std::size(wide_path)) == 0 || GetLastError() != ERROR_SUCCESS)
{
return 0;
}
const std::optional<std::string> path = windows_wide_to_utf8(wide_path);
return path.has_value() ? io_open(path.value().c_str(), IOFLAG_READ) : 0;
#elif defined(CONF_PLATFORM_MACOS)
char path[IO_MAX_PATH_LENGTH];
uint32_t path_size = sizeof(path);
if(_NSGetExecutablePath(path, &path_size))
{
return 0;
}
return io_open(path, IOFLAG_READ);
#else
static const char *NAMES[] = {
"/proc/self/exe", // Linux, Android
"/proc/curproc/exe", // NetBSD
"/proc/curproc/file", // DragonFly
};
for(auto &name : NAMES)
{
IOHANDLE result = io_open(name, IOFLAG_READ);
if(result)
{
return result;
}
}
return 0;
#endif
}
static NETSTATS network_stats = {0}; static NETSTATS network_stats = {0};
#define VLEN 128 #define VLEN 128
@ -403,11 +351,6 @@ long int io_length(IOHANDLE io)
return length; return length;
} }
int io_error(IOHANDLE io)
{
return ferror((FILE *)io);
}
unsigned io_write(IOHANDLE io, const void *buffer, unsigned size) unsigned io_write(IOHANDLE io, const void *buffer, unsigned size)
{ {
return fwrite(buffer, 1, size, (FILE *)io); return fwrite(buffer, 1, size, (FILE *)io);
@ -445,6 +388,63 @@ int io_sync(IOHANDLE io)
#endif #endif
} }
int io_error(IOHANDLE io)
{
return ferror((FILE *)io);
}
IOHANDLE io_stdin()
{
return stdin;
}
IOHANDLE io_stdout()
{
return stdout;
}
IOHANDLE io_stderr()
{
return stderr;
}
IOHANDLE io_current_exe()
{
// From https://stackoverflow.com/a/1024937.
#if defined(CONF_FAMILY_WINDOWS)
wchar_t wide_path[IO_MAX_PATH_LENGTH];
if(GetModuleFileNameW(NULL, wide_path, std::size(wide_path)) == 0 || GetLastError() != ERROR_SUCCESS)
{
return 0;
}
const std::optional<std::string> path = windows_wide_to_utf8(wide_path);
return path.has_value() ? io_open(path.value().c_str(), IOFLAG_READ) : 0;
#elif defined(CONF_PLATFORM_MACOS)
char path[IO_MAX_PATH_LENGTH];
uint32_t path_size = sizeof(path);
if(_NSGetExecutablePath(path, &path_size))
{
return 0;
}
return io_open(path, IOFLAG_READ);
#else
static const char *NAMES[] = {
"/proc/self/exe", // Linux, Android
"/proc/curproc/exe", // NetBSD
"/proc/curproc/file", // DragonFly
};
for(auto &name : NAMES)
{
IOHANDLE result = io_open(name, IOFLAG_READ);
if(result)
{
return result;
}
}
return 0;
#endif
}
#define ASYNC_BUFSIZE (8 * 1024) #define ASYNC_BUFSIZE (8 * 1024)
#define ASYNC_LOCAL_BUFSIZE (64 * 1024) #define ASYNC_LOCAL_BUFSIZE (64 * 1024)
@ -719,17 +719,6 @@ int aio_error(ASYNCIO *aio)
return aio->error; return aio->error;
} }
void aio_free(ASYNCIO *aio)
{
aio->lock.lock();
if(aio->thread)
{
thread_detach(aio->thread);
aio->thread = 0;
}
aio_handle_free_and_unlock(aio);
}
void aio_close(ASYNCIO *aio) void aio_close(ASYNCIO *aio)
{ {
{ {
@ -755,6 +744,17 @@ void aio_wait(ASYNCIO *aio)
thread_wait(thread); thread_wait(thread);
} }
void aio_free(ASYNCIO *aio)
{
aio->lock.lock();
if(aio->thread)
{
thread_detach(aio->thread);
aio->thread = 0;
}
aio_handle_free_and_unlock(aio);
}
struct THREAD_RUN struct THREAD_RUN
{ {
void (*threadfunc)(void *); void (*threadfunc)(void *);

View file

@ -219,12 +219,42 @@ bool mem_has_null(const void *block, size_t size);
*/ */
enum enum
{ {
/**
* Open file for reading.
*
* @see io_open
*/
IOFLAG_READ = 1, IOFLAG_READ = 1,
/**
* Open file for writing.
*
* @see io_open
*/
IOFLAG_WRITE = 2, IOFLAG_WRITE = 2,
/**
* Open file for appending at the end.
*
* @see io_open
*/
IOFLAG_APPEND = 4, IOFLAG_APPEND = 4,
/**
* Start seeking from the beginning of the file.
*
* @see io_seek
*/
IOSEEK_START = 0, IOSEEK_START = 0,
/**
* Start seeking from the current position.
*
* @see io_seek
*/
IOSEEK_CUR = 1, IOSEEK_CUR = 1,
/**
* Start seeking from the end of the file.
*
* @see io_seek
*/
IOSEEK_END = 2, IOSEEK_END = 2,
}; };
@ -236,10 +266,9 @@ enum
* @param File to open. * @param File to open.
* @param flags A set of IOFLAG flags. * @param flags A set of IOFLAG flags.
* *
* @sa IOFLAG_READ, IOFLAG_WRITE, IOFLAG_APPEND. * @see IOFLAG_READ, IOFLAG_WRITE, IOFLAG_APPEND.
*
* @return A handle to the file on success and 0 on failure.
* *
* @return A handle to the file on success, or `nullptr` on failure.
*/ */
IOHANDLE io_open(const char *filename, int flags); IOHANDLE io_open(const char *filename, int flags);
@ -253,7 +282,6 @@ IOHANDLE io_open(const char *filename, int flags);
* @param size Number of bytes to read from the file. * @param size Number of bytes to read from the file.
* *
* @return Number of bytes read. * @return Number of bytes read.
*
*/ */
unsigned io_read(IOHANDLE io, void *buffer, unsigned size); unsigned io_read(IOHANDLE io, void *buffer, unsigned size);
@ -279,7 +307,7 @@ void io_read_all(IOHANDLE io, void **result, unsigned *result_len);
* *
* @param io Handle to the file to read data from. * @param io Handle to the file to read data from.
* *
* @return The file's remaining contents or null on failure. * @return The file's remaining contents, or `nullptr` on failure.
* *
* @remark Guarantees that there are no internal null bytes. * @remark Guarantees that there are no internal null bytes.
* @remark Guarantees that result will contain zero-termination. * @remark Guarantees that result will contain zero-termination.
@ -300,7 +328,42 @@ char *io_read_all_str(IOHANDLE io);
int io_skip(IOHANDLE io, int size); int io_skip(IOHANDLE io, int size);
/** /**
* Writes data from a buffer to file. * Seeks to a specified offset in the file.
*
* @ingroup File-IO
*
* @param io Handle to the file.
* @param offset Offset from position to search.
* @param origin Position to start searching from.
*
* @return `0` on success.
*/
int io_seek(IOHANDLE io, int offset, int origin);
/**
* Gets the current position in the file.
*
* @ingroup File-IO
*
* @param io Handle to the file.
*
* @return The current position, or `-1` on failure.
*/
long int io_tell(IOHANDLE io);
/**
* Gets the total length of the file. Resets cursor to the beginning.
*
* @ingroup File-IO
*
* @param io Handle to the file.
*
* @return The total size, or `-1` on failure.
*/
long int io_length(IOHANDLE io);
/**
* Writes data from a buffer to a file.
* *
* @ingroup File-IO * @ingroup File-IO
* *
@ -313,51 +376,16 @@ int io_skip(IOHANDLE io, int size);
unsigned io_write(IOHANDLE io, const void *buffer, unsigned size); unsigned io_write(IOHANDLE io, const void *buffer, unsigned size);
/** /**
* Writes a platform dependent newline to file. * Writes a platform dependent newline to a file.
* *
* @ingroup File-IO * @ingroup File-IO
* *
* @param io Handle to the file. * @param io Handle to the file.
* *
* @return true on success, false on failure. * @return `true` on success, `false` on failure.
*/ */
bool io_write_newline(IOHANDLE io); bool io_write_newline(IOHANDLE io);
/**
* Seeks to a specified offset in the file.
*
* @ingroup File-IO
*
* @param io Handle to the file.
* @param offset Offset from pos to stop.
* @param origin Position to start searching from.
*
* @return 0 on success.
*/
int io_seek(IOHANDLE io, int offset, int origin);
/**
* Gets the current position in the file.
*
* @ingroup File-IO
*
* @param io Handle to the file.
*
* @return The current position. @c -1L if an error occurred.
*/
long int io_tell(IOHANDLE io);
/**
* Gets the total length of the file. Resetting cursor to the beginning
*
* @ingroup File-IO
*
* @param io Handle to the file.
*
* @return The total size. @c -1L if an error occurred.
*/
long int io_length(IOHANDLE io);
/** /**
* Closes a file. * Closes a file.
* *
@ -365,7 +393,7 @@ long int io_length(IOHANDLE io);
* *
* @param io Handle to the file. * @param io Handle to the file.
* *
* @return 0 on success. * @return `0` on success.
*/ */
int io_close(IOHANDLE io); int io_close(IOHANDLE io);
@ -376,7 +404,7 @@ int io_close(IOHANDLE io);
* *
* @param io Handle to the file. * @param io Handle to the file.
* *
* @return 0 on success. * @return `0` on success.
*/ */
int io_flush(IOHANDLE io); int io_flush(IOHANDLE io);
@ -387,7 +415,7 @@ int io_flush(IOHANDLE io);
* *
* @param io Handle to the file. * @param io Handle to the file.
* *
* @return 0 on success. * @return `0` on success.
*/ */
int io_sync(IOHANDLE io); int io_sync(IOHANDLE io);
@ -398,34 +426,57 @@ int io_sync(IOHANDLE io);
* *
* @param io Handle to the file. * @param io Handle to the file.
* *
* @return nonzero on error, 0 otherwise. * @return `0` on success, or non-`0` on error.
*/ */
int io_error(IOHANDLE io); int io_error(IOHANDLE io);
/** /**
* @ingroup File-IO * @ingroup File-IO
* @return An <IOHANDLE> to the standard input. *
* Returns a handle for the standard input.
*
* @return An @link IOHANDLE @endlink for the standard input.
*
* @remark The handle must not be closed.
*/ */
IOHANDLE io_stdin(); IOHANDLE io_stdin();
/** /**
* @ingroup File-IO * @ingroup File-IO
* @return An <IOHANDLE> to the standard output. *
* Returns a handle for the standard output.
*
* @return An @link IOHANDLE @endlink for the standard output.
*
* @remark The handle must not be closed.
*/ */
IOHANDLE io_stdout(); IOHANDLE io_stdout();
/** /**
* @ingroup File-IO * @ingroup File-IO
* @return An <IOHANDLE> to the standard error. *
* Returns a handle for the standard error.
*
* @return An @link IOHANDLE @endlink for the standard error.
*
* @remark The handle must not be closed.
*/ */
IOHANDLE io_stderr(); IOHANDLE io_stderr();
/** /**
* @ingroup File-IO * @ingroup File-IO
* @return An <IOHANDLE> to the current executable. *
* Returns a handle for the current executable.
*
* @return An @link IOHANDLE @endlink for the current executable.
*/ */
IOHANDLE io_current_exe(); IOHANDLE io_current_exe();
/**
* Wrapper for asynchronously writing to an @link IOHANDLE @endlink.
*
* @ingroup File-IO
*/
typedef struct ASYNCIO ASYNCIO; typedef struct ASYNCIO ASYNCIO;
/** /**
@ -436,12 +487,11 @@ typedef struct ASYNCIO ASYNCIO;
* @param io Handle to the file. * @param io Handle to the file.
* *
* @return The handle for asynchronous writing. * @return The handle for asynchronous writing.
*
*/ */
ASYNCIO *aio_new(IOHANDLE io); ASYNCIO *aio_new(IOHANDLE io);
/** /**
* Locks the ASYNCIO structure so it can't be written into by * Locks the `ASYNCIO` structure so it can't be written into by
* other threads. * other threads.
* *
* @ingroup File-IO * @ingroup File-IO
@ -451,7 +501,7 @@ ASYNCIO *aio_new(IOHANDLE io);
void aio_lock(ASYNCIO *aio); void aio_lock(ASYNCIO *aio);
/** /**
* Unlocks the ASYNCIO structure after finishing the contiguous * Unlocks the `ASYNCIO` structure after finishing the contiguous
* write. * write.
* *
* @ingroup File-IO * @ingroup File-IO
@ -477,12 +527,11 @@ void aio_write(ASYNCIO *aio, const void *buffer, unsigned size);
* @ingroup File-IO * @ingroup File-IO
* *
* @param aio Handle to the file. * @param aio Handle to the file.
*
*/ */
void aio_write_newline(ASYNCIO *aio); void aio_write_newline(ASYNCIO *aio);
/** /**
* Queues a chunk of data for writing. The ASYNCIO struct must be * Queues a chunk of data for writing. The `ASYNCIO` struct must be
* locked using @link aio_lock @endlink first. * locked using @link aio_lock @endlink first.
* *
* @ingroup File-IO * @ingroup File-IO
@ -490,18 +539,16 @@ void aio_write_newline(ASYNCIO *aio);
* @param aio Handle to the file. * @param aio Handle to the file.
* @param buffer Pointer to the data that should be written. * @param buffer Pointer to the data that should be written.
* @param size Number of bytes to write. * @param size Number of bytes to write.
*
*/ */
void aio_write_unlocked(ASYNCIO *aio, const void *buffer, unsigned size); void aio_write_unlocked(ASYNCIO *aio, const void *buffer, unsigned size);
/** /**
* Queues a newline for writing. The ASYNCIO struct must be locked * Queues a newline for writing. The `ASYNCIO` struct must be locked
* using @link aio_lock @endlink first. * using @link aio_lock @endlink first.
* *
* @ingroup File-IO * @ingroup File-IO
* *
* @param aio Handle to the file. * @param aio Handle to the file.
*
*/ */
void aio_write_newline_unlocked(ASYNCIO *aio); void aio_write_newline_unlocked(ASYNCIO *aio);
@ -509,16 +556,15 @@ void aio_write_newline_unlocked(ASYNCIO *aio);
* Checks whether errors have occurred during the asynchronous * Checks whether errors have occurred during the asynchronous
* writing. * writing.
* *
* Call this function regularly to see if there are errors. Call * Call this function regularly to see if there are errors. Call this
* this function after <aio_wait> to see if the process of writing * function after @link aio_wait @endlink to see if the process of writing
* to the file succeeded. * to the file succeeded.
* *
* @ingroup File-IO * @ingroup File-IO
* *
* @param aio Handle to the file. * @param aio Handle to the file.
* *
* @eturn 0 if no error occurred, and nonzero on error. * @return `0` on success, or non-`0` on error.
*
*/ */
int aio_error(ASYNCIO *aio); int aio_error(ASYNCIO *aio);
@ -528,7 +574,6 @@ int aio_error(ASYNCIO *aio);
* @ingroup File-IO * @ingroup File-IO
* *
* @param aio Handle to the file. * @param aio Handle to the file.
*
*/ */
void aio_close(ASYNCIO *aio); void aio_close(ASYNCIO *aio);
@ -538,17 +583,15 @@ void aio_close(ASYNCIO *aio);
* @ingroup File-IO * @ingroup File-IO
* *
* @param aio Handle to the file. * @param aio Handle to the file.
*
*/ */
void aio_wait(ASYNCIO *aio); void aio_wait(ASYNCIO *aio);
/** /**
* Frees the resources associated to the asynchronous file handle. * Frees the resources associated with the asynchronous file handle.
* *
* @ingroup File-IO * @ingroup File-IO
* *
* @param aio Handle to the file. * @param aio Handle to the file.
*
*/ */
void aio_free(ASYNCIO *aio); void aio_free(ASYNCIO *aio);

View file

@ -10,6 +10,11 @@ enum class TRISTATE
ALL, ALL,
}; };
/**
* Handle for input/output files/streams.
*
* @ingroup File-IO
*/
typedef void *IOHANDLE; typedef void *IOHANDLE;
typedef int (*FS_LISTDIR_CALLBACK)(const char *name, int is_dir, int dir_type, void *user); typedef int (*FS_LISTDIR_CALLBACK)(const char *name, int is_dir, int dir_type, void *user);