io.c File Reference

#include "vfatlib.h"
#include <debug.h>

Include dependency graph for io.c:

Go to the source code of this file.

Classes
struct	_change

Macros
#define	NDEBUG
#define	FSCTL_IS_VOLUME_DIRTY   CTL_CODE(FILE_DEVICE_FILE_SYSTEM, 30, METHOD_BUFFERED, FILE_ANY_ACCESS)

Typedefs
typedef struct _change	CHANGE

Functions
void	fs_open (char *path, int rw)
void	fs_read (off_t pos, int size, void *data)
int	fs_test (off_t pos, int size)
void	fs_write (off_t pos, int size, void *data)
static void	fs_flush (void)
int	fs_close (int write)
int	fs_changed (void)

Variables
static CHANGE *	changes
static CHANGE *	last
static int	fd
static int	did_change = 0

Macro Definition Documentation

FSCTL_IS_VOLUME_DIRTY

#define FSCTL_IS_VOLUME_DIRTY   CTL_CODE(FILE_DEVICE_FILE_SYSTEM, 30, METHOD_BUFFERED, FILE_ANY_ACCESS)

Definition at line 40 of file io.c.

NDEBUG

#define NDEBUG

Definition at line 36 of file io.c.

Typedef Documentation

CHANGE

typedef struct _change CHANGE

Function Documentation

fs_changed()

int fs_changed

(

void

)

Definition at line 475 of file io.c.

{
    return ! !changes || did_change;
}

Referenced by VfatChkdsk().

fs_close()

int fs_close

(

int

write

)

Definition at line 455 of file io.c.

{
    CHANGE *next;
    int changed;
 
    changed = ! !changes;
    if (write)
    fs_flush();
    else
    while (changes) {
        next = changes->next;
        free(changes->data);
        free(changes);
        changes = next;
    }
    if (close(fd) < 0)
    pdie("closing filesystem");
    return changed || did_change;
}

fs_flush()

static void fs_flush ( void  )

static

Definition at line 409 of file io.c.

{
#ifdef __REACTOS__
 
    CHANGE *this;
    int old_write_immed = (FsCheckFlags & FSCHECK_IMMEDIATE_WRITE);
 
    /* Disable writes to the list now */
    FsCheckFlags |= FSCHECK_IMMEDIATE_WRITE;
 
    while (changes) {
    this = changes;
    changes = changes->next;
 
    fs_write(this->pos, this->size, this->data);
 
    free(this->data);
    free(this);
    }
 
    /* Restore values */
    if (!old_write_immed) FsCheckFlags ^= FSCHECK_IMMEDIATE_WRITE;
 
#else
    CHANGE *this;
    int size;
 
    while (changes) {
    this = changes;
    changes = changes->next;
    if (lseek(fd, this->pos, 0) != this->pos)
        fprintf(stderr,
            "Seek to %lld failed: %s\n  Did not write %d bytes.\n",
            (long long)this->pos, strerror(errno), this->size);
    else if ((size = write(fd, this->data, this->size)) < 0)
        fprintf(stderr, "Writing %d bytes at %lld failed: %s\n", this->size,
            (long long)this->pos, strerror(errno));
    else if (size != this->size)
        fprintf(stderr, "Wrote %d bytes instead of %d bytes at %lld."
            "\n", size, this->size, (long long)this->pos);
    free(this->data);
    free(this);
    }
#endif
}

Referenced by fs_close().

fs_open()

void fs_open	(	char *	path,
		int	rw
	)

Definition at line 163 of file io.c.

{
    if ((fd = open(path, rw ? O_RDWR : O_RDONLY)) < 0) {
    perror("open");
    exit(6);
    }
    changes = last = NULL;
    did_change = 0;
}

fs_read()

void fs_read	(	off_t	pos,
		int	size,
		void *	data
	)

Read data from the partition, accounting for any pending updates that are queued for writing.

Parameters

[in]	pos	Byte offset, relative to the beginning of the partition, at which to read
[in]	size	Number of bytes to read
[out]	data	Where to put the data read

Definition at line 282 of file io.c.

{
    CHANGE *walk;
    int got;
 
#ifdef __REACTOS__
    const size_t readsize_aligned = (size % 512) ? (size + (512 - (size % 512))) : size;
    const off_t seekpos_aligned = pos - (pos % 512);
    const size_t seek_delta = (size_t)(pos - seekpos_aligned);
#if DBG
    const size_t readsize = (size_t)(pos - seekpos_aligned) + readsize_aligned;
#endif
    char* tmpBuf = alloc(readsize_aligned);
    if (lseek(fd, seekpos_aligned, 0) != seekpos_aligned) pdie("Seek to %lld",pos);
    if ((got = read(fd, tmpBuf, readsize_aligned)) < 0) pdie("Read %d bytes at %lld",size,pos);
    assert(got >= size);
    got = size;
    assert(seek_delta + size <= readsize);
    memcpy(data, tmpBuf+seek_delta, size);
    free(tmpBuf);
#else
    if (lseek(fd, pos, 0) != pos)
    pdie("Seek to %lld", (long long)pos);
    if ((got = read(fd, data, size)) < 0)
    pdie("Read %d bytes at %lld", size, (long long)pos);
#endif
    if (got != size)
    die("Got %d bytes instead of %d at %lld", got, size, (long long)pos);
    for (walk = changes; walk; walk = walk->next) {
    if (walk->pos < pos + size && walk->pos + walk->size > pos) {
        if (walk->pos < pos)
        memcpy(data, (char *)walk->data + pos - walk->pos,
               min(size, walk->size - pos + walk->pos));
        else
        memcpy((char *)data + walk->pos - pos, walk->data,
               min(walk->size, size + pos - walk->pos));
    }
    }
}

Referenced by add_file(), alloc_rootdir_entry(), check_backup_boot(), find_volume_de(), read_boot(), read_fat(), read_fsinfo(), and write_boot_label().

fs_test()

int fs_test	(	off_t	pos,
		int	size
	)

Definition at line 322 of file io.c.

{
    void *scratch;
    int okay;
 
#ifdef __REACTOS__
    const size_t readsize_aligned = (size % 512) ? (size + (512 - (size % 512))) : size;        // TMN:
    const off_t seekpos_aligned = pos - (pos % 512);                   // TMN:
    scratch = alloc(readsize_aligned);
    if (lseek(fd, seekpos_aligned, 0) != seekpos_aligned) pdie("Seek to %lld",pos);
    okay = read(fd, scratch, readsize_aligned) == (int)readsize_aligned;
    free(scratch);
#else
    if (lseek(fd, pos, 0) != pos)
    pdie("Seek to %lld", (long long)pos);
    scratch = alloc(size);
    okay = read(fd, scratch, size) == size;
    free(scratch);
#endif
    return okay;
}

Referenced by fix_bad(), read_boot(), and test_file().

fs_write()

void fs_write	(	off_t	pos,
		int	size,
		void *	data
	)

Definition at line 344 of file io.c.

{
    CHANGE *new;
    int did;
 
#ifdef __REACTOS__
    assert(interactive || rw);
 
    if (FsCheckFlags & FSCHECK_IMMEDIATE_WRITE) {
        void *scratch;
        const size_t readsize_aligned = (size % 512) ? (size + (512 - (size % 512))) : size;
        const off_t seekpos_aligned = pos - (pos % 512);
        const size_t seek_delta = (size_t)(pos - seekpos_aligned);
        BOOLEAN use_read = (seek_delta != 0) || ((readsize_aligned-size) != 0);
 
        /* Aloc temp buffer if write is not aligned */
        if (use_read)
            scratch = alloc(readsize_aligned);
        else
            scratch = data;
 
        did_change = 1;
        if (lseek(fd, seekpos_aligned, 0) != seekpos_aligned) pdie("Seek to %lld",seekpos_aligned);
 
        if (use_read)
        {
            /* Read aligned data */
            if (read(fd, scratch, readsize_aligned) < 0) pdie("Read %d bytes at %lld",size,pos);
 
            /* Patch data in memory */
            memcpy((char *)scratch + seek_delta, data, size);
        }
 
        /* Write it back */
        if ((did = write(fd, scratch, readsize_aligned)) == (int)readsize_aligned)
        {
            if (use_read) free(scratch);
            return;
        }
        if (did < 0) pdie("Write %d bytes at %lld", size, pos);
        die("Wrote %d bytes instead of %d at %lld", did, size, pos);
    }
#else
    if (write_immed) {
    did_change = 1;
    if (lseek(fd, pos, 0) != pos)
        pdie("Seek to %lld", (long long)pos);
    if ((did = write(fd, data, size)) == size)
        return;
    if (did < 0)
        pdie("Write %d bytes at %lld", size, (long long)pos);
    die("Wrote %d bytes instead of %d at %lld", did, size, (long long)pos);
    }
#endif
    new = alloc(sizeof(CHANGE));
    new->pos = pos;
    memcpy(new->data = alloc(new->size = size), data, size);
    new->next = NULL;
    if (last)
    last->next = new;
    else
    changes = new;
    last = new;
}

Referenced by add_file(), alloc_rootdir_entry(), auto_rename(), check_backup_boot(), check_fat_state_bit(), clear_lfn_slots(), fs_flush(), lfn_add_slot(), lfn_fix_checksum(), lfn_get(), lfn_remove(), read_fat(), read_fsinfo(), reclaim_file(), rename_file(), set_fat(), update_free(), write_boot_label(), and write_volume_label().

Variable Documentation

changes

CHANGE* changes

static

Definition at line 49 of file io.c.

Referenced by fs_changed(), fs_close(), fs_flush(), fs_open(), fs_read(), fs_write(), ME_HandleMessage(), NotifyInfo::modify(), and NotifyArea::ProcessTrayNotification().

did_change

int did_change = 0

static

Definition at line 51 of file io.c.

Referenced by fs_changed(), fs_close(), fs_open(), and fs_write().

fd

int fd

static

Definition at line 51 of file io.c.

Referenced by __file_size(), __is_regular_file(), __rpc_fd2sockinfo(), __rpc_nconf2fd(), __rpc_sockisbound(), __rpcgettp(), _chsize(), _chsize_s(), _close(), _commit(), _dup(), _eof(), _fcons(), _fdopen(), _filelength(), _filelengthi64(), _fstat(), _fstat64(), _fstati64(), _futime(), _get_osfhandle(), _isatty(), _locking(), _lseek(), _lseeki64(), LocaleTest::_money_put_X_bug(), _open_osfhandle(), _pipe(), _read(), _RunRemoteTest(), _setmode(), _sopen(), _sopen_s(), _tell(), _telli64(), _tiffCloseProc(), _tiffDummyMapProc(), _tiffDummyUnmapProc(), _tiffisCloseProc(), _tiffisReadProc(), _tiffisSeekProc(), _tiffisSizeProc(), _tiffMapProc(), _tiffosCloseProc(), _tiffosSeekProc(), _tiffosSizeProc(), _tiffosWriteProc(), _TIFFPrettyPrintField(), _TIFFprintAscii(), _TIFFprintAsciiBounded(), _TIFFprintAsciiTag(), _TIFFPrintField(), _TIFFPrintFieldInfo(), _tiffReadProc(), _tiffSeekProc(), _tiffSizeProc(), _tiffStreamOpen(), _tiffUnmapProc(), _tiffWriteProc(), _tutime(), _wfdopen(), _wfreopen(), _wfsopen(), _write(), _wsopen(), _wsopen_s(), add_protocol(), AddWallpapersFromDirectory(), adns__fdevents(), adns__setnonblock(), adns__tcp_tryconnect(), adns_beforeselect(), adns_processexceptional(), adns_processreadable(), adns_processwriteable(), aexpand(), alloc_pioinfo_block(), cff_fd_select_get(), check_for_files(), clnt_dg_create(), clnt_tli_create(), clnt_vc_create(), codeview_snarf_linetab2(), compat_fdopen(), Control_DoWindow(), count_blocks(), create_io_inherit_block(), CRTDLL__fstat(), do_searchW(), DriverEnumProc(), epoll_ctl(), exists_path(), fallback_lseek(), fallback_read(), fd_event(), ffileread(), file_get_Size(), FileSize(), flush_output_buffer(), flush_output_resources(), FormatTagEnumProc(), fs_close(), fs_flush(), fs_open(), fs_read(), fs_test(), fs_write(), FsVolumeInfo(), FTPGetOneF(), FTPPutOneF(), ftruncate_growable(), generate_random(), get_ioinfo(), get_ioinfo_alloc(), get_ioinfo_alloc_fd(), get_ioinfo_nolock(), GetExpandedNameA(), getkeyserv_handle(), getnetid(), CWineTest::GetNextFile(), getpublicandprivatekey(), GetSocketLinger(), GetSocketNagleAlgorithm(), gz_open(), gzdopen(), ICreateTypeInfo2_fnAddFuncDesc(), import_certs_from_file(), import_certs_from_path(), init_logger_addr(), InitSReadlineInfo(), install_from_unix_file(), InternetCheckConnectionW(), InternetFindNextFileA(), llseek(), load_licence(), local_rpcb(), LZClose(), LZOpenFileA(), LZRead(), LZSeek(), main(), makefd_xprt(), mkstemps(), mpg123_open_fd(), msft_read_guid(), msvcrt_alloc_fd(), msvcrt_free_fd(), msvcrt_init_fp(), NetBTAstatRemote(), NetBTCall(), NetBTInternalFindName(), NetBTNameWaitLoop(), NetBTSendNameQuery(), NetBTSessionReq(), NetBTWaitForNameResponse(), nonblock(), OleCreateFontIndirect(), open_stream(), open_typelib(), parseAndPrintFile(), poll_isset(), posix_lseek(), posix_read(), PredictorPrintDir(), printercache_load_blob(), printercache_save_blob(), pstcache_enumerate(), pstcache_init(), pstcache_load_bitmap(), pstcache_save_bitmap(), pstcache_touch_bitmap(), rd_close_file(), rd_lock_file(), rd_lseek_file(), rd_open_file(), rd_read_file(), rd_write_file(), rdpdr_abort_io(), read_header(), read_i(), read_importlib(), read_msft_importlib(), read_vc(), readblock(), rpc_broadcast_exp(), rpc_call(), run_ex(), run_open_osfhandle(), rw(), save_licence(), SearchScreenSavers(), SelectSetAdd(), SelectSetRemove(), setled(), SetSocketLinger(), SetSocketNagleAlgorithm(), sock_recv(), sock_send(), subprocess(), svc_dg_create(), svc_fd_create(), svc_getreq_common(), svc_getreqset(), svc_tli_create(), svc_vc_create(), test__creat(), test__open_osfhandle(), test_AddRefHfont(), test_bitmap_font_metrics(), test_chsize(), test_FDICopy(), test_FDIIsCabinet(), test_fdopen(), test_file_inherit(), test_file_inherit_child(), test_file_inherit_child_no(), test_fileops(), Test_FindFirstFileA(), Test_FindFirstFileExA(), Test_FindFirstFileExW(), Test_FindFirstFileW(), test_get_osfhandle(), test_height(), test_height_selection_vdmx(), test_ifont_size(), test_IsEqual(), test_MoveFileA(), test_overwrite(), test_persistent_state(), test_pipes_child(), test_readmode(), test_ReleaseHfont(), test_setmode(), test_stat(), test_stdin(), test_VarFormat(), test_write_flush_size(), TIFFClose(), TIFFErrorExt(), TIFFFdOpen(), TIFFOpen(), TIFFOpenW(), TIFFPrintDirectory(), TIFFSetFileno(), TIFFWarningExt(), tlb_lseek(), tlb_read(), tmpfile(), TruncBatchLog(), udf_lseek64(), unintr_read(), unintr_write(), valid_offset(), WaitForRemoteInput(), WaitForRemoteOutput(), WaitResponse(), wexpand(), wpp_default_lookup(), WriteTable(), xmlCtxtReadFd(), xmlReadFd(), and xsltSaveResultToFd().

last

CHANGE * last

static

Definition at line 49 of file io.c.

Referenced by fs_open(), and fs_write().