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 467 lib/common/ipc_server.c delay_next_flush(pcmk__client_t *c, unsigned int queue_len) queue_len 470 lib/common/ipc_server.c guint delay = (queue_len < 5)? (1000 + 100 * queue_len) : 1500; queue_len 489 lib/common/ipc_server.c unsigned int queue_len = 0; queue_len 501 lib/common/ipc_server.c queue_len = g_queue_get_length(c->event_queue); queue_len 535 lib/common/ipc_server.c queue_len -= sent; queue_len 536 lib/common/ipc_server.c if (sent > 0 || queue_len) { queue_len 538 lib/common/ipc_server.c sent, queue_len, c->ipcs, c->pid, queue_len 542 lib/common/ipc_server.c if (queue_len) { queue_len 548 lib/common/ipc_server.c if (queue_len > QB_MAX(c->queue_max, PCMK_IPC_DEFAULT_QUEUE_MAX)) { queue_len 549 lib/common/ipc_server.c if ((c->queue_backlog <= 1) || (queue_len < c->queue_backlog)) { queue_len 552 lib/common/ipc_server.c CRM_XS " %p", c->pid, queue_len, c->ipcs); queue_len 555 lib/common/ipc_server.c CRM_XS " %p", c->pid, queue_len, c->ipcs); queue_len 562 lib/common/ipc_server.c c->queue_backlog = queue_len; queue_len 563 lib/common/ipc_server.c delay_next_flush(c, queue_len);