queue_len         152 lib/cluster/cpg.c     int queue_len = 0;
queue_len         161 lib/cluster/cpg.c     queue_len = g_list_length(cs_message_queue);
queue_len         162 lib/cluster/cpg.c     if ((queue_len % 1000) == 0 && queue_len > 1) {
queue_len         163 lib/cluster/cpg.c         crm_err("CPG queue has grown to %d", queue_len);
queue_len         165 lib/cluster/cpg.c     } else if (queue_len == CS_SEND_MAX) {
queue_len         166 lib/cluster/cpg.c         crm_warn("CPG queue has grown to %d", queue_len);
queue_len         195 lib/cluster/cpg.c     queue_len -= sent;
queue_len         198 lib/cluster/cpg.c                  sent, queue_len, last_sent, ais_error2text(rc),
queue_len         202 lib/cluster/cpg.c                   sent, queue_len, last_sent, ais_error2text(rc),
queue_len         210 lib/cluster/cpg.c             delay_ms = QB_MIN(1000, CS_SEND_MAX + (10 * queue_len));
queue_len         458 lib/common/ipc_server.c delay_next_flush(pcmk__client_t *c, unsigned int queue_len)
queue_len         461 lib/common/ipc_server.c     guint delay = (queue_len < 5)? (1000 + 100 * queue_len) : 1500;
queue_len         480 lib/common/ipc_server.c     unsigned int queue_len = 0;
queue_len         492 lib/common/ipc_server.c         queue_len = g_queue_get_length(c->event_queue);
queue_len         526 lib/common/ipc_server.c     queue_len -= sent;
queue_len         527 lib/common/ipc_server.c     if (sent > 0 || queue_len) {
queue_len         529 lib/common/ipc_server.c                   sent, queue_len, c->ipcs, c->pid,
queue_len         533 lib/common/ipc_server.c     if (queue_len) {
queue_len         539 lib/common/ipc_server.c         if (queue_len > QB_MAX(c->queue_max, PCMK_IPC_DEFAULT_QUEUE_MAX)) {
queue_len         540 lib/common/ipc_server.c             if ((c->queue_backlog <= 1) || (queue_len < c->queue_backlog)) {
queue_len         543 lib/common/ipc_server.c                          CRM_XS " %p", c->pid, queue_len, c->ipcs);
queue_len         546 lib/common/ipc_server.c                          CRM_XS " %p", c->pid, queue_len, c->ipcs);
queue_len         553 lib/common/ipc_server.c         c->queue_backlog = queue_len;
queue_len         554 lib/common/ipc_server.c         delay_next_flush(c, queue_len);