Station API
Station.h@5:3df13e2e928e, 2011-12-22 (annotated)
- Committer:
- yamaguch
- Date:
- Thu Dec 22 02:08:01 2011 +0000
- Revision:
- 5:3df13e2e928e
- Parent:
- 2:a9d1a9c92927
added #include \"Utils.h\"
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 | 2:a9d1a9c92927 | 30 | /** |
yamaguch | 2:a9d1a9c92927 | 31 | * A simple command/response network interface for mbed |
yamaguch | 2:a9d1a9c92927 | 32 | */ |
yamaguch | 0:d81f611c59ec | 33 | class Station { |
yamaguch | 0:d81f611c59ec | 34 | public: |
yamaguch | 2:a9d1a9c92927 | 35 | /** |
yamaguch | 2:a9d1a9c92927 | 36 | * creates a Station object |
yamaguch | 2:a9d1a9c92927 | 37 | * |
yamaguch | 2:a9d1a9c92927 | 38 | * @param port port number |
yamaguch | 2:a9d1a9c92927 | 39 | */ |
yamaguch | 0:d81f611c59ec | 40 | Station(int port) : server(port) {} |
yamaguch | 0:d81f611c59ec | 41 | |
yamaguch | 0:d81f611c59ec | 42 | ~Station() {} |
yamaguch | 2:a9d1a9c92927 | 43 | |
yamaguch | 2:a9d1a9c92927 | 44 | /** |
yamaguch | 2:a9d1a9c92927 | 45 | * adds a command handler |
yamaguch | 2:a9d1a9c92927 | 46 | * |
yamaguch | 2:a9d1a9c92927 | 47 | * @param command name of the command |
yamaguch | 2:a9d1a9c92927 | 48 | * @param handler pointer to the handler of the command |
yamaguch | 2:a9d1a9c92927 | 49 | */ |
yamaguch | 0:d81f611c59ec | 50 | void addHandler(string command, void (*handler)(void)) { |
yamaguch | 0:d81f611c59ec | 51 | handlerMap.insert(pair<string, FunctionPointer>(command, FunctionPointer(handler))); |
yamaguch | 0:d81f611c59ec | 52 | } |
yamaguch | 2:a9d1a9c92927 | 53 | |
yamaguch | 2:a9d1a9c92927 | 54 | /** |
yamaguch | 2:a9d1a9c92927 | 55 | * adds a command handler |
yamaguch | 2:a9d1a9c92927 | 56 | * |
yamaguch | 2:a9d1a9c92927 | 57 | * @param command name of the command |
yamaguch | 2:a9d1a9c92927 | 58 | * @param tptr pointer to the object to call the handler on |
yamaguch | 2:a9d1a9c92927 | 59 | * @param handler pointer to the handler of the command |
yamaguch | 2:a9d1a9c92927 | 60 | */ |
yamaguch | 0:d81f611c59ec | 61 | template <typename T> void addHandler(string command, T* tptr, void (T::*handler)(void)) { |
yamaguch | 0:d81f611c59ec | 62 | handlerMap.insert(pair<string, FunctionPointer>(command, FunctionPointer(tptr, handler))); |
yamaguch | 0:d81f611c59ec | 63 | } |
yamaguch | 0:d81f611c59ec | 64 | |
yamaguch | 2:a9d1a9c92927 | 65 | /** |
yamaguch | 2:a9d1a9c92927 | 66 | * sets the buffer for communication between caller and callee |
yamaguch | 2:a9d1a9c92927 | 67 | * |
yamaguch | 2:a9d1a9c92927 | 68 | * @param buf pointer to the communication buffer |
yamaguch | 2:a9d1a9c92927 | 69 | * @param length length of the buffer |
yamaguch | 2:a9d1a9c92927 | 70 | */ |
yamaguch | 0:d81f611c59ec | 71 | void setBuffer(char *buf, int length) { |
yamaguch | 0:d81f611c59ec | 72 | this->buf = buf; |
yamaguch | 0:d81f611c59ec | 73 | this->length = length; |
yamaguch | 0:d81f611c59ec | 74 | } |
yamaguch | 0:d81f611c59ec | 75 | |
yamaguch | 2:a9d1a9c92927 | 76 | /** |
yamaguch | 2:a9d1a9c92927 | 77 | * Check for any client and handle its request. This function is expected to be called repeatedly in main loop. |
yamaguch | 2:a9d1a9c92927 | 78 | */ |
yamaguch | 0:d81f611c59ec | 79 | void handleClient() { |
yamaguch | 0:d81f611c59ec | 80 | ClientSocket client = server.accept(0); |
yamaguch | 0:d81f611c59ec | 81 | while (client) { |
yamaguch | 0:d81f611c59ec | 82 | if (client.available()) { |
yamaguch | 0:d81f611c59ec | 83 | memset(buf, '\0', length); |
yamaguch | 0:d81f611c59ec | 84 | int len = client.read(buf, this->length - 1); |
yamaguch | 0:d81f611c59ec | 85 | char name[16] = {}; |
yamaguch | 0:d81f611c59ec | 86 | sscanf(buf, "%s", name); |
yamaguch | 0:d81f611c59ec | 87 | callHandler(string(name)); |
yamaguch | 0:d81f611c59ec | 88 | if (buf[0]) { |
yamaguch | 0:d81f611c59ec | 89 | client.write(buf, strlen(buf)); |
yamaguch | 0:d81f611c59ec | 90 | } |
yamaguch | 0:d81f611c59ec | 91 | client.close(); |
yamaguch | 0:d81f611c59ec | 92 | } |
yamaguch | 0:d81f611c59ec | 93 | } |
yamaguch | 0:d81f611c59ec | 94 | } |
yamaguch | 0:d81f611c59ec | 95 | |
yamaguch | 0:d81f611c59ec | 96 | private: |
yamaguch | 0:d81f611c59ec | 97 | ServerSocket server; |
yamaguch | 0:d81f611c59ec | 98 | map<string, FunctionPointer> handlerMap; |
yamaguch | 0:d81f611c59ec | 99 | char *buf; |
yamaguch | 0:d81f611c59ec | 100 | int length; |
yamaguch | 0:d81f611c59ec | 101 | |
yamaguch | 0:d81f611c59ec | 102 | void callHandler(string name) { |
yamaguch | 0:d81f611c59ec | 103 | for (map<string, FunctionPointer>::iterator it = handlerMap.begin(); it != handlerMap.end(); it++) { |
yamaguch | 0:d81f611c59ec | 104 | if (name.compare(it->first) == 0) { |
yamaguch | 0:d81f611c59ec | 105 | (it->second).call(); |
yamaguch | 1:a22e390c70b3 | 106 | break; |
yamaguch | 0:d81f611c59ec | 107 | } |
yamaguch | 0:d81f611c59ec | 108 | } |
yamaguch | 0:d81f611c59ec | 109 | } |
yamaguch | 0:d81f611c59ec | 110 | }; |
yamaguch | 0:d81f611c59ec | 111 | |
yamaguch | 0:d81f611c59ec | 112 | #endif |