queue_len         203 lib/cluster/cpg.c     guint queue_len = 0;
queue_len         212 lib/cluster/cpg.c     queue_len = g_list_length(cs_message_queue);
queue_len         213 lib/cluster/cpg.c     if (((queue_len % 1000) == 0) && (queue_len > 1)) {
queue_len         214 lib/cluster/cpg.c         crm_err("CPG queue has grown to %d", queue_len);
queue_len         216 lib/cluster/cpg.c     } else if (queue_len == CS_SEND_MAX) {
queue_len         217 lib/cluster/cpg.c         crm_warn("CPG queue has grown to %d", queue_len);
queue_len         243 lib/cluster/cpg.c     queue_len -= sent;
queue_len         244 lib/cluster/cpg.c     do_crm_log((queue_len > 5)? LOG_INFO : LOG_TRACE,
queue_len         246 lib/cluster/cpg.c                sent, pcmk__plural_s(sent), queue_len, pcmk__cs_err_str(rc),
queue_len         253 lib/cluster/cpg.c             delay_ms = QB_MIN(1000, CS_SEND_MAX + (10 * queue_len));
queue_len         475 lib/common/ipc_server.c delay_next_flush(pcmk__client_t *c, unsigned int queue_len)
queue_len         478 lib/common/ipc_server.c     guint delay = (queue_len < 5)? (1000 + 100 * queue_len) : 1500;
queue_len         497 lib/common/ipc_server.c     unsigned int queue_len = 0;
queue_len         509 lib/common/ipc_server.c         queue_len = g_queue_get_length(c->event_queue);
queue_len         543 lib/common/ipc_server.c     queue_len -= sent;
queue_len         544 lib/common/ipc_server.c     if (sent > 0 || queue_len) {
queue_len         546 lib/common/ipc_server.c                   sent, queue_len, c->ipcs, c->pid,
queue_len         550 lib/common/ipc_server.c     if (queue_len) {
queue_len         556 lib/common/ipc_server.c         if (queue_len > QB_MAX(c->queue_max, PCMK_IPC_DEFAULT_QUEUE_MAX)) {
queue_len         557 lib/common/ipc_server.c             if ((c->queue_backlog <= 1) || (queue_len < c->queue_backlog)) {
queue_len         560 lib/common/ipc_server.c                          CRM_XS " %p", c->pid, queue_len, c->ipcs);
queue_len         563 lib/common/ipc_server.c                          CRM_XS " %p", c->pid, queue_len, c->ipcs);
queue_len         570 lib/common/ipc_server.c         c->queue_backlog = queue_len;
queue_len         571 lib/common/ipc_server.c         delay_next_flush(c, queue_len);