sigmasternchen/CFloor
1
0
Fork 0
mirror of https://github.com/sigmasternchen/CFloor synced 2025-03-15 20:28:56 +00:00
Code Issues Projects Releases Packages Wiki Activity Actions

connection works now, but no data is received.

Browse source
This commit is contained in:
overflowerror 2021-05-16 00:37:06 +02:00
parent 847852ac7a
commit a466e00497
1 changed files with 30 additions and 9 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

39
src/test.c
View file

@ -334,9 +334,11 @@ struct {
void stopWebserver() { void stopWebserver() {
if (serverdata.pid != 0) { if (serverdata.pid != 0) {
printf("stopping webserver...\n");
kill(serverdata.pid, SIGTERM); kill(serverdata.pid, SIGTERM);
int tmp; int tmp;
wait(&tmp); wait(&tmp);
printf("webserver stopped.\n");
} }
} }
@ -348,10 +350,12 @@ struct handler handlerGetter(struct metaData metaData, const char* host, struct
void startWebserver(handler_t handler) { void startWebserver(handler_t handler) {
printf("starting webserver...\n");
serverdata.handler = handler; serverdata.handler = handler;
struct headers headers = headers_create(); struct headers headers = headers_create();
headers_mod(&headers, "Server", "CShore 0.1"); headers_mod(&headers, "Server", "Test");
struct networkingConfig netConfig = (struct networkingConfig) { struct networkingConfig netConfig = (struct networkingConfig) {
binds: { binds: {
number: 1, number: 1,
@ -367,26 +371,42 @@ void startWebserver(handler_t handler) {
if (serverdata.pid == 0) { if (serverdata.pid == 0) {
networking_init(netConfig); networking_init(netConfig);
printf("webserver started.\n");
while(true) {
sleep(0xffff);
}
exit(0);
} else if (serverdata.pid < 0) { } else if (serverdata.pid < 0) {
printf("PANIC!\n"); printf("PANIC!\n");
exit(1); exit(1);
} }
usleep(100000); usleep(200000);
} }
FILE* sendRequest(FILE* stream, enum protocol procotol, enum method method, const char* uri, struct headers headers) { FILE* sendRequest(FILE* stream, enum protocol procotol, enum method method, const char* uri, struct headers headers) {
if (stream == NULL) { if (stream == NULL) {
int sfd = socket(AF_INET, SOCK_STREAM, 0); int sfd = socket(AF_INET, SOCK_STREAM, 0);
struct in_addr addr;
inet_aton("127.0.0.1", &addr);
struct sockaddr_in sockaddr = { struct sockaddr_in sockaddr = {
.sin_family = AF_INET, .sin_family = AF_INET,
.sin_port = LOCAL_PORT, .sin_port = htons(LOCAL_PORT)
.sin_addr = addr
}; };
if (inet_pton(AF_INET, "127.0.0.1", &sockaddr.sin_addr) < 0) {
printf("PANIC: %s\n", strerror(errno));
exit(1);
}
int fd = connect(sfd, &sockaddr, sizeof(struct sockaddr_in)); int fd = connect(sfd, &sockaddr, sizeof(struct sockaddr_in));
if (fd < 0) {
printf("PANIC: %s\n", strerror(errno));
exit(1);
}
stream = fdopen(fd, "rw"); stream = fdopen(fd, "rw");
if (stream == NULL) {
printf("PANIC: %s\n", strerror(errno));
exit(1);
}
} }
const char* protocolString = "HTTP/1.0"; const char* protocolString = "HTTP/1.0";
@ -454,10 +474,9 @@ void testIntegration() {
startWebserver(&testHandler1); startWebserver(&testHandler1);
FILE* stream = sendRequest(NULL, HTTP10, GET, "/", headers_create()); FILE* stream = sendRequest(NULL, HTTP10, GET, "/", headers_create());
printf("%s\n", readline(stream)); printf("%s\n", readline(stream));
printf("%s\n", readline(stream));
printf("%s\n", readline(stream));
printf("%s\n", readline(stream));
fclose(stream); fclose(stream);
stopWebserver(); stopWebserver();
@ -475,6 +494,8 @@ void test(const char* name, void (*testFunction)()) {
} }
int main(int argc, char** argv) { int main(int argc, char** argv) {
atexit(stopWebserver);
test("config", &testConfig); test("config", &testConfig);
test("util", &testUtil); test("util", &testUtil);
test("linked lists", &testLinkedList); test("linked lists", &testLinkedList);