Changeset 1437 in Sophya for trunk/ArchTOIPipe/Kernel/toiprocessor.cc

Timestamp:

Mar 12, 2001, 7:00:28 PM (25 years ago)

Author:

ansari

Message:

Protections diverses dans TOIProcessor et FITSTOIReader/Writer
Ajout d'un TOI (TOISeqBuffered) avec gestion d'un buffer entre put/get
Ajout de processeurs de test (RZTOIProc...) , programme test associe
et SMakefile (pour compil avec SOPHYA)

Reza 12/3/2001

File:

• trunk/ArchTOIPipe/Kernel/toiprocessor.cc (modified) (12 diffs)

trunk/ArchTOIPipe/Kernel/toiprocessor.cc

@@ -44 +44 @@
 
 void TOIProcessor::afterinit() {
+  int i;
   inTOIs = new (TOI*[inIx.size()]);
+  for(i=0; i<inIx.size(); i++) 
+    inTOIs[i] = NULL;
   outTOIs = new (TOI*[outIx.size()]);
+  for(i=0; i<outIx.size(); i++) 
+    outTOIs[i] = NULL;
 }
 
@@ -123 +128 @@
 }
 
+//  Methodes rajoutees par Reza 11/3/2001
+TOI* TOIProcessor::getInputTOI(int toiIndex) {
+  //  chkinit();
+  if (toiIndex >= inIx.size()) 
+    throw RangeCheckError("TOIProcessor::getInputTOI() out of bound toiIndex");
+  TOI* toi = inTOIs[toiIndex];
+  if (toi == NULL) 
+    throw NullPtrError("TOIProcessor::getInputTOI() - Not assigned TOI !");
+  return(toi);
+}
+
+TOI* TOIProcessor::getOutputTOI(int toiIndex) {
+  //  chkinit();
+  if (toiIndex >= outIx.size()) 
+    throw RangeCheckError("TOIProcessor::getOutputTOI() out of bound toiIndex");
+  TOI* toi = outTOIs[toiIndex];
+  if (toi == NULL) 
+    throw NullPtrError("TOIProcessor::getOutputTOI() - Not assigned TOI !");
+  return(toi);
+}
+
+bool TOIProcessor::checkInputTOIIndex(int toiIndex) {
+  if (toiIndex >= inIx.size()) return false;
+  if (inTOIs[toiIndex] == NULL) return false;
+  return true;
+}
+
+bool TOIProcessor::checkOutputTOIIndex(int toiIndex) {
+  if (toiIndex >= outIx.size()) return false;
+  if (outTOIs[toiIndex] == NULL) return false;
+  return true;
+}
+
+void TOIProcessor::PrintStatus(ostream & os) 
+{
+  os << " TOIProcessor::PrintStatus() - Name= " << name 
+     << " MinIn=" << getMinIn() << " MaxIn=" << getMaxIn() << endl;
+  os << " --- Inputs N= " << inIx.size() << endl;
+  int k;
+  for(k=0; k<inIx.size(); k++) {
+    os << "Input[" << k << "] : " <<  getInName(k) ;
+    if (inTOIs[k] != NULL) 
+      os << " Connected TOI " << inTOIs[k]->getName() << endl;
+    else os << " NO TOI " << endl;
+  }
+  os << " --- Outputs N= " << outIx.size() << endl;
+  for(k=0; k<outIx.size(); k++) {
+    os << "Output[" << k << "] : " <<  getOutName(k) ;
+    if (outTOIs[k] != NULL) 
+      os << " Connected TOI " << outTOIs[k]->getName() << endl;
+    else os << " NO TOI " << endl;
+  }
+  os << endl;
+  return;
+}
+
+//  Fin rajout Reza 11/3/2001 
+
 void TOIProcessor::addInput(string name, TOI* toi) {
   chkinit();
@@ -143 +206 @@
   if (i > outIx.size()) throw RangeCheckError("TOIProcessor::getOutName "
                                              " out of bound");
-  map<string, int>::iterator j = outIx.begin();
-  while (i) {i--; j++;};
-  return (*j).first;
+  map<string, int>::iterator j;
+  for(j=outIx.begin(); j!= outIx.end(); j++) 
+    if ((*j).second == i)  return (*j).first;
+
+  throw RangeCheckError("TOIProcessor::getOutName  Not found index !");
 }
 
@@ -151 +216 @@
   if (i > inIx.size()) throw RangeCheckError("TOIProcessor::getInName "
                                              " out of bound");
-  map<string, int>::iterator j = inIx.begin();
-  while (i) {i--; j++;};
-  return (*j).first;
+  map<string, int>::iterator j;
+  for(j=inIx.begin(); j!= inIx.end(); j++) 
+    if ((*j).second == i)  return (*j).first;
+
+  throw RangeCheckError("TOIProcessor::getOutName  Not found index !");
 }
 
@@ -189 +256 @@
 #ifndef NO_SOPHYA
 Array TOIProcessor::getData(int toiIndex, int iStart, int iEnd) {
-  TOI* toi = inTOIs[toiIndex];
+  TOI* toi = getInputTOI(toiIndex);
   toi->waitForData(iStart, iEnd);
   return toi->getData(iStart, iEnd);
@@ -195 +262 @@
 
 Array TOIProcessor::getError(int toiIndex, int iStart, int iEnd) {
-  TOI* toi = inTOIs[toiIndex];
+  TOI* toi = getInputTOI(toiIndex);
   toi->waitForData(iStart, iEnd);
   return toi->getError(iStart, iEnd);
@@ -201 +268 @@
 
 TArray<int_4> TOIProcessor::getFlag(int toiIndex, int iStart, int iEnd) {
-  TOI* toi = inTOIs[toiIndex];
+  TOI* toi = getInputTOI(toiIndex);
   toi->waitForData(iStart, iEnd);
   return toi->getFlag(iStart, iEnd);
@@ -208 +275 @@
 
 double TOIProcessor::getData(int toiIndex, int i) {
-  TOI* toi = inTOIs[toiIndex];
+  TOI* toi = getInputTOI(toiIndex);
   toi->waitForData(i);
   return toi->getData(i);
@@ -214 +281 @@
 
 double TOIProcessor::getError(int toiIndex, int i) {
-  TOI* toi = inTOIs[toiIndex];
+  TOI* toi = getInputTOI(toiIndex);
   toi->waitForData(i);
   return toi->getError(i);
@@ -220 +287 @@
 
 int_4 TOIProcessor::getFlag(int toiIndex, int i) {
-  TOI* toi = inTOIs[toiIndex];
+  TOI* toi = getInputTOI(toiIndex);
   toi->waitForData(i);
   return toi->getFlag(i);
@@ -257 +324 @@
 
 void TOIProcessor::putData(int toiIndex, int i, double value, int_4 flg) {
-  TOI* toi = outTOIs[toiIndex];
+  TOI* toi = getOutputTOI(toiIndex);
   toi->putData(i, value, flg);
   autoWontNeed(i);
@@ -266 +333 @@
 void TOIProcessor::putDataError(int toiIndex, int i, double value, 
                                 double error, int_4 flg) { 
-  TOI* toi = outTOIs[toiIndex];
+  TOI* toi = getOutputTOI(toiIndex);
+  if (toi == NULL) 
+    throw NullPtrError("TOIProcessor::putDataError() - Not assigned TOI !");
   toi->putDataError(i, value, error, flg);
   autoWontNeed(i);