iswrite.c File Reference

#include "isinternal.h"

Include dependency graph for iswrite.c:

Go to the source code of this file.

Functions
static int	irowinsert (const int ihandle, char *pcrow_buffer, off_t trownumber)
int	ivbwriterow (const int ihandle, char *pcrow, const off_t trownumber)
int	iswrcurr (const int ihandle, char *pcrow)
int	iswrite (const int ihandle, char *pcrow)

Function Documentation

static int irowinsert ( const int  ihandle, char *  pcrow_buffer, off_t  trownumber  )

static

Definition at line 23 of file iswrite.c.

References VBKEY::ckey, DICTINFO::inkeys, iserrno, ivbkeyinsert(), ivbkeyload(), ivbkeysearch(), MAXSUBS, NULL, DICTINFO::pskeydesc, psvbfile, VBKEY::tdupnumber, and vvbmakekey().

Referenced by ivbwriterow().

{
    struct VBKEY    *pskey;
    struct DICTINFO *psvbptr;
    struct keydesc  *pskptr;
    off_t       tdupnumber[MAXSUBS];
    int     ikeynumber, iresult;
    unsigned char   ckeyvalue[VB_MAX_KEYLEN];

    psvbptr = psvbfile[ihandle];
    /*
     * Step 1:
     *      Check each index for a potential ISNODUPS error (EDUPL)
     *      Also, calculate the duplicate number as needed
     */
    for (ikeynumber = 0; ikeynumber < psvbptr->inkeys; ikeynumber++) {
        pskptr = psvbptr->pskeydesc[ikeynumber];
        if (pskptr->k_nparts == 0) {
            continue;
        }
        vvbmakekey (psvbptr->pskeydesc[ikeynumber], pcrow_buffer, ckeyvalue);
        iresult = ivbkeysearch (ihandle, ISGREAT, ikeynumber, 0, ckeyvalue, (off_t)0);
        tdupnumber[ikeynumber] = 0;
        if (iresult >= 0 && !ivbkeyload (ihandle, ikeynumber, ISPREV, 0, &pskey)
            && !memcmp (pskey->ckey, ckeyvalue, (size_t)pskptr->k_len)) {
            iserrno = EDUPL;
            if (pskptr->k_flags & ISDUPS) {
                tdupnumber[ikeynumber] = pskey->tdupnumber + 1;
            } else {
                return -1;
            }
        }
        iresult = ivbkeysearch (ihandle, ISGTEQ, ikeynumber, 0, ckeyvalue,
                  tdupnumber[ikeynumber]);
    }

    /* Step 2: Perform the actual insertion into each index */
    for (ikeynumber = 0; ikeynumber < psvbptr->inkeys; ikeynumber++) {
        if (psvbptr->pskeydesc[ikeynumber]->k_nparts == 0) {
            continue;
        }
        vvbmakekey (psvbptr->pskeydesc[ikeynumber], pcrow_buffer, ckeyvalue);
        iresult = ivbkeyinsert (ihandle, NULL, ikeynumber, ckeyvalue,
                trownumber, tdupnumber[ikeynumber], NULL);
        if (iresult) {
/* BUG - do something SANE here */
            /* Eeek, an error occured.  Let's remove what we added */
            /* while (ikeynumber >= 0) */
            /* { */
            /* ivbkeydelete (ihandle, ikeynumber); */
            /* ikeynumber--; */
            /* } */
            return iresult;
        }
    }

    return 0;
}

Here is the call graph for this function:

Here is the caller graph for this function:

int iswrcurr	(	const int	ihandle,
		char *	pcrow
	)

Definition at line 122 of file iswrite.c.

References DICTINFO::imaxrowlength, DICTINFO::iminrowlength, DICTINFO::iopenmode, iserrno, isreclen, ivbdatafree(), ivbenter(), ivbexit(), ivbwriterow(), psvbfile, DICTINFO::trownumber, and tvbdataallocate().

{
    struct DICTINFO *psvbptr;
    off_t   trownumber;
    int iresult;

    if (ivbenter (ihandle, 1, 0)) {
        return -1;
    }
    psvbptr = psvbfile[ihandle];

    if ((psvbptr->iopenmode & ISVARLEN) && (isreclen > psvbptr->imaxrowlength
        || isreclen < psvbptr->iminrowlength)) {
        iserrno = EBADARG;
        return -1;
    }

    trownumber = tvbdataallocate (ihandle);
    if (trownumber == -1) {
        return -1;
    }

    iresult = ivbwriterow (ihandle, pcrow, trownumber);
    if (!iresult) {
        psvbptr->trownumber = trownumber;
    } else {
        ivbdatafree (ihandle, trownumber);
    }

    ivbexit (ihandle);
    return iresult;
}

Here is the call graph for this function:

int iswrite	(	const int	ihandle,
		char *	pcrow
	)

Definition at line 156 of file iswrite.c.

References DICTINFO::imaxrowlength, DICTINFO::iminrowlength, DICTINFO::iopenmode, iserrno, isreclen, ivbdatafree(), ivbenter(), ivbexit(), ivbwriterow(), psvbfile, DICTINFO::trownumber, and tvbdataallocate().

Referenced by indexed_write().

{
    struct DICTINFO *psvbptr;
    off_t trownumber;
    int iresult, isaveerror;

    if (ivbenter (ihandle, 1, 0)) {
        return -1;
    }
    psvbptr = psvbfile[ihandle];

    if ((psvbptr->iopenmode & ISVARLEN) && (isreclen > psvbptr->imaxrowlength
        || isreclen < psvbptr->iminrowlength)) {
        iserrno = EBADARG;
        return -1;
    }

    trownumber = tvbdataallocate (ihandle);
    if (trownumber == -1) {
        return -1;
    }

    iresult = ivbwriterow (ihandle, pcrow, trownumber);
    if (iresult) {
        isaveerror = iserrno;
        ivbdatafree (ihandle, trownumber);
        iserrno = isaveerror;
    }

    ivbexit (ihandle);
    return iresult;
}

Here is the call graph for this function:

Here is the caller graph for this function:

int ivbwriterow	(	const int	ihandle,
		char *	pcrow,
		const off_t	trownumber
	)

Definition at line 85 of file iswrite.c.

References DICTINFO::iminrowlength, DICTINFO::iopenmode, irowinsert(), iserrno, isreclen, isrecnum, ivbdatalock(), ivbdatawrite(), ivbtransinsert(), psvbfile, DICTINFO::trownumber, DICTINFO::tvarlennode, VBUNLOCK, and VBWRLOCK.

Referenced by ircvinsert(), iswrcurr(), iswrite(), and ivbrollmeback().

{
    struct DICTINFO *psvbptr;
    int     iresult = 0;

    psvbptr = psvbfile[ihandle];
    isrecnum = trownumber;
    if (psvbptr->iopenmode & ISTRANS) {
        iserrno = ivbdatalock (ihandle, VBWRLOCK, trownumber);
        if (iserrno) {
            return -1;
        }
    }
    iresult = irowinsert (ihandle, pcrow, trownumber);
    if (!iresult) {
        iserrno = 0;
        psvbptr->tvarlennode = 0;   /* Stop it from removing */
        iresult = ivbdatawrite (ihandle, (void *)pcrow, 0, trownumber);
        if (iresult) {
            iserrno = iresult;
            if (psvbptr->iopenmode & ISTRANS) {
                ivbdatalock (ihandle, VBUNLOCK, trownumber);
            }
            return -1;
        }
        if (psvbptr->iopenmode & ISVARLEN) {
            iresult = ivbtransinsert (ihandle, trownumber,
                    isreclen, pcrow);
        } else {
            iresult = ivbtransinsert (ihandle, trownumber,
                    psvbptr->iminrowlength, pcrow);
        }
    }
    return iresult;
}

Here is the call graph for this function:

Here is the caller graph for this function: