00001
00002
00003
00004
00005
00006
00007
00008
00009
00010
00011
00012
00013
00014
00015
00016
00017
00018
00019
00020
00021
00022
00023
00024
00025
00026
00027
00028
00029
00030
00031
00032
00033 #include "mmscore/mmseventsignupmanager.h"
00034 #include "mmstools/tools.h"
00035 #include <string.h>
00036 #include <algorithm>
00037
00038 MMSEventSignupManager::MMSEventSignupManager() {
00039 }
00040
00041 void MMSEventSignupManager::signup(IMMSEventSignup *signup) {
00042 this->signupmutex.lock();
00043 if(signup->isPlugin())
00044 this->signups.push_back((MMSEventSignup *)signup);
00045 else
00046 this->signals.push_back((MMSEventSignup *)signup);
00047
00048 this->signupmutex.unlock();
00049 }
00050
00051 vector<MMSPluginData *> MMSEventSignupManager::getReceiverPlugins(_IMMSEvent *event) {
00052 vector<MMSPluginData *> mydata;
00053
00054 vector<string> subscriptions;
00055 vector<MMSEventSignup *>::iterator signit;
00056
00057 string heading = event->getHeading();
00058
00059 for(signit = this->signups.begin();signit != this->signups.end();signit++) {
00060 (*signit)->lock();
00061 subscriptions = (*signit)->getSubScriptions();
00062
00063 for(vector<string>::iterator it = subscriptions.begin(); it != subscriptions.end(); ++it) {
00064
00065 if(heading.compare(0, (*it).size(), *it) == 0) {
00066 MMSPluginData *myplugin = new MMSPluginData;
00067 *myplugin = (*signit)->getPluginData();
00068 mydata.push_back(myplugin);
00069 }
00070 }
00071 (*signit)->unlock();
00072 }
00073
00074 if(mydata.empty())
00075 throw MMSEventSignupManagerError(0,"no subscriptions found for " + heading);
00076
00077 return mydata;
00078 }
00079
00080 vector<sigc::signal<void, _IMMSEvent*> *> MMSEventSignupManager::getReceiverSignals(_IMMSEvent *event) {
00081 vector<sigc::signal<void, _IMMSEvent*> *> mysignals;
00082 vector<string> subscriptions;
00083 vector<MMSEventSignup *>::iterator signupsit;
00084
00085 string heading = event->getHeading();
00086
00087 for(signupsit= this->signals.begin();signupsit != this->signals.end();++signupsit) {
00088 (*signupsit)->lock();
00089 subscriptions = (*signupsit)->getSubScriptions();
00090
00091 for(vector<string>::iterator it = subscriptions.begin(); it != subscriptions.end(); ++it) {
00092
00093 if(heading.compare(0, (*it).size(), *it) == 0) {
00094 mysignals.push_back((*signupsit)->getSignal());
00095 }
00096 }
00097 (*signupsit)->unlock();
00098 }
00099
00100 if(mysignals.empty())
00101 throw MMSEventSignupManagerError(0,"no subscriptions found");
00102
00103 return mysignals;
00104
00105 }