37 	u64 ts;  member
195 		if (p->ts >= min_valid_ts)  in pulse_queue_check_window()
201 static bool pulse_queue_enqueue(struct pri_detector *pde, u64 ts)  in pulse_queue_enqueue()  argument
214 	p->ts = ts;  in pulse_queue_enqueue()
217 	pde->last_ts = ts;  in pulse_queue_enqueue()
225 					  u64 ts, u32 min_count)  in pseq_handler_create_sequences()  argument
233 		u32 delta_ts = ts - p->ts;  in pseq_handler_create_sequences()
246 		ps.first_ts = p->ts;  in pseq_handler_create_sequences()
247 		ps.last_ts = ts;  in pseq_handler_create_sequences()
249 			pde->rs->pri_max, ts - p->ts);  in pseq_handler_create_sequences()
255 		min_valid_ts = ts - ps.dur;  in pseq_handler_create_sequences()
259 			if (p2->ts < min_valid_ts)  in pseq_handler_create_sequences()
263 			factor = pde_get_multiple(ps.last_ts - p2->ts, ps.pri,  in pseq_handler_create_sequences()
267 				ps.first_ts = p2->ts;  in pseq_handler_create_sequences()
304 pseq_handler_add_to_existing_seqs(struct pri_detector *pde, u64 ts)  in pseq_handler_add_to_existing_seqs()  argument
313 		if (ts > ps->deadline_ts) {  in pseq_handler_add_to_existing_seqs()
319 		delta_ts = ts - ps->last_ts;  in pseq_handler_add_to_existing_seqs()
323 			ps->last_ts = ts;  in pseq_handler_add_to_existing_seqs()
358 static void pri_detector_reset(struct pri_detector *pde, u64 ts)  in pri_detector_reset()  argument
371 	pde->last_ts = ts;  in pri_detector_reset()
386 	u64 ts = event->ts;  in pri_detector_add_pulse()  local
393 	if ((ts - de->last_ts) < rs->max_pri_tolerance)  in pri_detector_add_pulse()
400 	de->last_ts = ts;  in pri_detector_add_pulse()
402 	max_updated_seq = pseq_handler_add_to_existing_seqs(de, ts);  in pri_detector_add_pulse()
404 	if (!pseq_handler_create_sequences(de, ts, max_updated_seq)) {  in pri_detector_add_pulse()
405 		pri_detector_reset(de, ts);  in pri_detector_add_pulse()
412 		pulse_queue_enqueue(de, ts);  in pri_detector_add_pulse()