Changeset 1464 in Sophya for trunk/ArchTOIPipe/Kernel


Ignore:
Timestamp:
Apr 11, 2001, 12:01:44 PM (24 years ago)
Author:
ansari
Message:

1) Fin de passage des flags en int_8
2) TOIRegularWindow mis ds un fichier spare , Reza 11/4/2001

Location:
trunk/ArchTOIPipe/Kernel
Files:
2 added
8 edited

Legend:

Unmodified
Added
Removed

  • trunk/ArchTOIPipe/Kernel/asciitoiwtr.cc

    r1462 r1464  
    4040
    4141  double val;
    42   int_4 flg;
     42  int_8 flg;
    4343  for (int sn = snb; sn <= sne; sn++) {
    4444    s << sn << "   ";

  • trunk/ArchTOIPipe/Kernel/fitstoiwtr.cc

    r1462 r1464  
    5656  char** colunits = new (char*[ncols]);
    5757
    58   colnames[0] = "samplenum";
     58  colnames[0] = "sampleNum";
    5959  coltypes[0] = "1D";
    6060  colunits[0] = "integer";
    … …  
    7979      cout << " Column[" << j+1 << "] -Flag- Name=" << coln[ck] << endl;
    8080      ck++;
    81       coltypes[j+2] = "1D";
    82       colunits[j+2] = "IntFlag";
     81      coltypes[j+2] = "1J";
     82      colunits[j+2] = "Int_8Flag";
    8383    }
    8484  }
    … …  
    102102
    103103  double* tabdata = new double[ndata];
    104   double* tabflag = new double[ndata]; // ? pas integer ?? $CHECK$ - Reza
     104  long* tabflag = new long[ndata]; // ? pas int_8 ?? $CHECK$ - Reza
    105105  bool* tabck = new bool[ndata];
    106106  int i;
    107107  for(i=0; i<ndata; i++) {
    108108    tabdata[i] = -9.e19;  // $CHECK$ - Reza valeur par defaut !
    109     tabflag[i] = -9.e19;  // $CHECK$ - Reza valeur par defaut !
     109    tabflag[i] = 0;       // $CHECK$ - Reza valeur par defaut !
    110110    tabck[i] = checkInputTOIIndex(i);
    111111  }
    … …  
    115115    //  cout << " DBG-A-FitsWriter::run()" << sn << endl;
    116116    try {
    117       int_4 out_flg;
     117      int_8 out_flg;
    118118      double out_val;
    119119      for (i=0; i<ndata; i++) {
    … …  
    133133        if (outFlags) {
    134134          fits_write_col_dbl(fptr, 2*i+2, fitsLine, 1, 1, tabdata+i, &fstatus);
    135           fits_write_col_dbl(fptr, 2*i+3, fitsLine, 1, 1, tabflag+i, &fstatus);
     135          fits_write_col_lng(fptr, 2*i+3, fitsLine, 1, 1, tabflag+i, &fstatus);
    136136        } else {
    137137          fits_write_col_dbl(fptr, i+2, fitsLine, 1, 1, tabdata+i, &fstatus);

  • trunk/ArchTOIPipe/Kernel/toi.cc

    r1462 r1464  
    99#endif
    1010
    11 #define CHKSYNC(ctx) 
    12 //  if (((TOIRegularWindow*)this)->data.size() != ((TOIRegularWindow*)this)->flags.size())        \
    13 //    cout << ctx << ((TOIRegularWindow*)this)->data.size() << "  " <<  \
    14 //      ((TOIRegularWindow*)this)->flags.size() << endl;  \
    1511
    1612TOI::TOI() {
    … …  
    7369}
    7470
    75 #ifndef NO_SOPHYA
     71/*
     72 RZCMV   ----- l'interface va etre modifiee, NE PAS UTILISER
     73#ifndef NO_SOPHYA
    7674Array TOI::getError(int iStart, int iEnd) {
    7775  if (errorTOI == NULL) throw NotFoundExc("TOI::getDataError : no Error TOI");
    78   return errorTOI->getData(iStart, iEnd);
     76  return errorTOI->getData(iStart, iEnd);
     77}
     78Array TOI::getData(int iStart, int iEnd) {
     79  lock();
     80  Array a = doGetData(iStart, iEnd);
     81  unlock();
     82  if (fgsigput) { fgsigput = false; broadcast(); }
     83  return a;
     84}
     85TArray<int_4> TOI::getFlag(int iStart, int iEnd) {
     86  lock();
     87  TArray<int_4> a = doGetFlag(iStart, iEnd);
     88  unlock();
     89  if (fgsigput) { fgsigput = false; broadcast(); }
     90  return a;
    7991}
    8092#endif
    81 
    82 /*RZCMV
     93  l'interface va etre modifiee, NE PAS UTILISER ----
     94*/
     95
     96
     97/*
     98RZCMV  -------   A revoir les getError() ...
    8399double TOI::getError(int i) {
    84100  if (errorTOI == NULL) throw NotFoundExc("TOI::getDataError : no Error TOI");
    … …  
    94110*/
    95111
    96 #ifndef NO_SOPHYA
    97 Array TOI::getData(int iStart, int iEnd) {
    98   lock();
    99   Array a = doGetData(iStart, iEnd);
    100   unlock();
    101   if (fgsigput) { fgsigput = false; broadcast(); }
    102   return a;
    103 }
    104 #endif
    105 
    106112double TOI::getData(int i) {
    107113  lock();
    108   int_4 flg;
     114  int_8 flg;
    109115  double dat;
    110116  doGetData(i, dat, flg);
    … …  
    114120}
    115121
    116 void TOI::getData(int i, double &data,int_4 &flag) {
     122void TOI::getData(int i, double &data,int_8 &flag) {
    117123  lock();
    118124  doGetData(i, data, flag);
    … …  
    122128}
    123129
    124 
    125 
    126 #ifndef NO_SOPHYA
    127 TArray<int_4> TOI::getFlag(int iStart, int iEnd) {
    128   lock();
    129   TArray<int_4> a = doGetFlag(iStart, iEnd);
    130   unlock();
    131   if (fgsigput) { fgsigput = false; broadcast(); }
    132   return a;
    133 }
    134 #endif
    135 
    136130 
    137  
    138 
    139 void TOI::putData(int i, double value, int_4 flag) {
     131
     132void TOI::putData(int i, double value, int_8 flag) {
    140133  lock();
    141134  doPutData(i, value, flag);
    … …  
    208201
    209202
    210 TOIRegularWindow::TOIRegularWindow() {
    211   i0 = -1;
    212 }
    213 
    214 TOIRegularWindow::TOIRegularWindow(string nm) {
    215   i0 = -1;
    216   setName(nm);
    217 }
    218 
    219 TOIRegularWindow::~TOIRegularWindow() {
    220 }
    221 
    222 TOI::DataStatus TOIRegularWindow::isDataAvailNL(int iStart, int iEnd) {
    223   if (iEnd >= i0 + (long)data.size()) return DATA_NOT_YET;
    224   if (iStart < i0) return DATA_DELETED;
    225   return DATA_OK;
    226 }
    227 
    228 TOI::DataStatus TOIRegularWindow::isDataAvailNL(int i) {
    229   return TOI::isDataAvailNL(i);
    230 }
    231 
    232 void TOIRegularWindow::doWontNeedBefore(int i) {
    233   if (i>= i0 + (long)data.size())
    234     i = i0 + (long)data.size() - 1;
    235   if (i>i0) {  // don't empty list
    236     int osz = data.size();
    237     data.erase(data.begin(), data.begin()+(i-i0));
    238     flags.erase(flags.begin(), flags.begin()+(i-i0));
    239     i0 = i;
    240   }
    241 }
    242 
    243 
    244 #ifndef NO_SOPHYA
    245 Array TOIRegularWindow::doGetData(int iStart, int iEnd) {
    246   if (!isDataAvailNL(iStart, iEnd)) {
    247     throw RangeCheckError("TOI::getData : data not available");
    248   }
    249   Array dat(iEnd - iStart + 1);
    250   long j0 = iStart - i0;
    251   for (int i=0; i<iEnd-iStart+1; i++) {
    252     dat[i] = data[i+j0];
    253   }
    254   return dat;
    255 }
    256 #endif
    257 
    258 void TOIRegularWindow::doGetData(int i, double & val, int_4 & flg) {
    259   if (isDataAvailNL(i) != DATA_OK) {
    260     cerr << "TOI::getData : data not available " << i << endl;
    261     throw RangeCheckError("TOI::getData : data not available");
    262   }
    263 
    264   val = data[i - i0];
    265   flg = flags[i - i0];
    266 
    267 }
    268 
    269 
    270 #ifndef NO_SOPHYA
    271 TArray<int_4> TOIRegularWindow::doGetFlag(int iStart, int iEnd) {
    272   if (isDataAvailNL(iStart, iEnd) != DATA_OK) throw RangeCheckError("TOI::getData : data not available");
    273   TArray<int_4> dat(iEnd - iStart + 1);
    274   long j0 = iStart - i0;
    275   for (int i=0; i<iEnd-iStart+1; i++) {
    276     dat[i] = flags[i+j0];
    277   }
    278   return dat;
    279 }
    280 #endif
    281 
    282 /*RZCMV
    283 int_4 TOIRegularWindow::doGetFlag(int i) {
    284   if (isDataAvailNL(i) != DATA_OK) {
    285     cerr << "TOI::getFlag : data not available " << i << endl;
    286     throw RangeCheckError("TOI::getFlag : data not available");
    287   }
    288   return flags[i - i0];
    289 }
    290 */
    291 
    292 
    293 void TOIRegularWindow::doPutData(int i, double value, int_4 flag) {
    294   if (i0 == -1) {
    295     data.insert(data.begin(), 1,  defaultValue);
    296     flags.insert(flags.begin(), 1,  0);
    297     i0 = i;
    298   } else if (i<i0) {
    299     data.insert(data.begin(), i0-i, defaultValue);
    300     flags.insert(flags.begin(), i0-i, 0);
    301     i0 = i;
    302   } else if (i>=i0+(int)data.size()) {
    303     data.insert(data.end(), (long)  (i-(i0+data.size())+1), defaultValue);
    304     flags.insert(flags.end(), (long) (i-(i0+flags.size())+1), 0);
    305   }
    306   data[i-i0] = value;
    307   flags[i-i0] = flag; 
    308 }
    309 
    310 bool TOIRegularWindow::hasSomeData() {
    311   lock();
    312   bool x = !data.empty();
    313   unlock();
    314   return x;
    315 }
    316 
    317 int TOIRegularWindow::nextDataAvail(int iAfter) {
    318   lock();
    319   if (iAfter >= i0 + (long)data.size()) {unlock(); return -1;}
    320   if (iAfter < i0) {unlock(); return i0;}
    321   unlock();
    322   return iAfter+1;
    323 }
    324 
    325 /*  A faire, le nettoyage (heuristique selon demandes ?, guide ? ) */
    326                  
    327 

  • trunk/ArchTOIPipe/Kernel/toi.h

    r1462 r1464  
    66
    77#include <pthread.h>
    8 #include <vector>
    9 using namespace std;
    108
    119#ifdef WITH_SOPHYA
    … …  
    3129  //  Fin rajouts Reza 12/3/2001 ------
    3230
     31
    3332#ifdef WITH_SOPHYA
    34   // l'interface va etre modifiee, NE PAS UTILISER
     33  /* l'interface va etre modifiee, NE PAS UTILISER
    3534  virtual Array         getData(int iStart, int iEnd);
    3635  virtual Array         getError(int iStart, int iEnd);
    3736  virtual TArray<int_4> getFlag(int iStart, int iEnd);
    38   // l'interface va etre modifiee, NE PAS UTILISER
     37  l'interface va etre modifiee, NE PAS UTILISER */
    3938#endif
    4039
    … …  
    4241   
    4342  virtual double        getData(int i);
    44   virtual void          getData(int i,double &data,int_4 &flag);
     43  virtual void          getData(int i,double &data,int_8 &flag);
    4544  //RZCMV  virtual DataStatus    getDataError(int i,double &data,double &error,int_4 &flag);
    4645
    … …  
    5352  virtual bool          hasSomeData()=0;
    5453 
    55   virtual void          putData(int i, double value, int_4 flag=0);
     54  virtual void          putData(int i, double value, int_8 flag=0);
    5655  //RZCMV  virtual void          putDataError(int i, double value,
    5756  //                                 double error, int_4 flag=0);
    … …  
    8281 
    8382#ifdef WITH_SOPHYA
     83  /* l'interface va etre modifiee, NE PAS UTILISER
    8484  virtual Array         doGetData(int iStart, int iEnd)=0;
    8585  virtual TArray<int_4> doGetFlag(int iStart, int iEnd)=0;
     86  l'interface va etre modifiee, NE PAS UTILISER */
    8687#endif
    87   virtual void          doGetData(int i, double& data, int_4& flag)=0;
    88   virtual void          doPutData(int i, double value, int_4 flag=0)=0;
     88
     89  virtual void          doGetData(int i, double& data, int_8& flag)=0;
     90  virtual void          doPutData(int i, double value, int_8 flag=0)=0;
    8991  virtual void          doWontNeedBefore(int i);
    9092
    … …  
    135137};
    136138
    137 // Classe de TOI avec une fenetre glissante, et echantillonnage regulier.
    138 // Pour le moment au moins,
    139 // il faut que les providers fassent arriver les donnees par samplenum croissant.
    140 class TOIRegularWindow : public TOIRegular {
    141 public:
    142   TOIRegularWindow();
    143   TOIRegularWindow(string nm);
    144   virtual ~TOIRegularWindow();
    145 
    146   virtual DataStatus isDataAvailNL(int iStart, int iEnd);
    147   virtual DataStatus isDataAvailNL(int i); // override required
    148 
    149 
    150 //protected:
    151   vector<double> data;
    152   vector<int_4>  flags;
    153   long          i0;
    154   double defaultValue;
    155  
    156 #ifdef WITH_SOPHYA
    157   virtual Array         doGetData(int iStart, int iEnd);
    158   virtual TArray<int_4> doGetFlag(int iStart, int iEnd);
    159 #endif
    160   virtual void          doGetData(int i, double & val, int_4 & flg);
    161    
    162   virtual void          doPutData(int i, double value, int_4 flag=0);
    163   virtual void          doWontNeedBefore(int i);
    164 
    165   virtual int           nextDataAvail(int iAfter);
    166   virtual bool          hasSomeData();
    167 };
    168139
    169140#endif

  • trunk/ArchTOIPipe/Kernel/toiprocessor.cc

    r1462 r1464  
    259259
    260260#ifndef NO_SOPHYA
     261/* ---- l'interface va etre modifiee, NE PAS UTILISER
    261262Array TOIProcessor::getData(int toiIndex, int iStart, int iEnd) {
    262263  TOI* toi = getInputTOI(toiIndex);
    … …  
    276277  return toi->getFlag(iStart, iEnd);
    277278}
     279       l'interface va etre modifiee, NE PAS UTILISER ---- */
    278280#endif
    279281
    … …  
    284286}
    285287
    286 void  TOIProcessor::getData(int toiIndex, int i, double &data,int_4 &flag)
     288void  TOIProcessor::getData(int toiIndex, int i, double &data,int_8 &flag)
    287289{
    288290  TOI* toi = getInputTOI(toiIndex);
    … …  
    337339
    338340
    339 void TOIProcessor::putData(int toiIndex, int i, double value, int_4 flg) {
     341void TOIProcessor::putData(int toiIndex, int i, double value, int_8 flg) {
    340342  TOI* toi = getOutputTOI(toiIndex);
    341343  toi->putData(i, value, flg);

  • trunk/ArchTOIPipe/Kernel/toiprocessor.h

    r1462 r1464  
    4343protected:
    4444#ifndef NO_SOPHYA
     45  /* ---- l'interface va etre modifiee, NE PAS UTILISER
    4546  Array         getData(int toiIndex, int iStart, int iEnd);
    4647  Array         getError(int toiIndex, int iStart, int iEnd);
    4748  TArray<int_4> getFlag(int toiIndex, int iStart, int iEnd);
     49          l'interface va etre modifiee, NE PAS UTILISER ---- */
    4850#endif
    4951  // si multiple input (indexed input), tableau 2D.
    … …  
    5254  // utilisees que sur des entrees simples
    5355  double        getData(int toiIndex, int i);
    54   void          getData(int toiIndex, int i, double &data,int_4 &flag);
     56  void          getData(int toiIndex, int i, double &data,int_8 &flag);
    5557 
    5658  //RZCMV  double        getError(int toiIndex, int i);
    … …  
    6163  void          setNeededHistory(int nsamples); // -1 : disable
    6264
    63   void          putData(int toiIndex, int i, double value, int_4 flag=0);
     65  void          putData(int toiIndex, int i, double value, int_8 flag=0);
    6466  //RZCMV  void          putDataError(int toiIndex, int i, double value,
    6567  //RZCMV                            double error, int_4 flag=0);

  • trunk/ArchTOIPipe/Kernel/toiseqbuff.cc

    r1462 r1464  
    3030  buffsize = 2*wsz;
    3131  data = new double[buffsize];
    32   flags = new int_4[buffsize];
     32  flags = new int_8[buffsize];
    3333  for(int k=0; k<buffsize; k++) {
    3434    data[k] = defaultValue;
    … …  
    7777
    7878#ifndef NO_SOPHYA
     79/* ---- l'interface va etre modifiee, NE PAS UTILISER
    7980Array TOISeqBuffered::doGetData(int iStart, int iEnd) {
    8081  //  if (iEnd < iStart)
    … …  
    9495  return dat;
    9596}
     97  l'interface va etre modifiee, NE PAS UTILISER ---- */
    9698#endif
    9799
    98 void TOISeqBuffered::doGetData(int i, double & val, int_4 & flg) {
     100void TOISeqBuffered::doGetData(int i, double & val, int_8 & flg) {
    99101  if (!started) {
    100102    cout << " TOISeqBuffered::doGetData() - waitGet() Waiting for start ... " << endl;
    … …  
    137139
    138140#ifndef NO_SOPHYA
     141/* ---- l'interface va etre modifiee, NE PAS UTILISER
    139142TArray<int_4> TOISeqBuffered::doGetFlag(int iStart, int iEnd) {
    140143  if (!started) waitGet();
    … …  
    148151  return dat;
    149152}
     153  l'interface va etre modifiee, NE PAS UTILISER ---- */
    150154#endif
    151155
    … …  
    163167
    164168
    165 void TOISeqBuffered::doPutData(int i, double value, int_4 flag) {
     169void TOISeqBuffered::doPutData(int i, double value, int_8 flag) {
    166170  if (!started) {
    167171    first_in = next_in = i;
    … …  
    217221}
    218222
    219 /*  A faire, le nettoyage (heuristique selon demandes ?, guide ? ) */
    220223                 
    221224

  • trunk/ArchTOIPipe/Kernel/toiseqbuff.h

    r1462 r1464  
    3030protected:
    3131  double* data;
    32   int_4*  flags;
     32  int_8*  flags;
    3333  int wsize;
    3434  int buffsize;
    … …  
    4444
    4545#ifdef WITH_SOPHYA
     46  /* ---- l'interface va etre modifiee, NE PAS UTILISER
    4647  virtual Array         doGetData(int iStart, int iEnd);
    4748  virtual TArray<int_4> doGetFlag(int iStart, int iEnd);
     49  l'interface va etre modifiee, NE PAS UTILISER ---- */
    4850#endif
    49   virtual void          doGetData(int i, double & val, int_4 & flg);
     51  virtual void          doGetData(int i, double & val, int_8 & flg);
    5052   
    51   virtual void          doPutData(int i, double value, int_4 flag=0);
     53  virtual void          doPutData(int i, double value, int_8 flag=0);
    5254  virtual void          doWontNeedBefore(int i);
    5355
    … …  
    5658
    5759  inline double &       dataRef(int i) { return data[i%buffsize]; }
    58   inline int_4 &        flagRef(int i) { return flags[i%buffsize]; }
     60  inline int_8 &        flagRef(int i) { return flags[i%buffsize]; }
    5961  inline bool           isDataDeleted(int i)
    6062    { return((i < next_in-buffsize-1) ? true : false); }
Note: See TracChangeset for help on using the changeset viewer.