| OLD | NEW |
| 1 // Copyright 2015 The Chromium Authors. All rights reserved. | 1 // Copyright 2015 The Chromium Authors. All rights reserved. |
| 2 // Use of this source code is governed by a BSD-style license that can be | 2 // Use of this source code is governed by a BSD-style license that can be |
| 3 // found in the LICENSE file. | 3 // found in the LICENSE file. |
| 4 | 4 |
| 5 package rawdatastore | 5 package rawdatastore |
| 6 | 6 |
| 7 import ( | 7 import ( |
| 8 "fmt" | 8 "fmt" |
| 9 | 9 |
| 10 "github.com/luci/gae/service/info" | 10 "github.com/luci/gae/service/info" |
| (...skipping 52 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
| 63 for i, k := range keys { | 63 for i, k := range keys { |
| 64 if KeyIncomplete(k) { | 64 if KeyIncomplete(k) { |
| 65 k = NewKey(k.AppID(), k.Namespace(), k.Kind(), "", 1, k.
Parent()) | 65 k = NewKey(k.AppID(), k.Namespace(), k.Kind(), "", 1, k.
Parent()) |
| 66 } | 66 } |
| 67 if !KeyValid(k, false, tcf.aid, tcf.ns) { | 67 if !KeyValid(k, false, tcf.aid, tcf.ns) { |
| 68 lme.Assign(i, ErrInvalidKey) | 68 lme.Assign(i, ErrInvalidKey) |
| 69 continue | 69 continue |
| 70 } | 70 } |
| 71 v := vals[i] | 71 v := vals[i] |
| 72 if v == nil { | 72 if v == nil { |
| 73 » » » if !lme.Assign(i, errors.New("rawdatastore: PutMulti got
nil vals entry")) { | 73 » » » lme.Assign(i, errors.New("rawdatastore: PutMulti got nil
vals entry")) |
| 74 » » » » lme.Assign(i, v.Problem()) | 74 » » } else { |
| 75 » » » } | 75 » » » lme.Assign(i, v.Problem()) |
| 76 } | 76 } |
| 77 } | 77 } |
| 78 if me := lme.Get(); me != nil { | 78 if me := lme.Get(); me != nil { |
| 79 for _, err := range me.(errors.MultiError) { | 79 for _, err := range me.(errors.MultiError) { |
| 80 cb(nil, err) | 80 cb(nil, err) |
| 81 } | 81 } |
| 82 return nil | 82 return nil |
| 83 } | 83 } |
| 84 | 84 |
| 85 err := error(nil) | 85 err := error(nil) |
| (...skipping 28 matching lines...) Expand all Loading... |
| 114 } | 114 } |
| 115 return nil | 115 return nil |
| 116 } | 116 } |
| 117 return tcf.Interface.DeleteMulti(keys, cb) | 117 return tcf.Interface.DeleteMulti(keys, cb) |
| 118 } | 118 } |
| 119 | 119 |
| 120 func applyCheckFilter(c context.Context, i Interface) Interface { | 120 func applyCheckFilter(c context.Context, i Interface) Interface { |
| 121 inf := info.Get(c) | 121 inf := info.Get(c) |
| 122 return &checkFilter{i, inf.AppID(), inf.GetNamespace()} | 122 return &checkFilter{i, inf.AppID(), inf.GetNamespace()} |
| 123 } | 123 } |
| OLD | NEW |