TRKJ/EdgeAPI
2
0
Fork 0
mirror of https://github.com/TeaOSLab/EdgeAPI.git synced 2025-11-07 18:50:26 +08:00
Code Issues Packages Projects Releases Wiki Activity

修改OCSP自动更新的间隔时间和条数

Browse Source
This commit is contained in:
刘祥超
2022-03-11 10:00:53 +08:00
parent bf0db231fc
commit 473d0d9439
1 changed files with 8 additions and 3 deletions
Download Patch File Download Diff File Expand all files Collapse all files

11
internal/tasks/ssl_cert_update_ocsp_task.go
View File

@@ -34,7 +34,7 @@ type SSLCertUpdateOCSPTask struct {
func NewSSLCertUpdateOCSPTask() *SSLCertUpdateOCSPTask { func NewSSLCertUpdateOCSPTask() *SSLCertUpdateOCSPTask {
return &SSLCertUpdateOCSPTask{ return &SSLCertUpdateOCSPTask{
ticker: time.NewTicker(5 * time.Minute), ticker: time.NewTicker(1 * time.Minute),
} }
} }
@@ -48,7 +48,7 @@ func (this *SSLCertUpdateOCSPTask) Start() {
} }
func (this *SSLCertUpdateOCSPTask) Loop() error { func (this *SSLCertUpdateOCSPTask) Loop() error {
ok, err := models.SharedSysLockerDAO.Lock(nil, "ssl_cert_update_ocsp_task", 300-1) // 假设执行时间为1秒 ok, err := models.SharedSysLockerDAO.Lock(nil, "ssl_cert_update_ocsp_task", 60-1) // 假设执行时间为1秒
if err != nil { if err != nil {
return err return err
} }
@@ -57,10 +57,15 @@ func (this *SSLCertUpdateOCSPTask) Loop() error {
} }
var tx *dbs.Tx var tx *dbs.Tx
certs, err := models.SharedSSLCertDAO.ListCertsToUpdateOCSP(tx, 10) // TODO 将来可以设置单次任务条数
var size int64 = 20
certs, err := models.SharedSSLCertDAO.ListCertsToUpdateOCSP(tx, size)
if err != nil { if err != nil {
return errors.New("list certs failed: " + err.Error()) return errors.New("list certs failed: " + err.Error())
} }
if len(certs) == 0 {
return nil
}
for _, cert := range certs { for _, cert := range certs {
ocspData, err := this.UpdateCertOCSP(cert) ocspData, err := this.UpdateCertOCSP(cert)