diff options
| author | 2022-11-22 19:38:10 +0100 | |
|---|---|---|
| committer | 2022-11-22 18:38:10 +0000 | |
| commit | 50dc179d332af4a3dc0e69e2c4e39bbbccd3fec5 (patch) | |
| tree | b48421907353aa6530a76f8c345e3bc11aeab4c9 /internal/timeline/itemindex.go | |
| parent | [docs] Document http/s/socks5 proxy use (#1118) (diff) | |
| download | gotosocial-50dc179d332af4a3dc0e69e2c4e39bbbccd3fec5.tar.xz | |
[feature] Prune timelines once per hour to plug memory leak (#1117)
* export highest/lowest ULIDs as proper const
* add stop + start to timeline manager, other small fixes
* unexport unused interface funcs + tidy up
* add LastGot func
* add timeline Prune function
* test prune
* update lastGot
Diffstat (limited to 'internal/timeline/itemindex.go')
| -rw-r--r-- | internal/timeline/itemindex.go | 86 |
1 files changed, 0 insertions, 86 deletions
diff --git a/internal/timeline/itemindex.go b/internal/timeline/itemindex.go deleted file mode 100644 index 968650e07..000000000 --- a/internal/timeline/itemindex.go +++ /dev/null @@ -1,86 +0,0 @@ -/* - GoToSocial - Copyright (C) 2021-2022 GoToSocial Authors admin@gotosocial.org - - This program is free software: you can redistribute it and/or modify - it under the terms of the GNU Affero General Public License as published by - the Free Software Foundation, either version 3 of the License, or - (at your option) any later version. - - This program is distributed in the hope that it will be useful, - but WITHOUT ANY WARRANTY; without even the implied warranty of - MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the - GNU Affero General Public License for more details. - - You should have received a copy of the GNU Affero General Public License - along with this program. If not, see <http://www.gnu.org/licenses/>. -*/ - -package timeline - -import ( - "container/list" - "context" - "errors" -) - -type itemIndex struct { - data *list.List - skipInsert SkipInsertFunction -} - -type itemIndexEntry struct { - itemID string - boostOfID string - accountID string - boostOfAccountID string -} - -func (p *itemIndex) insertIndexed(ctx context.Context, i *itemIndexEntry) (bool, error) { - if p.data == nil { - p.data = &list.List{} - } - - // if we have no entries yet, this is both the newest and oldest entry, so just put it in the front - if p.data.Len() == 0 { - p.data.PushFront(i) - return true, nil - } - - var insertMark *list.Element - var position int - // We need to iterate through the index to make sure we put this item in the appropriate place according to when it was created. - // We also need to make sure we're not inserting a duplicate item -- this can happen sometimes and it's not nice UX (*shudder*). - for e := p.data.Front(); e != nil; e = e.Next() { - position++ - - entry, ok := e.Value.(*itemIndexEntry) - if !ok { - return false, errors.New("index: could not parse e as an itemIndexEntry") - } - - skip, err := p.skipInsert(ctx, i.itemID, i.accountID, i.boostOfID, i.boostOfAccountID, entry.itemID, entry.accountID, entry.boostOfID, entry.boostOfAccountID, position) - if err != nil { - return false, err - } - if skip { - return false, nil - } - - // if the item to index is newer than e, insert it before e in the list - if insertMark == nil { - if i.itemID > entry.itemID { - insertMark = e - } - } - } - - if insertMark != nil { - p.data.InsertBefore(i, insertMark) - return true, nil - } - - // if we reach this point it's the oldest item we've seen so put it at the back - p.data.PushBack(i) - return true, nil -} |
