50 #ifndef DATAPROCESSOR_H_
51 #define DATAPROCESSOR_H_
59 #include "tsparser/IMpegDescriptor.h"
60 using namespace ::br::pucrio::telemidia::ginga::core::tsparser;
62 #include "tsparser/IAIT.h"
63 using namespace ::br::pucrio::telemidia::ginga::core::tsparser::si;
65 #include "dsmcc/carousel/ServiceDomain.h"
66 #include "dsmcc/carousel/IServiceDomainListener.h"
67 #include "dsmcc/carousel/object/IObjectListener.h"
68 #include "dsmcc/carousel/data/MessageProcessor.h"
69 using namespace ::br::pucrio::telemidia::ginga::core::dataprocessing::carousel;
71 #include "EPGProcessor.h"
72 #include "IEPGListener.h"
73 using namespace ::br::pucrio::telemidia::ginga::core::dataprocessing::epg;
75 #include "FilterManager.h"
76 #include "IDataProcessor.h"
77 #include "dsmcc/IStreamEventListener.h"
79 #include "dsmcc/npt/NPTProcessor.h"
80 using namespace ::br::pucrio::telemidia::ginga::core::dataprocessing::dsmcc::npt;
89 IStreamEventListener* listener;
91 pthread_mutex_t* mutex;
99 namespace dataprocessing {
104 EPGProcessor* epgProcessor;
106 map<unsigned int, MessageProcessor*> processors;
107 map<string, set<IStreamEventListener*>*> eventListeners;
108 set<IObjectListener*> objectListeners;
110 set<unsigned int> processedIds;
111 pthread_mutex_t mutex;
112 NPTProcessor* nptProcessor;
113 vector<ITransportSection*> sections;
128 void setNptPrinter(
bool nptPrinter);
130 bool applicationInfoMounted(
IAIT* ait);
131 void serviceDomainMounted(
133 map<string, string>* names,
134 map<string, string>* paths);
137 void removeOCFilterAfterMount(
bool removeIt);
142 void createStreamTypeSectionFilter(
short streamType);
143 void createPidSectionFilter(
int pid);
148 void removeSEListener(
152 void addObjectListener(IObjectListener* listener);
153 void removeObjectListener(IObjectListener* listener);
157 static void* notifySEListener(
void* data);
158 void notifyEitListeners(set<IEventInfo*>* events);
162 void updateChannelStatus(
short newStatus,
IChannel* channel);
Definition: FilterManager.h:72
Definition: IDemuxer.h:108
Definition: IStreamEventListener.h:61
Definition: ISTCProvider.h:64
Definition: IDataProcessor.h:84
Definition: DataProcessor.h:100
Definition: IStreamEvent.h:63
Definition: IChannel.h:62
Definition: DataProcessor.h:88
Definition: ITimeBaseProvider.h:62
Definition: IServiceDomainListener.h:65
Definition: ITransportSection.h:62