262 lines
8.0 KiB
C
262 lines
8.0 KiB
C
/*
|
|
* Copyright (C) Nginx, Inc.
|
|
* Copyright (C) Valentin V. Bartenev
|
|
*/
|
|
|
|
|
|
#ifndef _NGX_HTTP_SPDY_H_INCLUDED_
|
|
#define _NGX_HTTP_SPDY_H_INCLUDED_
|
|
|
|
|
|
#include <ngx_config.h>
|
|
#include <ngx_core.h>
|
|
#include <ngx_http.h>
|
|
|
|
#include <zlib.h>
|
|
|
|
|
|
#define NGX_SPDY_VERSION 3
|
|
|
|
#define NGX_SPDY_NPN_ADVERTISE "\x08spdy/3.1"
|
|
#define NGX_SPDY_NPN_NEGOTIATED "spdy/3.1"
|
|
|
|
#define NGX_SPDY_STATE_BUFFER_SIZE 16
|
|
|
|
#define NGX_SPDY_CTL_BIT 1
|
|
|
|
#define NGX_SPDY_SYN_STREAM 1
|
|
#define NGX_SPDY_SYN_REPLY 2
|
|
#define NGX_SPDY_RST_STREAM 3
|
|
#define NGX_SPDY_SETTINGS 4
|
|
#define NGX_SPDY_PING 6
|
|
#define NGX_SPDY_GOAWAY 7
|
|
#define NGX_SPDY_HEADERS 8
|
|
#define NGX_SPDY_WINDOW_UPDATE 9
|
|
|
|
#define NGX_SPDY_FRAME_HEADER_SIZE 8
|
|
|
|
#define NGX_SPDY_SID_SIZE 4
|
|
#define NGX_SPDY_DELTA_SIZE 4
|
|
|
|
#define NGX_SPDY_SYN_STREAM_SIZE 10
|
|
#define NGX_SPDY_SYN_REPLY_SIZE 4
|
|
#define NGX_SPDY_RST_STREAM_SIZE 8
|
|
#define NGX_SPDY_PING_SIZE 4
|
|
#define NGX_SPDY_GOAWAY_SIZE 8
|
|
#define NGX_SPDY_WINDOW_UPDATE_SIZE 8
|
|
#define NGX_SPDY_NV_NUM_SIZE 4
|
|
#define NGX_SPDY_NV_NLEN_SIZE 4
|
|
#define NGX_SPDY_NV_VLEN_SIZE 4
|
|
#define NGX_SPDY_SETTINGS_NUM_SIZE 4
|
|
#define NGX_SPDY_SETTINGS_FID_SIZE 4
|
|
#define NGX_SPDY_SETTINGS_VAL_SIZE 4
|
|
|
|
#define NGX_SPDY_SETTINGS_PAIR_SIZE \
|
|
(NGX_SPDY_SETTINGS_FID_SIZE + NGX_SPDY_SETTINGS_VAL_SIZE)
|
|
|
|
#define NGX_SPDY_HIGHEST_PRIORITY 0
|
|
#define NGX_SPDY_LOWEST_PRIORITY 7
|
|
|
|
#define NGX_SPDY_FLAG_FIN 0x01
|
|
#define NGX_SPDY_FLAG_UNIDIRECTIONAL 0x02
|
|
#define NGX_SPDY_FLAG_CLEAR_SETTINGS 0x01
|
|
|
|
#define NGX_SPDY_MAX_FRAME_SIZE ((1 << 24) - 1)
|
|
|
|
#define NGX_SPDY_DATA_DISCARD 1
|
|
#define NGX_SPDY_DATA_ERROR 2
|
|
#define NGX_SPDY_DATA_INTERNAL_ERROR 3
|
|
|
|
|
|
typedef struct ngx_http_spdy_connection_s ngx_http_spdy_connection_t;
|
|
typedef struct ngx_http_spdy_out_frame_s ngx_http_spdy_out_frame_t;
|
|
|
|
|
|
typedef u_char *(*ngx_http_spdy_handler_pt) (ngx_http_spdy_connection_t *sc,
|
|
u_char *pos, u_char *end);
|
|
|
|
struct ngx_http_spdy_connection_s {
|
|
ngx_connection_t *connection;
|
|
ngx_http_connection_t *http_connection;
|
|
|
|
ngx_uint_t processing;
|
|
|
|
size_t send_window;
|
|
size_t recv_window;
|
|
size_t init_window;
|
|
|
|
ngx_queue_t waiting;
|
|
|
|
u_char buffer[NGX_SPDY_STATE_BUFFER_SIZE];
|
|
size_t buffer_used;
|
|
ngx_http_spdy_handler_pt handler;
|
|
|
|
z_stream zstream_in;
|
|
z_stream zstream_out;
|
|
|
|
ngx_pool_t *pool;
|
|
|
|
ngx_http_spdy_out_frame_t *free_ctl_frames;
|
|
ngx_connection_t *free_fake_connections;
|
|
|
|
ngx_http_spdy_stream_t **streams_index;
|
|
|
|
ngx_http_spdy_out_frame_t *last_out;
|
|
|
|
ngx_queue_t posted;
|
|
|
|
ngx_http_spdy_stream_t *stream;
|
|
|
|
ngx_uint_t entries;
|
|
size_t length;
|
|
u_char flags;
|
|
|
|
ngx_uint_t last_sid;
|
|
|
|
unsigned blocked:1;
|
|
unsigned incomplete:1;
|
|
};
|
|
|
|
|
|
struct ngx_http_spdy_stream_s {
|
|
ngx_uint_t id;
|
|
ngx_http_request_t *request;
|
|
ngx_http_spdy_connection_t *connection;
|
|
ngx_http_spdy_stream_t *index;
|
|
|
|
ngx_uint_t header_buffers;
|
|
ngx_uint_t queued;
|
|
|
|
/*
|
|
* A change to SETTINGS_INITIAL_WINDOW_SIZE could cause the
|
|
* send_window to become negative, hence it's signed.
|
|
*/
|
|
ssize_t send_window;
|
|
size_t recv_window;
|
|
|
|
ngx_http_spdy_out_frame_t *free_frames;
|
|
ngx_chain_t *free_data_headers;
|
|
ngx_chain_t *free_bufs;
|
|
|
|
ngx_queue_t queue;
|
|
|
|
unsigned priority:3;
|
|
unsigned handled:1;
|
|
unsigned blocked:1;
|
|
unsigned exhausted:1;
|
|
unsigned in_closed:1;
|
|
unsigned out_closed:1;
|
|
unsigned skip_data:2;
|
|
};
|
|
|
|
|
|
struct ngx_http_spdy_out_frame_s {
|
|
ngx_http_spdy_out_frame_t *next;
|
|
ngx_chain_t *first;
|
|
ngx_chain_t *last;
|
|
ngx_int_t (*handler)(ngx_http_spdy_connection_t *sc,
|
|
ngx_http_spdy_out_frame_t *frame);
|
|
|
|
ngx_http_spdy_stream_t *stream;
|
|
size_t length;
|
|
|
|
ngx_uint_t priority;
|
|
unsigned blocked:1;
|
|
unsigned fin:1;
|
|
};
|
|
|
|
|
|
static ngx_inline void
|
|
ngx_http_spdy_queue_frame(ngx_http_spdy_connection_t *sc,
|
|
ngx_http_spdy_out_frame_t *frame)
|
|
{
|
|
ngx_http_spdy_out_frame_t **out;
|
|
|
|
for (out = &sc->last_out; *out; out = &(*out)->next)
|
|
{
|
|
/*
|
|
* NB: higher values represent lower priorities.
|
|
*/
|
|
if (frame->priority >= (*out)->priority) {
|
|
break;
|
|
}
|
|
}
|
|
|
|
frame->next = *out;
|
|
*out = frame;
|
|
}
|
|
|
|
|
|
static ngx_inline void
|
|
ngx_http_spdy_queue_blocked_frame(ngx_http_spdy_connection_t *sc,
|
|
ngx_http_spdy_out_frame_t *frame)
|
|
{
|
|
ngx_http_spdy_out_frame_t **out;
|
|
|
|
for (out = &sc->last_out; *out; out = &(*out)->next)
|
|
{
|
|
if ((*out)->blocked) {
|
|
break;
|
|
}
|
|
}
|
|
|
|
frame->next = *out;
|
|
*out = frame;
|
|
}
|
|
|
|
|
|
void ngx_http_spdy_init(ngx_event_t *rev);
|
|
void ngx_http_spdy_request_headers_init(void);
|
|
|
|
ngx_int_t ngx_http_spdy_read_request_body(ngx_http_request_t *r,
|
|
ngx_http_client_body_handler_pt post_handler);
|
|
|
|
void ngx_http_spdy_close_stream(ngx_http_spdy_stream_t *stream, ngx_int_t rc);
|
|
|
|
ngx_int_t ngx_http_spdy_send_output_queue(ngx_http_spdy_connection_t *sc);
|
|
|
|
|
|
#define ngx_spdy_frame_aligned_write_uint16(p, s) \
|
|
(*(uint16_t *) (p) = htons((uint16_t) (s)), (p) + sizeof(uint16_t))
|
|
|
|
#define ngx_spdy_frame_aligned_write_uint32(p, s) \
|
|
(*(uint32_t *) (p) = htonl((uint32_t) (s)), (p) + sizeof(uint32_t))
|
|
|
|
#if (NGX_HAVE_NONALIGNED)
|
|
|
|
#define ngx_spdy_frame_write_uint16 ngx_spdy_frame_aligned_write_uint16
|
|
#define ngx_spdy_frame_write_uint32 ngx_spdy_frame_aligned_write_uint32
|
|
|
|
#else
|
|
|
|
#define ngx_spdy_frame_write_uint16(p, s) \
|
|
((p)[0] = (u_char) ((s) >> 8), \
|
|
(p)[1] = (u_char) (s), \
|
|
(p) + sizeof(uint16_t))
|
|
|
|
#define ngx_spdy_frame_write_uint32(p, s) \
|
|
((p)[0] = (u_char) ((s) >> 24), \
|
|
(p)[1] = (u_char) ((s) >> 16), \
|
|
(p)[2] = (u_char) ((s) >> 8), \
|
|
(p)[3] = (u_char) (s), \
|
|
(p) + sizeof(uint32_t))
|
|
|
|
#endif
|
|
|
|
|
|
#define ngx_spdy_ctl_frame_head(t) \
|
|
((uint32_t) NGX_SPDY_CTL_BIT << 31 | NGX_SPDY_VERSION << 16 | (t))
|
|
|
|
#define ngx_spdy_frame_write_head(p, t) \
|
|
ngx_spdy_frame_aligned_write_uint32(p, ngx_spdy_ctl_frame_head(t))
|
|
|
|
#define ngx_spdy_frame_write_flags_and_len(p, f, l) \
|
|
ngx_spdy_frame_aligned_write_uint32(p, (f) << 24 | (l))
|
|
#define ngx_spdy_frame_write_flags_and_id(p, f, i) \
|
|
ngx_spdy_frame_aligned_write_uint32(p, (f) << 24 | (i))
|
|
|
|
#define ngx_spdy_frame_write_sid ngx_spdy_frame_aligned_write_uint32
|
|
#define ngx_spdy_frame_write_window ngx_spdy_frame_aligned_write_uint32
|
|
|
|
#endif /* _NGX_HTTP_SPDY_H_INCLUDED_ */
|