only do the 10 second pause, not the reduction in max_sessions when the event system overloads
This commit is contained in:
parent
9423216b64
commit
0bcfdbe6ca
|
@ -33,7 +33,7 @@
|
||||||
* mod_sofia.h -- SOFIA SIP Endpoint
|
* mod_sofia.h -- SOFIA SIP Endpoint
|
||||||
*
|
*
|
||||||
*/
|
*/
|
||||||
|
#define HAVE_MEMLEAK_LOG 1
|
||||||
/*Defines etc..*/
|
/*Defines etc..*/
|
||||||
/*************************************************************************************************************************************************************/
|
/*************************************************************************************************************************************************************/
|
||||||
#define MANUAL_BYE 1
|
#define MANUAL_BYE 1
|
||||||
|
|
|
@ -333,17 +333,11 @@ static void *SWITCH_THREAD_FUNC switch_event_thread(switch_thread_t *thread, voi
|
||||||
|
|
||||||
|
|
||||||
if (++loops > 2) {
|
if (++loops > 2) {
|
||||||
uint32_t last_sps = 0, sess_count = switch_core_session_count();
|
|
||||||
if (auto_pause) {
|
if (auto_pause) {
|
||||||
switch_log_printf(SWITCH_CHANNEL_LOG, SWITCH_LOG_CRIT, "Event system *still* overloading.\n");
|
switch_log_printf(SWITCH_CHANNEL_LOG, SWITCH_LOG_CRIT, "Event system *still* overloading.\n");
|
||||||
} else {
|
} else {
|
||||||
switch_core_session_ctl(SCSC_LAST_SPS, &last_sps);
|
|
||||||
last_sps = (uint32_t) (float) (last_sps * 0.75f);
|
|
||||||
sess_count = (uint32_t) (float) (sess_count * 0.75f);
|
|
||||||
switch_log_printf(SWITCH_CHANNEL_LOG, SWITCH_LOG_CRIT,
|
switch_log_printf(SWITCH_CHANNEL_LOG, SWITCH_LOG_CRIT,
|
||||||
"Event system overloading. Taking a 10 second break, Reducing max_sessions to %d %dsps\n", sess_count, last_sps);
|
"Event system overloading. Taking a 10 second break\n");
|
||||||
switch_core_session_limit(sess_count);
|
|
||||||
switch_core_session_ctl(SCSC_SPS, &last_sps);
|
|
||||||
auto_pause = 10;
|
auto_pause = 10;
|
||||||
switch_core_session_ctl(SCSC_PAUSE_INBOUND, &auto_pause);
|
switch_core_session_ctl(SCSC_PAUSE_INBOUND, &auto_pause);
|
||||||
}
|
}
|
||||||
|
|
Loading…
Reference in New Issue