Changeset 1801 in Sophya for trunk/ArchTOIPipe/Kernel/fitstoirdr.cc

Timestamp:

Nov 30, 2001, 4:02:04 PM (24 years ago)

Author:

aubourg

Message:

gph424 parallele

File:

• trunk/ArchTOIPipe/Kernel/fitstoirdr.cc (modified) (4 diffs)

trunk/ArchTOIPipe/Kernel/fitstoirdr.cc

@@ -3 +3 @@
 //                               Christophe Magneville
 //                               Reza Ansari
-// $Id: fitstoirdr.cc,v 1.23 2001-11-29 18:19:32 aubourg Exp $
+// $Id: fitstoirdr.cc,v 1.24 2001-11-30 15:02:04 aubourg Exp $
 
 #include "fitstoirdr.h"
@@ -223 +223 @@
  uint_8 * tmpflg = new uint_8[Buff_Sz];
 
+ TOIManager* mgr = TOIManager::getManager();
+
  //////// Read data and put into pipe
  long ideb=-1,ifin=-1;
@@ -234 +236 @@
      long n = ifin-ideb+1;
      int anyNul;
-     fits_lock();
      if (implicitSN) {
+       if (ideb+implicitSNStart > mgr->getRequestedEnd() 
+           || ideb+implicitSNStart > forcedMaxIn) break;
+       if (ifin+implicitSNStart < mgr->getRequestedBegin()
+           || ifin+implicitSNStart < forcedMinIn) continue;
        for (long j=0; j<Buff_Sz; j++) {
          samplenum[j] = j+ideb+implicitSNStart;
        }
+       fits_lock();
      } else {
+       fits_lock();
        fits_read_col_dbl(fptr,1,ideb+1,1,n,0,samplenum,&anyNul,&fstatus);
+       if (ideb+implicitSNStart > mgr->getRequestedEnd() 
+           || ideb+implicitSNStart > forcedMaxIn) {
+         fits_unlock();
+         break;
+       }
+       if (ifin+implicitSNStart < mgr->getRequestedBegin()
+           || ifin+implicitSNStart < forcedMinIn) {
+         fits_unlock();
+         continue;
+       }
      }
      for(int k=0; k<getNOut(); k++) {
@@ -258 +275 @@
    long ip = i-ideb; // pointeurs dans les buffers
    long sn = (long) (samplenum[ip]+.1);
-   TOIManager* mgr = TOIManager::getManager();
-   if(samplenum[0] > mgr->getRequestedEnd()) break;
-   if(samplenum[0] > forcedMaxIn) break;
-   if(samplenum[ifin-ideb] < mgr->getRequestedBegin()) continue;
-   if(samplenum[ifin-ideb] < forcedMinIn) continue;
    if (ip == 0) { 
      for(int k=0; k<getNOut(); k++) {