129 |
static std::map<int,String> bufferedCommands; |
static std::map<int,String> bufferedCommands; |
130 |
|
|
131 |
static void SendLSCPNotify( LSCPEvent Event ); |
static void SendLSCPNotify( LSCPEvent Event ); |
132 |
|
static int EventSubscribers( std::list<LSCPEvent::event_t> events ); |
133 |
|
static void LockRTNotify( void ) { RTNotifyMutex.Lock(); } |
134 |
|
static void UnlockRTNotify( void ) { RTNotifyMutex.Unlock(); } |
135 |
|
|
136 |
protected: |
protected: |
137 |
int hSocket; |
int hSocket; |
162 |
static Mutex SubscriptionMutex; |
static Mutex SubscriptionMutex; |
163 |
static std::map< LSCPEvent::event_t, std::list<int> > eventSubscriptions; |
static std::map< LSCPEvent::event_t, std::list<int> > eventSubscriptions; |
164 |
static fd_set fdSet; |
static fd_set fdSet; |
165 |
|
|
166 |
|
//Protect main thread that generates real time notify messages |
167 |
|
//like voice count, stream count and buffer fill |
168 |
|
//from LSCP server removing engines and channels from underneath |
169 |
|
static Mutex RTNotifyMutex; |
170 |
}; |
}; |
171 |
|
|
172 |
/** |
/** |