Renesas / HttpServer_snapshot_mbed-os

HttpServer Library for "mbed-os" which added a snapshot handler.

Dependents:   GR-PEACH-webcam GR-Boards_WebCamera GR-Boards_WebCamera GR-Boards_WebCamera

Fork of HttpServer_snapshot by Renesas

Handler/RPCHandler.cpp@18:673d663a1ed7, 2019-09-13 (annotated)

Committer:
dkato
Date:
Fri Sep 13 02:08:33 2019 +0000
Revision:
18:673d663a1ed7
Parent:
11:0700755d64ae 
Add macro HTTP_SERVER_THREAD_MAX (default 1)

Who changed what in which revision?

UserRevisionLine numberNew contents of line
yueee_yt 0:fdf9c2c5200f 1 /*
yueee_yt 0:fdf9c2c5200f 2 Permission is hereby granted, free of charge, to any person obtaining a copy
yueee_yt 0:fdf9c2c5200f 3 of this software and associated documentation files (the "Software"), to deal
yueee_yt 0:fdf9c2c5200f 4 in the Software without restriction, including without limitation the rights
yueee_yt 0:fdf9c2c5200f 5 to use, copy, modify, merge, publish, distribute, sublicense, and/or sell
yueee_yt 0:fdf9c2c5200f 6 copies of the Software, and to permit persons to whom the Software is
yueee_yt 0:fdf9c2c5200f 7 furnished to do so, subject to the following conditions:
yueee_yt 4:1b6b021ee21d 8
yueee_yt 0:fdf9c2c5200f 9 The above copyright notice and this permission notice shall be included in
yueee_yt 0:fdf9c2c5200f 10 all copies or substantial portions of the Software.
yueee_yt 4:1b6b021ee21d 11
yueee_yt 0:fdf9c2c5200f 12 THE SOFTWARE IS PROVIDED "AS IS", WITHOUT WARRANTY OF ANY KIND, EXPRESS OR
yueee_yt 0:fdf9c2c5200f 13 IMPLIED, INCLUDING BUT NOT LIMITED TO THE WARRANTIES OF MERCHANTABILITY,
yueee_yt 0:fdf9c2c5200f 14 FITNESS FOR A PARTICULAR PURPOSE AND NONINFRINGEMENT. IN NO EVENT SHALL THE
yueee_yt 0:fdf9c2c5200f 15 AUTHORS OR COPYRIGHT HOLDERS BE LIABLE FOR ANY CLAIM, DAMAGES OR OTHER
yueee_yt 0:fdf9c2c5200f 16 LIABILITY, WHETHER IN AN ACTION OF CONTRACT, TORT OR OTHERWISE, ARISING FROM,
yueee_yt 0:fdf9c2c5200f 17 OUT OF OR IN CONNECTION WITH THE SOFTWARE OR THE USE OR OTHER DEALINGS IN
yueee_yt 0:fdf9c2c5200f 18 THE SOFTWARE.
yueee_yt 0:fdf9c2c5200f 19 */
yueee_yt 5:b8f6a11c70db 20
yueee_yt 5:b8f6a11c70db 21 //#define _DEBUG_RPC_HANDLER
yueee_yt 0:fdf9c2c5200f 22
yueee_yt 0:fdf9c2c5200f 23 #include "RPCHandler.h"
yueee_yt 2:82892309f848 24 #include "mbed_rpc.h"
yueee_yt 0:fdf9c2c5200f 25
yueee_yt 0:fdf9c2c5200f 26 #define RPC_DATA_LEN 128
yueee_yt 0:fdf9c2c5200f 27
dkato 11:0700755d64ae 28 RPCHandler::RPCHandler(const char* rootPath, const char* path, TCPSocket* pTCPSocket) : HTTPRequestHandler(rootPath, path, pTCPSocket)
yueee_yt 0:fdf9c2c5200f 29 {}
yueee_yt 0:fdf9c2c5200f 30
yueee_yt 0:fdf9c2c5200f 31 RPCHandler::~RPCHandler()
yueee_yt 0:fdf9c2c5200f 32 {
yueee_yt 4:1b6b021ee21d 33 #ifdef _DEBUG_RPC_HANDLER
yueee_yt 5:b8f6a11c70db 34 printf("++++(RPC Handler)Handler destroyed\r\n");
yueee_yt 4:1b6b021ee21d 35 #endif
yueee_yt 0:fdf9c2c5200f 36 }
yueee_yt 0:fdf9c2c5200f 37
yueee_yt 0:fdf9c2c5200f 38 void RPCHandler::doGet()
yueee_yt 0:fdf9c2c5200f 39 {
yueee_yt 4:1b6b021ee21d 40 #ifdef _DEBUG_RPC_HANDLER
yueee_yt 5:b8f6a11c70db 41 printf("++++(RPC Handler)doGet\r\n");
yueee_yt 4:1b6b021ee21d 42 #endif
yueee_yt 4:1b6b021ee21d 43 char resp[RPC_DATA_LEN] = {0};
yueee_yt 4:1b6b021ee21d 44 char req[RPC_DATA_LEN] = {0};
yueee_yt 4:1b6b021ee21d 45
yueee_yt 4:1b6b021ee21d 46 #ifdef _DEBUG_RPC_HANDLER
yueee_yt 5:b8f6a11c70db 47 printf("++++(RPC Handler)Path : %s\r\n", path().c_str());
yueee_yt 5:b8f6a11c70db 48 printf("++++(RPC Handler)Root Path : %s\r\n", rootPath().c_str());
yueee_yt 4:1b6b021ee21d 49 #endif
yueee_yt 4:1b6b021ee21d 50 //Remove path
yueee_yt 4:1b6b021ee21d 51 strncpy(req, path().c_str(), RPC_DATA_LEN-1);
yueee_yt 4:1b6b021ee21d 52 #ifdef _DEBUG_RPC_HANDLER
yueee_yt 5:b8f6a11c70db 53 printf("++++(RPC Handler)RPC req(before) : %s\r\n", req);
yueee_yt 4:1b6b021ee21d 54 #endif
yueee_yt 5:b8f6a11c70db 55 //Remove "%20", "+", "," from req
yueee_yt 4:1b6b021ee21d 56 cleanReq(req);
yueee_yt 4:1b6b021ee21d 57 #ifdef _DEBUG_RPC_HANDLER
yueee_yt 5:b8f6a11c70db 58 printf("++++(RPC Handler)RPC req(after) : %s\r\n", req);
yueee_yt 4:1b6b021ee21d 59 #endif
yueee_yt 4:1b6b021ee21d 60 //Do RPC Call
yueee_yt 4:1b6b021ee21d 61 RPC::call(req, resp); //FIXME: Use bool result
yueee_yt 4:1b6b021ee21d 62 #ifdef _DEBUG_RPC_HANDLER
yueee_yt 5:b8f6a11c70db 63 printf("++++(RPC Handler)Response %s \r\n",resp);
yueee_yt 4:1b6b021ee21d 64 #endif
yueee_yt 4:1b6b021ee21d 65 //Response
yueee_yt 4:1b6b021ee21d 66 setContentLen( strlen(resp) );
yueee_yt 4:1b6b021ee21d 67
yueee_yt 4:1b6b021ee21d 68 //Make sure that the browser won't cache this request
yueee_yt 4:1b6b021ee21d 69 respHeaders()["Cache-control"]="no-cache;no-store";
yueee_yt 4:1b6b021ee21d 70 respHeaders()["Pragma"]="no-cache";
yueee_yt 4:1b6b021ee21d 71 respHeaders()["Expires"]="0";
yueee_yt 4:1b6b021ee21d 72
yueee_yt 4:1b6b021ee21d 73 //Write data
yueee_yt 4:1b6b021ee21d 74 respHeaders()["Connection"] = "close";
yueee_yt 4:1b6b021ee21d 75 writeData(resp, strlen(resp));
yueee_yt 4:1b6b021ee21d 76 #ifdef _DEBUG_RPC_HANDLER
yueee_yt 5:b8f6a11c70db 77 printf("++++(RPC Handler)Exit RPCHandler::doGet()\r\n");
yueee_yt 4:1b6b021ee21d 78 #endif
yueee_yt 0:fdf9c2c5200f 79 }
yueee_yt 0:fdf9c2c5200f 80
yueee_yt 0:fdf9c2c5200f 81 void RPCHandler::doPost()
yueee_yt 0:fdf9c2c5200f 82 {
yueee_yt 0:fdf9c2c5200f 83
yueee_yt 0:fdf9c2c5200f 84 }
yueee_yt 0:fdf9c2c5200f 85
yueee_yt 0:fdf9c2c5200f 86 void RPCHandler::doHead()
yueee_yt 0:fdf9c2c5200f 87 {
yueee_yt 0:fdf9c2c5200f 88
yueee_yt 0:fdf9c2c5200f 89 }
yueee_yt 0:fdf9c2c5200f 90
yueee_yt 4:1b6b021ee21d 91
yueee_yt 0:fdf9c2c5200f 92 void RPCHandler::onReadable() //Data has been read
yueee_yt 0:fdf9c2c5200f 93 {
yueee_yt 0:fdf9c2c5200f 94
yueee_yt 0:fdf9c2c5200f 95 }
yueee_yt 0:fdf9c2c5200f 96
yueee_yt 0:fdf9c2c5200f 97 void RPCHandler::onWriteable() //Data has been written & buf is free
yueee_yt 0:fdf9c2c5200f 98 {
yueee_yt 4:1b6b021ee21d 99 #ifdef _DEBUG_RPC_HANDLER
yueee_yt 5:b8f6a11c70db 100 printf("++++(RPC Handler)onWriteable event\r\n");
yueee_yt 4:1b6b021ee21d 101 #endif
yueee_yt 5:b8f6a11c70db 102 // close(); //Data written, we can close the connection
yueee_yt 0:fdf9c2c5200f 103 }
yueee_yt 0:fdf9c2c5200f 104
yueee_yt 0:fdf9c2c5200f 105 void RPCHandler::onClose() //Connection is closing
yueee_yt 0:fdf9c2c5200f 106 {
yueee_yt 4:1b6b021ee21d 107 //Nothing to do
yueee_yt 0:fdf9c2c5200f 108 }
yueee_yt 0:fdf9c2c5200f 109
yueee_yt 0:fdf9c2c5200f 110 void RPCHandler::cleanReq(char* data)
yueee_yt 0:fdf9c2c5200f 111 {
yueee_yt 4:1b6b021ee21d 112 char* p;
yueee_yt 4:1b6b021ee21d 113 if((p = strstr(data, "+"))!=NULL)memset((void*) p, ' ', 1);
yueee_yt 4:1b6b021ee21d 114 else if((p = strstr(data, ","))!=NULL)memset((void*) p, ' ', 1);
yueee_yt 4:1b6b021ee21d 115 else if((p = strstr(data, "%20"))!=NULL) {
yueee_yt 4:1b6b021ee21d 116 memset((void*) p, ' ', 1);
yueee_yt 4:1b6b021ee21d 117 while(*(p+2)!=NULL) {
yueee_yt 4:1b6b021ee21d 118 p++;
yueee_yt 4:1b6b021ee21d 119 memset((void*) p,*(p+2),1);
yueee_yt 4:1b6b021ee21d 120 }
yueee_yt 4:1b6b021ee21d 121 }
yueee_yt 4:1b6b021ee21d 122
yueee_yt 4:1b6b021ee21d 123 if((p = strstr(data, "+"))!=NULL)memset((void*) p, ' ', 1);
yueee_yt 4:1b6b021ee21d 124 else if((p = strstr(data, ","))!=NULL)memset((void*) p, ' ', 1);
yueee_yt 4:1b6b021ee21d 125 else if((p = strstr(data, "%20"))!=NULL) {
yueee_yt 4:1b6b021ee21d 126 memset((void*) p, ' ', 1);
yueee_yt 4:1b6b021ee21d 127 while(*(p+2)!=NULL) {
yueee_yt 4:1b6b021ee21d 128 p++;
yueee_yt 4:1b6b021ee21d 129 memset((void*) p,*(p+2),1);
yueee_yt 4:1b6b021ee21d 130 }
yueee_yt 4:1b6b021ee21d 131 }
yueee_yt 0:fdf9c2c5200f 132 }
yueee_yt 4:1b6b021ee21d 133
yueee_yt 5:b8f6a11c70db 134
dkato 11:0700755d64ae 135