LRSD stephane / Mbed 2 deprecated WEBserverv4

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:3c32eeb9292a, 2011-09-22 (annotated)

Committer:
geiineuville
Date:
Thu Sep 22 15:59:17 2011 +0000
Revision:
0:3c32eeb9292a
V4

Who changed what in which revision?

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