Lines Matching refs:Http2Stream
79 Http2Scope::Http2Scope(Http2Stream* stream) : Http2Scope(stream->session()) {} in Http2Scope()
631 void Http2Stream::EmitStatistics() { in EmitStatistics()
729 BaseObjectPtr<Http2Stream> Http2Session::FindStream(int32_t id) { in FindStream()
731 return s != streams_.end() ? s->second : BaseObjectPtr<Http2Stream>(); in FindStream()
743 has_available_session_memory(sizeof(Http2Stream)); in CanAddStream()
746 void Http2Session::AddStream(Http2Stream* stream) { in AddStream()
748 streams_[stream->id()] = BaseObjectPtr<Http2Stream>(stream); in AddStream()
756 BaseObjectPtr<Http2Stream> Http2Session::RemoveStream(int32_t id) { in RemoveStream()
757 BaseObjectPtr<Http2Stream> stream; in RemoveStream()
889 BaseObjectPtr<Http2Stream> stream = session->FindStream(id); in OnBeginHeadersCallback()
894 Http2Stream::New(session, id, frame->headers.cat) == in OnBeginHeadersCallback()
926 BaseObjectPtr<Http2Stream> stream = session->FindStream(id); in OnHeaderCallback()
1020 BaseObjectPtr<Http2Stream> stream = FindStream(id); in DecrefHeaders()
1115 BaseObjectPtr<Http2Stream> stream = session->FindStream(id); in OnStreamClose()
1177 BaseObjectPtr<Http2Stream> stream = session->FindStream(id); in OnDataChunkReceived()
1289 Http2Stream* stream = static_cast<Http2Stream*>(stream_); in OnStreamRead()
1334 BaseObjectPtr<Http2Stream> stream = FindStream(id); in HandleHeadersFrame()
1410 BaseObjectPtr<Http2Stream> stream = FindStream(id); in HandleDataFrame()
1692 BaseObjectPtr<Http2Stream> stream = FindStream(stream_id); in ClearOutgoing()
1819 BaseObjectPtr<Http2Stream> stream = session->FindStream(frame->hd.stream_id); in OnSendData()
1865 Http2Stream* Http2Session::SubmitRequest( in SubmitRequest()
1872 Http2Stream* stream = nullptr; in SubmitRequest()
1873 Http2Stream::Provider::Stream prov(options); in SubmitRequest()
1883 stream = Http2Stream::New(this, *ret, NGHTTP2_HCAT_HEADERS, options); in SubmitRequest()
1961 bool Http2Session::HasWritesOnSocketForStream(Http2Stream* stream) { in HasWritesOnSocketForStream()
2006 Http2Stream* Http2Stream::New(Http2Session* session, in New()
2017 return new Http2Stream(session, obj, id, category, options); in New()
2020 Http2Stream::Http2Stream(Http2Session* session, in Http2Stream() function in node::http2::Http2Stream
2060 Http2Stream::~Http2Stream() { in ~Http2Stream()
2064 void Http2Stream::MemoryInfo(MemoryTracker* tracker) const { in MemoryInfo()
2069 std::string Http2Stream::diagnostic_name() const { in diagnostic_name()
2079 void Http2Stream::StartHeaders(nghttp2_headers_category category) { in StartHeaders()
2089 nghttp2_stream* Http2Stream::operator*() const { return stream(); } in operator *()
2091 nghttp2_stream* Http2Stream::stream() const { in stream()
2095 void Http2Stream::Close(int32_t code) { in Close()
2102 ShutdownWrap* Http2Stream::CreateShutdownWrap(Local<Object> object) { in CreateShutdownWrap()
2108 int Http2Stream::DoShutdown(ShutdownWrap* req_wrap) { in DoShutdown()
2126 void Http2Stream::Destroy() { in Destroy()
2138 BaseObjectPtr<Http2Stream> strong_ref = session_->RemoveStream(id_); in Destroy()
2173 int Http2Stream::SubmitResponse(const Http2Headers& headers, int options) { in SubmitResponse()
2183 Http2Stream::Provider::Stream prov(this, options); in SubmitResponse()
2196 int Http2Stream::SubmitInfo(const Http2Headers& headers) { in SubmitInfo()
2212 void Http2Stream::OnTrailers() { in OnTrailers()
2224 int Http2Stream::SubmitTrailers(const Http2Headers& headers) { in SubmitTrailers()
2233 Http2Stream::Provider::Stream prov(this, 0); in SubmitTrailers()
2251 int Http2Stream::SubmitPriority(const Http2Priority& priority, in SubmitPriority()
2271 void Http2Stream::SubmitRstStream(const uint32_t code) { in SubmitRstStream()
2305 void Http2Stream::FlushRstStream() { in FlushRstStream()
2318 Http2Stream* Http2Stream::SubmitPushPromise(const Http2Headers& headers, in SubmitPushPromise()
2332 Http2Stream* stream = nullptr; in SubmitPushPromise()
2334 stream = Http2Stream::New( in SubmitPushPromise()
2343 int Http2Stream::ReadStart() { in ReadStart()
2362 int Http2Stream::ReadStop() { in ReadStop()
2381 int Http2Stream::DoWrite(WriteWrap* req_wrap, in DoWrite()
2412 bool Http2Stream::AddHeader(nghttp2_rcbuf* name, in AddHeader()
2441 Http2Stream::Provider::Provider(Http2Stream* stream, int options) { in Provider()
2447 Http2Stream::Provider::Provider(int options) { in Provider()
2452 Http2Stream::Provider::~Provider() { in ~Provider()
2458 Http2Stream::Provider::Stream::Stream(int options) in Stream()
2459 : Http2Stream::Provider(options) { in Stream()
2460 provider_.read_callback = Http2Stream::Provider::Stream::OnRead; in Stream()
2463 Http2Stream::Provider::Stream::Stream(Http2Stream* stream, int options) in Stream()
2464 : Http2Stream::Provider(stream, options) { in Stream()
2465 provider_.read_callback = Http2Stream::Provider::Stream::OnRead; in Stream()
2468 ssize_t Http2Stream::Provider::Stream::OnRead(nghttp2_session* handle, in OnRead()
2477 BaseObjectPtr<Http2Stream> stream = session->FindStream(id); in OnRead()
2533 void Http2Stream::IncrementAvailableOutboundLength(size_t amount) { in IncrementAvailableOutboundLength()
2538 void Http2Stream::DecrementAvailableOutboundLength(size_t amount) { in DecrementAvailableOutboundLength()
2697 Http2Stream* stream = in Request()
2773 void Http2Stream::RstStream(const FunctionCallbackInfo<Value>& args) { in RstStream()
2776 Http2Stream* stream; in RstStream()
2785 void Http2Stream::Respond(const FunctionCallbackInfo<Value>& args) { in Respond()
2787 Http2Stream* stream; in Respond()
2802 void Http2Stream::Info(const FunctionCallbackInfo<Value>& args) { in Info()
2804 Http2Stream* stream; in Info()
2813 void Http2Stream::Trailers(const FunctionCallbackInfo<Value>& args) { in Trailers()
2815 Http2Stream* stream; in Trailers()
2825 void Http2Stream::GetID(const FunctionCallbackInfo<Value>& args) { in GetID()
2826 Http2Stream* stream; in GetID()
2832 void Http2Stream::Destroy(const FunctionCallbackInfo<Value>& args) { in Destroy()
2833 Http2Stream* stream; in Destroy()
2840 void Http2Stream::PushPromise(const FunctionCallbackInfo<Value>& args) { in PushPromise()
2842 Http2Stream* parent; in PushPromise()
2851 Http2Stream* stream = in PushPromise()
2866 void Http2Stream::Priority(const FunctionCallbackInfo<Value>& args) { in Priority()
2868 Http2Stream* stream; in Priority()
2880 void Http2Stream::RefreshState(const FunctionCallbackInfo<Value>& args) { in RefreshState()
2881 Http2Stream* stream; in RefreshState()
3239 SetProtoMethod(isolate, stream, "id", Http2Stream::GetID); in Initialize()
3240 SetProtoMethod(isolate, stream, "destroy", Http2Stream::Destroy); in Initialize()
3241 SetProtoMethod(isolate, stream, "priority", Http2Stream::Priority); in Initialize()
3242 SetProtoMethod(isolate, stream, "pushPromise", Http2Stream::PushPromise); in Initialize()
3243 SetProtoMethod(isolate, stream, "info", Http2Stream::Info); in Initialize()
3244 SetProtoMethod(isolate, stream, "trailers", Http2Stream::Trailers); in Initialize()
3245 SetProtoMethod(isolate, stream, "respond", Http2Stream::Respond); in Initialize()
3246 SetProtoMethod(isolate, stream, "rstStream", Http2Stream::RstStream); in Initialize()
3247 SetProtoMethod(isolate, stream, "refreshState", Http2Stream::RefreshState); in Initialize()