Changeset 18757 for trunk/ppMerge/src/ppMergeArguments.c

Timestamp:

Jul 27, 2008, 6:06:03 PM (18 years ago)

Author:

eugene

Message:

adding multithreading capability

File:

• trunk/ppMerge/src/ppMergeArguments.c (modified) (2 diffs)

trunk/ppMerge/src/ppMergeArguments.c

@@ -1 @@
-#ifdef HAVE_CONFIG_H
-#include <config.h>
-#endif
-
-#include <stdio.h>
-#include <string.h>
-#include <strings.h>
-#include <pslib.h>
-#include <psmodules.h>
-
 #include "ppMerge.h"
 
@@ -179 +169 @@
         psMetadataAddStr (config->arguments, PS_LIST_TAIL, "CELL_SELECTIONS", PS_DATA_STRING, "", argv[argnum]);
         psArgumentRemove (argnum, &argc, argv);
+    }
+
+    // Number of threads
+    if ((argnum = psArgumentGet(argc, argv, "-threads"))) {
+        psArgumentRemove(argnum, &argc, argv);
+        int nThreads = atoi(argv[argnum]);
+        psMetadataAddS32(config->arguments, PS_LIST_TAIL, "NTHREADS", 0, "number of warp threads", nThreads);
+        psArgumentRemove(argnum, &argc, argv);
+
+        // create the thread pool with number of desired threads, supplying our thread launcher function
+        // XXX need to determine the number of threads from the config data
+        psThreadPoolInit (nThreads, &ppMergeThreadLauncher);
     }