Include dependency graph for h2conn.c:

Data Structures
struct	vlc_h2_conn
	HTTP/2 connection. More...

struct	vlc_h2_stream
	HTTP/2 stream. More...

Macros
#define	CO(c) ((c)->opaque)

#define	SO(s) CO((s)->conn)

Functions
static void	vlc_h2_conn_destroy (struct vlc_h2_conn *conn)

static int	vlc_h2_conn_queue (struct vlc_h2_conn conn, struct vlc_h2_frame f)

static int	vlc_h2_conn_queue_prio (struct vlc_h2_conn conn, struct vlc_h2_frame f)

static void *	vlc_h2_stream_lookup (void *ctx, uint_fast32_t id)
	Looks a stream up by ID. More...

static int	vlc_h2_stream_error (void *ctx, uint_fast32_t id, uint_fast32_t code)
	Reports a local stream error. More...

static int	vlc_h2_stream_fatal (struct vlc_h2_stream *s, uint_fast32_t code)

static void	vlc_h2_stream_headers (void ctx, unsigned count, const char const hdrs[][2])
	Reports received stream headers. More...

static int	vlc_h2_stream_data (void ctx, struct vlc_h2_frame f)
	Reports received stream data. More...

static void	vlc_h2_stream_end (void *ctx)
	Reports received end of stream. More...

static int	vlc_h2_stream_reset (void *ctx, uint_fast32_t code)
	Reports remote stream error. More...

static void	vlc_h2_stream_wake_up (void *data)

static void	vlc_h2_stream_lock (struct vlc_h2_stream *s)

static int	vlc_h2_stream_unlock (struct vlc_h2_stream *s)

static struct vlc_http_msg *	vlc_h2_stream_wait (struct vlc_http_stream *stream)

static block_t *	vlc_h2_stream_read (struct vlc_http_stream *stream)
	Receives stream data. More...

static void	vlc_h2_stream_close (struct vlc_http_stream *stream, bool aborted)
	Terminates a stream. More...

static struct vlc_http_stream *	vlc_h2_stream_open (struct vlc_http_conn c, const struct vlc_http_msg msg)
	Creates a stream. More...

static void	vlc_h2_setting (void *ctx, uint_fast16_t id, uint_fast32_t value)
	Reports an HTTP/2 peer connection setting. More...

static int	vlc_h2_settings_done (void *ctx)
	Reports end of HTTP/2 peer settings. More...

static int	vlc_h2_ping (void *ctx, uint_fast64_t opaque)
	Reports a ping received from HTTP/2 peer. More...

static void	vlc_h2_error (void *ctx, uint_fast32_t code)
	Reports a local HTTP/2 connection failure. More...

static int	vlc_h2_reset (void *ctx, uint_fast32_t last_seq, uint_fast32_t code)
	Reports a remote HTTP/2 connection error. More...

static void	vlc_h2_window_status (void ctx, uint32_t restrict rcwd)

static ssize_t	vlc_https_recv (vlc_tls_t tls, void buf, size_t len)
	Receives TLS data. More...

static struct vlc_h2_frame *	vlc_h2_frame_recv (struct vlc_tls *tls)
	Receives an HTTP/2 frame through TLS. More...

static void	cleanup_parser (void *data)

static void *	vlc_h2_recv_thread (void *data)
	HTTP/2 receive thread. More...

static void	vlc_h2_conn_release (struct vlc_http_conn *c)

struct vlc_http_conn *	vlc_h2_conn_create (void ctx, struct vlc_tls tls)

Variables
static const struct vlc_http_stream_cbs	vlc_h2_stream_callbacks

static const struct vlc_h2_parser_cbs	vlc_h2_parser_callbacks
	HTTP/2 frames parser callbacks table. More...

static const struct vlc_http_conn_cbs	vlc_h2_conn_callbacks

Macro Definition Documentation

◆ CO

#define CO ( c ) ((c)->opaque)

◆ SO

#define SO ( s ) CO((s)->conn)

Function Documentation

◆ cleanup_parser()

static void cleanup_parser ( void * data )

static

References vlc_h2_frame::data, and vlc_h2_parse_destroy().

Referenced by vlc_h2_recv_thread().

◆ vlc_h2_conn_destroy()

static void vlc_h2_conn_destroy ( struct vlc_h2_conn * conn )

static

References vlc_h2_conn::conn, vlc_h2_conn::lock, vlc_h2_conn::out, vlc_h2_conn::streams, vlc_h2_conn::thread, vlc_http_conn::tls, vlc_cancel(), vlc_h2_error(), VLC_H2_NO_ERROR, vlc_h2_output_destroy(), vlc_join(), vlc_mutex_destroy(), vlc_tls_Close(), and vlc_tls_Shutdown().

Referenced by vlc_h2_conn_release(), and vlc_h2_stream_close().

◆ vlc_h2_conn_queue()

static int vlc_h2_conn_queue	(	struct vlc_h2_conn *	conn,
		struct vlc_h2_frame *	f
	)

static

References vlc_h2_conn::opaque, vlc_h2_conn::out, vlc_h2_frame_dump(), and vlc_h2_output_send().

Referenced by vlc_h2_conn_create(), vlc_h2_error(), vlc_h2_reset(), vlc_h2_settings_done(), vlc_h2_stream_error(), vlc_h2_stream_open(), and vlc_h2_stream_read().

◆ vlc_h2_conn_queue_prio()

static int vlc_h2_conn_queue_prio	(	struct vlc_h2_conn *	conn,
		struct vlc_h2_frame *	f
	)

static

References vlc_h2_conn::opaque, vlc_h2_conn::out, vlc_h2_frame_dump(), and vlc_h2_output_send_prio().

Referenced by vlc_h2_ping(), and vlc_h2_window_status().

◆ vlc_h2_conn_release()

static void vlc_h2_conn_release ( struct vlc_http_conn * c )

static

References vlc_h2_conn::conn, container_of, vlc_h2_conn_destroy(), vlc_mutex_lock(), and vlc_mutex_unlock().

◆ vlc_h2_error()

static void vlc_h2_error	(	void *	ctx,
		uint_fast32_t	code
	)

static

Reports a local HTTP/2 connection failure.

References CO, vlc_h2_conn::conn, vlc_h2_conn_queue(), vlc_h2_frame_goaway(), VLC_H2_NO_ERROR, vlc_h2_strerror(), vlc_http_dbg(), and vlc_http_err().

Referenced by vlc_h2_conn_destroy().

◆ vlc_h2_frame_recv()

static struct vlc_h2_frame* vlc_h2_frame_recv ( struct vlc_tls * tls )

static

Receives an HTTP/2 frame through TLS.

This function allocates memory for and receives a whole HTTP/2 frame from a TLS session.

The caller must "own" the read side of the TLS session.

Note: This is a blocking function and may be a thread cancellation point.

Returns: a frame or NULL if the connection failed

References vlc_h2_frame::data, vlc_h2_frame::next, unlikely, vlc_cleanup_pop, vlc_cleanup_push, and vlc_https_recv().

Referenced by vlc_h2_recv_thread().

◆ vlc_h2_ping()

static int vlc_h2_ping	(	void *	ctx,
		uint_fast64_t	opaque
	)

static

Reports a ping received from HTTP/2 peer.

References vlc_h2_conn::conn, vlc_h2_conn::opaque, vlc_h2_conn_queue_prio(), and vlc_h2_frame_pong().

◆ vlc_h2_recv_thread()

static void* vlc_h2_recv_thread ( void * data )

static

◆ vlc_h2_reset()

static int vlc_h2_reset	(	void *	ctx,
		uint_fast32_t	last_seq,
		uint_fast32_t	code
	)

static

Reports a remote HTTP/2 connection error.

References CO, vlc_h2_conn::conn, vlc_h2_conn_queue(), vlc_h2_frame_goaway(), VLC_H2_NO_ERROR, VLC_H2_REFUSED_STREAM, vlc_h2_stream_reset(), vlc_h2_strerror(), vlc_http_dbg(), and vlc_http_err().

◆ vlc_h2_setting()

static void vlc_h2_setting	(	void *	ctx,
		uint_fast16_t	id,
		uint_fast32_t	value
	)

static

Reports an HTTP/2 peer connection setting.

References CO, vlc_h2_conn::conn, vlc_h2_setting_name(), and vlc_http_dbg().

◆ vlc_h2_settings_done()

static int vlc_h2_settings_done ( void * ctx )

static

Reports end of HTTP/2 peer settings.

References vlc_h2_conn::conn, vlc_h2_conn_queue(), and vlc_h2_frame_settings_ack().

◆ vlc_h2_stream_close()

static void vlc_h2_stream_close	(	struct vlc_http_stream *	stream,
		bool	aborted
	)

static

Terminates a stream.

Sends an HTTP/2 stream reset, removes the stream from the HTTP/2 connection and deletes any stream resource.

References vlc_h2_stream::conn, vlc_h2_conn::conn, container_of, vlc_h2_stream::id, vlc_h2_stream::newer, vlc_h2_stream::older, vlc_h2_stream::recv_end, vlc_h2_stream::recv_hdr, vlc_h2_stream::recv_head, vlc_h2_stream::recv_wait, vlc_h2_stream::stream, vlc_cond_destroy(), VLC_H2_CANCEL, vlc_h2_conn_destroy(), VLC_H2_NO_ERROR, vlc_h2_stream_error(), vlc_http_msg_destroy(), vlc_mutex_lock(), and vlc_mutex_unlock().

◆ vlc_h2_stream_data()

static int vlc_h2_stream_data	(	void *	ctx,
		struct vlc_h2_frame *	f
	)

static

Reports received stream data.

References vlc_h2_stream::conn, vlc_h2_stream::id, vlc_h2_frame::next, vlc_h2_stream::recv_cwnd, vlc_h2_stream::recv_end, vlc_h2_stream::recv_tailp, vlc_h2_stream::recv_wait, vlc_cond_signal(), VLC_H2_FLOW_CONTROL_ERROR, vlc_h2_frame_data_get, VLC_H2_STREAM_CLOSED, vlc_h2_stream_error(), and vlc_h2_stream_fatal().

◆ vlc_h2_stream_end()

static void vlc_h2_stream_end ( void * ctx )

static

Reports received end of stream.

References vlc_h2_stream::id, vlc_h2_stream::recv_end, vlc_h2_stream::recv_wait, SO, vlc_cond_broadcast(), and vlc_http_dbg().

◆ vlc_h2_stream_error()

static int vlc_h2_stream_error	(	void *	ctx,
		uint_fast32_t	id,
		uint_fast32_t	code
	)

static

Reports a local stream error.

References CO, vlc_h2_conn::conn, vlc_h2_conn_queue(), vlc_h2_frame_rst_stream(), VLC_H2_NO_ERROR, vlc_h2_strerror(), vlc_http_dbg(), and vlc_http_err().

Referenced by vlc_h2_stream_close(), vlc_h2_stream_data(), vlc_h2_stream_fatal(), and vlc_h2_stream_read().

◆ vlc_h2_stream_fatal()

static int vlc_h2_stream_fatal	(	struct vlc_h2_stream *	s,
		uint_fast32_t	code
	)

static

References vlc_h2_stream::conn, vlc_h2_stream::id, vlc_h2_stream::recv_end, vlc_h2_stream::recv_err, and vlc_h2_stream_error().

Referenced by vlc_h2_stream_data(), and vlc_h2_stream_headers().

◆ vlc_h2_stream_headers()

static void vlc_h2_stream_headers	(	void *	ctx,
		unsigned	count,
		const char *const	hdrs[][2]
	)

static

Reports received stream headers.

References count, vlc_h2_stream::id, vlc_h2_stream::recv_hdr, vlc_h2_stream::recv_wait, SO, unlikely, vlc_cond_signal(), VLC_H2_PROTOCOL_ERROR, vlc_h2_stream_fatal(), vlc_http_dbg(), vlc_http_msg_destroy(), and vlc_http_msg_h2_headers().

◆ vlc_h2_stream_lock()

static void vlc_h2_stream_lock ( struct vlc_h2_stream * s )

static

References vlc_h2_stream::conn, vlc_h2_stream::interrupted, vlc_h2_conn::lock, vlc_h2_stream_wake_up(), vlc_interrupt_register(), and vlc_mutex_lock().

Referenced by vlc_h2_stream_read(), and vlc_h2_stream_wait().

◆ vlc_h2_stream_lookup()

static void* vlc_h2_stream_lookup	(	void *	ctx,
		uint_fast32_t	id
	)

static

Looks a stream up by ID.

References vlc_h2_conn::conn.

◆ vlc_h2_stream_open()

static struct vlc_http_stream* vlc_h2_stream_open	(	struct vlc_http_conn *	c,
		const struct vlc_http_msg *	msg
	)

static

Creates a stream.

Allocates a locally-initiated stream identifier on an HTTP/2 connection and queue stream headers for sending.

Headers are sent asynchronously. To obtain the result and answer from the other end, use vlc_http_stream_recv_headers().

Parameters

msg	HTTP message headers (including response status or request)

Returns: an HTTP stream, or NULL on error

References vlc_http_stream::cbs, CO, vlc_h2_stream::conn, vlc_h2_conn::conn, container_of, vlc_h2_stream::id, vlc_h2_conn::lock, vlc_h2_stream::newer, vlc_h2_conn::next_id, vlc_h2_stream::older, vlc_h2_stream::recv_cwnd, vlc_h2_stream::recv_end, vlc_h2_stream::recv_err, vlc_h2_stream::recv_hdr, vlc_h2_stream::recv_head, vlc_h2_stream::recv_tailp, vlc_h2_stream::recv_wait, vlc_h2_conn::released, vlc_h2_stream::stream, vlc_h2_conn::streams, unlikely, vlc_cond_destroy(), vlc_cond_init(), vlc_h2_conn_queue(), VLC_H2_INIT_WINDOW, vlc_h2_stream_callbacks, vlc_http_dbg(), vlc_http_msg_h2_frame(), vlc_mutex_lock(), and vlc_mutex_unlock().

◆ vlc_h2_stream_read()

static block_t* vlc_h2_stream_read ( struct vlc_http_stream * stream )

static

Receives stream data.

Dequeues pending incoming data for an HTTP/2 stream. If there is currently no data block, wait for one.

Returns: a VLC data block, NULL on end of stream, or vlc_http_error on stream error

References block_heap_Alloc(), vlc_h2_stream::conn, vlc_h2_conn::conn, container_of, block_t::i_buffer, vlc_h2_stream::id, vlc_h2_stream::interrupted, vlc_h2_conn::lock, mutex_cleanup_push, vlc_h2_frame::next, block_t::p_buffer, vlc_h2_stream::recv_cwnd, vlc_h2_stream::recv_end, vlc_h2_stream::recv_err, vlc_h2_stream::recv_head, vlc_h2_stream::recv_tailp, vlc_h2_stream::recv_wait, vlc_h2_stream::stream, unlikely, vlc_cleanup_pop, vlc_cond_wait(), vlc_h2_conn_queue(), vlc_h2_frame_data_get, vlc_h2_frame_size(), vlc_h2_frame_window_update(), VLC_H2_INIT_WINDOW, VLC_H2_INTERNAL_ERROR, vlc_h2_stream_error(), vlc_h2_stream_lock(), vlc_h2_stream_unlock(), and vlc_http_error.

◆ vlc_h2_stream_reset()

static int vlc_h2_stream_reset	(	void *	ctx,
		uint_fast32_t	code
	)

static

Reports remote stream error.

References vlc_h2_stream::id, vlc_h2_stream::recv_end, vlc_h2_stream::recv_err, vlc_h2_stream::recv_wait, SO, vlc_cond_broadcast(), vlc_h2_strerror(), and vlc_http_err().

Referenced by vlc_h2_recv_thread(), and vlc_h2_reset().

◆ vlc_h2_stream_unlock()

static int vlc_h2_stream_unlock ( struct vlc_h2_stream * s )

static

References vlc_h2_stream::conn, vlc_h2_conn::lock, vlc_interrupt_unregister(), and vlc_mutex_unlock().

Referenced by vlc_h2_stream_read(), and vlc_h2_stream_wait().

◆ vlc_h2_stream_wait()

static struct vlc_http_msg* vlc_h2_stream_wait ( struct vlc_http_stream * stream )

static

References vlc_h2_stream::conn, vlc_h2_conn::conn, container_of, vlc_h2_stream::interrupted, vlc_h2_conn::lock, mutex_cleanup_push, vlc_h2_stream::recv_end, vlc_h2_stream::recv_hdr, vlc_h2_stream::recv_wait, vlc_h2_stream::stream, vlc_cleanup_pop, vlc_cond_wait(), vlc_h2_stream_lock(), vlc_h2_stream_unlock(), and vlc_http_msg_attach().

◆ vlc_h2_stream_wake_up()

static void vlc_h2_stream_wake_up ( void * data )

static

References vlc_h2_stream::conn, vlc_h2_conn::conn, vlc_h2_stream::interrupted, vlc_h2_stream::recv_wait, vlc_cond_signal(), vlc_mutex_lock(), and vlc_mutex_unlock().

Referenced by vlc_h2_stream_lock().

◆ vlc_h2_window_status()

static void vlc_h2_window_status	(	void *	ctx,
		uint32_t *restrict	rcwd
	)

static

References vlc_h2_conn::conn, vlc_h2_conn_queue_prio(), and vlc_h2_frame_window_update().

◆ vlc_https_recv()

static ssize_t vlc_https_recv	(	vlc_tls_t *	tls,
		void *	buf,
		size_t	len
	)

static

Receives TLS data.

Receives bytes from the peer through a TLS session.

Note: This may be a cancellation point. The caller is responsible for serializing reads on a given connection.

References count, pollfd::events, pollfd::fd, poll(), POLLIN, vlc_tls::readv, vlc_restorecancel(), vlc_savecancel(), and vlc_tls_GetFD().

Referenced by vlc_h2_frame_recv().

Variable Documentation

◆ vlc_h2_conn_callbacks

const struct vlc_http_conn_cbs vlc_h2_conn_callbacks

static

Initial value:

=
{
    vlc_h2_stream_open,
    vlc_h2_conn_release,
}

Referenced by vlc_h2_conn_create().

◆ vlc_h2_parser_callbacks

const struct vlc_h2_parser_cbs vlc_h2_parser_callbacks

static

Initial value:

=
{
    vlc_h2_setting,
    vlc_h2_settings_done,
    vlc_h2_ping,
    vlc_h2_error,
    vlc_h2_reset,
    vlc_h2_window_status,
    vlc_h2_stream_lookup,
    vlc_h2_stream_error,
    vlc_h2_stream_headers,
    vlc_h2_stream_data,
    vlc_h2_stream_end,
    vlc_h2_stream_reset,
}

HTTP/2 frames parser callbacks table.

Referenced by vlc_h2_recv_thread().

◆ vlc_h2_stream_callbacks

const struct vlc_http_stream_cbs vlc_h2_stream_callbacks

static

Initial value:

=
{
    vlc_h2_stream_wait,
    vlc_h2_stream_read,
    vlc_h2_stream_close,
}

Referenced by vlc_h2_stream_open().

Data Structures

Macros

Functions

Variables

Macro Definition Documentation

◆ CO

◆ SO

Function Documentation

◆ cleanup_parser()

◆ vlc_h2_conn_destroy()

◆ vlc_h2_conn_queue()

◆ vlc_h2_conn_queue_prio()

◆ vlc_h2_conn_release()

◆ vlc_h2_error()

◆ vlc_h2_frame_recv()

◆ vlc_h2_ping()

◆ vlc_h2_recv_thread()

◆ vlc_h2_reset()

◆ vlc_h2_setting()

◆ vlc_h2_settings_done()

◆ vlc_h2_stream_close()

◆ vlc_h2_stream_data()

◆ vlc_h2_stream_end()

◆ vlc_h2_stream_error()

◆ vlc_h2_stream_fatal()

◆ vlc_h2_stream_headers()

◆ vlc_h2_stream_lock()

◆ vlc_h2_stream_lookup()

◆ vlc_h2_stream_open()

◆ vlc_h2_stream_read()

◆ vlc_h2_stream_reset()

◆ vlc_h2_stream_unlock()

◆ vlc_h2_stream_wait()

◆ vlc_h2_stream_wake_up()

◆ vlc_h2_window_status()

◆ vlc_https_recv()

Variable Documentation

◆ vlc_h2_conn_callbacks

◆ vlc_h2_parser_callbacks

◆ vlc_h2_stream_callbacks