aboutsummaryrefslogtreecommitdiffstats
path: root/apps/http-proxy/src/http_1x_message_fast_parser.cc
diff options
context:
space:
mode:
Diffstat (limited to 'apps/http-proxy/src/http_1x_message_fast_parser.cc')
-rw-r--r--apps/http-proxy/src/http_1x_message_fast_parser.cc105
1 files changed, 105 insertions, 0 deletions
diff --git a/apps/http-proxy/src/http_1x_message_fast_parser.cc b/apps/http-proxy/src/http_1x_message_fast_parser.cc
new file mode 100644
index 000000000..4b6b78d55
--- /dev/null
+++ b/apps/http-proxy/src/http_1x_message_fast_parser.cc
@@ -0,0 +1,105 @@
+/*
+ * Copyright (c) 2019 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.
+ */
+
+#include <hicn/http-proxy/http_session.h>
+#include <hicn/transport/http/request.h>
+#include <hicn/transport/http/response.h>
+
+#include <experimental/algorithm>
+#include <experimental/functional>
+#include <iostream>
+
+constexpr char HTTPMessageFastParser::http_ok[];
+constexpr char HTTPMessageFastParser::http_cors[];
+constexpr char HTTPMessageFastParser::http_failed[];
+
+std::string HTTPMessageFastParser::numbers = "0123456789";
+std::string HTTPMessageFastParser::content_length = "content-length";
+std::string HTTPMessageFastParser::transfer_encoding = "transfer-encoding";
+std::string HTTPMessageFastParser::chunked = "chunked";
+std::string HTTPMessageFastParser::cache_control = "cache-control";
+std::string HTTPMessageFastParser::mpd = "mpd";
+std::string HTTPMessageFastParser::connection = "connection";
+std::string HTTPMessageFastParser::separator = "\r\n\r\n";
+
+void HTTPMessageFastParser::getHeaders(const uint8_t *headers,
+ std::size_t length, bool request,
+ transport::Metadata *metadata) {
+ if (request) {
+ transport::RequestMetadata *_metadata =
+ (transport::RequestMetadata *)(metadata);
+
+ if (transport::http::HTTPRequest::parseHeaders(
+ headers, length, _metadata->headers, _metadata->http_version,
+ _metadata->method, _metadata->path)) {
+ return;
+ }
+ } else {
+ transport::ResponseMetadata *_metadata =
+ (transport::ResponseMetadata *)(metadata);
+
+ if (transport::http::HTTPResponse::parseHeaders(
+ headers, length, _metadata->headers, _metadata->http_version,
+ _metadata->status_code, _metadata->status_string)) {
+ return;
+ }
+ }
+
+ throw std::runtime_error("Error parsing response headers.");
+}
+
+std::size_t HTTPMessageFastParser::hasBody(const uint8_t *headers,
+ std::size_t length) {
+ const char *buffer = reinterpret_cast<const char *>(headers);
+ const char *begin = buffer;
+ const char *end = buffer + length;
+
+ using std::experimental::make_boyer_moore_searcher;
+ auto it = std::experimental::search(
+ begin, end,
+ make_boyer_moore_searcher(content_length.begin(), content_length.end()));
+
+ if (it != end) {
+ // Read header line
+ auto it2 = std::find_first_of(it, end, numbers.begin(), numbers.end());
+ auto it3 = std::find(it2, end, '\n');
+
+ return std::stoul(std::string(it2, it3));
+ }
+
+ return 0;
+}
+
+bool HTTPMessageFastParser::isMpdRequest(const uint8_t *headers,
+ std::size_t length) {
+ const char *buffer = reinterpret_cast<const char *>(headers);
+ const char *begin = buffer;
+ const char *end = buffer + length;
+
+ using std::experimental::make_boyer_moore_searcher;
+ auto it = std::experimental::search(
+ begin, end, make_boyer_moore_searcher(mpd.begin(), mpd.end()));
+
+ if (it != end) {
+ return true;
+ }
+
+ return false;
+}
+
+uint32_t HTTPMessageFastParser::parseCacheControl(const uint8_t *headers,
+ std::size_t length) {
+ return 0;
+}