/***** includes *****/
#include "lfds710_queue_bounded_manyproducer_manyconsumer_internal.h"





/****************************************************************************/
void lfds710_queue_bmm_init_valid_on_current_logical_core( struct lfds710_queue_bmm_state *qbmms,
                                                           struct lfds710_queue_bmm_element *element_array,
                                                           lfds710_pal_uint_t number_elements,
                                                           void *user_state )
{
  lfds710_pal_uint_t
    loop;

  LFDS710_PAL_ASSERT( qbmms != NULL );
  LFDS710_PAL_ASSERT( element_array != NULL );
  LFDS710_PAL_ASSERT( number_elements >= 2 );
  LFDS710_PAL_ASSERT( ( number_elements & (number_elements-1) ) == 0 ); // TRD : number_elements must be a positive integer power of 2
  // TRD : user_state can be NULL

  qbmms->number_elements = number_elements;
  qbmms->mask = qbmms->number_elements - 1;
  qbmms->read_index = 0;
  qbmms->write_index = 0;
  qbmms->element_array = element_array;
  qbmms->user_state = user_state;

  for( loop = 0 ; loop < qbmms->number_elements ; loop++ )
    qbmms->element_array[loop].sequence_number = loop;

  lfds710_misc_internal_backoff_init( &qbmms->dequeue_backoff );
  lfds710_misc_internal_backoff_init( &qbmms->enqueue_backoff );

  LFDS710_MISC_BARRIER_STORE;

  lfds710_misc_force_store();

  return;
}