cs_message_queue 133 lib/cluster/cpg.c GListPtr cs_message_queue = NULL; cs_message_queue 161 lib/cluster/cpg.c queue_len = g_list_length(cs_message_queue); cs_message_queue 175 lib/cluster/cpg.c while (cs_message_queue && sent < CS_SEND_MAX) { cs_message_queue 176 lib/cluster/cpg.c struct iovec *iov = cs_message_queue->data; cs_message_queue 190 lib/cluster/cpg.c cs_message_queue = g_list_remove(cs_message_queue, iov); cs_message_queue 196 lib/cluster/cpg.c if (sent > 1 || cs_message_queue) { cs_message_queue 206 lib/cluster/cpg.c if (cs_message_queue) { cs_message_queue 226 lib/cluster/cpg.c cs_message_queue = g_list_append(cs_message_queue, iov);