fix a bug in the PR#264
This commit is contained in:
@ -362,7 +362,6 @@ func (s *Server) processStreamingRPC(t transport.ServerTransport, stream *transp
|
|||||||
ss.statusCode = convertCode(appErr)
|
ss.statusCode = convertCode(appErr)
|
||||||
ss.statusDesc = appErr.Error()
|
ss.statusDesc = appErr.Error()
|
||||||
}
|
}
|
||||||
return nil
|
|
||||||
}
|
}
|
||||||
return t.WriteStatus(ss.s, ss.statusCode, ss.statusDesc)
|
return t.WriteStatus(ss.s, ss.statusCode, ss.statusDesc)
|
||||||
|
|
||||||
|
2
trace.go
2
trace.go
@ -46,7 +46,7 @@ import (
|
|||||||
|
|
||||||
// EnableTracing controls whether to trace RPCs using the golang.org/x/net/trace package.
|
// EnableTracing controls whether to trace RPCs using the golang.org/x/net/trace package.
|
||||||
// This should only be set before any RPCs are sent or received by this program.
|
// This should only be set before any RPCs are sent or received by this program.
|
||||||
var EnableTracing = true
|
var EnableTracing = false
|
||||||
|
|
||||||
// methodFamily returns the trace family for the given method.
|
// methodFamily returns the trace family for the given method.
|
||||||
// It turns "/pkg.Service/GetFoo" into "pkg.Service".
|
// It turns "/pkg.Service/GetFoo" into "pkg.Service".
|
||||||
|
Reference in New Issue
Block a user