Lines Matching refs:Http2Stream
75 Http2Scope::Http2Scope(Http2Stream* stream) : Http2Scope(stream->session()) {} in Http2Scope()
544 void Http2Stream::EmitStatistics() { in EmitStatistics()
664 BaseObjectPtr<Http2Stream> Http2Session::FindStream(int32_t id) { in FindStream()
666 return s != streams_.end() ? s->second : BaseObjectPtr<Http2Stream>(); in FindStream()
678 has_available_session_memory(sizeof(Http2Stream)); in CanAddStream()
681 void Http2Session::AddStream(Http2Stream* stream) { in AddStream()
683 streams_[stream->id()] = BaseObjectPtr<Http2Stream>(stream); in AddStream()
691 BaseObjectPtr<Http2Stream> Http2Session::RemoveStream(int32_t id) { in RemoveStream()
692 BaseObjectPtr<Http2Stream> stream; in RemoveStream()
802 BaseObjectPtr<Http2Stream> stream = session->FindStream(id); in OnBeginHeadersCallback()
807 Http2Stream::New(session, id, frame->headers.cat) == in OnBeginHeadersCallback()
839 BaseObjectPtr<Http2Stream> stream = session->FindStream(id); in OnHeaderCallback()
930 BaseObjectPtr<Http2Stream> stream = FindStream(id); in DecrefHeaders()
1005 BaseObjectPtr<Http2Stream> stream = session->FindStream(id); in OnStreamClose()
1066 BaseObjectPtr<Http2Stream> stream = session->FindStream(id); in OnDataChunkReceived()
1181 Http2Stream* stream = static_cast<Http2Stream*>(stream_); in OnStreamRead()
1225 BaseObjectPtr<Http2Stream> stream = FindStream(id); in HandleHeadersFrame()
1301 BaseObjectPtr<Http2Stream> stream = FindStream(id); in HandleDataFrame()
1573 BaseObjectPtr<Http2Stream> stream = FindStream(stream_id); in ClearOutgoing()
1700 BaseObjectPtr<Http2Stream> stream = session->FindStream(frame->hd.stream_id); in OnSendData()
1746 Http2Stream* Http2Session::SubmitRequest( in SubmitRequest()
1753 Http2Stream* stream = nullptr; in SubmitRequest()
1754 Http2Stream::Provider::Stream prov(options); in SubmitRequest()
1764 stream = Http2Stream::New(this, *ret, NGHTTP2_HCAT_HEADERS, options); in SubmitRequest()
1840 bool Http2Session::HasWritesOnSocketForStream(Http2Stream* stream) { in HasWritesOnSocketForStream()
1885 Http2Stream* Http2Stream::New(Http2Session* session, in New()
1896 return new Http2Stream(session, obj, id, category, options); in New()
1899 Http2Stream::Http2Stream(Http2Session* session, in Http2Stream() function in node::http2::Http2Stream
1938 Http2Stream::~Http2Stream() { in ~Http2Stream()
1942 void Http2Stream::MemoryInfo(MemoryTracker* tracker) const { in MemoryInfo()
1947 std::string Http2Stream::diagnostic_name() const { in diagnostic_name()
1954 void Http2Stream::StartHeaders(nghttp2_headers_category category) { in StartHeaders()
1964 nghttp2_stream* Http2Stream::operator*() const { return stream(); } in operator *()
1966 nghttp2_stream* Http2Stream::stream() const { in stream()
1970 void Http2Stream::Close(int32_t code) { in Close()
1977 ShutdownWrap* Http2Stream::CreateShutdownWrap(v8::Local<v8::Object> object) { in CreateShutdownWrap()
1983 int Http2Stream::DoShutdown(ShutdownWrap* req_wrap) { in DoShutdown()
2001 void Http2Stream::Destroy() { in Destroy()
2013 BaseObjectPtr<Http2Stream> strong_ref = session_->RemoveStream(id_); in Destroy()
2048 int Http2Stream::SubmitResponse(const Http2Headers& headers, int options) { in SubmitResponse()
2058 Http2Stream::Provider::Stream prov(this, options); in SubmitResponse()
2071 int Http2Stream::SubmitInfo(const Http2Headers& headers) { in SubmitInfo()
2087 void Http2Stream::OnTrailers() { in OnTrailers()
2099 int Http2Stream::SubmitTrailers(const Http2Headers& headers) { in SubmitTrailers()
2108 Http2Stream::Provider::Stream prov(this, 0); in SubmitTrailers()
2126 int Http2Stream::SubmitPriority(const Http2Priority& priority, in SubmitPriority()
2146 void Http2Stream::SubmitRstStream(const uint32_t code) { in SubmitRstStream()
2180 void Http2Stream::FlushRstStream() { in FlushRstStream()
2193 Http2Stream* Http2Stream::SubmitPushPromise(const Http2Headers& headers, in SubmitPushPromise()
2207 Http2Stream* stream = nullptr; in SubmitPushPromise()
2209 stream = Http2Stream::New( in SubmitPushPromise()
2218 int Http2Stream::ReadStart() { in ReadStart()
2237 int Http2Stream::ReadStop() { in ReadStop()
2256 int Http2Stream::DoWrite(WriteWrap* req_wrap, in DoWrite()
2288 bool Http2Stream::AddHeader(nghttp2_rcbuf* name, in AddHeader()
2317 Http2Stream::Provider::Provider(Http2Stream* stream, int options) { in Provider()
2323 Http2Stream::Provider::Provider(int options) { in Provider()
2328 Http2Stream::Provider::~Provider() { in ~Provider()
2334 Http2Stream::Provider::Stream::Stream(int options) in Stream()
2335 : Http2Stream::Provider(options) { in Stream()
2336 provider_.read_callback = Http2Stream::Provider::Stream::OnRead; in Stream()
2339 Http2Stream::Provider::Stream::Stream(Http2Stream* stream, int options) in Stream()
2340 : Http2Stream::Provider(stream, options) { in Stream()
2341 provider_.read_callback = Http2Stream::Provider::Stream::OnRead; in Stream()
2344 ssize_t Http2Stream::Provider::Stream::OnRead(nghttp2_session* handle, in OnRead()
2353 BaseObjectPtr<Http2Stream> stream = session->FindStream(id); in OnRead()
2409 void Http2Stream::IncrementAvailableOutboundLength(size_t amount) { in IncrementAvailableOutboundLength()
2414 void Http2Stream::DecrementAvailableOutboundLength(size_t amount) { in DecrementAvailableOutboundLength()
2574 Http2Stream* stream = in Request()
2650 void Http2Stream::RstStream(const FunctionCallbackInfo<Value>& args) { in RstStream()
2653 Http2Stream* stream; in RstStream()
2662 void Http2Stream::Respond(const FunctionCallbackInfo<Value>& args) { in Respond()
2664 Http2Stream* stream; in Respond()
2679 void Http2Stream::Info(const FunctionCallbackInfo<Value>& args) { in Info()
2681 Http2Stream* stream; in Info()
2690 void Http2Stream::Trailers(const FunctionCallbackInfo<Value>& args) { in Trailers()
2692 Http2Stream* stream; in Trailers()
2702 void Http2Stream::GetID(const FunctionCallbackInfo<Value>& args) { in GetID()
2703 Http2Stream* stream; in GetID()
2709 void Http2Stream::Destroy(const FunctionCallbackInfo<Value>& args) { in Destroy()
2710 Http2Stream* stream; in Destroy()
2717 void Http2Stream::PushPromise(const FunctionCallbackInfo<Value>& args) { in PushPromise()
2719 Http2Stream* parent; in PushPromise()
2728 Http2Stream* stream = in PushPromise()
2743 void Http2Stream::Priority(const FunctionCallbackInfo<Value>& args) { in Priority()
2745 Http2Stream* stream; in Priority()
2757 void Http2Stream::RefreshState(const FunctionCallbackInfo<Value>& args) { in RefreshState()
2758 Http2Stream* stream; in RefreshState()
3115 env->SetProtoMethod(stream, "id", Http2Stream::GetID); in Initialize()
3116 env->SetProtoMethod(stream, "destroy", Http2Stream::Destroy); in Initialize()
3117 env->SetProtoMethod(stream, "priority", Http2Stream::Priority); in Initialize()
3118 env->SetProtoMethod(stream, "pushPromise", Http2Stream::PushPromise); in Initialize()
3119 env->SetProtoMethod(stream, "info", Http2Stream::Info); in Initialize()
3120 env->SetProtoMethod(stream, "trailers", Http2Stream::Trailers); in Initialize()
3121 env->SetProtoMethod(stream, "respond", Http2Stream::Respond); in Initialize()
3122 env->SetProtoMethod(stream, "rstStream", Http2Stream::RstStream); in Initialize()
3123 env->SetProtoMethod(stream, "refreshState", Http2Stream::RefreshState); in Initialize()