12c593315Sopenharmony_ci/* 22c593315Sopenharmony_ci * nghttp2 - HTTP/2 C Library 32c593315Sopenharmony_ci * 42c593315Sopenharmony_ci * Copyright (c) 2012 Tatsuhiro Tsujikawa 52c593315Sopenharmony_ci * 62c593315Sopenharmony_ci * Permission is hereby granted, free of charge, to any person obtaining 72c593315Sopenharmony_ci * a copy of this software and associated documentation files (the 82c593315Sopenharmony_ci * "Software"), to deal in the Software without restriction, including 92c593315Sopenharmony_ci * without limitation the rights to use, copy, modify, merge, publish, 102c593315Sopenharmony_ci * distribute, sublicense, and/or sell copies of the Software, and to 112c593315Sopenharmony_ci * permit persons to whom the Software is furnished to do so, subject to 122c593315Sopenharmony_ci * the following conditions: 132c593315Sopenharmony_ci * 142c593315Sopenharmony_ci * The above copyright notice and this permission notice shall be 152c593315Sopenharmony_ci * included in all copies or substantial portions of the Software. 162c593315Sopenharmony_ci * 172c593315Sopenharmony_ci * THE SOFTWARE IS PROVIDED "AS IS", WITHOUT WARRANTY OF ANY KIND, 182c593315Sopenharmony_ci * EXPRESS OR IMPLIED, INCLUDING BUT NOT LIMITED TO THE WARRANTIES OF 192c593315Sopenharmony_ci * MERCHANTABILITY, FITNESS FOR A PARTICULAR PURPOSE AND 202c593315Sopenharmony_ci * NONINFRINGEMENT. IN NO EVENT SHALL THE AUTHORS OR COPYRIGHT HOLDERS BE 212c593315Sopenharmony_ci * LIABLE FOR ANY CLAIM, DAMAGES OR OTHER LIABILITY, WHETHER IN AN ACTION 222c593315Sopenharmony_ci * OF CONTRACT, TORT OR OTHERWISE, ARISING FROM, OUT OF OR IN CONNECTION 232c593315Sopenharmony_ci * WITH THE SOFTWARE OR THE USE OR OTHER DEALINGS IN THE SOFTWARE. 242c593315Sopenharmony_ci */ 252c593315Sopenharmony_ci#ifndef SHRPX_HTTP2_DOWNSTREAM_CONNECTION_H 262c593315Sopenharmony_ci#define SHRPX_HTTP2_DOWNSTREAM_CONNECTION_H 272c593315Sopenharmony_ci 282c593315Sopenharmony_ci#include "shrpx.h" 292c593315Sopenharmony_ci 302c593315Sopenharmony_ci#include <openssl/ssl.h> 312c593315Sopenharmony_ci 322c593315Sopenharmony_ci#include <nghttp2/nghttp2.h> 332c593315Sopenharmony_ci 342c593315Sopenharmony_ci#include "shrpx_downstream_connection.h" 352c593315Sopenharmony_ci 362c593315Sopenharmony_cinamespace shrpx { 372c593315Sopenharmony_ci 382c593315Sopenharmony_cistruct StreamData; 392c593315Sopenharmony_ciclass Http2Session; 402c593315Sopenharmony_ciclass DownstreamConnectionPool; 412c593315Sopenharmony_ci 422c593315Sopenharmony_ciclass Http2DownstreamConnection : public DownstreamConnection { 432c593315Sopenharmony_cipublic: 442c593315Sopenharmony_ci Http2DownstreamConnection(Http2Session *http2session); 452c593315Sopenharmony_ci virtual ~Http2DownstreamConnection(); 462c593315Sopenharmony_ci virtual int attach_downstream(Downstream *downstream); 472c593315Sopenharmony_ci virtual void detach_downstream(Downstream *downstream); 482c593315Sopenharmony_ci 492c593315Sopenharmony_ci virtual int push_request_headers(); 502c593315Sopenharmony_ci virtual int push_upload_data_chunk(const uint8_t *data, size_t datalen); 512c593315Sopenharmony_ci virtual int end_upload_data(); 522c593315Sopenharmony_ci 532c593315Sopenharmony_ci virtual void pause_read(IOCtrlReason reason) {} 542c593315Sopenharmony_ci virtual int resume_read(IOCtrlReason reason, size_t consumed); 552c593315Sopenharmony_ci virtual void force_resume_read() {} 562c593315Sopenharmony_ci 572c593315Sopenharmony_ci virtual int on_read(); 582c593315Sopenharmony_ci virtual int on_write(); 592c593315Sopenharmony_ci virtual int on_timeout(); 602c593315Sopenharmony_ci 612c593315Sopenharmony_ci virtual void on_upstream_change(Upstream *upstream) {} 622c593315Sopenharmony_ci 632c593315Sopenharmony_ci // This object is not poolable because we don't have facility to 642c593315Sopenharmony_ci // migrate to another Http2Session object. 652c593315Sopenharmony_ci virtual bool poolable() const { return false; } 662c593315Sopenharmony_ci 672c593315Sopenharmony_ci virtual const std::shared_ptr<DownstreamAddrGroup> & 682c593315Sopenharmony_ci get_downstream_addr_group() const; 692c593315Sopenharmony_ci virtual DownstreamAddr *get_addr() const; 702c593315Sopenharmony_ci 712c593315Sopenharmony_ci int send(); 722c593315Sopenharmony_ci 732c593315Sopenharmony_ci void attach_stream_data(StreamData *sd); 742c593315Sopenharmony_ci StreamData *detach_stream_data(); 752c593315Sopenharmony_ci 762c593315Sopenharmony_ci int submit_rst_stream(Downstream *downstream, 772c593315Sopenharmony_ci uint32_t error_code = NGHTTP2_INTERNAL_ERROR); 782c593315Sopenharmony_ci 792c593315Sopenharmony_ci Http2DownstreamConnection *dlnext, *dlprev; 802c593315Sopenharmony_ci 812c593315Sopenharmony_ciprivate: 822c593315Sopenharmony_ci Http2Session *http2session_; 832c593315Sopenharmony_ci StreamData *sd_; 842c593315Sopenharmony_ci}; 852c593315Sopenharmony_ci 862c593315Sopenharmony_ci} // namespace shrpx 872c593315Sopenharmony_ci 882c593315Sopenharmony_ci#endif // SHRPX_HTTP2_DOWNSTREAM_CONNECTION_H 89