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

Unified Diff: logdog/client/butler/streamserver/handshake.go

Issue 2435883002: LogDog: Fix archival Get/Tail implementations. (Closed)
Patch Set: LogDog: Fix archival Get/Tail implementations. Created 4 years, 2 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
Index: logdog/client/butler/streamserver/handshake.go
diff --git a/logdog/client/butler/streamserver/handshake.go b/logdog/client/butler/streamserver/handshake.go
index 7ccba4590b14c0a67e333ba83a6fb1b494bb1758..d0d6d6f47e51a6f6d419b94760d629e809613765 100644
--- a/logdog/client/butler/streamserver/handshake.go
+++ b/logdog/client/butler/streamserver/handshake.go
@@ -118,9 +118,9 @@ func (p *handshakeProtocol) loadFlags(ctx context.Context, r io.Reader) (*stream
//
// We use a countReader because the 'json' library doesn't give us a way to
// know how many bytes it consumed when it decoded.
- if chr.Count() != frameSize {
+ if chr.Count != frameSize {
log.Fields{
- "blockSize": chr.Count(),
+ "blockSize": chr.Count,
"frameSize": frameSize,
}.Errorf(ctx, "Stream description block was not fully consumed.")
return nil, errors.New("handshake: stream description block was not fully consumed")

Powered by Google App Engine
This is Rietveld 408576698