()
| 1454 | } |
| 1455 | |
| 1456 | func (t *http2Server) incrMsgRecv() { |
| 1457 | if channelz.IsOn() { |
| 1458 | t.channelz.SocketMetrics.MessagesReceived.Add(1) |
| 1459 | t.channelz.SocketMetrics.LastMessageReceivedTimestamp.Store(transportinternal.TimeNowFunc()) |
| 1460 | } |
| 1461 | } |
| 1462 | |
| 1463 | func (t *http2Server) getOutFlowWindow() int64 { |
| 1464 | resp := make(chan uint32, 1) |