nghttpx: Rename Http2Upstream::add_downstream as add_pending_downstream

This commit is contained in:
Tatsuhiro Tsujikawa 2014-08-18 21:38:03 +09:00
parent 83a39f5b49
commit 500c5eea56
2 changed files with 3 additions and 3 deletions

View File

@ -276,7 +276,7 @@ int on_begin_headers_callback(nghttp2_session *session,
frame->hd.stream_id, frame->hd.stream_id,
0); 0);
upstream->add_downstream(downstream); upstream->add_pending_downstream(downstream);
downstream->init_upstream_timer(); downstream->init_upstream_timer();
downstream->reset_upstream_rtimer(); downstream->reset_upstream_rtimer();
downstream->init_response_body_buf(); downstream->init_response_body_buf();
@ -1169,7 +1169,7 @@ bufferevent_event_cb Http2Upstream::get_downstream_eventcb()
return downstream_eventcb; return downstream_eventcb;
} }
void Http2Upstream::add_downstream(Downstream *downstream) void Http2Upstream::add_pending_downstream(Downstream *downstream)
{ {
downstream_queue_.add_pending(downstream); downstream_queue_.add_pending(downstream);
} }

View File

@ -54,7 +54,7 @@ public:
virtual bufferevent_data_cb get_downstream_readcb(); virtual bufferevent_data_cb get_downstream_readcb();
virtual bufferevent_data_cb get_downstream_writecb(); virtual bufferevent_data_cb get_downstream_writecb();
virtual bufferevent_event_cb get_downstream_eventcb(); virtual bufferevent_event_cb get_downstream_eventcb();
void add_downstream(Downstream *downstream); void add_pending_downstream(Downstream *downstream);
void remove_downstream(Downstream *downstream); void remove_downstream(Downstream *downstream);
Downstream* find_downstream(int32_t stream_id); Downstream* find_downstream(int32_t stream_id);