1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
110
111
112
113
114
115
116
117
118
119
120
121
122
123
124
125
126
127
128
129
130
131
132
133
134
135
136
137
138
139
140
141
142
143
144
145
146
147
|
/** @file
A brief file description
@section license License
Licensed to the Apache Software Foundation (ASF) under one
or more contributor license agreements. See the NOTICE file
distributed with this work for additional information
regarding copyright ownership. The ASF licenses this file
to you under the Apache License, Version 2.0 (the
"License"); you may not use this file except in compliance
with the License. You may obtain a copy of the License at
http://www.apache.org/licenses/LICENSE-2.0
Unless required by applicable law or agreed to in writing, software
distributed under the License is distributed on an "AS IS" BASIS,
WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
See the License for the specific language governing permissions and
limitations under the License.
*/
#pragma once
#include "I_VConnection.h"
#include "ProxyTransaction.h"
#include "quic/QUICStreamVCAdapter.h"
#include "Http3FrameDispatcher.h"
#include "Http3FrameCollector.h"
class QUICStreamIO;
class HQSession;
class Http09Session;
class Http3Session;
class Http3HeaderFramer;
class Http3DataFramer;
class Http3HeaderVIOAdaptor;
class Http3StreamDataVIOAdaptor;
class HQTransaction : public ProxyTransaction
{
public:
using super = ProxyTransaction;
HQTransaction(HQSession *session, QUICStreamVCAdapter::IOInfo &info);
virtual ~HQTransaction();
// Implement ProxyClienTransaction interface
void set_active_timeout(ink_hrtime timeout_in) override;
void set_inactivity_timeout(ink_hrtime timeout_in) override;
void cancel_inactivity_timeout() override;
void transaction_done() override;
void release() override;
int get_transaction_id() const override;
void increment_transactions_stat() override;
void decrement_transactions_stat() override;
// VConnection interface
virtual VIO *do_io_read(Continuation *c, int64_t nbytes = INT64_MAX, MIOBuffer *buf = 0) override;
virtual VIO *do_io_write(Continuation *c = nullptr, int64_t nbytes = INT64_MAX, IOBufferReader *buf = 0,
bool owner = false) override;
virtual void do_io_close(int lerrno = -1) override;
virtual void do_io_shutdown(ShutdownHowTo_t) override;
virtual void reenable(VIO *) override;
// HQTransaction
virtual int state_stream_open(int, void *) = 0;
virtual int state_stream_closed(int event, void *data) = 0;
NetVConnectionContext_t direction() const;
protected:
virtual int64_t _process_read_vio() = 0;
virtual int64_t _process_write_vio() = 0;
Event *_send_tracked_event(Event *, int, VIO *);
void _signal_read_event();
void _signal_write_event();
EThread *_thread = nullptr;
Event *_cross_thread_event = nullptr;
MIOBuffer _read_vio_buf = CLIENT_CONNECTION_FIRST_READ_BUFFER_SIZE_INDEX;
QUICStreamVCAdapter::IOInfo &_info;
VIO _read_vio;
VIO _write_vio;
Event *_read_event = nullptr;
Event *_write_event = nullptr;
};
class Http3Transaction : public HQTransaction
{
public:
using super = HQTransaction;
Http3Transaction(Http3Session *session, QUICStreamVCAdapter::IOInfo &info);
~Http3Transaction();
int state_stream_open(int event, void *data) override;
int state_stream_closed(int event, void *data) override;
void do_io_close(int lerrno = -1) override;
bool is_response_header_sent() const;
bool is_response_body_sent() const;
// TODO: Just a place holder for now
bool has_request_body(int64_t content_length, bool is_chunked_set) const override;
private:
int64_t _process_read_vio() override;
int64_t _process_write_vio() override;
// These are for HTTP/3
Http3FrameDispatcher _frame_dispatcher;
Http3FrameCollector _frame_collector;
Http3FrameGenerator *_header_framer = nullptr;
Http3FrameGenerator *_data_framer = nullptr;
Http3HeaderVIOAdaptor *_header_handler = nullptr;
Http3StreamDataVIOAdaptor *_data_handler = nullptr;
};
/**
Only for interop. Will be removed.
*/
class Http09Transaction : public HQTransaction
{
public:
using super = HQTransaction;
Http09Transaction(Http09Session *session, QUICStreamVCAdapter::IOInfo &info);
~Http09Transaction();
int state_stream_open(int event, void *data) override;
int state_stream_closed(int event, void *data) override;
void do_io_close(int lerrno = -1) override;
private:
int64_t _process_read_vio() override;
int64_t _process_write_vio() override;
// These are for HTTP/0.9
bool _protocol_detected = false;
bool _legacy_request = false;
bool _client_req_header_complete = false;
};
|
