(debugData string)
| 1370 | } |
| 1371 | |
| 1372 | func (t *http2Server) Drain(debugData string) { |
| 1373 | t.mu.Lock() |
| 1374 | defer t.mu.Unlock() |
| 1375 | if t.drainEvent != nil { |
| 1376 | return |
| 1377 | } |
| 1378 | t.drainEvent = grpcsync.NewEvent() |
| 1379 | t.controlBuf.put(&goAway{code: http2.ErrCodeNo, debugData: []byte(debugData), headsUp: true}) |
| 1380 | } |
| 1381 | |
| 1382 | var goAwayPing = &ping{data: [8]byte{1, 6, 1, 8, 0, 3, 3, 9}} |
| 1383 |