2 #include "libtest_tests_internal.h"
7 struct lfds710_list_asu_element
15 struct test_per_thread_state
18 number_elements_per_thread;
20 struct lfds710_list_asu_state
27 /***** private prototypes *****/
28 static libshared_pal_thread_return_t LIBSHARED_PAL_THREAD_CALLING_CONVENTION new_start_thread( void *libtest_threadset_per_thread_state );
34 /****************************************************************************/
35 void libtest_tests_list_asu_new_start( struct lfds710_list_asu_state *list_of_logical_processors, struct libshared_memory_state *ms, enum lfds710_misc_validity *dvs )
40 number_elements_per_thread,
41 number_logical_processors,
45 struct lfds710_list_asu_element
48 struct lfds710_list_asu_state
51 struct lfds710_misc_validation_info
58 struct libtest_logical_processor
61 struct libtest_threadset_per_thread_state
64 struct libtest_threadset_state
67 struct test_per_thread_state
70 LFDS710_PAL_ASSERT( list_of_logical_processors != NULL );
71 LFDS710_PAL_ASSERT( ms != NULL );
72 LFDS710_PAL_ASSERT( dvs != NULL );
74 /* TRD : run one thread per logical processor
76 each thread loops, calling lfds710_list_asu_new_element_by_position( LFDS710_LIST_ASU_POSITION_START )
77 data element contain s thread_number and element_number
78 verification should show element_number decreasing on a per thread basis
81 *dvs = LFDS710_MISC_VALIDITY_VALID;
83 lfds710_list_asu_query( list_of_logical_processors, LFDS710_LIST_ASU_QUERY_GET_POTENTIALLY_INACCURATE_COUNT, NULL, (void **) &number_logical_processors );
84 tpts = libshared_memory_alloc_from_unknown_node( ms, sizeof(struct test_per_thread_state) * number_logical_processors, LFDS710_PAL_ATOMIC_ISOLATION_IN_BYTES );
85 pts = libshared_memory_alloc_from_unknown_node( ms, sizeof(struct libtest_threadset_per_thread_state) * number_logical_processors, LFDS710_PAL_ATOMIC_ISOLATION_IN_BYTES );
86 per_thread_counters = libshared_memory_alloc_from_unknown_node( ms, sizeof(lfds710_pal_uint_t) * number_logical_processors, LFDS710_PAL_ATOMIC_ISOLATION_IN_BYTES );
87 element_array = libshared_memory_alloc_largest_possible_array_from_unknown_node( ms, sizeof(struct test_element), LFDS710_PAL_ATOMIC_ISOLATION_IN_BYTES, &number_elements );
89 number_elements_per_thread = number_elements / number_logical_processors;
91 lfds710_list_asu_init_valid_on_current_logical_core( &lasus, NULL );
93 for( loop = 0 ; loop < number_logical_processors ; loop++ )
94 for( subloop = 0 ; subloop < number_elements_per_thread ; subloop++ )
96 (element_array+(loop*number_elements_per_thread)+subloop)->thread_number = loop;
97 (element_array+(loop*number_elements_per_thread)+subloop)->element_number = subloop;
100 libtest_threadset_init( &ts, NULL );
104 while( LFDS710_LIST_ASU_GET_START_AND_THEN_NEXT(*list_of_logical_processors,lasue) )
106 lp = LFDS710_LIST_ASU_GET_VALUE_FROM_ELEMENT( *lasue );
108 (tpts+loop)->lasus = &lasus;
109 (tpts+loop)->element_array = element_array + (loop*number_elements_per_thread);
110 (tpts+loop)->number_elements_per_thread = number_elements_per_thread;
112 libtest_threadset_add_thread( &ts, &pts[loop], lp, new_start_thread, &tpts[loop] );
117 LFDS710_MISC_BARRIER_STORE;
119 lfds710_misc_force_store();
121 // TRD : run the test
122 libtest_threadset_run( &ts );
124 libtest_threadset_cleanup( &ts );
126 /* TRD : validate the resultant list
127 iterate over each element
128 we expect to find element numbers increment on a per thread basis
131 LFDS710_MISC_BARRIER_LOAD;
133 vi.min_elements = vi.max_elements = number_elements_per_thread * number_logical_processors;
135 lfds710_list_asu_query( &lasus, LFDS710_LIST_ASU_QUERY_SINGLETHREADED_VALIDATE, &vi, dvs );
137 for( loop = 0 ; loop < number_logical_processors ; loop++ )
138 *(per_thread_counters+loop) = number_elements_per_thread - 1;
142 while( *dvs == LFDS710_MISC_VALIDITY_VALID and LFDS710_LIST_ASU_GET_START_AND_THEN_NEXT(lasus, lasue) )
144 element = LFDS710_LIST_ASU_GET_VALUE_FROM_ELEMENT( *lasue );
146 if( element->thread_number >= number_logical_processors )
148 *dvs = LFDS710_MISC_VALIDITY_INVALID_TEST_DATA;
152 if( element->element_number < per_thread_counters[element->thread_number] )
153 *dvs = LFDS710_MISC_VALIDITY_INVALID_MISSING_ELEMENTS;
155 if( element->element_number > per_thread_counters[element->thread_number] )
156 *dvs = LFDS710_MISC_VALIDITY_INVALID_ADDITIONAL_ELEMENTS;
158 if( element->element_number == per_thread_counters[element->thread_number] )
159 per_thread_counters[element->thread_number]--;
162 lfds710_list_asu_cleanup( &lasus, NULL );
171 /****************************************************************************/
172 static libshared_pal_thread_return_t LIBSHARED_PAL_THREAD_CALLING_CONVENTION new_start_thread( void *libtest_threadset_per_thread_state )
177 struct libtest_threadset_per_thread_state
180 struct test_per_thread_state
183 LFDS710_MISC_MAKE_VALID_ON_CURRENT_LOGICAL_CORE_INITS_COMPLETED_BEFORE_NOW_ON_ANY_OTHER_LOGICAL_CORE;
185 LFDS710_PAL_ASSERT( libtest_threadset_per_thread_state != NULL );
187 pts = (struct libtest_threadset_per_thread_state *) libtest_threadset_per_thread_state;
188 tpts = LIBTEST_THREADSET_GET_USER_STATE_FROM_PER_THREAD_STATE( *pts );
190 libtest_threadset_thread_ready_and_wait( pts );
192 for( loop = 0 ; loop < tpts->number_elements_per_thread ; loop++ )
194 LFDS710_LIST_ASU_SET_KEY_IN_ELEMENT( (tpts->element_array+loop)->lasue, tpts->element_array+loop );
195 LFDS710_LIST_ASU_SET_VALUE_IN_ELEMENT( (tpts->element_array+loop)->lasue, tpts->element_array+loop );
196 lfds710_list_asu_insert_at_position( tpts->lasus, &(tpts->element_array+loop)->lasue, NULL, LFDS710_LIST_ASU_POSITION_START );
199 LFDS710_MISC_BARRIER_STORE;
201 lfds710_misc_force_store();
203 return LIBSHARED_PAL_THREAD_RETURN_CAST(RETURN_SUCCESS);