seems that the push is fast than pop.I add some code to log the queue length,just like below:
if (!sofia_private) {
if (sess_count >= sess_max || !sofia_test_pflag(profile, PFLAG_RUNNING) || !switch_core_ready_inbound()) {
nua_respond(nh, 503, "Maximum Calls In Progress", SIPTAG_RETRY_AFTER_STR("300"), NUTAG_WITH_THIS(nua), TAG_END());
goto end;
}
switch_log_printf(SWITCH_CHANNEL_LOG, SWITCH_LOG_DEBUG, "switch_queue_size(mod_sofia_globals.msg_queue):%d\n", switch_queue_size(mod_sofia_globals.msg_queue));
switch_log_printf(SWITCH_CHANNEL_LOG, SWITCH_LOG_DEBUG, "critical:%d\n", (unsigned int)critical);
if (switch_queue_size(mod_sofia_globals.msg_queue) > (unsigned int)critical) {
nua_respond(nh, 503, "System Busy", SIPTAG_RETRY_AFTER_STR("300"), NUTAG_WITH_THIS(nua), TAG_END());
goto end;
}
if (sofia_test_pflag(profile, PFLAG_STANDBY)) {
nua_respond(nh, 503, "System Paused", NUTAG_WITH_THIS(nua), TAG_END());
goto end;
}
}
And I found the switch_queue_size(mod_sofia_globals.msg_queue) is increase so fast and almost did not decrease,the below is the log:
2014-04-28 18:55:31.416405 [DEBUG] sofia.c:2081 switch_queue_size(mod_sofia_globals.msg_queue):56157
2014-04-28 18:55:31.436402 [DEBUG] sofia.c:2081 switch_queue_size(mod_sofia_globals.msg_queue):56158
2014-04-28 18:55:31.436402 [DEBUG] sofia.c:2081 switch_queue_size(mod_sofia_globals.msg_queue):56159
2014-04-28 18:55:31.476402 [DEBUG] sofia.c:2081 switch_queue_size(mod_sofia_globals.msg_queue):56160
2014-04-28 18:55:31.496402 [DEBUG] sofia.c:2081 switch_queue_size(mod_sofia_globals.msg_queue):56161
2014-04-28 18:55:31.496402 [DEBUG] sofia.c:2081 switch_queue_size(mod_sofia_globals.msg_queue):56162
2014-04-28 18:55:31.496402 [DEBUG] sofia.c:2081 switch_queue_size(mod_sofia_globals.msg_queue):56163
2014-04-28 18:55:31.516402 [DEBUG] sofia.c:2081 switch_queue_size(mod_sofia_globals.msg_queue):56164
2014-04-28 18:55:31.516402 [DEBUG] sofia.c:2081 switch_queue_size(mod_sofia_globals.msg_queue):56165
2014-04-28 18:55:31.536402 [DEBUG] sofia.c:2081 switch_queue_size(mod_sofia_globals.msg_queue):56166
2014-04-28 18:55:31.556402 [DEBUG] sofia.c:2081 switch_queue_size(mod_sofia_globals.msg_queue):56167
2014-04-28 18:55:31.576407 [DEBUG] sofia.c:2081 switch_queue_size(mod_sofia_globals.msg_queue):56168
2014-04-28 18:55:31.576407 [DEBUG] sofia.c:2081 switch_queue_size(mod_sofia_globals.msg_queue):56169
2014-04-28 18:55:31.576407 [DEBUG] sofia.c:2081 switch_queue_size(mod_sofia_globals.msg_queue):56170
2014-04-28 18:55:31.596403 [DEBUG] sofia.c:2081 switch_queue_size(mod_sofia_globals.msg_queue):56171
2014-04-28 18:55:31.616404 [DEBUG] sofia.c:2081 switch_queue_size(mod_sofia_globals.msg_queue):56169
2014-04-28 18:55:31.636404 [DEBUG] sofia.c:2081 switch_queue_size(mod_sofia_globals.msg_queue):56170
2014-04-28 18:55:31.656403 [DEBUG] sofia.c:2081 switch_queue_size(mod_sofia_globals.msg_queue):56172
2014-04-28 18:55:31.656403 [DEBUG] sofia.c:2081 switch_queue_size(mod_sofia_globals.msg_queue):56173
2014-04-28 18:55:31.656403 [DEBUG] sofia.c:2081 switch_queue_size(mod_sofia_globals.msg_queue):56174
2014-04-28 18:55:31.676404 [DEBUG] sofia.c:2081 switch_queue_size(mod_sofia_globals.msg_queue):56175
2014-04-28 18:55:31.676404 [DEBUG] sofia.c:2081 switch_queue_size(mod_sofia_globals.msg_queue):56175
2014-04-28 18:55:31.716404 [DEBUG] sofia.c:2081 switch_queue_size(mod_sofia_globals.msg_queue):56177
2014-04-28 18:55:31.716404 [DEBUG] sofia.c:2081 switch_queue_size(mod_sofia_globals.msg_queue):56178
2014-04-28 18:55:31.756407 [DEBUG] sofia.c:2081 switch_queue_size(mod_sofia_globals.msg_queue):56180
2014-04-28 18:55:31.756407 [DEBUG] sofia.c:2081 switch_queue_size(mod_sofia_globals.msg_queue):56181
2014-04-28 18:55:31.756407 [DEBUG] sofia.c:2081 switch_queue_size(mod_sofia_globals.msg_queue):56182
2014-04-28 18:55:31.756407 [DEBUG] sofia.c:2081 switch_queue_size(mod_sofia_globals.msg_queue):56183
2014-04-28 18:55:31.776414 [DEBUG] sofia.c:2081 switch_queue_size(mod_sofia_globals.msg_queue):56184
2014-04-28 18:55:31.796402 [DEBUG] sofia.c:2081 switch_queue_size(mod_sofia_globals.msg_queue):56185
2014-04-28 18:55:31.836415 [DEBUG] sofia.c:2081 switch_queue_size(mod_sofia_globals.msg_queue):56179
2014-04-28 18:55:31.856415 [DEBUG] sofia.c:2081 switch_queue_size(mod_sofia_globals.msg_queue):56180
2014-04-28 18:55:31.896415 [DEBUG] sofia.c:2081 switch_queue_size(mod_sofia_globals.msg_queue):56183
2014-04-28 18:55:31.896415 [DEBUG] sofia.c:2081 switch_queue_size(mod_sofia_globals.msg_queue):56184
2014-04-28 18:55:31.896415 [DEBUG] sofia.c:2081 switch_queue_size(mod_sofia_globals.msg_queue):56185
2014-04-28 18:55:31.916416 [DEBUG] sofia.c:2081 switch_queue_size(mod_sofia_globals.msg_queue):56186
2014-04-28 18:55:31.916416 [DEBUG] sofia.c:2081 switch_queue_size(mod_sofia_globals.msg_queue):56187
2014-04-28 18:55:31.916416 [DEBUG] sofia.c:2081 switch_queue_size(mod_sofia_globals.msg_queue):56188
2014-04-28 18:55:31.936415 [DEBUG] sofia.c:2081 switch_queue_size(mod_sofia_globals.msg_queue):56189
2014-04-28 18:55:31.936415 [DEBUG] sofia.c:2081 switch_queue_size(mod_sofia_globals.msg_queue):56190
2014-04-28 18:55:31.936415 [DEBUG] sofia.c:2081 switch_queue_size(mod_sofia_globals.msg_queue):56191
2014-04-28 18:55:31.996416 [DEBUG] sofia.c:2081 switch_queue_size(mod_sofia_globals.msg_queue):56192
2014-04-28 18:55:32.036417 [DEBUG] sofia.c:2081 switch_queue_size(mod_sofia_globals.msg_queue):56194
2014-04-28 18:55:32.036417 [DEBUG] sofia.c:2081 switch_queue_size(mod_sofia_globals.msg_queue):56195
2014-04-28 18:55:32.036417 [DEBUG] sofia.c:2081 switch_queue_size(mod_sofia_globals.msg_queue):56196
2014-04-28 18:55:32.056417 [DEBUG] sofia.c:2081 switch_queue_size(mod_sofia_globals.msg_queue):56197