Home My Page Projects Code Snippets Project Openings diderot
Summary Activity Tracker Tasks SCM

SCM Repository

[diderot] Diff of /branches/pure-cfg/src/lib/parallel-target/main.c
[diderot] / branches / pure-cfg / src / lib / parallel-target / main.c  
ViewVC logotype

Diff of /branches/pure-cfg/src/lib/parallel-target/main.c

Parent Directory Parent Directory | Revision Log Revision Log | View Patch Patch

revision 1208, Thu May 12 19:50:53 2011 UTC revision 1209, Thu May 12 21:51:37 2011 UTC
# Line 13  Line 13 
13  #include <assert.h>  #include <assert.h>
14  #include <Diderot/diderot.h>  #include <Diderot/diderot.h>
15  #include <pthread.h>  #include <pthread.h>
16  #include <semaphore.h>  
17    #ifdef HAVE_BUILTIN_ATOMIC_OPS
18    STATIC_INLINE uint32_t AtomicInc (uint32_t *x)
19    {
20        return __sync_add_and_fetch(x, 1);
21    }
22    STATIC_INLINE uint32_t AtomicDec (uint32_t *x)
23    {
24        return __sync_sub_and_fetch(x, 1);
25    }
26    #else
27    #  error atomic operations not supported
28    #endif
29    
30  // The number of strands a worker will take for processing at one time  // The number of strands a worker will take for processing at one time
31  #define BLOCK_SIZE 32  #define BLOCK_SIZE 32
# Line 24  Line 36 
36      int32_t         *base;      // nDims array of base indices      int32_t         *base;      // nDims array of base indices
37      uint32_t        *size;      // nDims array of iteration sizes      uint32_t        *size;      // nDims array of iteration sizes
38      uint32_t        numStrands; // number of strands in the world      uint32_t        numStrands; // number of strands in the world
39      sem_t           numActive;  // number of active strands in the world      uint32_t        numActive;  // number of active strands in the world
40      void            **inState;      void            **inState;
41      void            **outState;      void            **outState;
42      uint8_t         *status;    // array of strand status flags      uint8_t         *status;    // array of strand status flags
# Line 50  Line 62 
62          pthread_mutex_lock(&wrld->lock);          pthread_mutex_lock(&wrld->lock);
63    
64          // If there is no more work to do this iteration, we wait          // If there is no more work to do this iteration, we wait
65          while(wrld->nextStrand == wrld->numStrands)          while(wrld->nextStrand == wrld->numStrands) {
         {  
66              wrld->nWorkers++;              wrld->nWorkers++;
67              if (wrld->nWorkers == wrld->numThreads) {              if (wrld->nWorkers == wrld->numThreads) {
68                  pthread_cond_signal(&wrld->main);                  pthread_cond_signal(&wrld->main);
# Line 126  Line 137 
137      int nWorkers = cpuInfo.numHWCores;      int nWorkers = cpuInfo.numHWCores;
138      pthread_t *workers = (pthread_t *) malloc (nWorkers * sizeof(pthread_t));      pthread_t *workers = (pthread_t *) malloc (nWorkers * sizeof(pthread_t));
139    
140        printf ("initializing %d workers ...\n", nWorkers);
141      wrld->numThreads = nWorkers;      wrld->numThreads = nWorkers;
142      for (int i = 0; i < nWorkers; i++) {      for (int i = 0; i < nWorkers; i++) {
143          pthread_create (&workers[i], NULL, worker_func, wrld);          pthread_create (&workers[i], NULL, worker_func, wrld);
Legend:
Removed from v.1208  
changed lines
  Added in v.1209
root@smlnj-gforge.cs.uchicago.edu
 ViewVC Help
Powered by ViewVC 1.0.0  
Powered By FusionForge