#include "isinternal.h"

Include dependency graph for isrecover.c:

Data Structures
struct	RCV_HDL

struct	STRANS

Functions
static int	ircvrollback (void)

static int	irollbackall (void)

static void	vcloseall (void)

static int	igetrcvhandle (const int ihandle, const int ipid)

static int	ircvchecktrans (const int ilength, const int ipid)

static int	iignore (const int ipid)

static int	ircvbuild (char *pcbuffer)

static int	ircvbegin (char *pcbuffer, const int ilength)

static int	ircvcreateindex (char *pcbuffer)

static int	ircvcluster (char *pcbuffer)

static int	ircvcommit (char *pcbuffer)

static int	ircvdelete (char *pcbuffer)

static int	ircvdeleteindex (char *pcbuffer)

static int	ircvfileerase (char *pcbuffer)

static int	ircvfileclose (char *pcbuffer)

static int	ircvfileopen (char *pcbuffer)

static int	ircvinsert (char *pcbuffer)

static int	ircvfilerename (char *pcbuffer)

static int	ircvsetunique (char *pcbuffer)

static int	ircvuniqueid (char *pcbuffer)

static int	ircvupdate (char *pcbuffer)

int	isrecover ()

Variables
static int	ivbrecvmode = 0x00

static struct STRANS *	pstranshead = ((void*)0)

static struct SLOGHDR *	psvblogheader

static struct RCV_HDL *	psrecoverhandle [128+1]

static char *	clclbuffer = ((void*)0)

static char *	cvbrtransbuffer = ((void*)0)

Function Documentation

static int igetrcvhandle	(	const int	ihandle,
		const int	ipid
	)

static

Definition at line 96 of file isrecover.c.

References RCV_HDL::ihandle, RCV_HDL::ipid, and RCV_HDL::psnext.

Referenced by ircvcreateindex(), ircvdelete(), ircvdeleteindex(), ircvfileopen(), ircvinsert(), ircvsetunique(), ircvuniqueid(), and ircvupdate().

 {
     struct RCV_HDL *psrcvhdl = psrecoverhandle[ihandle];
 
     while (psrcvhdl && psrcvhdl->ipid != ipid) {
         psrcvhdl = psrcvhdl->psnext;
     }
     if (psrcvhdl && psrcvhdl->ipid == ipid) {
         return psrcvhdl->ihandle;
     }
     return -1;
 }

Here is the caller graph for this function:

static int iignore ( const int ipid )

static

Definition at line 153 of file isrecover.c.

References STRANS::iignoreme, STRANS::ipid, STRANS::psnext, and pstranshead.

Referenced by ircvbuild(), ircvcluster(), ircvcreateindex(), ircvdelete(), ircvdeleteindex(), ircvfileclose(), ircvfileerase(), ircvfileopen(), ircvfilerename(), ircvinsert(), ircvsetunique(), ircvuniqueid(), and ircvupdate().

 {
     struct STRANS *pstrans = pstranshead;
 
     while (pstrans && pstrans->ipid != ipid) {
         pstrans = pstrans->psnext;
     }
     if (pstrans && pstrans->ipid == ipid) {
         return pstrans->iignoreme;
     }
     return 0;
 }

Here is the caller graph for this function:

static int ircvbegin	(	char *	pcbuffer,
		const int	ilength
	)

static

Definition at line 200 of file isrecover.c.

References SLOGHDR::cpid, STRANS::iignoreme, inl_ldint(), STRANS::ipid, ircvchecktrans(), ircvrollback(), NULL, STRANS::psnext, STRANS::psprev, pstranshead, and pvvbmalloc().

Referenced by isrecover().

 {
     struct STRANS   *pstrans = pstranshead;
     int     ipid;
 
     ipid = inl_ldint (psvblogheader->cpid);
     while (pstrans && pstrans->ipid != ipid) {
         pstrans = pstrans->psnext;
     }
     if (pstrans) {
         ircvrollback ();
     }
     pstrans = pvvbmalloc (sizeof (struct STRANS));
     if (!pstrans) {
         return ENOMEM;
     }
     pstrans->psprev = NULL;
     pstrans->psnext = pstranshead;
     if (pstranshead) {
         pstranshead->psprev = pstrans;
     }
     pstranshead = pstrans;
     pstrans->ipid = ipid;
     pstrans->iignoreme = ircvchecktrans (ilength, ipid);
     return 0;
 }

Here is the call graph for this function:

Here is the caller graph for this function:

static int ircvbuild ( char * pcbuffer )

static

Definition at line 167 of file isrecover.c.

References SLOGHDR::cpid, iignore(), inl_ldint(), STRANS::ipid, isbuild(), isclose(), iserrno, and isreclen.

Referenced by isrecover().

 {
     char        *pcfilename;
     int     ihandle, iloop, imode, imaxrowlen, ipid;
     struct keydesc  skeydesc;
 
     imode = inl_ldint (pcbuffer);
     ipid = inl_ldint (psvblogheader->cpid);
     if (iignore (ipid)) {
         return 0;
     }
     isreclen = inl_ldint (pcbuffer + INTSIZE);
     imaxrowlen = inl_ldint (pcbuffer + (INTSIZE * 2));
     skeydesc.k_flags = inl_ldint (pcbuffer + (INTSIZE * 3));
     skeydesc.k_nparts = inl_ldint (pcbuffer + (INTSIZE * 4));
     pcbuffer += (INTSIZE * 6);
     for (iloop = 0; iloop < skeydesc.k_nparts; iloop++) {
         skeydesc.k_part[iloop].kp_start = inl_ldint (pcbuffer + (iloop * 3 * INTSIZE));
         skeydesc.k_part[iloop].kp_leng =
             inl_ldint (pcbuffer + INTSIZE + (iloop * 3 * INTSIZE));
         skeydesc.k_part[iloop].kp_type =
             inl_ldint (pcbuffer + (INTSIZE * 2) + +(iloop * 3 * INTSIZE));
     }
     pcfilename = pcbuffer + (skeydesc.k_nparts * 3 * INTSIZE);
     ihandle = isbuild (pcfilename, imaxrowlen, &skeydesc, imode);
     imode = iserrno;    /* Save any error result */
     if (ihandle != -1) {
         isclose (ihandle);
     }
     return imode;
 }

Here is the call graph for this function:

Here is the caller graph for this function:

static int ircvchecktrans	(	const int	ilength,
		const int	ipid
	)

static

Definition at line 110 of file isrecover.c.

References clclbuffer, SLOGHDR::coperation, SLOGHDR::cpid, cvbrtransbuffer, inl_ldint(), ivblogfilehandle, ivbrecvmode, MAX_BUFFER_LENGTH, pvvbmalloc(), RECOV_VB, tvblseek(), tvbread(), VBL_BEGIN, VBL_COMMIT, and VBL_ROLLBACK.

Referenced by ircvbegin().

 {
     off_t   tlength;
     off_t   tlength2;
     off_t   trcvsaveoffset;
     int ifound = 0, iresult = 0;
 
     tlength = ilength;
     trcvsaveoffset = tvblseek (ivblogfilehandle, (off_t)0, SEEK_CUR);
     if (!clclbuffer) {
         clclbuffer = pvvbmalloc (MAX_BUFFER_LENGTH);
     }
     psvblogheader = (struct SLOGHDR *)(clclbuffer - INTSIZE);
     while (!ifound) {
         tlength2 = tvbread (ivblogfilehandle, clclbuffer, (size_t) tlength);
         if (tlength2 != tlength && tlength2 != tlength - INTSIZE) {
             break;
         }
         if (inl_ldint (psvblogheader->cpid) == ipid) {
             if (!memcmp (psvblogheader->coperation, VBL_COMMIT, 2)) {
                 ifound = 1;
             } else if (!memcmp (psvblogheader->coperation, VBL_BEGIN, 2)) {
                 ifound = 1;
                 if (ivbrecvmode & RECOV_VB) {
                     iresult = 1;
                 }
             } else if (!memcmp (psvblogheader->coperation, VBL_ROLLBACK, 2)) {
                 ifound = 1;
                 iresult = 1;
             }
         }
         if (tlength2 == tlength - INTSIZE) {
             break;
         }
         tlength = inl_ldint (clclbuffer + tlength - INTSIZE);
     }
 
     psvblogheader = (struct SLOGHDR *)(cvbrtransbuffer - INTSIZE);
     tvblseek (ivblogfilehandle, trcvsaveoffset, SEEK_SET);
     return iresult;
 }

Here is the call graph for this function:

Here is the caller graph for this function:

static int ircvcluster ( char * pcbuffer )

static

Definition at line 269 of file isrecover.c.

References SLOGHDR::cpid, iignore(), and inl_ldint().

Referenced by isrecover().

 {
     int ipid;
 
     ipid = inl_ldint (psvblogheader->cpid);
     if (iignore (ipid)) {
         return 0;
     }
 /* RXW
     fprintf (stderr, "ircvcluster not yet implemented!\n");
 */
     return 0;
 }

Here is the call graph for this function:

Here is the caller graph for this function:

static int ircvcommit ( char * pcbuffer )

static

Definition at line 284 of file isrecover.c.

References SLOGHDR::cpid, RCV_HDL::ihandle, inl_ldint(), STRANS::ipid, isrelease(), RCV_HDL::itranslock, RCV_HDL::psnext, STRANS::psnext, STRANS::psprev, pstranshead, VB_MAX_FILES, and vvbfree().

Referenced by isrecover().

 {
     struct RCV_HDL  *psrcv;
     struct STRANS   *pstrans = pstranshead;
     int     iloop, ipid;
 
     ipid = inl_ldint (psvblogheader->cpid);
     while (pstrans && pstrans->ipid != ipid) {
         pstrans = pstrans->psnext;
     }
     if (!pstrans) {
         return EBADLOG;
     }
     if (pstrans->psnext) {
         pstrans->psnext->psprev = pstrans->psprev;
     }
     if (pstrans->psprev) {
         pstrans->psprev->psnext = pstrans->psnext;
     } else {
         pstranshead = pstrans->psnext;
     }
     vvbfree (pstrans);
     for (iloop = 0; iloop <= VB_MAX_FILES; iloop++) {
         if (!psrecoverhandle[iloop]) {
             continue;
         }
         for (psrcv = psrecoverhandle[iloop]; psrcv; psrcv = psrcv->psnext) {
             if (psrcv->itranslock) {
                 isrelease (psrcv->ihandle);
             }
         }
     }
     return 0;
 }

Here is the call graph for this function:

Here is the caller graph for this function:

static int ircvcreateindex ( char * pcbuffer )

static

Definition at line 228 of file isrecover.c.

References SLOGHDR::cpid, igetrcvhandle(), iignore(), inl_ldint(), DICTINFO::iopenmode, STRANS::ipid, isaddindex(), iserrno, ivbfileopenlock(), and psvbfile.

Referenced by isrecover().

 {
     int     ihandle, iloop, ipid, isaveerror = 0;
     struct keydesc  skeydesc;
 
     ihandle = inl_ldint (pcbuffer);
     ipid = inl_ldint (psvblogheader->cpid);
     if (iignore (ipid)) {
         return 0;
     }
     ihandle = igetrcvhandle (ihandle, ipid);
     if (ihandle == -1) {
         return ENOTOPEN;
     }
     skeydesc.k_flags = inl_ldint (pcbuffer + INTSIZE);
     skeydesc.k_nparts = inl_ldint (pcbuffer + (INTSIZE * 2));
     pcbuffer += (INTSIZE * 4);
     for (iloop = 0; iloop < skeydesc.k_nparts; iloop++) {
         skeydesc.k_part[iloop].kp_start = inl_ldint (pcbuffer + (iloop * 3 * INTSIZE));
         skeydesc.k_part[iloop].kp_leng =
             inl_ldint (pcbuffer + INTSIZE + (iloop * 3 * INTSIZE));
         skeydesc.k_part[iloop].kp_type =
             inl_ldint (pcbuffer + (INTSIZE * 2) + +(iloop * 3 * INTSIZE));
     }
     /* Promote the file open lock to EXCLUSIVE */
     iserrno = ivbfileopenlock (ihandle, 2);
     if (iserrno) {
         return iserrno;
     }
     psvbfile[ihandle]->iopenmode |= ISEXCLLOCK;
     if (isaddindex (ihandle, &skeydesc)) {
         isaveerror = iserrno;
     }
     /* Demote the file open lock back to SHARED */
     psvbfile[ihandle]->iopenmode &= ~ISEXCLLOCK;
     ivbfileopenlock (ihandle, 0);
     ivbfileopenlock (ihandle, 1);
     return isaveerror;
 }

Here is the call graph for this function:

Here is the caller graph for this function:

static int ircvdelete ( char * pcbuffer )

static

Definition at line 320 of file isrecover.c.

References SLOGHDR::cpid, igetrcvhandle(), iignore(), inl_ldint(), inl_ldquad(), STRANS::ipid, isdelrec(), iserrno, and QUADSIZE.

Referenced by isrecover().

 {
     char    *pcrow;
     off_t   trownumber;
     int ihandle, ipid;
 
     ihandle = inl_ldint (pcbuffer);
     ipid = inl_ldint (psvblogheader->cpid);
     if (iignore (ipid)) {
         return 0;
     }
     ihandle = igetrcvhandle (ihandle, ipid);
     if (ihandle == -1) {
         return ENOTOPEN;
     }
     trownumber = inl_ldquad (pcbuffer + INTSIZE);
     pcrow = pcbuffer + INTSIZE + QUADSIZE + INTSIZE;
     isdelrec (ihandle, trownumber);
     return iserrno;
 }

Here is the call graph for this function:

Here is the caller graph for this function:

static int ircvdeleteindex ( char * pcbuffer )

static

Definition at line 342 of file isrecover.c.

References SLOGHDR::cpid, igetrcvhandle(), iignore(), inl_ldint(), DICTINFO::iopenmode, STRANS::ipid, isdelindex(), iserrno, ivbfileopenlock(), and psvbfile.

Referenced by isrecover().

 {
     int     ihandle, iloop, ipid, isaveerror = 0;
     struct keydesc  skeydesc;
 
     ihandle = inl_ldint (pcbuffer);
     ipid = inl_ldint (psvblogheader->cpid);
     if (iignore (ipid)) {
         return 0;
     }
     ihandle = igetrcvhandle (ihandle, ipid);
     if (ihandle == -1) {
         return ENOTOPEN;
     }
     skeydesc.k_flags = inl_ldint (pcbuffer + INTSIZE);
     skeydesc.k_nparts = inl_ldint (pcbuffer + (INTSIZE * 2));
     pcbuffer += (INTSIZE * 4);
     for (iloop = 0; iloop < skeydesc.k_nparts; iloop++) {
         skeydesc.k_part[iloop].kp_start = inl_ldint (pcbuffer + (iloop * 3 * INTSIZE));
         skeydesc.k_part[iloop].kp_leng =
             inl_ldint (pcbuffer + INTSIZE + (iloop * 3 * INTSIZE));
         skeydesc.k_part[iloop].kp_type =
             inl_ldint (pcbuffer + (INTSIZE * 2) + +(iloop * 3 * INTSIZE));
     }
     /* Promote the file open lock to EXCLUSIVE */
     iserrno = ivbfileopenlock (ihandle, 2);
     if (iserrno) {
         return iserrno;
     }
     psvbfile[ihandle]->iopenmode |= ISEXCLLOCK;
     if (isdelindex (ihandle, &skeydesc)) {
         isaveerror = iserrno;
     }
     /* Demote the file open lock back to SHARED */
     psvbfile[ihandle]->iopenmode &= ~ISEXCLLOCK;
     ivbfileopenlock (ihandle, 0);
     ivbfileopenlock (ihandle, 1);
     return isaveerror;
 }

Here is the call graph for this function:

Here is the caller graph for this function:

static int ircvfileclose ( char * pcbuffer )

static

Definition at line 396 of file isrecover.c.

References SLOGHDR::cpid, RCV_HDL::ihandle, iignore(), inl_ldint(), RCV_HDL::ipid, isclose(), iserrno, RCV_HDL::psnext, and RCV_HDL::psprev.

Referenced by isrecover().

 {
     struct RCV_HDL  *psrcv;
     int     ihandle, ivarlenflag, ipid;
 
     ihandle = inl_ldint (pcbuffer);
     ivarlenflag = inl_ldint (pcbuffer + INTSIZE);
     ipid = inl_ldint (psvblogheader->cpid);
     if (iignore (ipid)) {
         return 0;
     }
     psrcv = psrecoverhandle[ihandle];
     while (psrcv && psrcv->ipid != ipid) {
         psrcv = psrcv->psnext;
     }
     if (!psrcv || psrcv->ipid != ipid) {
         return ENOTOPEN;    /* It wasn't open! */
     }
     iserrno = 0;
     isclose (psrcv->ihandle);
     if (psrcv->psprev) {
         psrcv->psprev->psnext = psrcv->psnext;
     } else {
         psrecoverhandle[ihandle] = psrcv->psnext;
     }
     if (psrcv->psnext) {
         psrcv->psnext->psprev = psrcv->psprev;
     }
 
     return iserrno;
 }

Here is the call graph for this function:

Here is the caller graph for this function:

static int ircvfileerase ( char * pcbuffer )

static

Definition at line 383 of file isrecover.c.

References SLOGHDR::cpid, iignore(), inl_ldint(), iserase(), and iserrno.

Referenced by isrecover().

 {
     int ipid;
 
     ipid = inl_ldint (psvblogheader->cpid);
     if (iignore (ipid)) {
         return 0;
     }
     iserase (pcbuffer);
     return iserrno;
 }

Here is the call graph for this function:

Here is the caller graph for this function:

static int ircvfileopen ( char * pcbuffer )

static

Definition at line 429 of file isrecover.c.

References SLOGHDR::cpid, igetrcvhandle(), RCV_HDL::ihandle, iignore(), inl_ldint(), RCV_HDL::ipid, iserrno, isopen(), NULL, RCV_HDL::psnext, RCV_HDL::psprev, pvvbmalloc(), and vvbfree().

Referenced by isrecover().

 {
     struct RCV_HDL  *psrcv;
     int     ihandle, ivarlenflag, ipid;
 
     ihandle = inl_ldint (pcbuffer);
     ivarlenflag = inl_ldint (pcbuffer + INTSIZE);
     ipid = inl_ldint (psvblogheader->cpid);
     if (iignore (ipid)) {
         return 0;
     }
     if (igetrcvhandle (ihandle, ipid) != -1) {
         return ENOTOPEN;    /* It was already open! */
     }
     psrcv = pvvbmalloc (sizeof (struct RCV_HDL));
     if (psrcv == NULL) {
         return ENOMEM;  /* Oops */
     }
     psrcv->ihandle = isopen (pcbuffer + INTSIZE + INTSIZE,
             ISINOUT | ISMANULOCK | (ivarlenflag ? ISVARLEN : ISFIXLEN));
     psrcv->ipid = ipid;
     if (psrcv->ihandle < 0) {
         vvbfree (psrcv);
         return iserrno;
     }
     psrcv->psprev = NULL;
     psrcv->psnext = psrecoverhandle[ihandle];
     if (psrecoverhandle[ihandle]) {
         psrecoverhandle[ihandle]->psprev = psrcv;
     }
     psrecoverhandle[ihandle] = psrcv;
     return 0;
 }

Here is the call graph for this function:

Here is the caller graph for this function:

static int ircvfilerename ( char * pcbuffer )

static

Definition at line 498 of file isrecover.c.

References SLOGHDR::cpid, iignore(), inl_ldint(), RCV_HDL::ipid, iserrno, and isrename().

Referenced by isrecover().

 {
     char    *pcoldname, *pcnewname;
     int ioldnamelength, ipid;
 
     ipid = inl_ldint (psvblogheader->cpid);
     if (iignore (ipid)) {
         return 0;
     }
     ioldnamelength = inl_ldint (pcbuffer);
     pcoldname = pcbuffer + INTSIZE + INTSIZE;
     pcnewname = pcbuffer + INTSIZE + INTSIZE + ioldnamelength;
     isrename (pcoldname, pcnewname);
     return iserrno;
 }

Here is the call graph for this function:

Here is the caller graph for this function:

static int ircvinsert ( char * pcbuffer )

static

Definition at line 464 of file isrecover.c.

References SLOGHDR::cpid, igetrcvhandle(), RCV_HDL::ihandle, iignore(), DICTINFO::iisdictlocked, inl_ldint(), inl_ldquad(), RCV_HDL::ipid, iserrno, isreclen, ivbenter(), ivbexit(), ivbforcedataallocate(), ivbwriterow(), psvbfile, and QUADSIZE.

Referenced by isrecover().

 {
     char    *pcrow;
     off_t   trownumber;
     int ihandle, ipid;
 
     ihandle = inl_ldint (pcbuffer);
     ipid = inl_ldint (psvblogheader->cpid);
     if (iignore (ipid)) {
         return 0;
     }
     ihandle = igetrcvhandle (ihandle, ipid);
     if (ihandle == -1) {
         return ENOTOPEN;
     }
     trownumber = inl_ldquad (pcbuffer + INTSIZE);
     isreclen = inl_ldint (pcbuffer + INTSIZE + QUADSIZE);
     pcrow = pcbuffer + INTSIZE + QUADSIZE + INTSIZE;
     if (ivbenter (ihandle, 1, 0)) {
         return iserrno;
     }
     psvbfile[ihandle]->iisdictlocked |= 0x02;
     if (ivbforcedataallocate (ihandle, trownumber)) {
         return EDUPL;
     }
     if (ivbwriterow (ihandle, pcrow, trownumber)) {
         return iserrno;
     }
     ivbexit (ihandle);
     return iserrno;
 }

Here is the call graph for this function:

Here is the caller graph for this function:

static int ircvrollback ( void )

static

Definition at line 47 of file isrecover.c.

References SLOGHDR::cpid, inl_ldint(), STRANS::ipid, STRANS::psnext, STRANS::psprev, pstranshead, and vvbfree().

Referenced by ircvbegin(), irollbackall(), and isrecover().

 {
     struct STRANS   *pstrans = pstranshead;
     int     ipid;
 
     ipid = inl_ldint (psvblogheader->cpid);
     while (pstrans && pstrans->ipid != ipid) {
         pstrans = pstrans->psnext;
     }
     if (!pstrans) {
         return EBADLOG;
     }
     if (pstrans->psnext) {
         pstrans->psnext->psprev = pstrans->psprev;
     }
     if (pstrans->psprev) {
         pstrans->psprev->psnext = pstrans->psnext;
     } else {
         pstranshead = pstrans->psnext;
     }
     vvbfree (pstrans);
     return 0;
 }

Here is the call graph for this function:

Here is the caller graph for this function:

static int ircvsetunique ( char * pcbuffer )

static

Definition at line 515 of file isrecover.c.

References SLOGHDR::cpid, igetrcvhandle(), RCV_HDL::ihandle, iignore(), inl_ldint(), inl_ldquad(), RCV_HDL::ipid, iserrno, and issetunique().

Referenced by isrecover().

 {
     off_t   tuniqueid;
     int ihandle, ipid;
 
     ihandle = inl_ldint (pcbuffer);
     ipid = inl_ldint (psvblogheader->cpid);
     if (iignore (ipid)) {
         return 0;
     }
     ihandle = igetrcvhandle (ihandle, ipid);
     if (ihandle == -1) {
         return ENOTOPEN;
     }
     tuniqueid = inl_ldquad (pcbuffer + INTSIZE);
     issetunique (ihandle, tuniqueid);
     return iserrno;
 }

Here is the call graph for this function:

Here is the caller graph for this function:

static int ircvuniqueid ( char * pcbuffer )

static

Definition at line 535 of file isrecover.c.

References SLOGHDR::cpid, igetrcvhandle(), RCV_HDL::ihandle, iignore(), inl_ldint(), inl_ldquad(), RCV_HDL::ipid, isuniqueid(), and psvbfile.

Referenced by isrecover().

 {
     off_t   tuniqueid;
     int ihandle, ipid;
 
     ihandle = inl_ldint (pcbuffer);
     ipid = inl_ldint (psvblogheader->cpid);
     if (iignore (ipid)) {
         return 0;
     }
     ihandle = igetrcvhandle (ihandle, ipid);
     if (ihandle == -1) {
         return ENOTOPEN;
     }
     tuniqueid = inl_ldquad (pcbuffer + INTSIZE);
     if (tuniqueid != inl_ldquad (psvbfile[ihandle]->sdictnode.cuniqueid)) {
         return EBADFILE;
     }
     isuniqueid (ihandle, &tuniqueid);
     return 0;
 }

Here is the call graph for this function:

Here is the caller graph for this function:

static int ircvupdate ( char * pcbuffer )

static

Definition at line 558 of file isrecover.c.

References SLOGHDR::cpid, igetrcvhandle(), RCV_HDL::ihandle, iignore(), inl_ldint(), inl_ldquad(), RCV_HDL::ipid, iserrno, isreclen, isrewrec(), and QUADSIZE.

Referenced by isrecover().

 {
     char    *pcrow;
     off_t   trownumber;
     int ihandle, ipid;
 
     ihandle = inl_ldint (pcbuffer);
     ipid = inl_ldint (psvblogheader->cpid);
     if (iignore (ipid)) {
         return 0;
     }
     ihandle = igetrcvhandle (ihandle, ipid);
     if (ihandle == -1) {
         return ENOTOPEN;
     }
     trownumber = inl_ldquad (pcbuffer + INTSIZE);
     isreclen = inl_ldint (pcbuffer + INTSIZE + QUADSIZE);
     pcrow = pcbuffer + INTSIZE + QUADSIZE + INTSIZE + INTSIZE + isreclen;
     isreclen = inl_ldint (pcbuffer + INTSIZE + QUADSIZE + INTSIZE);
     isrewrec (ihandle, trownumber, pcrow);
     return iserrno;
 }

Here is the call graph for this function:

Here is the caller graph for this function:

static int irollbackall ( void )

static

Definition at line 72 of file isrecover.c.

References SLOGHDR::cpid, inl_stint(), STRANS::ipid, and ircvrollback().

Referenced by isrecover().

 {
     while (pstranshead) {
         inl_stint (pstranshead->ipid, psvblogheader->cpid);
         ircvrollback ();
     }
     return 0;
 }

Here is the call graph for this function:

Here is the caller graph for this function:

int isrecover ( )

Definition at line 584 of file isrecover.c.

References SLOGHDR::coperation, cvbrtransbuffer, inl_ldint(), ircvbegin(), ircvbuild(), ircvcluster(), ircvcommit(), ircvcreateindex(), ircvdelete(), ircvdeleteindex(), ircvfileclose(), ircvfileerase(), ircvfileopen(), ircvfilerename(), ircvinsert(), ircvrollback(), ircvsetunique(), ircvuniqueid(), ircvupdate(), irollbackall(), iserrno, ivbintrans, ivblogfilehandle, MAX_BUFFER_LENGTH, NULL, psvbfile, pvvbmalloc(), tvblseek(), tvbread(), VB_MAX_FILES, VBL_BEGIN, VBL_BUILD, VBL_CLUSTER, VBL_COMMIT, VBL_CREINDEX, VBL_DELETE, VBL_DELINDEX, VBL_FILECLOSE, VBL_FILEERASE, VBL_FILEOPEN, VBL_INSERT, VBL_RENAME, VBL_ROLLBACK, VBL_SETUNIQUE, VBL_UNIQUEID, VBL_UPDATE, VBRECOVER, vcloseall(), and vvbfree().

 {
     char    *pcbuffer;
     off_t   tlength, tlength2, toffset;
     int iloop, isaveerror;
 
     /* Initialize by stating that *ALL* tables must be closed! */
     for (iloop = 0; iloop <= VB_MAX_FILES; iloop++) {
         if (psvbfile[iloop]) {
             iserrno = ETOOMANY;
             return -1;
         }
     }
     ivbintrans = VBRECOVER;
     for (iloop = 0; iloop <= VB_MAX_FILES; iloop++) {
         psrecoverhandle[iloop] = NULL;
     }
     /* Begin by reading the header of the first transaction */
     iserrno = EBADFILE;
     if (tvblseek (ivblogfilehandle, (off_t)0, SEEK_SET) != 0) {
         return -1;
     }
     cvbrtransbuffer = pvvbmalloc (MAX_BUFFER_LENGTH);
     if (!cvbrtransbuffer) {
         iserrno = EBADMEM;
         return -1;
     }
     psvblogheader = (struct SLOGHDR *)(cvbrtransbuffer - INTSIZE);
     if (tvbread (ivblogfilehandle, cvbrtransbuffer, INTSIZE) != INTSIZE) {
         return 0;   /* Nothing to do if the file is empty */
     }
     toffset = 0;
     tlength = inl_ldint (cvbrtransbuffer);
     /* Now, recurse forwards */
     while (1) {
         tlength2 = tvbread (ivblogfilehandle, cvbrtransbuffer, tlength);
         iserrno = EBADFILE;
         if (tlength2 != tlength && tlength2 != tlength - INTSIZE) {
             break;
         }
         pcbuffer = cvbrtransbuffer - INTSIZE + sizeof (struct SLOGHDR);
         if (!memcmp (psvblogheader->coperation, VBL_BUILD, 2)) {
             iserrno = ircvbuild (pcbuffer);
         } else if (!memcmp (psvblogheader->coperation, VBL_BEGIN, 2)) {
             iserrno = ircvbegin (pcbuffer,
                        inl_ldint (cvbrtransbuffer + tlength - INTSIZE));
         } else if (!memcmp (psvblogheader->coperation, VBL_CREINDEX, 2)) {
             iserrno = ircvcreateindex (pcbuffer);
         } else if (!memcmp (psvblogheader->coperation, VBL_CLUSTER, 2)) {
             iserrno = ircvcluster (pcbuffer);
         } else if (!memcmp (psvblogheader->coperation, VBL_COMMIT, 2)) {
             iserrno = ircvcommit (pcbuffer);
         } else if (!memcmp (psvblogheader->coperation, VBL_DELETE, 2)) {
             iserrno = ircvdelete (pcbuffer);
         } else if (!memcmp (psvblogheader->coperation, VBL_DELINDEX, 2)) {
             iserrno = ircvdeleteindex (pcbuffer);
         } else if (!memcmp (psvblogheader->coperation, VBL_FILEERASE, 2)) {
             iserrno = ircvfileerase (pcbuffer);
         } else if (!memcmp (psvblogheader->coperation, VBL_FILECLOSE, 2)) {
             iserrno = ircvfileclose (pcbuffer);
         } else if (!memcmp (psvblogheader->coperation, VBL_FILEOPEN, 2)) {
             iserrno = ircvfileopen (pcbuffer);
         } else if (!memcmp (psvblogheader->coperation, VBL_INSERT, 2)) {
             iserrno = ircvinsert (pcbuffer);
         } else if (!memcmp (psvblogheader->coperation, VBL_RENAME, 2)) {
             iserrno = ircvfilerename (pcbuffer);
         } else if (!memcmp (psvblogheader->coperation, VBL_ROLLBACK, 2)) {
             iserrno = ircvrollback ();
         } else if (!memcmp (psvblogheader->coperation, VBL_SETUNIQUE, 2)) {
             iserrno = ircvsetunique (pcbuffer);
         } else if (!memcmp (psvblogheader->coperation, VBL_UNIQUEID, 2)) {
             iserrno = ircvuniqueid (pcbuffer);
         } else if (!memcmp (psvblogheader->coperation, VBL_UPDATE, 2)) {
             iserrno = ircvupdate (pcbuffer);
         }
         if (iserrno) {
             break;
         }
         toffset += tlength2;
         if (tlength2 == tlength - INTSIZE) {
             break;
         }
         tlength = inl_ldint (cvbrtransbuffer + tlength - INTSIZE);
     }
     isaveerror = iserrno;
     /* We now rollback any transactions that were never 'closed' */
     iserrno = irollbackall ();
     if (!isaveerror) {
         isaveerror = iserrno;
     }
     vcloseall ();
     iserrno = isaveerror;
     vvbfree (cvbrtransbuffer);
     if (iserrno) {
         return -1;
     }
     return 0;
 }

Here is the call graph for this function:

static void vcloseall ( void )

static

Definition at line 82 of file isrecover.c.

References DICTINFO::iisopen, isclose(), psvbfile, and VB_MAX_FILES.

Referenced by isrecover().

 {
     struct DICTINFO *psvbptr;
     int     iloop;
 
     for (iloop = 0; iloop <= VB_MAX_FILES; iloop++) {
         psvbptr = psvbfile[iloop];
         if (psvbptr && psvbptr->iisopen == 0) {
             isclose (iloop);
         }
     }
 }