cs_message_queue 43 lib/cluster/cpg.c static GList *cs_message_queue = NULL; cs_message_queue 223 lib/cluster/cpg.c queue_len = g_list_length(cs_message_queue); cs_message_queue 237 lib/cluster/cpg.c while ((cs_message_queue != NULL) && (sent < CS_SEND_MAX)) { cs_message_queue 238 lib/cluster/cpg.c struct iovec *iov = cs_message_queue->data; cs_message_queue 249 lib/cluster/cpg.c cs_message_queue = g_list_remove(cs_message_queue, iov); cs_message_queue 255 lib/cluster/cpg.c if ((sent > 1) || (cs_message_queue != NULL)) { cs_message_queue 263 lib/cluster/cpg.c if (cs_message_queue) { cs_message_queue 1024 lib/cluster/cpg.c cs_message_queue = g_list_append(cs_message_queue, iov);