Kenji Arai / mbed-os_TYBLE16

mbed-os5 only for TYBLE16

Dependents:   TYBLE16_simple_data_logger TYBLE16_MP3_Air

features/netsocket/InternetSocket.h@0:5b88d5760320, 2019-12-17 (annotated)

Committer:
kenjiArai
Date:
Tue Dec 17 23:23:45 2019 +0000
Revision:
0:5b88d5760320
Child:
1:9db0e321a9f4
mbed-os5 only for TYBLE16

Who changed what in which revision?

UserRevisionLine numberNew contents of line
kenjiArai 0:5b88d5760320 1
kenjiArai 0:5b88d5760320 2 /** \addtogroup netsocket */
kenjiArai 0:5b88d5760320 3 /** @{*/
kenjiArai 0:5b88d5760320 4 /* Socket
kenjiArai 0:5b88d5760320 5 * Copyright (c) 2015 ARM Limited
kenjiArai 0:5b88d5760320 6 *
kenjiArai 0:5b88d5760320 7 * Licensed under the Apache License, Version 2.0 (the "License");
kenjiArai 0:5b88d5760320 8 * you may not use this file except in compliance with the License.
kenjiArai 0:5b88d5760320 9 * You may obtain a copy of the License at
kenjiArai 0:5b88d5760320 10 *
kenjiArai 0:5b88d5760320 11 * http://www.apache.org/licenses/LICENSE-2.0
kenjiArai 0:5b88d5760320 12 *
kenjiArai 0:5b88d5760320 13 * Unless required by applicable law or agreed to in writing, software
kenjiArai 0:5b88d5760320 14 * distributed under the License is distributed on an "AS IS" BASIS,
kenjiArai 0:5b88d5760320 15 * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
kenjiArai 0:5b88d5760320 16 * See the License for the specific language governing permissions and
kenjiArai 0:5b88d5760320 17 * limitations under the License.
kenjiArai 0:5b88d5760320 18 */
kenjiArai 0:5b88d5760320 19
kenjiArai 0:5b88d5760320 20 #ifndef INTERNETSOCKET_H
kenjiArai 0:5b88d5760320 21 #define INTERNETSOCKET_H
kenjiArai 0:5b88d5760320 22
kenjiArai 0:5b88d5760320 23 #include "netsocket/Socket.h"
kenjiArai 0:5b88d5760320 24 #include "netsocket/NetworkStack.h"
kenjiArai 0:5b88d5760320 25 #include "rtos/Mutex.h"
kenjiArai 0:5b88d5760320 26 #include "rtos/EventFlags.h"
kenjiArai 0:5b88d5760320 27 #include "Callback.h"
kenjiArai 0:5b88d5760320 28 #include "mbed_atomic.h"
kenjiArai 0:5b88d5760320 29 #include "mbed_toolchain.h"
kenjiArai 0:5b88d5760320 30 #include "SocketStats.h"
kenjiArai 0:5b88d5760320 31
kenjiArai 0:5b88d5760320 32 /** Socket implementation that uses IP network stack.
kenjiArai 0:5b88d5760320 33 * Not to be directly used by applications. Cannot be directly instantiated.
kenjiArai 0:5b88d5760320 34 */
kenjiArai 0:5b88d5760320 35 class InternetSocket : public Socket {
kenjiArai 0:5b88d5760320 36 public:
kenjiArai 0:5b88d5760320 37 /** Destroy the socket.
kenjiArai 0:5b88d5760320 38 *
kenjiArai 0:5b88d5760320 39 * @note Closes socket if it's still open.
kenjiArai 0:5b88d5760320 40 */
kenjiArai 0:5b88d5760320 41 virtual ~InternetSocket();
kenjiArai 0:5b88d5760320 42
kenjiArai 0:5b88d5760320 43 /** Open a network socket on the network stack of the given
kenjiArai 0:5b88d5760320 44 * network interface.
kenjiArai 0:5b88d5760320 45 *
kenjiArai 0:5b88d5760320 46 * @note Not needed if stack is passed to the socket's constructor.
kenjiArai 0:5b88d5760320 47 *
kenjiArai 0:5b88d5760320 48 * @param stack Network stack as target for socket.
kenjiArai 0:5b88d5760320 49 * @return 0 on success, negative error code on failure (@see nsapi_types.h).
kenjiArai 0:5b88d5760320 50 */
kenjiArai 0:5b88d5760320 51 nsapi_error_t open(NetworkStack *stack);
kenjiArai 0:5b88d5760320 52
kenjiArai 0:5b88d5760320 53 #if !defined(DOXYGEN_ONLY)
kenjiArai 0:5b88d5760320 54 template <typename S>
kenjiArai 0:5b88d5760320 55 nsapi_error_t open(S *stack)
kenjiArai 0:5b88d5760320 56 {
kenjiArai 0:5b88d5760320 57 return open(nsapi_create_stack(stack));
kenjiArai 0:5b88d5760320 58 }
kenjiArai 0:5b88d5760320 59 #endif //!defined(DOXYGEN_ONLY)
kenjiArai 0:5b88d5760320 60
kenjiArai 0:5b88d5760320 61 /** Close any open connection, and deallocate any memory associated
kenjiArai 0:5b88d5760320 62 * with the socket. Called from destructor if socket is not closed.
kenjiArai 0:5b88d5760320 63 *
kenjiArai 0:5b88d5760320 64 * @return 0 on success, negative error code on failure (@see nsapi_types.h).
kenjiArai 0:5b88d5760320 65 */
kenjiArai 0:5b88d5760320 66 virtual nsapi_error_t close();
kenjiArai 0:5b88d5760320 67
kenjiArai 0:5b88d5760320 68 /** Subscribe to an IP multicast group.
kenjiArai 0:5b88d5760320 69 *
kenjiArai 0:5b88d5760320 70 * @param address Multicast group IP address.
kenjiArai 0:5b88d5760320 71 * @return 0 on success, negative error code on failure (@see nsapi_types.h).
kenjiArai 0:5b88d5760320 72 */
kenjiArai 0:5b88d5760320 73 int join_multicast_group(const SocketAddress &address);
kenjiArai 0:5b88d5760320 74
kenjiArai 0:5b88d5760320 75 /** Leave an IP multicast group.
kenjiArai 0:5b88d5760320 76 *
kenjiArai 0:5b88d5760320 77 * @param address Multicast group IP address.
kenjiArai 0:5b88d5760320 78 * @return 0 on success, negative error code on failure (@see nsapi_types.h).
kenjiArai 0:5b88d5760320 79 */
kenjiArai 0:5b88d5760320 80 int leave_multicast_group(const SocketAddress &address);
kenjiArai 0:5b88d5760320 81
kenjiArai 0:5b88d5760320 82 /** Bind the socket to a port on which to receive data.
kenjiArai 0:5b88d5760320 83 *
kenjiArai 0:5b88d5760320 84 * @param port Local port to bind.
kenjiArai 0:5b88d5760320 85 * @return 0 on success, negative error code on failure (@see nsapi_types.h).
kenjiArai 0:5b88d5760320 86 */
kenjiArai 0:5b88d5760320 87 nsapi_error_t bind(uint16_t port);
kenjiArai 0:5b88d5760320 88
kenjiArai 0:5b88d5760320 89 /** Bind the socket to a specific address and port on which to receive
kenjiArai 0:5b88d5760320 90 * data. If the IP address is zeroed, only the port is bound.
kenjiArai 0:5b88d5760320 91 *
kenjiArai 0:5b88d5760320 92 * @param address Null-terminated local address to bind.
kenjiArai 0:5b88d5760320 93 * @param port Local port to bind.
kenjiArai 0:5b88d5760320 94 * @return 0 on success, negative error code on failure (@see nsapi_types.h).
kenjiArai 0:5b88d5760320 95 */
kenjiArai 0:5b88d5760320 96 nsapi_error_t bind(const char *address, uint16_t port);
kenjiArai 0:5b88d5760320 97
kenjiArai 0:5b88d5760320 98 /** @copydoc Socket::bind
kenjiArai 0:5b88d5760320 99 */
kenjiArai 0:5b88d5760320 100 virtual nsapi_error_t bind(const SocketAddress &address);
kenjiArai 0:5b88d5760320 101
kenjiArai 0:5b88d5760320 102 /** @copydoc Socket::set_blocking
kenjiArai 0:5b88d5760320 103 */
kenjiArai 0:5b88d5760320 104 virtual void set_blocking(bool blocking);
kenjiArai 0:5b88d5760320 105
kenjiArai 0:5b88d5760320 106 /** @copydoc Socket::set_timeout
kenjiArai 0:5b88d5760320 107 */
kenjiArai 0:5b88d5760320 108 virtual void set_timeout(int timeout);
kenjiArai 0:5b88d5760320 109
kenjiArai 0:5b88d5760320 110 /** @copydoc Socket::setsockopt
kenjiArai 0:5b88d5760320 111 */
kenjiArai 0:5b88d5760320 112 virtual nsapi_error_t setsockopt(int level, int optname, const void *optval, unsigned optlen);
kenjiArai 0:5b88d5760320 113
kenjiArai 0:5b88d5760320 114 /** @copydoc Socket::getsockopt
kenjiArai 0:5b88d5760320 115 */
kenjiArai 0:5b88d5760320 116 virtual nsapi_error_t getsockopt(int level, int optname, void *optval, unsigned *optlen);
kenjiArai 0:5b88d5760320 117
kenjiArai 0:5b88d5760320 118 /** @copydoc Socket::sigio
kenjiArai 0:5b88d5760320 119 */
kenjiArai 0:5b88d5760320 120 virtual void sigio(mbed::Callback<void()> func);
kenjiArai 0:5b88d5760320 121
kenjiArai 0:5b88d5760320 122 /** @copydoc Socket::getpeername
kenjiArai 0:5b88d5760320 123 */
kenjiArai 0:5b88d5760320 124 virtual nsapi_error_t getpeername(SocketAddress *address);
kenjiArai 0:5b88d5760320 125
kenjiArai 0:5b88d5760320 126 /** Register a callback on state change of the socket.
kenjiArai 0:5b88d5760320 127 *
kenjiArai 0:5b88d5760320 128 * @see Socket::sigio
kenjiArai 0:5b88d5760320 129 * @deprecated
kenjiArai 0:5b88d5760320 130 * The behavior of Socket::attach differs from other attach functions in
kenjiArai 0:5b88d5760320 131 * Mbed OS and has been known to cause confusion. Replaced by Socket::sigio.
kenjiArai 0:5b88d5760320 132 */
kenjiArai 0:5b88d5760320 133 MBED_DEPRECATED_SINCE("mbed-os-5.4",
kenjiArai 0:5b88d5760320 134 "The behavior of Socket::attach differs from other attach functions in "
kenjiArai 0:5b88d5760320 135 "Mbed OS and has been known to cause confusion. Replaced by Socket::sigio.")
kenjiArai 0:5b88d5760320 136 void attach(mbed::Callback<void()> func);
kenjiArai 0:5b88d5760320 137
kenjiArai 0:5b88d5760320 138 /** Register a callback on state change of the socket.
kenjiArai 0:5b88d5760320 139 *
kenjiArai 0:5b88d5760320 140 * @see Socket::sigio
kenjiArai 0:5b88d5760320 141 * @deprecated
kenjiArai 0:5b88d5760320 142 * The attach function does not support cv-qualifiers. Replaced by
kenjiArai 0:5b88d5760320 143 * attach(callback(obj, method)).
kenjiArai 0:5b88d5760320 144 */
kenjiArai 0:5b88d5760320 145 template <typename T, typename M>
kenjiArai 0:5b88d5760320 146 MBED_DEPRECATED_SINCE("mbed-os-5.1",
kenjiArai 0:5b88d5760320 147 "The attach function does not support cv-qualifiers. Replaced by "
kenjiArai 0:5b88d5760320 148 "attach(callback(obj, method)).")
kenjiArai 0:5b88d5760320 149 void attach(T *obj, M method)
kenjiArai 0:5b88d5760320 150 {
kenjiArai 0:5b88d5760320 151 attach(mbed::callback(obj, method));
kenjiArai 0:5b88d5760320 152 }
kenjiArai 0:5b88d5760320 153
kenjiArai 0:5b88d5760320 154 #if !defined(DOXYGEN_ONLY)
kenjiArai 0:5b88d5760320 155
kenjiArai 0:5b88d5760320 156 protected:
kenjiArai 0:5b88d5760320 157 InternetSocket();
kenjiArai 0:5b88d5760320 158 virtual nsapi_protocol_t get_proto() = 0;
kenjiArai 0:5b88d5760320 159 virtual void event();
kenjiArai 0:5b88d5760320 160 int modify_multicast_group(const SocketAddress &address, nsapi_socket_option_t socketopt);
kenjiArai 0:5b88d5760320 161 char _interface_name[NSAPI_INTERFACE_NAME_MAX_SIZE];
kenjiArai 0:5b88d5760320 162 NetworkStack *_stack;
kenjiArai 0:5b88d5760320 163 nsapi_socket_t _socket;
kenjiArai 0:5b88d5760320 164 uint32_t _timeout;
kenjiArai 0:5b88d5760320 165 mbed::Callback<void()> _event;
kenjiArai 0:5b88d5760320 166 mbed::Callback<void()> _callback;
kenjiArai 0:5b88d5760320 167 rtos::EventFlags _event_flag;
kenjiArai 0:5b88d5760320 168 rtos::Mutex _lock;
kenjiArai 0:5b88d5760320 169 SocketAddress _remote_peer;
kenjiArai 0:5b88d5760320 170 uint8_t _readers;
kenjiArai 0:5b88d5760320 171 uint8_t _writers;
kenjiArai 0:5b88d5760320 172 core_util_atomic_flag _pending;
kenjiArai 0:5b88d5760320 173 bool _factory_allocated;
kenjiArai 0:5b88d5760320 174
kenjiArai 0:5b88d5760320 175 // Event flags
kenjiArai 0:5b88d5760320 176 static const int READ_FLAG = 0x1u;
kenjiArai 0:5b88d5760320 177 static const int WRITE_FLAG = 0x2u;
kenjiArai 0:5b88d5760320 178 static const int FINISHED_FLAG = 0x3u;
kenjiArai 0:5b88d5760320 179
kenjiArai 0:5b88d5760320 180 friend class DTLSSocket; // Allow DTLSSocket::connect() to do name resolution on the _stack
kenjiArai 0:5b88d5760320 181 SocketStats _socket_stats;
kenjiArai 0:5b88d5760320 182
kenjiArai 0:5b88d5760320 183 #endif //!defined(DOXYGEN_ONLY)
kenjiArai 0:5b88d5760320 184 };
kenjiArai 0:5b88d5760320 185
kenjiArai 0:5b88d5760320 186 #endif // INTERNETSOCKET_H
kenjiArai 0:5b88d5760320 187
kenjiArai 0:5b88d5760320 188 /** @}*/