Lines Matching defs:messages

136 	struct spdk_ring		*messages;
445 	spdk_ring_free(thread->messages);
549 	thread->messages = spdk_ring_create(SPDK_RING_TYPE_MP_SC, 65536, SPDK_ENV_NUMA_ID_ANY);
550 	if (!thread->messages) {
560 		 * up organically as messages are passed to the thread. */
669 	if (spdk_ring_count(thread->messages) > 0) {
670 		SPDK_INFOLOG(thread, "thread %s still has messages\n", thread->name);
845 	void *messages[SPDK_MSG_BATCH_SIZE];
851 	 * spdk_ring_dequeue() fills messages and returns how many entries it wrote,
855 	memset(messages, 0, sizeof(messages));
864 	count = spdk_ring_dequeue(thread->messages, messages, max_msgs);
866 	    spdk_ring_count(thread->messages) != 0) {
877 		struct spdk_msg *msg = messages[i];
888 			/* Insert the messages at the head. We want to re-use the hot
1289 	if (spdk_ring_count(thread->messages) ||
1439 	rc = spdk_ring_enqueue(thread->messages, (void **)&msg, 1, NULL);
2787 		 * Clear msg_fd since thread messages will be polled directly in poll mode.