Measure system

Dependencies:   EthernetNetIf mbed RF12B

Committer:
benecsj
Date:
Tue May 17 16:49:23 2011 +0000
Revision:
3:799d8c61fb03
Parent:
2:afe5826411e3

        

Who changed what in which revision?

UserRevisionLine numberNew contents of line
benecsj 0:8d62137f7ff4 1
benecsj 0:8d62137f7ff4 2 /*
benecsj 0:8d62137f7ff4 3 Copyright (c) 2010 Donatien Garnier (donatiengar [at] gmail [dot] com)
benecsj 0:8d62137f7ff4 4
benecsj 0:8d62137f7ff4 5 Permission is hereby granted, free of charge, to any person obtaining a copy
benecsj 0:8d62137f7ff4 6 of this software and associated documentation files (the "Software"), to deal
benecsj 0:8d62137f7ff4 7 in the Software without restriction, including without limitation the rights
benecsj 0:8d62137f7ff4 8 to use, copy, modify, merge, publish, distribute, sublicense, and/or sell
benecsj 0:8d62137f7ff4 9 copies of the Software, and to permit persons to whom the Software is
benecsj 0:8d62137f7ff4 10 furnished to do so, subject to the following conditions:
benecsj 0:8d62137f7ff4 11
benecsj 0:8d62137f7ff4 12 The above copyright notice and this permission notice shall be included in
benecsj 0:8d62137f7ff4 13 all copies or substantial portions of the Software.
benecsj 0:8d62137f7ff4 14
benecsj 0:8d62137f7ff4 15 THE SOFTWARE IS PROVIDED "AS IS", WITHOUT WARRANTY OF ANY KIND, EXPRESS OR
benecsj 0:8d62137f7ff4 16 IMPLIED, INCLUDING BUT NOT LIMITED TO THE WARRANTIES OF MERCHANTABILITY,
benecsj 0:8d62137f7ff4 17 FITNESS FOR A PARTICULAR PURPOSE AND NONINFRINGEMENT. IN NO EVENT SHALL THE
benecsj 0:8d62137f7ff4 18 AUTHORS OR COPYRIGHT HOLDERS BE LIABLE FOR ANY CLAIM, DAMAGES OR OTHER
benecsj 0:8d62137f7ff4 19 LIABILITY, WHETHER IN AN ACTION OF CONTRACT, TORT OR OTHERWISE, ARISING FROM,
benecsj 0:8d62137f7ff4 20 OUT OF OR IN CONNECTION WITH THE SOFTWARE OR THE USE OR OTHER DEALINGS IN
benecsj 0:8d62137f7ff4 21 THE SOFTWARE.
benecsj 0:8d62137f7ff4 22 */
benecsj 0:8d62137f7ff4 23
benecsj 1:b26ab2467b1a 24 #include "MeasureSystem.h"
benecsj 0:8d62137f7ff4 25 #include "FSHandler.h"
benecsj 0:8d62137f7ff4 26 #include "MeasureSystem.h"
benecsj 0:8d62137f7ff4 27
benecsj 0:8d62137f7ff4 28 //#define __DEBUG
benecsj 0:8d62137f7ff4 29 //#include "dbg/dbg.h"
benecsj 0:8d62137f7ff4 30
benecsj 0:8d62137f7ff4 31 #define CHUNK_SIZE 128
benecsj 0:8d62137f7ff4 32
benecsj 0:8d62137f7ff4 33 #define DEFAULT_PAGE "/index.htm"
benecsj 0:8d62137f7ff4 34
benecsj 0:8d62137f7ff4 35 FSHandler::FSHandler(const char* rootPath, const char* path, TCPSocket* pTCPSocket) : HTTPRequestHandler(rootPath, path, pTCPSocket), m_err404(false)
benecsj 0:8d62137f7ff4 36 {}
benecsj 0:8d62137f7ff4 37
benecsj 0:8d62137f7ff4 38 FSHandler::~FSHandler()
benecsj 0:8d62137f7ff4 39 {
benecsj 0:8d62137f7ff4 40 if(m_fp)
benecsj 0:8d62137f7ff4 41 fclose(m_fp);
benecsj 0:8d62137f7ff4 42 printf("3-FS-Handler destroyed\r\n");
benecsj 0:8d62137f7ff4 43 HandlerActive = false;
benecsj 0:8d62137f7ff4 44 }
benecsj 0:8d62137f7ff4 45
benecsj 0:8d62137f7ff4 46 //static init
benecsj 0:8d62137f7ff4 47 map<string,string> FSHandler::m_lFsPath = map<string,string>();
benecsj 0:8d62137f7ff4 48
benecsj 0:8d62137f7ff4 49 void FSHandler::mount(const string& fsPath, const string& rootPath)
benecsj 0:8d62137f7ff4 50 {
benecsj 0:8d62137f7ff4 51 m_lFsPath[rootPath]=fsPath;
benecsj 0:8d62137f7ff4 52 }
benecsj 0:8d62137f7ff4 53
benecsj 0:8d62137f7ff4 54 void FSHandler::doGet()
benecsj 0:8d62137f7ff4 55 {
benecsj 0:8d62137f7ff4 56 printf("3-FS-In FSHandler::doGet() - rootPath=%s, path=%s\r\n", rootPath().c_str(), path().c_str());
benecsj 0:8d62137f7ff4 57 //FIXME: Translate path to local/path
benecsj 0:8d62137f7ff4 58
benecsj 0:8d62137f7ff4 59
benecsj 0:8d62137f7ff4 60 if (path().compare("/log") == 0)
benecsj 0:8d62137f7ff4 61 {
benecsj 2:afe5826411e3 62 path() = "/syslog/log.txt";
benecsj 2:afe5826411e3 63 }
benecsj 2:afe5826411e3 64 else
benecsj 2:afe5826411e3 65 if (path().compare("/list") == 0)
benecsj 2:afe5826411e3 66 {
benecsj 2:afe5826411e3 67 UpdateList();
benecsj 2:afe5826411e3 68 path() = "/system/files.dat";
benecsj 0:8d62137f7ff4 69 }
benecsj 0:8d62137f7ff4 70
benecsj 0:8d62137f7ff4 71 string checkedRootPath = rootPath();
benecsj 0:8d62137f7ff4 72 if(checkedRootPath.empty())
benecsj 0:8d62137f7ff4 73 checkedRootPath="/";
benecsj 0:8d62137f7ff4 74 string filePath = m_lFsPath[checkedRootPath];
benecsj 1:b26ab2467b1a 75 if (path().size() > 1 & path().size() < 40)
benecsj 0:8d62137f7ff4 76 {
benecsj 0:8d62137f7ff4 77 filePath += path();
benecsj 0:8d62137f7ff4 78 }
benecsj 0:8d62137f7ff4 79 else
benecsj 0:8d62137f7ff4 80 {
benecsj 0:8d62137f7ff4 81 filePath += DEFAULT_PAGE;
benecsj 0:8d62137f7ff4 82 }
benecsj 0:8d62137f7ff4 83
benecsj 0:8d62137f7ff4 84 printf("3-FS-Trying to open %s\r\n", filePath.c_str());
benecsj 0:8d62137f7ff4 85
benecsj 0:8d62137f7ff4 86 m_fp = fopen(filePath.c_str(), "r"); //FIXME: if null, error 404
benecsj 0:8d62137f7ff4 87
benecsj 0:8d62137f7ff4 88 if (!m_fp)
benecsj 0:8d62137f7ff4 89 {
benecsj 0:8d62137f7ff4 90 string filePath = m_lFsPath["/extern"];
benecsj 0:8d62137f7ff4 91 if (path().size() > 1)
benecsj 0:8d62137f7ff4 92 {
benecsj 0:8d62137f7ff4 93 filePath += path();
benecsj 0:8d62137f7ff4 94 }
benecsj 0:8d62137f7ff4 95 else
benecsj 0:8d62137f7ff4 96 {
benecsj 0:8d62137f7ff4 97 filePath += DEFAULT_PAGE;
benecsj 0:8d62137f7ff4 98 }
benecsj 0:8d62137f7ff4 99
benecsj 0:8d62137f7ff4 100 printf("3-FS-Trying to open %s\r\n", filePath.c_str());
benecsj 0:8d62137f7ff4 101
benecsj 0:8d62137f7ff4 102 m_fp = fopen(filePath.c_str(), "r"); //FIXME: if null, error 404
benecsj 0:8d62137f7ff4 103 }
benecsj 0:8d62137f7ff4 104
benecsj 0:8d62137f7ff4 105 if(!m_fp)
benecsj 0:8d62137f7ff4 106 {
benecsj 0:8d62137f7ff4 107 m_err404 = true;
benecsj 0:8d62137f7ff4 108 setErrCode(404);
benecsj 0:8d62137f7ff4 109 const char* msg = "File not found.";
benecsj 0:8d62137f7ff4 110 setContentLen(strlen(msg));
benecsj 0:8d62137f7ff4 111 respHeaders()["Content-Type"] = "text/html";
benecsj 0:8d62137f7ff4 112 respHeaders()["Connection"] = "close";
benecsj 0:8d62137f7ff4 113 writeData(msg,strlen(msg)); //Only send header
benecsj 0:8d62137f7ff4 114 printf("\r\n3-FS-Exit FSHandler::doGet() w Error 404\r\n");
benecsj 0:8d62137f7ff4 115 return;
benecsj 0:8d62137f7ff4 116 }
benecsj 0:8d62137f7ff4 117
benecsj 0:8d62137f7ff4 118 //Seek EOF to get length
benecsj 0:8d62137f7ff4 119 fseek(m_fp, 0, SEEK_END);
benecsj 0:8d62137f7ff4 120 setContentLen( ftell(m_fp) );
benecsj 0:8d62137f7ff4 121 fseek(m_fp, 0, SEEK_SET); //Goto SOF
benecsj 0:8d62137f7ff4 122
benecsj 0:8d62137f7ff4 123 respHeaders()["Connection"] = "close";
benecsj 0:8d62137f7ff4 124 onWriteable();
benecsj 0:8d62137f7ff4 125 printf("3-FS-Exit FSHandler::doGet()\r\n");
benecsj 0:8d62137f7ff4 126 }
benecsj 0:8d62137f7ff4 127
benecsj 0:8d62137f7ff4 128 void FSHandler::doPost()
benecsj 0:8d62137f7ff4 129 {
benecsj 0:8d62137f7ff4 130
benecsj 0:8d62137f7ff4 131 }
benecsj 0:8d62137f7ff4 132
benecsj 0:8d62137f7ff4 133 void FSHandler::doHead()
benecsj 0:8d62137f7ff4 134 {
benecsj 0:8d62137f7ff4 135
benecsj 0:8d62137f7ff4 136 }
benecsj 0:8d62137f7ff4 137
benecsj 0:8d62137f7ff4 138 void FSHandler::onReadable() //Data has been read
benecsj 0:8d62137f7ff4 139 {
benecsj 0:8d62137f7ff4 140
benecsj 0:8d62137f7ff4 141 }
benecsj 0:8d62137f7ff4 142
benecsj 0:8d62137f7ff4 143 void FSHandler::onWriteable() //Data has been written & buf is free
benecsj 0:8d62137f7ff4 144 {
benecsj 0:8d62137f7ff4 145 // DBG("\r\nFSHandler::onWriteable() event\r\n");
benecsj 0:8d62137f7ff4 146 if(m_err404)
benecsj 0:8d62137f7ff4 147 {
benecsj 0:8d62137f7ff4 148 //Error has been served, now exit
benecsj 0:8d62137f7ff4 149 close();
benecsj 0:8d62137f7ff4 150 return;
benecsj 0:8d62137f7ff4 151 }
benecsj 0:8d62137f7ff4 152
benecsj 0:8d62137f7ff4 153 static char rBuf[CHUNK_SIZE];
benecsj 0:8d62137f7ff4 154 while(true)
benecsj 0:8d62137f7ff4 155 {
benecsj 0:8d62137f7ff4 156 int len = fread(rBuf, 1, CHUNK_SIZE, m_fp);
benecsj 0:8d62137f7ff4 157 if(len>0)
benecsj 0:8d62137f7ff4 158 {
benecsj 0:8d62137f7ff4 159 int writtenLen = writeData(rBuf, len);
benecsj 0:8d62137f7ff4 160 if(writtenLen < 0) //Socket error
benecsj 0:8d62137f7ff4 161 {
benecsj 0:8d62137f7ff4 162 printf("3-FS-FSHandler: Socket error %d\r\n", writtenLen);
benecsj 0:8d62137f7ff4 163 if(writtenLen == TCPSOCKET_MEM)
benecsj 0:8d62137f7ff4 164 {
benecsj 0:8d62137f7ff4 165 fseek(m_fp, -len, SEEK_CUR);
benecsj 0:8d62137f7ff4 166 return; //Wait for the queued TCP segments to be transmitted
benecsj 0:8d62137f7ff4 167 }
benecsj 0:8d62137f7ff4 168 else
benecsj 0:8d62137f7ff4 169 {
benecsj 0:8d62137f7ff4 170 //This is a critical error
benecsj 0:8d62137f7ff4 171 close();
benecsj 0:8d62137f7ff4 172 return;
benecsj 0:8d62137f7ff4 173 }
benecsj 0:8d62137f7ff4 174 }
benecsj 0:8d62137f7ff4 175 else if(writtenLen < len) //Short write, socket's buffer is full
benecsj 0:8d62137f7ff4 176 {
benecsj 0:8d62137f7ff4 177 fseek(m_fp, writtenLen - len, SEEK_CUR);
benecsj 0:8d62137f7ff4 178 return;
benecsj 0:8d62137f7ff4 179 }
benecsj 0:8d62137f7ff4 180 }
benecsj 0:8d62137f7ff4 181 else
benecsj 0:8d62137f7ff4 182 {
benecsj 0:8d62137f7ff4 183 close(); //Data written, we can close the connection
benecsj 0:8d62137f7ff4 184 return;
benecsj 0:8d62137f7ff4 185 }
benecsj 0:8d62137f7ff4 186 }
benecsj 0:8d62137f7ff4 187 }
benecsj 0:8d62137f7ff4 188
benecsj 0:8d62137f7ff4 189 void FSHandler::onClose() //Connection is closing
benecsj 0:8d62137f7ff4 190 {
benecsj 0:8d62137f7ff4 191 if(m_fp)
benecsj 0:8d62137f7ff4 192 fclose(m_fp);
benecsj 0:8d62137f7ff4 193 }