@@ -143,25 +143,23 @@ func InitIssueIndexer(syncReindex bool) {
143143 var populate bool
144144 switch setting .Indexer .IssueType {
145145 case "bleve" :
146- graceful .GetManager ().RunWithShutdownFns (func (_ , atTerminate func (context.Context , func ())) {
147- issueIndexer := NewBleveIndexer (setting .Indexer .IssuePath )
148- exist , err := issueIndexer .Init ()
149- if err != nil {
150- holder .cancel ()
151- log .Fatal ("Unable to initialize Bleve Issue Indexer: %v" , err )
146+ issueIndexer := NewBleveIndexer (setting .Indexer .IssuePath )
147+ exist , err := issueIndexer .Init ()
148+ if err != nil {
149+ holder .cancel ()
150+ log .Fatal ("Unable to initialize Bleve Issue Indexer: %v" , err )
151+ }
152+ populate = ! exist
153+ holder .set (issueIndexer )
154+ graceful .GetManager ().RunAtTerminate (context .Background (), func () {
155+ log .Debug ("Closing issue indexer" )
156+ issueIndexer := holder .get ()
157+ if issueIndexer != nil {
158+ issueIndexer .Close ()
152159 }
153- populate = ! exist
154- holder .set (issueIndexer )
155- atTerminate (context .Background (), func () {
156- log .Debug ("Closing issue indexer" )
157- issueIndexer := holder .get ()
158- if issueIndexer != nil {
159- issueIndexer .Close ()
160- }
161- log .Info ("PID: %d Issue Indexer closed" , os .Getpid ())
162- })
163- log .Debug ("Created Bleve Indexer" )
160+ log .Info ("PID: %d Issue Indexer closed" , os .Getpid ())
164161 })
162+ log .Debug ("Created Bleve Indexer" )
165163 case "db" :
166164 issueIndexer := & DBIndexer {}
167165 holder .set (issueIndexer )
0 commit comments