diff options
Diffstat (limited to 'web/server/h2o/streaming.h')
-rw-r--r-- | web/server/h2o/streaming.h | 61 |
1 files changed, 0 insertions, 61 deletions
diff --git a/web/server/h2o/streaming.h b/web/server/h2o/streaming.h deleted file mode 100644 index ae6447257..000000000 --- a/web/server/h2o/streaming.h +++ /dev/null @@ -1,61 +0,0 @@ -// SPDX-License-Identifier: GPL-3.0-or-later - -#ifndef HTTPD_STREAMING_H -#define HTTPD_STREAMING_H - -#include "daemon/common.h" -#include "mqtt_websockets/c-rbuf/include/ringbuffer.h" -#include "h2o.h" - -typedef enum { - STREAM_X_HTTP_1_1 = 0, - STREAM_X_HTTP_1_1_DONE, - STREAM_ACTIVE, - STREAM_CLOSE -} h2o_stream_state_t; - -typedef enum { - HTTP_STREAM = 0, - HTTP_URL, - HTTP_PROTO, - HTTP_USER_AGENT_KEY, - HTTP_USER_AGENT_VALUE, - HTTP_HDR, - HTTP_DONE -} http_stream_parse_state_t; - -typedef struct { - h2o_socket_t *sock; - h2o_stream_state_t state; - - rbuf_t rx; - pthread_cond_t rx_buf_cond; - pthread_mutex_t rx_buf_lock; - - rbuf_t tx; - h2o_iovec_t tx_buf; - pthread_mutex_t tx_buf_lock; - - http_stream_parse_state_t parse_state; - char *url; - char *user_agent; - - int shutdown; -} h2o_stream_conn_t; - -// h2o_stream_conn_t related functions -void h2o_stream_conn_t_init(h2o_stream_conn_t *conn); -void h2o_stream_conn_t_destroy(h2o_stream_conn_t *conn); - -// streaming upgrade related functions -int is_streaming_handshake(h2o_req_t *req); -void stream_on_complete(void *user_data, h2o_socket_t *sock, size_t reqsize); - -// read and write functions to be used by streaming parser -int h2o_stream_write(void *ctx, const char *data, size_t data_len); -size_t h2o_stream_read(void *ctx, char *buf, size_t read_bytes); - -// call this periodically to check if there are any pending write requests -void h2o_stream_check_pending_write_reqs(void); - -#endif /* HTTPD_STREAMING_H */ |