Lines Matching refs:stream_id
128 SpdyStreamId stream_id,
135 << stream_id << ")";
166 NewStream(stream_id, priority, filename);
190 void SpdySM::OnStreamFrameData(SpdyStreamId stream_id,
194 VLOG(2) << ACCEPTOR_CLIENT_IDENT << "SpdySM: StreamData(" << stream_id
196 StreamToSmif::iterator it = stream_to_smif_.find(stream_id);
198 VLOG(2) << "Dropping frame from unknown stream " << stream_id;
209 void SpdySM::OnSynStream(SpdyStreamId stream_id,
218 int ret = SpdyHandleNewStream(stream_id, priority, headers, http_data,
240 stream_to_smif_[stream_id] = sm_http_interface;
241 sm_http_interface->SetStreamID(stream_id);
247 void SpdySM::OnSynReply(SpdyStreamId stream_id,
253 << stream_id << ")";
256 void SpdySM::OnHeaders(SpdyStreamId stream_id,
260 << stream_id << ")";
263 void SpdySM::OnRstStream(SpdyStreamId stream_id,
266 << stream_id << ")";
267 client_output_ordering_.RemoveStreamId(stream_id);
320 void SpdySM::NewStream(uint32 stream_id,
324 mci.stream_id = stream_id;
330 SendErrorNotFound(stream_id);
343 void SpdySM::SendEOF(uint32 stream_id) {
344 SendEOFImpl(stream_id);
347 void SpdySM::SendErrorNotFound(uint32 stream_id) {
348 SendErrorNotFoundImpl(stream_id);
351 void SpdySM::SendOKResponse(uint32 stream_id, std::string* output) {
352 SendOKResponseImpl(stream_id, output);
355 size_t SpdySM::SendSynStream(uint32 stream_id, const BalsaHeaders& headers) {
356 return SendSynStreamImpl(stream_id, headers);
359 size_t SpdySM::SendSynReply(uint32 stream_id, const BalsaHeaders& headers) {
360 return SendSynReplyImpl(stream_id, headers);
363 void SpdySM::SendDataFrame(uint32 stream_id, const char* data, int64 len,
366 SendDataFrameImpl(stream_id, data, len, spdy_flags, compress);
369 void SpdySM::SendEOFImpl(uint32 stream_id) {
370 SendDataFrame(stream_id, NULL, 0, DATA_FLAG_FIN, false);
371 VLOG(2) << ACCEPTOR_CLIENT_IDENT << "SpdySM: Sending EOF: " << stream_id;
372 KillStream(stream_id);
373 stream_to_smif_.erase(stream_id);
376 void SpdySM::SendErrorNotFoundImpl(uint32 stream_id) {
379 SendSynReplyImpl(stream_id, my_headers);
380 SendDataFrame(stream_id, "wtf?", 4, DATA_FLAG_FIN, false);
381 client_output_ordering_.RemoveStreamId(stream_id);
384 void SpdySM::SendOKResponseImpl(uint32 stream_id, std::string* output) {
387 SendSynReplyImpl(stream_id, my_headers);
389 stream_id, output->c_str(), output->size(), DATA_FLAG_FIN, false);
390 client_output_ordering_.RemoveStreamId(stream_id);
393 void SpdySM::KillStream(uint32 stream_id) {
394 client_output_ordering_.RemoveStreamId(stream_id);
425 size_t SpdySM::SendSynStreamImpl(uint32 stream_id,
442 stream_id, 0, 0, 0, CONTROL_FLAG_NONE, true, &block);
447 << stream_id;
451 size_t SpdySM::SendSynReplyImpl(uint32 stream_id, const BalsaHeaders& headers) {
459 stream_id, CONTROL_FLAG_NONE, true, &block);
464 << stream_id;
468 void SpdySM::SendDataFrameImpl(uint32 stream_id, const char* data, int64 len,
475 stream_id, data, len, flags);
492 stream_id, data, size, chunk_flags);
496 << stream_id << " [" << size << "] shrunk to "
519 << "header stream_id: [" << mci->stream_id << "]";
520 if ((mci->stream_id % 2) == 0) {
530 mci->bytes_sent = SendSynStream(mci->stream_id, headers);
534 mci->bytes_sent = SendSynReply(mci->stream_id, headers);
540 << "remove_stream_id: [" << mci->stream_id << "]";
541 SendEOF(mci->stream_id);
559 SendDataFrame(mci->stream_id,
563 << mci->stream_id << "]: " << num_to_write;
