RSS Git Download  Clone
Raw View History
Blames found: 7 Mode: text/x-c++src Binary: false


Hang on, we reloading big blames...
/******************************************************************************* * TmsEventServerList.cc TMS List of Event Servers * T.Barnaby, BEAM Ltd, 2007-04-19 ******************************************************************************* */ #include <stdlib.h> #include <stdint.h> #include <TmsEventServerList.h> namespace Tms { TmsEventServerList::TmsEventServerList(){ } TmsEventServerList::~TmsEventServerList(){ olock.lock(); olock.unlock(); } BError TmsEventServerList::append(BString name){ BError err; TmsEvent* e = new TmsEvent(name); #ifdef ZAP if(err = e->connectService(name)){ delete e; printf("TmsEventServerList::append: Connection Error: %s\n", err.getString().retStr()); return err; } #endif // printf("TmsEventServerList::append: Name: %s Num: %d\n", name.retStr(), oeventServers.number()); del(name); // Make sure there is only one entry olock.lock(); oeventServers.append(e); olock.unlock(); return err; } BError TmsEventServerList::del(BString name){ BError err; BIter i; olock.lock(); for(oeventServers.start(i); !oeventServers.isEnd(i); ){ if(oeventServers[i]->getServiceName() == name){ delete oeventServers[i]; oeventServers.del(i); } else { oeventServers.next(i); } } olock.unlock(); return err; }
BError TmsEventServerList::errorEvent(BUInt32 cycleNumber, BError error){
BError err; BIter i; olock.lock(); for(oeventServers.start(i); !oeventServers.isEnd(i); ){ if(err = oeventServers[i]->errorEvent(cycleNumber, error)){ if(err.getErrorNo() < 0){ delete oeventServers[i]; oeventServers.del(i); } else { oeventServers.next(i); } } else { oeventServers.next(i); } } olock.unlock(); return err; }
BError TmsEventServerList::cycleStartEvent(BUInt32 cycleNumber){
BError err; BIter i; olock.lock(); // printf("TmsEventServerList::cycleStartEvent: Num: %d\n", oeventServers.number()); for(oeventServers.start(i); !oeventServers.isEnd(i); ){ if(err = oeventServers[i]->cycleStartEvent(cycleNumber)){ if(err.getErrorNo() < 0){ delete oeventServers[i]; oeventServers.del(i); } else { oeventServers.next(i); } } else { oeventServers.next(i); } } olock.unlock(); return err; }
BError TmsEventServerList::cycleStopEvent(BUInt32 cycleNumber){
BError err; BIter i; olock.lock(); for(oeventServers.start(i); !oeventServers.isEnd(i); ){ if(err = oeventServers[i]->cycleStopEvent(cycleNumber)){ if(err.getErrorNo() < 0){ delete oeventServers[i]; oeventServers.del(i); } else { oeventServers.next(i); } } else { oeventServers.next(i); } } olock.unlock(); return err; } BError TmsEventServerList::dataEvent(DataInfo dataInfo){ BError err; BIter i; olock.lock(); for(oeventServers.start(i); !oeventServers.isEnd(i); ){ if(err = oeventServers[i]->dataEvent(dataInfo)){ if(err.getErrorNo() < 0){ delete oeventServers[i]; oeventServers.del(i); } else { oeventServers.next(i); } } else { oeventServers.next(i); } } olock.unlock(); return err; } }