2 #include "libtest_tests_internal.h"
5 struct test_per_thread_state
10 struct lfds710_queue_bmm_state
14 /***** private prototypes *****/
15 static libshared_pal_thread_return_t LIBSHARED_PAL_THREAD_CALLING_CONVENTION thread_simple_enqueuer( void *libtest_threadset_per_thread_state );
21 /****************************************************************************/
22 void libtest_tests_queue_bmm_enqueuing( struct lfds710_list_asu_state *list_of_logical_processors, struct libshared_memory_state *ms, enum lfds710_misc_validity *dvs )
28 power_of_two_number_elements = 1,
30 number_logical_processors,
33 struct lfds710_list_asu_element
36 struct lfds710_queue_bmm_element
39 struct lfds710_queue_bmm_state
42 struct lfds710_misc_validation_info
45 struct libtest_logical_processor
48 struct libtest_threadset_per_thread_state
51 struct libtest_threadset_state
54 struct test_per_thread_state
57 LFDS710_PAL_ASSERT( list_of_logical_processors != NULL );
58 LFDS710_PAL_ASSERT( ms != NULL );
59 LFDS710_PAL_ASSERT( dvs != NULL );
61 /* TRD : create an empty queue, with the largest possible number of elements
62 then run one thread per CPU
63 where each thread busy-works, enqueuing key/values, where the key is the thread ID and the value is an incrementing per-thread counter
64 run until the queue is full
66 when we're done, we check that all the elements are present
67 and increment on a per-thread basis
70 *dvs = LFDS710_MISC_VALIDITY_VALID;
72 lfds710_list_asu_query( list_of_logical_processors, LFDS710_LIST_ASU_QUERY_GET_POTENTIALLY_INACCURATE_COUNT, NULL, (void **) &number_logical_processors );
75 lfds710_list_asu_query( list_of_logical_processors, LFDS710_LIST_ASU_QUERY_GET_POTENTIALLY_INACCURATE_COUNT, NULL, (void **) &number_logical_processors );
76 tpts = libshared_memory_alloc_from_unknown_node( ms, sizeof(struct test_per_thread_state) * number_logical_processors, LFDS710_PAL_ATOMIC_ISOLATION_IN_BYTES );
77 pts = libshared_memory_alloc_from_unknown_node( ms, sizeof(struct libtest_threadset_per_thread_state) * number_logical_processors, LFDS710_PAL_ATOMIC_ISOLATION_IN_BYTES );
78 per_thread_counters = libshared_memory_alloc_from_unknown_node( ms, sizeof(lfds710_pal_uint_t) * number_logical_processors, LFDS710_PAL_ATOMIC_ISOLATION_IN_BYTES );
79 qbmme_array = libshared_memory_alloc_largest_possible_array_from_unknown_node( ms, sizeof(struct lfds710_queue_bmm_element), LFDS710_PAL_ATOMIC_ISOLATION_IN_BYTES, &number_elements );
81 // TRD : need to only use a power of 2 number of elements
82 number_elements >>= 1;
84 while( number_elements != 0 )
86 number_elements >>= 1;
87 power_of_two_number_elements <<= 1;
90 lfds710_queue_bmm_init_valid_on_current_logical_core( &qbmms, qbmme_array, power_of_two_number_elements, NULL );
92 libtest_threadset_init( &ts, NULL );
94 while( LFDS710_LIST_ASU_GET_START_AND_THEN_NEXT(*list_of_logical_processors,lasue) )
96 lp = LFDS710_LIST_ASU_GET_VALUE_FROM_ELEMENT( *lasue );
97 (tpts+loop)->qbmms = &qbmms;
98 (tpts+loop)->thread_number = loop;
99 libtest_threadset_add_thread( &ts, &pts[loop], lp, thread_simple_enqueuer, &tpts[loop] );
103 LFDS710_MISC_BARRIER_STORE;
105 lfds710_misc_force_store();
107 // TRD : run the test
108 libtest_threadset_run( &ts );
110 libtest_threadset_cleanup( &ts );
113 LFDS710_MISC_BARRIER_LOAD;
115 /* TRD : first, validate the queue
117 we expect to find element numbers increment on a per thread basis
120 vi.min_elements = vi.max_elements = power_of_two_number_elements;
122 lfds710_queue_bmm_query( &qbmms, LFDS710_QUEUE_BMM_QUERY_SINGLETHREADED_VALIDATE, &vi, dvs );
124 for( loop = 0 ; loop < number_logical_processors ; loop++ )
125 *(per_thread_counters+loop) = 0;
127 while( *dvs == LFDS710_MISC_VALIDITY_VALID and lfds710_queue_bmm_dequeue(&qbmms, (void **) &thread_number, (void **) &counter_number) )
129 if( thread_number >= number_logical_processors )
131 *dvs = LFDS710_MISC_VALIDITY_INVALID_TEST_DATA;
135 if( counter_number > per_thread_counters[thread_number] )
136 *dvs = LFDS710_MISC_VALIDITY_INVALID_MISSING_ELEMENTS;
138 if( counter_number < per_thread_counters[thread_number] )
139 *dvs = LFDS710_MISC_VALIDITY_INVALID_ADDITIONAL_ELEMENTS;
141 if( counter_number == per_thread_counters[thread_number] )
142 per_thread_counters[thread_number]++;
145 lfds710_queue_bmm_cleanup( &qbmms, NULL );
154 /****************************************************************************/
155 static libshared_pal_thread_return_t LIBSHARED_PAL_THREAD_CALLING_CONVENTION thread_simple_enqueuer( void *libtest_threadset_per_thread_state )
160 struct test_per_thread_state
163 struct libtest_threadset_per_thread_state
166 LFDS710_MISC_MAKE_VALID_ON_CURRENT_LOGICAL_CORE_INITS_COMPLETED_BEFORE_NOW_ON_ANY_OTHER_LOGICAL_CORE;
168 LFDS710_PAL_ASSERT( libtest_threadset_per_thread_state != NULL );
170 pts = (struct libtest_threadset_per_thread_state *) libtest_threadset_per_thread_state;
171 tpts = LIBTEST_THREADSET_GET_USER_STATE_FROM_PER_THREAD_STATE( *pts );
173 libtest_threadset_thread_ready_and_wait( pts );
175 while( lfds710_queue_bmm_enqueue(tpts->qbmms, (void *) (tpts->thread_number), (void *) (counter++)) );
177 LFDS710_MISC_BARRIER_STORE;
179 lfds710_misc_force_store();
181 return LIBSHARED_PAL_THREAD_RETURN_CAST(RETURN_SUCCESS);