%% options copyright owner = Dirk Krause copyright year = 2015-xxxx license = bsd %% header /** @file Generic dk4_stream_t API for input from Windows file handle. */ #ifndef DK4CONF_H_INCLUDED #include "dk4conf.h" #endif #if DK4_ON_WINDOWS #ifndef DK4TYPES_H_INCLUDED #include "dk4types.h" #endif #ifndef WINDOWS_H_INCLUDED #include #define WINDOWS_H_INCLUDED 1 #endif #ifndef DK4ERROR_H_INCLUDED #include "dk4error.h" #endif #ifndef DK4STRM_H_INCLUDED #include "dk4strm.h" #endif #ifndef STDIO_H_INCLUDED #include #define STDIO_H_INCLUDED 1 #endif /** Structure for keeping a HANDLE. */ typedef struct { HANDLE ha; /**< Windows file handle. */ int feof; /**< Flag: Found EOF while reading. */ } dk4_stream_handle_t; #ifdef __cplusplus extern "C" { #endif /** Low level function to access a Windows handle. @param api The stream API structure for arguments and results. */ void dk4stream_windows_handle_function(dk4_stream_api_t *api); /** Low level function to access a Windows handle and close it on dk4stream_close(). @param api The stream API structure for arguments and results. */ void dk4stream_windows_handle_with_close_function(dk4_stream_api_t *api); /** Open a stream for an existing handle. @param ha Existing file handle, not closed on dk4stream_close(). @param fl Access flag: DK4_STREAM_READ,, DK4_STREAM_WRITE or (DK4_STREAM_READ | DK4_STREAM_WRITE). @param ibs Input buffer size (0 for default). @param obs Output buffer size (0 for default). @param erp Error report, may be NULL. @return Pointer to new stream on success, NULL on error. */ dk4_stream_t * dk4stream_open_for_windows_handle( HANDLE ha, int fl, size_t ibs, size_t obs, dk4_er_t *erp ); /** Open a stream for an existing handle. @param ha Existing file handle, closed on dk4stream_close(). @param fl Access flag: DK4_STREAM_READ,, DK4_STREAM_WRITE or (DK4_STREAM_READ | DK4_STREAM_WRITE). @param ibs Input buffer size (0 for default). @param obs Output buffer size (0 for default). @param erp Error report, may be NULL. @return Pointer to new stream on success, NULL on error. */ dk4_stream_t * dk4stream_open_for_windows_handle_with_close( HANDLE ha, int fl, size_t ibs, size_t obs, dk4_er_t *erp ); #ifdef __cplusplus } #endif #endif %% module #include "dk4conf.h" #if DK4_ON_WINDOWS #include "dk4strmh.h" #ifndef DK4MEM_H_INCLUDED #include "dk4mem.h" #endif /** Low level function to access a Windows handle. @param api The stream API structure for arguments and results. @param wc Flag: Close handle when closing the stream. */ static void dk4stream_windows_handle_static_function(dk4_stream_api_t *api, int wc) { dk4_stream_handle_t *sh; DWORD dwi; DWORD dwo; if (NULL != api) { api->res = 0; api->sz_out = 0; sh = (dk4_stream_handle_t *)(api->d); if (NULL != sh) { switch (api->cmd) { case DK4_STREAM_API_READ : { if (0 == sh->feof) { if ((dk4_um_t)0xFFFFFFFFUL < (dk4_um_t)(api->sz_in)) { dwi = 0xFFFFFFFFUL; } else { dwi = (DWORD)(api->sz_in); } dwo = (DWORD)0UL; if (ReadFile(sh->ha, api->b, dwi, &dwo, NULL)) { if ((DWORD)0UL == dwo) { sh->feof = 1; } api->sz_out = (size_t)dwo; if ((DWORD)0UL < dwo) { api->res = 1; } } } } break; case DK4_STREAM_API_WRITE : { if ((dk4_um_t)0xFFFFFFFFUL >= (dk4_um_t)(api->sz_in)) { dwi = (DWORD)(api->sz_in); dwo = (DWORD)0UL; if (WriteFile(sh->ha, api->b, dwi, &dwo, NULL)) { api->sz_out = dwo; if (dwo == dwi) { api->res = 1; } } } else { /* ERROR: Size too large */ } } break; case DK4_STREAM_API_FLUSH : { api->res = 1; /* Dont know how to flush */ } break; case DK4_STREAM_API_AT_END : { if (0 != sh->feof) { api->res = 1; } } break; case DK4_STREAM_API_CLOSE : { if (0 != wc) { if (CloseHandle(sh->ha)) { api->res = 1; } } else { api->res = 1; } dk4mem_free(sh); } break; } } } } void dk4stream_windows_handle_with_close_function(dk4_stream_api_t *api) { dk4stream_windows_handle_static_function(api, 1); } void dk4stream_windows_handle_function(dk4_stream_api_t *api) { dk4stream_windows_handle_static_function(api, 0); } dk4_stream_t * dk4stream_open_for_windows_handle( HANDLE ha, int fl, size_t ibs, size_t obs, dk4_er_t *erp ) { dk4_stream_handle_t *sh = NULL; dk4_stream_t *back = NULL; sh = dk4mem_new(dk4_stream_handle_t,1,erp); if (NULL != sh) { sh->ha = ha; sh->feof = 0; back = dk4stream_open( (void *)sh, dk4stream_windows_handle_function, fl, ibs, obs, erp ); if (NULL == back) { dk4mem_free(sh); } } return back; } dk4_stream_t * dk4stream_open_for_windows_handle_with_close( HANDLE ha, int fl, size_t ibs, size_t obs, dk4_er_t *erp ) { dk4_stream_handle_t *sh = NULL; dk4_stream_t *back = NULL; sh = dk4mem_new(dk4_stream_handle_t,1,erp); if (NULL != sh) { sh->ha = ha; sh->feof = 0; back = dk4stream_open( (void *)sh, dk4stream_windows_handle_with_close_function, fl, ibs, obs, erp ); if (NULL == back) { dk4mem_free(sh); } } return back; } #endif /* if DK4_ON_WINDOWS */