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()
985 BaseObjectPtr<Http2Stream> stream = session->FindStream(id); in OnStreamClose()
1046 BaseObjectPtr<Http2Stream> stream = session->FindStream(id); in OnDataChunkReceived()
1161 Http2Stream* stream = static_cast<Http2Stream*>(stream_); in OnStreamRead()
1205 BaseObjectPtr<Http2Stream> stream = FindStream(id); in HandleHeadersFrame()
1281 BaseObjectPtr<Http2Stream> stream = FindStream(id); in HandleDataFrame()
1553 BaseObjectPtr<Http2Stream> stream = FindStream(stream_id); in ClearOutgoing()
1680 BaseObjectPtr<Http2Stream> stream = session->FindStream(frame->hd.stream_id); in OnSendData()
1726 Http2Stream* Http2Session::SubmitRequest( in SubmitRequest()
1733 Http2Stream* stream = nullptr; in SubmitRequest()
1734 Http2Stream::Provider::Stream prov(options); in SubmitRequest()
1744 stream = Http2Stream::New(this, *ret, NGHTTP2_HCAT_HEADERS, options); in SubmitRequest()
1820 bool Http2Session::HasWritesOnSocketForStream(Http2Stream* stream) { in HasWritesOnSocketForStream()
1865 Http2Stream* Http2Stream::New(Http2Session* session, in New()
1876 return new Http2Stream(session, obj, id, category, options); in New()
1879 Http2Stream::Http2Stream(Http2Session* session, in Http2Stream() function in node::http2::Http2Stream
1918 Http2Stream::~Http2Stream() { in ~Http2Stream()
1922 void Http2Stream::MemoryInfo(MemoryTracker* tracker) const { in MemoryInfo()
1927 std::string Http2Stream::diagnostic_name() const { in diagnostic_name()
1934 void Http2Stream::StartHeaders(nghttp2_headers_category category) { in StartHeaders()
1944 nghttp2_stream* Http2Stream::operator*() const { return stream(); } in operator *()
1946 nghttp2_stream* Http2Stream::stream() const { in stream()
1950 void Http2Stream::Close(int32_t code) { in Close()
1957 ShutdownWrap* Http2Stream::CreateShutdownWrap(v8::Local<v8::Object> object) { in CreateShutdownWrap()
1963 int Http2Stream::DoShutdown(ShutdownWrap* req_wrap) { in DoShutdown()
1981 void Http2Stream::Destroy() { in Destroy()
1993 BaseObjectPtr<Http2Stream> strong_ref = session_->RemoveStream(id_); in Destroy()
2028 int Http2Stream::SubmitResponse(const Http2Headers& headers, int options) { in SubmitResponse()
2038 Http2Stream::Provider::Stream prov(this, options); in SubmitResponse()
2051 int Http2Stream::SubmitInfo(const Http2Headers& headers) { in SubmitInfo()
2067 void Http2Stream::OnTrailers() { in OnTrailers()
2079 int Http2Stream::SubmitTrailers(const Http2Headers& headers) { in SubmitTrailers()
2088 Http2Stream::Provider::Stream prov(this, 0); in SubmitTrailers()
2106 int Http2Stream::SubmitPriority(const Http2Priority& priority, in SubmitPriority()
2126 void Http2Stream::SubmitRstStream(const uint32_t code) { in SubmitRstStream()
2160 void Http2Stream::FlushRstStream() { in FlushRstStream()
2173 Http2Stream* Http2Stream::SubmitPushPromise(const Http2Headers& headers, in SubmitPushPromise()
2187 Http2Stream* stream = nullptr; in SubmitPushPromise()
2189 stream = Http2Stream::New( in SubmitPushPromise()
2198 int Http2Stream::ReadStart() { in ReadStart()
2217 int Http2Stream::ReadStop() { in ReadStop()
2236 int Http2Stream::DoWrite(WriteWrap* req_wrap, in DoWrite()
2268 bool Http2Stream::AddHeader(nghttp2_rcbuf* name, in AddHeader()
2297 Http2Stream::Provider::Provider(Http2Stream* stream, int options) { in Provider()
2303 Http2Stream::Provider::Provider(int options) { in Provider()
2308 Http2Stream::Provider::~Provider() { in ~Provider()
2314 Http2Stream::Provider::Stream::Stream(int options) in Stream()
2315 : Http2Stream::Provider(options) { in Stream()
2316 provider_.read_callback = Http2Stream::Provider::Stream::OnRead; in Stream()
2319 Http2Stream::Provider::Stream::Stream(Http2Stream* stream, int options) in Stream()
2320 : Http2Stream::Provider(stream, options) { in Stream()
2321 provider_.read_callback = Http2Stream::Provider::Stream::OnRead; in Stream()
2324 ssize_t Http2Stream::Provider::Stream::OnRead(nghttp2_session* handle, in OnRead()
2333 BaseObjectPtr<Http2Stream> stream = session->FindStream(id); in OnRead()
2389 void Http2Stream::IncrementAvailableOutboundLength(size_t amount) { in IncrementAvailableOutboundLength()
2394 void Http2Stream::DecrementAvailableOutboundLength(size_t amount) { in DecrementAvailableOutboundLength()
2554 Http2Stream* stream = in Request()
2630 void Http2Stream::RstStream(const FunctionCallbackInfo<Value>& args) { in RstStream()
2633 Http2Stream* stream; in RstStream()
2642 void Http2Stream::Respond(const FunctionCallbackInfo<Value>& args) { in Respond()
2644 Http2Stream* stream; in Respond()
2659 void Http2Stream::Info(const FunctionCallbackInfo<Value>& args) { in Info()
2661 Http2Stream* stream; in Info()
2670 void Http2Stream::Trailers(const FunctionCallbackInfo<Value>& args) { in Trailers()
2672 Http2Stream* stream; in Trailers()
2682 void Http2Stream::GetID(const FunctionCallbackInfo<Value>& args) { in GetID()
2683 Http2Stream* stream; in GetID()
2689 void Http2Stream::Destroy(const FunctionCallbackInfo<Value>& args) { in Destroy()
2690 Http2Stream* stream; in Destroy()
2697 void Http2Stream::PushPromise(const FunctionCallbackInfo<Value>& args) { in PushPromise()
2699 Http2Stream* parent; in PushPromise()
2708 Http2Stream* stream = in PushPromise()
2723 void Http2Stream::Priority(const FunctionCallbackInfo<Value>& args) { in Priority()
2725 Http2Stream* stream; in Priority()
2737 void Http2Stream::RefreshState(const FunctionCallbackInfo<Value>& args) { in RefreshState()
2738 Http2Stream* stream; in RefreshState()
3095 env->SetProtoMethod(stream, "id", Http2Stream::GetID); in Initialize()
3096 env->SetProtoMethod(stream, "destroy", Http2Stream::Destroy); in Initialize()
3097 env->SetProtoMethod(stream, "priority", Http2Stream::Priority); in Initialize()
3098 env->SetProtoMethod(stream, "pushPromise", Http2Stream::PushPromise); in Initialize()
3099 env->SetProtoMethod(stream, "info", Http2Stream::Info); in Initialize()
3100 env->SetProtoMethod(stream, "trailers", Http2Stream::Trailers); in Initialize()
3101 env->SetProtoMethod(stream, "respond", Http2Stream::Respond); in Initialize()
3102 env->SetProtoMethod(stream, "rstStream", Http2Stream::RstStream); in Initialize()
3103 env->SetProtoMethod(stream, "refreshState", Http2Stream::RefreshState); in Initialize()