13 commits

Author	SHA1	Message	Date
Dmitrii Stepanov	57d895c321	[#13] mclock: Schedule requests as soon as possible ... Let's assume that for some tag `limit = 1000 RPS` defined and each request takes 10 ms to complete. At some point in time 1000 requests were accepted. Then first request will be scheduled at `now()`, second - at `now() + 1 ms`, third - at `now() + 2 ms` etc. Total processing duration of 1000 requests will be 1 second + 10 ms. After this fix scheduler looks forward to schedule requests within limit. So for situation above total processing duration of 1000 requests will be 10 ms in ideal world. The same for reservation scheduling. Signed-off-by: Dmitrii Stepanov <d.stepanov@yadro.com>	2025-03-24 16:36:47 +03:00
Dmitrii Stepanov	1ca213ee7c	[#12] mclock: Fix deadlock caused by mclock.Close ... Deadlock scenario: - mclock closed by `Close` method, it locks mutex and calls `clock.close` - clock starts `scheduleRequest` goroutine, it tries to lock mutex - `clock.Close` waits for all goroutines Signed-off-by: Dmitrii Stepanov <d.stepanov@yadro.com>	2025-03-20 10:31:15 +03:00
Dmitrii Stepanov	346752477b	[#12] mclock: Fix timer-based scheduling ... Let's assume that there are two requests in the queue with execution time t1 and t2. The timer is set to t1. The timer is triggered, schedules the t1 request, calculates the time for the next timer t2 to be triggered. But it doesn't schedules timer to this time because of the `q.timeBasedScheduleTs > nextTs` check. Signed-off-by: Dmitrii Stepanov <d.stepanov@yadro.com>	2025-03-19 17:12:00 +03:00
Dmitrii Stepanov	3e7ca94035	Revert "[#7] mclock: Add tag stat" ... This reverts commit 25102d1e1a. Signed-off-by: Dmitrii Stepanov <d.stepanov@yadro.com>	2025-03-10 16:58:38 +03:00
Dmitrii Stepanov	25102d1e1a	[#7] mclock: Add tag stat ... Signed-off-by: Dmitrii Stepanov <d.stepanov@yadro.com>	2025-02-27 07:29:15 +00:00
Dmitrii Stepanov	f4d8ebf13d	[#1] mclock: Add assert package ... Signed-off-by: Dmitrii Stepanov <d.stepanov@yadro.com>	2025-01-28 11:35:54 +03:00
Dmitrii Stepanov	9a48a50220	[#1] mclock: Refactor scheduleRequest ... Split to `scheduleRequest` and `scheduleRequestUnsafe`. Signed-off-by: Dmitrii Stepanov <d.stepanov@yadro.com>	2025-01-28 11:23:07 +03:00
Dmitrii Stepanov	d8663f1a74	[#1] mclock: Fix possible deadlock ... There is a possible call-chain `scheduleRequest()` -> `runAt()` -> `scheduleRequest()`, so second `scheduleRequest()` may be locked on mutext held by first `scheduleRequest()`. Signed-off-by: Dmitrii Stepanov <d.stepanov@yadro.com>	2025-01-28 11:20:54 +03:00
Dmitrii Stepanov	f1cb5b40d5	[#1] mclock: Use time.Duration for idle timeout ... Signed-off-by: Dmitrii Stepanov <d.stepanov@yadro.com>	2025-01-28 11:20:54 +03:00
Dmitrii Stepanov	47559a8d16	[#1] mclock: Refactor: split code between files ... Signed-off-by: Dmitrii Stepanov <d.stepanov@yadro.com>	2025-01-28 11:20:53 +03:00
Dmitrii Stepanov	54b4bf7cc1	[#1] mclock: Fix time based scheduling ... Signed-off-by: Dmitrii Stepanov <d.stepanov@yadro.com>	2025-01-28 11:20:53 +03:00
Dmitrii Stepanov	e18d1a7c45	[#1] mclock: Fix bench format ... Signed-off-by: Dmitrii Stepanov <d.stepanov@yadro.com>	2025-01-28 11:20:52 +03:00
Dmitrii Stepanov	0dccab22c2	[#1] mclock: Initial implementation ... Signed-off-by: Dmitrii Stepanov <d.stepanov@yadro.com>	2025-01-28 11:20:51 +03:00