80 строки
1.6 KiB
C
80 строки
1.6 KiB
C
/*
|
|
* Copyright (c) 2010 Cisco Systems, Inc. All rights reserved.
|
|
* Copyright (c) 2014 The University of Tennessee and The University
|
|
* of Tennessee Research Foundation. All rights
|
|
* reserved.
|
|
* $COPYRIGHT$
|
|
*/
|
|
|
|
#include "opal_config.h"
|
|
|
|
#include <stdio.h>
|
|
|
|
#include "support.h"
|
|
#include "opal/constants.h"
|
|
#include "opal/threads/threads.h"
|
|
#include "opal/sys/atomic.h"
|
|
|
|
|
|
#if !OPAL_ENABLE_MULTI_THREADS
|
|
|
|
/* If we don't have thread support, there's no point in running this
|
|
test */
|
|
|
|
int main(int argc, char *argv[])
|
|
{
|
|
printf("OMPI was compiled without thread support -- skipping this test\n");
|
|
return 77;
|
|
}
|
|
|
|
#else
|
|
|
|
/* Only have the body of this test if we have thread support */
|
|
|
|
static volatile int count = 0;
|
|
|
|
|
|
static void* thr1_run(opal_object_t* obj)
|
|
{
|
|
(void)opal_atomic_add(&count, 1);
|
|
return NULL;
|
|
}
|
|
|
|
static void* thr2_run(opal_object_t* obj)
|
|
{
|
|
(void)opal_atomic_add(&count, 2);
|
|
return NULL;
|
|
}
|
|
|
|
int main(int argc, char** argv)
|
|
{
|
|
int rc;
|
|
opal_thread_t thr1;
|
|
opal_thread_t thr2;
|
|
|
|
test_init("opal_thread_t");
|
|
|
|
OBJ_CONSTRUCT(&thr1, opal_thread_t);
|
|
OBJ_CONSTRUCT(&thr2, opal_thread_t);
|
|
|
|
thr1.t_run = thr1_run;
|
|
thr2.t_run = thr2_run;
|
|
|
|
rc = opal_thread_start(&thr1);
|
|
test_verify_int(OPAL_SUCCESS, rc);
|
|
|
|
rc = opal_thread_start(&thr2);
|
|
test_verify_int(OPAL_SUCCESS, rc);
|
|
|
|
rc = opal_thread_join(&thr1, NULL);
|
|
test_verify_int(OPAL_SUCCESS, rc);
|
|
|
|
rc = opal_thread_join(&thr2, NULL);
|
|
test_verify_int(OPAL_SUCCESS, rc);
|
|
|
|
test_verify_int(3, count);
|
|
return test_finalize();
|
|
}
|
|
|
|
#endif /* OPAL_ENABLE_MULTI_THREADS */
|