xref: /third_party/node/src/node_http2_state.h (revision 1cb0ef41) 
1#ifndef SRC_NODE_HTTP2_STATE_H_
2#define SRC_NODE_HTTP2_STATE_H_
3
4#if defined(NODE_WANT_INTERNALS) && NODE_WANT_INTERNALS
5
6#include "aliased_buffer.h"
7
8struct nghttp2_rcbuf;
9
10namespace node {
11namespace http2 {
12
13  enum Http2SettingsIndex {
14    IDX_SETTINGS_HEADER_TABLE_SIZE,
15    IDX_SETTINGS_ENABLE_PUSH,
16    IDX_SETTINGS_INITIAL_WINDOW_SIZE,
17    IDX_SETTINGS_MAX_FRAME_SIZE,
18    IDX_SETTINGS_MAX_CONCURRENT_STREAMS,
19    IDX_SETTINGS_MAX_HEADER_LIST_SIZE,
20    IDX_SETTINGS_ENABLE_CONNECT_PROTOCOL,
21    IDX_SETTINGS_COUNT
22  };
23
24  enum Http2SessionStateIndex {
25    IDX_SESSION_STATE_EFFECTIVE_LOCAL_WINDOW_SIZE,
26    IDX_SESSION_STATE_EFFECTIVE_RECV_DATA_LENGTH,
27    IDX_SESSION_STATE_NEXT_STREAM_ID,
28    IDX_SESSION_STATE_LOCAL_WINDOW_SIZE,
29    IDX_SESSION_STATE_LAST_PROC_STREAM_ID,
30    IDX_SESSION_STATE_REMOTE_WINDOW_SIZE,
31    IDX_SESSION_STATE_OUTBOUND_QUEUE_SIZE,
32    IDX_SESSION_STATE_HD_DEFLATE_DYNAMIC_TABLE_SIZE,
33    IDX_SESSION_STATE_HD_INFLATE_DYNAMIC_TABLE_SIZE,
34    IDX_SESSION_STATE_COUNT
35  };
36
37  enum Http2StreamStateIndex {
38    IDX_STREAM_STATE,
39    IDX_STREAM_STATE_WEIGHT,
40    IDX_STREAM_STATE_SUM_DEPENDENCY_WEIGHT,
41    IDX_STREAM_STATE_LOCAL_CLOSE,
42    IDX_STREAM_STATE_REMOTE_CLOSE,
43    IDX_STREAM_STATE_LOCAL_WINDOW_SIZE,
44    IDX_STREAM_STATE_COUNT
45  };
46
47  enum Http2OptionsIndex {
48    IDX_OPTIONS_MAX_DEFLATE_DYNAMIC_TABLE_SIZE,
49    IDX_OPTIONS_MAX_RESERVED_REMOTE_STREAMS,
50    IDX_OPTIONS_MAX_SEND_HEADER_BLOCK_LENGTH,
51    IDX_OPTIONS_PEER_MAX_CONCURRENT_STREAMS,
52    IDX_OPTIONS_PADDING_STRATEGY,
53    IDX_OPTIONS_MAX_HEADER_LIST_PAIRS,
54    IDX_OPTIONS_MAX_OUTSTANDING_PINGS,
55    IDX_OPTIONS_MAX_OUTSTANDING_SETTINGS,
56    IDX_OPTIONS_MAX_SESSION_MEMORY,
57    IDX_OPTIONS_MAX_SETTINGS,
58    IDX_OPTIONS_FLAGS
59  };
60
61  enum Http2StreamStatisticsIndex {
62    IDX_STREAM_STATS_ID,
63    IDX_STREAM_STATS_TIMETOFIRSTBYTE,
64    IDX_STREAM_STATS_TIMETOFIRSTHEADER,
65    IDX_STREAM_STATS_TIMETOFIRSTBYTESENT,
66    IDX_STREAM_STATS_SENTBYTES,
67    IDX_STREAM_STATS_RECEIVEDBYTES,
68    IDX_STREAM_STATS_COUNT
69  };
70
71  enum Http2SessionStatisticsIndex {
72    IDX_SESSION_STATS_TYPE,
73    IDX_SESSION_STATS_PINGRTT,
74    IDX_SESSION_STATS_FRAMESRECEIVED,
75    IDX_SESSION_STATS_FRAMESSENT,
76    IDX_SESSION_STATS_STREAMCOUNT,
77    IDX_SESSION_STATS_STREAMAVERAGEDURATION,
78    IDX_SESSION_STATS_DATA_SENT,
79    IDX_SESSION_STATS_DATA_RECEIVED,
80    IDX_SESSION_STATS_MAX_CONCURRENT_STREAMS,
81    IDX_SESSION_STATS_COUNT
82  };
83
84class Http2State : public BaseObject {
85 public:
86  Http2State(Realm* realm, v8::Local<v8::Object> obj)
87      : BaseObject(realm, obj),
88        root_buffer(realm->isolate(), sizeof(http2_state_internal)),
89        session_state_buffer(
90            realm->isolate(),
91            offsetof(http2_state_internal, session_state_buffer),
92            IDX_SESSION_STATE_COUNT,
93            root_buffer),
94        stream_state_buffer(realm->isolate(),
95                            offsetof(http2_state_internal, stream_state_buffer),
96                            IDX_STREAM_STATE_COUNT,
97                            root_buffer),
98        stream_stats_buffer(realm->isolate(),
99                            offsetof(http2_state_internal, stream_stats_buffer),
100                            IDX_STREAM_STATS_COUNT,
101                            root_buffer),
102        session_stats_buffer(
103            realm->isolate(),
104            offsetof(http2_state_internal, session_stats_buffer),
105            IDX_SESSION_STATS_COUNT,
106            root_buffer),
107        options_buffer(realm->isolate(),
108                       offsetof(http2_state_internal, options_buffer),
109                       IDX_OPTIONS_FLAGS + 1,
110                       root_buffer),
111        settings_buffer(realm->isolate(),
112                        offsetof(http2_state_internal, settings_buffer),
113                        IDX_SETTINGS_COUNT + 1,
114                        root_buffer) {}
115
116  AliasedUint8Array root_buffer;
117  AliasedFloat64Array session_state_buffer;
118  AliasedFloat64Array stream_state_buffer;
119  AliasedFloat64Array stream_stats_buffer;
120  AliasedFloat64Array session_stats_buffer;
121  AliasedUint32Array options_buffer;
122  AliasedUint32Array settings_buffer;
123
124  void MemoryInfo(MemoryTracker* tracker) const override;
125  SET_SELF_SIZE(Http2State)
126  SET_MEMORY_INFO_NAME(Http2State)
127
128  SET_BINDING_ID(http2_binding_data)
129
130 private:
131  struct http2_state_internal {
132    // doubles first so that they are always sizeof(double)-aligned
133    double session_state_buffer[IDX_SESSION_STATE_COUNT];
134    double stream_state_buffer[IDX_STREAM_STATE_COUNT];
135    double stream_stats_buffer[IDX_STREAM_STATS_COUNT];
136    double session_stats_buffer[IDX_SESSION_STATS_COUNT];
137    uint32_t options_buffer[IDX_OPTIONS_FLAGS + 1];
138    uint32_t settings_buffer[IDX_SETTINGS_COUNT + 1];
139  };
140};
141
142}  // namespace http2
143}  // namespace node
144
145#endif  // defined(NODE_WANT_INTERNALS) && NODE_WANT_INTERNALS
146
147#endif  // SRC_NODE_HTTP2_STATE_H_
148