Lines Matching refs:trInfo
755 func (s *Server) traceInfo(st transport.ServerTransport, stream *transport.Stream) (trInfo *traceIn…
761 trInfo = &traceInfo{
764 trInfo.firstLine.client = false
765 trInfo.firstLine.remoteAddr = st.RemoteAddr()
768 trInfo.firstLine.deadline = dl.Sub(time.Now())
770 return trInfo
853 …ServerTransport, stream *transport.Stream, srv *service, md *MethodDesc, trInfo *traceInfo) (err e…
882 if trInfo != nil {
883 defer trInfo.tr.Finish()
884 trInfo.firstLine.client = false
885 trInfo.tr.LazyLog(&trInfo.firstLine, false)
888 trInfo.tr.LazyLog(&fmtStringer{"%v", []interface{}{err}}, true)
889 trInfo.tr.SetError()
1006 if trInfo != nil {
1007 trInfo.tr.LazyLog(&payload{sent: false, msg: v}, true)
1020 if trInfo != nil {
1021 trInfo.tr.LazyLog(stringer(appStatus.Message()), true)
1022 trInfo.tr.SetError()
1029 if trInfo != nil {
1030 trInfo.tr.LazyLog(stringer("OK"), false)
1063 if trInfo != nil {
1064 trInfo.tr.LazyLog(&payload{sent: true, msg: reply}, true)
1072 …ServerTransport, stream *transport.Stream, srv *service, sd *StreamDesc, trInfo *traceInfo) (err e…
1110 trInfo: trInfo,
1142 if trInfo != nil {
1143 trInfo.tr.LazyLog(&trInfo.firstLine, false)
1147 ss.trInfo.tr.LazyLog(&fmtStringer{"%v", []interface{}{err}}, true)
1148 ss.trInfo.tr.SetError()
1150 ss.trInfo.tr.Finish()
1151 ss.trInfo.tr = nil
1181 if trInfo != nil {
1183 ss.trInfo.tr.LazyLog(stringer(appStatus.Message()), true)
1184 ss.trInfo.tr.SetError()
1191 if trInfo != nil {
1193 ss.trInfo.tr.LazyLog(stringer("OK"), false)
1199 func (s *Server) handleStream(t transport.ServerTransport, stream *transport.Stream, trInfo *traceI…
1206 if trInfo != nil {
1207 trInfo.tr.LazyLog(&fmtStringer{"Malformed method name %q", []interface{}{sm}}, true)
1208 trInfo.tr.SetError()
1212 if trInfo != nil {
1213 trInfo.tr.LazyLog(&fmtStringer{"%v", []interface{}{err}}, true)
1214 trInfo.tr.SetError()
1218 if trInfo != nil {
1219 trInfo.tr.Finish()
1228 s.processStreamingRPC(t, stream, nil, unknownDesc, trInfo)
1231 if trInfo != nil {
1232 trInfo.tr.LazyLog(&fmtStringer{"Unknown service %v", []interface{}{service}}, true)
1233 trInfo.tr.SetError()
1237 if trInfo != nil {
1238 trInfo.tr.LazyLog(&fmtStringer{"%v", []interface{}{err}}, true)
1239 trInfo.tr.SetError()
1243 if trInfo != nil {
1244 trInfo.tr.Finish()
1250 s.processUnaryRPC(t, stream, srv, md, trInfo)
1254 s.processStreamingRPC(t, stream, srv, sd, trInfo)
1257 if trInfo != nil {
1258 trInfo.tr.LazyLog(&fmtStringer{"Unknown method %v", []interface{}{method}}, true)
1259 trInfo.tr.SetError()
1262 s.processStreamingRPC(t, stream, nil, unknownDesc, trInfo)
1267 if trInfo != nil {
1268 trInfo.tr.LazyLog(&fmtStringer{"%v", []interface{}{err}}, true)
1269 trInfo.tr.SetError()
1273 if trInfo != nil {
1274 trInfo.tr.Finish()