| 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 prod | 5 package prod | 
| 6 | 6 | 
| 7 import ( | 7 import ( | 
| 8         "time" | 8         "time" | 
| 9 | 9 | 
| 10         "github.com/luci/gae/service/info" | 10         "github.com/luci/gae/service/info" | 
| (...skipping 59 matching lines...) Expand 10 before | Expand all | Expand 10 after  Loading... | 
| 70 func (g giImpl) Namespace(namespace string) (context.Context, error) { | 70 func (g giImpl) Namespace(namespace string) (context.Context, error) { | 
| 71         aeCtx, err := appengine.Namespace(g.aeCtx, namespace) | 71         aeCtx, err := appengine.Namespace(g.aeCtx, namespace) | 
| 72         if err != nil { | 72         if err != nil { | 
| 73                 return g.usrCtx, err | 73                 return g.usrCtx, err | 
| 74         } | 74         } | 
| 75         usrCtx := context.WithValue(g.usrCtx, prodContextKey, aeCtx) | 75         usrCtx := context.WithValue(g.usrCtx, prodContextKey, aeCtx) | 
| 76         pc := *getProbeCache(usrCtx) | 76         pc := *getProbeCache(usrCtx) | 
| 77         pc.namespace = namespace | 77         pc.namespace = namespace | 
| 78         return withProbeCache(usrCtx, &pc), nil | 78         return withProbeCache(usrCtx, &pc), nil | 
| 79 } | 79 } | 
|  | 80 func (g giImpl) MustNamespace(ns string) context.Context { | 
|  | 81         ret, err := g.Namespace(ns) | 
|  | 82         if err != nil { | 
|  | 83                 panic(err) | 
|  | 84         } | 
|  | 85         return ret | 
|  | 86 } | 
| 80 func (g giImpl) PublicCertificates() ([]info.Certificate, error) { | 87 func (g giImpl) PublicCertificates() ([]info.Certificate, error) { | 
| 81         certs, err := appengine.PublicCertificates(g.aeCtx) | 88         certs, err := appengine.PublicCertificates(g.aeCtx) | 
| 82         if err != nil { | 89         if err != nil { | 
| 83                 return nil, err | 90                 return nil, err | 
| 84         } | 91         } | 
| 85         ret := make([]info.Certificate, len(certs)) | 92         ret := make([]info.Certificate, len(certs)) | 
| 86         for i, c := range certs { | 93         for i, c := range certs { | 
| 87                 ret[i] = info.Certificate(c) | 94                 ret[i] = info.Certificate(c) | 
| 88         } | 95         } | 
| 89         return ret, nil | 96         return ret, nil | 
| (...skipping 30 matching lines...) Expand all  Loading... | 
| 120 func getProbeCache(c context.Context) *infoProbeCache { | 127 func getProbeCache(c context.Context) *infoProbeCache { | 
| 121         if pc, ok := c.Value(probeCacheKey).(*infoProbeCache); ok { | 128         if pc, ok := c.Value(probeCacheKey).(*infoProbeCache); ok { | 
| 122                 return pc | 129                 return pc | 
| 123         } | 130         } | 
| 124         return nil | 131         return nil | 
| 125 } | 132 } | 
| 126 | 133 | 
| 127 func withProbeCache(c context.Context, pc *infoProbeCache) context.Context { | 134 func withProbeCache(c context.Context, pc *infoProbeCache) context.Context { | 
| 128         return context.WithValue(c, probeCacheKey, pc) | 135         return context.WithValue(c, probeCacheKey, pc) | 
| 129 } | 136 } | 
| OLD | NEW | 
|---|