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

Unified Diff: tokenserver/appengine/impl/utils/policy/policy.go

Issue 2963503003: [errors] Greatly simplify common/errors package. (Closed)
Patch Set: fix nits Created 3 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 side-by-side diff with in-line comments
Download patch
« no previous file with comments | « tokenserver/appengine/impl/certconfig/rpc_fetch_crl.go ('k') | tools/cmd/gorun/main.go » ('j') | no next file with comments »
Expand Comments ('e') | Collapse Comments ('c') | Show Comments Hide Comments ('s')
Index: tokenserver/appengine/impl/utils/policy/policy.go
diff --git a/tokenserver/appengine/impl/utils/policy/policy.go b/tokenserver/appengine/impl/utils/policy/policy.go
index 3f936b928270ccfad61daf98809c6da97c75bba2..e8b7d217ae518d710e6081d00f4f2db973331fc6 100644
--- a/tokenserver/appengine/impl/utils/policy/policy.go
+++ b/tokenserver/appengine/impl/utils/policy/policy.go
@@ -123,7 +123,7 @@ func (p *Policy) ImportConfigs(c context.Context) (rev string, err error) {
err = errors.New("no configs fetched by the callback")
}
if err != nil {
- return "", errors.Annotate(err).Reason("failed to fetch policy configs").Err()
+ return "", errors.Annotate(err, "failed to fetch policy configs").Err()
}
rev = fetcher.Revision()
@@ -132,7 +132,7 @@ func (p *Policy) ImportConfigs(c context.Context) (rev string, err error) {
// SHA256 digest).
cfgBlob, err := serializeBundle(bundle)
if err != nil {
- return "", errors.Annotate(err).Reason("failed to serialize the configs").Err()
+ return "", errors.Annotate(err, "failed to serialize the configs").Err()
}
digest := sha256.Sum256(cfgBlob)
digestHex := hex.EncodeToString(digest[:])
@@ -141,7 +141,7 @@ func (p *Policy) ImportConfigs(c context.Context) (rev string, err error) {
// Do we have it already?
existingHdr, err := getImportedPolicyHeader(c, p.Name)
if err != nil {
- return "", errors.Annotate(err).Reason("failed to grab ImportedPolicyHeader").Err()
+ return "", errors.Annotate(err, "failed to grab ImportedPolicyHeader").Err()
}
if existingHdr != nil && digestHex == existingHdr.SHA256 {
logging.Infof(
@@ -160,9 +160,7 @@ func (p *Policy) ImportConfigs(c context.Context) (rev string, err error) {
v := validation.Context{Logger: logging.Get(c)}
p.Validate(bundle, &v)
if err := v.Finalize(); err != nil {
- return "", errors.Annotate(err).
- Reason("configs at rev %(rev)s are invalid").
- D("rev", rev).Err()
+ return "", errors.Annotate(err, "configs at rev %s are invalid", rev).Err()
}
}
@@ -173,7 +171,7 @@ func (p *Policy) ImportConfigs(c context.Context) (rev string, err error) {
err = errors.New("wrong revision in result of Prepare callback")
}
if err != nil {
- return "", errors.Annotate(err).Reason("failed to convert configs into a queryable form").Err()
+ return "", errors.Annotate(err, "failed to convert configs into a queryable form").Err()
}
logging.Infof(c, "Storing new configs")
@@ -210,7 +208,7 @@ func (p *Policy) grabQueryable(c context.Context, prev lazyslot.Value) (val lazy
hdr, err := getImportedPolicyHeader(c, p.Name)
switch {
case err != nil:
- err = errors.Annotate(err).Reason("failed to fetch importedPolicyHeader entity").Err()
+ err = errors.Annotate(err, "failed to fetch importedPolicyHeader entity").Err()
return
case hdr == nil:
err = ErrNoPolicy
@@ -231,7 +229,7 @@ func (p *Policy) grabQueryable(c context.Context, prev lazyslot.Value) (val lazy
body, err := getImportedPolicyBody(c, p.Name)
switch {
case err != nil:
- err = errors.Annotate(err).Reason("failed to fetch importedPolicyBody entity").Err()
+ err = errors.Annotate(err, "failed to fetch importedPolicyBody entity").Err()
return
case body == nil: // this is rare, the body shouldn't disappear
logging.Errorf(c, "The policy body is unexpectedly gone")
@@ -249,7 +247,7 @@ func (p *Policy) grabQueryable(c context.Context, prev lazyslot.Value) (val lazy
logging.Infof(c, "Using configs at rev %s", body.Revision)
configs, unknown, err := deserializeBundle(body.Data)
if err != nil {
- err = errors.Annotate(err).Reason("failed to deserialize cached configs").Err()
+ err = errors.Annotate(err, "failed to deserialize cached configs").Err()
return
}
if len(unknown) != 0 {
@@ -261,7 +259,7 @@ func (p *Policy) grabQueryable(c context.Context, prev lazyslot.Value) (val lazy
}
queryable, err := p.Prepare(configs, body.Revision)
if err != nil {
- err = errors.Annotate(err).Reason("failed to process cached configs").Err()
+ err = errors.Annotate(err, "failed to process cached configs").Err()
return
}
« no previous file with comments | « tokenserver/appengine/impl/certconfig/rpc_fetch_crl.go ('k') | tools/cmd/gorun/main.go » ('j') | no next file with comments »

Powered by Google App Engine
This is Rietveld 408576698