combocid.h File Reference

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

Go to the source code of this file.

Functions
void	AtEOXact_ComboCid (void)
void	RestoreComboCIDState (char *comboCIDstate)
void	SerializeComboCIDState (Size maxsize, char *start_address)
Size	EstimateComboCIDStateSpace (void)

Function Documentation

AtEOXact_ComboCid()

void AtEOXact_ComboCid ( void  )

extern

Definition at line 182 of file combocid.c.

{
    /*
     * Don't bother to pfree. These are allocated in TopTransactionContext, so
     * they're going to go away at the end of transaction anyway.
     */
    comboHash = NULL;
 
    comboCids = NULL;
    usedComboCids = 0;
    sizeComboCids = 0;
}

References comboCids, comboHash, fb(), sizeComboCids, and usedComboCids.

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

EstimateComboCIDStateSpace()

Size EstimateComboCIDStateSpace ( void  )

extern

Definition at line 297 of file combocid.c.

{
    Size        size;
 
    /* Add space required for saving usedComboCids */
    size = sizeof(int);
 
    /* Add space required for saving ComboCidKeyData */
    size = add_size(size, mul_size(sizeof(ComboCidKeyData), usedComboCids));
 
    return size;
}

References add_size(), fb(), mul_size(), and usedComboCids.

Referenced by InitializeParallelDSM().

RestoreComboCIDState()

void RestoreComboCIDState ( char *  comboCIDstate )

extern

Definition at line 342 of file combocid.c.

{
    int         num_elements;
    ComboCidKeyData *keydata;
    int         i;
    CommandId   cid;
 
    Assert(!comboCids && !comboHash);
 
    /* First, we retrieve the number of combo CIDs that were serialized. */
    num_elements = *(int *) comboCIDstate;
    keydata = (ComboCidKeyData *) (comboCIDstate + sizeof(int));
 
    /* Use GetComboCommandId to restore each combo CID. */
    for (i = 0; i < num_elements; i++)
    {
        cid = GetComboCommandId(keydata[i].cmin, keydata[i].cmax);
 
        /* Verify that we got the expected answer. */
        if (cid != i)
            elog(ERROR, "unexpected command ID while restoring combo CIDs");
    }
}

References Assert, comboCids, comboHash, elog, ERROR, fb(), GetComboCommandId(), and i.

Referenced by ParallelWorkerMain().

SerializeComboCIDState()

void SerializeComboCIDState ( Size  maxsize, char *  start_address  )

extern

Definition at line 316 of file combocid.c.

{
    char       *endptr;
 
    /* First, we store the number of currently-existing combo CIDs. */
    *(int *) start_address = usedComboCids;
 
    /* If maxsize is too small, throw an error. */
    endptr = start_address + sizeof(int) +
        (sizeof(ComboCidKeyData) * usedComboCids);
    if (endptr < start_address || endptr > start_address + maxsize)
        elog(ERROR, "not enough space to serialize ComboCID state");
 
    /* Now, copy the actual cmin/cmax pairs. */
    if (usedComboCids > 0)
        memcpy(start_address + sizeof(int), comboCids,
               (sizeof(ComboCidKeyData) * usedComboCids));
}

References comboCids, elog, ERROR, fb(), and usedComboCids.

Referenced by InitializeParallelDSM().