starainrt
7e6cc73106
- 新增自启动幂等配置、统一错误语义、进程等待和进程树终止能力 - 增强服务生命周期管理，支持等待状态、重启、幂等创建和配置更新 - 新增 NTFS 卷索引、文件 ID 解析、文件遍历、USN 变更监听和 bookmark 持久化 - 修复 NTFS boot sector、fragment、MFT、USN 解析边界和路径重建问题 - 补充权限、进程、服务、NTFS 解析和工作流回归测试 - 增加 Windows 测试脚本和管理员 NTFS smoke 验证脚本 - 升级 Go 兼容版本到 1.18，并更新 stario、win32api 及相关间接依赖
48 lines
969 B
Go
48 lines
969 B
Go
package wincmd
|
|
|
|
import "time"
|
|
|
|
func waitUntil(timeout time.Duration, interval time.Duration, timeoutMsg string, check func() (bool, error)) error {
|
|
if timeout <= 0 {
|
|
timeout = time.Second
|
|
}
|
|
return waitUntilStrict(timeout, interval, timeoutMsg, check)
|
|
}
|
|
|
|
func waitUntilStrict(timeout time.Duration, interval time.Duration, timeoutMsg string, check func() (bool, error)) error {
|
|
if timeout <= 0 {
|
|
done, err := check()
|
|
if err != nil {
|
|
return err
|
|
}
|
|
if done {
|
|
return nil
|
|
}
|
|
if timeoutMsg == "" {
|
|
timeoutMsg = "wait condition timeout"
|
|
}
|
|
return wrapTimeoutError(timeoutMsg)
|
|
}
|
|
if interval <= 0 {
|
|
interval = 10 * time.Millisecond
|
|
}
|
|
|
|
deadline := time.Now().Add(timeout)
|
|
for {
|
|
done, err := check()
|
|
if err != nil {
|
|
return err
|
|
}
|
|
if done {
|
|
return nil
|
|
}
|
|
if time.Now().After(deadline) {
|
|
if timeoutMsg == "" {
|
|
timeoutMsg = "wait condition timeout"
|
|
}
|
|
return wrapTimeoutError(timeoutMsg)
|
|
}
|
|
time.Sleep(interval)
|
|
}
|
|
}
|