mirror of
https://gitee.com/ulthon/ulthon_admin.git
synced 2026-08-30 20:55:32 +08:00
feat(timer): syncConfig concurrency 不变量与控制器 cap 防御
TimerServiceBase syncConfig 不覆盖 DB concurrency(NULL=继承代码默认)。TimerControllerBase cap 改 >= 语义,放行 concurrency_id < cap 的 0-indexed 分片。 Ultraworked with [Sisyphus](https://github.com/code-yeongyu/oh-my-openagent) Co-authored-by: Sisyphus <clio-agent@sisyphuslabs.ai>
This commit is contained in:
@@ -10,6 +10,14 @@ class TimerControllerBase extends ToolsController
|
||||
{
|
||||
protected $frequency = null;
|
||||
|
||||
/**
|
||||
* 最大并发上限 cap.
|
||||
* 放行 concurrency_id < $concurrency 的请求(0-indexed 分片,合法 id ∈ [0, cap-1]);
|
||||
* 放行 concurrency_count <= $concurrency 的请求(并发总数声明,合法 ∈ [1, cap])。
|
||||
* DB 实际并发通过 T6 有效域钳制 = min(DB concurrency, 控制器 cap, max_handles 预算),
|
||||
* 动态扩容时高 concurrency_id 只要 < cap 就不会被误杀。
|
||||
* 子类按任务实际承载力自行设置(默认 1 = 单分片,只允许 id=0)。
|
||||
*/
|
||||
protected $concurrency = 1;
|
||||
|
||||
protected $concurrencyId = 0;
|
||||
@@ -21,12 +29,14 @@ class TimerControllerBase extends ToolsController
|
||||
parent::initialize();
|
||||
|
||||
$concurrency_id = $this->request->param('concurrency_id', 0);
|
||||
if ($concurrency_id > $this->concurrency) {
|
||||
// cap 防御:0-indexed 分片号,合法 id ∈ [0, cap-1];id >= cap 视为越界(超 cap 的分片不被本控制器承载)
|
||||
if ($concurrency_id >= $this->concurrency) {
|
||||
$this->error('concurrency id error');
|
||||
}
|
||||
$this->concurrencyId = $concurrency_id;
|
||||
|
||||
$concurrency_count = $this->request->param('concurrency_count', 1);
|
||||
// cap 防御:并发总数声明,合法 ∈ [1, cap];count > cap 视为超限(DB concurrency 经 T6 钳制后不会超过 cap)
|
||||
if ($concurrency_count > $this->concurrency) {
|
||||
$this->error('concurrency count error');
|
||||
}
|
||||
|
||||
Reference in New Issue
Block a user