diff options
| author | 2022-11-22 19:38:10 +0100 | |
|---|---|---|
| committer | 2022-11-22 18:38:10 +0000 | |
| commit | 50dc179d332af4a3dc0e69e2c4e39bbbccd3fec5 (patch) | |
| tree | b48421907353aa6530a76f8c345e3bc11aeab4c9 /internal/processing | |
| 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/processing')
| -rw-r--r-- | internal/processing/processor.go | 11 | 
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  }  | 
