This commit is contained in:
shoopea 2020-01-12 17:37:46 +08:00
parent f94e710911
commit 44762e03ea
3 changed files with 3 additions and 3 deletions

2
job.go
View File

@ -222,7 +222,7 @@ func loadCurrentJobs() ([]Job, error) {
zb := bytes.NewReader(zpayload) zb := bytes.NewReader(zpayload)
zr, err := zlib.NewReader(zb) zr, err := zlib.NewReader(zb)
if err != nil { if err != nil {
logOnError(err, "loadCurrentJobs : zlib.NewReader.") logOnError(err, "loadCurrentJobs : zlib.NewReader")
continue continue
} }
b := new(bytes.Buffer) b := new(bytes.Buffer)

2
obj.go
View File

@ -1049,7 +1049,7 @@ func loadObjJob() error {
zb := bytes.NewReader(zpayload) zb := bytes.NewReader(zpayload)
zr, err := zlib.NewReader(zb) zr, err := zlib.NewReader(zb)
if err != nil { if err != nil {
logOnError(err, "loadObjJob : zlib.NewReader.") logOnError(err, "loadObjJob : zlib.NewReader")
continue continue
} }
b := new(bytes.Buffer) b := new(bytes.Buffer)

2
sql.go
View File

@ -385,7 +385,7 @@ func initDB() {
,started TIMESTAMP ,started TIMESTAMP
,ended TIMESTAMP ,ended TIMESTAMP
,timeout TIMESTAMP ,timeout TIMESTAMP
,payload VARCHAR(65532) ,payload VARBINARY(20000)
,FOREIGN KEY (obj_id) REFERENCES obj(id) ON DELETE CASCADE ,FOREIGN KEY (obj_id) REFERENCES obj(id) ON DELETE CASCADE
,KEY (is_done) ,KEY (is_done)
,KEY (in_work) ,KEY (in_work)