1 /*
2  * nghttp2 - HTTP/2 C Library
3  *
4  * Copyright (c) 2012 Tatsuhiro Tsujikawa
5  *
6  * Permission is hereby granted, free of charge, to any person obtaining
7  * a copy of this software and associated documentation files (the
8  * "Software"), to deal in the Software without restriction, including
9  * without limitation the rights to use, copy, modify, merge, publish,
10  * distribute, sublicense, and/or sell copies of the Software, and to
11  * permit persons to whom the Software is furnished to do so, subject to
12  * the following conditions:
13  *
14  * The above copyright notice and this permission notice shall be
15  * included in all copies or substantial portions of the Software.
16  *
17  * THE SOFTWARE IS PROVIDED "AS IS", WITHOUT WARRANTY OF ANY KIND,
18  * EXPRESS OR IMPLIED, INCLUDING BUT NOT LIMITED TO THE WARRANTIES OF
19  * MERCHANTABILITY, FITNESS FOR A PARTICULAR PURPOSE AND
20  * NONINFRINGEMENT. IN NO EVENT SHALL THE AUTHORS OR COPYRIGHT HOLDERS BE
21  * LIABLE FOR ANY CLAIM, DAMAGES OR OTHER LIABILITY, WHETHER IN AN ACTION
22  * OF CONTRACT, TORT OR OTHERWISE, ARISING FROM, OUT OF OR IN CONNECTION
23  * WITH THE SOFTWARE OR THE USE OR OTHER DEALINGS IN THE SOFTWARE.
24  */
25 #ifndef SHRPX_HTTP2_DOWNSTREAM_CONNECTION_H
26 #define SHRPX_HTTP2_DOWNSTREAM_CONNECTION_H
27 
28 #include "shrpx.h"
29 
30 #include <openssl/ssl.h>
31 
32 #include <nghttp2/nghttp2.h>
33 
34 #include "shrpx_downstream_connection.h"
35 
36 namespace shrpx {
37 
38 struct StreamData;
39 class Http2Session;
40 class DownstreamConnectionPool;
41 
42 class Http2DownstreamConnection : public DownstreamConnection {
43 public:
44   Http2DownstreamConnection(Http2Session *http2session);
45   virtual ~Http2DownstreamConnection();
46   virtual int attach_downstream(Downstream *downstream);
47   virtual void detach_downstream(Downstream *downstream);
48 
49   virtual int push_request_headers();
50   virtual int push_upload_data_chunk(const uint8_t *data, size_t datalen);
51   virtual int end_upload_data();
52 
pause_read(IOCtrlReason reason)53   virtual void pause_read(IOCtrlReason reason) {}
54   virtual int resume_read(IOCtrlReason reason, size_t consumed);
force_resume_read()55   virtual void force_resume_read() {}
56 
57   virtual int on_read();
58   virtual int on_write();
59   virtual int on_timeout();
60 
on_upstream_change(Upstream * upstream)61   virtual void on_upstream_change(Upstream *upstream) {}
62 
63   // This object is not poolable because we dont' have facility to
64   // migrate to another Http2Session object.
poolable()65   virtual bool poolable() const { return false; }
66 
67   virtual const std::shared_ptr<DownstreamAddrGroup> &
68   get_downstream_addr_group() const;
69   virtual DownstreamAddr *get_addr() const;
70 
71   int send();
72 
73   void attach_stream_data(StreamData *sd);
74   StreamData *detach_stream_data();
75 
76   int submit_rst_stream(Downstream *downstream,
77                         uint32_t error_code = NGHTTP2_INTERNAL_ERROR);
78 
79   Http2DownstreamConnection *dlnext, *dlprev;
80 
81 private:
82   Http2Session *http2session_;
83   StreamData *sd_;
84 };
85 
86 } // namespace shrpx
87 
88 #endif // SHRPX_HTTP2_DOWNSTREAM_CONNECTION_H
89