archives/snowflake
2
0
Fork 0
mirror of https://gitlab.torproject.org/tpo/anti-censorship/pluggable-transports/snowflake.git synced 2025-10-13 11:11:30 -04:00
Code Issues Projects Releases Packages Wiki Activity Actions

Rename context_→ctx.

Browse source
This commit is contained in:
David Fifield 2018-11-05 16:40:16 -07:00
parent ff34e01e9c
commit 7662ccb00c
1 changed files with 7 additions and 7 deletions
Download patch file Download diff file Expand all files Collapse all files

14
appengine/reflect.go
View file

@ -20,7 +20,7 @@ const (
urlFetchTimeout = 20 * time.Second
)
var context_ context.Context
var ctx context.Context
// Join two URL paths.
func pathJoin(a, b string) string {
@ -67,26 +67,26 @@ func copyRequest(r *http.Request) (*http.Request, error) {
}
func handler(w http.ResponseWriter, r *http.Request) {
context_ = appengine.NewContext(r)
ctx = appengine.NewContext(r)
fr, err := copyRequest(r)
if err != nil {
log.Errorf(context_, "copyRequest: %s", err)
log.Errorf(ctx, "copyRequest: %s", err)
http.Error(w, err.Error(), http.StatusInternalServerError)
return
}
if urlFetchTimeout != 0 {
var cancel context.CancelFunc
context_, cancel = context.WithTimeout(context_, urlFetchTimeout)
ctx, cancel = context.WithTimeout(ctx, urlFetchTimeout)
defer cancel()
}
// Use urlfetch.Transport directly instead of urlfetch.Client because we
// want only a single HTTP transaction, not following redirects.
transport := urlfetch.Transport{
Context: context_,
Context: ctx,
}
resp, err := transport.RoundTrip(fr)
if err != nil {
log.Errorf(context_, "RoundTrip: %s", err)
log.Errorf(ctx, "RoundTrip: %s", err)
http.Error(w, err.Error(), http.StatusInternalServerError)
return
}
@ -102,7 +102,7 @@ func handler(w http.ResponseWriter, r *http.Request) {
w.WriteHeader(resp.StatusCode)
n, err := io.Copy(w, resp.Body)
if err != nil {
log.Errorf(context_, "io.Copy after %d bytes: %s", n, err)
log.Errorf(ctx, "io.Copy after %d bytes: %s", n, err)
}
}