Anh Tran / Mbed OS GR-Boards_WebCamera

test public

Dependencies:   HttpServer_snapshot_mbed-os

mbed-rpc/rpc.cpp@0:e9fd5575b10e, 2019-10-18 (annotated)

Committer:
anhtran
Date:
Fri Oct 18 03:09:43 2019 +0000
Revision:
0:e9fd5575b10e
abc

Who changed what in which revision?

UserRevisionLine numberNew contents of line
anhtran 0:e9fd5575b10e 1 /* mbed Microcontroller Library
anhtran 0:e9fd5575b10e 2 * Copyright (c) 2006-2013 ARM Limited
anhtran 0:e9fd5575b10e 3 *
anhtran 0:e9fd5575b10e 4 * Licensed under the Apache License, Version 2.0 (the "License");
anhtran 0:e9fd5575b10e 5 * you may not use this file except in compliance with the License.
anhtran 0:e9fd5575b10e 6 * You may obtain a copy of the License at
anhtran 0:e9fd5575b10e 7 *
anhtran 0:e9fd5575b10e 8 * http://www.apache.org/licenses/LICENSE-2.0
anhtran 0:e9fd5575b10e 9 *
anhtran 0:e9fd5575b10e 10 * Unless required by applicable law or agreed to in writing, software
anhtran 0:e9fd5575b10e 11 * distributed under the License is distributed on an "AS IS" BASIS,
anhtran 0:e9fd5575b10e 12 * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
anhtran 0:e9fd5575b10e 13 * See the License for the specific language governing permissions and
anhtran 0:e9fd5575b10e 14 * limitations under the License.
anhtran 0:e9fd5575b10e 15 */
anhtran 0:e9fd5575b10e 16 #include "rpc.h"
anhtran 0:e9fd5575b10e 17
anhtran 0:e9fd5575b10e 18 using namespace std;
anhtran 0:e9fd5575b10e 19
anhtran 0:e9fd5575b10e 20 namespace mbed {
anhtran 0:e9fd5575b10e 21
anhtran 0:e9fd5575b10e 22 RPC::RPC(const char *name) {
anhtran 0:e9fd5575b10e 23 _from_construct = false;
anhtran 0:e9fd5575b10e 24 if (name != NULL) {
anhtran 0:e9fd5575b10e 25 _name = new char[strlen(name) + 1];
anhtran 0:e9fd5575b10e 26 strcpy(_name, name);
anhtran 0:e9fd5575b10e 27 } else {
anhtran 0:e9fd5575b10e 28 _name = new char[12];
anhtran 0:e9fd5575b10e 29 sprintf(_name, "obj%p", this);
anhtran 0:e9fd5575b10e 30 }
anhtran 0:e9fd5575b10e 31 // put this object at head of the list
anhtran 0:e9fd5575b10e 32 _next = _head;
anhtran 0:e9fd5575b10e 33 _head = this;
anhtran 0:e9fd5575b10e 34 }
anhtran 0:e9fd5575b10e 35
anhtran 0:e9fd5575b10e 36 RPC::~RPC() {
anhtran 0:e9fd5575b10e 37 // remove this object from the list
anhtran 0:e9fd5575b10e 38 if (_head == this) { // first in the list, so just drop me
anhtran 0:e9fd5575b10e 39 _head = _next;
anhtran 0:e9fd5575b10e 40 } else { // find the object before me, then drop me
anhtran 0:e9fd5575b10e 41 RPC* p = _head;
anhtran 0:e9fd5575b10e 42 while (p->_next != this) {
anhtran 0:e9fd5575b10e 43 p = p->_next;
anhtran 0:e9fd5575b10e 44 }
anhtran 0:e9fd5575b10e 45 p->_next = _next;
anhtran 0:e9fd5575b10e 46 }
anhtran 0:e9fd5575b10e 47 }
anhtran 0:e9fd5575b10e 48
anhtran 0:e9fd5575b10e 49 const rpc_method *RPC::get_rpc_methods() {
anhtran 0:e9fd5575b10e 50 static const rpc_method methods[] = {
anhtran 0:e9fd5575b10e 51 {"delete", rpc_method_caller<RPC, &RPC::delete_self> },
anhtran 0:e9fd5575b10e 52 RPC_METHOD_END
anhtran 0:e9fd5575b10e 53 };
anhtran 0:e9fd5575b10e 54 return methods;
anhtran 0:e9fd5575b10e 55 }
anhtran 0:e9fd5575b10e 56
anhtran 0:e9fd5575b10e 57 RPC *RPC::lookup(const char *name) {
anhtran 0:e9fd5575b10e 58 size_t len = strlen(name);
anhtran 0:e9fd5575b10e 59 for (RPC *p = _head; p != NULL; p = p->_next) {
anhtran 0:e9fd5575b10e 60 /* Check that p->_name matches name and is the correct length */
anhtran 0:e9fd5575b10e 61 if (strncmp(p->_name, name, len) == 0 && (strlen(p->_name) == len)) {
anhtran 0:e9fd5575b10e 62 return p;
anhtran 0:e9fd5575b10e 63 }
anhtran 0:e9fd5575b10e 64 }
anhtran 0:e9fd5575b10e 65 return NULL;
anhtran 0:e9fd5575b10e 66 }
anhtran 0:e9fd5575b10e 67
anhtran 0:e9fd5575b10e 68 void RPC::delete_self() {
anhtran 0:e9fd5575b10e 69 delete[] _name;
anhtran 0:e9fd5575b10e 70 if (_from_construct) {
anhtran 0:e9fd5575b10e 71 delete this;
anhtran 0:e9fd5575b10e 72 }
anhtran 0:e9fd5575b10e 73 }
anhtran 0:e9fd5575b10e 74
anhtran 0:e9fd5575b10e 75 void RPC::list_objs(Arguments *args, Reply *result) {
anhtran 0:e9fd5575b10e 76 for (RPC *ptr = RPC::_head; ptr != NULL; ptr = ptr->_next) {
anhtran 0:e9fd5575b10e 77 if (ptr->_from_construct) {
anhtran 0:e9fd5575b10e 78 result->putData<const char*>(ptr->_name);
anhtran 0:e9fd5575b10e 79 }
anhtran 0:e9fd5575b10e 80 }
anhtran 0:e9fd5575b10e 81 }
anhtran 0:e9fd5575b10e 82
anhtran 0:e9fd5575b10e 83 void RPC::clear(Arguments*, Reply*) {
anhtran 0:e9fd5575b10e 84 RPC *ptr = RPC::_head;
anhtran 0:e9fd5575b10e 85 while (ptr != NULL) {
anhtran 0:e9fd5575b10e 86 RPC *tmp = ptr;
anhtran 0:e9fd5575b10e 87 ptr = ptr->_next;
anhtran 0:e9fd5575b10e 88 delete[] tmp->_name;
anhtran 0:e9fd5575b10e 89 if (tmp->_from_construct) {
anhtran 0:e9fd5575b10e 90 delete tmp;
anhtran 0:e9fd5575b10e 91 }
anhtran 0:e9fd5575b10e 92 }
anhtran 0:e9fd5575b10e 93 }
anhtran 0:e9fd5575b10e 94
anhtran 0:e9fd5575b10e 95 const rpc_function RPC::_RPC_funcs[] = {
anhtran 0:e9fd5575b10e 96 {"clear", &RPC::clear },
anhtran 0:e9fd5575b10e 97 { "objects", &RPC::list_objs },
anhtran 0:e9fd5575b10e 98 RPC_METHOD_END
anhtran 0:e9fd5575b10e 99 };
anhtran 0:e9fd5575b10e 100
anhtran 0:e9fd5575b10e 101 rpc_class RPC::_RPC_class = { "RPC", _RPC_funcs, NULL };
anhtran 0:e9fd5575b10e 102
anhtran 0:e9fd5575b10e 103 RPC *RPC::_head = NULL;
anhtran 0:e9fd5575b10e 104
anhtran 0:e9fd5575b10e 105 rpc_class *RPC::_classes = &_RPC_class;
anhtran 0:e9fd5575b10e 106
anhtran 0:e9fd5575b10e 107 bool RPC::call(const char *request, char *reply) {
anhtran 0:e9fd5575b10e 108 if (request == NULL) return false;
anhtran 0:e9fd5575b10e 109
anhtran 0:e9fd5575b10e 110 Arguments args(request);
anhtran 0:e9fd5575b10e 111 Reply r(reply);
anhtran 0:e9fd5575b10e 112
anhtran 0:e9fd5575b10e 113 /* If there's no name print object and class names to result */
anhtran 0:e9fd5575b10e 114 if (args.obj_name == NULL) {
anhtran 0:e9fd5575b10e 115 for (RPC *p = RPC::_head; p != NULL; p = p->_next) {
anhtran 0:e9fd5575b10e 116 r.putData<const char*>(p->_name);
anhtran 0:e9fd5575b10e 117 }
anhtran 0:e9fd5575b10e 118 for (rpc_class *c = RPC::_classes; c != NULL; c = c->next) {
anhtran 0:e9fd5575b10e 119 r.putData<const char*>(c->name);
anhtran 0:e9fd5575b10e 120 }
anhtran 0:e9fd5575b10e 121 return true;
anhtran 0:e9fd5575b10e 122 }
anhtran 0:e9fd5575b10e 123
anhtran 0:e9fd5575b10e 124 /* First try matching an instance */
anhtran 0:e9fd5575b10e 125 RPC *p = lookup(args.obj_name);
anhtran 0:e9fd5575b10e 126 if (p != NULL) {
anhtran 0:e9fd5575b10e 127 /* Get the list of methods we support */
anhtran 0:e9fd5575b10e 128 const rpc_method *cur_method = p->get_rpc_methods();
anhtran 0:e9fd5575b10e 129
anhtran 0:e9fd5575b10e 130 /* When there's no method print method names to result */
anhtran 0:e9fd5575b10e 131 if (args.method_name == NULL) {
anhtran 0:e9fd5575b10e 132 while (true) {
anhtran 0:e9fd5575b10e 133 for (; cur_method->name != NULL; cur_method++) {
anhtran 0:e9fd5575b10e 134 r.putData<const char*>(cur_method->name);
anhtran 0:e9fd5575b10e 135 }
anhtran 0:e9fd5575b10e 136
anhtran 0:e9fd5575b10e 137 /* write_name_arr's args are references, so result and cur_method will have changed */
anhtran 0:e9fd5575b10e 138 if (cur_method->super != 0) {
anhtran 0:e9fd5575b10e 139 cur_method = cur_method->super(p);
anhtran 0:e9fd5575b10e 140 } else {
anhtran 0:e9fd5575b10e 141 return true;
anhtran 0:e9fd5575b10e 142 }
anhtran 0:e9fd5575b10e 143 }
anhtran 0:e9fd5575b10e 144 }
anhtran 0:e9fd5575b10e 145
anhtran 0:e9fd5575b10e 146 /* Look through the methods for the one whose name matches */
anhtran 0:e9fd5575b10e 147 while (true) {
anhtran 0:e9fd5575b10e 148 for (; cur_method->name != NULL; cur_method++) {
anhtran 0:e9fd5575b10e 149 if (strcmp(cur_method->name, args.method_name) == 0) {
anhtran 0:e9fd5575b10e 150 (cur_method->method_caller)(p, &args, &r);
anhtran 0:e9fd5575b10e 151 return true;
anhtran 0:e9fd5575b10e 152 }
anhtran 0:e9fd5575b10e 153 }
anhtran 0:e9fd5575b10e 154
anhtran 0:e9fd5575b10e 155 if (cur_method->super != 0) {
anhtran 0:e9fd5575b10e 156 cur_method = cur_method->super(p);
anhtran 0:e9fd5575b10e 157 } else {
anhtran 0:e9fd5575b10e 158 /* end of methods and no match */
anhtran 0:e9fd5575b10e 159 return false;
anhtran 0:e9fd5575b10e 160 }
anhtran 0:e9fd5575b10e 161
anhtran 0:e9fd5575b10e 162 }
anhtran 0:e9fd5575b10e 163 }
anhtran 0:e9fd5575b10e 164
anhtran 0:e9fd5575b10e 165 /* Then try a class */
anhtran 0:e9fd5575b10e 166 for (const rpc_class *q = _classes; q != NULL; q = q->next) {
anhtran 0:e9fd5575b10e 167 if (strcmp(q->name, args.obj_name) == 0) {
anhtran 0:e9fd5575b10e 168 /* Matched the class name, so get its functions */
anhtran 0:e9fd5575b10e 169 const rpc_function *cur_func = q->static_functions;
anhtran 0:e9fd5575b10e 170 if (args.method_name == NULL) {
anhtran 0:e9fd5575b10e 171 for (; cur_func->name != NULL; cur_func++) {
anhtran 0:e9fd5575b10e 172 r.putData<const char*>(cur_func->name);
anhtran 0:e9fd5575b10e 173 }
anhtran 0:e9fd5575b10e 174 return true;
anhtran 0:e9fd5575b10e 175 } else {
anhtran 0:e9fd5575b10e 176 /* Otherwise call the appropriate function */
anhtran 0:e9fd5575b10e 177 for (; cur_func->name != NULL; cur_func++) {
anhtran 0:e9fd5575b10e 178 if (strcmp(cur_func->name, args.method_name) == 0) {
anhtran 0:e9fd5575b10e 179 (cur_func->function_caller)(&args, &r);
anhtran 0:e9fd5575b10e 180 return true;
anhtran 0:e9fd5575b10e 181 }
anhtran 0:e9fd5575b10e 182 }
anhtran 0:e9fd5575b10e 183 return false;
anhtran 0:e9fd5575b10e 184 }
anhtran 0:e9fd5575b10e 185 }
anhtran 0:e9fd5575b10e 186 }
anhtran 0:e9fd5575b10e 187
anhtran 0:e9fd5575b10e 188 return false;
anhtran 0:e9fd5575b10e 189 }
anhtran 0:e9fd5575b10e 190
anhtran 0:e9fd5575b10e 191 } // namespace mbed
anhtran 0:e9fd5575b10e 192