Kenji Arai / mbed-os_TYBLE16

mbed-os5 only for TYBLE16

Dependents:   TYBLE16_simple_data_logger TYBLE16_MP3_Air

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

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

Who changed what in which revision?

UserRevisionLine numberNew contents of line
kenjiArai 0:5b88d5760320 1 /* Socket
kenjiArai 0:5b88d5760320 2 * Copyright (c) 2015 ARM Limited
kenjiArai 0:5b88d5760320 3 *
kenjiArai 0:5b88d5760320 4 * Licensed under the Apache License, Version 2.0 (the "License");
kenjiArai 0:5b88d5760320 5 * you may not use this file except in compliance with the License.
kenjiArai 0:5b88d5760320 6 * You may obtain a copy of the License at
kenjiArai 0:5b88d5760320 7 *
kenjiArai 0:5b88d5760320 8 * http://www.apache.org/licenses/LICENSE-2.0
kenjiArai 0:5b88d5760320 9 *
kenjiArai 0:5b88d5760320 10 * Unless required by applicable law or agreed to in writing, software
kenjiArai 0:5b88d5760320 11 * distributed under the License is distributed on an "AS IS" BASIS,
kenjiArai 0:5b88d5760320 12 * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
kenjiArai 0:5b88d5760320 13 * See the License for the specific language governing permissions and
kenjiArai 0:5b88d5760320 14 * limitations under the License.
kenjiArai 0:5b88d5760320 15 */
kenjiArai 0:5b88d5760320 16
kenjiArai 0:5b88d5760320 17 #include "TCPServer.h"
kenjiArai 0:5b88d5760320 18
kenjiArai 0:5b88d5760320 19 using mbed::Callback;
kenjiArai 0:5b88d5760320 20
kenjiArai 0:5b88d5760320 21 TCPServer::TCPServer()
kenjiArai 0:5b88d5760320 22 {
kenjiArai 0:5b88d5760320 23 _socket_stats.stats_update_proto(this, NSAPI_TCP);
kenjiArai 0:5b88d5760320 24 }
kenjiArai 0:5b88d5760320 25
kenjiArai 0:5b88d5760320 26 TCPServer::~TCPServer()
kenjiArai 0:5b88d5760320 27 {
kenjiArai 0:5b88d5760320 28 }
kenjiArai 0:5b88d5760320 29
kenjiArai 0:5b88d5760320 30 nsapi_error_t TCPServer::accept(TCPSocket *connection, SocketAddress *address)
kenjiArai 0:5b88d5760320 31 {
kenjiArai 0:5b88d5760320 32 _lock.lock();
kenjiArai 0:5b88d5760320 33 nsapi_error_t ret;
kenjiArai 0:5b88d5760320 34
kenjiArai 0:5b88d5760320 35 while (true) {
kenjiArai 0:5b88d5760320 36 if (!_socket) {
kenjiArai 0:5b88d5760320 37 ret = NSAPI_ERROR_NO_SOCKET;
kenjiArai 0:5b88d5760320 38 break;
kenjiArai 0:5b88d5760320 39 }
kenjiArai 0:5b88d5760320 40
kenjiArai 0:5b88d5760320 41 core_util_atomic_flag_clear(&_pending);
kenjiArai 0:5b88d5760320 42 void *socket;
kenjiArai 0:5b88d5760320 43 ret = _stack->socket_accept(_socket, &socket, address);
kenjiArai 0:5b88d5760320 44
kenjiArai 0:5b88d5760320 45 if (0 == ret) {
kenjiArai 0:5b88d5760320 46 connection->_lock.lock();
kenjiArai 0:5b88d5760320 47
kenjiArai 0:5b88d5760320 48 if (connection->_socket) {
kenjiArai 0:5b88d5760320 49 connection->close();
kenjiArai 0:5b88d5760320 50 }
kenjiArai 0:5b88d5760320 51
kenjiArai 0:5b88d5760320 52 connection->_stack = _stack;
kenjiArai 0:5b88d5760320 53 connection->_socket = socket;
kenjiArai 0:5b88d5760320 54 connection->_event = Callback<void()>(connection, &TCPSocket::event);
kenjiArai 0:5b88d5760320 55 _stack->socket_attach(socket, &Callback<void()>::thunk, &connection->_event);
kenjiArai 0:5b88d5760320 56 _socket_stats.stats_update_peer(connection, *address);
kenjiArai 0:5b88d5760320 57 _socket_stats.stats_update_socket_state(connection, SOCK_CONNECTED);
kenjiArai 0:5b88d5760320 58 connection->_lock.unlock();
kenjiArai 0:5b88d5760320 59 break;
kenjiArai 0:5b88d5760320 60 } else if ((_timeout == 0) || (ret != NSAPI_ERROR_WOULD_BLOCK)) {
kenjiArai 0:5b88d5760320 61 break;
kenjiArai 0:5b88d5760320 62 } else {
kenjiArai 0:5b88d5760320 63 uint32_t flag;
kenjiArai 0:5b88d5760320 64
kenjiArai 0:5b88d5760320 65 // Release lock before blocking so other threads
kenjiArai 0:5b88d5760320 66 // accessing this object aren't blocked
kenjiArai 0:5b88d5760320 67 _lock.unlock();
kenjiArai 0:5b88d5760320 68 flag = _event_flag.wait_any(READ_FLAG, _timeout);
kenjiArai 0:5b88d5760320 69 _lock.lock();
kenjiArai 0:5b88d5760320 70
kenjiArai 0:5b88d5760320 71 if (flag & osFlagsError) {
kenjiArai 0:5b88d5760320 72 // Timeout break
kenjiArai 0:5b88d5760320 73 ret = NSAPI_ERROR_WOULD_BLOCK;
kenjiArai 0:5b88d5760320 74 break;
kenjiArai 0:5b88d5760320 75 }
kenjiArai 0:5b88d5760320 76 }
kenjiArai 0:5b88d5760320 77 }
kenjiArai 0:5b88d5760320 78
kenjiArai 0:5b88d5760320 79 _lock.unlock();
kenjiArai 0:5b88d5760320 80 return ret;
kenjiArai 0:5b88d5760320 81 }