queue_len         214 lib/cluster/cpg.c     guint queue_len = 0;
queue_len         223 lib/cluster/cpg.c     queue_len = g_list_length(cs_message_queue);
queue_len         224 lib/cluster/cpg.c     if (((queue_len % 1000) == 0) && (queue_len > 1)) {
queue_len         225 lib/cluster/cpg.c         crm_err("CPG queue has grown to %d", queue_len);
queue_len         227 lib/cluster/cpg.c     } else if (queue_len == CS_SEND_MAX) {
queue_len         228 lib/cluster/cpg.c         crm_warn("CPG queue has grown to %d", queue_len);
queue_len         254 lib/cluster/cpg.c     queue_len -= sent;
queue_len         255 lib/cluster/cpg.c     do_crm_log((queue_len > 5)? LOG_INFO : LOG_TRACE,
queue_len         257 lib/cluster/cpg.c                sent, pcmk__plural_s(sent), queue_len, pcmk__cs_err_str(rc),
queue_len         264 lib/cluster/cpg.c             delay_ms = QB_MIN(1000, CS_SEND_MAX + (10 * queue_len));
queue_len         461 lib/common/ipc_server.c delay_next_flush(pcmk__client_t *c, unsigned int queue_len)
queue_len         464 lib/common/ipc_server.c     guint delay = (queue_len < 5)? (1000 + 100 * queue_len) : 1500;
queue_len         483 lib/common/ipc_server.c     unsigned int queue_len = 0;
queue_len         495 lib/common/ipc_server.c         queue_len = g_queue_get_length(c->event_queue);
queue_len         529 lib/common/ipc_server.c     queue_len -= sent;
queue_len         530 lib/common/ipc_server.c     if (sent > 0 || queue_len) {
queue_len         532 lib/common/ipc_server.c                   sent, queue_len, c->ipcs, c->pid,
queue_len         536 lib/common/ipc_server.c     if (queue_len) {
queue_len         542 lib/common/ipc_server.c         if (queue_len > QB_MAX(c->queue_max, PCMK_IPC_DEFAULT_QUEUE_MAX)) {
queue_len         543 lib/common/ipc_server.c             if ((c->queue_backlog <= 1) || (queue_len < c->queue_backlog)) {
queue_len         546 lib/common/ipc_server.c                          CRM_XS " %p", c->pid, queue_len, c->ipcs);
queue_len         549 lib/common/ipc_server.c                          CRM_XS " %p", c->pid, queue_len, c->ipcs);
queue_len         556 lib/common/ipc_server.c         c->queue_backlog = queue_len;
queue_len         557 lib/common/ipc_server.c         delay_next_flush(c, queue_len);