nghttp2/lib/nghttp2_submit.c

545 lines
15 KiB
C
Raw Normal View History

2013-07-12 17:19:03 +02:00
/*
2014-03-30 12:09:21 +02:00
* nghttp2 - HTTP/2 C Library
2013-07-12 17:19:03 +02:00
*
* Copyright (c) 2012, 2013 Tatsuhiro Tsujikawa
2013-07-12 17:19:03 +02:00
*
* Permission is hereby granted, free of charge, to any person obtaining
* a copy of this software and associated documentation files (the
* "Software"), to deal in the Software without restriction, including
* without limitation the rights to use, copy, modify, merge, publish,
* distribute, sublicense, and/or sell copies of the Software, and to
* permit persons to whom the Software is furnished to do so, subject to
* the following conditions:
*
* The above copyright notice and this permission notice shall be
* included in all copies or substantial portions of the Software.
*
* THE SOFTWARE IS PROVIDED "AS IS", WITHOUT WARRANTY OF ANY KIND,
* EXPRESS OR IMPLIED, INCLUDING BUT NOT LIMITED TO THE WARRANTIES OF
* MERCHANTABILITY, FITNESS FOR A PARTICULAR PURPOSE AND
* NONINFRINGEMENT. IN NO EVENT SHALL THE AUTHORS OR COPYRIGHT HOLDERS BE
* LIABLE FOR ANY CLAIM, DAMAGES OR OTHER LIABILITY, WHETHER IN AN ACTION
* OF CONTRACT, TORT OR OTHERWISE, ARISING FROM, OUT OF OR IN CONNECTION
* WITH THE SOFTWARE OR THE USE OR OTHER DEALINGS IN THE SOFTWARE.
*/
#include "nghttp2_submit.h"
#include <string.h>
#include <assert.h>
2013-07-12 17:19:03 +02:00
#include "nghttp2_session.h"
#include "nghttp2_frame.h"
#include "nghttp2_helper.h"
2014-03-25 18:04:24 +01:00
#include "nghttp2_priority_spec.h"
2013-07-12 17:19:03 +02:00
/* This function takes ownership of |nva_copy|. Regardless of the
return value, the caller must not free |nva_copy| after this
function returns. */
2014-11-27 15:39:04 +01:00
static int32_t submit_headers_shared(nghttp2_session *session, uint8_t flags,
int32_t stream_id,
const nghttp2_priority_spec *pri_spec,
nghttp2_nv *nva_copy, size_t nvlen,
const nghttp2_data_provider *data_prd,
void *stream_user_data,
uint8_t attach_stream) {
int rv;
2013-07-12 17:19:03 +02:00
uint8_t flags_copy;
nghttp2_outbound_item *item = NULL;
nghttp2_frame *frame = NULL;
nghttp2_headers_category hcat;
2014-03-25 18:04:24 +01:00
2014-11-27 15:39:04 +01:00
if (stream_id == 0) {
rv = NGHTTP2_ERR_INVALID_ARGUMENT;
goto fail;
}
item = malloc(sizeof(nghttp2_outbound_item));
2014-11-27 15:39:04 +01:00
if (item == NULL) {
rv = NGHTTP2_ERR_NOMEM;
goto fail;
2013-07-12 17:19:03 +02:00
}
nghttp2_session_outbound_item_init(session, item);
2014-11-27 15:39:04 +01:00
if (data_prd != NULL && data_prd->read_callback != NULL) {
item->aux_data.headers.data_prd = *data_prd;
2013-07-12 17:19:03 +02:00
}
2014-03-25 18:04:24 +01:00
item->aux_data.headers.stream_user_data = stream_user_data;
item->aux_data.headers.attach_stream = attach_stream;
2014-11-27 15:39:04 +01:00
flags_copy = (flags & (NGHTTP2_FLAG_END_STREAM | NGHTTP2_FLAG_PRIORITY)) |
NGHTTP2_FLAG_END_HEADERS;
2013-07-15 14:45:59 +02:00
2014-11-27 15:39:04 +01:00
if (stream_id == -1) {
if (session->next_stream_id > INT32_MAX) {
rv = NGHTTP2_ERR_STREAM_ID_NOT_AVAILABLE;
goto fail;
}
stream_id = session->next_stream_id;
session->next_stream_id += 2;
hcat = NGHTTP2_HCAT_REQUEST;
} else {
/* More specific categorization will be done later. */
hcat = NGHTTP2_HCAT_HEADERS;
}
frame = &item->frame;
2014-11-27 15:39:04 +01:00
nghttp2_frame_headers_init(&frame->headers, flags_copy, stream_id, hcat,
pri_spec, nva_copy, nvlen);
rv = nghttp2_session_add_item(session, item);
2014-03-25 18:04:24 +01:00
2014-11-27 15:39:04 +01:00
if (rv != 0) {
2013-07-15 14:45:59 +02:00
nghttp2_frame_headers_free(&frame->headers);
goto fail2;
2013-07-12 17:19:03 +02:00
}
2014-11-27 15:39:04 +01:00
if (hcat == NGHTTP2_HCAT_REQUEST) {
return stream_id;
}
return 0;
2014-11-27 15:39:04 +01:00
fail:
/* nghttp2_frame_headers_init() takes ownership of nva_copy. */
nghttp2_nv_array_del(nva_copy);
2014-11-27 15:39:04 +01:00
fail2:
free(item);
return rv;
}
2014-11-27 15:39:04 +01:00
static void adjust_priority_spec_weight(nghttp2_priority_spec *pri_spec) {
if (pri_spec->weight < NGHTTP2_MIN_WEIGHT) {
pri_spec->weight = NGHTTP2_MIN_WEIGHT;
2014-11-27 15:39:04 +01:00
} else if (pri_spec->weight > NGHTTP2_MAX_WEIGHT) {
pri_spec->weight = NGHTTP2_MAX_WEIGHT;
}
}
2014-11-27 15:39:04 +01:00
static int32_t submit_headers_shared_nva(nghttp2_session *session,
uint8_t flags, int32_t stream_id,
const nghttp2_priority_spec *pri_spec,
const nghttp2_nv *nva, size_t nvlen,
const nghttp2_data_provider *data_prd,
void *stream_user_data,
uint8_t attach_stream) {
int rv;
nghttp2_nv *nva_copy;
nghttp2_priority_spec copy_pri_spec;
2014-03-25 18:04:24 +01:00
2014-11-27 15:39:04 +01:00
if (pri_spec) {
copy_pri_spec = *pri_spec;
adjust_priority_spec_weight(&copy_pri_spec);
} else {
nghttp2_priority_spec_default_init(&copy_pri_spec);
2014-03-25 18:04:24 +01:00
}
rv = nghttp2_nv_array_copy(&nva_copy, nva, nvlen);
2014-11-27 15:39:04 +01:00
if (rv < 0) {
return rv;
}
2014-11-27 15:39:04 +01:00
return submit_headers_shared(session, flags, stream_id, &copy_pri_spec,
nva_copy, nvlen, data_prd, stream_user_data,
attach_stream);
2013-07-12 17:19:03 +02:00
}
int32_t nghttp2_submit_headers(nghttp2_session *session, uint8_t flags,
int32_t stream_id,
const nghttp2_priority_spec *pri_spec,
const nghttp2_nv *nva, size_t nvlen,
2014-11-27 15:39:04 +01:00
void *stream_user_data) {
2014-03-25 18:04:24 +01:00
flags &= NGHTTP2_FLAG_END_STREAM;
2014-11-27 15:39:04 +01:00
if (pri_spec && !nghttp2_priority_spec_check_default(pri_spec)) {
flags |= NGHTTP2_FLAG_PRIORITY;
} else {
pri_spec = NULL;
2014-03-25 18:04:24 +01:00
}
2014-11-27 15:39:04 +01:00
return submit_headers_shared_nva(session, flags, stream_id, pri_spec, nva,
nvlen, NULL, stream_user_data, 0);
2013-07-12 17:19:03 +02:00
}
int nghttp2_submit_ping(nghttp2_session *session, uint8_t flags _U_,
2014-11-27 15:39:04 +01:00
const uint8_t *opaque_data) {
2013-07-15 14:45:59 +02:00
return nghttp2_session_add_ping(session, NGHTTP2_FLAG_NONE, opaque_data);
2013-07-12 17:19:03 +02:00
}
int nghttp2_submit_priority(nghttp2_session *session, uint8_t flags _U_,
2014-03-25 18:04:24 +01:00
int32_t stream_id,
2014-11-27 15:39:04 +01:00
const nghttp2_priority_spec *pri_spec) {
2014-02-18 16:45:20 +01:00
int rv;
nghttp2_outbound_item *item;
nghttp2_frame *frame;
nghttp2_priority_spec copy_pri_spec;
2014-03-25 18:04:24 +01:00
2014-11-27 15:39:04 +01:00
if (stream_id == 0 || pri_spec == NULL) {
return NGHTTP2_ERR_INVALID_ARGUMENT;
}
2014-03-25 18:04:24 +01:00
2014-11-27 15:39:04 +01:00
if (stream_id == pri_spec->stream_id) {
2014-03-25 18:04:24 +01:00
return NGHTTP2_ERR_INVALID_ARGUMENT;
}
copy_pri_spec = *pri_spec;
adjust_priority_spec_weight(&copy_pri_spec);
item = malloc(sizeof(nghttp2_outbound_item));
2014-03-25 18:04:24 +01:00
2014-11-27 15:39:04 +01:00
if (item == NULL) {
return NGHTTP2_ERR_NOMEM;
}
2014-03-25 18:04:24 +01:00
nghttp2_session_outbound_item_init(session, item);
frame = &item->frame;
nghttp2_frame_priority_init(&frame->priority, stream_id, &copy_pri_spec);
2014-03-25 18:04:24 +01:00
rv = nghttp2_session_add_item(session, item);
2014-03-25 18:04:24 +01:00
2014-11-27 15:39:04 +01:00
if (rv != 0) {
nghttp2_frame_priority_free(&frame->priority);
free(item);
2014-03-25 18:04:24 +01:00
2014-02-18 16:45:20 +01:00
return rv;
}
2014-03-25 18:04:24 +01:00
return 0;
}
int nghttp2_submit_rst_stream(nghttp2_session *session, uint8_t flags _U_,
2014-11-27 15:39:04 +01:00
int32_t stream_id, uint32_t error_code) {
if (stream_id == 0) {
return NGHTTP2_ERR_INVALID_ARGUMENT;
}
2013-07-15 14:45:59 +02:00
return nghttp2_session_add_rst_stream(session, stream_id, error_code);
2013-07-12 17:19:03 +02:00
}
int nghttp2_submit_goaway(nghttp2_session *session, uint8_t flags _U_,
2014-11-27 15:39:04 +01:00
int32_t last_stream_id, uint32_t error_code,
const uint8_t *opaque_data, size_t opaque_data_len) {
return nghttp2_session_add_goaway(session, last_stream_id, error_code,
opaque_data, opaque_data_len, 0);
2013-07-12 17:19:03 +02:00
}
int nghttp2_submit_settings(nghttp2_session *session, uint8_t flags _U_,
2014-11-27 15:39:04 +01:00
const nghttp2_settings_entry *iv, size_t niv) {
return nghttp2_session_add_settings(session, NGHTTP2_FLAG_NONE, iv, niv);
2013-07-12 17:19:03 +02:00
}
int32_t nghttp2_submit_push_promise(nghttp2_session *session, uint8_t flags _U_,
2014-11-27 15:39:04 +01:00
int32_t stream_id, const nghttp2_nv *nva,
size_t nvlen,
void *promised_stream_user_data) {
nghttp2_outbound_item *item;
2013-07-24 18:49:05 +02:00
nghttp2_frame *frame;
nghttp2_nv *nva_copy;
2013-07-24 18:49:05 +02:00
uint8_t flags_copy;
int32_t promised_stream_id;
int rv;
2013-07-24 18:49:05 +02:00
if (stream_id == 0 || nghttp2_session_is_my_stream_id(session, stream_id)) {
return NGHTTP2_ERR_INVALID_ARGUMENT;
}
2014-11-27 15:39:04 +01:00
if (!session->server) {
return NGHTTP2_ERR_PROTO;
}
/* All 32bit signed stream IDs are spent. */
2014-11-27 15:39:04 +01:00
if (session->next_stream_id > INT32_MAX) {
return NGHTTP2_ERR_STREAM_ID_NOT_AVAILABLE;
}
item = malloc(sizeof(nghttp2_outbound_item));
2014-11-27 15:39:04 +01:00
if (item == NULL) {
2013-07-24 18:49:05 +02:00
return NGHTTP2_ERR_NOMEM;
}
nghttp2_session_outbound_item_init(session, item);
item->aux_data.headers.stream_user_data = promised_stream_user_data;
frame = &item->frame;
rv = nghttp2_nv_array_copy(&nva_copy, nva, nvlen);
2014-11-27 15:39:04 +01:00
if (rv < 0) {
free(item);
return rv;
2013-07-24 18:49:05 +02:00
}
flags_copy = NGHTTP2_FLAG_END_HEADERS;
promised_stream_id = session->next_stream_id;
session->next_stream_id += 2;
2014-11-27 15:39:04 +01:00
nghttp2_frame_push_promise_init(&frame->push_promise, flags_copy, stream_id,
promised_stream_id, nva_copy, nvlen);
rv = nghttp2_session_add_item(session, item);
2014-11-27 15:39:04 +01:00
if (rv != 0) {
2013-07-24 18:49:05 +02:00
nghttp2_frame_push_promise_free(&frame->push_promise);
free(item);
return rv;
2013-07-24 18:49:05 +02:00
}
return promised_stream_id;
2013-07-24 18:49:05 +02:00
}
2013-07-15 14:45:59 +02:00
int nghttp2_submit_window_update(nghttp2_session *session, uint8_t flags,
int32_t stream_id,
2014-11-27 15:39:04 +01:00
int32_t window_size_increment) {
int rv;
nghttp2_stream *stream = 0;
2014-11-27 15:39:04 +01:00
if (window_size_increment == 0) {
return 0;
2013-07-12 17:19:03 +02:00
}
2013-08-18 15:04:09 +02:00
flags = 0;
2014-11-27 15:39:04 +01:00
if (stream_id == 0) {
rv = nghttp2_adjust_local_window_size(
&session->local_window_size, &session->recv_window_size,
&session->recv_reduction, &window_size_increment);
if (rv != 0) {
return rv;
}
2013-07-12 17:19:03 +02:00
} else {
2013-07-15 14:45:59 +02:00
stream = nghttp2_session_get_stream(session, stream_id);
2014-11-27 15:39:04 +01:00
if (!stream) {
return 0;
2013-07-15 14:45:59 +02:00
}
2014-11-27 15:39:04 +01:00
rv = nghttp2_adjust_local_window_size(
&stream->local_window_size, &stream->recv_window_size,
&stream->recv_reduction, &window_size_increment);
if (rv != 0) {
return rv;
}
2013-07-12 17:19:03 +02:00
}
2014-11-27 15:39:04 +01:00
if (window_size_increment > 0) {
if (stream_id == 0) {
session->consumed_size =
2014-11-27 15:39:04 +01:00
nghttp2_max(0, session->consumed_size - window_size_increment);
} else {
stream->consumed_size =
2014-11-27 15:39:04 +01:00
nghttp2_max(0, stream->consumed_size - window_size_increment);
}
return nghttp2_session_add_window_update(session, flags, stream_id,
window_size_increment);
}
return 0;
2013-07-12 17:19:03 +02:00
}
int nghttp2_submit_altsvc(nghttp2_session *session, uint8_t flags _U_,
2014-11-27 15:39:04 +01:00
int32_t stream_id, uint32_t max_age, uint16_t port,
2014-04-01 14:47:51 +02:00
const uint8_t *protocol_id, size_t protocol_id_len,
const uint8_t *host, size_t host_len,
2014-11-27 15:39:04 +01:00
const uint8_t *origin, size_t origin_len) {
2014-04-01 14:47:51 +02:00
int rv;
size_t varlen;
uint8_t *var, *varp;
nghttp2_outbound_item *item;
2014-04-01 14:47:51 +02:00
nghttp2_frame *frame;
nghttp2_ext_altsvc *altsvc;
2014-04-01 14:47:51 +02:00
uint8_t *copy_protocol_id, *copy_host, *copy_origin;
2014-11-27 15:39:04 +01:00
if (!session->server) {
return NGHTTP2_ERR_PROTO;
2014-04-01 14:47:51 +02:00
}
varlen = protocol_id_len + host_len + origin_len;
/* 9 = fixed part 8 bytes + HOST_LEN 1 byte */
2014-11-27 15:39:04 +01:00
if (varlen + 9 > NGHTTP2_MAX_PAYLOADLEN) {
return NGHTTP2_ERR_INVALID_ARGUMENT;
}
altsvc = malloc(sizeof(nghttp2_ext_altsvc));
2014-11-27 15:39:04 +01:00
if (altsvc == NULL) {
rv = NGHTTP2_ERR_NOMEM;
goto fail;
}
2014-11-27 15:39:04 +01:00
if (varlen == 0) {
2014-04-01 14:47:51 +02:00
var = NULL;
copy_protocol_id = NULL;
copy_host = NULL;
copy_origin = NULL;
} else {
var = malloc(varlen);
2014-11-27 15:39:04 +01:00
if (var == NULL) {
rv = NGHTTP2_ERR_NOMEM;
goto var_alloc_fail;
2014-04-01 14:47:51 +02:00
}
varp = var;
memcpy(varp, protocol_id, protocol_id_len);
copy_protocol_id = varp;
varp += protocol_id_len;
memcpy(varp, host, host_len);
copy_host = varp;
varp += host_len;
memcpy(varp, origin, origin_len);
copy_origin = varp;
}
item = malloc(sizeof(nghttp2_outbound_item));
2014-04-01 14:47:51 +02:00
2014-11-27 15:39:04 +01:00
if (item == NULL) {
rv = NGHTTP2_ERR_NOMEM;
2014-04-01 14:47:51 +02:00
goto frame_alloc_fail;
2014-04-01 14:47:51 +02:00
}
nghttp2_session_outbound_item_init(session, item);
frame = &item->frame;
frame->ext.payload = altsvc;
nghttp2_frame_altsvc_init(&frame->ext, stream_id, max_age, port,
2014-11-27 15:39:04 +01:00
copy_protocol_id, protocol_id_len, copy_host,
host_len, copy_origin, origin_len);
2014-04-01 14:47:51 +02:00
rv = nghttp2_session_add_item(session, item);
2014-04-01 14:47:51 +02:00
2014-11-27 15:39:04 +01:00
if (rv != 0) {
nghttp2_frame_altsvc_free(&frame->ext);
free(item);
free(altsvc);
2014-04-01 14:47:51 +02:00
return rv;
}
return 0;
2014-11-27 15:39:04 +01:00
frame_alloc_fail:
free(var);
2014-11-27 15:39:04 +01:00
var_alloc_fail:
free(altsvc);
2014-11-27 15:39:04 +01:00
fail:
return rv;
2014-04-01 14:47:51 +02:00
}
2014-03-25 18:04:24 +01:00
static uint8_t set_request_flags(const nghttp2_priority_spec *pri_spec,
2014-11-27 15:39:04 +01:00
const nghttp2_data_provider *data_prd) {
2013-07-15 14:45:59 +02:00
uint8_t flags = NGHTTP2_FLAG_NONE;
2014-11-27 15:39:04 +01:00
if (data_prd == NULL || data_prd->read_callback == NULL) {
2013-07-15 14:45:59 +02:00
flags |= NGHTTP2_FLAG_END_STREAM;
2013-07-12 17:19:03 +02:00
}
2014-03-25 18:04:24 +01:00
2014-11-27 15:39:04 +01:00
if (pri_spec) {
flags |= NGHTTP2_FLAG_PRIORITY;
2013-07-15 14:45:59 +02:00
}
2014-03-25 18:04:24 +01:00
return flags;
}
int32_t nghttp2_submit_request(nghttp2_session *session,
const nghttp2_priority_spec *pri_spec,
const nghttp2_nv *nva, size_t nvlen,
const nghttp2_data_provider *data_prd,
2014-11-27 15:39:04 +01:00
void *stream_user_data) {
2014-03-25 18:04:24 +01:00
uint8_t flags;
2014-11-27 15:39:04 +01:00
if (pri_spec && nghttp2_priority_spec_check_default(pri_spec)) {
pri_spec = NULL;
}
2014-03-25 18:04:24 +01:00
flags = set_request_flags(pri_spec, data_prd);
2014-11-27 15:39:04 +01:00
return submit_headers_shared_nva(session, flags, -1, pri_spec, nva, nvlen,
data_prd, stream_user_data, 0);
2013-07-12 17:19:03 +02:00
}
2014-11-27 15:39:04 +01:00
static uint8_t set_response_flags(const nghttp2_data_provider *data_prd) {
2013-07-15 14:45:59 +02:00
uint8_t flags = NGHTTP2_FLAG_NONE;
2014-11-27 15:39:04 +01:00
if (data_prd == NULL || data_prd->read_callback == NULL) {
2013-07-15 14:45:59 +02:00
flags |= NGHTTP2_FLAG_END_STREAM;
2013-07-12 17:19:03 +02:00
}
2013-11-28 13:35:48 +01:00
return flags;
}
2014-11-27 15:39:04 +01:00
int nghttp2_submit_response(nghttp2_session *session, int32_t stream_id,
const nghttp2_nv *nva, size_t nvlen,
2014-11-27 15:39:04 +01:00
const nghttp2_data_provider *data_prd) {
2013-11-28 13:35:48 +01:00
uint8_t flags = set_response_flags(data_prd);
2014-11-27 15:39:04 +01:00
return submit_headers_shared_nva(session, flags, stream_id, NULL, nva, nvlen,
data_prd, NULL, 1);
2013-11-28 13:35:48 +01:00
}
2013-07-15 14:45:59 +02:00
int nghttp2_submit_data(nghttp2_session *session, uint8_t flags,
int32_t stream_id,
2014-11-27 15:39:04 +01:00
const nghttp2_data_provider *data_prd) {
2014-02-18 16:45:20 +01:00
int rv;
nghttp2_outbound_item *item;
nghttp2_frame *frame;
nghttp2_data_aux_data *aux_data;
2014-07-30 15:37:59 +02:00
uint8_t nflags = flags & NGHTTP2_FLAG_END_STREAM;
2014-11-27 15:39:04 +01:00
if (stream_id == 0) {
return NGHTTP2_ERR_INVALID_ARGUMENT;
}
item = malloc(sizeof(nghttp2_outbound_item));
2014-11-27 15:39:04 +01:00
if (item == NULL) {
2013-07-12 17:19:03 +02:00
return NGHTTP2_ERR_NOMEM;
}
nghttp2_session_outbound_item_init(session, item);
frame = &item->frame;
aux_data = &item->aux_data.data;
aux_data->data_prd = *data_prd;
aux_data->eof = 0;
aux_data->flags = nflags;
/* flags are sent on transmission */
nghttp2_frame_data_init(&frame->data, NGHTTP2_FLAG_NONE, stream_id);
rv = nghttp2_session_add_item(session, item);
2014-11-27 15:39:04 +01:00
if (rv != 0) {
nghttp2_frame_data_free(&frame->data);
free(item);
2014-02-18 16:45:20 +01:00
return rv;
2013-07-12 17:19:03 +02:00
}
2014-02-18 16:45:20 +01:00
return 0;
2013-07-12 17:19:03 +02:00
}
2013-08-03 11:05:14 +02:00
2014-11-27 15:39:04 +01:00
ssize_t nghttp2_pack_settings_payload(uint8_t *buf, size_t buflen,
const nghttp2_settings_entry *iv,
2014-11-27 15:39:04 +01:00
size_t niv) {
if (!nghttp2_iv_check(iv, niv)) {
2013-08-03 11:05:14 +02:00
return NGHTTP2_ERR_INVALID_ARGUMENT;
}
2014-11-27 15:39:04 +01:00
if (buflen < (niv * NGHTTP2_FRAME_SETTINGS_ENTRY_LENGTH)) {
return NGHTTP2_ERR_INSUFF_BUFSIZE;
}
2013-08-03 11:05:14 +02:00
return nghttp2_frame_pack_settings_payload(buf, iv, niv);
}