summaryrefslogtreecommitdiff
path: root/internal/processing
diff options
context:
space:
mode:
authorLibravatar tobi <31960611+tsmethurst@users.noreply.github.com>2022-11-22 19:38:10 +0100
committerLibravatar GitHub <noreply@github.com>2022-11-22 18:38:10 +0000
commit50dc179d332af4a3dc0e69e2c4e39bbbccd3fec5 (patch)
treeb48421907353aa6530a76f8c345e3bc11aeab4c9 /internal/processing
parent[docs] Document http/s/socks5 proxy use (#1118) (diff)
downloadgotosocial-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/processing')
-rw-r--r--internal/processing/processor.go11
1 files changed, 11 insertions, 0 deletions
diff --git a/internal/processing/processor.go b/internal/processing/processor.go
index b7d42ffeb..f464a08b4 100644
--- a/internal/processing/processor.go
+++ b/internal/processing/processor.go
@@ -351,6 +351,11 @@ func (p *processor) Start() error {
return err
}
+ // Start status timelines
+ if err := p.statusTimelines.Start(); err != nil {
+ return err
+ }
+
return nil
}
@@ -359,8 +364,14 @@ func (p *processor) Stop() error {
if err := p.clientWorker.Stop(); err != nil {
return err
}
+
if err := p.fedWorker.Stop(); err != nil {
return err
}
+
+ if err := p.statusTimelines.Stop(); err != nil {
+ return err
+ }
+
return nil
}