Marco Mayer / Mbed OS Queue

Important changes to repositories hosted on mbed.com

Mbed hosted mercurial repositories are deprecated and are due to be permanently deleted in July 2026.

To keep a copy of this software download the repository Zip archive or clone locally using Mercurial.

It is also possible to export all your personal repositories from the account settings page.

mbed-os/features/netsocket/NetworkStack.cpp@0:6bf0743ece18, 2020-03-28 (annotated)

Committer:
demayer
Date:
Sat Mar 28 15:28:19 2020 +0000
Revision:
0:6bf0743ece18
IMU Thread with an event-queue running parallel to handle tasks like a 5 times blinking LED. Button with interrupt detected.

Who changed what in which revision?

UserRevisionLine numberNew contents of line
demayer 0:6bf0743ece18 1 /* Socket
demayer 0:6bf0743ece18 2 * Copyright (c) 2015 ARM Limited
demayer 0:6bf0743ece18 3 *
demayer 0:6bf0743ece18 4 * Licensed under the Apache License, Version 2.0 (the "License");
demayer 0:6bf0743ece18 5 * you may not use this file except in compliance with the License.
demayer 0:6bf0743ece18 6 * You may obtain a copy of the License at
demayer 0:6bf0743ece18 7 *
demayer 0:6bf0743ece18 8 * http://www.apache.org/licenses/LICENSE-2.0
demayer 0:6bf0743ece18 9 *
demayer 0:6bf0743ece18 10 * Unless required by applicable law or agreed to in writing, software
demayer 0:6bf0743ece18 11 * distributed under the License is distributed on an "AS IS" BASIS,
demayer 0:6bf0743ece18 12 * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
demayer 0:6bf0743ece18 13 * See the License for the specific language governing permissions and
demayer 0:6bf0743ece18 14 * limitations under the License.
demayer 0:6bf0743ece18 15 */
demayer 0:6bf0743ece18 16
demayer 0:6bf0743ece18 17 #include "NetworkStack.h"
demayer 0:6bf0743ece18 18 #include "nsapi_dns.h"
demayer 0:6bf0743ece18 19 #include "mbed.h"
demayer 0:6bf0743ece18 20 #include "stddef.h"
demayer 0:6bf0743ece18 21 #include <new>
demayer 0:6bf0743ece18 22
demayer 0:6bf0743ece18 23
demayer 0:6bf0743ece18 24 // Default NetworkStack operations
demayer 0:6bf0743ece18 25 nsapi_error_t NetworkStack::gethostbyname(const char *name, SocketAddress *address, nsapi_version_t version)
demayer 0:6bf0743ece18 26 {
demayer 0:6bf0743ece18 27 // check for simple ip addresses
demayer 0:6bf0743ece18 28 if (address->set_ip_address(name)) {
demayer 0:6bf0743ece18 29 if (version != NSAPI_UNSPEC && address->get_ip_version() != version) {
demayer 0:6bf0743ece18 30 return NSAPI_ERROR_DNS_FAILURE;
demayer 0:6bf0743ece18 31 }
demayer 0:6bf0743ece18 32
demayer 0:6bf0743ece18 33 return NSAPI_ERROR_OK;
demayer 0:6bf0743ece18 34 }
demayer 0:6bf0743ece18 35
demayer 0:6bf0743ece18 36 // if the version is unspecified, try to guess the version from the
demayer 0:6bf0743ece18 37 // ip address of the underlying stack
demayer 0:6bf0743ece18 38 if (version == NSAPI_UNSPEC) {
demayer 0:6bf0743ece18 39 SocketAddress testaddress;
demayer 0:6bf0743ece18 40 if (testaddress.set_ip_address(this->get_ip_address())) {
demayer 0:6bf0743ece18 41 version = testaddress.get_ip_version();
demayer 0:6bf0743ece18 42 }
demayer 0:6bf0743ece18 43 }
demayer 0:6bf0743ece18 44
demayer 0:6bf0743ece18 45 return nsapi_dns_query(this, name, address, version);
demayer 0:6bf0743ece18 46 }
demayer 0:6bf0743ece18 47
demayer 0:6bf0743ece18 48 nsapi_error_t NetworkStack::add_dns_server(const SocketAddress &address)
demayer 0:6bf0743ece18 49 {
demayer 0:6bf0743ece18 50 return nsapi_dns_add_server(address);
demayer 0:6bf0743ece18 51 }
demayer 0:6bf0743ece18 52
demayer 0:6bf0743ece18 53 nsapi_error_t NetworkStack::setstackopt(int level, int optname, const void *optval, unsigned optlen)
demayer 0:6bf0743ece18 54 {
demayer 0:6bf0743ece18 55 return NSAPI_ERROR_UNSUPPORTED;
demayer 0:6bf0743ece18 56 }
demayer 0:6bf0743ece18 57
demayer 0:6bf0743ece18 58 nsapi_error_t NetworkStack::getstackopt(int level, int optname, void *optval, unsigned *optlen)
demayer 0:6bf0743ece18 59 {
demayer 0:6bf0743ece18 60 return NSAPI_ERROR_UNSUPPORTED;
demayer 0:6bf0743ece18 61 }
demayer 0:6bf0743ece18 62
demayer 0:6bf0743ece18 63 nsapi_error_t NetworkStack::setsockopt(void *handle, int level, int optname, const void *optval, unsigned optlen)
demayer 0:6bf0743ece18 64 {
demayer 0:6bf0743ece18 65 return NSAPI_ERROR_UNSUPPORTED;
demayer 0:6bf0743ece18 66 }
demayer 0:6bf0743ece18 67
demayer 0:6bf0743ece18 68 nsapi_error_t NetworkStack::getsockopt(void *handle, int level, int optname, void *optval, unsigned *optlen)
demayer 0:6bf0743ece18 69 {
demayer 0:6bf0743ece18 70 return NSAPI_ERROR_UNSUPPORTED;
demayer 0:6bf0743ece18 71 }
demayer 0:6bf0743ece18 72
demayer 0:6bf0743ece18 73
demayer 0:6bf0743ece18 74 // NetworkStackWrapper class for encapsulating the raw nsapi_stack structure
demayer 0:6bf0743ece18 75 class NetworkStackWrapper : public NetworkStack
demayer 0:6bf0743ece18 76 {
demayer 0:6bf0743ece18 77 private:
demayer 0:6bf0743ece18 78 inline nsapi_stack_t *_stack()
demayer 0:6bf0743ece18 79 {
demayer 0:6bf0743ece18 80 return reinterpret_cast<nsapi_stack_t *>(
demayer 0:6bf0743ece18 81 reinterpret_cast<uint8_t *>(this)
demayer 0:6bf0743ece18 82 - offsetof(nsapi_stack_t, _stack_buffer));
demayer 0:6bf0743ece18 83 }
demayer 0:6bf0743ece18 84
demayer 0:6bf0743ece18 85 inline const nsapi_stack_api_t *_stack_api()
demayer 0:6bf0743ece18 86 {
demayer 0:6bf0743ece18 87 return _stack()->stack_api;
demayer 0:6bf0743ece18 88 }
demayer 0:6bf0743ece18 89
demayer 0:6bf0743ece18 90 public:
demayer 0:6bf0743ece18 91 virtual const char *get_ip_address()
demayer 0:6bf0743ece18 92 {
demayer 0:6bf0743ece18 93 if (!_stack_api()->get_ip_address) {
demayer 0:6bf0743ece18 94 return 0;
demayer 0:6bf0743ece18 95 }
demayer 0:6bf0743ece18 96
demayer 0:6bf0743ece18 97 static uint8_t buffer[sizeof(SocketAddress)];
demayer 0:6bf0743ece18 98 SocketAddress *address = new (buffer) SocketAddress(_stack_api()->get_ip_address(_stack()));
demayer 0:6bf0743ece18 99 return address->get_ip_address();
demayer 0:6bf0743ece18 100 }
demayer 0:6bf0743ece18 101
demayer 0:6bf0743ece18 102 virtual nsapi_error_t gethostbyname(const char *name, SocketAddress *address, nsapi_version_t version)
demayer 0:6bf0743ece18 103 {
demayer 0:6bf0743ece18 104 if (!_stack_api()->gethostbyname) {
demayer 0:6bf0743ece18 105 return NetworkStack::gethostbyname(name, address, version);
demayer 0:6bf0743ece18 106 }
demayer 0:6bf0743ece18 107
demayer 0:6bf0743ece18 108 nsapi_addr_t addr = {NSAPI_UNSPEC, 0};
demayer 0:6bf0743ece18 109 nsapi_error_t err = _stack_api()->gethostbyname(_stack(), name, &addr, version);
demayer 0:6bf0743ece18 110 address->set_addr(addr);
demayer 0:6bf0743ece18 111 return err;
demayer 0:6bf0743ece18 112 }
demayer 0:6bf0743ece18 113
demayer 0:6bf0743ece18 114 virtual nsapi_error_t add_dns_server(const SocketAddress &address)
demayer 0:6bf0743ece18 115 {
demayer 0:6bf0743ece18 116 if (!_stack_api()->add_dns_server) {
demayer 0:6bf0743ece18 117 return NetworkStack::add_dns_server(address);
demayer 0:6bf0743ece18 118 }
demayer 0:6bf0743ece18 119
demayer 0:6bf0743ece18 120 return _stack_api()->add_dns_server(_stack(), address.get_addr());
demayer 0:6bf0743ece18 121 }
demayer 0:6bf0743ece18 122
demayer 0:6bf0743ece18 123 virtual nsapi_error_t setstackopt(int level, int optname, const void *optval, unsigned optlen)
demayer 0:6bf0743ece18 124 {
demayer 0:6bf0743ece18 125 if (!_stack_api()->setstackopt) {
demayer 0:6bf0743ece18 126 return NSAPI_ERROR_UNSUPPORTED;
demayer 0:6bf0743ece18 127 }
demayer 0:6bf0743ece18 128
demayer 0:6bf0743ece18 129 return _stack_api()->setstackopt(_stack(), level, optname, optval, optlen);
demayer 0:6bf0743ece18 130 }
demayer 0:6bf0743ece18 131
demayer 0:6bf0743ece18 132 virtual nsapi_error_t getstackopt(int level, int optname, void *optval, unsigned *optlen)
demayer 0:6bf0743ece18 133 {
demayer 0:6bf0743ece18 134 if (!_stack_api()->getstackopt) {
demayer 0:6bf0743ece18 135 return NSAPI_ERROR_UNSUPPORTED;
demayer 0:6bf0743ece18 136 }
demayer 0:6bf0743ece18 137
demayer 0:6bf0743ece18 138 return _stack_api()->getstackopt(_stack(), level, optname, optval, optlen);
demayer 0:6bf0743ece18 139 }
demayer 0:6bf0743ece18 140
demayer 0:6bf0743ece18 141 protected:
demayer 0:6bf0743ece18 142 virtual nsapi_error_t socket_open(nsapi_socket_t *socket, nsapi_protocol_t proto)
demayer 0:6bf0743ece18 143 {
demayer 0:6bf0743ece18 144 if (!_stack_api()->socket_open) {
demayer 0:6bf0743ece18 145 return NSAPI_ERROR_UNSUPPORTED;
demayer 0:6bf0743ece18 146 }
demayer 0:6bf0743ece18 147
demayer 0:6bf0743ece18 148 return _stack_api()->socket_open(_stack(), socket, proto);
demayer 0:6bf0743ece18 149 }
demayer 0:6bf0743ece18 150
demayer 0:6bf0743ece18 151 virtual nsapi_error_t socket_close(nsapi_socket_t socket)
demayer 0:6bf0743ece18 152 {
demayer 0:6bf0743ece18 153 if (!_stack_api()->socket_close) {
demayer 0:6bf0743ece18 154 return NSAPI_ERROR_UNSUPPORTED;
demayer 0:6bf0743ece18 155 }
demayer 0:6bf0743ece18 156
demayer 0:6bf0743ece18 157 return _stack_api()->socket_close(_stack(), socket);
demayer 0:6bf0743ece18 158 }
demayer 0:6bf0743ece18 159
demayer 0:6bf0743ece18 160 virtual nsapi_error_t socket_bind(nsapi_socket_t socket, const SocketAddress &address)
demayer 0:6bf0743ece18 161 {
demayer 0:6bf0743ece18 162 if (!_stack_api()->socket_bind) {
demayer 0:6bf0743ece18 163 return NSAPI_ERROR_UNSUPPORTED;
demayer 0:6bf0743ece18 164 }
demayer 0:6bf0743ece18 165
demayer 0:6bf0743ece18 166 return _stack_api()->socket_bind(_stack(), socket, address.get_addr(), address.get_port());
demayer 0:6bf0743ece18 167 }
demayer 0:6bf0743ece18 168
demayer 0:6bf0743ece18 169 virtual nsapi_error_t socket_listen(nsapi_socket_t socket, int backlog)
demayer 0:6bf0743ece18 170 {
demayer 0:6bf0743ece18 171 if (!_stack_api()->socket_listen) {
demayer 0:6bf0743ece18 172 return NSAPI_ERROR_UNSUPPORTED;
demayer 0:6bf0743ece18 173 }
demayer 0:6bf0743ece18 174
demayer 0:6bf0743ece18 175 return _stack_api()->socket_listen(_stack(), socket, backlog);
demayer 0:6bf0743ece18 176 }
demayer 0:6bf0743ece18 177
demayer 0:6bf0743ece18 178 virtual nsapi_error_t socket_connect(nsapi_socket_t socket, const SocketAddress &address)
demayer 0:6bf0743ece18 179 {
demayer 0:6bf0743ece18 180 if (!_stack_api()->socket_connect) {
demayer 0:6bf0743ece18 181 return NSAPI_ERROR_UNSUPPORTED;
demayer 0:6bf0743ece18 182 }
demayer 0:6bf0743ece18 183
demayer 0:6bf0743ece18 184 return _stack_api()->socket_connect(_stack(), socket, address.get_addr(), address.get_port());
demayer 0:6bf0743ece18 185 }
demayer 0:6bf0743ece18 186
demayer 0:6bf0743ece18 187 virtual nsapi_error_t socket_accept(nsapi_socket_t server, nsapi_socket_t *socket, SocketAddress *address)
demayer 0:6bf0743ece18 188 {
demayer 0:6bf0743ece18 189 if (!_stack_api()->socket_accept) {
demayer 0:6bf0743ece18 190 return NSAPI_ERROR_UNSUPPORTED;
demayer 0:6bf0743ece18 191 }
demayer 0:6bf0743ece18 192
demayer 0:6bf0743ece18 193 nsapi_addr_t addr = {NSAPI_IPv4, 0};
demayer 0:6bf0743ece18 194 uint16_t port = 0;
demayer 0:6bf0743ece18 195
demayer 0:6bf0743ece18 196 nsapi_error_t err = _stack_api()->socket_accept(_stack(), server, socket, &addr, &port);
demayer 0:6bf0743ece18 197
demayer 0:6bf0743ece18 198 if (address) {
demayer 0:6bf0743ece18 199 address->set_addr(addr);
demayer 0:6bf0743ece18 200 address->set_port(port);
demayer 0:6bf0743ece18 201 }
demayer 0:6bf0743ece18 202
demayer 0:6bf0743ece18 203 return err;
demayer 0:6bf0743ece18 204 }
demayer 0:6bf0743ece18 205
demayer 0:6bf0743ece18 206 virtual nsapi_size_or_error_t socket_send(nsapi_socket_t socket, const void *data, nsapi_size_t size)
demayer 0:6bf0743ece18 207 {
demayer 0:6bf0743ece18 208 if (!_stack_api()->socket_send) {
demayer 0:6bf0743ece18 209 return NSAPI_ERROR_UNSUPPORTED;
demayer 0:6bf0743ece18 210 }
demayer 0:6bf0743ece18 211
demayer 0:6bf0743ece18 212 return _stack_api()->socket_send(_stack(), socket, data, size);
demayer 0:6bf0743ece18 213 }
demayer 0:6bf0743ece18 214
demayer 0:6bf0743ece18 215 virtual nsapi_size_or_error_t socket_recv(nsapi_socket_t socket, void *data, nsapi_size_t size)
demayer 0:6bf0743ece18 216 {
demayer 0:6bf0743ece18 217 if (!_stack_api()->socket_recv) {
demayer 0:6bf0743ece18 218 return NSAPI_ERROR_UNSUPPORTED;
demayer 0:6bf0743ece18 219 }
demayer 0:6bf0743ece18 220
demayer 0:6bf0743ece18 221 return _stack_api()->socket_recv(_stack(), socket, data, size);
demayer 0:6bf0743ece18 222 }
demayer 0:6bf0743ece18 223
demayer 0:6bf0743ece18 224 virtual nsapi_size_or_error_t socket_sendto(nsapi_socket_t socket, const SocketAddress &address, const void *data, nsapi_size_t size)
demayer 0:6bf0743ece18 225 {
demayer 0:6bf0743ece18 226 if (!_stack_api()->socket_sendto) {
demayer 0:6bf0743ece18 227 return NSAPI_ERROR_UNSUPPORTED;
demayer 0:6bf0743ece18 228 }
demayer 0:6bf0743ece18 229
demayer 0:6bf0743ece18 230 return _stack_api()->socket_sendto(_stack(), socket, address.get_addr(), address.get_port(), data, size);
demayer 0:6bf0743ece18 231 }
demayer 0:6bf0743ece18 232
demayer 0:6bf0743ece18 233 virtual nsapi_size_or_error_t socket_recvfrom(nsapi_socket_t socket, SocketAddress *address, void *data, nsapi_size_t size)
demayer 0:6bf0743ece18 234 {
demayer 0:6bf0743ece18 235 if (!_stack_api()->socket_recvfrom) {
demayer 0:6bf0743ece18 236 return NSAPI_ERROR_UNSUPPORTED;
demayer 0:6bf0743ece18 237 }
demayer 0:6bf0743ece18 238
demayer 0:6bf0743ece18 239 nsapi_addr_t addr = {NSAPI_IPv4, 0};
demayer 0:6bf0743ece18 240 uint16_t port = 0;
demayer 0:6bf0743ece18 241
demayer 0:6bf0743ece18 242 nsapi_size_or_error_t err = _stack_api()->socket_recvfrom(_stack(), socket, &addr, &port, data, size);
demayer 0:6bf0743ece18 243
demayer 0:6bf0743ece18 244 if (address) {
demayer 0:6bf0743ece18 245 address->set_addr(addr);
demayer 0:6bf0743ece18 246 address->set_port(port);
demayer 0:6bf0743ece18 247 }
demayer 0:6bf0743ece18 248
demayer 0:6bf0743ece18 249 return err;
demayer 0:6bf0743ece18 250 }
demayer 0:6bf0743ece18 251
demayer 0:6bf0743ece18 252 virtual void socket_attach(nsapi_socket_t socket, void (*callback)(void *), void *data)
demayer 0:6bf0743ece18 253 {
demayer 0:6bf0743ece18 254 if (!_stack_api()->socket_attach) {
demayer 0:6bf0743ece18 255 return;
demayer 0:6bf0743ece18 256 }
demayer 0:6bf0743ece18 257
demayer 0:6bf0743ece18 258 return _stack_api()->socket_attach(_stack(), socket, callback, data);
demayer 0:6bf0743ece18 259 }
demayer 0:6bf0743ece18 260
demayer 0:6bf0743ece18 261 virtual nsapi_error_t setsockopt(nsapi_socket_t socket, int level, int optname, const void *optval, unsigned optlen)
demayer 0:6bf0743ece18 262 {
demayer 0:6bf0743ece18 263 if (!_stack_api()->setsockopt) {
demayer 0:6bf0743ece18 264 return NSAPI_ERROR_UNSUPPORTED;
demayer 0:6bf0743ece18 265 }
demayer 0:6bf0743ece18 266
demayer 0:6bf0743ece18 267 return _stack_api()->setsockopt(_stack(), socket, level, optname, optval, optlen);
demayer 0:6bf0743ece18 268 }
demayer 0:6bf0743ece18 269
demayer 0:6bf0743ece18 270 virtual nsapi_error_t getsockopt(nsapi_socket_t socket, int level, int optname, void *optval, unsigned *optlen)
demayer 0:6bf0743ece18 271 {
demayer 0:6bf0743ece18 272 if (!_stack_api()->getsockopt) {
demayer 0:6bf0743ece18 273 return NSAPI_ERROR_UNSUPPORTED;
demayer 0:6bf0743ece18 274 }
demayer 0:6bf0743ece18 275
demayer 0:6bf0743ece18 276 return _stack_api()->getsockopt(_stack(), socket, level, optname, optval, optlen);
demayer 0:6bf0743ece18 277 }
demayer 0:6bf0743ece18 278 };
demayer 0:6bf0743ece18 279
demayer 0:6bf0743ece18 280
demayer 0:6bf0743ece18 281 // Conversion function for network stacks
demayer 0:6bf0743ece18 282 NetworkStack *nsapi_create_stack(nsapi_stack_t *stack)
demayer 0:6bf0743ece18 283 {
demayer 0:6bf0743ece18 284 MBED_STATIC_ASSERT(sizeof stack->_stack_buffer >= sizeof(NetworkStackWrapper),
demayer 0:6bf0743ece18 285 "The nsapi_stack_t stack buffer must fit a NetworkStackWrapper");
demayer 0:6bf0743ece18 286 return new (stack->_stack_buffer) NetworkStackWrapper;
demayer 0:6bf0743ece18 287 }
demayer 0:6bf0743ece18 288
demayer 0:6bf0743ece18 289 NetworkStack *nsapi_create_stack(NetworkStack *stack)
demayer 0:6bf0743ece18 290 {
demayer 0:6bf0743ece18 291 return stack;
demayer 0:6bf0743ece18 292 }
demayer 0:6bf0743ece18 293