Searched refs:activeStreams (Results 1 – 3 of 3) sorted by relevance
106 activeStreams map[uint32]*Stream member218 activeStreams: make(map[uint32]*Stream),364 if uint32(len(t.activeStreams)) >= t.maxStreams {381 t.activeStreams[streamID] = s382 if len(t.activeStreams) == 1 {440 s := t.activeStreams[se.StreamID]489 if t.activeStreams == nil {493 s, ok := t.activeStreams[f.Header().StreamID]527 for _, s := range t.activeStreams {664 ns := len(t.activeStreams)[all …]
101 activeStreams map[uint32]*Stream member224 activeStreams: make(map[uint32]*Stream),539 t.activeStreams[id] = s549 if len(t.activeStreams) == 1 && t.keepaliveEnabled {666 if t.activeStreams != nil {667 delete(t.activeStreams, s.id)707 streams := t.activeStreams708 t.activeStreams = nil742 active := len(t.activeStreams)787 s, ok := t.activeStreams[f.Header().StreamID][all …]
344 activeStreams *outStreamList // Streams that are sending data. member363 activeStreams: newOutStreamList(),449 l.activeStreams.enqueue(str)586 l.activeStreams.enqueue(str)688 l.activeStreams.enqueue(stream)703 str := l.activeStreams.dequeue()724 l.activeStreams.enqueue(str)793 l.activeStreams.enqueue(str)