source: Sophya/trunk/SophyaPI/PIext/nobjmgr.cc@ 2701

Last change on this file since 2701 was 2701, checked in by ansari, 20 years ago

1/ Prise en charge de DataTable et SwPPFDataTable pour piapp (NObjMgrAdapter) :
nomhistadapter.cc et piiinit.cc
2/ Lecture de tous les objets ds un fichier PPF par NamedObjMgr::ReadAll() pour
fichier PPF sans nametag.
3/ Ajout bloc try/catch ds PIStdImgApp::Run() (boucle d'evenements)

Reza , 27 Avril 2005

File size: 46.1 KB
Line 
1#include <stdio.h>
2#include <stdlib.h>
3#include <ctype.h>
4
5#include <typeinfo>
6#include <iostream>
7#include <string>
8#include <list>
9#include <map>
10
11#include "sopnamsp.h"
12#include "strutil.h"
13#include "datatypes.h"
14
15#include "nobjmgr.h"
16#include "servnobjm.h"
17#include "nomgadapter.h"
18#include "pistdimgapp.h"
19
20#include "dvlist.h"
21
22// EVOL-PLANCK
23#ifdef SANS_EVOLPLANCK
24#include "fitsimage.h"
25#else
26#include "fitsautoreader.h"
27#include "tvector.h"
28#include "pitvmaad.h"
29#include "piyfxdrw.h"
30#endif
31
32#include "pisurfdr.h"
33#include "pipodrw.h"
34
35#include "pintuple.h"
36#include "pintup3d.h"
37#include "pigfd1.h"
38#include "pigfd2.h"
39
40#include "zthread.h"
41
42
43//++
44// Class NamedObjMgr
45// Lib PI
46// include nobjmgr.h
47//
48// Cette classe fournit les services nécéssaires à la gestion des objets
49// (l'ensemble des objets PPersist de PEIDA++) au sein du programme
50// d'analyse interactive *piapp* . Elle constitue en outre l'interface
51// entre les fonctions utilisateur et l'application graphique.
52//--
53//++
54// Links Voir aussi
55// PIStdImgApp
56// Services2NObjMgr
57// PIACmd
58//--
59
60
61// ..................................................................
62// ...... Gestion des objets nommes, variables globales ............
63struct nobj_diritem {
64 int id; // Directory Id
65 int nobj; // Number of objects in directory
66 bool lock; // True -> directory locked, No Add, del or rename
67 bool keepold; // True -> When duplicate object name, old object moved to /old
68};
69
70typedef map<string, nobj_diritem, less<string> > NObjDirList;
71
72struct nobj_item {
73 AnyDataObj* obj; // Object pointer
74 NObjMgrAdapter* obja; // Object adapter pointer
75 int oid; // object Id
76 int dirid; // Directory Id
77 list<int> wrsid; // List of Window Resource Id (Drawer, PIBaseWdg, ...)
78 // (for PIStdImgApp)
79 bool operator==(nobj_item const& b) const
80 { return (this->obj == b.obj); }
81};
82
83typedef map<string, nobj_item, less<string> > NObjList;
84
85static NObjDirList* myDirs = NULL;
86static NObjList* myObjs = NULL;
87static int fgOInit = 0;
88static int myNObj = 0;
89static int myDirId = 0;
90static string* currDir;
91
92static PIStdImgApp* myImgApp=NULL;
93static Services2NObjMgr* servnobjm=NULL;
94
95static DVList* myVars = NULL; // Pour stocker les variables
96
97static string* TmpDir; // Repertoire pour les compilations / link dynamique
98
99// Pour gestion multithread
100static ZMutex* myMutex;
101// ..................................................................
102
103//++
104// Titre Constructeurs
105//--
106//++
107// NamedObjMgr()
108// Constructeur. Les différents instantiation de la classe "NamedObjMgr"
109// dans une même application créent des objets qui travaillent sur la même
110// liste d'objets. Les objets de cette classe ne possedent en effet pas
111// de variables membres.
112//--
113
114/* --Methode-- */
115NamedObjMgr::NamedObjMgr(bool fgimgapp)
116{
117_fgimgapp = fgimgapp;
118if (fgOInit == 0) {
119 myNObj = 0;
120 myDirId = 0;
121 myDirs = new NObjDirList;
122 myObjs = new NObjList;
123 myVars = new DVList;
124 currDir = new string("home");
125 string dirn = "home";
126 CreateDir_P(dirn);
127 SetKeepOldDirAtt(dirn, false);
128 dirn = "tmp";
129 CreateDir_P(dirn);
130 SetKeepOldDirAtt(dirn, false);
131 dirn = "autoc";
132 CreateDir_P(dirn);
133 SetKeepOldDirAtt(dirn, false);
134 dirn = "old";
135 CreateDir_P(dirn);
136 SetKeepOldDirAtt(dirn, false);
137 dirn = "home";
138 SetCurrentDir(dirn);
139 myDirId = 50;
140 char* varenv;
141 TmpDir = new string("");
142 if ( (varenv=getenv("TMPDIR")) != NULL ) (*TmpDir) = varenv;
143 int l = (*TmpDir).length();
144 if ( (l>0) && ((*TmpDir)[l-1] != '/') ) (*TmpDir) += '/';
145 servnobjm = new Services2NObjMgr(*TmpDir);
146 myMutex = new ZMutex;
147 }
148fgOInit++;
149}
150
151
152/* --Methode-- */
153NamedObjMgr::~NamedObjMgr()
154{
155fgOInit--;
156if (fgOInit == 0) {
157 string patt = "/*/*";
158 DelObjects(patt, true);
159 delete myObjs;
160 delete myDirs;
161 delete myVars;
162 delete myMutex;
163}
164}
165
166//++
167// Titre Méthodes
168//--
169//++
170// void SetImgApp(PIStdImgApp* app)
171// Spécifie l'objet "PIStdImgApp" associé.
172// PIStdImgApp* GetImgApp()
173// Accès à l'objet "PIStdImgApp" associé.
174//--
175
176/* --Methode-- */
177void NamedObjMgr::SetImgApp(PIStdImgApp* app)
178{
179myImgApp = app;
180servnobjm->SetImgApp(app);
181
182NObjDirList::iterator it;
183string cn;
184for(it= myDirs->begin(); it != myDirs->end(); it++) {
185 cn = '/' + (*it).first;
186 (myImgApp->ObjMgrW())->AddDirectory(cn.c_str(), (*it).second.id);
187 }
188}
189
190
191static bool verbeux = false; // true -> plus de message (creation/suppression d'objets)
192void NamedObjMgr::SetVerbose(bool fg)
193{
194verbeux = fg;
195}
196
197/* --Methode-- */
198PIStdImgApp* NamedObjMgr::GetImgApp()
199{
200return(myImgApp);
201}
202
203/* --Methode-- */
204Services2NObjMgr* NamedObjMgr::GetServiceObj()
205{
206return(servnobjm);
207}
208
209/* --Methode-- */
210string const& NamedObjMgr::GetTmpDir()
211{
212return *TmpDir;
213}
214
215/* --Methode-- */
216void NamedObjMgr::SetTmpDir(string const& tmpdir)
217{
218if(tmpdir.length()<1) return;
219*TmpDir = tmpdir;
220int l = (*TmpDir).length();
221if ( (l>0) && ((*TmpDir)[l-1] != '/') ) (*TmpDir) += '/';
222servnobjm->SetTmpDir(*TmpDir);
223}
224
225/* --Methode-- */
226bool NamedObjMgr::SetVar(string const & key, string const & val)
227{
228 if ((key.length() < 1) || (! isalpha(key[0])) ) {
229 cout << "NamedObjMgr::SetVar( " << key << " ...) Bad VarName " << endl;
230 return(false);
231 }
232 ZSync(*myMutex);
233#ifdef SANS_EVOLPLANCK
234 bool fg = true;
235#else
236 bool fg = myVars->HasKey(key);
237#endif
238 myVars->SetS(key, val);
239 // cout << " DEBUG::SetVar " << *myVars << endl;
240 return(fg);
241}
242
243/* --Methode-- */
244bool NamedObjMgr::HasVar(string const & key)
245{
246 if ((key.length() < 1) || (! isalpha(key[0])) ) {
247 cout << "NamedObjMgr::HasVar( " << key << ") Bad VarName " << endl;
248 return(false);
249 }
250 ZSync(*myMutex);
251#ifdef SANS_EVOLPLANCK
252 DVList::ValList::const_iterator it;
253 for(it=myVars->Begin(); it!= myVars->End(); it++)
254 if ((*it).first == key) return true;
255 return(false);
256#else
257 return(myVars->HasKey(key));
258#endif
259}
260
261/* --Methode-- */
262bool NamedObjMgr::DeleteVar(string const & key)
263{
264 if ((key.length() < 1) || (! isalpha(key[0])) ) {
265 cout << "NamedObjMgr::DeleteVar( " << key << ") Bad VarName " << endl;
266 return(false);
267 }
268 ZSync(*myMutex);
269#ifdef SANS_EVOLPLANCK
270 return(false);
271#else
272 return(myVars->DeleteKey(key));
273#endif
274}
275
276/* --Methode-- */
277string NamedObjMgr::GetVar(string const & key)
278{
279 if ((key.length() < 1) || (! isalpha(key[0])) ) {
280 cout << "NamedObjMgr::GetVar( " << key << ") Bad VarName " << endl;
281 return("");
282 }
283 ZSync(*myMutex);
284 // cout << " DEBUG::GetVar " << *myVars << endl;
285 return(myVars->GetS(key));
286}
287
288/* --Methode-- */
289DVList& NamedObjMgr::GetVarList()
290{
291 // cout << " DEBUG::GetVarList " << *myVars << endl;
292 ZSync(*myMutex);
293 return(*myVars);
294}
295
296/* --Methode-- */
297bool NamedObjMgr::CreateDir(string & dirname)
298{
299 ZSync(*myMutex);
300 return CreateDir_P(dirname);
301}
302
303/* --Methode-- */
304bool NamedObjMgr::CreateDir_P(string & dirname)
305{
306if ( !CheckDirName(dirname) ) {
307 cout << "NamedObjMgr::CreateDir( " << dirname << ") Error - Invalid name !" << endl;
308 return(false);
309 }
310NObjDirList::iterator it = myDirs->find(dirname);
311if (it != myDirs->end()) {
312 cout << "NamedObjMgr::CreateDir( " << dirname << ") Error - Existing directory !" << endl;
313 return(false);
314 }
315myDirId++;
316nobj_diritem di;
317di.id = myDirId;
318di.nobj = 0;
319di.lock = false;
320di.keepold = false;
321(*myDirs)[dirname] = di;
322if (myImgApp) {
323 string str = '/' + dirname;
324 if ( !_fgimgapp ) myImgApp->LockMutex();
325 (myImgApp->ObjMgrW())->AddDirectory(str.c_str(), myDirId);
326 if ( !_fgimgapp ) myImgApp->UnlockMutex(true);
327}
328if (verbeux) cout << "NamedObjMgr::CreateDir() " << dirname << " Created " << endl;
329return(true);
330}
331
332/* --Methode-- */
333bool NamedObjMgr::DeleteDir(string & dirname)
334{
335if ( !CheckDirName(dirname) ) {
336 cout << "NamedObjMgr::DeleteDir( " << dirname << ") Error - Invalid name !" << endl;
337 return(false);
338 }
339ZSync(*myMutex);
340NObjDirList::iterator it = myDirs->find(dirname);
341if (it == myDirs->end()) {
342 cout << "NamedObjMgr::DeleteDir( " << dirname << ") Error - No such directory !" << endl;
343 return(false);
344 }
345if ((*it).second.nobj > 0) {
346 cout << "NamedObjMgr::DeleteDir() " << dirname << " not empty ! " << endl;
347 return(false);
348 }
349if ((*it).second.lock ) {
350 cout << "NamedObjMgr::DeleteDir() " << dirname << " locked ! " << endl;
351 return(false);
352 }
353if ((*it).second.id < 50) {
354 cout << "NamedObjMgr::DeleteDir() " << dirname << " cannot be deleted ! " << endl;
355 return(false);
356 }
357
358if (myImgApp) {
359 if ( !_fgimgapp ) myImgApp->LockMutex();
360 (myImgApp->ObjMgrW())->DelDirectory((*it).second.id);
361 if ( !_fgimgapp ) myImgApp->UnlockMutex(true);
362}
363myDirs->erase(it);
364if (verbeux) cout << "NamedObjMgr::DeleteDir() " << dirname << " deleted " << endl;
365return(true);
366}
367
368/* --Methode-- */
369void NamedObjMgr::LockDir(string & dirname)
370{
371ZSync(*myMutex);
372if ( !CheckDirName(dirname) ) return;
373NObjDirList::iterator it = myDirs->find(dirname);
374if (it == myDirs->end()) return;
375(*it).second.lock = true;
376if (verbeux) cout << "NamedObjMgr::LockDir() " << dirname << " Locked " << endl;
377return;
378}
379
380/* --Methode-- */
381void NamedObjMgr::UnlockDir(string & dirname)
382{
383ZSync(*myMutex);
384if ( !CheckDirName(dirname) ) return;
385NObjDirList::iterator it = myDirs->find(dirname);
386if (it == myDirs->end()) return;
387(*it).second.lock = true;
388if (verbeux) cout << "NamedObjMgr::UnlockDir() " << dirname << " Unlocked " << endl;
389return;
390}
391
392/* --Methode-- */
393void NamedObjMgr::SetKeepOldDirAtt(string & dirname, bool keepold)
394{
395ZSync(*myMutex);
396if ( !CheckDirName(dirname) ) return;
397NObjDirList::iterator it = myDirs->find(dirname);
398if (it == myDirs->end()) return;
399(*it).second.keepold = keepold;
400if (!verbeux) return;
401cout << "NamedObjMgr::SetKeepOldDirAtt() " << dirname << " -> ";
402if ( keepold ) cout << " True " << endl;
403else cout << " False " << endl;
404return;
405}
406
407
408/* --Methode-- */
409bool NamedObjMgr::SetCurrentDir(string & dirname)
410{
411ZSync(*myMutex);
412if ( !CheckDirName(dirname) ) {
413 cout << "NamedObjMgr::SetCurrentDir( " << dirname << ") Error - Invalid name !" << endl;
414 return(false);
415 }
416NObjDirList::iterator it = myDirs->find(dirname);
417if (it == myDirs->end()) {
418 cout << "NamedObjMgr::SetCurrentDir( " << dirname << ") Error - No such directory !" << endl;
419 return(false);
420 }
421*currDir = dirname;
422if (verbeux) cout << "NamedObjMgr::SetCurrentDir() -> " << dirname << endl;
423return(true);
424}
425
426/* --Methode-- */
427void NamedObjMgr::GetCurrentDir(string & dirname)
428{
429ZSync(*myMutex);
430dirname = *currDir;
431}
432
433/* --Methode-- */
434void NamedObjMgr::ListDirs(string & patt)
435{
436ZSync(*myMutex);
437NObjDirList::iterator it;
438string cn;
439cout << "NamedObjMgr::ListDirs( " << patt << " ) " << endl;
440int k = 0;
441for(it= myDirs->begin(); it != myDirs->end(); it++) {
442 cn = (*it).first;
443 if (csh_parse(cn.c_str(), patt.c_str()) == 0) continue;
444 k++;
445 cout << k << "- " << (*it).first;
446 if ( (*it).second.lock ) cout << " Locked " ;
447 if ( (*it).second.keepold ) cout << " KeepOld " ;
448 cout << " (Id= " << (*it).second.id << " NbObj= " << (*it).second.nobj << ")" << endl;
449
450 }
451}
452
453/* --Methode-- */
454void NamedObjMgr::GetDirList(string & patt, vector<string>& lstd)
455{
456ZSync(*myMutex);
457NObjDirList::iterator it;
458string cn;
459for(it= myDirs->begin(); it != myDirs->end(); it++) {
460 cn = (*it).first;
461 if (csh_parse(cn.c_str(), patt.c_str()) == 0) continue;
462 lstd.push_back(cn);
463 }
464}
465
466/* --Methode-- */
467void NamedObjMgr::CleanDir(string & dirname)
468{
469ZSync(*myMutex);
470CleanDir_P(dirname);
471}
472
473/* --Methode-- */
474void NamedObjMgr::CleanDir_P(string & dirname)
475{
476if ( !CheckDirName(dirname) ) {
477 cout << "NamedObjMgr::CleanDir( " << dirname << ") Error - Invalid name !" << endl;
478 // return(false); $CHECK$ illegal return value in void function
479 }
480NObjDirList::iterator itr = myDirs->find(dirname);
481if (itr == myDirs->end()) {
482 cout << "NamedObjMgr::CleanDir( " << dirname << ") Error - No such directory !" << endl;
483 // return(false); $CHECK$ illegal return value in void function
484 }
485
486int did = (*itr).second.id;
487NObjList::iterator it;
488list<int>::iterator iwr;
489bool nodisp = true;
490list<string> odel;
491for(it = myObjs->begin(); it != myObjs->end(); it++) {
492 if ((*it).second.dirid != did) continue;
493 nodisp = true;
494 if (myImgApp)
495 for(iwr=(*it).second.wrsid.begin(); iwr != (*it).second.wrsid.end(); iwr++)
496 if (myImgApp->CheckWRsId(*iwr)) { nodisp = false; break; }
497 if (nodisp) odel.push_back((*it).first);
498 }
499list<string>::iterator ii;
500for(ii=odel.begin(); ii != odel.end(); ii++) DelObj(*ii,true);
501if (myImgApp) {
502 if ( !_fgimgapp ) myImgApp->LockMutex();
503 (myImgApp->ObjMgrW())->UpdateList(did);
504 if ( !_fgimgapp ) myImgApp->UnlockMutex(true);
505}
506}
507
508
509
510//++
511// Titre Gestion de la liste des objets
512//--
513//++
514// void AddObj(AnyDataObj* obj, string& nom)
515// Ajoute l'objet "obj" à la liste, identifié par "nom".
516// Si un objet de même nom existe, l'ancien objet est renommé en concaténant
517// un numéro à son nom.
518// void DelObj(string const& nom, bool fgd=true)
519// Supprime l'objet "nom" de la liste. L'objet est détruit si "fgd==true" ("delete obj")
520// void DelObjects(string const& patt, bool fgd=true)
521// Supprime l'ensemble des objets dont le nom correspond au patron "patt".
522// Le patron peut contenir les caractères "*" et "?" . Les objets sont détruits si "fgd==true"
523// AnyDataObj* GetObj(string const& nom)
524// Retourne l'objet identifié par "nom" dans la liste. Retourne "NULL" si "nom" n'est
525// pas dans la liste.
526// void RenameObj(string const& nom, string& nomnew)
527// Change le nom d'un objet dans la liste.
528// void CopyObj(string const& nom, string& nomcp)
529// Copy l'objet "nom" de la liste dans l'objet "nomcp" de la liste.
530//--
531
532/* --Methode-- */
533bool NamedObjMgr::AddObj(AnyDataObj* obj, string & nom, bool crd)
534{
535 ZSync(*myMutex);
536 return AddObj_P(obj, nom, crd);
537}
538
539/* --Methode-- */
540bool NamedObjMgr::AddObj_P(AnyDataObj* obj, string & nom, bool crd)
541{
542
543if (obj == NULL) return(false);
544// On verifie si l'objet est deja dans la liste
545NObjList::iterator it;
546for(it = myObjs->begin(); it != myObjs->end(); it++) {
547 if ((*it).second.obj == obj) {
548 cout << "NamedObjMgr::AddObj() Object already present with name " << (*it).first << endl;
549 return(false);
550 }
551 }
552string nobj;
553string nrep;
554char buff[32];
555int did = ParseObjectName(nom, nrep, nobj);
556if (did == 0) {
557 if (!crd) {
558 cout << "NamedObjMgr::AddObj() No " << nrep << " Directory " << endl;
559 return(false);
560 }
561 else { CreateDir_P(nrep); did = myDirId; }
562 }
563
564// Si c'est le repertoire /autoc, on nettoie
565if (nrep == "autoc") {
566 CleanDir_P(nrep);
567 }
568
569myNObj++;
570if ((nobj.length() < 1) || (! isalpha(nobj[0]) ) ) {
571 cout << "NamedObjMgr::AddObj() bad object name " << nobj ;
572 sprintf(buff,"O%d", myNObj);
573 nobj = buff;
574 cout << " changed to " << nobj << endl;
575 }
576
577nom = '/' + nrep + '/' + nobj;
578NObjDirList::iterator itr = myDirs->find(nrep);
579if ((*itr).second.lock) {
580 cout << "NamedObjMgr::AddObj() " << nrep << " Locked Directory " << endl;
581 return(false);
582 }
583it = myObjs->find(nom);
584if (it != myObjs->end()) { // l'objet existe deja
585 if (nrep == "autoc") { // Dans /autoc , on garde les objets affiches, donc del. par Clean
586 sprintf(buff, "%d", (*it).second.oid);
587 string nomnew = "/autoc/" + nobj + buff;
588 RenameObj_P(nom, nomnew);
589 }
590 else if ( (*itr).second.keepold ) { // On met l'ancien objet dans /old
591 string on,od;
592// ParseObjectName((*it).first, od, on);
593 sprintf(buff, "%d", (*it).second.oid);
594 string nomnew = "/old/" + nobj + buff;
595 RenameObj_P(nom, nomnew);
596 }
597 else { // Sinon, on remplace l'objet
598 cout << "NamedObjMgr::AddObj() - Replacing " << nom << endl;
599 DelObj_P(nom);
600 }
601 }
602
603nobj_item no;
604no.obj = obj;
605no.obja = servnobjm->GetAdapter(obj); // L'adaptateur
606no.oid = myNObj;
607no.dirid = did;
608(*myObjs)[nom] = no;
609
610(*itr).second.nobj++;
611
612if (myImgApp != NULL) {
613 if ( !_fgimgapp ) myImgApp->LockMutex();
614 if ( (myImgApp->ObjMgrW())->Visible() ) {
615 string oln = nobj + " (T= " + no.obja->GetDataObjType() + ")" ;
616 (myImgApp->ObjMgrW())->AddObjList(did, oln.c_str(), no.oid);
617 }
618 if ( !_fgimgapp ) myImgApp->UnlockMutex(true);
619}
620if (verbeux) cout << "NamedObjMgr::AddObj() Object " << nom << " ( "
621 << typeid(*obj).name() << " ) added (Total= " << myObjs->size() << ")" << endl;
622return(true);
623}
624
625bool NamedObjMgr::AddObj(AnyDataObj& obj, string & nom, bool crd)
626{
627ZSync(*myMutex);
628NObjMgrAdapter* adap = GetServiceObj()->GetAdapter(&obj);
629if (adap == NULL) {
630 cout << "NamedObjMgr::AddObj() No Adapter ! " << nom << endl;
631 return(false);
632}
633AnyDataObj * cloneobj = adap->CloneDataObj(true);
634delete adap;
635if (cloneobj == NULL) {
636 cout << "NamedObjMgr::AddObj() Pb cloning object ! " << nom << endl;
637 return(false);
638}
639return ( AddObj_P(cloneobj , nom, crd) );
640}
641
642/* --Methode-- */
643bool NamedObjMgr::RenameObj(string & nom, string& nomnew)
644{
645 ZSync(*myMutex);
646 return RenameObj_P(nom, nomnew);
647}
648
649/* --Methode-- */
650bool NamedObjMgr::RenameObj_P(string & nom, string& nomnew)
651{
652string n1,r1,n2,r2;
653int dids = ParseObjectName(nom, r1, n1);
654NObjDirList::iterator itr1 = myDirs->find(r1);
655int did = ParseObjectName(nomnew, r2, n2);
656NObjDirList::iterator itr2 = myDirs->find(r2);
657
658if (did == 0) {
659 cout << "NamedObjMgr::RenameObj() Error - No " << r2 << " directory !" << endl;
660 return(false);
661}
662nom = '/' + r1 + '/' + n1;
663nomnew = '/' + r2 + '/' + n2;
664NObjList::iterator it1 = myObjs->find(nom);
665if (it1 == myObjs->end()) {
666 cout << "NamedObjMgr::RenameObj() Error - No " << nom << " object !" << endl;
667 return(false);
668}
669if ((n2.length() < 1) || (! isalpha(n2[0])) ) {
670 cout << "NamedObjMgr::RenameObj() Error - bad new object name" << n2 << endl;
671 return(false);
672}
673NObjList::iterator it2 = myObjs->find(nomnew);
674if (it2 != myObjs->end()) {
675 cout << "NamedObjMgr::RenameObj() Error - Object " << nomnew << " exist !" << endl;
676 return(false);
677 }
678
679if ( (*itr1).second.lock || (*itr2).second.lock ) {
680 cout << "NamedObjMgr::RenameObj() Error - Source or destination directory locked !"
681 << endl;
682 return(false);
683 }
684
685
686nobj_item no = (*it1).second;
687no.dirid = did;
688myObjs->erase(it1);
689NObjDirList::iterator itr = myDirs->find(r1);
690(*itr).second.nobj--;
691(*myObjs)[nomnew] = no;
692itr = myDirs->find(r2);
693(*itr).second.nobj++;
694
695if (myImgApp != NULL) {
696 if ( !_fgimgapp ) myImgApp->LockMutex();
697 if ( (myImgApp->ObjMgrW())->Visible() ) {
698 (myImgApp->ObjMgrW())->DelObjList(dids, no.oid);
699 string oln = n2 + " (T= " + no.obja->GetDataObjType() + ")" ;
700 (myImgApp->ObjMgrW())->AddObjList(did, oln.c_str(), no.oid);
701 }
702 if ( !_fgimgapp ) myImgApp->UnlockMutex(true);
703}
704if (verbeux)
705 cout << "NamedObjMgr::RenameObj() - Object " << nom << " renamed to " << nomnew << endl;
706return(true);
707}
708
709/* --Methode-- */
710bool NamedObjMgr::CopyObj(string & nom, string& nomcp)
711{
712ZSync(*myMutex);
713if(nomcp.length()<=0)
714 {cout<<"NamedObjMgr::CopyObj() Error, copied obj name "<<nomcp<<" not valid"<<endl;
715 return(false);}
716NObjMgrAdapter* obnom = GetObjAdapter(nom);
717if(obnom==NULL)
718 {cout<<"NamedObjMgr::CopyObj() Error - No "<<nom<<" object !"<<endl;
719 return(false);}
720AnyDataObj* obnomcp = obnom->CloneDataObj();
721if(obnomcp==NULL) return(false);
722if(! AddObj_P(obnomcp,nomcp,false) ) {delete obnomcp; return(false);}
723return true;
724}
725
726/* --Methode-- */
727bool NamedObjMgr::DelObj(string & nom, bool fgd)
728{
729 ZSync(*myMutex);
730 return DelObj_P(nom, fgd);
731}
732
733/* --Methode-- */
734bool NamedObjMgr::DelObj_P(string & nom, bool fgd)
735{
736string n1,r1;
737int did = ParseObjectName(nom, r1, n1);
738nom = '/' + r1 + '/' + n1;
739NObjList::iterator it = myObjs->find(nom);
740if (it == myObjs->end()) return(false);
741NObjDirList::iterator itr = myDirs->find(r1);
742if ( (*itr).second.lock ) {
743 cout << "NamedObjMgr::DelObj() Error - Locked directory " << r1 << endl;
744 return(false);
745 }
746list<int>::iterator ii;
747if (myImgApp) {
748//DBG cerr << " *DBG* NamedObjMgr::DelObj Sz= " << (*it).second.wrsid.size() << endl;
749// Si appel venant de PIStdImgApp, il ne faut pas locker le Mutex global de la boucle d'evts
750 bool fglock = (_fgimgapp) ? false : true;
751 if (fglock) myImgApp->LockMutex();
752 for(ii=(*it).second.wrsid.begin(); ii != (*it).second.wrsid.end(); ii++)
753 myImgApp->DelWRsId((*ii));
754 if (fglock) myImgApp->UnlockMutex(true);
755}
756delete (*it).second.obja; // destruction de l'adaptateur
757if (fgd) delete (*it).second.obj;
758
759if (myImgApp != NULL) {
760 if ( !_fgimgapp ) myImgApp->LockMutex();
761 if ( (myImgApp->ObjMgrW())->Visible() ) {
762 int olid = (*it).second.oid;
763 (myImgApp->ObjMgrW())->DelObjList(did, olid);
764 }
765 if ( !_fgimgapp ) myImgApp->UnlockMutex(true);
766}
767myObjs->erase(it);
768(*itr).second.nobj--;
769
770
771if (!verbeux) return(true);
772if (fgd) cout << "NamedObjMgr::DelObj() Object " << nom << " deleted (Total= " << myObjs->size() << ")" << endl;
773else cout << "NamedObjMgr::DelObj() Object " << nom << " removed (Total= " << myObjs->size() << ")" << endl;
774return(true);
775}
776
777/* --Methode-- */
778bool NamedObjMgr::DelObj_Id(int oid)
779{
780ZSync(*myMutex);
781NObjList::iterator it;
782string nom;
783bool of = false;
784for(it = myObjs->begin(); it != myObjs->end(); it++)
785 if ( (*it).second.oid == oid ) {
786 of = true; nom = (*it).first;
787 break;
788 }
789if (of) return(DelObj(nom, true));
790else return(false);
791}
792
793/* --Methode-- */
794void NamedObjMgr::DelObjects(string & patt, bool fgd)
795{
796ZSync(*myMutex);
797string n1,r1;
798ParseObjectName(patt, r1, n1);
799patt = '/' + r1 + '/' + n1;
800NObjList::iterator it;
801list<string> odel;
802string cn;
803for(it = myObjs->begin(); it != myObjs->end(); it++) {
804 cn = (*it).first;
805 if (csh_parse(cn.c_str(), patt.c_str()) != 0) odel.push_back(cn);
806 }
807list<string>::iterator ii;
808for(ii=odel.begin(); ii != odel.end(); ii++) DelObj_P(*ii, fgd);
809}
810
811/* --Methode-- */
812AnyDataObj* NamedObjMgr::GetObj(string & nom)
813{
814ZSync(*myMutex);
815string n1,r1;
816ParseObjectName(nom, r1, n1);
817nom = '/' + r1 + '/' + n1;
818NObjList::iterator it = myObjs->find(nom);
819if (it == myObjs->end()) return(NULL);
820return((*it).second.obj);
821}
822
823/* --Methode-- */
824NObjMgrAdapter* NamedObjMgr::GetObjAdapter(string & nom)
825{
826ZSync(*myMutex);
827string n1,r1;
828ParseObjectName(nom, r1, n1);
829nom = '/' + r1 + '/' + n1;
830NObjList::iterator it = myObjs->find(nom);
831if (it == myObjs->end()) return(NULL);
832return((*it).second.obja);
833}
834
835/* --Methode-- */
836void NamedObjMgr::ListObjs(string & patt)
837{
838ZSync(*myMutex);
839int k;
840AnyDataObj* obj=NULL;
841string ctyp;
842char strg[256];
843
844string n1,r1;
845ParseObjectName(patt, r1, n1);
846patt = '/' + r1 + '/' + n1;
847 cout << "NamedObjMgr::ListObjs( " << patt << " ) TotNObjs= " << myObjs->size() << "\n" ;
848NObjList::iterator it; k = 0;
849string cn;
850for(it = myObjs->begin(); it != myObjs->end(); it++) {
851 cn = (*it).first;
852 if (csh_parse(cn.c_str(), patt.c_str()) == 0) continue;
853 obj = (*it).second.obj;
854 ctyp = typeid(*obj).name();
855 sprintf(strg, "%2d/ %16s : %s", k, typeid(*obj).name(), ((*it).first).c_str());
856 ctyp = strg;
857 cout << ctyp << "\n" ;
858 k++;
859}
860cout << endl;
861return;
862}
863
864/* --Methode-- */
865void NamedObjMgr::GetObjList(string & patt, vector<string> &lst)
866{
867ZSync(*myMutex);
868string n1,r1;
869if (patt.length() < 1) return;
870bool fgr = (patt[0] == '/') ? true : false;
871ParseObjectName(patt, r1, n1);
872patt = '/' + r1 + '/' + n1;
873NObjList::iterator it;
874string cn;
875for(it = myObjs->begin(); it != myObjs->end(); it++) {
876 cn = (*it).first;
877 if (csh_parse(cn.c_str(), patt.c_str()) == 0) continue;
878 if (fgr) lst.push_back(cn);
879 else {
880 ParseObjectName(cn, r1, n1);
881 lst.push_back(n1);
882 }
883 }
884}
885
886//++
887// Titre Entrées-Sorties (I/O) sur les objets
888//--
889//++
890// void ReadObj(PInPersist& s, int num=-1)
891// Lit l'objet à partir avec le tag numéro "num" dans le flot "PInPersist s"
892// et l'ajoute à la liste. Si "num" est négatif, tous les objets présents
893// sur le flot "s" sont créés et ajoutés à la liste.
894// void ReadObj(string const & nomppf, string nobj="")
895// Lit le premier objet à partir du fichier PPF "nomppf". L'objet est ajouté
896// à la liste avec le nom "nobj". Si "nobj" est une chaîne vide, un nom est
897// composé à partir du nom de fichier.
898//--
899
900/* --Methode-- */
901void NamedObjMgr::ReadObj(string const & flnm, string & nobj)
902{
903ZSync(*myMutex);
904PPersist* ppobj=NULL;
905bool ok = true;
906#ifdef SANS_EVOLPLANCK
907TRY{
908 PInPersist pis(flnm);
909 ppobj = PPersistMgr::ReadObject(pis);
910 if (ppobj == NULL) ok = false;
911} CATCH(merr)
912 { printf("NamedObjMgr::ReadObj()/Error Exception= %ld (%s) \n",
913 (long)merr, PeidaExc(merr)); ok = false; } ENDTRY;
914#else
915try {
916 PInPersist pis(flnm);
917 ppobj = pis.ReadObject();
918 }
919catch (IOExc iox) {
920 cerr << "NamedObjMgr::ReadObj()/Error Exception - Msg= " << iox.Msg() << endl;
921 ok = false;
922 }
923#endif
924if (!ok) return;
925if (nobj.length()<1) nobj = servnobjm->FileName2Name(flnm);
926AddObj_P(ppobj->DataObj(), nobj, true);
927cout << "NamedObjMgr::ReadObj(...) object " << nobj << " read from file " << endl;
928return;
929}
930/* --Methode-- */
931void NamedObjMgr::ReadObj(vector<string> & flnm_objname)
932// flnm_objname[0] = nom du fichier .ppf
933// flnm_objname[1...] = nom des tags des objects a lire
934{
935if(flnm_objname.size()<2) return;
936ZSync(*myMutex);
937int nread=0;
938try {
939 PInPersist pis(flnm_objname[0]);
940 for(int i=1;i<flnm_objname.size();i++) {
941 bool ok = pis.GotoNameTag(flnm_objname[i]);
942 if(!ok) {
943 cout<<"NamedObjMgr::ReadObj(...) Unknown object: "<<flnm_objname[i]<<endl;
944 continue;
945 }
946 PPersist *ppobj = pis.ReadObject();;
947 if(ppobj==NULL) {
948 cout<<"NamedObjMgr::ReadObj(...) impossible to read "<<flnm_objname[i]<<endl;
949 continue;
950 }
951 AddObj_P(ppobj->DataObj(),flnm_objname[i],true);
952 nread++;
953 cout<<"NamedObjMgr::ReadObj(...) object "<<flnm_objname[i]<<" read from file "<<endl;
954 }
955} catch (IOExc iox) {
956 cerr<<"NamedObjMgr::ReadObj()/Error Exception - Msg= "<<iox.Msg()<<endl;
957}
958cout<<nread<<" objects have been read"<<endl;
959return;
960}
961
962/* --Methode-- */
963void NamedObjMgr::ReadObj(PInPersist& s, int num)
964{
965ZSync(*myMutex);
966int_4 i; // $CHECK$ int -> int_4 a cause de TagKey
967#ifdef SANS_EVOLPLANCK
968int_4 cid, key, ln; // $CHECK$ int -> int_4 a cause de TagKey
969#endif
970int n0, n1;
971bool ok = true;
972PPersist* obj=NULL;
973string nom;
974
975int nread = 0;
976int nbtags = 0;
977#ifdef SANS_EVOLPLANCK
978nbtags = s.NbTags();
979#else
980nbtags = s.NbNameTags();
981#endif
982if ( (nbtags < 1) || (num >= nbtags) ) {
983 if (num >= 0) {
984 cerr << "NamedObjMgr::ReadObj(PInPersist, " << num << " Error! NbTags ="
985 << nbtags << endl;
986 return;
987 }
988
989#ifdef SANS_EVOLPLANCK
990 TRY {
991 obj = PPersistMgr::ReadObject(s);
992 if (obj == NULL) ok = false;
993 } CATCH(merr) {
994 printf("NamedObjMgr::ReadObj()/Error Exception= %ld (%s) \n", (long)merr, PeidaExc(merr));
995 ok = false;
996 } ENDTRY;
997#else
998try {
999 obj = s.ReadObject();
1000 }
1001catch (IOExc iox) {
1002 cerr << "NamedObjMgr::ReadObj()/Error Exception - Msg= " << iox.Msg() << endl;
1003 ok = false;
1004 }
1005#endif
1006
1007 if (!ok) return;
1008 nom = "";
1009 AddObj_P(obj->DataObj(), nom, false);
1010 nread++;
1011}
1012
1013if (num < 0) { n0 = 0; n1 = nbtags; }
1014else { n0 = num; n1 = num+1; }
1015for(i=n0; i<n1; i++) {
1016#ifdef SANS_EVOLPLANCK
1017 key = s.TagKey(i, cid, ln);
1018 if (ln <= 0) nom = "";
1019 else nom = s.TagName(i);
1020 s.GotoTag(i);
1021 TRY {
1022 obj = PPersistMgr::ReadObject(s);
1023 if (obj == NULL) ok = false;
1024 } CATCH(merr) {
1025 printf("NamedObjMgr::ReadObj()/Error Exception= %ld (%s) \n", (long)merr, PeidaExc(merr));
1026 ok = false;
1027 } ENDTRY;
1028#else
1029 s.GotoNameTagNum(i);
1030 nom = s.GetTagName(i);
1031 try {
1032 obj = s.ReadObject();
1033 }
1034 catch (IOExc iox) {
1035 cerr << "NamedObjMgr::ReadObj()/Error Exception - Msg= " << iox.Msg() << endl;
1036 ok = false;
1037 }
1038#endif
1039 if (ok) { AddObj_P(obj->DataObj(), nom, true); nread++; }
1040}
1041
1042cout << "NamedObjMgr::ReadObj(...) " << nread << " Objects read " << endl;
1043return;
1044}
1045/* --Methode-- */
1046void NamedObjMgr::ReadAll(string const & flnm)
1047{
1048ZSync(*myMutex);
1049#ifdef SANS_EVOLPLANCK
1050bool ok = true;
1051PPersist* obj=NULL;
1052
1053PInPersist* ppin=NULL;
1054TRY{
1055 ppin = new PInPersist(flnm);
1056 if (ppin->NbTags() < 1) obj = PPersistMgr::ReadObject((*ppin));
1057 else obj = NULL;
1058} CATCH(merr)
1059 { printf("NamedObjMgr::ReadAll()/Error Exception= %ld (%s) \n",
1060 (long)merr, PeidaExc(merr)); ok = false; }
1061ENDTRY;
1062if (!ok) return;
1063if (obj) {
1064 string nom = servnobjm->FileName2Name(flnm);
1065 AddObj_P(obj->DataObj(), nom, false);
1066 }
1067else ReadObj((*ppin), -1);
1068delete ppin;
1069#else
1070try {
1071 PInPersist pis(flnm);
1072 if (pis.NbNameTags() >= 1) {
1073 if (pis.NbNameTags() < pis.NbTopLevelObjects()) {
1074 cout << "NamedObjMgr::ReadAll()/Warning File " << flnm << " NbNameTags="
1075 << pis.NbNameTags() << " < NbTopLevelObjects= "
1076 << pis.NbTopLevelObjects() << endl;
1077 cout << " ... Reading " << pis.NbNameTags() << " objects at NameTags " ;
1078 }
1079 ReadObj(pis, -1);
1080 return;
1081 }
1082
1083 string nom = servnobjm->FileName2Name(flnm);
1084 int kn = 1;
1085 for(int ii=0; ii<pis.NbTopLevelObjects(); ii++) {
1086 PPersist* obj = pis.ReadObject();
1087 if (!obj) continue;
1088 AddObj_P(obj->DataObj(), nom, false);
1089 kn++;
1090 nom += (string)MuTyV(kn);
1091 }
1092}
1093catch (IOExc& iox) {
1094 cerr << "NamedObjMgr::ReadAll()/Error Exception - Msg= " << iox.Msg() << endl;
1095}
1096#endif
1097return;
1098}
1099
1100/* --Methode-- */
1101void NamedObjMgr::ReadFits(string const & flnm, string & nobj)
1102{
1103ZSync(*myMutex);
1104#ifdef SANS_EVOLPLANCK
1105bool ok = false;
1106RzImage* obj=NULL;
1107TRY{
1108 obj = RzReadFits((char*)flnm.c_str());
1109 if (obj == NULL) ok = false;
1110 else ok = true;
1111} CATCH(merr) {
1112 printf("NamedObjMgr::ReadFITS(_Error Exception= %ld (%s) \n", (long)merr, PeidaExc(merr));
1113 ok = false;
1114} ENDTRY;
1115
1116if (ok && (obj != NULL)) {
1117 if (nobj.length()<1) nobj = servnobjm->FileName2Name(flnm);
1118 AddObj_P((AnyDataObj*)obj, nobj);
1119}
1120#else
1121 try {
1122 FITS_AutoReader fiar(flnm);
1123 char bun[16];
1124 int nhdu = fiar.NbBlocks();
1125 if (nobj.length()<1) nobj = servnobjm->FileName2Name(flnm);
1126 string name;
1127 AnyDataObj* obj;
1128 int kon = 1;
1129 for(int k=1; k<=nhdu; k++) {
1130 obj = fiar.ReadObject(k);
1131 if (obj) {
1132 cout << " NamedObjMgr::ReadFits() " << (string)typeid(*obj).name()
1133 << " read From HDU " << k << endl;
1134 if (typeid(*obj) == typeid(DVList)) {
1135 delete obj;
1136 continue;
1137 }
1138 if (kon > 1) {
1139 sprintf(bun, "%d", kon);
1140 name = nobj + bun;
1141 }
1142 else name = nobj;
1143 AddObj_P(obj, name, false);
1144 kon++;
1145 }
1146 else cerr << " NamedObjMgr::ReadFits() NULL pointer from FITS_AutoReader" << endl;
1147 }
1148 }
1149 catch(PThrowable & exc) {
1150 cerr << " NamedObjMgr::ReadFits() / Error - Catched Exception \n "
1151 << " Type= " << (string)typeid(exc).name()
1152 << " - Msg= " << exc.Msg() << endl;
1153
1154 }
1155#endif
1156
1157return;
1158}
1159
1160/* --Methode-- */
1161void NamedObjMgr::SaveObj(string & nom, POutPersist& s, bool keeppath)
1162{
1163 ZSync(*myMutex);
1164 SaveObj_P(nom, s, keeppath);
1165}
1166
1167static int key_for_write = 5000;
1168/* --Methode-- */
1169void NamedObjMgr::SaveObj_P(string & nom, POutPersist& s, bool keeppath)
1170{
1171if (nom.length() < 1) return;
1172string nob,rep;
1173ParseObjectName(nom, rep, nob);
1174nom = '/' + rep + '/' + nob;
1175NObjMgrAdapter* obja=NULL;
1176string nomf = (keeppath) ? nom : nob;
1177obja = GetObjAdapter(nom);
1178if (obja == NULL) return;
1179printf("NamedObjMgr::SaveObj(%s, ) (Type=%s) \n",
1180 nom.c_str(), typeid(*(obja->GetDataObj())).name());
1181obja->SavePPF(s, nomf);
1182return;
1183}
1184
1185/* --Methode-- */
1186void NamedObjMgr::SaveObjects(string & patt, string const& flnm)
1187{
1188ZSync(*myMutex);
1189string n1,r1;
1190if (patt.length() < 1) return;
1191bool keeppath = (patt[0] == '/') ? true : false;
1192ParseObjectName(patt, r1, n1);
1193patt = '/' + r1 + '/' + n1;
1194
1195bool ok = true;
1196POutPersist* pout=NULL;
1197#ifdef SANS_EVOLPLANCK
1198TRY{
1199 pout = new POutPersist(flnm);
1200} CATCH(merr)
1201 { printf("NamedObjMgr::SaveObjects()/Error Exception= %ld (%s) \n",
1202 (long)merr, PeidaExc(merr)); ok = false; } ENDTRY;
1203#else
1204try {
1205 pout = new POutPersist(flnm);
1206}
1207catch (IOExc iox) {
1208 cerr << "NamedObjMgr::SaveObjects()/Error Exception - Msg= " << iox.Msg() << endl;
1209 ok = false;
1210}
1211#endif
1212if (!ok) return;
1213NObjList::iterator it;
1214string cn;
1215for(it = myObjs->begin(); it != myObjs->end(); it++) {
1216 cn = (*it).first;
1217 if (csh_parse(cn.c_str(), patt.c_str()) == 0) continue;
1218 SaveObj_P(cn, (*pout), keeppath);
1219 }
1220delete pout;
1221return;
1222}
1223
1224/* --Methode-- */
1225void NamedObjMgr::SaveListObjects(vector<string> &liste)
1226// Les n-1 premiers elements (liste[0 -> n-2]) contiennent
1227// les noms des objects a mettre dans le fichier ppf
1228// dont le nom est le dernier argument (liste[n-1])
1229{
1230 ZSync(*myMutex);
1231
1232 if(liste.size()<2) {
1233 cerr<<"NamedObjMgr::SaveListObjects()/Error not enough argument"<<endl;
1234 return;
1235 }
1236
1237 // open ppf file
1238 string ppfname = liste[liste.size()-1];
1239 POutPersist* pout=NULL;
1240 try {
1241 pout = new POutPersist(ppfname);
1242 } catch(IOExc iox) {
1243 cerr<<"NamedObjMgr::SaveObjects()/Error Exception - Msg= "<<iox.Msg()<<endl;
1244 return;
1245 }
1246
1247 // put objects in ppf file
1248 for(int i=0;i<liste.size()-1;i++) {
1249 bool keeppath = (liste[i][0] == '/') ? true : false;
1250 SaveObj_P(liste[i], (*pout), keeppath);
1251 }
1252
1253 // close ppf file
1254 delete pout;
1255
1256 return;
1257}
1258
1259/* --Methode-- */
1260void NamedObjMgr::SaveAll(string const& flnm)
1261{
1262ZSync(*myMutex);
1263bool ok = true;
1264
1265POutPersist* pout=NULL;
1266#ifdef SANS_EVOLPLANCK
1267TRY{
1268 pout = new POutPersist(flnm);
1269} CATCH(merr)
1270 { printf("NamedObjMgr::SaveAll()/Error Exception= %ld (%s) \n",
1271 (long)merr, PeidaExc(merr)); ok = false; } ENDTRY;
1272#else
1273try {
1274 pout = new POutPersist(flnm);
1275}
1276catch (IOExc iox) {
1277 cerr << "NamedObjMgr::SaveAll()/Error Exception - Msg= " << iox.Msg() << endl;
1278 ok = false;
1279}
1280#endif
1281if (!ok) return;
1282NObjList::iterator it;
1283string no;
1284for(it = myObjs->begin(); it != myObjs->end(); it++) {
1285 no = (*it).first;
1286 SaveObj_P(no, (*pout), true);
1287 }
1288delete pout;
1289return;
1290}
1291
1292/* --Methode-- */
1293void NamedObjMgr::SaveFits(string& nom, string const & flnm)
1294{
1295ZSync(*myMutex);
1296
1297NObjMgrAdapter* obja=NULL;
1298obja = GetObjAdapter(nom);
1299if (obja == NULL) return;
1300cout << " SaveFits: Object" << nom << " to FITS file " << flnm << endl;
1301obja->SaveFits(flnm);
1302return;
1303}
1304
1305
1306
1307/* --Methode-- */
1308void NamedObjMgr::PrintObj(string& nom)
1309{
1310ZSync(*myMutex);
1311NObjMgrAdapter* obja=NULL;
1312obja = GetObjAdapter(nom);
1313if (obja == NULL) return;
1314AnyDataObj* ob = obja->GetDataObj();
1315if (ob == NULL) {
1316 cerr << "NamedObjMgr::PrintObj() / Error - NULL object ! in " << nom << endl;
1317 return;
1318 }
1319string ctyp = typeid(*ob).name();
1320cout << "NamedObjMgr::PrintObj(" << nom << ") Type: " << ctyp << endl;
1321obja->Print(cout);
1322
1323return;
1324}
1325
1326/* --Methode-- */
1327void NamedObjMgr::DisplayObj(string& nom, string dopt)
1328{
1329// Pas de display si option dopt = nodisp
1330if ( (dopt == "nodisp") || (dopt == "nodisplay") ) return;
1331
1332ZSync(*myMutex);
1333
1334NObjMgrAdapter* obja=NULL;
1335obja = GetObjAdapter(nom);
1336if (obja == NULL) {
1337 cout << "NamedObjMgr::DisplayObj() Error , No object with name " << nom << endl;
1338 return;
1339}
1340if (obja->GetDataObj() == NULL) {
1341 cerr << "NamedObjMgr::DisplayObj() / Error - NULL object ! in " << nom << endl;
1342 return;
1343 }
1344if (!myImgApp) return;
1345
1346PIDrawer * dr = NULL;
1347P2DArrayAdapter* arr = NULL;
1348dr = obja->GetDrawer(dopt);
1349if (!dr) arr = obja->Get2DArray(dopt);
1350
1351if (!dr && !arr) {
1352 string ctyp = typeid(*(obja->GetDataObj())).name();
1353 cout << "NamedObjMgr::DisplayObj() Error , No display for " << ctyp << endl;
1354 return;
1355 }
1356
1357int wrsid = 0;
1358
1359string n1,r1;
1360ParseObjectName(nom, r1, n1);
1361
1362// Si appel venant de PIStdImgApp, il ne faut pas locker le Mutex global de la boucle d'evts
1363bool fglock = (_fgimgapp) ? false : true;
1364
1365if (dr) {
1366 PIDrawer3D * dr3 = dynamic_cast<PIDrawer3D *>(dr);
1367 if(dr3) wrsid = myImgApp->Disp3DDrawer(dr3, n1, dopt, "", 0, fglock);
1368 else wrsid = myImgApp->DispScDrawer( dr, n1, dopt, "", 0, fglock);
1369 }
1370else if (arr) wrsid = myImgApp->DispImage(arr, n1, dopt, false, 0, fglock);
1371
1372AddWRsId(nom, wrsid);
1373return;
1374}
1375
1376/* --Methode-- */
1377void NamedObjMgr::DisplayImage(string& nom, string dopt, bool fgimagnav)
1378{
1379// Pas de display si option dopt = nodisp
1380if ( (dopt == "nodisp") || (dopt == "nodisplay") ) return;
1381
1382ZSync(*myMutex);
1383
1384NObjMgrAdapter* obja=NULL;
1385obja = GetObjAdapter(nom);
1386if (obja == NULL) {
1387 cout << "NamedObjMgr::DisplayImage() Error , No such object " << nom << endl;
1388 return;
1389}
1390if (obja->GetDataObj() == NULL) {
1391 cerr << "NamedObjMgr::DisplayImage() / Error - NULL object ! in " << nom << endl;
1392 return;
1393 }
1394if (!myImgApp) return;
1395
1396P2DArrayAdapter* arr = obja->Get2DArray(dopt);
1397
1398if (!arr) {
1399 string ctyp = typeid(*(obja->GetDataObj())).name();
1400 cout << "NamedObjMgr::DisplayImage() Error , Not supported for " << ctyp << endl;
1401 return;
1402 }
1403
1404string n1,r1;
1405ParseObjectName(nom, r1, n1);
1406
1407// Si appel venant de PIStdImgApp, il ne faut pas locker le Mutex global de la boucle d'evts
1408bool fglock = (_fgimgapp) ? false : true;
1409
1410int wrsid = 0;
1411wrsid = myImgApp->DispImage(arr, n1, dopt, fgimagnav, 0, fglock);
1412
1413AddWRsId(nom, wrsid);
1414return;
1415}
1416/* --Methode-- */
1417void NamedObjMgr::DisplaySurf3D(string& nom, string dopt)
1418{
1419// Pas de display si option dopt = nodisp
1420if ( (dopt == "nodisp") || (dopt == "nodisplay") ) return;
1421
1422ZSync(*myMutex);
1423
1424NObjMgrAdapter* obja=NULL;
1425obja = GetObjAdapter(nom);
1426if (obja == NULL) {
1427 cout << "NamedObjMgr::DisplaySurf3D() Error , No such object " << nom << endl;
1428 return;
1429}
1430if (obja->GetDataObj() == NULL) {
1431 cerr << "NamedObjMgr::DisplaySurf3D() / Error - NULL object ! in " << nom << endl;
1432 return;
1433 }
1434if (!myImgApp) return;
1435
1436P2DArrayAdapter* arr = obja->Get2DArray(dopt);
1437
1438if (!arr) {
1439 string ctyp = typeid(*(obja->GetDataObj())).name();
1440 cout << "NamedObjMgr::DisplaySurf3D() Error , Not supported " << ctyp << endl;
1441 return;
1442 }
1443
1444if ((arr->XSize() > 250) || (arr->YSize() > 250)) {
1445 cout << "NamedObjMgr::DisplaySurf3D() Error , 2D-Array(" << arr->XSize()
1446 << "x" << arr->YSize() << ") too big (max=250x250)" << endl;
1447 delete arr;
1448 return;
1449 }
1450
1451string n1,r1;
1452ParseObjectName(nom, r1, n1);
1453
1454// Si appel venant de PIStdImgApp, il ne faut pas locker le Mutex global de la boucle d'evts
1455bool fglock = (_fgimgapp) ? false : true;
1456
1457int wrsid = 0;
1458PISurfaceDrawer* sdr = new PISurfaceDrawer(arr, true, true, true);
1459wrsid = myImgApp->Disp3DDrawer(sdr, n1, dopt, "", 0, fglock);
1460AddWRsId(nom, wrsid);
1461return;
1462}
1463
1464/* --Methode-- */
1465void NamedObjMgr::DisplayNT(string& nom, string& nmx, string& nmy, string& nmz,
1466 string& erx, string& ery, string& erz, string& wt,
1467 string& label, string dopt, bool fg3d)
1468{
1469// Pas de display si option dopt = nodisp
1470if ( (dopt == "nodisp") || (dopt == "nodisplay") ) return;
1471
1472ZSync(*myMutex);
1473
1474AnyDataObj* obj=GetObj(nom);
1475if (obj == NULL) {
1476 cout << "NamedObjMgr::DisplayNT() Error , No such object " << nom << endl;
1477 return;
1478}
1479if (!myImgApp) return;
1480
1481NTupleInterface * nt = dynamic_cast<NTupleInterface *>(obj);
1482if (nt == NULL) {
1483// if (typeid(*obj) != typeid(NTupleInterface)) {
1484 string ctyp = typeid(*obj).name();
1485 cout << "NamedObjMgr::DisplayNT() Error , Object not an NTuple " << ctyp << endl;
1486 return;
1487 }
1488
1489int wrsid = 0;
1490dopt = "defline " + dopt;
1491
1492string n1,r1;
1493ParseObjectName(nom, r1, n1);
1494
1495// Si appel venant de PIStdImgApp, il ne faut pas locker le Mutex global de la boucle d'evts
1496bool fglock = (_fgimgapp) ? false : true;
1497
1498if ( fg3d && (nmz.length()>0) ) { // Display 3D
1499 PINTuple3D* pin = new PINTuple3D(nt, false);
1500 pin->SelectXYZ(nmx.c_str(), nmy.c_str(), nmz.c_str());
1501 pin->SelectWt(wt.c_str());
1502 pin->SelectLabel(label.c_str());
1503 pin->SelectErrBar(erx.c_str(), ery.c_str(), erz.c_str());
1504 string titre = nmz + "%" + nmy + "%" + nmz;
1505 wrsid = myImgApp->Disp3DDrawer(pin, n1, dopt, titre, 0, fglock);
1506}
1507else {
1508 PINTuple* pin = new PINTuple(nt, false);
1509 pin->SelectXY(nmx.c_str(), nmy.c_str());
1510 pin->SelectWt(wt.c_str());
1511 pin->SelectLabel(label.c_str());
1512 pin->SelectErrBar(erx.c_str(), ery.c_str());
1513 string titre = nmy + "%" + nmx;
1514 wrsid = myImgApp->DispScDrawer( (PIDrawer*)pin, n1, dopt, titre, 0, fglock);
1515 }
1516
1517AddWRsId(nom, wrsid);
1518return;
1519}
1520
1521/* --Methode-- cmv 13/10/98 : Obsolete mais ne pas virer SVP */
1522void NamedObjMgr::DisplayGFD(string& nom, string& numvarx, string& numvary, string& err, string dopt)
1523// Pour le display 2D ou 3D d'un ``GeneralFitData''.
1524//| nom = nom de l'objet GeneralFitData a representer.
1525//| numvarx = numero (nombre entier) de la 1ere variable d'abscisse.
1526//| numvary = numero (nombre entier) de la 2sd variable d'abscisse (3D).
1527//| Pour le display 2D, numvary="" string vide.
1528//| err = qu'elles erreurs faut il representer ?
1529//| - 2D : x y xy (display y=f(x))
1530//| - 3D : x y z xy xz yz xzy (display z=f(x,y))
1531//| Ceci n'est suivi que si on a PI_NotDefLineAtt, sinon toutes
1532//| les barres d'erreurs sont representees.
1533//| opt = options generales pour le display.
1534{
1535// Pas de display si option dopt = nodisp
1536if ( (dopt == "nodisp") || (dopt == "nodisplay") ) return;
1537
1538ZSync(*myMutex);
1539
1540AnyDataObj* obj=GetObj(nom);
1541if(obj == NULL)
1542 {cout << "NamedObjMgr::DisplayGFD() Error , No such object " << nom << endl;
1543 return;}
1544if(!myImgApp) return;
1545if(typeid(*obj) != typeid(GeneralFitData))
1546 {string ctyp = typeid(*obj).name();
1547 cout<<"NamedObjMgr::DisplayGFD() Error , Object not a GeneralFitData "<<ctyp<<endl;
1548 return;}
1549
1550// Decodage des erreurs a representer
1551bool errx=false, erry=false, errz=false;
1552if(err.length()>0) {
1553 for(int i=0;i<(int_4)err.length();i++)
1554 if (err[i]=='x' || err[i]=='X') errx = true;
1555 else if(err[i]=='y' || err[i]=='Y') erry = true;
1556 else if(err[i]=='z' || err[i]=='Z') errz = true;
1557}
1558// Decodage des numeros de variables en abscisse
1559 int numvx=-1, numvy=-1;
1560 if(numvarx.length()>0) numvx = atoi(numvarx.c_str());
1561 if(numvary.length()>0) numvy = atoi(numvary.c_str());
1562
1563 string n1,r1;
1564 ParseObjectName(nom, r1, n1);
1565 // Si appel venant de PIStdImgApp, il ne faut pas locker le Mutex global de la boucle d'evts
1566 bool fglock = (_fgimgapp) ? false : true;
1567
1568 int wrsid = 0;
1569 if(numvy>=0) { // display 3D
1570 PIGenFitDat3D* pigfd = new PIGenFitDat3D(((GeneralFitData*)obj),false);
1571 pigfd->SelectXY(numvx,numvy);
1572 pigfd->SelectErrBar(errx,erry,errz);
1573 wrsid = myImgApp->Disp3DDrawer(pigfd,n1,dopt,"",0,fglock);
1574} else { // display 2D
1575 PIGenFitDat* pigfd = new PIGenFitDat(((GeneralFitData*)obj),false);
1576 pigfd->SelectX(numvx);
1577 pigfd->SelectErrBar(errx,erry);
1578 wrsid = myImgApp->DispScDrawer((PIDrawer*)pigfd,n1,dopt,"",0,fglock);
1579}
1580
1581AddWRsId(nom, wrsid);
1582
1583return;
1584}
1585
1586/* --Methode-- */
1587void NamedObjMgr::DisplayVector(string & nomvx, string& nomvy, string dopt)
1588// Pour l'affichage 2-D de points avec coordonnees definies par deux vecteurs
1589// nomvx et nomvy
1590{
1591// Pas de display si option dopt = nodisp
1592if ( (dopt == "nodisp") || (dopt == "nodisplay") ) return;
1593
1594ZSync(*myMutex);
1595
1596#ifdef SANS_EVOLPLANCK
1597 cerr << " NamedObjMgr::DisplayVector() Error: Not implemented with PEIDA " << endl;
1598#else
1599
1600if(!myImgApp) return;
1601
1602AnyDataObj* obj;
1603obj = GetObj(nomvx);
1604if(obj == NULL) {
1605 cout << "NamedObjMgr::DisplayVector() Error , No such object " << nomvx << endl;
1606 return;
1607}
1608//Vector * vx = dynamic_cast<Vector *>(obj);
1609BaseArray* bax = dynamic_cast<BaseArray *>(obj);
1610if (bax == NULL) {
1611 cout << "NamedObjMgr::DisplayVector() Error " << nomvx << " not a BaseArray ! " << endl;
1612 return;
1613}
1614
1615obj = GetObj(nomvy);
1616if(obj == NULL) {
1617 cout << "NamedObjMgr::DisplayVector() Error , No such object " << nomvy << endl;
1618 return;
1619}
1620BaseArray* bay = dynamic_cast<BaseArray *>(obj);
1621if (bay == NULL) {
1622 cout << "NamedObjMgr::DisplayVector() Error " << nomvy << " not a BaseArray ! " << endl;
1623 return;
1624}
1625
1626Vector vx = *bax;
1627Vector vy = *bay;
1628Vector * cvx, * cvy;
1629
1630if (vx.Size() != vy.Size()) {
1631 cout << "NamedObjMgr::DisplayVector() Warning / Vx.Size() != Vy.Size() " << endl;
1632 if (vx.Size() < vy.Size()) {
1633 cvx = new Vector(vx);
1634 cvy = new Vector(vy.SubVector(Range(0, 0, vx.Size()-1)));
1635 }
1636 else {
1637 cvx = new Vector(vx.SubVector(Range(0, 0, vy.Size()-1)));
1638 cvy = new Vector(vy);
1639 }
1640}
1641else {
1642 cvx = new Vector(vx);
1643 cvy = new Vector(vy);
1644}
1645
1646POVectorAdapter * avx = new POVectorAdapter(cvx, true);
1647POVectorAdapter * avy = new POVectorAdapter(cvy, true);
1648PIYfXDrawer * vxydrw = new PIYfXDrawer(avx, avy, true);
1649
1650string nx,rx;
1651ParseObjectName(nomvx, rx, nx);
1652string ny,ry;
1653ParseObjectName(nomvy, ry, ny);
1654
1655// Si appel venant de PIStdImgApp, il ne faut pas locker le Mutex global de la boucle d'evts
1656bool fglock = (_fgimgapp) ? false : true;
1657
1658string title = ny + " (Y) vs. " + nx + " (X)";
1659// display 2D
1660myImgApp->DispScDrawer(vxydrw, title, dopt, "", 0, fglock);
1661
1662return;
1663
1664#endif
1665}
1666
1667/* --Methode--
1668void NamedObjMgr::DisplayImage(string& nom, string dopt)
1669{
1670 cout << "NamedObjMgr::DisplayImage() a faire ! " << endl;
1671}
1672*/
1673
1674
1675
1676
1677/* --Methode--
1678void NamedObjMgr::SetGraphicAttributes(string gratt)
1679{
1680bool fg = false;
1681servnobjm->DecodeDispOption(gratt, fg);
1682Services2NObjMgr::SetDefaultStatsOption(Services2NObjMgr::GetStatsOption(gratt));
1683}
1684
1685void NamedObjMgr::SetGraphicWinZone(int nzx, int nzy, bool fcr)
1686{
1687if (!myImgApp) return;
1688if (fcr) myImgApp->CreateGraphWin(nzx, nzy);
1689else myImgApp->SetZone(nzx, nzy);
1690}
1691*/
1692
1693/* --Methode-- */
1694void NamedObjMgr::AddWRsId(string & nom, int wrsid)
1695{
1696if(wrsid != 0) {
1697 NObjList::iterator it = myObjs->find(nom);
1698 if (it == myObjs->end()) return;
1699 (*it).second.wrsid.push_back(wrsid);
1700 }
1701return;
1702}
1703
1704/* --Methode-- */
1705void NamedObjMgr::UpdateObjMgrWindow(int did)
1706{
1707if (!myImgApp) return;
1708ZSync(*myMutex);
1709if ( !_fgimgapp ) myImgApp->LockMutex();
1710
1711(myImgApp->ObjMgrW())->ClearObjList();
1712
1713NObjList::iterator it;
1714string cn;
1715for(it = myObjs->begin(); it != myObjs->end(); it++) {
1716 if ((*it).second.dirid != did) continue;
1717 cn = (*it).first.substr(1);
1718 // cn = cn.substr(cn.find('/')+1) + " (T= " + typeid(*((*it).second.obj)).name() + ")" ;
1719 cn = cn.substr(cn.find('/')+1) + " (T= " + (*it).second.obja->GetDataObjType() + ")" ;
1720 (myImgApp->ObjMgrW())->AddObj(cn.c_str(), (*it).second.oid);
1721 }
1722
1723if ( !_fgimgapp ) myImgApp->UnlockMutex(true);
1724}
1725
1726
1727/* Nouvelle-Fonction */
1728void NamedObjMgr::RemoveSpacesFromName(string & nom)
1729{
1730// on supprime les blancs de debut et de fin
1731size_t p = nom.find_first_not_of(" ");
1732if(p>nom.length()) { nom = ""; return; }
1733nom = nom.substr(p);
1734p = nom.find(' ');
1735if(p>nom.length()) p=nom.length();
1736nom = nom.substr(0, p);
1737}
1738
1739/* Nouvelle-Fonction */
1740bool NamedObjMgr::CheckDirName(string & nom)
1741{
1742RemoveSpacesFromName(nom);
1743if (nom.length() < 1) return(false);
1744if (nom[0] == '/') nom = nom.substr(1) ;
1745size_t p = nom.find('/');
1746if (p < nom.length()) nom = nom.substr(0,p);
1747if ((nom.length() < 1) || (! isalpha(nom[0]) ) ) return(false);
1748return(true);
1749}
1750
1751/* Nouvelle-Fonction */
1752int NamedObjMgr::ParseObjectName(string & nom, string & nomrep, string & nomobj)
1753{
1754RemoveSpacesFromName(nom);
1755// Si le nom ne commence pas par un slash, c'est le repertoire courant
1756if (nom[0] != '/') { nomrep = *currDir; nomobj = nom; }
1757else {
1758 string xx = nom.substr(1);
1759 size_t p = xx.find('/');
1760 if (p < xx.length()) {
1761 nomrep = xx.substr(0,p);
1762 nomobj = xx.substr(p+1);
1763 }
1764 else {
1765 nomrep = xx;
1766 nomobj = "";
1767 }
1768 }
1769int rc = 0;
1770NObjDirList::iterator it = myDirs->find(nomrep);
1771if (it != myDirs->end()) rc = (*it).second.id;
1772return(rc);
1773}
1774
Note: See TracBrowser for help on using the repository browser.