mirror of
https://github.com/genodelabs/genode.git
synced 2024-12-21 22:47:50 +00:00
libports: remove old lwIP foc_panda tracing tests
These tests were used for examine lwIP on foc_panda a few years back but serve no particular purpose as of now. Issue #2121.
This commit is contained in:
Josef Söntgen
Christian Helmuth
parent
6be193cf80
commit
9013ca5364
@ -1,121 +0,0 @@
|
|||||||
#
|
|
||||||
# \brief Test for using the lwIP TCP/IP stack
|
|
||||||
# \author Norman Feske
|
|
||||||
# \date 2011-05-22
|
|
||||||
#
|
|
||||||
# This test case executes a small HTTP server on Genode running on qemu. When
|
|
||||||
# the HTTP server is up, a HTTP request to the server is performed using
|
|
||||||
# 'lynx'. The response is validated against a known pattern.
|
|
||||||
#
|
|
||||||
# The test uses qemu's "-net user" option, redirecting Genode's port 80 to the
|
|
||||||
# host's port 5555. Consequently, it cannot be executed on non-qemu test
|
|
||||||
# environments (i.e., the test won't work with the Linux version of Genode).
|
|
||||||
#
|
|
||||||
# Please make sure to include a nic driver in your build configuration. E.g.,
|
|
||||||
# on the x86 platform, you may enable the 'dde_ipxe' repository.
|
|
||||||
#
|
|
||||||
|
|
||||||
#
|
|
||||||
# TODO: Add support for Linux via user-level networking (using the
|
|
||||||
# tun/tap proxy driver at os/src/drivers/nic/linux)
|
|
||||||
#
|
|
||||||
if {[have_spec linux]} {
|
|
||||||
puts "Run script does not support Linux."; exit 0 }
|
|
||||||
|
|
||||||
requires_installation_of lynx
|
|
||||||
|
|
||||||
#
|
|
||||||
# Build
|
|
||||||
#
|
|
||||||
|
|
||||||
set build_components {
|
|
||||||
core init
|
|
||||||
drivers/timer drivers/nic
|
|
||||||
test/lwip/http_srv_tracing
|
|
||||||
}
|
|
||||||
|
|
||||||
source ${genode_dir}/repos/base/run/platform_drv.inc
|
|
||||||
append_platform_drv_build_components
|
|
||||||
|
|
||||||
build $build_components
|
|
||||||
|
|
||||||
create_boot_directory
|
|
||||||
|
|
||||||
#
|
|
||||||
# Generate config
|
|
||||||
#
|
|
||||||
|
|
||||||
set config {
|
|
||||||
<config verbose="yes">
|
|
||||||
<parent-provides>
|
|
||||||
<service name="ROM"/>
|
|
||||||
<service name="RAM"/>
|
|
||||||
<service name="IRQ"/>
|
|
||||||
<service name="IO_MEM"/>
|
|
||||||
<service name="IO_PORT"/>
|
|
||||||
<service name="PD"/>
|
|
||||||
<service name="RM"/>
|
|
||||||
<service name="CPU"/>
|
|
||||||
<service name="LOG"/>
|
|
||||||
</parent-provides>
|
|
||||||
<default-route>
|
|
||||||
<any-service> <parent/> <any-child/> </any-service>
|
|
||||||
</default-route>
|
|
||||||
<start name="timer">
|
|
||||||
<resource name="RAM" quantum="1M"/>
|
|
||||||
<provides> <service name="Timer"/> </provides>
|
|
||||||
</start>
|
|
||||||
<start name="nic_drv">
|
|
||||||
<resource name="RAM" quantum="4M"/>
|
|
||||||
<provides> <service name="Nic"/> </provides>
|
|
||||||
</start>
|
|
||||||
<start name="test-lwip_httpsrv_tracing">
|
|
||||||
<resource name="RAM" quantum="64M"/>
|
|
||||||
<config>
|
|
||||||
<libc stdout="/dev/log" stderr="/dev/log">
|
|
||||||
<vfs> <dir name="dev"> <log/> </dir> </vfs>
|
|
||||||
</libc>
|
|
||||||
</config>
|
|
||||||
</start>}
|
|
||||||
|
|
||||||
append_platform_drv_config
|
|
||||||
|
|
||||||
append config {
|
|
||||||
</config>
|
|
||||||
}
|
|
||||||
|
|
||||||
install_config $config
|
|
||||||
|
|
||||||
#
|
|
||||||
# Boot modules
|
|
||||||
#
|
|
||||||
|
|
||||||
# generic modules
|
|
||||||
set boot_modules {
|
|
||||||
core init timer
|
|
||||||
nic_drv
|
|
||||||
ld.lib.so libc.lib.so lwip.lib.so
|
|
||||||
test-lwip_httpsrv_tracing
|
|
||||||
}
|
|
||||||
|
|
||||||
# platform-specific modules
|
|
||||||
append_platform_drv_boot_modules
|
|
||||||
|
|
||||||
build_boot_image $boot_modules
|
|
||||||
|
|
||||||
#
|
|
||||||
# Execute test case
|
|
||||||
#
|
|
||||||
|
|
||||||
# qemu config
|
|
||||||
append qemu_args " -m 128 -nographic -serial mon:stdio "
|
|
||||||
|
|
||||||
append_if [have_spec x86] qemu_args " -net nic,model=e1000 "
|
|
||||||
append_if [have_spec lan9118] qemu_args " -net nic,model=lan9118 "
|
|
||||||
|
|
||||||
append qemu_args " -net user -redir tcp:5555::80 "
|
|
||||||
|
|
||||||
#run_genode_until {.*Sent response.*} 60
|
|
||||||
run_genode_until forever
|
|
||||||
|
|
||||||
# vi: set ft=tcl :
|
|
||||||
@ -1,80 +0,0 @@
|
|||||||
# vi: set ft=tcl :
|
|
||||||
assert_spec foc
|
|
||||||
assert_spec panda
|
|
||||||
|
|
||||||
#
|
|
||||||
# Build
|
|
||||||
#
|
|
||||||
build {
|
|
||||||
core
|
|
||||||
init
|
|
||||||
drivers/timer
|
|
||||||
drivers/gpio
|
|
||||||
drivers/usb
|
|
||||||
test/lwip/http_srv_tracing_nonblocking
|
|
||||||
}
|
|
||||||
|
|
||||||
create_boot_directory
|
|
||||||
|
|
||||||
#
|
|
||||||
# Config
|
|
||||||
#
|
|
||||||
set config {
|
|
||||||
<config prio_levels="2">
|
|
||||||
<parent-provides>
|
|
||||||
<service name="ROM"/>
|
|
||||||
<service name="RAM"/>
|
|
||||||
<service name="IRQ"/>
|
|
||||||
<service name="IO_MEM"/>
|
|
||||||
<service name="IO_PORT"/>
|
|
||||||
<service name="PD"/>
|
|
||||||
<service name="RM"/>
|
|
||||||
<service name="CPU"/>
|
|
||||||
<service name="LOG"/>
|
|
||||||
</parent-provides>
|
|
||||||
<default-route>
|
|
||||||
<any-service> <parent/> <any-child/> </any-service>
|
|
||||||
</default-route>
|
|
||||||
<start name="timer">
|
|
||||||
<resource name="RAM" quantum="1M"/>
|
|
||||||
<provides><service name="Timer"/></provides>
|
|
||||||
</start>
|
|
||||||
<start name="gpio_drv">
|
|
||||||
<resource name="RAM" quantum="4M"/>
|
|
||||||
<provides><service name="Gpio"/></provides>
|
|
||||||
<config/>
|
|
||||||
</start>
|
|
||||||
<start name="usb_drv">
|
|
||||||
<resource name="RAM" quantum="6M"/>
|
|
||||||
<provides>
|
|
||||||
<service name="Input"/>
|
|
||||||
<service name="Nic"/>
|
|
||||||
</provides>
|
|
||||||
<config ehci="yes">
|
|
||||||
<hid/>
|
|
||||||
<nic mac="02:00:00:00:01:01" />
|
|
||||||
</config>
|
|
||||||
</start>
|
|
||||||
|
|
||||||
<start name="test-lwip_httpsrv_tracing_nob">
|
|
||||||
<resource name="RAM" quantum="64M"/>
|
|
||||||
</start>
|
|
||||||
</config>}
|
|
||||||
|
|
||||||
install_config $config
|
|
||||||
|
|
||||||
#
|
|
||||||
# Boot modules
|
|
||||||
#
|
|
||||||
set boot_modules {
|
|
||||||
core
|
|
||||||
init
|
|
||||||
timer
|
|
||||||
usb_drv
|
|
||||||
gpio_drv
|
|
||||||
test-lwip_httpsrv_tracing_nob
|
|
||||||
ld.lib.so libc.lib.so lwip.lib.so
|
|
||||||
}
|
|
||||||
|
|
||||||
build_boot_image [join $boot_modules " "]
|
|
||||||
|
|
||||||
@ -1,85 +0,0 @@
|
|||||||
# vi: set ft=tcl :
|
|
||||||
assert_spec foc
|
|
||||||
assert_spec panda
|
|
||||||
|
|
||||||
#
|
|
||||||
# Build
|
|
||||||
#
|
|
||||||
build {
|
|
||||||
core
|
|
||||||
init
|
|
||||||
drivers/timer
|
|
||||||
drivers/usb
|
|
||||||
drivers/gpio
|
|
||||||
test/lwip/http_srv_tracing
|
|
||||||
}
|
|
||||||
|
|
||||||
create_boot_directory
|
|
||||||
|
|
||||||
#
|
|
||||||
# Config
|
|
||||||
#
|
|
||||||
set config {
|
|
||||||
<config prio_levels="2">
|
|
||||||
<parent-provides>
|
|
||||||
<service name="ROM"/>
|
|
||||||
<service name="RAM"/>
|
|
||||||
<service name="IRQ"/>
|
|
||||||
<service name="IO_MEM"/>
|
|
||||||
<service name="IO_PORT"/>
|
|
||||||
<service name="PD"/>
|
|
||||||
<service name="RM"/>
|
|
||||||
<service name="CPU"/>
|
|
||||||
<service name="LOG"/>
|
|
||||||
</parent-provides>
|
|
||||||
<default-route>
|
|
||||||
<any-service> <parent/> <any-child/> </any-service>
|
|
||||||
</default-route>
|
|
||||||
<start name="timer">
|
|
||||||
<resource name="RAM" quantum="1M"/>
|
|
||||||
<provides><service name="Timer"/></provides>
|
|
||||||
</start>
|
|
||||||
<start name="gpio_drv">
|
|
||||||
<resource name="RAM" quantum="4M"/>
|
|
||||||
<provides><service name="Gpio"/></provides>
|
|
||||||
<config/>
|
|
||||||
</start>
|
|
||||||
<start name="usb_drv">
|
|
||||||
<resource name="RAM" quantum="12M"/>
|
|
||||||
<provides>
|
|
||||||
<service name="Input"/>
|
|
||||||
<service name="Nic"/>
|
|
||||||
</provides>
|
|
||||||
<config ehci="yes">
|
|
||||||
<hid/>
|
|
||||||
<nic mac="02:00:00:00:01:01" />
|
|
||||||
</config>
|
|
||||||
</start>
|
|
||||||
|
|
||||||
<start name="test-lwip_httpsrv_tracing">
|
|
||||||
<resource name="RAM" quantum="64M"/>
|
|
||||||
<config>
|
|
||||||
<libc stdout="/dev/log" stderr="/dev/log">
|
|
||||||
<vfs> <dir name="dev"> <log/> </dir> </vfs>
|
|
||||||
</libc>
|
|
||||||
</config>
|
|
||||||
</start>
|
|
||||||
</config>}
|
|
||||||
|
|
||||||
install_config $config
|
|
||||||
|
|
||||||
#
|
|
||||||
# Boot modules
|
|
||||||
#
|
|
||||||
set boot_modules {
|
|
||||||
core
|
|
||||||
init
|
|
||||||
timer
|
|
||||||
usb_drv
|
|
||||||
gpio_drv
|
|
||||||
test-lwip_httpsrv_tracing
|
|
||||||
ld.lib.so libc.lib.so lwip.lib.so
|
|
||||||
}
|
|
||||||
|
|
||||||
build_boot_image [join $boot_modules " "]
|
|
||||||
|
|
||||||
@ -1,147 +0,0 @@
|
|||||||
/*
|
|
||||||
* \brief Minimal HTTP server lwIP demonstration
|
|
||||||
* \author lwIP Team
|
|
||||||
* \author Stefan Kalkowski
|
|
||||||
* \date 2009-10-23
|
|
||||||
*
|
|
||||||
* This small example shows how to use the LwIP in Genode directly.
|
|
||||||
* If you simply want to use LwIP's socket API, you might use
|
|
||||||
* Genode's libc together with its LwIP backend, especially useful
|
|
||||||
* when porting legacy code.
|
|
||||||
*/
|
|
||||||
|
|
||||||
/*
|
|
||||||
* Copyright (C) 2009-2013 Genode Labs GmbH
|
|
||||||
*
|
|
||||||
* This file is part of the Genode OS framework, which is distributed
|
|
||||||
* under the terms of the GNU General Public License version 2.
|
|
||||||
*/
|
|
||||||
|
|
||||||
/* Genode includes */
|
|
||||||
#include <base/log.h>
|
|
||||||
#include <base/thread.h>
|
|
||||||
#include <util/string.h>
|
|
||||||
#include <nic/packet_allocator.h>
|
|
||||||
|
|
||||||
/* LwIP includes */
|
|
||||||
extern "C" {
|
|
||||||
#include <lwip/sockets.h>
|
|
||||||
#include <lwip/api.h>
|
|
||||||
}
|
|
||||||
|
|
||||||
#include <lwip/genode.h>
|
|
||||||
|
|
||||||
namespace Fiasco {
|
|
||||||
#include <l4/sys/ktrace.h>
|
|
||||||
}
|
|
||||||
|
|
||||||
|
|
||||||
//enum { FILE_SIZE = 1UL }; /* 1 Byte */
|
|
||||||
enum { FILE_SIZE = 3072UL }; /* 3 KiB */
|
|
||||||
//enum { FILE_SIZE = 5120UL }; /* 5 KiB */
|
|
||||||
//enum { FILE_SIZE = 8388608UL }; /* 8 MiB */
|
|
||||||
//enum { FILE_SIZE = 2097152UL }; /* 2 MiB */
|
|
||||||
//enum { FILE_SIZE = 16777216UL }; /* 16 MiB */
|
|
||||||
//enum { FILE_SIZE = 33554432UL }; /* 32 MiB */
|
|
||||||
|
|
||||||
const static char http_html_hdr[] =
|
|
||||||
"HTTP/1.0 200 OK\r\nContent-type: text/html\r\n\r\n"; /* HTTP response header */
|
|
||||||
|
|
||||||
static char http_file_data[FILE_SIZE];
|
|
||||||
|
|
||||||
|
|
||||||
/**
|
|
||||||
* Handle a single client's request.
|
|
||||||
*
|
|
||||||
* \param conn socket connected to the client
|
|
||||||
*/
|
|
||||||
void http_server_serve(int conn) {
|
|
||||||
char buf[1024];
|
|
||||||
ssize_t buflen;
|
|
||||||
|
|
||||||
/* Read the data from the port, blocking if nothing yet there.
|
|
||||||
We assume the request (the part we care about) is in one packet */
|
|
||||||
buflen = lwip_recv(conn, buf, 1024, 0);
|
|
||||||
|
|
||||||
/* Ignore all receive errors */
|
|
||||||
if (buflen > 0) {
|
|
||||||
|
|
||||||
/* Is this an HTTP GET command? (only check the first 5 chars, since
|
|
||||||
there are other formats for GET, and we're keeping it very simple)*/
|
|
||||||
if (buflen >= 5 &&
|
|
||||||
buf[0] == 'G' &&
|
|
||||||
buf[1] == 'E' &&
|
|
||||||
buf[2] == 'T' &&
|
|
||||||
buf[3] == ' ' &&
|
|
||||||
buf[4] == '/' ) {
|
|
||||||
|
|
||||||
/* Send http header */
|
|
||||||
//Fiasco::fiasco_tbuf_log_3val(">> lwip_send", Genode::strlen(http_html_hdr), 0, 0);
|
|
||||||
lwip_send(conn, http_html_hdr, Genode::strlen(http_html_hdr), 0);
|
|
||||||
//Fiasco::fiasco_tbuf_log("<< lwip_send");
|
|
||||||
|
|
||||||
/*
|
|
||||||
unsigned int val = 0xdeadbeef;
|
|
||||||
Fiasco::fiasco_tbuf_log_3val(">> lwip_send", sizeof (unsigned int), 0, 0);
|
|
||||||
lwip_send(conn, &val, sizeof (unsigned int), 0);
|
|
||||||
Fiasco::fiasco_tbuf_log("<< lwip_send");
|
|
||||||
*/
|
|
||||||
|
|
||||||
lwip_send(conn, http_file_data, sizeof (http_file_data), 0);
|
|
||||||
}
|
|
||||||
}
|
|
||||||
}
|
|
||||||
|
|
||||||
#include <l4/sys/kdebug.h>
|
|
||||||
|
|
||||||
int main()
|
|
||||||
{
|
|
||||||
enum { BUF_SIZE = Nic::Packet_allocator::DEFAULT_PACKET_SIZE * 128 };
|
|
||||||
|
|
||||||
int s;
|
|
||||||
|
|
||||||
lwip_tcpip_init();
|
|
||||||
|
|
||||||
/* Initialize network stack and do DHCP */
|
|
||||||
if (lwip_nic_init(0, 0, 0, BUF_SIZE, BUF_SIZE)) {
|
|
||||||
Genode::error("got no IP address!");
|
|
||||||
return -1;
|
|
||||||
}
|
|
||||||
|
|
||||||
Genode::log("Create new socket ...");
|
|
||||||
if((s = lwip_socket(AF_INET, SOCK_STREAM, 0)) < 0) {
|
|
||||||
Genode::error("no socket available!");
|
|
||||||
return -1;
|
|
||||||
}
|
|
||||||
|
|
||||||
Genode::log("Now, I will bind ...");
|
|
||||||
struct sockaddr_in in_addr;
|
|
||||||
in_addr.sin_family = AF_INET;
|
|
||||||
in_addr.sin_port = htons(80);
|
|
||||||
in_addr.sin_addr.s_addr = INADDR_ANY;
|
|
||||||
if(lwip_bind(s, (struct sockaddr*)&in_addr, sizeof(in_addr))) {
|
|
||||||
Genode::error("bind failed!");
|
|
||||||
return -1;
|
|
||||||
}
|
|
||||||
|
|
||||||
Genode::log("Now, I will listen ...");
|
|
||||||
if(lwip_listen(s, 5)) {
|
|
||||||
Genode::error("listen failed!");
|
|
||||||
return -1;
|
|
||||||
}
|
|
||||||
|
|
||||||
Genode::log("Start the server loop ...");
|
|
||||||
while(true) {
|
|
||||||
struct sockaddr addr;
|
|
||||||
socklen_t len = sizeof(addr);
|
|
||||||
int client = lwip_accept(s, &addr, &len);
|
|
||||||
if(client < 0) {
|
|
||||||
Genode::warning("invalid socket from accept!");
|
|
||||||
continue;
|
|
||||||
}
|
|
||||||
http_server_serve(client);
|
|
||||||
lwip_close(client);
|
|
||||||
}
|
|
||||||
|
|
||||||
return 0;
|
|
||||||
}
|
|
||||||
@ -1,6 +0,0 @@
|
|||||||
TARGET = test-lwip_httpsrv_tracing
|
|
||||||
LIBS = lwip libc
|
|
||||||
SRC_CC = main.cc
|
|
||||||
REQUIRES = foc
|
|
||||||
|
|
||||||
INC_DIR += $(REP_DIR)/src/lib/lwip/include
|
|
||||||
@ -1,218 +0,0 @@
|
|||||||
/*
|
|
||||||
* \brief Minimal HTTP server lwIP demonstration
|
|
||||||
* \author lwIP Team
|
|
||||||
* \author Stefan Kalkowski
|
|
||||||
* \date 2009-10-23
|
|
||||||
*
|
|
||||||
* This small example shows how to use the LwIP in Genode directly.
|
|
||||||
* If you simply want to use LwIP's socket API, you might use
|
|
||||||
* Genode's libc together with its LwIP backend, especially useful
|
|
||||||
* when porting legacy code.
|
|
||||||
*/
|
|
||||||
|
|
||||||
/*
|
|
||||||
* Copyright (C) 2009-2013 Genode Labs GmbH
|
|
||||||
*
|
|
||||||
* This file is part of the Genode OS framework, which is distributed
|
|
||||||
* under the terms of the GNU General Public License version 2.
|
|
||||||
*/
|
|
||||||
|
|
||||||
/* Genode includes */
|
|
||||||
#include <base/log.h>
|
|
||||||
#include <base/thread.h>
|
|
||||||
#include <util/string.h>
|
|
||||||
#include <nic/packet_allocator.h>
|
|
||||||
|
|
||||||
/* LwIP includes */
|
|
||||||
extern "C" {
|
|
||||||
#include <lwip/sockets.h>
|
|
||||||
#include <lwip/api.h>
|
|
||||||
}
|
|
||||||
|
|
||||||
#include <lwip/genode.h>
|
|
||||||
#include <errno.h>
|
|
||||||
|
|
||||||
//enum { FILE_SIZE = 8388608UL }; /* 8 MiB */
|
|
||||||
//enum { FILE_SIZE = 2097152UL }; /* 2 MiB */
|
|
||||||
//enum { FILE_SIZE = 16777216UL }; /* 16 MiB */
|
|
||||||
//enum { FILE_SIZE = 33554432UL }; /* 32 MiB */
|
|
||||||
enum { FILE_SIZE = 5120UL }; /* 5 KiB */
|
|
||||||
|
|
||||||
enum { MAX_CLIENTS = 1024 };
|
|
||||||
enum { TRY_TO_CONNECT = 100 };
|
|
||||||
|
|
||||||
const static char http_html_hdr[] =
|
|
||||||
"HTTP/1.0 200 OK\r\nContent-type: text/html\r\n\r\n"; /* HTTP response header */
|
|
||||||
|
|
||||||
static char http_file_data[FILE_SIZE];
|
|
||||||
|
|
||||||
struct clients {
|
|
||||||
int fd;
|
|
||||||
struct sockaddr addr;
|
|
||||||
socklen_t len;
|
|
||||||
};
|
|
||||||
|
|
||||||
static struct clients c[MAX_CLIENTS];
|
|
||||||
|
|
||||||
/**
|
|
||||||
* Handle a single client's request.
|
|
||||||
*
|
|
||||||
* \param conn socket connected to the client
|
|
||||||
*/
|
|
||||||
void http_server_serve(int conn) {
|
|
||||||
char buf[1024];
|
|
||||||
ssize_t buflen;
|
|
||||||
|
|
||||||
/* Read the data from the port, blocking if nothing yet there.
|
|
||||||
We assume the request (the part we care about) is in one packet */
|
|
||||||
buflen = lwip_recv(conn, buf, 1024, 0);
|
|
||||||
Genode::log("Packet received!");
|
|
||||||
|
|
||||||
/* Ignore all receive errors */
|
|
||||||
if (buflen > 0) {
|
|
||||||
|
|
||||||
/* Is this an HTTP GET command? (only check the first 5 chars, since
|
|
||||||
there are other formats for GET, and we're keeping it very simple)*/
|
|
||||||
if (buflen >= 5 &&
|
|
||||||
buf[0] == 'G' &&
|
|
||||||
buf[1] == 'E' &&
|
|
||||||
buf[2] == 'T' &&
|
|
||||||
buf[3] == ' ' &&
|
|
||||||
buf[4] == '/' ) {
|
|
||||||
|
|
||||||
Genode::log("Will send response");
|
|
||||||
|
|
||||||
/* Send http header */
|
|
||||||
lwip_send(conn, http_html_hdr, Genode::strlen(http_html_hdr), 0);
|
|
||||||
lwip_send(conn, http_file_data, FILE_SIZE, 0);
|
|
||||||
}
|
|
||||||
}
|
|
||||||
}
|
|
||||||
|
|
||||||
#include <l4/sys/kdebug.h>
|
|
||||||
|
|
||||||
int main()
|
|
||||||
{
|
|
||||||
enum { BUF_SIZE = Nic::Packet_allocator::DEFAULT_PACKET_SIZE * 128 };
|
|
||||||
|
|
||||||
int s, c_num;
|
|
||||||
|
|
||||||
fd_set rs, ws, es;
|
|
||||||
|
|
||||||
lwip_tcpip_init();
|
|
||||||
|
|
||||||
/* Initialize network stack and do DHCP */
|
|
||||||
if (lwip_nic_init(0, 0, 0, BUF_SIZE, BUF_SIZE)) {
|
|
||||||
Genode::error("got no IP address!");
|
|
||||||
return -1;
|
|
||||||
}
|
|
||||||
|
|
||||||
Genode::log("Create new socket ...");
|
|
||||||
if((s = lwip_socket(AF_INET, SOCK_STREAM, 0)) < 0) {
|
|
||||||
Genode::error("no socket available!");
|
|
||||||
return -1;
|
|
||||||
}
|
|
||||||
|
|
||||||
Genode::log("Now, I will bind to port 80 ...");
|
|
||||||
struct sockaddr_in in_addr;
|
|
||||||
in_addr.sin_family = AF_INET;
|
|
||||||
in_addr.sin_port = htons(80);
|
|
||||||
in_addr.sin_addr.s_addr = INADDR_ANY;
|
|
||||||
memset(&(in_addr.sin_zero), '\0', 8);
|
|
||||||
|
|
||||||
if (lwip_bind(s, (struct sockaddr*)&in_addr, sizeof(in_addr))) {
|
|
||||||
Genode::error("bind failed!");
|
|
||||||
return -1;
|
|
||||||
}
|
|
||||||
|
|
||||||
Genode::log("Now, I will listen ...");
|
|
||||||
if (lwip_listen(s, 5)) {
|
|
||||||
Genode::error("listen failed!");
|
|
||||||
return -1;
|
|
||||||
}
|
|
||||||
|
|
||||||
Genode::log("Make socket non-blocking ...");
|
|
||||||
if (lwip_fcntl(s, F_SETFL, O_NONBLOCK)) {
|
|
||||||
Genode::error("fcntl() failed!");
|
|
||||||
return -1;
|
|
||||||
}
|
|
||||||
|
|
||||||
struct timeval timeout;
|
|
||||||
timeout.tv_sec = 1;
|
|
||||||
timeout.tv_usec = 0;
|
|
||||||
|
|
||||||
for (int i = 0; i < MAX_CLIENTS; i++)
|
|
||||||
c[i].fd = -1;
|
|
||||||
|
|
||||||
c_num = 0;
|
|
||||||
|
|
||||||
Genode::log("Start the server loop ...");
|
|
||||||
while(true) {
|
|
||||||
/* clear fds */
|
|
||||||
FD_ZERO(&rs);
|
|
||||||
FD_ZERO(&ws);
|
|
||||||
FD_ZERO(&es);
|
|
||||||
|
|
||||||
/* set fds */
|
|
||||||
FD_SET(s, &rs);
|
|
||||||
for (int i = 0, num = c_num; i < MAX_CLIENTS; i++) {
|
|
||||||
if (c[i].fd != -1) {
|
|
||||||
FD_SET(c[i].fd, &rs);
|
|
||||||
|
|
||||||
if (num > 0)
|
|
||||||
num--;
|
|
||||||
else
|
|
||||||
break;
|
|
||||||
}
|
|
||||||
}
|
|
||||||
|
|
||||||
int ready = lwip_select(c_num + 1, &rs, &ws, &es, &timeout);
|
|
||||||
|
|
||||||
if (ready > 0) {
|
|
||||||
if (FD_ISSET(s, &rs)) {
|
|
||||||
for (int i = 0; i < TRY_TO_CONNECT; i++) {
|
|
||||||
int *fd = &c[c_num].fd;
|
|
||||||
struct sockaddr *addr = &c[c_num].addr;
|
|
||||||
socklen_t *len = &c[c_num].len;
|
|
||||||
|
|
||||||
*fd = lwip_accept(s, addr, len);
|
|
||||||
|
|
||||||
if (*fd < 0) {
|
|
||||||
/* there is currently nobody waiting */
|
|
||||||
if (errno == EWOULDBLOCK)
|
|
||||||
break;
|
|
||||||
|
|
||||||
continue;
|
|
||||||
}
|
|
||||||
if (lwip_fcntl(*fd, F_SETFL, O_NONBLOCK)) {
|
|
||||||
lwip_close(*fd);
|
|
||||||
continue;
|
|
||||||
}
|
|
||||||
|
|
||||||
c_num++;
|
|
||||||
}
|
|
||||||
}
|
|
||||||
|
|
||||||
for (int i = 0, num = c_num; i < MAX_CLIENTS; i++) {
|
|
||||||
int *fd = &c[i].fd;
|
|
||||||
|
|
||||||
if (*fd != -1) {
|
|
||||||
if (FD_ISSET(*fd, &rs)) {
|
|
||||||
http_server_serve(*fd);
|
|
||||||
lwip_close(*fd);
|
|
||||||
|
|
||||||
c_num--;
|
|
||||||
*fd = -1;
|
|
||||||
}
|
|
||||||
|
|
||||||
if (num > 0)
|
|
||||||
num--;
|
|
||||||
else
|
|
||||||
break;
|
|
||||||
}
|
|
||||||
}
|
|
||||||
}
|
|
||||||
}
|
|
||||||
|
|
||||||
return 0;
|
|
||||||
}
|
|
||||||
@ -1,6 +0,0 @@
|
|||||||
TARGET = test-lwip_httpsrv_tracing_nob
|
|
||||||
LIBS = lwip libc
|
|
||||||
SRC_CC = main.cc
|
|
||||||
REQUIRES = foc
|
|
||||||
|
|
||||||
INC_DIR += $(REP_DIR)/src/lib/lwip/include
|
|
||||||
Loading…
Reference in New Issue
Block a user