Compare commits

..

No commits in common. "main" and "routing" have entirely different histories.

24 changed files with 452 additions and 656 deletions

View File

@ -3,7 +3,7 @@
-include config.mk -include config.mk
LIB_ARCHIVE := $(BUILD_DIR)/lib$(LIB).a LIB := $(BUILD_DIR)/$(LIB_FILENAME)
SRCS != find '$(SRC_DIR)' -iname '*.c' SRCS != find '$(SRC_DIR)' -iname '*.c'
SRCS_H != find include -iname '*.h' SRCS_H != find include -iname '*.h'
@ -17,38 +17,54 @@ OBJS_EXAMPLE := $(SRCS_EXAMPLE:%=$(BUILD_DIR)/%.o)
DEPS := $(SRCS:%=$(BUILD_DIR)/%.d) $(SRCS_TEST:%=$(BUILD_DIR)/%.d) DEPS := $(SRCS:%=$(BUILD_DIR)/%.d) $(SRCS_TEST:%=$(BUILD_DIR)/%.d)
BIN_TEST := $(BUILD_DIR)/$(TEST_DIR)/runner BINS_TEST := $(OBJS_TEST:%.c.o=%)
BINS_EXAMPLE := $(OBJS_EXAMPLE:%.c.o=%) BINS_EXAMPLE := $(OBJS_EXAMPLE:%.c.o=%)
TARGETS_TEST := $(BINS_TEST:%=test-%)
TARGETS_MEM_TEST := $(BINS_TEST:%=test-mem-%)
TARGETS_EXAMPLE := $(BINS_EXAMPLE:%=example-%)
_CFLAGS := $(addprefix -I,$(INC_DIRS)) $(CFLAGS) -Wall -Wextra _CFLAGS := $(addprefix -I,$(INC_DIRS)) $(CFLAGS) -Wall -Wextra
.PHONY: all
all: lib
# =====COMPILATION===== # =====COMPILATION=====
# Utility used by the CI to lint # Utility used by the CI to lint
.PHONY: lib
$(LIB_ARCHIVE): $(OBJS)
ar -rcs $@ $^
.PHONY: objs .PHONY: objs
objs: $(OBJS) objs: $(OBJS)
.PHONY: lib
lib: $(LIB)
$(LIB): $(OBJS)
ar -rcs $@ $(OBJS)
$(BUILD_DIR)/$(SRC_DIR)/%.c.o: $(SRC_DIR)/%.c $(BUILD_DIR)/$(SRC_DIR)/%.c.o: $(SRC_DIR)/%.c
mkdir -p $(dir $@) mkdir -p $(dir $@)
$(CC) -c $(_CFLAGS) $< -o $@ $(CC) -c $(_CFLAGS) $< -o $@
# =====TESTING===== # =====TESTING=====
.PHONY: test .PHONY: test
test: $(BIN_TEST) test: $(TARGETS_TEST)
'./$^'
.PHONY: test-mem .PHONY: test-mem
test-mem: $(BIN_TEST) test-mem: $(TARGETS_MEM_TEST)
valgrind --tool=memcheck --error-exitcode=1 --track-origins=yes --leak-check=full './$^'
.PHONY: $(TARGETS_TEST)
$(TARGETS_TEST): test-%: %
./$^
.PHONY: $(TARGETS_MEM_TEST)
$(TARGETS_MEM_TEST): test-mem-%: %
valgrind --tool=memcheck --error-exitcode=1 --track-origins=yes --leak-check=full ./$^
.PHONY: build-test .PHONY: build-test
build-test: $(BIN_TEST) build-test: $(BINS_TEST)
$(BIN_TEST): $(OBJS_TEST) $(LIB_ARCHIVE) $(BINS_TEST): %: %.c.o $(LIB)
$(CC) -o $@ $^ $(_LDFLAGS) $(CC) \
$^ -o $@
# Along with the include directory, each test includes $(TEST_DIR) (which # Along with the include directory, each test includes $(TEST_DIR) (which
# contains the acutest.h header file), and the src directory of the module it's # contains the acutest.h header file), and the src directory of the module it's
@ -64,8 +80,8 @@ $(BUILD_DIR)/$(TEST_DIR)/%.c.o: $(TEST_DIR)/%.c
.PHONY: build-example .PHONY: build-example
build-example: $(BINS_EXAMPLE) build-example: $(BINS_EXAMPLE)
$(BINS_EXAMPLE): %: %.c.o $(LIB_ARCHIVE) $(BINS_EXAMPLE): %: %.c.o $(LIB)
$(CC) $(LDFLAGS) \ $(CC) \
$^ -o $@ $^ -o $@
# Example binaries link the resulting library # Example binaries link the resulting library
@ -76,22 +92,22 @@ $(BUILD_DIR)/$(EXAMPLE_DIR)/%.c.o: $(EXAMPLE_DIR)/%.c
# =====MAINTENANCE===== # =====MAINTENANCE=====
.PHONY: lint .PHONY: lint
lint: lint:
@ clang-format -n --Werror \ clang-format -n --Werror \
$(shell find '$(SRC_DIR)/$(LIB)' -iname '*.c') \ $(filter-out $(THIRDPARTY),$(SRCS)) \
$(shell find '$(SRC_DIR)/_include/$(LIB)' -iname '*.h') \ $(filter-out $(THIRDPARTY),$(SRCS_H)) \
$(shell find 'include/$(LIB)' -iname '*.h') $(filter-out $(THIRDPARTY),$(SRCS_H_INTERNAL))
.PHONY: fmt .PHONY: fmt
fmt: fmt:
@ clang-format -i \ clang-format -i \
$(shell find '$(SRC_DIR)/$(LIB)' -iname '*.c') \ $(filter-out $(THIRDPARTY),$(SRCS)) \
$(shell find '$(SRC_DIR)/_include/$(LIB)' -iname '*.h') \ $(filter-out $(THIRDPARTY),$(SRCS_H)) \
$(shell find 'include/$(LIB)' -iname '*.h') $(filter-out $(THIRDPARTY),$(SRCS_H_INTERNAL))
.PHONY: check .PHONY: check
check: check:
@ mkdir -p $(BUILD_DIR)/cppcheck mkdir -p $(BUILD_DIR)/cppcheck
@ cppcheck \ cppcheck \
$(addprefix -I,$(INC_DIRS)) \ $(addprefix -I,$(INC_DIRS)) \
--cppcheck-build-dir=$(BUILD_DIR)/cppcheck \ --cppcheck-build-dir=$(BUILD_DIR)/cppcheck \
--error-exitcode=1 \ --error-exitcode=1 \
@ -100,7 +116,7 @@ check:
--check-level=exhaustive \ --check-level=exhaustive \
--quiet \ --quiet \
-j$(shell nproc) \ -j$(shell nproc) \
$(shell find '$(SRC_DIR)/$(LIB)' -iname '*.c') $(filter-out $(THIRDPARTY),$(SRCS))
.PHONY: clean .PHONY: clean
clean: clean:

View File

@ -1,9 +1,10 @@
LIB = lnm LIB_FILENAME = liblnm.a
BUILD_DIR = build BUILD_DIR = build
SRC_DIR = src SRC_DIR = src
TEST_DIR = test TEST_DIR = test
EXAMPLE_DIR = example EXAMPLE_DIR = example
THIRDPARTY = src/picohttpparser.c include/picohttpparser.h
PUB_INC_DIR = include PUB_INC_DIR = include
INC_DIRS = $(PUB_INC_DIR) src/_include INC_DIRS = $(PUB_INC_DIR) src/_include

View File

@ -1,53 +0,0 @@
#include "lnm/http/res.h"
#include "lnm/log.h"
#include "lnm/http/loop.h"
#include "lnm/loop.h"
lnm_err ctx_init(void **c_ctx, void *gctx) {
*c_ctx = NULL;
return lnm_err_ok;
}
void ctx_reset(void *c_ctx) {}
void ctx_free(void *c_ctx) {}
lnm_err data_streamer(uint64_t *written, char *buf,
lnm_http_conn *conn, uint64_t offset,
uint64_t len) {
// Don't do anything, just let the application return random data stored in
// the read buffer. The goal is to benchmark the networking pipeline
*written = len;
return lnm_err_ok;
}
lnm_http_step_err step_fn(lnm_http_conn *conn) {
lnm_http_loop_ctx *ctx = conn->ctx;
uint64_t len = 1 << 30;
lnm_http_res_body_set_fn(&ctx->res, data_streamer, len);
return lnm_http_step_err_done;
}
int main() {
lnm_http_loop *hl;
lnm_http_loop_init(&hl, NULL, ctx_init,
ctx_reset,
ctx_free);
lnm_http_router *router;
lnm_http_router_init(&router);
lnm_http_route *route;
lnm_http_router_add(&route, router, lnm_http_method_get, "/");
lnm_http_route_step_append(route, step_fn, false);
lnm_http_loop_router_set(hl, router);
lnm_log_init_global();
lnm_log_register_stdout(lnm_log_level_warning);
printf("res = %i\n", lnm_http_loop_run(hl, 8080, 1, 0));
}

View File

@ -40,6 +40,7 @@ typedef struct lnm_http_req {
struct { struct {
size_t o; size_t o;
size_t len; size_t len;
regmatch_t groups[LNM_HTTP_MAX_REGEX_GROUPS];
} path; } path;
struct { struct {
size_t o; size_t o;

View File

@ -8,6 +8,7 @@
#include "lnm/http/req.h" #include "lnm/http/req.h"
#include "lnm/log.h" #include "lnm/log.h"
#include "lnm/loop.h" #include "lnm/loop.h"
#include "lnm/loop_internal.h"
static const char *section = "http"; static const char *section = "http";

View File

@ -65,9 +65,6 @@ void lnm_vlog(lnm_log_level level, const char *section, const char *fmt,
continue; continue;
} }
va_list aq;
va_copy(aq, ap);
switch (stream->type) { switch (stream->type) {
case lnm_logger_stream_type_file: case lnm_logger_stream_type_file:
fprintf(stream->ptr, "[%s][%s][%s] ", date_str, fprintf(stream->ptr, "[%s][%s][%s] ", date_str,
@ -77,7 +74,7 @@ void lnm_vlog(lnm_log_level level, const char *section, const char *fmt,
break; break;
} }
va_end(aq); va_end(ap);
} }
} }

View File

@ -59,8 +59,8 @@ uint64_t lnm_digits(uint64_t num) {
bool lnm_is_ascii(const char *s) { bool lnm_is_ascii(const char *s) {
bool valid = true; bool valid = true;
while (valid && (*s != '\0')) { while (valid && *s != '\0') {
valid = *s >= 0; valid = *s < 0;
s++; s++;
} }

View File

@ -1,9 +1,8 @@
#define TEST_NO_MAIN
#include "acutest.h"
#include "tests.h"
#include "lnm/common.h" #include "lnm/common.h"
#include "lnm/http/route.h" #include "lnm/http/route.h"
#include "test.h"
#include "lnm/http/loop.h"
void test_routing_simple() { void test_routing_simple() {
lnm_http_router *router; lnm_http_router *router;
@ -102,3 +101,11 @@ void test_routing_nest() {
lnm_http_router_free(r2); lnm_http_router_free(r2);
} }
TEST_LIST = {
{ "routing simple", test_routing_simple },
{ "routing star", test_routing_star },
{ "routing merge", test_routing_merge },
{ "routing nest", test_routing_nest },
{ NULL, NULL }
};

View File

@ -1,10 +0,0 @@
#include "acutest.h"
#include "tests.h"
TEST_LIST = {
{ "routing simple", test_routing_simple },
{ "routing star", test_routing_star },
{ "routing merge", test_routing_merge },
{ "routing nest", test_routing_nest },
{ NULL, NULL }
};

File diff suppressed because it is too large Load Diff

View File

@ -1,9 +0,0 @@
#ifndef TEST_TESTS
#define TEST_TESTS
void test_routing_simple();
void test_routing_star();
void test_routing_merge();
void test_routing_nest();
#endif