takashi kadono / Mbed OS Nucleo446_SSD1331

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.

Dependencies:   ssd1331

mbed-os/TESTS/netsocket/udp/udpsocket_open_limit.cpp@3:f3764f852aa8, 2018-10-11 (annotated)

Committer:
kadonotakashi
Date:
Thu Oct 11 02:27:46 2018 +0000
Revision:
3:f3764f852aa8
Parent:
0:8fdf9a60065b 
Nucreo 446 + SSD1331 test version;

Who changed what in which revision?

UserRevisionLine numberNew contents of line
kadonotakashi 0:8fdf9a60065b 1 /*
kadonotakashi 0:8fdf9a60065b 2 * Copyright (c) 2018, ARM Limited, All Rights Reserved
kadonotakashi 0:8fdf9a60065b 3 * SPDX-License-Identifier: Apache-2.0
kadonotakashi 0:8fdf9a60065b 4 *
kadonotakashi 0:8fdf9a60065b 5 * Licensed under the Apache License, Version 2.0 (the "License"); you may
kadonotakashi 0:8fdf9a60065b 6 * not use this file except in compliance with the License.
kadonotakashi 0:8fdf9a60065b 7 * You may obtain a copy of the License at
kadonotakashi 0:8fdf9a60065b 8 *
kadonotakashi 0:8fdf9a60065b 9 * http://www.apache.org/licenses/LICENSE-2.0
kadonotakashi 0:8fdf9a60065b 10 *
kadonotakashi 0:8fdf9a60065b 11 * Unless required by applicable law or agreed to in writing, software
kadonotakashi 0:8fdf9a60065b 12 * distributed under the License is distributed on an "AS IS" BASIS, WITHOUT
kadonotakashi 0:8fdf9a60065b 13 * WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
kadonotakashi 0:8fdf9a60065b 14 * See the License for the specific language governing permissions and
kadonotakashi 0:8fdf9a60065b 15 * limitations under the License.
kadonotakashi 0:8fdf9a60065b 16 */
kadonotakashi 0:8fdf9a60065b 17
kadonotakashi 0:8fdf9a60065b 18 #include "greentea-client/test_env.h"
kadonotakashi 0:8fdf9a60065b 19 #include "mbed.h"
kadonotakashi 0:8fdf9a60065b 20 #include "udp_tests.h"
kadonotakashi 0:8fdf9a60065b 21 #include "UDPSocket.h"
kadonotakashi 0:8fdf9a60065b 22 #include "unity/unity.h"
kadonotakashi 0:8fdf9a60065b 23 #include "utest.h"
kadonotakashi 0:8fdf9a60065b 24
kadonotakashi 0:8fdf9a60065b 25 using namespace utest::v1;
kadonotakashi 0:8fdf9a60065b 26
kadonotakashi 0:8fdf9a60065b 27 namespace {
kadonotakashi 0:8fdf9a60065b 28 typedef struct UDPSocketItem {
kadonotakashi 0:8fdf9a60065b 29 UDPSocket *sock;
kadonotakashi 0:8fdf9a60065b 30 UDPSocketItem *next;
kadonotakashi 0:8fdf9a60065b 31 } SocketItem;
kadonotakashi 0:8fdf9a60065b 32 }
kadonotakashi 0:8fdf9a60065b 33
kadonotakashi 0:8fdf9a60065b 34 void UDPSOCKET_OPEN_LIMIT()
kadonotakashi 0:8fdf9a60065b 35 {
kadonotakashi 0:8fdf9a60065b 36 int open_sockets[2] = {0};
kadonotakashi 0:8fdf9a60065b 37
kadonotakashi 0:8fdf9a60065b 38 for (int i = 0; i < 2; i++) {
kadonotakashi 0:8fdf9a60065b 39 UDPSocketItem *socket_list_head = NULL;
kadonotakashi 0:8fdf9a60065b 40 UDPSocketItem *it;
kadonotakashi 0:8fdf9a60065b 41
kadonotakashi 0:8fdf9a60065b 42 UDPSocket *sock;
kadonotakashi 0:8fdf9a60065b 43 int ret;
kadonotakashi 0:8fdf9a60065b 44 while (true) {
kadonotakashi 0:8fdf9a60065b 45 sock = new UDPSocket;
kadonotakashi 0:8fdf9a60065b 46 if (!sock) {
kadonotakashi 0:8fdf9a60065b 47 break;
kadonotakashi 0:8fdf9a60065b 48 }
kadonotakashi 0:8fdf9a60065b 49 ret = sock->open(get_interface());
kadonotakashi 0:8fdf9a60065b 50 if (ret == NSAPI_ERROR_NO_MEMORY || ret == NSAPI_ERROR_NO_SOCKET) {
kadonotakashi 0:8fdf9a60065b 51 printf("[round#%02d] unable to open new socket, error: %d\n", i, ret);
kadonotakashi 0:8fdf9a60065b 52 delete sock;
kadonotakashi 0:8fdf9a60065b 53 break;
kadonotakashi 0:8fdf9a60065b 54 }
kadonotakashi 0:8fdf9a60065b 55
kadonotakashi 0:8fdf9a60065b 56 // Hopefully this doesn't interfere when trying to allocate more sockets
kadonotakashi 0:8fdf9a60065b 57 it = new UDPSocketItem;
kadonotakashi 0:8fdf9a60065b 58 if (!it) {
kadonotakashi 0:8fdf9a60065b 59 delete sock;
kadonotakashi 0:8fdf9a60065b 60 break;
kadonotakashi 0:8fdf9a60065b 61 }
kadonotakashi 0:8fdf9a60065b 62
kadonotakashi 0:8fdf9a60065b 63 it->sock = sock;
kadonotakashi 0:8fdf9a60065b 64 // Order of items in the list doesn't matter
kadonotakashi 0:8fdf9a60065b 65 it->next = socket_list_head;
kadonotakashi 0:8fdf9a60065b 66 socket_list_head = it;
kadonotakashi 0:8fdf9a60065b 67 }
kadonotakashi 0:8fdf9a60065b 68
kadonotakashi 0:8fdf9a60065b 69 if (!socket_list_head) {
kadonotakashi 0:8fdf9a60065b 70 break;
kadonotakashi 0:8fdf9a60065b 71 }
kadonotakashi 0:8fdf9a60065b 72
kadonotakashi 0:8fdf9a60065b 73 UDPSocketItem *tmp;
kadonotakashi 0:8fdf9a60065b 74 for (UDPSocketItem *it = socket_list_head; it;) {
kadonotakashi 0:8fdf9a60065b 75 ++open_sockets[i];
kadonotakashi 0:8fdf9a60065b 76 tmp = it;
kadonotakashi 0:8fdf9a60065b 77 it = it->next;
kadonotakashi 0:8fdf9a60065b 78 socket_list_head = it;
kadonotakashi 0:8fdf9a60065b 79 delete tmp->sock;
kadonotakashi 0:8fdf9a60065b 80 delete tmp;
kadonotakashi 0:8fdf9a60065b 81 }
kadonotakashi 0:8fdf9a60065b 82 printf("[round#%02d] %d sockets opened\n", i, open_sockets[i]);
kadonotakashi 0:8fdf9a60065b 83 }
kadonotakashi 0:8fdf9a60065b 84 TEST_ASSERT_EQUAL(open_sockets[0], open_sockets[1]);
kadonotakashi 0:8fdf9a60065b 85 // In case of lwIP one is taken by DHCP -> reduction by one to three
kadonotakashi 0:8fdf9a60065b 86 TEST_ASSERT(open_sockets[0] >= 3);
kadonotakashi 0:8fdf9a60065b 87 }