tcpthreaded.c File Reference

#include <linux/module.h>
#include <linux/kernel.h>
#include "lwip/sys.h"
#include "lwip/api.h"
#include <rtl_sched.h>
#include <rtl_debug.h>

Include dependency graph for tcpthreaded.c:

Go to the source code of this file.

Functions
void	serve_echo (void *arg)
void	tcpecho_thread (void *arg)
int	init_module (void)
void	cleanup_module (void)

---

Function Documentation

void cleanup_module (  void   )

Definition at line 77 of file tcpthreaded.c. { printk("\n Multithreaded TCP echo server removed\n"); }

int init_module (  void   )

Definition at line 70 of file tcpthreaded.c. References NULL, sys_thread_new(), and tcpecho_thread(). { printk("\n Multithreaded TCP echo server inserted\n"); sys_thread_new(tcpecho_thread, NULL, 0); return 0; }

Here is the call graph for this function:

void serve_echo (  void *  arg  )  [static]

Definition at line 18 of file tcpthreaded.c. References data, len, netbuf_data(), netbuf_delete(), netbuf_next(), netconn_close(), netconn_delete(), netconn_recv(), newconn, NULL, sys_thread_exit(), and u16_t. Referenced by tcpecho_thread(). { struct netconn *newconn; /* Grab new connection. */ newconn = (struct netconn *) arg; //netconn_accept(conn); rtl_printf("accepted new connection %p by thread 0x%x\n", newconn,(unsigned int)pthread_self()); /* Process the new connection. */ if(newconn != NULL) { struct netbuf *buf; void *data; u16_t len; while((buf = netconn_recv(newconn)) != NULL) { do { netbuf_data(buf, &data, &len); rtl_printf("Got : %s\n", data); } while(netbuf_next(buf) >= 0); netbuf_delete(buf); } /* Close connection and discard connection identifier. */ netconn_close(newconn); netconn_delete(newconn); } sys_thread_exit(); }

Here is the call graph for this function:

void tcpecho_thread (  void *  arg  )  [static]

Definition at line 50 of file tcpthreaded.c. References conn, netconn_accept(), netconn_bind(), netconn_listen(), netconn_new(), NETCONN_TCP, NULL, serve_echo(), and sys_thread_new(). Referenced by init_module(). { struct netconn *conn; /* Create a new connection identifier. */ conn = netconn_new(NETCONN_TCP); /* Bind connection to well known port number 7. */ netconn_bind(conn, NULL, 7); /* Tell connection to go into listening mode. */ netconn_listen(conn); while(1) { /* Grab new connection. */ sys_thread_new(serve_echo, netconn_accept(conn), 0); } }

Here is the call graph for this function:

---