From 9cd6b1a9f1af73847f7d0c4e68232147b9448c68 Mon Sep 17 00:00:00 2001 From: Neil Alexander Date: Tue, 15 Dec 2020 16:40:50 +0000 Subject: [PATCH] Close the rows --- roomserver/storage/postgres/events_table.go | 1 + roomserver/storage/sqlite3/events_table.go | 1 + 2 files changed, 2 insertions(+) diff --git a/roomserver/storage/postgres/events_table.go b/roomserver/storage/postgres/events_table.go index 25c5be62c..0cf0bd22f 100644 --- a/roomserver/storage/postgres/events_table.go +++ b/roomserver/storage/postgres/events_table.go @@ -439,6 +439,7 @@ func (s *eventStatements) SelectRoomNIDsForEventNIDs( if err != nil { return nil, err } + defer internal.CloseAndLogIfError(ctx, rows, "selectRoomNIDsForEventNIDsStmt: rows.close() failed") result := make(map[types.EventNID]types.RoomNID) for rows.Next() { var eventNID types.EventNID diff --git a/roomserver/storage/sqlite3/events_table.go b/roomserver/storage/sqlite3/events_table.go index 3c82c094e..841ab029c 100644 --- a/roomserver/storage/sqlite3/events_table.go +++ b/roomserver/storage/sqlite3/events_table.go @@ -496,6 +496,7 @@ func (s *eventStatements) SelectRoomNIDsForEventNIDs( if err != nil { return nil, err } + defer internal.CloseAndLogIfError(ctx, rows, "selectRoomNIDsForEventNIDsStmt: rows.close() failed") result := make(map[types.EventNID]types.RoomNID) for rows.Next() { var eventNID types.EventNID