mirror of
https://github.com/jambonz/freeswitch-modules.git
synced 2026-01-25 02:08:27 +00:00
Compare commits
1 Commits
| Author | SHA1 | Date | |
|---|---|---|---|
| 3459188bb6 |
@@ -38,7 +38,6 @@ namespace {
|
|||||||
static uint32_t playCount = 0;
|
static uint32_t playCount = 0;
|
||||||
|
|
||||||
switch_status_t processIncomingBinary(private_t* tech_pvt, switch_core_session_t* session, const char* message, size_t dataLength) {
|
switch_status_t processIncomingBinary(private_t* tech_pvt, switch_core_session_t* session, const char* message, size_t dataLength) {
|
||||||
CircularBuffer_t *cBuffer = (CircularBuffer_t *) tech_pvt->circularBuffer;
|
|
||||||
uint8_t* data = reinterpret_cast<uint8_t*>(const_cast<char*>(message));
|
uint8_t* data = reinterpret_cast<uint8_t*>(const_cast<char*>(message));
|
||||||
uint16_t* data_uint16 = reinterpret_cast<uint16_t*>(data);
|
uint16_t* data_uint16 = reinterpret_cast<uint16_t*>(data);
|
||||||
std::vector<uint16_t> pcm_data(data_uint16, data_uint16 + dataLength / sizeof(uint16_t));
|
std::vector<uint16_t> pcm_data(data_uint16, data_uint16 + dataLength / sizeof(uint16_t));
|
||||||
@@ -70,7 +69,9 @@ namespace {
|
|||||||
return SWITCH_STATUS_FALSE;
|
return SWITCH_STATUS_FALSE;
|
||||||
}
|
}
|
||||||
|
|
||||||
switch_mutex_lock(tech_pvt->mutex);
|
if (nullptr != tech_pvt->mutex && switch_mutex_trylock(tech_pvt->mutex) == SWITCH_STATUS_SUCCESS) {
|
||||||
|
//switch_mutex_lock(tech_pvt->mutex);
|
||||||
|
CircularBuffer_t *cBuffer = (CircularBuffer_t *) tech_pvt->circularBuffer;
|
||||||
|
|
||||||
try {
|
try {
|
||||||
// Resize the buffer if necessary
|
// Resize the buffer if necessary
|
||||||
@@ -92,11 +93,11 @@ namespace {
|
|||||||
switch_mutex_unlock(tech_pvt->mutex);
|
switch_mutex_unlock(tech_pvt->mutex);
|
||||||
return SWITCH_STATUS_FALSE;
|
return SWITCH_STATUS_FALSE;
|
||||||
}
|
}
|
||||||
|
|
||||||
switch_mutex_unlock(tech_pvt->mutex);
|
switch_mutex_unlock(tech_pvt->mutex);
|
||||||
|
|
||||||
return SWITCH_STATUS_SUCCESS;
|
return SWITCH_STATUS_SUCCESS;
|
||||||
}
|
}
|
||||||
|
return SWITCH_STATUS_FALSE;
|
||||||
|
}
|
||||||
|
|
||||||
void processIncomingMessage(private_t* tech_pvt, switch_core_session_t* session, const char* message) {
|
void processIncomingMessage(private_t* tech_pvt, switch_core_session_t* session, const char* message) {
|
||||||
std::string msg = message;
|
std::string msg = message;
|
||||||
|
|||||||
Reference in New Issue
Block a user