diff options
| author | zeripath <art27@cantab.net> | 2020-02-02 23:19:58 +0000 |
|---|---|---|
| committer | GitHub <noreply@github.com> | 2020-02-02 23:19:58 +0000 |
| commit | 2c903383b5154795b90e4b4ed8eaadc6fac17a13 (patch) | |
| tree | d5ca361d9597e027ad92f1e02a841be1d266b554 /routers | |
| parent | b4914249ee389a733e7dcfd2df20708ab3215827 (diff) | |
| download | gitea-2c903383b5154795b90e4b4ed8eaadc6fac17a13.tar.gz gitea-2c903383b5154795b90e4b4ed8eaadc6fac17a13.zip | |
Add Unique Queue infrastructure and move TestPullRequests to this (#9856)
* Upgrade levelqueue to version 0.2.0
This adds functionality for Unique Queues
* Add UniqueQueue interface and functions to create them
* Add UniqueQueue implementations
* Move TestPullRequests over to use UniqueQueue
* Reduce code duplication
* Add bytefifos
* Ensure invalid types are logged
* Fix close race in PersistableChannelQueue Shutdown
Diffstat (limited to 'routers')
| -rw-r--r-- | routers/init.go | 4 |
1 files changed, 3 insertions, 1 deletions
diff --git a/routers/init.go b/routers/init.go index 1d7cf78438..f86a7ad4b2 100644 --- a/routers/init.go +++ b/routers/init.go @@ -113,7 +113,9 @@ func GlobalInit(ctx context.Context) { code_indexer.Init() mirror_service.InitSyncMirrors() webhook.InitDeliverHooks() - pull_service.Init() + if err := pull_service.Init(); err != nil { + log.Fatal("Failed to initialize test pull requests queue: %v", err) + } if err := task.Init(); err != nil { log.Fatal("Failed to initialize task scheduler: %v", err) } |