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.h@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 #ifndef HTTPD_H
okini3939 0:d18dff347122 20 #define HTTPD_H
okini3939 0:d18dff347122 21
okini3939 0:d18dff347122 22 #include "mbed.h"
okini3939 0:d18dff347122 23 #include "rtos.h"
dgriffin65 1:b724fdb741e7 24 #include "NetworkStack.h"
dgriffin65 1:b724fdb741e7 25 #include "EthInterface.h"
okini3939 0:d18dff347122 26 #include "CBuffer.h"
okini3939 0:d18dff347122 27
dgriffin65 1:b724fdb741e7 28 #define DEBUG
okini3939 0:d18dff347122 29
okini3939 0:d18dff347122 30 #define HTTPD_PORT 80
dgriffin65 1:b724fdb741e7 31 #define HTTPD_MAX_CLIENTS 5
okini3939 0:d18dff347122 32 #define HTTPD_KEEPALIVE 10
okini3939 0:d18dff347122 33 #define HTTPD_TIMEOUT 15000
okini3939 0:d18dff347122 34 #define HTTPD_MAX_HANDLES 10
okini3939 0:d18dff347122 35
okini3939 0:d18dff347122 36 #define HTTPD_CMD_SIZE 100
okini3939 0:d18dff347122 37 #define HTTPD_BUF_SIZE 256
okini3939 0:d18dff347122 38 #define HTTPD_STACK_SIZE (1024 * 6)
okini3939 0:d18dff347122 39 //#define HTTPD_ENABLE_CLOSER
okini3939 0:d18dff347122 40
okini3939 0:d18dff347122 41 //Debug is disabled by default
okini3939 0:d18dff347122 42 #if defined(DEBUG) and (!defined(TARGET_LPC11U24))
okini3939 0:d18dff347122 43 #define DBG(x, ...) std::printf("[DBG]" x "\r\n", ##__VA_ARGS__);
okini3939 0:d18dff347122 44 #define WARN(x, ...) std::printf("[WARN]" x "\r\n", ##__VA_ARGS__);
okini3939 0:d18dff347122 45 #define ERR(x, ...) std::printf("[ERR]" x "\r\n", ##__VA_ARGS__);
okini3939 0:d18dff347122 46 #define INFO(x, ...) std::printf("[INFO]" x "\r\n", ##__VA_ARGS__);
okini3939 0:d18dff347122 47 #else
okini3939 0:d18dff347122 48 #define DBG(x, ...)
okini3939 0:d18dff347122 49 #define WARN(x, ...)
okini3939 0:d18dff347122 50 #define ERR(x, ...)
okini3939 0:d18dff347122 51 #define INFO(x, ...)
okini3939 0:d18dff347122 52 #endif
okini3939 0:d18dff347122 53
okini3939 0:d18dff347122 54
okini3939 0:d18dff347122 55 class HTTPD {
okini3939 0:d18dff347122 56 public:
okini3939 0:d18dff347122 57
okini3939 0:d18dff347122 58 enum Request {
okini3939 0:d18dff347122 59 REQ_HTTPGET,
okini3939 0:d18dff347122 60 REQ_HTTPPOST,
okini3939 0:d18dff347122 61 REQ_PUT,
okini3939 0:d18dff347122 62 };
okini3939 0:d18dff347122 63
okini3939 0:d18dff347122 64 enum Mode {
okini3939 0:d18dff347122 65 MODE_REQUEST,
okini3939 0:d18dff347122 66 MODE_REQSTR,
okini3939 0:d18dff347122 67 MODE_HEADER,
okini3939 0:d18dff347122 68 MODE_BODY,
okini3939 0:d18dff347122 69 MODE_ENTER,
okini3939 0:d18dff347122 70 MODE_ERROR,
okini3939 0:d18dff347122 71 MODE_WEBSOCKET,
okini3939 0:d18dff347122 72 MODE_WEBSOCKET_MASK,
okini3939 0:d18dff347122 73 MODE_WEBSOCKET_BODY,
okini3939 0:d18dff347122 74 MODE_WEBSOCKET_ENTER,
okini3939 0:d18dff347122 75 };
okini3939 0:d18dff347122 76
okini3939 0:d18dff347122 77 struct STATE {
okini3939 0:d18dff347122 78 Thread *thread;
dgriffin65 1:b724fdb741e7 79 TCPSocket *client;
okini3939 0:d18dff347122 80 volatile Request req;
okini3939 0:d18dff347122 81 volatile Mode mode;
okini3939 0:d18dff347122 82 CircBuffer <char>*buf;
okini3939 0:d18dff347122 83 char uri[HTTPD_CMD_SIZE];
okini3939 0:d18dff347122 84 char *filename;
okini3939 0:d18dff347122 85 char *querystring;
okini3939 0:d18dff347122 86 int enter;
okini3939 0:d18dff347122 87 int length;
okini3939 0:d18dff347122 88 int n;
okini3939 0:d18dff347122 89 int keepalive;
okini3939 0:d18dff347122 90 int websocket;
okini3939 0:d18dff347122 91 char *websocket_key;
okini3939 0:d18dff347122 92 int websocket_opcode;
okini3939 0:d18dff347122 93 int websocket_flg;
okini3939 0:d18dff347122 94 char websocket_mask[4];
okini3939 0:d18dff347122 95 int websocket_payload;
okini3939 0:d18dff347122 96 int (*sendws)(int id, const char *buf, int len, const char *mask);
okini3939 0:d18dff347122 97 };
okini3939 0:d18dff347122 98
okini3939 0:d18dff347122 99 HTTPD ();
okini3939 0:d18dff347122 100
dgriffin65 1:b724fdb741e7 101 int start (NetworkStack *ns, int port = HTTPD_PORT);
okini3939 0:d18dff347122 102
okini3939 0:d18dff347122 103 // --- HTTPD_req.cpp ---
okini3939 0:d18dff347122 104 void httpdError (int id, int err);
okini3939 0:d18dff347122 105
okini3939 0:d18dff347122 106 // --- HTTPD_ws.cpp ---
okini3939 0:d18dff347122 107 static int sendWebsocket (int id, const char *buf, int len, const char *mask = NULL);
okini3939 0:d18dff347122 108
okini3939 0:d18dff347122 109 // --- HTTPD_util.cpp ---
okini3939 0:d18dff347122 110 char *getUri (int id);
okini3939 0:d18dff347122 111 char *getFilename (int id);
okini3939 0:d18dff347122 112 char *getQueryString (int id);
dgriffin65 1:b724fdb741e7 113
dgriffin65 1:b724fdb741e7 114 TCPSocket *getClientSocket(int id) {
dgriffin65 1:b724fdb741e7 115 if (id >= HTTPD_MAX_CLIENTS) return NULL;
dgriffin65 1:b724fdb741e7 116 return _state[id].client;
dgriffin65 1:b724fdb741e7 117 }
okini3939 0:d18dff347122 118 int send (int id, const char *body, int len, const char *header = NULL);
dgriffin65 1:b724fdb741e7 119 int sendstr (int id, const char *buf);
dgriffin65 1:b724fdb741e7 120 int hprintf(int id, const char* format, ...);
okini3939 0:d18dff347122 121 int receive (int id, char *buf, int len);
okini3939 0:d18dff347122 122 int attach (const char *uri, const char *dir);
okini3939 0:d18dff347122 123 int attach (const char *uri, void (*funcCgi)(int id));
okini3939 0:d18dff347122 124 int base64encode (const char *input, int length, char *output, int len);
okini3939 0:d18dff347122 125 int urlencode (const char *str, char *buf, int len);
okini3939 0:d18dff347122 126 int urldecode (const char *str, char *buf, int len);
okini3939 0:d18dff347122 127
okini3939 0:d18dff347122 128 static HTTPD * getInstance() {
okini3939 0:d18dff347122 129 return _inst;
okini3939 0:d18dff347122 130 };
okini3939 0:d18dff347122 131
okini3939 0:d18dff347122 132 private :
okini3939 0:d18dff347122 133 static HTTPD *_inst;
okini3939 0:d18dff347122 134 Thread *_daemon;
dgriffin65 1:b724fdb741e7 135 TCPServer _server;
dgriffin65 1:b724fdb741e7 136
dgriffin65 1:b724fdb741e7 137 NetworkStack *m_ns;
okini3939 0:d18dff347122 138
okini3939 0:d18dff347122 139 #ifdef HTTPD_ENABLE_CLOSER
okini3939 0:d18dff347122 140 struct STATE _state[HTTPD_MAX_CLIENTS + 1];
okini3939 0:d18dff347122 141 #else
okini3939 0:d18dff347122 142 struct STATE _state[HTTPD_MAX_CLIENTS];
okini3939 0:d18dff347122 143 #endif
okini3939 0:d18dff347122 144
okini3939 0:d18dff347122 145 struct HANDLER {
okini3939 0:d18dff347122 146 char *uri;
okini3939 0:d18dff347122 147 char *dir;
okini3939 0:d18dff347122 148 void (*funcCgi)(int id);
okini3939 0:d18dff347122 149 } _handler[HTTPD_MAX_HANDLES];
okini3939 0:d18dff347122 150
okini3939 0:d18dff347122 151 int _handler_count;
okini3939 0:d18dff347122 152
dgriffin65 1:b724fdb741e7 153 static void daemon ();
okini3939 0:d18dff347122 154 static void child (void const *arg);
okini3939 0:d18dff347122 155 static void closer (void const *arg);
okini3939 0:d18dff347122 156
okini3939 0:d18dff347122 157 // --- HTTPD_req.cpp ---
okini3939 0:d18dff347122 158 int httpdFile (int id, char *dir);
okini3939 0:d18dff347122 159 void recvData (int id, char c);
okini3939 0:d18dff347122 160 int parseRequest (int id);
okini3939 0:d18dff347122 161 int parseHeader (int id);
okini3939 0:d18dff347122 162 void reqContentLength (int id, const char *buf);
okini3939 0:d18dff347122 163 void reqConnection (int id, const char *buf);
okini3939 0:d18dff347122 164 void reqUpgrade (int id, const char *buf);
okini3939 0:d18dff347122 165 void reqWebSocketVersion (int id, const char *buf);
okini3939 0:d18dff347122 166 void reqWebSocketKey (int id, const char *buf);
okini3939 0:d18dff347122 167
okini3939 0:d18dff347122 168 // --- HTTPD_ws.cpp ---
okini3939 0:d18dff347122 169 void recvWS (int id, char c);
okini3939 0:d18dff347122 170 int parseWebsocket (int id);
okini3939 0:d18dff347122 171 int acceptWebsocket (int id);
okini3939 0:d18dff347122 172
okini3939 0:d18dff347122 173 // --- HTTPD_util.cpp ---
okini3939 0:d18dff347122 174 int getHandler (const char *uri);
okini3939 0:d18dff347122 175 char *mimetype (char *file);
okini3939 0:d18dff347122 176 int strnicmp (const char *p1, const char *p2, int n);
okini3939 0:d18dff347122 177 int from_hex (int ch);
okini3939 0:d18dff347122 178 int to_hex (int code);
okini3939 0:d18dff347122 179 };
okini3939 0:d18dff347122 180
okini3939 0:d18dff347122 181 #endif