| /dports/net/freeswitch/freeswitch-1.10.3.-release/src/mod/endpoints/mod_rtmp/ |
| H A D | rtmp.c | 585 while (switch_queue_size(q) > 0 && switch_queue_trypop(q, &pop) == SWITCH_STATUS_SUCCESS && pop) { in flush_video_send_queue()
785 …ERROR, "queued %zu bytes, ts: %d, queue size:%d\n", len, timestamp, switch_queue_size(rsession->vi… in rtmp_send_message()
789 if (rsession->video_send_queue && switch_queue_size(rsession->video_send_queue)) { in rtmp_send_message()
791 …L_LOG, SWITCH_LOG_ERROR, "Got a key frame, flush video queue %d\n", switch_queue_size(rsession->vi… in rtmp_send_message()
799 …ERROR, "queued %zu bytes, ts: %d, queue size:%d\n", len, timestamp, switch_queue_size(rsession->vi… in rtmp_send_message()
817 …OG_ERROR, "pop len: %zu, ts: %d, queue size: %d\n", len, timestamp, switch_queue_size(rsession->vi… in rtmp_send_message()
|
| H A D | rtmp_video.c | 637 if (rsession->video_send_queue && switch_queue_size(rsession->video_send_queue) > 30) { in rtmp_write_video_frame()
|
| /dports/net/freeswitch/freeswitch-1.10.3.-release/src/ |
| H A D | switch_core_memory.c | 554 …switch_queue_size(memory_manager.pool_recycle_queue) + switch_queue_size(memory_manager.pool_queue…
578 int len = switch_queue_size(memory_manager.pool_queue);
|
| H A D | switch_core_media_bug.c | 481 while(switch_queue_size(spy_q) > 0) { in switch_core_media_bug_patch_spy_frame()
578 if (switch_queue_size(q) > min) { in flush_video_queue()
582 if (min && switch_queue_size(q) <= min) { in flush_video_queue()
588 return switch_queue_size(q); in flush_video_queue()
|
| H A D | switch_core_session.c | 1216 x += switch_queue_size(session->private_event_queue);
1220 x += switch_queue_size(session->message_queue);
1229 return switch_queue_size(session->event_queue);
1289 count = switch_queue_size(session->private_event_queue);
1293 count += switch_queue_size(session->private_event_queue_pri);
1312 if (switch_queue_size(session->private_event_queue_pri)) {
|
| H A D | switch_log.c | 727 int size = switch_queue_size(LOG_RECYCLE_QUEUE); in switch_core_memory_reclaim_logger()
|
| H A D | switch_core_sqldb.c | 1668 ttl += switch_queue_size(qm->sql_queue[i]); in qm_ttl()
1854 size = switch_queue_size(qm->sql_queue[index]); in switch_sql_queue_manager_size()
2340 …switch_snprintf(line + l, sizeof(line) - l, "%d%s", switch_queue_size(qm->sql_queue[i]), i == qm->… in switch_user_sql_thread()
|
| H A D | switch_event.c | 369 …if (!PENDING && switch_queue_size(EVENT_DISPATCH_QUEUE) > (unsigned int)(DISPATCH_QUEUE_LEN * DISP… in switch_event_queue_dispatch_event()
527 size = switch_queue_size(EVENT_RECYCLE_QUEUE); in switch_core_memory_reclaim_events()
530 size = switch_queue_size(EVENT_HEADER_RECYCLE_QUEUE); in switch_core_memory_reclaim_events()
|
| H A D | switch_apr.c | 1152 SWITCH_DECLARE(unsigned int) switch_queue_size(switch_queue_t *queue) in switch_queue_size() function
|
| H A D | switch_rtp.c | 5479 …on->dtmf_data.out_digit_dur && rtp_session->dtmf_data.dtmf_queue && switch_queue_size(rtp_session-… in do_2833()
7353 …switch_queue_size(rtp_session->dtmf_data.dtmf_queue) || switch_queue_size(rtp_session->dtmf_data.d… in rtp_common_read()
7949 has = switch_queue_size(rtp_session->dtmf_data.dtmf_inqueue); in switch_rtp_has_dtmf()
|
| H A D | switch_utils.c | 280 return switch_queue_size(fb->queue); in switch_frame_buffer_size()
|
| H A D | switch_channel.c | 491 has = switch_queue_size(channel->dtmf_queue); in switch_channel_has_dtmf()
|
| /dports/net/freeswitch/freeswitch-1.10.3.-release/src/mod/applications/mod_mp4v2/ |
| H A D | mod_mp4v2.c | 268 if (switch_queue_size(q) > min) { in flush_video_queue()
272 if (min && switch_queue_size(q) <= min) { in flush_video_queue()
278 return switch_queue_size(q); in flush_video_queue()
|
| /dports/net/freeswitch/freeswitch-1.10.3.-release/src/mod/applications/mod_hiredis/ |
| H A D | hiredis_pipeline.c | 47 while ( profile->pipeline_running || switch_queue_size(profile->active_requests) > 0 ) { in pipeline_thread()
|
| /dports/net/freeswitch/freeswitch-1.10.3.-release/src/mod/applications/mod_av/ |
| H A D | avformat.c | 762 if (switch_queue_size(q) > min) { in flush_video_queue()
766 if (min && switch_queue_size(q) <= min) { in flush_video_queue()
772 return switch_queue_size(q); in flush_video_queue()
826 size = switch_queue_size(context->eh.video_queue); in video_thread_run()
1355 vid_frames = switch_queue_size(context->eh.video_queue);
2359 if (!context->file_read_thread_running && switch_queue_size(context->eh.video_queue) == 0) {
2497 if (switch_queue_size(context->eh.video_queue) > 0) {
|
| /dports/net/freeswitch/freeswitch-1.10.3.-release/src/mod/applications/mod_video_filter/ |
| H A D | mod_video_filter.c | 121 if (switch_queue_size(q) > min) { in flush_video_queue()
125 if (min && switch_queue_size(q) <= min) { in flush_video_queue()
131 return switch_queue_size(q); in flush_video_queue()
|
| /dports/net/freeswitch/freeswitch-1.10.3.-release/src/mod/formats/mod_vlc/ |
| H A D | mod_vlc.c | 1149 while((flags & SVR_FLUSH) && switch_queue_size(vcontext->video_queue) > 1) { in vlc_file_read_video()
1320 …xt->audio_buffer && switch_buffer_inuse(vcontext->audio_buffer)) || switch_queue_size(vcontext->vi… in vlc_file_av_close()
1746 if (switch_queue_size(context->video_queue) == 0) { in vlc_write_video_imem_get_callback()
1988 while(switch_buffer_inuse(context->audio_buffer) || switch_queue_size(context->video_queue)) { in SWITCH_STANDARD_APP()
2529 while(switch_queue_size(tech_pvt->context->video_queue) > 1) { in vlc_read_video_frame()
|
| /dports/net/freeswitch/freeswitch-1.10.3.-release/src/mod/formats/mod_local_stream/ |
| H A D | mod_local_stream.c | 206 if (switch_queue_size(q) == 0) { in flush_video_queue()
1048 …while(context->ready && context->source->ready && switch_queue_size(context->video_q) > min_qsize)… in local_stream_file_read_video()
1059 while (!(flags & SVR_BLOCK) && switch_queue_size(context->video_q) < buf_qsize) { in local_stream_file_read_video()
|
| /dports/net/freeswitch/freeswitch-1.10.3.-release/src/mod/event_handlers/mod_event_socket/ |
| H A D | mod_event_socket.c | 181 …TCH_LOG_CRIT, "Lost [%d] log lines! Log Queue size: [%u/%u]\n", ll, switch_queue_size(l->log_queue… in socket_logger()
185 unsigned int qsize = switch_queue_size(l->log_queue); in socket_logger()
390 …ITCH_LOG_CRIT, "Lost [%d] events! Event Queue size: [%u/%u]\n", le, switch_queue_size(l->event_que… in event_handler()
394 unsigned int qsize = switch_queue_size(l->event_queue); in event_handler()
|
| /dports/net/freeswitch/freeswitch-1.10.3.-release/src/mod/event_handlers/mod_amqp/ |
| H A D | mod_amqp_producer.c | 103 unsigned int queue_size = switch_queue_size(profile->send_queue); in mod_amqp_producer_event_handler()
|
| /dports/net/freeswitch/freeswitch-1.10.3.-release/src/include/ |
| H A D | switch_apr.h | 646 SWITCH_DECLARE(unsigned int) switch_queue_size(switch_queue_t *queue);
|
| /dports/net/freeswitch/freeswitch-1.10.3.-release/src/mod/applications/mod_conference/ |
| H A D | conference_loop.c | 887 if (switch_queue_size(member->dtmf_queue)) { in conference_loop_input()
1256 if (switch_queue_size(member->dtmf_queue)) { in conference_loop_input()
|
| H A D | conference_video.c | 1829 …while (switch_queue_size(q) > min && switch_queue_trypop(q, &pop) == SWITCH_STATUS_SUCCESS && pop)… in conference_video_flush_queue()
1835 return r + switch_queue_size(q); in conference_video_flush_queue()
2776 size = switch_queue_size(member->video_queue); in conference_video_pop_next_image()
4288 size = switch_queue_size(canvas->video_queue); in pop_conference_video_next_canvas_image()
5009 switch_queue_size(member->video_queue) < (int)member->conference->video_fps.fps && in conference_video_thread_callback()
|
| /dports/net/freeswitch/freeswitch-1.10.3.-release/src/mod/endpoints/mod_verto/ |
| H A D | mod_verto.c | 1452 int this_pass = switch_queue_size(jsock->event_queue); in jsock_check_event_queue()
|
| /dports/net/freeswitch/freeswitch-1.10.3.-release/src/mod/endpoints/mod_sofia/ |
| H A D | sofia.c | 2384 …if ((switch_queue_size(mod_sofia_globals.msg_queue) > (SOFIA_MSG_QUEUE_SIZE * (unsigned int)msg_qu… in sofia_queue_message()
2484 if (switch_queue_size(mod_sofia_globals.msg_queue) > (unsigned int)critical) { in sofia_event_callback()
|