be-fsstubs.h File Reference

This graph shows which files directly or indirectly include this file:

Go to the source code of this file.

Functions
int	lo_read (int fd, char *buf, int len)
int	lo_write (int fd, const char *buf, int len)
void	AtEOXact_LargeObject (bool isCommit)
void	AtEOSubXact_LargeObject (bool isCommit, SubTransactionId mySubid, SubTransactionId parentSubid)

Function Documentation

AtEOSubXact_LargeObject()

void AtEOSubXact_LargeObject	(	bool	isCommit,
		SubTransactionId	mySubid,
		SubTransactionId	parentSubid
	)

Definition at line 653 of file be-fsstubs.c.

{
    int         i;
 
    if (fscxt == NULL)          /* no LO operations in this xact */
        return;
 
    for (i = 0; i < cookies_size; i++)
    {
        LargeObjectDesc *lo = cookies[i];
 
        if (lo != NULL && lo->subid == mySubid)
        {
            if (isCommit)
                lo->subid = parentSubid;
            else
                closeLOfd(i);
        }
    }
}

References closeLOfd(), cookies, cookies_size, fscxt, i, and LargeObjectDesc::subid.

Referenced by AbortSubTransaction(), and CommitSubTransaction().

AtEOXact_LargeObject()

void AtEOXact_LargeObject

(

bool

isCommit

)

Definition at line 607 of file be-fsstubs.c.

{
    int         i;
 
    if (!lo_cleanup_needed)
        return;                 /* no LO operations in this xact */
 
    /*
     * Close LO fds and clear cookies array so that LO fds are no longer good.
     * The memory context and resource owner holding them are going away at
     * the end-of-transaction anyway, but on commit, we need to close them to
     * avoid warnings about leaked resources at commit.  On abort we can skip
     * this step.
     */
    if (isCommit)
    {
        for (i = 0; i < cookies_size; i++)
        {
            if (cookies[i] != NULL)
                closeLOfd(i);
        }
    }
 
    /* Needn't actually pfree since we're about to zap context */
    cookies = NULL;
    cookies_size = 0;
 
    /* Release the LO memory context to prevent permanent memory leaks. */
    if (fscxt)
        MemoryContextDelete(fscxt);
    fscxt = NULL;
 
    /* Give inv_api.c a chance to clean up, too */
    close_lo_relation(isCommit);
 
    lo_cleanup_needed = false;
}

References close_lo_relation(), closeLOfd(), cookies, cookies_size, fscxt, i, lo_cleanup_needed, and MemoryContextDelete().

Referenced by AbortTransaction(), CommitTransaction(), and PrepareTransaction().

lo_read()

int lo_read	(	int	fd,
		char *	buf,
		int	len
	)

Definition at line 154 of file be-fsstubs.c.

{
    int         status;
    LargeObjectDesc *lobj;
 
    if (fd < 0 || fd >= cookies_size || cookies[fd] == NULL)
        ereport(ERROR,
                (errcode(ERRCODE_UNDEFINED_OBJECT),
                 errmsg("invalid large-object descriptor: %d", fd)));
    lobj = cookies[fd];
 
    /*
     * Check state.  inv_read() would throw an error anyway, but we want the
     * error to be about the FD's state not the underlying privilege; it might
     * be that the privilege exists but user forgot to ask for read mode.
     */
    if ((lobj->flags & IFS_RDLOCK) == 0)
        ereport(ERROR,
                (errcode(ERRCODE_OBJECT_NOT_IN_PREREQUISITE_STATE),
                 errmsg("large object descriptor %d was not opened for reading",
                        fd)));
 
    status = inv_read(lobj, buf, len);
 
    return status;
}

References buf, cookies, cookies_size, ereport, errcode(), errmsg(), ERROR, fd(), LargeObjectDesc::flags, IFS_RDLOCK, inv_read(), and len.

Referenced by be_loread(), dumpLOs(), exportFile(), and pickout().

lo_write()

int lo_write	(	int	fd,
		const char *	buf,
		int	len
	)

Definition at line 182 of file be-fsstubs.c.

{
    int         status;
    LargeObjectDesc *lobj;
 
    if (fd < 0 || fd >= cookies_size || cookies[fd] == NULL)
        ereport(ERROR,
                (errcode(ERRCODE_UNDEFINED_OBJECT),
                 errmsg("invalid large-object descriptor: %d", fd)));
    lobj = cookies[fd];
 
    /* see comment in lo_read() */
    if ((lobj->flags & IFS_WRLOCK) == 0)
        ereport(ERROR,
                (errcode(ERRCODE_OBJECT_NOT_IN_PREREQUISITE_STATE),
                 errmsg("large object descriptor %d was not opened for writing",
                        fd)));
 
    status = inv_write(lobj, buf, len);
 
    return status;
}

References buf, cookies, cookies_size, ereport, errcode(), errmsg(), ERROR, fd(), LargeObjectDesc::flags, IFS_WRLOCK, inv_write(), and len.

Referenced by be_lowrite(), dump_lo_buf(), importFile(), and overwrite().