summaryrefslogtreecommitdiffstats
path: root/debian/vendor-h2o/t/00unit/test.c
diff options
context:
space:
mode:
authorDaniel Baumann <daniel.baumann@progress-linux.org>2024-04-13 21:12:02 +0000
committerDaniel Baumann <daniel.baumann@progress-linux.org>2024-04-13 21:12:02 +0000
commit77e50caaf2ef81cd91075cf836fed0e75718ffb4 (patch)
tree53b7b411290b63192fc9e924a3b6b65cdf67e9d0 /debian/vendor-h2o/t/00unit/test.c
parentAdding upstream version 1.8.3. (diff)
downloaddnsdist-77e50caaf2ef81cd91075cf836fed0e75718ffb4.tar.xz
dnsdist-77e50caaf2ef81cd91075cf836fed0e75718ffb4.zip
Adding debian version 1.8.3-2.debian/1.8.3-2
Signed-off-by: Daniel Baumann <daniel.baumann@progress-linux.org>
Diffstat (limited to 'debian/vendor-h2o/t/00unit/test.c')
-rw-r--r--debian/vendor-h2o/t/00unit/test.c202
1 files changed, 202 insertions, 0 deletions
diff --git a/debian/vendor-h2o/t/00unit/test.c b/debian/vendor-h2o/t/00unit/test.c
new file mode 100644
index 0000000..a74859d
--- /dev/null
+++ b/debian/vendor-h2o/t/00unit/test.c
@@ -0,0 +1,202 @@
+/*
+ * Copyright (c) 2014 DeNA Co., Ltd.
+ *
+ * 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 "h2o.h"
+#include "h2o/configurator.h"
+#include "../../src/standalone.h"
+#include "./test.h"
+
+static void loopback_on_send(h2o_ostream_t *self, h2o_req_t *req, h2o_iovec_t *inbufs, size_t inbufcnt, h2o_send_state_t send_state)
+{
+ h2o_loopback_conn_t *conn = H2O_STRUCT_FROM_MEMBER(h2o_loopback_conn_t, _ostr_final, self);
+ size_t i;
+
+ for (i = 0; i != inbufcnt; ++i) {
+ h2o_buffer_reserve(&conn->body, inbufs[i].len);
+ memcpy(conn->body->bytes + conn->body->size, inbufs[i].base, inbufs[i].len);
+ conn->body->size += inbufs[i].len;
+ }
+
+ if (h2o_send_state_is_in_progress(send_state))
+ h2o_proceed_response(&conn->req);
+ else
+ conn->_is_complete = 1;
+}
+
+static socklen_t get_sockname(h2o_conn_t *conn, struct sockaddr *sa)
+{
+ struct sockaddr_in *sin = (void *)sa;
+ sin->sin_family = AF_INET;
+ sin->sin_addr.s_addr = htonl(0x7f000001);
+ sin->sin_port = htons(80);
+ return sizeof(*sin);
+}
+
+static socklen_t get_peername(h2o_conn_t *conn, struct sockaddr *sa)
+{
+ struct sockaddr_in *sin = (void *)sa;
+ sin->sin_family = AF_INET;
+ sin->sin_addr.s_addr = htonl(0x7f000001);
+ sin->sin_port = htons(55555);
+ return sizeof(*sin);
+}
+
+h2o_loopback_conn_t *h2o_loopback_create(h2o_context_t *ctx, h2o_hostconf_t **hosts)
+{
+ static const h2o_conn_callbacks_t callbacks = {get_sockname, get_peername};
+ h2o_loopback_conn_t *conn = (void *)h2o_create_connection(sizeof(*conn), ctx, hosts, (struct timeval){0}, &callbacks);
+
+ memset((char *)conn + sizeof(conn->super), 0, offsetof(struct st_h2o_loopback_conn_t, req) - sizeof(conn->super));
+ conn->super.ctx = ctx;
+ conn->super.hosts = hosts;
+ conn->super.callbacks = &callbacks;
+ h2o_init_request(&conn->req, &conn->super, NULL);
+ h2o_buffer_init(&conn->body, &h2o_socket_buffer_prototype);
+ conn->req._ostr_top = &conn->_ostr_final;
+ conn->_ostr_final.do_send = loopback_on_send;
+
+ return conn;
+}
+
+void h2o_loopback_destroy(h2o_loopback_conn_t *conn)
+{
+ h2o_buffer_dispose(&conn->body);
+ h2o_dispose_request(&conn->req);
+ free(conn);
+}
+
+void h2o_loopback_run_loop(h2o_loopback_conn_t *conn)
+{
+ if (conn->req.input.scheme == NULL)
+ conn->req.input.scheme = &H2O_URL_SCHEME_HTTP;
+ if (conn->req.version == 0)
+ conn->req.version = 0x100; /* HTTP/1.0 */
+
+ h2o_process_request(&conn->req);
+
+ while (!conn->_is_complete) {
+#if H2O_USE_LIBUV
+ uv_run(conn->super.ctx->loop, UV_RUN_ONCE);
+#else
+ h2o_evloop_run(conn->super.ctx->loop, INT32_MAX);
+#endif
+ }
+}
+
+char *sha1sum(const void *src, size_t len)
+{
+ SHA_CTX ctx;
+ unsigned char bin[SHA_DIGEST_LENGTH];
+ static char hexbuf[SHA_DIGEST_LENGTH * 2 + 1];
+ size_t i;
+
+ SHA1_Init(&ctx);
+ SHA1_Update(&ctx, src, len);
+ SHA1_Final(bin, &ctx);
+
+ for (i = 0; i != SHA_DIGEST_LENGTH; ++i) {
+ hexbuf[i * 2] = ("0123456789abcdef")[bin[i] >> 4];
+ hexbuf[i * 2 + 1] = ("0123456789abcdef")[bin[i] & 0xf];
+ }
+ hexbuf[i * 2] = '\0';
+
+ return hexbuf;
+}
+
+h2o_loop_t *test_loop;
+
+static void test_loopback(void)
+{
+ h2o_globalconf_t conf;
+ h2o_context_t ctx;
+ h2o_loopback_conn_t *conn;
+
+ h2o_config_init(&conf);
+ h2o_config_register_host(&conf, h2o_iovec_init(H2O_STRLIT("default")), 65535);
+ h2o_context_init(&ctx, test_loop, &conf);
+
+ conn = h2o_loopback_create(&ctx, ctx.globalconf->hosts);
+ conn->req.input.method = h2o_iovec_init(H2O_STRLIT("GET"));
+ conn->req.input.path = h2o_iovec_init(H2O_STRLIT("/"));
+ h2o_loopback_run_loop(conn);
+
+ ok(conn->req.res.status == 404);
+
+ h2o_loopback_destroy(conn);
+
+ h2o_context_dispose(&ctx);
+ h2o_config_dispose(&conf);
+}
+
+int main(int argc, char **argv)
+{
+ init_openssl();
+
+ { /* library tests */
+ subtest("lib/cache.c", test_lib__common__cache_c);
+ subtest("lib/common/multithread.c", test_lib__common__multithread_c);
+ subtest("lib/common/hostinfo.c", test_lib__common__hostinfo_c);
+ subtest("lib/common/serverutil.c", test_lib__common__serverutil_c);
+ subtest("lib/common/serverutil.c", test_lib__common__socket_c);
+ subtest("lib/common/string.c", test_lib__common__string_c);
+ subtest("lib/common/url.c", test_lib__common__url_c);
+ subtest("lib/common/time.c", test_lib__common__time_c);
+ subtest("lib/core/headers.c", test_lib__core__headers_c);
+ subtest("lib/core/proxy.c", test_lib__core__proxy_c);
+ subtest("lib/core/util.c", test_lib__core__util_c);
+ subtest("lib/handler/headers.c", test_lib__handler__headers_c);
+ subtest("lib/handler/mimemap.c", test_lib__handler__mimemap_c);
+ subtest("lib/http2/hpack.c", test_lib__http2__hpack);
+ subtest("lib/http2/scheduler.c", test_lib__http2__scheduler);
+ subtest("lib/http2/casper.c", test_lib__http2__casper);
+ subtest("lib/http2/cache_digests.c", test_lib__http2__cache_digests);
+ }
+
+ { /* tests that use the run loop */
+#if H2O_USE_LIBUV
+ test_loop = h2o_mem_alloc(sizeof(*test_loop));
+ uv_loop_init(test_loop);
+#else
+ test_loop = h2o_evloop_create();
+#endif
+
+ subtest("lib/t/test.c/loopback", test_loopback);
+ subtest("lib/fastcgi.c", test_lib__handler__fastcgi_c);
+ subtest("lib/file.c", test_lib__handler__file_c);
+ subtest("lib/gzip.c", test_lib__handler__gzip_c);
+ subtest("lib/redirect.c", test_lib__handler__redirect_c);
+ subtest("issues/293.c", test_issues293);
+ subtest("issues/percent-encode-zero-byte.c", test_percent_encode_zero_byte);
+
+#if H2O_USE_LIBUV
+ uv_loop_close(test_loop);
+ free(test_loop);
+#else
+// h2o_evloop_destroy(loop);
+#endif
+ }
+
+ { /* src tests */
+ subtest("src/ssl.c", test_src__ssl_c);
+ }
+
+ return done_testing();
+}