More flag checks

git-svn-id: http://svn.freeswitch.org/svn/freeswitch/trunk/contrib@14046 d0543943-73ff-0310-b7d9-9358b9ac24b2

mod/endpoints/mod_khomp/mod_khomp.cpp

@@ -166,6 +166,8 @@ static void printChannels(switch_stream_handle_t* stream, unsigned int device,
  */
 static switch_status_t tech_init(KhompPvt *tech_pvt, switch_core_session_t *session)
 {
+    tech_pvt->flags = 0;
+    
     tech_pvt->_read_frame.data = tech_pvt->_databuf;
     tech_pvt->_read_frame.buflen = sizeof(tech_pvt->_databuf);
 

mod/endpoints/mod_khomp/src/khomp_pvt.cpp

@@ -241,6 +241,9 @@ bool KhompPvt::obtain_tx(void)
 
 bool KhompPvt::start_stream(void)
 {
+    if(switch_test_flag(this, TFLAG_STREAM))
+        return true;
+    
     try
     {
         Globals::_k3lapi.mixer(_KDeviceId, _KChannelId, 0, kmsPlay, _KChannelId);
@@ -258,6 +261,9 @@ bool KhompPvt::start_stream(void)
 
 bool KhompPvt::stop_stream(void)
 {
+    if(!switch_test_flag(this, TFLAG_STREAM))
+        return true;
+    
     try
     {
         Globals::_k3lapi.mixer(_KDeviceId, _KChannelId, 0, kmsGenerator, kmtSilence);
@@ -275,6 +281,9 @@ bool KhompPvt::stop_stream(void)
 
 bool KhompPvt::start_listen(bool conn_rx)
 {
+    if(switch_test_flag(this, TFLAG_LISTEN))
+        return true;
+    
 	const size_t buffer_size = KHOMP_PACKET_SIZE;
 
     if (conn_rx)
@@ -299,6 +308,9 @@ bool KhompPvt::start_listen(bool conn_rx)
 
 bool KhompPvt::stop_listen(void)
 {
+    if(!switch_test_flag(this, TFLAG_LISTEN))
+        return true;
+    
     try
     {
         Globals::_k3lapi.command(_KDeviceId, _KChannelId, CM_STOP_LISTEN);