Lines Matching defs:stream_id
158 << syn_stream->stream_id() << ")";
193 NewStream(syn_stream->stream_id(),
252 stream_to_smif_[syn_stream->stream_id()] = sm_http_interface;
253 sm_http_interface->SetStreamID(syn_stream->stream_id());
263 reinterpret_cast<const SpdySynReplyControlFrame*>(frame)->stream_id()
271 << rst_stream->stream_id() << ")";
272 client_output_ordering_.RemoveStreamId(rst_stream ->stream_id());
281 bool SpdySM::OnControlFrameHeaderData(spdy::SpdyStreamId stream_id,
292 void SpdySM::OnStreamFrameData(SpdyStreamId stream_id,
294 VLOG(2) << ACCEPTOR_CLIENT_IDENT << "SpdySM: StreamData(" << stream_id
296 StreamToSmif::iterator it = stream_to_smif_.find(stream_id);
298 VLOG(2) << "Dropping frame from unknown stream " << stream_id;
359 void SpdySM::NewStream(uint32 stream_id,
363 mci.stream_id = stream_id;
369 SendErrorNotFound(stream_id);
382 void SpdySM::SendEOF(uint32 stream_id) {
383 SendEOFImpl(stream_id);
386 void SpdySM::SendErrorNotFound(uint32 stream_id) {
387 SendErrorNotFoundImpl(stream_id);
390 void SpdySM::SendOKResponse(uint32 stream_id, std::string* output) {
391 SendOKResponseImpl(stream_id, output);
394 size_t SpdySM::SendSynStream(uint32 stream_id, const BalsaHeaders& headers) {
395 return SendSynStreamImpl(stream_id, headers);
398 size_t SpdySM::SendSynReply(uint32 stream_id, const BalsaHeaders& headers) {
399 return SendSynReplyImpl(stream_id, headers);
402 void SpdySM::SendDataFrame(uint32 stream_id, const char* data, int64 len,
405 SendDataFrameImpl(stream_id, data, len, spdy_flags, compress);
408 void SpdySM::SendEOFImpl(uint32 stream_id) {
409 SendDataFrame(stream_id, NULL, 0, DATA_FLAG_FIN, false);
410 VLOG(2) << ACCEPTOR_CLIENT_IDENT << "SpdySM: Sending EOF: " << stream_id;
411 KillStream(stream_id);
412 stream_to_smif_.erase(stream_id);
415 void SpdySM::SendErrorNotFoundImpl(uint32 stream_id) {
418 SendSynReplyImpl(stream_id, my_headers);
419 SendDataFrame(stream_id, "wtf?", 4, DATA_FLAG_FIN, false);
420 client_output_ordering_.RemoveStreamId(stream_id);
423 void SpdySM::SendOKResponseImpl(uint32 stream_id, std::string* output) {
426 SendSynReplyImpl(stream_id, my_headers);
428 stream_id, output->c_str(), output->size(), DATA_FLAG_FIN, false);
429 client_output_ordering_.RemoveStreamId(stream_id);
432 void SpdySM::KillStream(uint32 stream_id) {
433 client_output_ordering_.RemoveStreamId(stream_id);
461 size_t SpdySM::SendSynStreamImpl(uint32 stream_id,
478 spdy_framer_->CreateSynStream(stream_id, 0, 0, CONTROL_FLAG_NONE, true,
484 << stream_id;
488 size_t SpdySM::SendSynReplyImpl(uint32 stream_id, const BalsaHeaders& headers) {
496 spdy_framer_->CreateSynReply(stream_id, CONTROL_FLAG_NONE, true, &block);
501 << stream_id;
505 void SpdySM::SendDataFrameImpl(uint32 stream_id, const char* data, int64 len,
515 SpdyDataFrame* fdf = spdy_framer_->CreateDataFrame(stream_id, data, len,
532 SpdyDataFrame* fdf = spdy_framer_->CreateDataFrame(stream_id, data, size,
537 << stream_id << " [" << size << "] shrunk to " << fdf->length()
560 << "header stream_id: [" << mci->stream_id << "]";
561 if ((mci->stream_id % 2) == 0) {
571 mci->bytes_sent = SendSynStream(mci->stream_id, headers);
575 mci->bytes_sent = SendSynReply(mci->stream_id, headers);
581 << "remove_stream_id: [" << mci->stream_id << "]";
582 SendEOF(mci->stream_id);
600 SendDataFrame(mci->stream_id,
604 << mci->stream_id << "]: " << num_to_write;
