LRSD stephane / Mbed 2 deprecated WEBserver0-lrsd

Important changes to repositories hosted on mbed.com

Mbed hosted mercurial repositories are deprecated and are due to be permanently deleted in July 2026.

To keep a copy of this software download the repository Zip archive or clone locally using Mercurial.

It is also possible to export all your personal repositories from the account settings page.

Dependencies:   mbed

lwip/Core/TCPConnection.cpp@0:441400ffd086, 2011-09-02 (annotated)

Committer:
geiineuville
Date:
Fri Sep 02 08:36:24 2011 +0000
Revision:
0:441400ffd086
V0

Who changed what in which revision?

UserRevisionLine numberNew contents of line
geiineuville 0:441400ffd086 1 #include "lwip/arch.h"
geiineuville 0:441400ffd086 2
geiineuville 0:441400ffd086 3 #include "dns.h"
geiineuville 0:441400ffd086 4
geiineuville 0:441400ffd086 5 #include "TCPConnection.h"
geiineuville 0:441400ffd086 6 #include "TCPListener.h"
geiineuville 0:441400ffd086 7 #include "NetServer.h"
geiineuville 0:441400ffd086 8
geiineuville 0:441400ffd086 9 using namespace std;
geiineuville 0:441400ffd086 10 using namespace mbed;
geiineuville 0:441400ffd086 11
geiineuville 0:441400ffd086 12 void TCPConnection::dnsreply_callback(const char *name, struct ip_addr *ipaddr, void *arg) {
geiineuville 0:441400ffd086 13 TCPConnection *connection = static_cast<TCPConnection *>(arg);
geiineuville 0:441400ffd086 14 if(connection) {
geiineuville 0:441400ffd086 15 (connection->dnsreply)(name, ipaddr);
geiineuville 0:441400ffd086 16 }
geiineuville 0:441400ffd086 17 }
geiineuville 0:441400ffd086 18
geiineuville 0:441400ffd086 19 err_t TCPConnection::connected_callback(void *arg, struct tcp_pcb *pcb, err_t err) {
geiineuville 0:441400ffd086 20 TCPConnection *connection = static_cast<TCPConnection *>(arg);
geiineuville 0:441400ffd086 21 LWIP_UNUSED_ARG(pcb);
geiineuville 0:441400ffd086 22 if(connection) {
geiineuville 0:441400ffd086 23 return (connection->connected)(err);
geiineuville 0:441400ffd086 24 }
geiineuville 0:441400ffd086 25 return ERR_OK;
geiineuville 0:441400ffd086 26 }
geiineuville 0:441400ffd086 27
geiineuville 0:441400ffd086 28 err_t TCPConnection::sent_callback(void *arg, struct tcp_pcb *pcb, u16_t space) {
geiineuville 0:441400ffd086 29 TCPConnection *connection = static_cast<TCPConnection *>(arg);
geiineuville 0:441400ffd086 30 LWIP_UNUSED_ARG(pcb);
geiineuville 0:441400ffd086 31 if(connection) {
geiineuville 0:441400ffd086 32 return (connection->sent)(space);
geiineuville 0:441400ffd086 33 }
geiineuville 0:441400ffd086 34 return ERR_OK;
geiineuville 0:441400ffd086 35 }
geiineuville 0:441400ffd086 36
geiineuville 0:441400ffd086 37 err_t TCPConnection::recv_callback(void *arg, struct tcp_pcb *pcb, struct pbuf *p, err_t err) {
geiineuville 0:441400ffd086 38 TCPConnection *connection = static_cast<TCPConnection *>(arg);
geiineuville 0:441400ffd086 39 LWIP_UNUSED_ARG(pcb);
geiineuville 0:441400ffd086 40 if(connection) {
geiineuville 0:441400ffd086 41 return (connection->recv)(p, err);
geiineuville 0:441400ffd086 42 }
geiineuville 0:441400ffd086 43 return ERR_OK;
geiineuville 0:441400ffd086 44 }
geiineuville 0:441400ffd086 45
geiineuville 0:441400ffd086 46 err_t TCPConnection::poll_callback(void *arg, struct tcp_pcb *pcb) {
geiineuville 0:441400ffd086 47 TCPConnection *connection = static_cast<TCPConnection *>(arg);
geiineuville 0:441400ffd086 48 LWIP_UNUSED_ARG(pcb);
geiineuville 0:441400ffd086 49 if(connection) {
geiineuville 0:441400ffd086 50 return (connection->poll)();
geiineuville 0:441400ffd086 51 }
geiineuville 0:441400ffd086 52 return ERR_OK;
geiineuville 0:441400ffd086 53 }
geiineuville 0:441400ffd086 54
geiineuville 0:441400ffd086 55 void TCPConnection::error_callback(void *arg, err_t erra) {
geiineuville 0:441400ffd086 56 TCPConnection *connection = static_cast<TCPConnection *>(arg);
geiineuville 0:441400ffd086 57 if(connection) {
geiineuville 0:441400ffd086 58 (connection->err)(erra);
geiineuville 0:441400ffd086 59 }
geiineuville 0:441400ffd086 60 }
geiineuville 0:441400ffd086 61
geiineuville 0:441400ffd086 62 TCPConnection::TCPConnection() : _parent(NULL), _port(0) {
geiineuville 0:441400ffd086 63 }
geiineuville 0:441400ffd086 64
geiineuville 0:441400ffd086 65 TCPConnection::TCPConnection(struct ip_addr ip, u16_t port) : _parent(NULL) {
geiineuville 0:441400ffd086 66 this->_ipaddr = ip;
geiineuville 0:441400ffd086 67 this->_port = port;
geiineuville 0:441400ffd086 68 }
geiineuville 0:441400ffd086 69
geiineuville 0:441400ffd086 70 TCPConnection::TCPConnection(TCPListener *parent, struct tcp_pcb *pcb)
geiineuville 0:441400ffd086 71 : TCPItem(pcb), _parent(parent), _ipaddr(pcb->remote_ip), _port(pcb->remote_port) {
geiineuville 0:441400ffd086 72 tcp_arg(this->_pcb, static_cast<void *>(this));
geiineuville 0:441400ffd086 73 connected(ERR_OK);
geiineuville 0:441400ffd086 74 }
geiineuville 0:441400ffd086 75
geiineuville 0:441400ffd086 76 TCPConnection::~TCPConnection() {
geiineuville 0:441400ffd086 77 }
geiineuville 0:441400ffd086 78
geiineuville 0:441400ffd086 79 err_t TCPConnection::write(void *msg, u16_t len, u8_t flags) const {
geiineuville 0:441400ffd086 80 return tcp_write(this->_pcb, msg, len, flags);
geiineuville 0:441400ffd086 81 }
geiineuville 0:441400ffd086 82
geiineuville 0:441400ffd086 83 void TCPConnection::recved(u32_t len) const {
geiineuville 0:441400ffd086 84 tcp_recved(this->_pcb, len);
geiineuville 0:441400ffd086 85 }
geiineuville 0:441400ffd086 86
geiineuville 0:441400ffd086 87 err_t TCPConnection::connected(err_t err) {
geiineuville 0:441400ffd086 88 tcp_recv(this->_pcb, TCPConnection::recv_callback);
geiineuville 0:441400ffd086 89 tcp_sent(this->_pcb, TCPConnection::sent_callback);
geiineuville 0:441400ffd086 90 tcp_poll(this->_pcb, TCPConnection::poll_callback, 1); // addjust time (in twice a sec)
geiineuville 0:441400ffd086 91 tcp_err(this->_pcb, TCPConnection::error_callback);
geiineuville 0:441400ffd086 92 return ERR_OK;
geiineuville 0:441400ffd086 93 }
geiineuville 0:441400ffd086 94
geiineuville 0:441400ffd086 95 void TCPConnection::connect() {
geiineuville 0:441400ffd086 96 NetServer::ready();
geiineuville 0:441400ffd086 97 open();
geiineuville 0:441400ffd086 98 tcp_connect(this->_pcb, &this->_ipaddr, this->_port, TCPConnection::connected_callback);
geiineuville 0:441400ffd086 99 }
geiineuville 0:441400ffd086 100
geiineuville 0:441400ffd086 101 err_t TCPConnection::dnsrequest(const char *hostname, struct ip_addr *addr) const {
geiineuville 0:441400ffd086 102 return dns_gethostbyname(hostname, addr, TCPConnection::dnsreply_callback, (void *)this);
geiineuville 0:441400ffd086 103 }