24
24
25
25
using namespace utest ::v1;
26
26
27
- namespace {
28
- static const int SIGNAL_SIGIO = 0x1 ;
29
- static const int SIGIO_TIMEOUT = 20000 ; // [ms]
30
- }
31
-
32
- static void _sigio_handler (osThreadId id)
33
- {
34
- osSignalSet (id, SIGNAL_SIGIO);
35
- }
36
-
37
27
static nsapi_error_t _tcpsocket_connect_to_daytime_srv (TCPSocket &sock)
38
28
{
39
29
SocketAddress tcp_addr;
@@ -49,7 +39,6 @@ static nsapi_error_t _tcpsocket_connect_to_daytime_srv(TCPSocket &sock)
49
39
return sock.connect (tcp_addr);
50
40
}
51
41
52
-
53
42
void TCPSOCKET_ENDPOINT_CLOSE ()
54
43
{
55
44
static const int MORE_THAN_AVAILABLE = 30 ;
@@ -63,24 +52,16 @@ void TCPSOCKET_ENDPOINT_CLOSE()
63
52
TEST_FAIL ();
64
53
return ;
65
54
}
66
- sock.sigio (callback (_sigio_handler, ThisThread::get_id ()));
67
55
68
56
int recvd = 0 ;
69
57
int recvd_total = 0 ;
70
58
while (true ) {
71
- recvd = sock.recv (&( buff[recvd_total]) , MORE_THAN_AVAILABLE);
59
+ recvd = sock.recv (buff, MORE_THAN_AVAILABLE);
72
60
if (recvd_total > 0 && recvd == 0 ) {
73
61
break ; // Endpoint closed socket, success
74
62
} else if (recvd <= 0 ) {
75
- TEST_FAIL ( );
63
+ TEST_ASSERT_EQUAL ( 0 , recvd );
76
64
break ;
77
- } else if (recvd == NSAPI_ERROR_WOULD_BLOCK) {
78
- if (tc_exec_time.read () >= time_allotted ||
79
- osSignalWait (SIGNAL_SIGIO, SIGIO_TIMEOUT).status == osEventTimeout) {
80
- TEST_FAIL ();
81
- break ;
82
- }
83
- continue ;
84
65
}
85
66
recvd_total += recvd;
86
67
TEST_ASSERT (recvd_total < MORE_THAN_AVAILABLE);
0 commit comments