Chromium Code Reviews
chromiumcodereview-hr@appspot.gserviceaccount.com (chromiumcodereview-hr) | Please choose your nickname with Settings | Help | Chromium Project | Gerrit Changes | Sign out
(878)

Side by Side Diff: appengine/cmd/dm/mutate/add_backdep.go

Issue 1537883002: Initial distributor implementation (Closed) Base URL: https://chromium.googlesource.com/external/github.com/luci/luci-go@master
Patch Set: self review Created 4 years, 6 months ago
Use n/p to move between diff chunks; N/P to move between comments. Draft comments are only viewable by you.
Jump to:
View unified diff | Download patch
OLDNEW
1 // Copyright 2015 The LUCI Authors. All rights reserved. 1 // Copyright 2015 The LUCI Authors. All rights reserved.
2 // Use of this source code is governed under the Apache License, Version 2.0 2 // Use of this source code is governed under the Apache License, Version 2.0
3 // that can be found in the LICENSE file. 3 // that can be found in the LICENSE file.
4 4
5 package mutate 5 package mutate
6 6
7 import ( 7 import (
8 "github.com/luci/gae/service/datastore" 8 "github.com/luci/gae/service/datastore"
9 "github.com/luci/luci-go/appengine/cmd/dm/model" 9 "github.com/luci/luci-go/appengine/cmd/dm/model"
10 "github.com/luci/luci-go/appengine/tumble" 10 "github.com/luci/luci-go/appengine/tumble"
(...skipping 25 matching lines...) Expand all
36 err = ds.Put(bdg) 36 err = ds.Put(bdg)
37 } 37 }
38 if err != nil { 38 if err != nil {
39 return 39 return
40 } 40 }
41 41
42 bd.Propagated = bdg.AttemptFinished 42 bd.Propagated = bdg.AttemptFinished
43 43
44 err = ds.Put(bd) 44 err = ds.Put(bd)
45 45
46 » if a.NeedsAck { 46 » if a.NeedsAck && bdg.AttemptFinished {
47 » » muts = append(muts, &AckFwdDep{ 47 » » muts = append(muts, &AckFwdDep{a.Dep})
48 » » » Dep: a.Dep,
49 » » » DepIsFinished: bdg.AttemptFinished,
50 » » })
51 } 48 }
52 return 49 return
53 } 50 }
54 51
55 func init() { 52 func init() {
56 tumble.Register((*AddBackDep)(nil)) 53 tumble.Register((*AddBackDep)(nil))
57 } 54 }
OLDNEW

Powered by Google App Engine
This is Rietveld 408576698