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.
Socket.cpp
00001 /* Socket 00002 * Copyright (c) 2015 ARM Limited 00003 * 00004 * Licensed under the Apache License, Version 2.0 (the "License"); 00005 * you may not use this file except in compliance with the License. 00006 * You may obtain a copy of the License at 00007 * 00008 * http://www.apache.org/licenses/LICENSE-2.0 00009 * 00010 * Unless required by applicable law or agreed to in writing, software 00011 * distributed under the License is distributed on an "AS IS" BASIS, 00012 * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. 00013 * See the License for the specific language governing permissions and 00014 * limitations under the License. 00015 */ 00016 00017 #include "Socket.h" 00018 #include "mbed.h" 00019 00020 Socket::Socket() 00021 : _stack(0) 00022 , _socket(0) 00023 , _timeout(osWaitForever) 00024 { 00025 } 00026 00027 nsapi_error_t Socket::open(NetworkStack *stack) 00028 { 00029 _lock.lock(); 00030 00031 if (_stack != NULL || stack == NULL) { 00032 _lock.unlock(); 00033 return NSAPI_ERROR_PARAMETER ; 00034 } 00035 _stack = stack; 00036 00037 nsapi_socket_t socket; 00038 nsapi_error_t err = _stack->socket_open(&socket, get_proto()); 00039 if (err) { 00040 _lock.unlock(); 00041 return err; 00042 } 00043 00044 _socket = socket; 00045 _event = callback(this, &Socket::event); 00046 _stack->socket_attach(_socket, Callback<void()>::thunk, &_event); 00047 00048 _lock.unlock(); 00049 return NSAPI_ERROR_OK ; 00050 } 00051 00052 nsapi_error_t Socket::close() 00053 { 00054 _lock.lock(); 00055 00056 nsapi_error_t ret = NSAPI_ERROR_OK ; 00057 if (_socket) { 00058 _stack->socket_attach(_socket, 0, 0); 00059 nsapi_socket_t socket = _socket; 00060 _socket = 0; 00061 ret = _stack->socket_close(socket); 00062 } 00063 _stack = 0; 00064 00065 // Wakeup anything in a blocking operation 00066 // on this socket 00067 event(); 00068 00069 _lock.unlock(); 00070 return ret; 00071 } 00072 00073 int Socket::modify_multicast_group(const SocketAddress &address, nsapi_socket_option_t socketopt) 00074 { 00075 nsapi_ip_mreq_t mreq; 00076 00077 // Set up group address 00078 mreq.imr_multiaddr = address.get_addr(); 00079 mreq.imr_interface = nsapi_addr_t(); // Default address, NSAPI_UNSPEC 00080 00081 return this->setsockopt(NSAPI_SOCKET , socketopt, &mreq, sizeof(mreq)); 00082 } 00083 00084 int Socket::join_multicast_group(const SocketAddress &address) 00085 { 00086 return modify_multicast_group(address, NSAPI_ADD_MEMBERSHIP ); 00087 } 00088 00089 int Socket::leave_multicast_group(const SocketAddress &address) 00090 { 00091 return modify_multicast_group(address, NSAPI_DROP_MEMBERSHIP ); 00092 } 00093 00094 00095 nsapi_error_t Socket::bind(uint16_t port) 00096 { 00097 // Underlying bind is thread safe 00098 SocketAddress addr(0, port); 00099 return bind(addr); 00100 } 00101 00102 nsapi_error_t Socket::bind(const char *address, uint16_t port) 00103 { 00104 // Underlying bind is thread safe 00105 SocketAddress addr(address, port); 00106 return bind(addr); 00107 } 00108 00109 nsapi_error_t Socket::bind(const SocketAddress &address) 00110 { 00111 _lock.lock(); 00112 nsapi_error_t ret; 00113 00114 if (!_socket) { 00115 ret = NSAPI_ERROR_NO_SOCKET ; 00116 } else { 00117 ret = _stack->socket_bind(_socket, address); 00118 } 00119 00120 _lock.unlock(); 00121 return ret; 00122 } 00123 00124 void Socket::set_blocking(bool blocking) 00125 { 00126 // Socket::set_timeout is thread safe 00127 set_timeout(blocking ? -1 : 0); 00128 } 00129 00130 void Socket::set_timeout(int timeout) 00131 { 00132 _lock.lock(); 00133 00134 if (timeout >= 0) { 00135 _timeout = (uint32_t)timeout; 00136 } else { 00137 _timeout = osWaitForever; 00138 } 00139 00140 _lock.unlock(); 00141 } 00142 00143 nsapi_error_t Socket::setsockopt(int level, int optname, const void *optval, unsigned optlen) 00144 { 00145 _lock.lock(); 00146 nsapi_error_t ret; 00147 00148 if (!_socket) { 00149 ret = NSAPI_ERROR_NO_SOCKET ; 00150 } else { 00151 ret = _stack->setsockopt(_socket, level, optname, optval, optlen); 00152 } 00153 00154 _lock.unlock(); 00155 return ret; 00156 } 00157 00158 nsapi_error_t Socket::getsockopt(int level, int optname, void *optval, unsigned *optlen) 00159 { 00160 _lock.lock(); 00161 nsapi_error_t ret; 00162 00163 if (!_socket) { 00164 ret = NSAPI_ERROR_NO_SOCKET ; 00165 } else { 00166 ret = _stack->getsockopt(_socket, level, optname, optval, optlen); 00167 } 00168 00169 _lock.unlock(); 00170 return ret; 00171 00172 } 00173 00174 void Socket::sigio(Callback<void()> callback) 00175 { 00176 _lock.lock(); 00177 _callback = callback; 00178 _lock.unlock(); 00179 } 00180 00181 void Socket::attach(Callback<void()> callback) 00182 { 00183 sigio(callback); 00184 }
Generated on Tue Jul 12 2022 13:31:28 by
