Hiroshi Yamaguchi
Station API
Station.h@0:d81f611c59ec, 2011-11-30 (annotated)
- Committer:
- yamaguch
- Date:
- Wed Nov 30 04:35:45 2011 +0000
- Revision:
- 0:d81f611c59ec
- Child:
- 1:a22e390c70b3
Who changed what in which revision?
| User | Revision | Line number | New contents of line |
|---|---|---|---|
| yamaguch | 0:d81f611c59ec | 1 | /* |
| yamaguch | 0:d81f611c59ec | 2 | Copyright (c) 2011, Senio Networks, Inc. |
| yamaguch | 0:d81f611c59ec | 3 | |
| yamaguch | 0:d81f611c59ec | 4 | Permission is hereby granted, free of charge, to any person obtaining a copy |
| yamaguch | 0:d81f611c59ec | 5 | of this software and associated documentation files (the "Software"), to deal |
| yamaguch | 0:d81f611c59ec | 6 | in the Software without restriction, including without limitation the rights |
| yamaguch | 0:d81f611c59ec | 7 | to use, copy, modify, merge, publish, distribute, sublicense, and/or sell |
| yamaguch | 0:d81f611c59ec | 8 | copies of the Software, and to permit persons to whom the Software is |
| yamaguch | 0:d81f611c59ec | 9 | furnished to do so, subject to the following conditions: |
| yamaguch | 0:d81f611c59ec | 10 | |
| yamaguch | 0:d81f611c59ec | 11 | The above copyright notice and this permission notice shall be included in |
| yamaguch | 0:d81f611c59ec | 12 | all copies or substantial portions of the Software. |
| yamaguch | 0:d81f611c59ec | 13 | |
| yamaguch | 0:d81f611c59ec | 14 | THE SOFTWARE IS PROVIDED "AS IS", WITHOUT WARRANTY OF ANY KIND, EXPRESS OR |
| yamaguch | 0:d81f611c59ec | 15 | IMPLIED, INCLUDING BUT NOT LIMITED TO THE WARRANTIES OF MERCHANTABILITY, |
| yamaguch | 0:d81f611c59ec | 16 | FITNESS FOR A PARTICULAR PURPOSE AND NONINFRINGEMENT. IN NO EVENT SHALL THE |
| yamaguch | 0:d81f611c59ec | 17 | AUTHORS OR COPYRIGHT HOLDERS BE LIABLE FOR ANY CLAIM, DAMAGES OR OTHER |
| yamaguch | 0:d81f611c59ec | 18 | LIABILITY, WHETHER IN AN ACTION OF CONTRACT, TORT OR OTHERWISE, ARISING FROM, |
| yamaguch | 0:d81f611c59ec | 19 | OUT OF OR IN CONNECTION WITH THE SOFTWARE OR THE USE OR OTHER DEALINGS IN |
| yamaguch | 0:d81f611c59ec | 20 | THE SOFTWARE. |
| yamaguch | 0:d81f611c59ec | 21 | */ |
| yamaguch | 0:d81f611c59ec | 22 | |
| yamaguch | 0:d81f611c59ec | 23 | #ifndef STATION_H |
| yamaguch | 0:d81f611c59ec | 24 | #define STATION_H |
| yamaguch | 0:d81f611c59ec | 25 | |
| yamaguch | 0:d81f611c59ec | 26 | #include "SimpleSocket.h" |
| yamaguch | 0:d81f611c59ec | 27 | #include <map> |
| yamaguch | 0:d81f611c59ec | 28 | #include <string> |
| yamaguch | 0:d81f611c59ec | 29 | |
| yamaguch | 0:d81f611c59ec | 30 | class Station { |
| yamaguch | 0:d81f611c59ec | 31 | public: |
| yamaguch | 0:d81f611c59ec | 32 | Station(int port) : server(port) {} |
| yamaguch | 0:d81f611c59ec | 33 | |
| yamaguch | 0:d81f611c59ec | 34 | ~Station() {} |
| yamaguch | 0:d81f611c59ec | 35 | |
| yamaguch | 0:d81f611c59ec | 36 | void addHandler(string command, void (*handler)(void)) { |
| yamaguch | 0:d81f611c59ec | 37 | handlerMap.insert(pair<string, FunctionPointer>(command, FunctionPointer(handler))); |
| yamaguch | 0:d81f611c59ec | 38 | } |
| yamaguch | 0:d81f611c59ec | 39 | |
| yamaguch | 0:d81f611c59ec | 40 | template <typename T> void addHandler(string command, T* tptr, void (T::*handler)(void)) { |
| yamaguch | 0:d81f611c59ec | 41 | handlerMap.insert(pair<string, FunctionPointer>(command, FunctionPointer(tptr, handler))); |
| yamaguch | 0:d81f611c59ec | 42 | } |
| yamaguch | 0:d81f611c59ec | 43 | |
| yamaguch | 0:d81f611c59ec | 44 | void setBuffer(char *buf, int length) { |
| yamaguch | 0:d81f611c59ec | 45 | this->buf = buf; |
| yamaguch | 0:d81f611c59ec | 46 | this->length = length; |
| yamaguch | 0:d81f611c59ec | 47 | } |
| yamaguch | 0:d81f611c59ec | 48 | |
| yamaguch | 0:d81f611c59ec | 49 | void handleClient() { |
| yamaguch | 0:d81f611c59ec | 50 | ClientSocket client = server.accept(0); |
| yamaguch | 0:d81f611c59ec | 51 | while (client) { |
| yamaguch | 0:d81f611c59ec | 52 | if (client.available()) { |
| yamaguch | 0:d81f611c59ec | 53 | memset(buf, '\0', length); |
| yamaguch | 0:d81f611c59ec | 54 | int len = client.read(buf, this->length - 1); |
| yamaguch | 0:d81f611c59ec | 55 | char name[16] = {}; |
| yamaguch | 0:d81f611c59ec | 56 | sscanf(buf, "%s", name); |
| yamaguch | 0:d81f611c59ec | 57 | callHandler(string(name)); |
| yamaguch | 0:d81f611c59ec | 58 | if (buf[0]) { |
| yamaguch | 0:d81f611c59ec | 59 | client.write(buf, strlen(buf)); |
| yamaguch | 0:d81f611c59ec | 60 | } |
| yamaguch | 0:d81f611c59ec | 61 | client.close(); |
| yamaguch | 0:d81f611c59ec | 62 | } |
| yamaguch | 0:d81f611c59ec | 63 | } |
| yamaguch | 0:d81f611c59ec | 64 | } |
| yamaguch | 0:d81f611c59ec | 65 | |
| yamaguch | 0:d81f611c59ec | 66 | private: |
| yamaguch | 0:d81f611c59ec | 67 | ServerSocket server; |
| yamaguch | 0:d81f611c59ec | 68 | map<string, FunctionPointer> handlerMap; |
| yamaguch | 0:d81f611c59ec | 69 | char *buf; |
| yamaguch | 0:d81f611c59ec | 70 | int length; |
| yamaguch | 0:d81f611c59ec | 71 | |
| yamaguch | 0:d81f611c59ec | 72 | void callHandler(string name) { |
| yamaguch | 0:d81f611c59ec | 73 | for (map<string, FunctionPointer>::iterator it = handlerMap.begin(); it != handlerMap.end(); it++) { |
| yamaguch | 0:d81f611c59ec | 74 | if (name.compare(it->first) == 0) { |
| yamaguch | 0:d81f611c59ec | 75 | (it->second).call(); |
| yamaguch | 0:d81f611c59ec | 76 | return; |
| yamaguch | 0:d81f611c59ec | 77 | } |
| yamaguch | 0:d81f611c59ec | 78 | } |
| yamaguch | 0:d81f611c59ec | 79 | sprintf(buf, "Unknown: %s\n", name.c_str()); |
| yamaguch | 0:d81f611c59ec | 80 | } |
| yamaguch | 0:d81f611c59ec | 81 | }; |
| yamaguch | 0:d81f611c59ec | 82 | |
| yamaguch | 0:d81f611c59ec | 83 | #endif |