aboutsummaryrefslogtreecommitdiff
path: root/syncapi
diff options
context:
space:
mode:
authorNeil Alexander <neilalexander@users.noreply.github.com>2022-03-24 10:03:22 +0000
committerNeil Alexander <neilalexander@users.noreply.github.com>2022-03-24 10:03:22 +0000
commitd983d17355584b7de086389e069a935f1a5510a1 (patch)
tree0920bd8f9a5f64ac749397cf012904b8275a6d52 /syncapi
parent6c95f9b535191bc28cb983a6fa0eab036dc40916 (diff)
Fix lint errors
Diffstat (limited to 'syncapi')
-rw-r--r--syncapi/storage/postgres/output_room_events_table.go4
-rw-r--r--syncapi/storage/sqlite3/output_room_events_table.go4
2 files changed, 4 insertions, 4 deletions
diff --git a/syncapi/storage/postgres/output_room_events_table.go b/syncapi/storage/postgres/output_room_events_table.go
index 26689f44..14af6a94 100644
--- a/syncapi/storage/postgres/output_room_events_table.go
+++ b/syncapi/storage/postgres/output_room_events_table.go
@@ -472,7 +472,7 @@ func (s *outputRoomEventsStatements) SelectContextBeforeEvent(
if err != nil {
return
}
- defer rows.Close()
+ defer internal.CloseAndLogIfError(ctx, rows, "rows.close() failed")
for rows.Next() {
var (
@@ -504,7 +504,7 @@ func (s *outputRoomEventsStatements) SelectContextAfterEvent(
if err != nil {
return
}
- defer rows.Close()
+ defer internal.CloseAndLogIfError(ctx, rows, "rows.close() failed")
for rows.Next() {
var (
diff --git a/syncapi/storage/sqlite3/output_room_events_table.go b/syncapi/storage/sqlite3/output_room_events_table.go
index b9115262..acd95969 100644
--- a/syncapi/storage/sqlite3/output_room_events_table.go
+++ b/syncapi/storage/sqlite3/output_room_events_table.go
@@ -514,7 +514,7 @@ func (s *outputRoomEventsStatements) SelectContextBeforeEvent(
if err != nil {
return
}
- defer rows.Close()
+ defer internal.CloseAndLogIfError(ctx, rows, "rows.close() failed")
for rows.Next() {
var (
@@ -550,7 +550,7 @@ func (s *outputRoomEventsStatements) SelectContextAfterEvent(
if err != nil {
return
}
- defer rows.Close()
+ defer internal.CloseAndLogIfError(ctx, rows, "rows.close() failed")
for rows.Next() {
var (