(ids [][frame.SessionIDLen]byte)
| 1243 | } |
| 1244 | |
| 1245 | func (c *Client) releaseInFlight(ids [][frame.SessionIDLen]byte) { |
| 1246 | c.mu.Lock() |
| 1247 | defer c.mu.Unlock() |
| 1248 | for _, id := range ids { |
| 1249 | delete(c.inFlight, id) |
| 1250 | // Re-add to txReady if the batch cap left data behind or new data |
| 1251 | // arrived while this session was in-flight. |
| 1252 | if s, ok := c.sessions[id]; ok && s.HasPendingTx() { |
| 1253 | c.txReady[id] = struct{}{} |
| 1254 | } |
| 1255 | } |
| 1256 | } |
| 1257 | |
| 1258 | func (c *Client) routeRx(f *frame.Frame) { |
| 1259 | c.mu.Lock() |