Lines Matching refs:id
113 // TODO(rch) deal with the error case of stream id 0
180 QuicStreamId id = it->first;
183 if (stream_map_.find(id) != stream_map_.end()) {
185 CloseStream(id);
211 QuicConsumedData QuicSession::WriteData(QuicStreamId id,
215 return connection_->SendStreamData(id, data, offset, fin);
218 void QuicSession::SendRstStream(QuicStreamId id,
220 connection_->SendRstStream(id, error);
221 CloseStream(id);
243 prematurely_closed_streams_.insert(make_pair(stream->id(), true));
292 << ". activating " << stream->id();
293 DCHECK(stream_map_.count(stream->id()) == 0);
294 stream_map_[stream->id()] = stream;
298 QuicStreamId id = next_stream_id_;
300 return id;
347 for (QuicStreamId id = largest_peer_created_stream_id_ + 2;
348 id < stream_id;
349 id += 2) {
350 implicitly_created_streams_.insert(id);
363 bool QuicSession::IsClosedStream(QuicStreamId id) {
364 DCHECK_NE(0u, id);
365 if (id == kCryptoStreamId) {
368 if (stream_map_.count(id) != 0) {
372 if (id % 2 == next_stream_id_ % 2) {
373 // Locally created streams are strictly in-order. If the id is in the
375 return id < next_stream_id_;
379 return id <= largest_peer_created_stream_id_ &&
380 implicitly_created_streams_.count(id) == 0;
387 void QuicSession::MarkWriteBlocked(QuicStreamId id) {
388 write_blocked_streams_.AddBlockedObject(id);
