examples/locks_pthreads.c File Reference

Include dependency graph for examples/locks_pthreads.c:

Go to the source code of this file.

Macros
#define	ERROR_RETURN(retval)   { fprintf(stderr, "Error %d %s:line %d: \n", retval,__FILE__,__LINE__); exit(retval); }
#define	LOOPS   100000
#define	SLEEP_VALUE   20000

Functions
void *	Master (void *arg)
void *	Slave (void *arg)
int	main (int argc, char **argv)

Variables
int	count
int	rank

Macro Definition Documentation

ERROR_RETURN

#define ERROR_RETURN

(

retval

)

{ fprintf(stderr, "Error %d %s:line %d: \n", retval,__FILE__,__LINE__); exit(retval); }

Definition at line 13 of file examples/locks_pthreads.c.

LOOPS

#define LOOPS   100000

Definition at line 15 of file examples/locks_pthreads.c.

SLEEP_VALUE

#define SLEEP_VALUE   20000

Definition at line 16 of file examples/locks_pthreads.c.

Function Documentation

main()

int main	(	int	argc,
		char **	argv
	)

Definition at line 73 of file examples/locks_pthreads.c.

{
   pthread_t master;
   pthread_t slave1;
   int result_m, result_s, rc, i;
   int retval;

   /* Setup a random number so compilers can't optimize it out */
   count = rand();
   result_m = count;
   rank = 0;

   for (i = 0; i < LOOPS; i++) {
      result_m = 2 * result_m - i;
   }
   result_s = result_m;

   for (i = 0; i < LOOPS; i++) {
      result_s += i;
   }

   if ((retval = PAPI_library_init(PAPI_VER_CURRENT)) != PAPI_VER_CURRENT)
   {
      printf("Library initialization error! \n");
      exit(-1);
   }

   if ((retval = PAPI_thread_init(&pthread_self)) != PAPI_OK)
     ERROR_RETURN(retval);

   if ((retval = PAPI_set_debug(PAPI_VERB_ECONT)) != PAPI_OK)
      ERROR_RETURN(retval);

   PAPI_lock(PAPI_USR2_LOCK);
   rc = pthread_create(&master, NULL, Master, NULL);
   if (rc) {
      retval = PAPI_ESYS;
      ERROR_RETURN(retval);
   }
   rc = pthread_create(&slave1, NULL, Slave, NULL);
   if (rc) {
      retval = PAPI_ESYS;
      ERROR_RETURN(retval);
   }
   pthread_join(master, NULL);
   printf("Master: Expected: %d  Recieved: %d\n", result_m, count);
   if (result_m != count)
      ERROR_RETURN(1);
   PAPI_unlock(PAPI_USR2_LOCK);

   pthread_join(slave1, NULL);
   printf("Slave: Expected: %d  Recieved: %d\n", result_s, count);

   if (result_s != count)
      ERROR_RETURN(1);

   exit(0);
}

Here is the call graph for this function:

Master()

void* Master

(

void *

arg

)

Definition at line 21 of file examples/locks_pthreads.c.

{
   int i, retval, tmp;
   int *pointer, * pointer2;

   tmp = 20;
   pointer = &tmp;

   /* register the thread */
   if ( (retval=PAPI_register_thread())!= PAPI_OK )
      ERROR_RETURN(retval);
   
   /* save the pointer for late use */
   if ( (retval=PAPI_set_thr_specific(1,pointer))!= PAPI_OK )
      ERROR_RETURN(retval);
   /* change the value of tmp */
   tmp = 15;

   usleep(SLEEP_VALUE);
   PAPI_lock(PAPI_USR1_LOCK);
   /* Make sure Slaves are not sleeping */
   for (i = 0; i < LOOPS; i++) {
      count = 2 * count - i;
   }
   PAPI_unlock(PAPI_USR1_LOCK);

   /* retrieve the pointer saved by PAPI_set_thr_specific */
   if ( (retval=PAPI_get_thr_specific(1, (void *)&pointer2)) != PAPI_OK )
      ERROR_RETURN(retval);

   /* the output value should be 15 */
   printf("Thread specific data is %d \n", *pointer2);
   
   pthread_exit(NULL);
}

Here is the call graph for this function:

Here is the caller graph for this function:

Slave()

void* Slave

(

void *

arg

)

Definition at line 57 of file examples/locks_pthreads.c.

{
   int i;

   PAPI_lock(PAPI_USR2_LOCK);
   PAPI_lock(PAPI_USR1_LOCK);
   for (i = 0; i < LOOPS; i++) {
      count += i;
   }
   PAPI_unlock(PAPI_USR1_LOCK);
   PAPI_unlock(PAPI_USR2_LOCK);
   pthread_exit(NULL);
}

Here is the call graph for this function:

Here is the caller graph for this function:

Variable Documentation

count

int count

Definition at line 18 of file examples/locks_pthreads.c.

rank

int rank

Definition at line 19 of file examples/locks_pthreads.c.