Skip to content

Commit 9ab1c76

Browse files
committed
TODO: These are the places with remaining graceful queries
1 parent f751693 commit 9ab1c76

File tree

4 files changed

+5
-0
lines changed

4 files changed

+5
-0
lines changed

modules/migrations/migrate.go

Lines changed: 1 addition & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -29,6 +29,7 @@ func RegisterDownloaderFactory(factory base.DownloaderFactory) {
2929
}
3030

3131
// MigrateRepository migrate repository according MigrateOptions
32+
// FIXME: graceful: ctx may need to be checked more often
3233
func MigrateRepository(ctx context.Context, doer *models.User, ownerName string, opts base.MigrateOptions) (*models.Repository, error) {
3334
var (
3435
downloader base.Downloader

modules/notification/notification.go

Lines changed: 1 addition & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -21,6 +21,7 @@ var (
2121
)
2222

2323
// RegisterNotifier providers method to receive notify messages
24+
// FIXME: graceful: This may need to become a queue
2425
func RegisterNotifier(notifier base.Notifier) {
2526
go notifier.Run()
2627
notifiers = append(notifiers, notifier)

services/mailer/mailer.go

Lines changed: 2 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -292,6 +292,8 @@ func NewContext() {
292292
}
293293

294294
mailQueue = make(chan *Message, setting.MailService.QueueLength)
295+
296+
// FIXME: graceful: Needs to become a queue and graceful
295297
go processMailQueue()
296298
}
297299

services/mirror/mirror.go

Lines changed: 1 addition & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -427,6 +427,7 @@ func syncMirror(repoID string) {
427427
}
428428

429429
// InitSyncMirrors initializes a go routine to sync the mirrors
430+
// FIXME: graceful: Needs to be a proper queue and graceful
430431
func InitSyncMirrors() {
431432
go graceful.GetManager().RunWithShutdownContext(SyncMirrors)
432433
}

0 commit comments

Comments
 (0)