LRSD stephane / Mbed 2 deprecated WEBserverv3

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.h@0:9cf1d79ebe04, 2011-09-08 (annotated)

Committer:
geiineuville
Date:
Thu Sep 08 08:57:21 2011 +0000
Revision:
0:9cf1d79ebe04
v0 v1 v2   \"v3\"

Who changed what in which revision?

UserRevisionLine numberNew contents of line
geiineuville 0:9cf1d79ebe04 1 #ifndef TCPCONNECTION_H
geiineuville 0:9cf1d79ebe04 2 #define TCPCONNECTION_H
geiineuville 0:9cf1d79ebe04 3
geiineuville 0:9cf1d79ebe04 4 #include "arch/cc.h"
geiineuville 0:9cf1d79ebe04 5 #include "lwip/err.h"
geiineuville 0:9cf1d79ebe04 6 //#include "lwip/tcp.h"
geiineuville 0:9cf1d79ebe04 7
geiineuville 0:9cf1d79ebe04 8 #include "TCPItem.h"
geiineuville 0:9cf1d79ebe04 9
geiineuville 0:9cf1d79ebe04 10 namespace mbed {
geiineuville 0:9cf1d79ebe04 11
geiineuville 0:9cf1d79ebe04 12 class NetServer;
geiineuville 0:9cf1d79ebe04 13 class TCPListener;
geiineuville 0:9cf1d79ebe04 14
geiineuville 0:9cf1d79ebe04 15 class TCPConnection : public TCPItem {
geiineuville 0:9cf1d79ebe04 16 public:
geiineuville 0:9cf1d79ebe04 17 TCPConnection(struct ip_addr, u16_t);
geiineuville 0:9cf1d79ebe04 18 TCPConnection(TCPListener *, struct tcp_pcb *);
geiineuville 0:9cf1d79ebe04 19
geiineuville 0:9cf1d79ebe04 20 virtual ~TCPConnection();
geiineuville 0:9cf1d79ebe04 21
geiineuville 0:9cf1d79ebe04 22 void connect();
geiineuville 0:9cf1d79ebe04 23
geiineuville 0:9cf1d79ebe04 24 err_t write(void *, u16_t len, u8_t flags = TCP_WRITE_FLAG_COPY) const;
geiineuville 0:9cf1d79ebe04 25
geiineuville 0:9cf1d79ebe04 26 void recved(u32_t len) const;
geiineuville 0:9cf1d79ebe04 27 u16_t sndbuf() const { return tcp_sndbuf(_pcb); }
geiineuville 0:9cf1d79ebe04 28
geiineuville 0:9cf1d79ebe04 29 void set_poll_timer(const u32_t &time) {
geiineuville 0:9cf1d79ebe04 30 if(_pcb) {
geiineuville 0:9cf1d79ebe04 31 _pcb->polltmr = time;
geiineuville 0:9cf1d79ebe04 32 }
geiineuville 0:9cf1d79ebe04 33 }
geiineuville 0:9cf1d79ebe04 34
geiineuville 0:9cf1d79ebe04 35 u32_t get_poll_interval() const {
geiineuville 0:9cf1d79ebe04 36 return (_pcb)? _pcb->pollinterval: 0;
geiineuville 0:9cf1d79ebe04 37 }
geiineuville 0:9cf1d79ebe04 38
geiineuville 0:9cf1d79ebe04 39 void set_poll_interval(const u32_t &value) {
geiineuville 0:9cf1d79ebe04 40 if(_pcb) {
geiineuville 0:9cf1d79ebe04 41 _pcb->pollinterval = value;
geiineuville 0:9cf1d79ebe04 42 }
geiineuville 0:9cf1d79ebe04 43 }
geiineuville 0:9cf1d79ebe04 44
geiineuville 0:9cf1d79ebe04 45 u32_t get_poll_timer() const {
geiineuville 0:9cf1d79ebe04 46 return (_pcb)? _pcb->polltmr: 0;
geiineuville 0:9cf1d79ebe04 47 }
geiineuville 0:9cf1d79ebe04 48
geiineuville 0:9cf1d79ebe04 49 // [iva2k] Expose remote IP
geiineuville 0:9cf1d79ebe04 50 struct ip_addr get_remote_ip() const {
geiineuville 0:9cf1d79ebe04 51 return _ipaddr;
geiineuville 0:9cf1d79ebe04 52 }
geiineuville 0:9cf1d79ebe04 53
geiineuville 0:9cf1d79ebe04 54 protected:
geiineuville 0:9cf1d79ebe04 55 TCPConnection();
geiineuville 0:9cf1d79ebe04 56
geiineuville 0:9cf1d79ebe04 57 /**
geiineuville 0:9cf1d79ebe04 58 * Function to be called when more send buffer space is available.
geiineuville 0:9cf1d79ebe04 59 * @param space the amount of bytes available
geiineuville 0:9cf1d79ebe04 60 * @return ERR_OK: try to send some data by calling tcp_output
geiineuville 0:9cf1d79ebe04 61 */
geiineuville 0:9cf1d79ebe04 62 virtual err_t sent(u16_t space) = 0;
geiineuville 0:9cf1d79ebe04 63
geiineuville 0:9cf1d79ebe04 64 /**
geiineuville 0:9cf1d79ebe04 65 * Function to be called when (in-sequence) data has arrived.
geiineuville 0:9cf1d79ebe04 66 * @param p the packet buffer which arrived
geiineuville 0:9cf1d79ebe04 67 * @param err an error argument (TODO: that is current always ERR_OK?)
geiineuville 0:9cf1d79ebe04 68 * @return ERR_OK: try to send some data by calling tcp_output
geiineuville 0:9cf1d79ebe04 69 */
geiineuville 0:9cf1d79ebe04 70 virtual err_t recv(struct pbuf *p, err_t err) = 0;
geiineuville 0:9cf1d79ebe04 71
geiineuville 0:9cf1d79ebe04 72 /**
geiineuville 0:9cf1d79ebe04 73 * Function to be called when a connection has been set up.
geiineuville 0:9cf1d79ebe04 74 * @param pcb the tcp_pcb that now is connected
geiineuville 0:9cf1d79ebe04 75 * @param err an error argument (TODO: that is current always ERR_OK?)
geiineuville 0:9cf1d79ebe04 76 * @return value is currently ignored
geiineuville 0:9cf1d79ebe04 77 */
geiineuville 0:9cf1d79ebe04 78 virtual err_t connected(err_t err);
geiineuville 0:9cf1d79ebe04 79
geiineuville 0:9cf1d79ebe04 80 /**
geiineuville 0:9cf1d79ebe04 81 * Function which is called periodically.
geiineuville 0:9cf1d79ebe04 82 * The period can be adjusted in multiples of the TCP slow timer interval
geiineuville 0:9cf1d79ebe04 83 * by changing tcp_pcb.polltmr.
geiineuville 0:9cf1d79ebe04 84 * @return ERR_OK: try to send some data by calling tcp_output
geiineuville 0:9cf1d79ebe04 85 */
geiineuville 0:9cf1d79ebe04 86 virtual err_t poll() = 0;
geiineuville 0:9cf1d79ebe04 87
geiineuville 0:9cf1d79ebe04 88 /**
geiineuville 0:9cf1d79ebe04 89 * Function to be called whenever a fatal error occurs.
geiineuville 0:9cf1d79ebe04 90 * There is no pcb parameter since most of the times, the pcb is
geiineuville 0:9cf1d79ebe04 91 * already deallocated (or there is no pcb) when this function is called.
geiineuville 0:9cf1d79ebe04 92 * @param err an indication why the error callback is called:
geiineuville 0:9cf1d79ebe04 93 * ERR_ABRT: aborted through tcp_abort or by a TCP timer
geiineuville 0:9cf1d79ebe04 94 * ERR_RST: the connection was reset by the remote host
geiineuville 0:9cf1d79ebe04 95 */
geiineuville 0:9cf1d79ebe04 96 virtual void err(err_t err) = 0;
geiineuville 0:9cf1d79ebe04 97
geiineuville 0:9cf1d79ebe04 98 virtual void dnsreply(const char *hostname, struct ip_addr *addr) = 0;
geiineuville 0:9cf1d79ebe04 99
geiineuville 0:9cf1d79ebe04 100 err_t dnsrequest(const char *hostname, struct ip_addr *addr) const;
geiineuville 0:9cf1d79ebe04 101
geiineuville 0:9cf1d79ebe04 102 private:
geiineuville 0:9cf1d79ebe04 103 static void dnsreply_callback(const char *name, struct ip_addr *ipaddr, void *arg);
geiineuville 0:9cf1d79ebe04 104 static err_t connected_callback(void *arg, struct tcp_pcb *pcb, err_t err);
geiineuville 0:9cf1d79ebe04 105 static err_t sent_callback(void *arg, struct tcp_pcb *pcb, u16_t space);
geiineuville 0:9cf1d79ebe04 106 static err_t recv_callback(void *arg, struct tcp_pcb *pcb, struct pbuf *p, err_t err);
geiineuville 0:9cf1d79ebe04 107 static err_t poll_callback(void *arg, struct tcp_pcb *pcb);
geiineuville 0:9cf1d79ebe04 108 static void error_callback(void *arg, err_t erra);
geiineuville 0:9cf1d79ebe04 109
geiineuville 0:9cf1d79ebe04 110 protected:
geiineuville 0:9cf1d79ebe04 111 TCPListener *_parent;
geiineuville 0:9cf1d79ebe04 112 struct ip_addr _ipaddr;
geiineuville 0:9cf1d79ebe04 113 u16_t _port;
geiineuville 0:9cf1d79ebe04 114
geiineuville 0:9cf1d79ebe04 115 friend class NetServer;
geiineuville 0:9cf1d79ebe04 116 };
geiineuville 0:9cf1d79ebe04 117
geiineuville 0:9cf1d79ebe04 118 };
geiineuville 0:9cf1d79ebe04 119
geiineuville 0:9cf1d79ebe04 120 #endif /* TCPCONNECTION_H */