Lines Matching defs:max_msgs

842 msg_queue_run_batch(struct spdk_thread *thread, uint32_t max_msgs)
858 	if (max_msgs > 0) {
859 		max_msgs = spdk_min(max_msgs, SPDK_MSG_BATCH_SIZE);
861 		max_msgs = SPDK_MSG_BATCH_SIZE;
864 	count = spdk_ring_dequeue(thread->messages, messages, max_msgs);
1105 thread_poll(struct spdk_thread *thread, uint32_t max_msgs, uint64_t now)
1121 	msg_count = msg_queue_run_batch(thread, max_msgs);
1208 spdk_thread_poll(struct spdk_thread *thread, uint32_t max_msgs, uint64_t now)
1221 		rc = thread_poll(thread, max_msgs, now);
1227 			rc = thread_poll(thread, max_msgs, now);