vblowlevel.c File Reference

#include "isinternal.h"

Include dependency graph for vblowlevel.c:

Go to the source code of this file.

Macros
#define	USE_LOCKFILE_EX

Functions
int	ivbopen (const char *pcfilename, const int iflags, const mode_t tmode)
int	ivbclose (const int ihandle)
off_t	tvblseek (const int ihandle, off_t toffset, const int iwhence)
ssize_t	tvbread (const int ihandle, void *pvbuffer, const size_t tcount)
ssize_t	tvbwrite (const int ihandle, const void *pvbuffer, const size_t tcount)
int	ivbblockread (const int ihandle, const int iisindex, const off_t tblocknumber, char *cbuffer)
int	ivbblockwrite (const int ihandle, const int iisindex, const off_t tblocknumber, const char *cbuffer)
int	ivblock (const int ihandle, const off_t toffset, const off_t tlength, const int imode)

Variables
struct DICTINFO *	psvbfile [128+1]
struct VBFILE	svbfile [128 *3]
static int	iinitialized = 0

Macro Definition Documentation

#define USE_LOCKFILE_EX

Definition at line 29 of file vblowlevel.c.

Function Documentation

int ivbblockread	(	const int	ihandle,
		const int	iisindex,
		const off_t	tblocknumber,
		char *	cbuffer
	)

Definition at line 137 of file vblowlevel.c.

References DICTINFO::idatahandle, DICTINFO::iindexhandle, DICTINFO::inodesize, tvblseek(), and tvbread().

Referenced by iaddkeydescriptor(), icheckkey(), icheckkeydesc(), idatafreecheck(), idelnodes(), iindexfreecheck(), iquicknodesave(), isopen(), ivbdatafree(), ivbdataread(), ivbdatawrite(), ivbenter(), ivbfileopenlock(), ivbforcedataallocate(), ivbnodefree(), ivbnodeload(), ivbvarlendelete(), ivbvarlenread(), tdelkeydescriptor(), ttailnode(), tvbdataallocate(), and tvbnodeallocate().

{
    struct DICTINFO *psvbptr;
    off_t       toffset;
    ssize_t     tresult;
    int     thandle;

    psvbptr = psvbfile[ihandle];
    toffset = (off_t) ((tblocknumber - 1) * psvbptr->inodesize);
    if (iisindex) {
        thandle = psvbptr->iindexhandle;
    } else {
        thandle = psvbptr->idatahandle;
    }
    if (tvblseek (thandle, toffset, SEEK_SET) != toffset) {
        return EIO;
    }

    tresult = tvbread (thandle, cbuffer, (size_t) psvbptr->inodesize);
    if (!iisindex && tresult == 0) {
        tresult = (ssize_t) psvbptr->inodesize;
        memset (cbuffer, 0, (size_t)psvbptr->inodesize);
    }
    if (tresult != (ssize_t)psvbptr->inodesize) {
        return EIO;
    }
    return 0;
}

Here is the call graph for this function:

Here is the caller graph for this function:

int ivbblockwrite	(	const int	ihandle,
		const int	iisindex,
		const off_t	tblocknumber,
		const char *	cbuffer
	)

Definition at line 167 of file vblowlevel.c.

References DICTINFO::idatahandle, DICTINFO::iindexhandle, DICTINFO::inodesize, tvblseek(), and tvbwrite().

Referenced by iaddkeydescriptor(), iindexcheck(), iquicknodesave(), isbuild(), ivbdatafree(), ivbdatawrite(), ivbexit(), ivbforcedataallocate(), ivbforceexit(), ivbnodefree(), ivbnodesave(), ivbvarlendelete(), ivbvarlenwrite(), tdelkeydescriptor(), ttailnode(), tvbdataallocate(), and tvbnodeallocate().

{
    struct DICTINFO *psvbptr;
    off_t       toffset;
    ssize_t     tresult;
    int     thandle;

    psvbptr = psvbfile[ihandle];
    toffset = (off_t) ((tblocknumber - 1) * psvbptr->inodesize);
    if (iisindex) {
        thandle = psvbptr->iindexhandle;
    } else {
        thandle = psvbptr->idatahandle;
    }
/* RXW
    tresult = tvblseek (thandle, toffset, SEEK_SET);
    if (tresult == (off_t) -1) {
*/
    if (tvblseek (thandle, toffset, SEEK_SET) != toffset) {
        return EIO;
    }

    tresult = tvbwrite (thandle, cbuffer, (size_t) psvbptr->inodesize);
    if (tresult != (ssize_t)psvbptr->inodesize) {
        return EIO;
    }
    return 0;
}

Here is the call graph for this function:

Here is the caller graph for this function:

int ivbclose

(

const int

ihandle

)

Definition at line 93 of file vblowlevel.c.

References VBFILE::irefcount, and svbfile.

Referenced by isbuild(), islogclose(), isopen(), and ivbclose2().

{
    if (!svbfile[ihandle].irefcount) {
        errno = ENOENT;
        return -1;
    }
    svbfile[ihandle].irefcount--;
    if (!svbfile[ihandle].irefcount) {
        return close (svbfile[ihandle].ihandle);
    }
    return 0;
}

Here is the caller graph for this function:

int ivblock	(	const int	ihandle,
		const off_t	toffset,
		const off_t	tlength,
		const int	imode
	)

Definition at line 197 of file vblowlevel.c.

References svbfile, VBRDLCKW, VBRDLOCK, VBUNLOCK, VBWRLCKW, and VBWRLOCK.

Referenced by ivbdatalock(), ivbenter(), ivbexit(), ivbfileopenlock(), and iwritetrans().

{
#ifdef  _WIN32
#ifdef  USE_LOCKFILE_EX

    OVERLAPPED  toverlapped;
    DWORD       tflags = 0;
    DWORD       winerrno = 0;
    int     bunlock = 0;

    if (!svbfile[ihandle].irefcount) {
        errno = ENOENT;
        return -1;
    }

    switch (imode) {
    case    VBUNLOCK:
        bunlock = 1;
        break;

    case    VBRDLOCK:
        tflags = LOCKFILE_FAIL_IMMEDIATELY;
        break;

    case    VBRDLCKW:
        tflags = 0;
        break;

    case    VBWRLOCK:
        tflags = LOCKFILE_EXCLUSIVE_LOCK | LOCKFILE_FAIL_IMMEDIATELY;
        break;

    case    VBWRLCKW:
        tflags = LOCKFILE_EXCLUSIVE_LOCK;
        break;

    default:
        errno = EBADARG;
        return -1;
    }

    memset (&toverlapped, 0, sizeof(OVERLAPPED));
    toverlapped.Offset = (DWORD)(toffset & 0xffffffff);
    toverlapped.OffsetHigh = (DWORD)(toffset >> 32);
    errno = 0;
    if (!bunlock) {
        if (LockFileEx (svbfile[ihandle].whandle, tflags, 0, (int)(tlength & 0xffffffff),
            (int)(tlength >> 32), &toverlapped)) {
            return 0;
        }
    } else {
        if (UnlockFileEx (svbfile[ihandle].whandle, 0, (int)(tlength & 0xffffffff),
            (int)(tlength >> 32), &toverlapped)) {
            return 0;
        }
        winerrno = GetLastError ();
        if (winerrno == ERROR_NOT_LOCKED) {
            //ALREADY UNLOCKED **SAME FCNTL**
            return 0;
        }
    }

    errno = EBADARG;
    return -1;
#else
/* This will probably not work correctly - 64 bit */
    int     itype, iresult = -1;
    off_t       soffset;
    off_t       tempoffset;

    if (!svbfile[ihandle].irefcount) {
        errno = ENOENT;
        return -1;
    }
    switch (imode) {
    case VBUNLOCK:
        itype = _LK_UNLCK;
        break;

    case VBRDLOCK:
        itype = _LK_NBRLCK;
        break;

    case VBRDLCKW:
        itype = _LK_RLCK;
        break;

    case VBWRLOCK:
        itype = _LK_NBLCK;
        break;

    case VBWRLCKW:
        itype = _LK_LOCK;
        break;

    default:
        errno = EBADARG;
        return -1;
    }
    soffset = lseek (svbfile[ihandle].ihandle, 0, SEEK_CUR);
    if (soffset == -1) {
        errno = 172;
        return -1;
    }
    tempoffset = lseek (svbfile[ihandle].ihandle, toffset, SEEK_SET);
    if (tempoffset == -1) {
        errno = 172;
        return -1;
    }
    errno = 0;
    iresult = _locking (svbfile[ihandle].ihandle, itype, (long)tlength);
    /* Something weird going on here */
    if (errno == 22) {
        errno = 0;
        iresult = 0;
    }
    lseek (svbfile[ihandle].ihandle, soffset, SEEK_SET);
    return iresult;
#endif
#else
    int     icommand, itype, iresult;
    struct flock    sflock;

    if (!svbfile[ihandle].irefcount) {
        errno = ENOENT;
        return -1;
    }
    switch (imode) {
    case VBUNLOCK:
        icommand = F_SETLK;
        itype = F_UNLCK;
        break;

    case VBRDLOCK:
        icommand = F_SETLK;
        itype = F_RDLCK;
        break;

    case VBRDLCKW:
        icommand = F_SETLKW;
        itype = F_RDLCK;
        break;

    case VBWRLOCK:
        icommand = F_SETLK;
        itype = F_WRLCK;
        break;

    case VBWRLCKW:
        icommand = F_SETLKW;
        itype = F_WRLCK;
        break;

    default:
        errno = EBADARG;
        return -1;
    }
    sflock.l_type = itype;
    sflock.l_whence = SEEK_SET;
    sflock.l_start = toffset;
    sflock.l_len = tlength;
    sflock.l_pid = 0;
    do {
        iresult = fcntl (svbfile[ihandle].ihandle, icommand, &sflock);
    } while (iresult && errno == EINTR);

    return iresult;
#endif
}

Here is the caller graph for this function:

int ivbopen	(	const char *	pcfilename,
		const int	iflags,
		const mode_t	tmode
	)

Definition at line 32 of file vblowlevel.c.

References VBFILE::ihandle, iinitialized, VBFILE::irefcount, O_BINARY, svbfile, VBFILE::tdevice, VBFILE::tinode, and VB_MAX_FILES.

Referenced by isbuild(), islogopen(), and isopen().

{
    int     iloop;
    struct stat sstat;

    if (!iinitialized) {
        memset ((void *)&svbfile[0], 0, sizeof (svbfile));
        iinitialized = 1;
    }
    if (stat (pcfilename, &sstat)) {
        if (!iflags & O_CREAT) {
            return -1;
        }
    } else {
        for (iloop = 0; iloop < VB_MAX_FILES * 3; iloop++) {
            if (svbfile[iloop].irefcount
                && svbfile[iloop].tdevice == sstat.st_dev
#ifdef  _WIN32
                && !strcmp(svbfile[iloop].cfilename, pcfilename)) {
#else
                && svbfile[iloop].tinode == sstat.st_ino) {
#endif
                svbfile[iloop].irefcount++;
                return iloop;
            }
        }
    }
    for (iloop = 0; iloop < VB_MAX_FILES * 3; iloop++) {
        if (svbfile[iloop].irefcount == 0) {
            svbfile[iloop].ihandle = open (pcfilename, iflags | O_BINARY, tmode);
            if (svbfile[iloop].ihandle == -1) {
                break;
            }
            if ((iflags & O_CREAT) && stat (pcfilename, &sstat)) {
                close (svbfile[iloop].ihandle);
                return -1;
            }
#ifdef  _WIN32
            svbfile[iloop].tinode = 0;
            if (svbfile[iloop].cfilename) {
                free (svbfile[iloop].cfilename);
            }
            svbfile[iloop].whandle = (HANDLE)_get_osfhandle (svbfile[iloop].ihandle);
            if (svbfile[iloop].whandle == INVALID_HANDLE_VALUE) {
                close (svbfile[iloop].ihandle);
                return -1;
            }
            svbfile[iloop].cfilename = strdup (pcfilename);
#else
            svbfile[iloop].tinode = sstat.st_ino;
#endif
            svbfile[iloop].tdevice = sstat.st_dev;
            svbfile[iloop].irefcount++;
            return iloop;
        }
    }
    errno = ENOENT;
    return -1;
}

Here is the caller graph for this function:

off_t tvblseek	(	const int	ihandle,
		off_t	toffset,
		const int	iwhence
	)

Definition at line 107 of file vblowlevel.c.

References svbfile, and unlikely.

Referenced by ircvchecktrans(), iscommit(), isrecover(), isrollback(), ivbblockread(), ivbblockwrite(), ivbdataread(), ivbdatawrite(), ivbrollmeback(), ivbrollmeforward(), and iwritetrans().

{
    if (unlikely(!svbfile[ihandle].irefcount)) {
        errno = ENOENT;
        return -1;
    }
    return lseek (svbfile[ihandle].ihandle, toffset, iwhence);
}

Here is the caller graph for this function:

ssize_t tvbread	(	const int	ihandle,
		void *	pvbuffer,
		const size_t	tcount
	)

Definition at line 117 of file vblowlevel.c.

References svbfile, and unlikely.

Referenced by ircvchecktrans(), isrecover(), ivbblockread(), ivbdataread(), ivbrollmeback(), and ivbrollmeforward().

{
    if (unlikely(!svbfile[ihandle].irefcount)) {
        errno = ENOENT;
        return -1;
    }
    return read (svbfile[ihandle].ihandle, pvbuffer, tcount);
}

Here is the caller graph for this function:

ssize_t tvbwrite	(	const int	ihandle,
		const void *	pvbuffer,
		const size_t	tcount
	)

Definition at line 127 of file vblowlevel.c.

References svbfile, and unlikely.

Referenced by ivbblockwrite(), ivbdatawrite(), and iwritetrans().

{
    if (unlikely(!svbfile[ihandle].irefcount)) {
        errno = ENOENT;
        return -1;
    }
    return write (svbfile[ihandle].ihandle, pvbuffer, tcount);
}

Here is the caller graph for this function:

Variable Documentation

int iinitialized = 0

static

Definition at line 26 of file vblowlevel.c.

Referenced by ivbopen(), and vinitpiduid().

struct DICTINFO* psvbfile[128+1]

Definition at line 23 of file vblowlevel.c.

Referenced by iaddkeydescriptor(), icheckkey(), icheckkeydesc(), idatafreecheck(), idelnodes(), idemotelocks(), iindexcheck(), iindexfreecheck(), ilockdelete(), ilockinsert(), imakekeysfromdata(), inewroot(), inodesplit(), ipostamble(), ipreamble(), iprocessdelete(), iquicknodesave(), ircvcreateindex(), ircvdeleteindex(), ircvinsert(), ircvuniqueid(), irowdelete(), irowinsert(), irowupdate(), isaddindex(), isbuild(), ischeck(), iscleanup(), isclose(), iscommit(), isdelcurr(), isdelete(), isdelindex(), isdelrec(), isdi_curidx(), isdi_datfd(), isdi_datlen(), isdi_idxfd(), isdi_kdsc(), isdi_name(), iserase(), isflush(), isindexinfo(), islock(), isopen(), isread(), isrecover(), isrelcurr(), isrelease(), isrelrec(), isrewcurr(), isrewrec(), isrewrite(), isrollback(), issetcollate(), issetunique(), isstart(), istartrownumber(), isuniqueid(), isunlock(), iswrcurr(), iswrite(), itreeload(), ivbcheckkey(), ivbclose2(), ivbclose3(), ivbdatafree(), ivbdatalock(), ivbdataread(), ivbdatawrite(), ivbenter(), ivbexit(), ivbfileopenlock(), ivbforcedataallocate(), ivbforceexit(), ivbkeycompare(), ivbkeydelete(), ivbkeyinsert(), ivbkeyload(), ivbkeylocaterow(), ivbkeysearch(), ivbnodefree(), ivbnodeload(), ivbnodesave(), ivbrollmeback(), ivbrollmeforward(), ivbtransclose(), ivbtranscreateindex(), ivbtransdelete(), ivbtransdeleteindex(), ivbtransinsert(), ivbtransopen(), ivbtranssetunique(), ivbtransuniqueid(), ivbtransupdate(), ivbvarlendelete(), ivbvarlenread(), ivbvarlenwrite(), ivbwriterow(), psvbkeyallocate(), tdelkeydescriptor(), ttailnode(), tvbdataallocate(), tvbdatacountgetnext(), tvbnodeallocate(), tvbnodecountgetnext(), vaddkeyforrow(), vcloseall(), vrebuildindexfree(), vvbkeyallfree(), vvbkeyfree(), and vvbkeyunmalloc().

struct VBFILE svbfile[128 *3]

Definition at line 24 of file vblowlevel.c.

Referenced by ilockdelete(), ilockinsert(), ipreamble(), ivbclose(), ivbclose2(), ivbdatalock(), ivblock(), ivbopen(), tvblseek(), tvbread(), and tvbwrite().