aboutsummaryrefslogtreecommitdiffstats
path: root/src/plugins/http/http.h
diff options
context:
space:
mode:
authorFlorin Coras <fcoras@cisco.com>2022-01-13 11:59:44 -0800
committerFlorin Coras <fcoras@cisco.com>2022-01-20 00:39:21 -0800
commit0b65621d41619e242b136e78fecfb325c90ae0bc (patch)
tree300e7002f2eae2afb5c235e2fe96705e34a79dbe /src/plugins/http/http.h
parentb85de19145a01d3acdf326c3cfa4e94b585bb59f (diff)
http: add http protocol plugin
Basic HTTP/1.1 server side implementation. Type: feature Signed-off-by: Florin Coras <fcoras@cisco.com> Change-Id: I06bddaf7f11e28db802b4cd7ef8160c78cb019b6
Diffstat (limited to 'src/plugins/http/http.h')
-rw-r--r--src/plugins/http/http.h194
1 files changed, 194 insertions, 0 deletions
diff --git a/src/plugins/http/http.h b/src/plugins/http/http.h
new file mode 100644
index 00000000000..209fc3236df
--- /dev/null
+++ b/src/plugins/http/http.h
@@ -0,0 +1,194 @@
+/*
+ * Copyright (c) 2022 Cisco and/or its affiliates.
+ * Licensed under the Apache License, Version 2.0 (the "License");
+ * you may not use this file except in compliance with the License.
+ * You may obtain a copy of the License at:
+ *
+ * http://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing, software
+ * distributed under the License is distributed on an "AS IS" BASIS,
+ * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+ * See the License for the specific language governing permissions and
+ * limitations under the License.
+ */
+
+#ifndef SRC_PLUGINS_HTTP_HTTP_H_
+#define SRC_PLUGINS_HTTP_HTTP_H_
+
+#include <vnet/plugin/plugin.h>
+#include <vpp/app/version.h>
+
+#include <vppinfra/time_range.h>
+
+#include <vnet/session/application_interface.h>
+#include <vnet/session/application.h>
+
+#define HTTP_DEBUG 0
+
+#if HTTP_DEBUG
+#define HTTP_DBG(_lvl, _fmt, _args...) \
+ if (_lvl <= HTTP_DEBUG) \
+ clib_warning (_fmt, ##_args)
+#else
+#define HTTP_DBG(_lvl, _fmt, _args...)
+#endif
+
+typedef struct http_conn_id_
+{
+ union
+ {
+ session_handle_t app_session_handle;
+ u32 parent_app_api_ctx;
+ };
+ session_handle_t tc_session_handle;
+ u32 parent_app_wrk_index;
+} http_conn_id_t;
+
+STATIC_ASSERT (sizeof (http_conn_id_t) <= TRANSPORT_CONN_ID_LEN,
+ "ctx id must be less than TRANSPORT_CONN_ID_LEN");
+
+typedef enum http_state_
+{
+ HTTP_CONN_STATE_LISTEN,
+ HTTP_CONN_STATE_CONNECTING,
+ HTTP_CONN_STATE_ESTABLISHED,
+ HTTP_CONN_STATE_TRANSPORT_CLOSED,
+ HTTP_CONN_STATE_APP_CLOSED,
+ HTTP_CONN_STATE_CLOSED
+} http_conn_state_t;
+
+typedef enum http_req_state_
+{
+ HTTP_REQ_STATE_WAIT_METHOD,
+ HTTP_REQ_STATE_WAIT_APP,
+ HTTP_REQ_STATE_SEND_MORE_DATA,
+ HTTP_REQ_N_STATES,
+} http_req_state_t;
+
+typedef enum http_req_method_
+{
+ HTTP_REQ_GET = 0,
+ HTTP_REQ_POST,
+} http_req_method_t;
+
+typedef enum http_msg_type_
+{
+ HTTP_MSG_REQUEST,
+ HTTP_MSG_REPLY
+} http_msg_type_t;
+
+#define foreach_http_content_type \
+ _ (TEXT_HTML, "text/html") \
+ _ (TEXT_CSS, "text/css") \
+ _ (TEXT_JS, "text/javascript") \
+ _ (TEXT_JSON, "application/json")
+
+typedef enum http_content_type_
+{
+#define _(s, str) HTTP_CONTENT_##s,
+ foreach_http_content_type
+#undef _
+} http_content_type_t;
+
+#define foreach_http_status_code \
+ _ (200, OK, "200 OK") \
+ _ (400, BAD_REQUEST, "400 Bad Request") \
+ _ (405, METHOD_NOT_ALLOWED, "405 Method Not Allowed") \
+ _ (500, INTERNAL_ERROR, "500 Internal Server Error")
+
+typedef enum http_status_code_
+{
+#define _(c, s, str) HTTP_STATUS_##s,
+ foreach_http_status_code
+#undef _
+ HTTP_N_STATUS
+} http_status_code_t;
+
+typedef struct http_msg_data_
+{
+ http_content_type_t content_type;
+ u32 len;
+ u32 offset;
+ u8 data[0];
+} http_msg_data_t;
+
+typedef struct http_msg_
+{
+ http_msg_type_t type;
+ union
+ {
+ http_req_method_t method_type;
+ http_status_code_t code;
+ };
+ http_msg_data_t data;
+} http_msg_t;
+
+typedef struct http_buffer_
+{
+ svm_fifo_t *src;
+ svm_fifo_seg_t *segs;
+ u32 len;
+ u32 cur_seg;
+ u32 offset;
+} http_buffer_t;
+
+typedef struct http_tc_
+{
+ union
+ {
+ transport_connection_t connection;
+ http_conn_id_t c_http_conn_id;
+ };
+#define h_tc_session_handle c_http_conn_id.tc_session_handle
+#define h_pa_wrk_index c_http_conn_id.parent_app_wrk_index
+#define h_pa_session_handle c_http_conn_id.app_session_handle
+#define h_hc_index connection.c_index
+
+ http_conn_state_t state;
+ u32 timer_handle;
+
+ /*
+ * Current request
+ */
+ http_req_state_t req_state;
+ http_req_method_t method;
+ u8 *rx_buf;
+ u32 rx_buf_offset;
+ http_buffer_t tx_buf;
+} http_conn_t;
+
+typedef struct http_worker_
+{
+ http_conn_t *conn_pool;
+} http_worker_t;
+
+typedef struct http_main_
+{
+ http_worker_t *wrk;
+ http_conn_t *listener_ctx_pool;
+ u32 app_index;
+
+ clib_timebase_t timebase;
+
+ /*
+ * Runtime config
+ */
+ u8 debug_level;
+
+ /*
+ * Config
+ */
+ u64 first_seg_size;
+ u32 fifo_size;
+} http_main_t;
+
+#endif /* SRC_PLUGINS_HTTP_HTTP_H_ */
+
+/*
+ * fd.io coding-style-patch-verification: ON
+ *
+ * Local Variables:
+ * eval: (c-set-style "gnu")
+ * End:
+ */