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

Unified Diff: service/taskqueue/taskqueue.go

Issue 1291813003: Make LazyMultiError constructed via function (Closed) Base URL: https://github.com/luci/gae.git@master
Patch Set: interface not pointer Created 5 years, 4 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 side-by-side diff with in-line comments
Download patch
« no previous file with comments | « service/memcache/memcache.go ('k') | no next file » | no next file with comments »
Expand Comments ('e') | Collapse Comments ('c') | Show Comments Hide Comments ('s')
Index: service/taskqueue/taskqueue.go
diff --git a/service/taskqueue/taskqueue.go b/service/taskqueue/taskqueue.go
index 5735ffb35d847f88ba5cf3b92b61865ff84e084f..7a1f9a6bbc320a0902ab026ccb9fd6a6cd2bb7f8 100644
--- a/service/taskqueue/taskqueue.go
+++ b/service/taskqueue/taskqueue.go
@@ -24,7 +24,7 @@ func (t *taskqueueImpl) Delete(task *Task, queueName string) error {
}
func (t *taskqueueImpl) AddMulti(tasks []*Task, queueName string) error {
- lme := errors.LazyMultiError{Size: len(tasks)}
+ lme := errors.NewLazyMultiError(len(tasks))
i := 0
err := t.RawInterface.AddMulti(tasks, queueName, func(t *Task, err error) {
if !lme.Assign(i, err) {
@@ -39,7 +39,7 @@ func (t *taskqueueImpl) AddMulti(tasks []*Task, queueName string) error {
}
func (t *taskqueueImpl) DeleteMulti(tasks []*Task, queueName string) error {
- lme := errors.LazyMultiError{Size: len(tasks)}
+ lme := errors.NewLazyMultiError(len(tasks))
i := 0
err := t.RawInterface.DeleteMulti(tasks, queueName, func(err error) {
lme.Assign(i, err)
@@ -57,7 +57,7 @@ func (t *taskqueueImpl) Purge(queueName string) error {
func (t *taskqueueImpl) Stats(queueNames ...string) ([]Statistics, error) {
ret := make([]Statistics, len(queueNames))
- lme := errors.LazyMultiError{Size: len(queueNames)}
+ lme := errors.NewLazyMultiError(len(queueNames))
i := 0
err := t.RawInterface.Stats(queueNames, func(s *Statistics, err error) {
if !lme.Assign(i, err) {
« no previous file with comments | « service/memcache/memcache.go ('k') | no next file » | no next file with comments »

Powered by Google App Engine
This is Rietveld 408576698