Changeset 18967 for trunk/ppMerge/src/ppMergeSetThreads.c

Timestamp:

Aug 8, 2008, 8:17:12 AM (18 years ago)

Author:

Paul Price

Message:

Fixing following changes to psThread.

File:

• trunk/ppMerge/src/ppMergeSetThreads.c (modified) (5 diffs)

trunk/ppMerge/src/ppMergeSetThreads.c

@@ -2 +2 @@
 
 // "PPMERGE_READOUT_COMBINE", 5
-bool ppMergeThread_pmReadoutCombine (psThreadJob *job) {
+bool ppMergeThread_pmReadoutCombine(const psThreadJob *job)
+{
+    PS_ASSERT_THREAD_JOB_NON_NULL(job, false);
 
     pmReadout *output           = job->args->data[0];
@@ -13 +15 @@
 
     // after we are done, tell the I/O system that this file group is done
-    fileGroup->busy = false; 
+    fileGroup->busy = false;
     return status;
 }
 
-bool ppMergeThread_pmDarkCombine (psThreadJob *job) {
+bool ppMergeThread_pmDarkCombine(const psThreadJob *job)
+{
+    PS_ASSERT_THREAD_JOB_NON_NULL(job, false);
 
     pmCell *outCell             = job->args->data[0];
     ppMergeFileGroup *fileGroup = job->args->data[1];
-    psScalar *iter              = job->args->data[2];
-    psScalar *rej               = job->args->data[3];
-    psScalar *maskVal           = job->args->data[4];
+    psScalar *iter              = job->args->data[2];
+    psScalar *rej               = job->args->data[3];
+    psScalar *maskVal           = job->args->data[4];
 
     bool status = pmDarkCombine(outCell, fileGroup->readouts, iter->data.S32, rej->data.F32, maskVal->data.U8);
@@ -32 +36 @@
 }
 
-bool ppMergeThread_pmShutterCorrectionGenerate (psThreadJob *job) {
+bool ppMergeThread_pmShutterCorrectionGenerate(const psThreadJob *job)
+{
+    PS_ASSERT_THREAD_JOB_NON_NULL(job, false);
 
     pmReadout *output             = job->args->data[0];
@@ -39 +45 @@
     psScalar *shutterRef          = job->args->data[3];
     pmShutterCorrectionData *data = job->args->data[4];
-    psScalar *iter                = job->args->data[5];
-    psScalar *rej                 = job->args->data[6];
-    psScalar *maskVal             = job->args->data[7];
+    psScalar *iter                = job->args->data[5];
+    psScalar *rej                 = job->args->data[6];
+    psScalar *maskVal             = job->args->data[7];
 
     bool status = pmShutterCorrectionGenerate(output, pattern, fileGroup->readouts, shutterRef->data.F32, data, iter->data.S32, rej->data.F32, maskVal->data.U8);
@@ -50 +56 @@
 }
 
-bool ppMergeSetThreads () {
+bool ppMergeSetThreads(void)
+{
 
-    psThreadTask *task = NULL;
+    {
+        psThreadTask *task = psThreadTaskAlloc("PPMERGE_READOUT_COMBINE", 5);
+        task->function = &ppMergeThread_pmReadoutCombine;
+        psThreadTaskAdd(task);
+        psFree(task);
+    }
 
-    task = psThreadTaskAlloc ("PPMERGE_READOUT_COMBINE", 5);
-    task->function = &ppMergeThread_pmReadoutCombine;
-    psThreadTaskAdd (task);
+    {
+        psThreadTask *task = psThreadTaskAlloc("PPMERGE_DARK_COMBINE", 5);
+        task->function = &ppMergeThread_pmDarkCombine;
+        psThreadTaskAdd(task);
+        psFree(task);
+    }
 
-    task = psThreadTaskAlloc ("PPMERGE_DARK_COMBINE", 5);
-    task->function = &ppMergeThread_pmDarkCombine;
-    psThreadTaskAdd (task);
-
-    task = psThreadTaskAlloc ("PPMERGE_SHUTTER_CORRECTION", 8);
-    task->function = &ppMergeThread_pmShutterCorrectionGenerate;
-    psThreadTaskAdd (task);
+    {
+        psThreadTask *task = psThreadTaskAlloc("PPMERGE_SHUTTER_CORRECTION", 8);
+        task->function = &ppMergeThread_pmShutterCorrectionGenerate;
+        psThreadTaskAdd(task);
+        psFree(task);
+    }
 
     return true;