67 				struct scheduler_msg *msg)  in sched_history_queue()  argument
69 	msg->queue_id = queue->qid;  in sched_history_queue()
70 	msg->queue_depth = qdf_list_size(&queue->mq_list);  in sched_history_queue()
71 	msg->queued_at_us = qdf_get_log_timestamp_usecs();  in sched_history_queue()
74 static void sched_history_start(struct scheduler_msg *msg)  in sched_history_start()  argument
78 		.callback = msg->callback,  in sched_history_start()
79 		.type_id = msg->type,  in sched_history_start()
80 		.queue_start_us = msg->queued_at_us,  in sched_history_start()
81 		.queue_duration_us = started_at_us - msg->queued_at_us,  in sched_history_start()
82 		.queue_depth = msg->queue_depth,  in sched_history_start()
142 				       struct scheduler_msg *msg) { }  in sched_history_queue()  argument
143 static inline void sched_history_start(struct scheduler_msg *msg) { }  in sched_history_start()  argument
252 		      struct scheduler_msg *msg)  in scheduler_mq_put()  argument
255 	sched_history_queue(msg_q, msg);  in scheduler_mq_put()
256 	qdf_list_insert_back(&msg_q->mq_list, &msg->node);  in scheduler_mq_put()
261 			    struct scheduler_msg *msg)  in scheduler_mq_put_front()  argument
264 	sched_history_queue(msg_q, msg);  in scheduler_mq_put_front()
265 	qdf_list_insert_front(&msg_q->mq_list, &msg->node);  in scheduler_mq_put_front()
313 struct scheduler_msg *scheduler_core_msg_dup(struct scheduler_msg *msg)  in scheduler_core_msg_dup()  argument
327 	qdf_mem_copy(dup, msg, sizeof(*dup));  in scheduler_core_msg_dup()
345 void scheduler_core_msg_free(struct scheduler_msg *msg)  in scheduler_core_msg_free()  argument
347 	qdf_flex_mem_free(&sched_pool, msg);  in scheduler_core_msg_free()
356 	struct scheduler_msg *msg;  in scheduler_thread_process_queues()  local
383 		msg = scheduler_mq_get(&sch_ctx->queue_ctx.sch_msg_q[i]);  in scheduler_thread_process_queues()
384 		if (!msg) {  in scheduler_thread_process_queues()
391 			sch_ctx->watchdog_msg_type = msg->type;  in scheduler_thread_process_queues()
392 			sch_ctx->watchdog_callback = msg->callback;  in scheduler_thread_process_queues()
394 			sched_history_start(msg);  in scheduler_thread_process_queues()
398 					scheduler_msg_process_fn[i](msg);  in scheduler_thread_process_queues()
406 			scheduler_core_msg_free(msg);  in scheduler_thread_process_queues()
473 	struct scheduler_msg *msg;  in scheduler_flush_single_queue()  local
476 	while ((msg = scheduler_mq_get(mq))) {  in scheduler_flush_single_queue()
477 		if (msg->flush_callback) {  in scheduler_flush_single_queue()
479 				    msg->type);  in scheduler_flush_single_queue()
480 			flush_cb = msg->flush_callback;  in scheduler_flush_single_queue()
481 			flush_cb(msg);  in scheduler_flush_single_queue()
482 		} else if (msg->bodyptr) {  in scheduler_flush_single_queue()
484 				    msg->type);  in scheduler_flush_single_queue()
485 			qdf_mem_free(msg->bodyptr);  in scheduler_flush_single_queue()
488 		scheduler_core_msg_free(msg);  in scheduler_flush_single_queue()