This graph shows which files directly or indirectly include 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 )

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, sizeComboCids, and usedComboCids.

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

◆ EstimateComboCIDStateSpace()

Size EstimateComboCIDStateSpace ( void )

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(), mul_size(), size, and usedComboCids.

Referenced by InitializeParallelDSM().

◆ RestoreComboCIDState()

void RestoreComboCIDState ( char * comboCIDstate )

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, GetComboCommandId(), and i.

Referenced by ParallelWorkerMain().

◆ SerializeComboCIDState()

void SerializeComboCIDState	(	Size	maxsize,
		char *	start_address
	)

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));
}