Christian Gulde / ModBusTCP

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.

Fork of HTTPD by AMETEK Powervar

HTTPD.cpp@1:b724fdb741e7, 2017-06-15 (annotated)

Committer:
dgriffin65
Date:
Thu Jun 15 20:17:24 2017 +0000
Revision:
1:b724fdb741e7
Parent:
0:d18dff347122 
Updated to mbed-os

Who changed what in which revision?

UserRevisionLine numberNew contents of line
okini3939 0:d18dff347122 1 /* Copyright (C) 2013 Hiroshi Suga, MIT License
okini3939 0:d18dff347122 2 *
okini3939 0:d18dff347122 3 * Permission is hereby granted, free of charge, to any person obtaining a copy of this software
okini3939 0:d18dff347122 4 * and associated documentation files (the "Software"), to deal in the Software without restriction,
okini3939 0:d18dff347122 5 * including without limitation the rights to use, copy, modify, merge, publish, distribute,
okini3939 0:d18dff347122 6 * sublicense, and/or sell copies of the Software, and to permit persons to whom the Software is
okini3939 0:d18dff347122 7 * furnished to do so, subject to the following conditions:
okini3939 0:d18dff347122 8 *
okini3939 0:d18dff347122 9 * The above copyright notice and this permission notice shall be included in all copies or
okini3939 0:d18dff347122 10 * substantial portions of the Software.
okini3939 0:d18dff347122 11 *
okini3939 0:d18dff347122 12 * THE SOFTWARE IS PROVIDED "AS IS", WITHOUT WARRANTY OF ANY KIND, EXPRESS OR IMPLIED, INCLUDING
okini3939 0:d18dff347122 13 * BUT NOT LIMITED TO THE WARRANTIES OF MERCHANTABILITY, FITNESS FOR A PARTICULAR PURPOSE AND
okini3939 0:d18dff347122 14 * NONINFRINGEMENT. IN NO EVENT SHALL THE AUTHORS OR COPYRIGHT HOLDERS BE LIABLE FOR ANY CLAIM,
okini3939 0:d18dff347122 15 * DAMAGES OR OTHER LIABILITY, WHETHER IN AN ACTION OF CONTRACT, TORT OR OTHERWISE, ARISING FROM,
okini3939 0:d18dff347122 16 * OUT OF OR IN CONNECTION WITH THE SOFTWARE OR THE USE OR OTHER DEALINGS IN THE SOFTWARE.
okini3939 0:d18dff347122 17 */
okini3939 0:d18dff347122 18
okini3939 0:d18dff347122 19 #include "HTTPD.h"
okini3939 0:d18dff347122 20
okini3939 0:d18dff347122 21 HTTPD * HTTPD::_inst;
okini3939 0:d18dff347122 22
okini3939 0:d18dff347122 23 HTTPD::HTTPD () {
okini3939 0:d18dff347122 24 _inst = this;
okini3939 0:d18dff347122 25 memset(_state, 0, sizeof(_state));
okini3939 0:d18dff347122 26 _handler_count = 0;
okini3939 0:d18dff347122 27 }
okini3939 0:d18dff347122 28
dgriffin65 1:b724fdb741e7 29 int HTTPD::start (NetworkStack *ns, int port) {
okini3939 0:d18dff347122 30 int i;
okini3939 0:d18dff347122 31
dgriffin65 1:b724fdb741e7 32 m_ns = ns;
dgriffin65 1:b724fdb741e7 33
okini3939 0:d18dff347122 34 for (i = 0; i < HTTPD_MAX_CLIENTS; i ++) {
okini3939 0:d18dff347122 35 _state[i].buf = new CircBuffer<char>(HTTPD_BUF_SIZE);
dgriffin65 1:b724fdb741e7 36 _state[i].thread = new Thread(osPriorityNormal, HTTPD_STACK_SIZE);
dgriffin65 1:b724fdb741e7 37 _state[i].client = new TCPSocket();
dgriffin65 1:b724fdb741e7 38 _state[i].thread->start(callback(child, (void*)i));
okini3939 0:d18dff347122 39 }
dgriffin65 1:b724fdb741e7 40
okini3939 0:d18dff347122 41 #ifdef HTTPD_ENABLE_CLOSER
okini3939 0:d18dff347122 42 _state[HTTPD_MAX_CLIENTS].thread = new Thread(closer, (void*)HTTPD_MAX_CLIENTS, osPriorityNormal, 128);
dgriffin65 1:b724fdb741e7 43 _state[HTTPD_MAX_CLIENTS].client = new TCPSocket(m_ns);
okini3939 0:d18dff347122 44 #endif
okini3939 0:d18dff347122 45
dgriffin65 1:b724fdb741e7 46 _server.open(m_ns);
okini3939 0:d18dff347122 47 _server.bind(port);
dgriffin65 1:b724fdb741e7 48 _server.set_blocking(true);
okini3939 0:d18dff347122 49 _server.listen();
dgriffin65 1:b724fdb741e7 50 _daemon = new Thread(osPriorityNormal, HTTPD_STACK_SIZE);
dgriffin65 1:b724fdb741e7 51 _daemon->start(HTTPD::daemon);
okini3939 0:d18dff347122 52 return 0;
okini3939 0:d18dff347122 53 }
okini3939 0:d18dff347122 54
dgriffin65 1:b724fdb741e7 55 void HTTPD::daemon () {
okini3939 0:d18dff347122 56 HTTPD *httpd = HTTPD::getInstance();
okini3939 0:d18dff347122 57 int i, t = 0;
okini3939 0:d18dff347122 58
okini3939 0:d18dff347122 59 INFO("Wait for new connection...\r\n");
okini3939 0:d18dff347122 60 for (;;) {
okini3939 0:d18dff347122 61 if (t >= 0) {
dgriffin65 1:b724fdb741e7 62 if (httpd->_server.accept(httpd->_state[t].client) == 0) {
okini3939 0:d18dff347122 63 INFO("accept %d\r\n", t);
okini3939 0:d18dff347122 64 httpd->_state[t].thread->signal_set(1);
okini3939 0:d18dff347122 65 }
okini3939 0:d18dff347122 66 } else {
okini3939 0:d18dff347122 67 #ifdef HTTPD_ENABLE_CLOSER
dgriffin65 1:b724fdb741e7 68 if (httpd->_server.accept(httpd->_state[HTTPD_MAX_CLIENTS].client) == 0) {
okini3939 0:d18dff347122 69 INFO("accept x\r\n");
okini3939 0:d18dff347122 70 httpd->_state[HTTPD_MAX_CLIENTS].thread->signal_set(1);
okini3939 0:d18dff347122 71 }
okini3939 0:d18dff347122 72 #endif
okini3939 0:d18dff347122 73 }
okini3939 0:d18dff347122 74
okini3939 0:d18dff347122 75 t = -1;
okini3939 0:d18dff347122 76 for (i = 0; i < HTTPD_MAX_CLIENTS; i ++) {
okini3939 0:d18dff347122 77 if (httpd->_state[i].thread->get_state() == Thread::WaitingAnd) {
okini3939 0:d18dff347122 78 if (t < 0) t = i; // next empty thread
okini3939 0:d18dff347122 79 }
okini3939 0:d18dff347122 80 }
okini3939 0:d18dff347122 81 }
okini3939 0:d18dff347122 82 }
okini3939 0:d18dff347122 83
okini3939 0:d18dff347122 84 void HTTPD::child (void const *arg) {
okini3939 0:d18dff347122 85 HTTPD *httpd = HTTPD::getInstance();
okini3939 0:d18dff347122 86 int id = (int)arg;
okini3939 0:d18dff347122 87 int i, n;
okini3939 0:d18dff347122 88 char buf[HTTPD_BUF_SIZE];
okini3939 0:d18dff347122 89
okini3939 0:d18dff347122 90 for (;;) {
okini3939 0:d18dff347122 91 Thread::signal_wait(1);
okini3939 0:d18dff347122 92 httpd->_state[id].mode = MODE_REQUEST;
okini3939 0:d18dff347122 93 httpd->_state[id].buf->flush();
okini3939 0:d18dff347122 94 httpd->_state[id].keepalive = 0;
dgriffin65 1:b724fdb741e7 95 INFO("Connection from client\r\n");
dgriffin65 1:b724fdb741e7 96 // INFO("Connection from %s\r\n", httpd->_state[id].client->get_ip_address());
dgriffin65 1:b724fdb741e7 97
dgriffin65 1:b724fdb741e7 98 httpd->_state[id].client->set_blocking(false);
dgriffin65 1:b724fdb741e7 99 httpd->_state[id].client->set_timeout(HTTPD_TIMEOUT);
dgriffin65 1:b724fdb741e7 100
okini3939 0:d18dff347122 101 for (;;) {
dgriffin65 1:b724fdb741e7 102 //if (! httpd->_state[id].client->is_connected()) break;
okini3939 0:d18dff347122 103
dgriffin65 1:b724fdb741e7 104 n = httpd->_state[id].client->recv(buf, sizeof(buf));
dgriffin65 1:b724fdb741e7 105
dgriffin65 1:b724fdb741e7 106 if (n < 0 ) {
dgriffin65 1:b724fdb741e7 107 printf("HTTPD::child breaking n = %d\r\n", n);
dgriffin65 1:b724fdb741e7 108 break;
dgriffin65 1:b724fdb741e7 109 }
okini3939 0:d18dff347122 110 buf[n] = 0;
dgriffin65 1:b724fdb741e7 111 //DBG("Recv %d ", n);
dgriffin65 1:b724fdb741e7 112 DBG("Recv %d '%s'", n, buf);
okini3939 0:d18dff347122 113
okini3939 0:d18dff347122 114 for (i = 0; i < n; i ++) {
okini3939 0:d18dff347122 115 httpd->recvData(id, buf[i]);
okini3939 0:d18dff347122 116 }
okini3939 0:d18dff347122 117 }
okini3939 0:d18dff347122 118
okini3939 0:d18dff347122 119 httpd->_state[id].client->close();
dgriffin65 1:b724fdb741e7 120 INFO("Closed client connection\r\n");
dgriffin65 1:b724fdb741e7 121 //INFO("Close %s\r\n", httpd->_state[id].client->get_ip_address());
okini3939 0:d18dff347122 122 }
okini3939 0:d18dff347122 123 }
okini3939 0:d18dff347122 124
okini3939 0:d18dff347122 125 void HTTPD::closer (void const *arg) {
okini3939 0:d18dff347122 126 HTTPD *httpd = HTTPD::getInstance();
okini3939 0:d18dff347122 127 int id = (int)arg;
okini3939 0:d18dff347122 128
okini3939 0:d18dff347122 129 for (;;) {
okini3939 0:d18dff347122 130 Thread::signal_wait(1);
okini3939 0:d18dff347122 131
okini3939 0:d18dff347122 132 httpd->_state[id].client->close();
dgriffin65 1:b724fdb741e7 133 INFO("Closed client connection\r\n");
dgriffin65 1:b724fdb741e7 134 //INFO("Close %s\r\n", httpd->_state[id].client->get_ip_address());
okini3939 0:d18dff347122 135 }
okini3939 0:d18dff347122 136 }
okini3939 0:d18dff347122 137