Changeset 668 in code for trunk/msgstore_fs.go

Timestamp:

Nov 3, 2021, 5:21:12 PM (4 years ago)

Author:

contact

Message:

msgstore_fs: abort on timeout

File:

• trunk/msgstore_fs.go (modified) (4 diffs)

trunk/msgstore_fs.go

@@ -498 +498 @@
                 year, month, day := start.Date()
                 start = time.Date(year, month, day, 0, 0, 0, 0, start.Location()).Add(-1)
+
+                if err := ctx.Err(); err != nil {
+                        return nil, err
+                }
         }
 
@@ -523 +527 @@
                 year, month, day := start.Date()
                 start = time.Date(year, month, day+1, 0, 0, 0, 0, start.Location())
+
+                if err := ctx.Err(); err != nil {
+                        return nil, err
+                }
         }
         return history, nil
@@ -566 +574 @@
                 year, month, day := t.Date()
                 t = time.Date(year, month, day, 0, 0, 0, 0, t.Location()).Add(-1)
+
+                if err := ctx.Err(); err != nil {
+                        return nil, err
+                }
         }
 
@@ -625 +637 @@
                         LatestMessage: t,
                 })
+
+                if err := ctx.Err(); err != nil {
+                        return nil, err
+                }
         }