queue_len         134 lib/cluster/cpg.c     int queue_len = 0;
queue_len         143 lib/cluster/cpg.c     queue_len = g_list_length(cs_message_queue);
queue_len         144 lib/cluster/cpg.c     if ((queue_len % 1000) == 0 && queue_len > 1) {
queue_len         145 lib/cluster/cpg.c         crm_err("CPG queue has grown to %d", queue_len);
queue_len         147 lib/cluster/cpg.c     } else if (queue_len == CS_SEND_MAX) {
queue_len         148 lib/cluster/cpg.c         crm_warn("CPG queue has grown to %d", queue_len);
queue_len         177 lib/cluster/cpg.c     queue_len -= sent;
queue_len         180 lib/cluster/cpg.c                  sent, queue_len, last_sent, ais_error2text(rc),
queue_len         184 lib/cluster/cpg.c                   sent, queue_len, last_sent, ais_error2text(rc),
queue_len         192 lib/cluster/cpg.c             delay_ms = QB_MIN(1000, CS_SEND_MAX + (10 * queue_len));
queue_len         519 lib/common/ipc.c delay_next_flush(crm_client_t *c, unsigned int queue_len)
queue_len         522 lib/common/ipc.c     guint delay = (queue_len < 40)? (1000 + 100 * queue_len) : 5000;
queue_len         532 lib/common/ipc.c     unsigned int queue_len = 0;
queue_len         543 lib/common/ipc.c     queue_len = g_list_length(c->event_queue);
queue_len         570 lib/common/ipc.c     queue_len -= sent;
queue_len         571 lib/common/ipc.c     if (sent > 0 || queue_len) {
queue_len         573 lib/common/ipc.c                   sent, queue_len, c->ipcs, c->pid,
queue_len         577 lib/common/ipc.c     if (queue_len) {
queue_len         583 lib/common/ipc.c         if (queue_len > QB_MAX(c->queue_max, PCMK_IPC_DEFAULT_QUEUE_MAX)) {
queue_len         584 lib/common/ipc.c             if ((c->queue_backlog <= 1) || (queue_len < c->queue_backlog)) {
queue_len         587 lib/common/ipc.c                          CRM_XS " %p", c->pid, queue_len, c->ipcs);
queue_len         590 lib/common/ipc.c                          CRM_XS " %p", c->pid, queue_len, c->ipcs);
queue_len         597 lib/common/ipc.c         c->queue_backlog = queue_len;
queue_len         598 lib/common/ipc.c         delay_next_flush(c, queue_len);