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