Changeset 667 in code for trunk/msgstore_fs.go

Timestamp:

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

Author:

contact

Message:

msgstore: add context to messageStore methods

This allows setting a hard timeout.

File:

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

trunk/msgstore_fs.go

@@ -3 +3 @@
 import (
         "bufio"
+        "context"
         "fmt"
         "io"
@@ -477 +478 @@
 }
 
-func (ms *fsMessageStore) LoadBeforeTime(network *Network, entity string, start time.Time, end time.Time, limit int, events bool) ([]*irc.Message, error) {
+func (ms *fsMessageStore) LoadBeforeTime(ctx context.Context, network *Network, entity string, start time.Time, end time.Time, limit int, events bool) ([]*irc.Message, error) {
         start = start.In(time.Local)
         end = end.In(time.Local)
@@ -502 +503 @@
 }
 
-func (ms *fsMessageStore) LoadAfterTime(network *Network, entity string, start time.Time, end time.Time, limit int, events bool) ([]*irc.Message, error) {
+func (ms *fsMessageStore) LoadAfterTime(ctx context.Context, network *Network, entity string, start time.Time, end time.Time, limit int, events bool) ([]*irc.Message, error) {
         start = start.In(time.Local)
         end = end.In(time.Local)
@@ -526 +527 @@
 }
 
-func (ms *fsMessageStore) LoadLatestID(network *Network, entity, id string, limit int) ([]*irc.Message, error) {
+func (ms *fsMessageStore) LoadLatestID(ctx context.Context, network *Network, entity, id string, limit int) ([]*irc.Message, error) {
         var afterTime time.Time
         var afterOffset int64
@@ -570 +571 @@
 }
 
-func (ms *fsMessageStore) ListTargets(network *Network, start, end time.Time, limit int, events bool) ([]chatHistoryTarget, error) {
+func (ms *fsMessageStore) ListTargets(ctx context.Context, network *Network, start, end time.Time, limit int, events bool) ([]chatHistoryTarget, error) {
         start = start.In(time.Local)
         end = end.In(time.Local)