aboutsummaryrefslogtreecommitdiff
path: root/models/webhook.go
diff options
context:
space:
mode:
authorevolvedlight <steve@evolvedlight.co.uk>2014-10-13 20:30:31 +0100
committerevolvedlight <steve@evolvedlight.co.uk>2014-10-13 20:30:31 +0100
commit8d2a6fc484b540819e211d52b8d54e97269f0918 (patch)
treee5bfe7d3937bb2d18ba2fb50ea72514bd5bb4e13 /models/webhook.go
parent29ac3980ffdb5faa525d77fddc109c9023ebe257 (diff)
parent89bd994c836ecc9b6ceb80849f470521e1b15917 (diff)
Merge remote-tracking branch 'upstream/dev'
Conflicts: models/repo.go
Diffstat (limited to 'models/webhook.go')
-rw-r--r--models/webhook.go16
1 files changed, 15 insertions, 1 deletions
diff --git a/models/webhook.go b/models/webhook.go
index 9508c98a..ac0c2409 100644
--- a/models/webhook.go
+++ b/models/webhook.go
@@ -235,8 +235,22 @@ func UpdateHookTask(t *HookTask) error {
return err
}
+var (
+ // Prevent duplicate deliveries.
+ // This happens with massive hook tasks cannot finish delivering
+ // before next shooting starts.
+ isShooting = false
+)
+
// DeliverHooks checks and delivers undelivered hooks.
+// FIXME: maybe can use goroutine to shoot a number of them at same time?
func DeliverHooks() {
+ if isShooting {
+ return
+ }
+ isShooting = true
+ defer func() { isShooting = false }()
+
tasks := make([]*HookTask, 0, 10)
timeout := time.Duration(setting.WebhookDeliverTimeout) * time.Second
x.Where("is_delivered=?", false).Iterate(new(HookTask),
@@ -255,7 +269,7 @@ func DeliverHooks() {
t.IsDelivered = true
- // TODO: record response.
+ // FIXME: record response.
switch t.Type {
case GOGS:
{