| 1 | /********************************************************* | 
|---|
| 2 | * | 
|---|
| 3 | * Fonction main pour la creation et le lancement des processeurs | 
|---|
| 4 | * | 
|---|
| 5 | * Auteur Vivien FEBVRE | 
|---|
| 6 | * | 
|---|
| 7 | *********************************************************/ | 
|---|
| 8 |  | 
|---|
| 9 |  | 
|---|
| 10 |  | 
|---|
| 11 | // inclusion des bibliotheques | 
|---|
| 12 |  | 
|---|
| 13 | #include "toi.h" | 
|---|
| 14 | #include "toisegment.h" | 
|---|
| 15 | #include "toiprocessor.h" | 
|---|
| 16 | #include "fitstoirdr.h" | 
|---|
| 17 | #include "fitstoiwtr.h" | 
|---|
| 18 | #include "toisqfilter.h" | 
|---|
| 19 | #include "toimanager.h" | 
|---|
| 20 |  | 
|---|
| 21 | int main(int argc, char** argv) { | 
|---|
| 22 |  | 
|---|
| 23 | cout << "****** Creation du toimanager ******" << endl; | 
|---|
| 24 |  | 
|---|
| 25 | // creation du gestionnaire de processeur | 
|---|
| 26 | TOIManager* mgr = TOIManager::getManager(); | 
|---|
| 27 |  | 
|---|
| 28 | // non définit : valeur par defaut | 
|---|
| 29 | // mgr->setRequestedSample(104001000,104003000); | 
|---|
| 30 |  | 
|---|
| 31 |  | 
|---|
| 32 | // 1 seul fichier a lire | 
|---|
| 33 |  | 
|---|
| 34 | // creation des entrees | 
|---|
| 35 | FITSTOIReader r1(argv[1]); | 
|---|
| 36 | //  r1.addFile(argv[2]); | 
|---|
| 37 | //  FITSTOIWriter w(argv[3]); | 
|---|
| 38 |  | 
|---|
| 39 | // creation de la sortie | 
|---|
| 40 | FITSTOIWriter w(argv[argc - 1]); | 
|---|
| 41 |  | 
|---|
| 42 |  | 
|---|
| 43 | TOI* toi1 = new TOISegmented(); | 
|---|
| 44 | r1.addOutput("boloMuV_8", toi1); | 
|---|
| 45 |  | 
|---|
| 46 | //  TOI* toi2 = new TOISegmented(); | 
|---|
| 47 | //  r2.addOutput("boloMuV_11", toi2); | 
|---|
| 48 |  | 
|---|
| 49 | w.addInput("143K01", toi1); | 
|---|
| 50 | //  w.addInput("143K02", toi2); | 
|---|
| 51 |  | 
|---|
| 52 | cout << "*** starting" << endl; | 
|---|
| 53 |  | 
|---|
| 54 | //démarage de tous les processeurs enregistrés dans le manager | 
|---|
| 55 | mgr->startAll(); | 
|---|
| 56 |  | 
|---|
| 57 | // demarage manuel | 
|---|
| 58 | //r1.start(); | 
|---|
| 59 | //r2.start(); | 
|---|
| 60 | //w.start(); | 
|---|
| 61 |  | 
|---|
| 62 | cout << "*** joining" << endl; | 
|---|
| 63 | mgr->joinAll(); | 
|---|
| 64 | cout << "****** Fin de l'execution ******" << endl; | 
|---|
| 65 | return(0); | 
|---|
| 66 | } | 
|---|