windy/tele-recv
1
0
Fork 0
Code Issues Pull Requests Packages Projects Releases Wiki Activity

update process

Browse Source
This commit is contained in:
fengzhiqiang
2020-12-23 14:02:16 +08:00
parent 216e92f983
commit bc3f765baf
1 changed files with 3 additions and 4 deletions
Download Patch File Download Diff File Expand all files Collapse all files
utils/sqlite.go
+3 -4
View File
@@ -108,15 +108,13 @@ func LoadUnprocessed() {
err := rows.Scan(&t.id, &t.text) err := rows.Scan(&t.id, &t.text)
checkDbErr(err, "error in scan telegram") checkDbErr(err, "error in scan telegram")
if WriteToClient(t.text) == nil { if WriteToClient(t.text) == nil {
processed(t) processed(db, t)
} }
} }
} }
} }
func processed(t telegram) { func processed(db *sql.DB, t telegram) {
db := getDb()
log.Println("get lock")
getWriteLock() getWriteLock()
stmt, _ := db.Prepare(update) stmt, _ := db.Prepare(update)
result, err := stmt.Exec(t.id) result, err := stmt.Exec(t.id)
@@ -140,6 +138,7 @@ func countTelegram() int64 {
func getWriteLock() { func getWriteLock() {
count := 0 count := 0
log.Println("write lock :", isWriting)
for isWriting && count < 10 { for isWriting && count < 10 {
log.Println("waiting for write ") log.Println("waiting for write ")
time.Sleep(5 * time.Second) time.Sleep(5 * time.Second)