创建mbed
Dependencies: EthernetInterface SDFileSystem mbed-rtos mbed
Diff: main.cpp
- Revision:
- 1:6465a3f5c58a
- Parent:
- 0:610235504baa
--- a/main.cpp Mon Mar 05 14:58:17 2018 +0000 +++ b/main.cpp Tue Mar 06 08:53:46 2018 +0000 @@ -1,371 +1,51 @@ #include "mbed.h" -#include "EthernetInterface.h" -#include "SDFileSystem.h" #include "rtos.h" -#define EnDebugMSG false //true-> print debug message to PC USB terminal, false->not print -#include "filelib.h" - -#define IP "192.168.100.100" -#define MASK "255.255.255.0" -#define GATEWAY "192.168.100.1" -#define PORT 80 +DigitalOut led1(LED1); +DigitalOut led2(LED2); +DigitalOut led3(LED3); +DigitalOut led4(LED4); -Serial pc (USBTX,USBRX); // tx, rx -SDFileSystem sd(SD_MOSI, SD_MISO, SD_SCK, SD_CS, "wfs"); // the pinout on the mbed - -char sMethod[7]; -char sURL[250]; -char sProtocol[8]; - -EthernetInterface eth; +Serial pc(PC_6,PC_7); +uint16_t ledvalue=0; +uint16_t ledvalue2=0; +Ticker tick; +void setLed(uint8_t val) +{ + // led1=val % 2; -TCPSocketServer svr; -bool serverIsListened = false; + led2=(val /2 ) % 2; -TCPSocketConnection client; -bool clientIsConnected = false; + led3=(val /4 ) % 2; -char sentBuffer[1608] = {}; // 2*536=1072, 3*536=1608, 4*536=2144 !1500 -char line_response[256]= {0}; -char file_path[256] = {0}; + led4=(val /5 ) % 2; +} -DigitalOut led1(LED1); //server listning status -DigitalOut led2(LED2); //socket connecting status - -Ticker ledTick; - -void ledTickfunc() +void printstr(void const *args) { - if(serverIsListened) { - led1 = !led1; - } else { - led1 = false; + while (true) { + pc.printf("Hello World,Now value is %d.\n",ledvalue); + // pc.printf("Hello World,Now value is %d.\n",*(uint8_t *)args); + Thread::wait(1000); } } -void send_HTTP_header(char* protocol, int code, char* title, char* mime_type, long long lengthBody) -{ - snprintf(line_response, sizeof(line_response),"%s %d %s\r\n", protocol, code, title ); - snprintf(sentBuffer, sizeof(sentBuffer),"%s",line_response); - - if ( mime_type != NULL ) { - snprintf(line_response, sizeof(line_response), "Content-Type: %s\r\n", mime_type ); - snprintf(sentBuffer, sizeof(sentBuffer), "%s%s",sentBuffer,line_response); //append to sentBuffer - } - if ( lengthBody >= 0 ) { - snprintf(line_response, sizeof(line_response), "Content-Length: %lld\r\n", lengthBody ); - snprintf(sentBuffer, sizeof(sentBuffer), "%s%s",sentBuffer,line_response); //append to sentBuffer - } - snprintf(line_response, sizeof(line_response), "Connection: close\r\n" ); - snprintf(sentBuffer, sizeof(sentBuffer),"%s%s\r\n",sentBuffer,line_response); //append to sentBuffer - - if (EnDebugMSG) - printf("\n-->sent Header--\n"); - - client.send_all(sentBuffer,strlen(sentBuffer)); - if (EnDebugMSG) { - printf(sentBuffer); - printf("\n--end Header-- bytes:%d",strlen(sentBuffer)); - } - Thread::wait(200); //200ms important for browser! -} - -void send_HTML_line(char* line, unsigned int length_line) -{ - client.send_all(line,length_line); - if (EnDebugMSG) - printf("\n-->send HTML line:\n%s ...Ok!",line); - Thread::wait(10); -} - -void send_HTML_error( int status_code, char* title, char* body_text) -{ - send_HTTP_header("HTTP/1.1", status_code, title, "text/html", -1); - if (EnDebugMSG) - printf("\n-->send_error...\n"); - sentBuffer[0]=NULL; //clear buffer - sprintf(line_response, "<!DOCTYPE html>\r\n<html>\r\n<head>\r\n<title>%d %s</title>\r\n</head>\r\n", status_code, title); - snprintf(&(sentBuffer[strlen(sentBuffer)]),sizeof(sentBuffer),"%s",line_response); //append to buffer - sprintf(line_response, "<body><center><h2><center>%d %s</center></h2>\r\n",status_code, title ); - snprintf(&(sentBuffer[strlen(sentBuffer)]),sizeof(sentBuffer),"%s",line_response); //append to buffer - sprintf(line_response, "%s\r\n", body_text ); - snprintf(&(sentBuffer[strlen(sentBuffer)]),sizeof(sentBuffer),"%s",line_response); //append to buffer - sprintf(line_response, "<p>mbed HTTP File Server</p>\r\n</center></body></html>\r\n"); - snprintf(&(sentBuffer[strlen(sentBuffer)]),sizeof(sentBuffer),"%s",line_response); //append to buffer - send_HTML_line(sentBuffer, strlen(sentBuffer)); -} - -int send_file(char *path_file) -{ - char *mime_type = {0}; - unsigned int bytes_for_send=0; - long long filesize, all_send_bytes = 0; - - mime_type = get_mime_type( path_file ); - snprintf(file_path, sizeof(file_path),"/wfs/%s",path_file); - if (EnDebugMSG) { - printf("\n-->from send_file:%s",file_path); - printf("\n-->from send_file mime type:%s",mime_type); - } - - if (Mystat(path_file, &myStatBuf)) { //fault with file - send_HTML_error( 403, "Forbidden", "403 - File access forbidden."); - return 403; - } - FILE* fp = NULL; - fp = fopen(file_path,"r"); - if (fp==NULL ) { - send_HTML_error( 403, "Forbidden", "403 - File access forbidden."); - return 403; - } - - filesize = myStatBuf.st_size; - send_HTTP_header("HTTP/1.1", 200, "Ok", mime_type, myStatBuf.st_size); - //binary send - all_send_bytes=0; - while(filesize) { //check for EOF !feof(fp) - bytes_for_send = filesize; - if (bytes_for_send > sizeof(sentBuffer)) { - bytes_for_send = sizeof(sentBuffer); - } - fread (sentBuffer,1,bytes_for_send,fp); - filesize -= bytes_for_send; - if (EnDebugMSG) - printf("\n---bytes_for_send...%d",bytes_for_send); - client.send_all(sentBuffer,bytes_for_send); - //Thread::wait(10); - all_send_bytes += bytes_for_send; - } - if (EnDebugMSG) - printf("\n---buffer fill end - all ...%lld", all_send_bytes); - //binary send - - sprintf(line_response, "\r\n"); - client.send_all(line_response,strlen(line_response)); - if ( fp != NULL ) - fclose(fp); - //Thread::wait(10); - return 0; -} - -int send_directory(char *path) +void led(void const *args) { - char process_name[64]= {0}; - - char posOfLastSlash; - char *pLS; - - struct dirent *p; - struct sMystat sb; - struct tm *timeinfo; - char timeBuf[40]; - - if (EnDebugMSG) - printf("\n-->from send_directory:%s",path); - snprintf(file_path,sizeof(file_path),"/wfs%s",path); - DIR *d = opendir(file_path); - if (EnDebugMSG && d!=NULL) - printf("\n-->from send_directory:%s ...open OK",file_path); - if (d==NULL) { //error open dir - send_HTML_error( 403, "Forbidden", "403 - Directory access forbidden."); - return -1; - } - send_HTTP_header("HTTP/1.1", 200, "Ok",NULL, -1); - sentBuffer[0]=NULL; - sprintf(line_response,"<!DOCTYPE html>\r\n<html>\n<head><title>Index of %s</title>\n",path); - snprintf(&(sentBuffer[strlen(sentBuffer)]),sizeof(sentBuffer),"%s",line_response); //append to buffer - - sprintf(line_response,"<meta content=\"text/html; charset=iso-8859-1\" http-equiv=\"Content-Type\"></head>\n"); - snprintf(&(sentBuffer[strlen(sentBuffer)]),sizeof(sentBuffer),"%s",line_response); //append to buffer - - - sprintf(line_response,"<body><center>\n<h3>Index of %s</h3>\n", path); - snprintf(&(sentBuffer[strlen(sentBuffer)]),sizeof(sentBuffer),"%s",line_response); //append to buffer - send_HTML_line(sentBuffer, strlen(sentBuffer)); -//begin table - sentBuffer[0]=NULL; //clear buffer - sprintf(line_response,"<table border=\"0\">\n"); - snprintf(&(sentBuffer[strlen(sentBuffer)]),sizeof(sentBuffer),"%s",line_response); //append to buffer - sprintf(line_response,"<tr><th align=\"left\" width=\"200\">Name</th><th align=\"right\" width=\"100\">Size(bytes)</th><th align=\"right\" width=\"200\">Date/Time</th></tr>\n"); - snprintf(&(sentBuffer[strlen(sentBuffer)]),sizeof(sentBuffer),"%s",line_response); //append to buffer -//begin table - - pLS=strrchr(path,'/'); - posOfLastSlash=pLS-path+1; - if (EnDebugMSG) - printf("\r\n>>posOfLastSlash=%d",posOfLastSlash); - snprintf(process_name,posOfLastSlash+1,"%s",path); - if (EnDebugMSG) - printf("\r\n>>process_name=%s",process_name); - sprintf(line_response,"<tr><td align=\"left\"><a href=\"%s\">../</a></td></tr>\n",process_name); - snprintf(&(sentBuffer[strlen(sentBuffer)]),sizeof(sentBuffer),"%s",line_response); //append to buffer - while((p = readdir(d)) != NULL) { - if (EnDebugMSG) - printf("\n :%s",p->d_name); - sprintf(file_path,"%s/%s",path,p->d_name); - Mystat( file_path, &sb ); - if (get_dirInfo(file_path)==0 ) { //this is directory path - if (EnDebugMSG) - printf("\nDIR"); - sprintf(line_response, "<tr><td align=\"left\"><a href=\"%s\">%s</a><br></td></tr>\n",file_path,p->d_name); - if (strlen(line_response)>(sizeof(sentBuffer)-strlen(sentBuffer))) { //buffer must be sent - send_HTML_line(sentBuffer, strlen(sentBuffer)); - sentBuffer[0]=NULL; //clear buffer - } - snprintf(&(sentBuffer[strlen(sentBuffer)]),sizeof(sentBuffer),"%s",line_response); //append to buffer - - } else { //this is file - if (EnDebugMSG) - printf("\nFILE"); - timeinfo = localtime (&sb.st_mtime); - //strftime(timeBuf,40, "%I:%M:%S %p (%Y/%m/%d)\r\n", localtime(&sb.st_mtime)); - strftime(timeBuf, 40, "%c", timeinfo); - sprintf(line_response, "<tr><td align=\"left\"><a href=\"%s\">%s</a></td><td align=\"right\">%lld</td><td align=\"right\">%s</td></tr>\n", file_path, p->d_name,(long long) sb.st_size,timeBuf); // asctime(timeinfo) ); - - if (strlen(line_response)>(sizeof(sentBuffer)-strlen(sentBuffer))) { //buffer must be sent - send_HTML_line(sentBuffer, strlen(sentBuffer)); - sentBuffer[0]=NULL; //clear buffer - } - snprintf(&(sentBuffer[strlen(sentBuffer)]),sizeof(sentBuffer),"%s",line_response); //append to buffer - } - } - send_HTML_line(sentBuffer, strlen(sentBuffer)); - closedir(d); - - sprintf(line_response, "</table>\n<br><h4>mbed HTTP File Server</h4>\n</center></body></html>\n"); - send_HTML_line(line_response, strlen(line_response)); - - return 0; -} - -void parseHTTPRequest(char* buffer) -{ - char spacePos; - char *tmpBuffer; - spacePos = strcspn(buffer, " ") + 1; //position of first space character - snprintf(sMethod, spacePos,"%s", buffer); - - //get Protocol - tmpBuffer=&(buffer[spacePos]); //move pointer to buffer (delete Method) - spacePos = strcspn(tmpBuffer, "\r\n") + 1; - tmpBuffer[spacePos]='\0'; //set end of string ...cut - sprintf(sProtocol, "%s", strrchr(tmpBuffer,' ')); //get string after last (space ) - printf("\r\nsProtocol:%s", tmpBuffer); - buffer = &(sProtocol[1]); //cut first character (space) - sprintf(sProtocol, "%s", buffer); - - //get URL - snprintf(sURL,strlen(tmpBuffer)-strlen(sProtocol),"%s\r\n", tmpBuffer); //URL is between Method and Protocol - - printf("\nParse Method:%s",sMethod); - printf("\nParse URL:%s",sURL); - printf("\nParse PROTOCOL:%s",sProtocol); - printf("\n\r\n"); -} - -int processHTTP(char* sMethod, char* sURL, char* sProtocol) -{ - int gdi, gfi; //status of get_dir_info(xxx), and get_file_info(xxx) - - if (strcmp(sMethod,"GET")!=0) { - send_HTML_error( 501, "501 Not Implemented", "501 - The server either does not recognize the request method"); - return 501; - } - if (sURL[0]!= '/') { - send_HTML_error( 400, "Bad Request", "400 - The request cannot be fulfilled due to bad syntax."); - return 400; - } - if (sURL[strlen(sURL)-1]=='/') { - sURL[strlen(sURL)-1]=sURL[strlen(sURL)]; //delete last symbol - if (EnDebugMSG) - printf("\n delete last:%s",sURL); - } - gdi= get_dirInfo(sURL); - gfi= get_fileInfo(sURL); - if (gfi!=0) { //!=0 file not found - if (gdi==0) { //0-ok this is directory - return send_directory(sURL); - } - if (EnDebugMSG) - printf("\n404-br File not found or...(Fresult is:%d)",gfi); - send_HTML_error( 404, "Not Found","404 - The requested resource could not be found."); - return 404; - } else { //==0 found - if (gdi==0) //0-ok this is directory - return send_directory(sURL); - else - return send_file(sURL); + while (true) { + led1=!led1; + Thread::wait(100); } } int main() { - printf("\r\n---- HTTP Server ----\r\n"); - - ledTick.attach(&ledTickfunc,0.5); - //ledTick.detach(); - //setup ethernet interface - eth.init(); //Use DHCP - // eth.init(IP,MASK,GATEWAY); //IP,mask,Gateway - eth.connect(); - printf("IP Address is %s\n\r", eth.getIPAddress()); - - //setup tcp socket - if(svr.bind(PORT)< 0) { - printf("tcp server bind failed.\n\r"); - return -1; - } else { - printf("tcp server bind successed.\n\r"); - serverIsListened = true; - } - - if(svr.listen(1) < 0) { - printf("tcp server listen failed.\n\r"); - return -1; - } else { - printf("tcp server is listening...\n\r"); + //Thread thread(printstr); + Thread thread(printstr,&ledvalue); + Thread thread2(led,&ledvalue2); + while (1) + { + setLed(++ledvalue); + Thread::wait(100); } - - //listening for http GET request - while (serverIsListened) { - //blocking mode(never timeout) - if(svr.accept(client)<0) { - printf("failed to accept connection.\n\r"); - } else { - //client.set_blocking(false,5000); //5000=5sec - printf("connection success!\n\rIP: %s\n\r",client.get_address()); - clientIsConnected = true; - led2 = true; - while(clientIsConnected) { - char buffer[1024] = {}; - switch(client.receive(buffer, 1023)) { - case 0: - printf("recieved buffer is empty.\n\r"); - clientIsConnected = false; - break; - case -1: - printf("failed to read data from client.\n\r"); - clientIsConnected = false; - break; - default: - printf("Recieved Data: %d\n\r\n\r%.*s\n\r",strlen(buffer),strlen(buffer),buffer); - parseHTTPRequest(buffer); - //if(buffer[0] == 'G' && buffer[1] == 'E' && buffer[2] == 'T' ) { - if (strcmp(sMethod, "GET" ) == 0 ) { - printf("GET request incomming.\n\r"); - processHTTP(sMethod, sURL, sProtocol); - clientIsConnected = false; - }//if get - break; - } //switch - //ledTick.attach(&ledTickfunc,0.5); - }//while - printf("close connection.\n\rHTTP server is listening...\n\r\n"); - client.close(); - Thread::wait(50); - led2 = false; - } - } - }