cs_message_queue 115 lib/cluster/cpg.c GListPtr cs_message_queue = NULL; cs_message_queue 143 lib/cluster/cpg.c queue_len = g_list_length(cs_message_queue); cs_message_queue 157 lib/cluster/cpg.c while (cs_message_queue && sent < CS_SEND_MAX) { cs_message_queue 158 lib/cluster/cpg.c struct iovec *iov = cs_message_queue->data; cs_message_queue 172 lib/cluster/cpg.c cs_message_queue = g_list_remove(cs_message_queue, iov); cs_message_queue 178 lib/cluster/cpg.c if (sent > 1 || cs_message_queue) { cs_message_queue 188 lib/cluster/cpg.c if (cs_message_queue) { cs_message_queue 208 lib/cluster/cpg.c cs_message_queue = g_list_append(cs_message_queue, iov);