@@ -77,8 +77,8 @@ void eventual_success_test(void *arg)
7777 if (ret == ABT_SUCCESS ) {
7878 g_success_counter ++ ;
7979 int * result = (int * )value ;
80- ATS_printf (1 , "[U%d:E%d] eventual signaled, value=%d\n" ,
81- ( int ) tid , eid , result ? * result : -1 );
80+ ATS_printf (1 , "[U%d:E%d] eventual signaled, value=%d\n" , ( int ) tid , eid ,
81+ result ? * result : -1 );
8282 } else if (ret == ABT_ERR_COND_TIMEDOUT ) {
8383 ATS_printf (1 , "[U%d:E%d] unexpected timeout\n" , (int )tid , eid );
8484 } else {
@@ -125,8 +125,10 @@ int main(int argc, char *argv[])
125125
126126 xstreams = (ABT_xstream * )malloc (num_xstreams * sizeof (ABT_xstream ));
127127 pools = (ABT_pool * )malloc (num_xstreams * sizeof (ABT_pool ));
128- timeout_threads = (ABT_thread * )malloc (num_timeout_threads * sizeof (ABT_thread ));
129- success_threads = (ABT_thread * )malloc (num_success_threads * sizeof (ABT_thread ));
128+ timeout_threads =
129+ (ABT_thread * )malloc (num_timeout_threads * sizeof (ABT_thread ));
130+ success_threads =
131+ (ABT_thread * )malloc (num_success_threads * sizeof (ABT_thread ));
130132
131133 /* Create an eventual */
132134 ret = ABT_eventual_create (sizeof (int ), & eventual );
@@ -172,7 +174,8 @@ int main(int argc, char *argv[])
172174 ret = ABT_eventual_reset (eventual );
173175 ATS_ERROR (ret , "ABT_eventual_reset" );
174176
175- /* Test 2: Success threads - create threads that wait with future deadline */
177+ /* Test 2: Success threads - create threads that wait with future deadline
178+ */
176179 ATS_printf (1 , "\n=== Test 2: Success test (with signal) ===\n" );
177180 for (i = 0 ; i < num_success_threads ; i ++ ) {
178181 ret = ABT_thread_create (pools [pidx ], eventual_success_test , NULL ,
@@ -191,8 +194,8 @@ int main(int argc, char *argv[])
191194 /* Signal the eventual */
192195 ret = ABT_eventual_set (eventual , & test_value , sizeof (int ));
193196 ATS_ERROR (ret , "ABT_eventual_set" );
194- ATS_printf (1 , "[U%d:E%d] eventual_set with value=%d\n" ,
195- ( int ) tid , eid , test_value );
197+ ATS_printf (1 , "[U%d:E%d] eventual_set with value=%d\n" , ( int ) tid , eid ,
198+ test_value );
196199
197200 /* Wait for success threads to complete */
198201 for (i = 0 ; i < num_success_threads ; i ++ ) {
@@ -214,7 +217,9 @@ int main(int argc, char *argv[])
214217 ret = ABT_eventual_timedwait (eventual , & value , & ts );
215218 if (ret == ABT_SUCCESS ) {
216219 int * result = (int * )value ;
217- ATS_printf (1 , "[U%d:E%d] already ready eventual returned immediately, value=%d\n" ,
220+ ATS_printf (1 ,
221+ "[U%d:E%d] already ready eventual returned immediately, "
222+ "value=%d\n" ,
218223 (int )tid , eid , result ? * result : -1 );
219224 if (result && * result == test_value ) {
220225 ATS_printf (1 , "Value matches expected value\n" );
@@ -253,7 +258,8 @@ int main(int argc, char *argv[])
253258
254259 if (!failed ) {
255260 ATS_printf (1 , "\n=== All tests passed ===\n" );
256- ATS_printf (1 , "Timeouts: %d/%d\n" , g_timeout_counter , expected_timeouts );
261+ ATS_printf (1 , "Timeouts: %d/%d\n" , g_timeout_counter ,
262+ expected_timeouts );
257263 ATS_printf (1 , "Success: %d/%d\n" , g_success_counter , expected_success );
258264 }
259265
0 commit comments