NetworkSocketAPI
Dependents: HelloWizFi250Interface
Fork of NetworkSocketAPI by
TCPSocket.cpp@120:6eb542426f15, 2016-05-09 (annotated)
- Committer:
- Christopher Haster
- Date:
- Mon May 09 22:40:00 2016 -0500
- Revision:
- 120:6eb542426f15
- Parent:
- 118:96627c4b83d5
Fix port issue in SocketAddress constructor
Who changed what in which revision?
User | Revision | Line number | New contents of line |
---|---|---|---|
Christopher Haster |
79:43a7e8c0d6cc | 1 | /* Socket |
Christopher Haster |
79:43a7e8c0d6cc | 2 | * Copyright (c) 2015 ARM Limited |
Christopher Haster |
79:43a7e8c0d6cc | 3 | * |
Christopher Haster |
79:43a7e8c0d6cc | 4 | * Licensed under the Apache License, Version 2.0 (the "License"); |
Christopher Haster |
79:43a7e8c0d6cc | 5 | * you may not use this file except in compliance with the License. |
Christopher Haster |
79:43a7e8c0d6cc | 6 | * You may obtain a copy of the License at |
Christopher Haster |
79:43a7e8c0d6cc | 7 | * |
Christopher Haster |
79:43a7e8c0d6cc | 8 | * http://www.apache.org/licenses/LICENSE-2.0 |
Christopher Haster |
79:43a7e8c0d6cc | 9 | * |
Christopher Haster |
79:43a7e8c0d6cc | 10 | * Unless required by applicable law or agreed to in writing, software |
Christopher Haster |
79:43a7e8c0d6cc | 11 | * distributed under the License is distributed on an "AS IS" BASIS, |
Christopher Haster |
79:43a7e8c0d6cc | 12 | * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. |
Christopher Haster |
79:43a7e8c0d6cc | 13 | * See the License for the specific language governing permissions and |
Christopher Haster |
79:43a7e8c0d6cc | 14 | * limitations under the License. |
Christopher Haster |
79:43a7e8c0d6cc | 15 | */ |
Christopher Haster |
79:43a7e8c0d6cc | 16 | |
Christopher Haster |
79:43a7e8c0d6cc | 17 | #include "TCPSocket.h" |
Christopher Haster |
82:97d166c4a193 | 18 | #include "Timer.h" |
Christopher Haster |
79:43a7e8c0d6cc | 19 | |
Christopher Haster |
90:0a988e4abb72 | 20 | TCPSocket::TCPSocket() |
Christopher Haster |
90:0a988e4abb72 | 21 | { |
Christopher Haster |
90:0a988e4abb72 | 22 | } |
Christopher Haster |
90:0a988e4abb72 | 23 | |
Christopher Haster |
105:2fd212f8da61 | 24 | TCPSocket::TCPSocket(NetworkStack *iface) |
Christopher Haster |
79:43a7e8c0d6cc | 25 | { |
Christopher Haster |
90:0a988e4abb72 | 26 | open(iface); |
Christopher Haster |
90:0a988e4abb72 | 27 | } |
Christopher Haster |
90:0a988e4abb72 | 28 | |
Christopher Haster |
105:2fd212f8da61 | 29 | int TCPSocket::open(NetworkStack *iface) |
Christopher Haster |
90:0a988e4abb72 | 30 | { |
Christopher Haster |
90:0a988e4abb72 | 31 | return Socket::open(iface, NSAPI_TCP); |
Christopher Haster |
79:43a7e8c0d6cc | 32 | } |
Christopher Haster |
79:43a7e8c0d6cc | 33 | |
Christopher Haster |
80:9c6673c93082 | 34 | int TCPSocket::connect(const SocketAddress &addr) |
Christopher Haster |
79:43a7e8c0d6cc | 35 | { |
Christopher Haster |
79:43a7e8c0d6cc | 36 | if (!_socket) { |
Christopher Haster |
79:43a7e8c0d6cc | 37 | return NSAPI_ERROR_NO_SOCKET; |
Christopher Haster |
79:43a7e8c0d6cc | 38 | } |
Christopher Haster |
79:43a7e8c0d6cc | 39 | |
Christopher Haster |
79:43a7e8c0d6cc | 40 | return _iface->socket_connect(_socket, addr); |
Christopher Haster |
79:43a7e8c0d6cc | 41 | } |
Christopher Haster |
79:43a7e8c0d6cc | 42 | |
Christopher Haster |
79:43a7e8c0d6cc | 43 | int TCPSocket::connect(const char *host, uint16_t port) |
Christopher Haster |
79:43a7e8c0d6cc | 44 | { |
Christopher Haster |
80:9c6673c93082 | 45 | SocketAddress addr(_iface, host, port); |
Christopher Haster |
96:656011e49d9f | 46 | if (!addr) { |
Christopher Haster |
79:43a7e8c0d6cc | 47 | return NSAPI_ERROR_DNS_FAILURE; |
Christopher Haster |
79:43a7e8c0d6cc | 48 | } |
Christopher Haster |
79:43a7e8c0d6cc | 49 | |
Christopher Haster |
79:43a7e8c0d6cc | 50 | return connect(addr); |
Christopher Haster |
79:43a7e8c0d6cc | 51 | } |
Christopher Haster |
79:43a7e8c0d6cc | 52 | |
Christopher Haster |
79:43a7e8c0d6cc | 53 | int TCPSocket::send(const void *data, unsigned size) |
Christopher Haster |
79:43a7e8c0d6cc | 54 | { |
Christopher Haster |
82:97d166c4a193 | 55 | mbed::Timer timer; |
Christopher Haster |
82:97d166c4a193 | 56 | timer.start(); |
Christopher Haster |
118:96627c4b83d5 | 57 | mbed::Timeout timeout; |
Christopher Haster |
118:96627c4b83d5 | 58 | if (_timeout >= 0) { |
Christopher Haster |
118:96627c4b83d5 | 59 | timeout.attach_us(&Socket::wakeup, _timeout * 1000); |
Christopher Haster |
118:96627c4b83d5 | 60 | } |
Christopher Haster |
82:97d166c4a193 | 61 | |
Christopher Haster |
82:97d166c4a193 | 62 | while (true) { |
Christopher Haster |
82:97d166c4a193 | 63 | if (!_socket) { |
Christopher Haster |
82:97d166c4a193 | 64 | return NSAPI_ERROR_NO_SOCKET; |
Christopher Haster |
82:97d166c4a193 | 65 | } |
Christopher Haster |
82:97d166c4a193 | 66 | |
Christopher Haster |
82:97d166c4a193 | 67 | int sent = _iface->socket_send(_socket, data, size); |
Christopher Haster |
115:950b19eb0f02 | 68 | if (sent != NSAPI_ERROR_WOULD_BLOCK |
Christopher Haster |
118:96627c4b83d5 | 69 | || (_timeout >= 0 && timer.read_ms() >= _timeout)) { |
Christopher Haster |
82:97d166c4a193 | 70 | return sent; |
Christopher Haster |
82:97d166c4a193 | 71 | } |
Christopher Haster |
116:bc043343d753 | 72 | |
Christopher Haster |
116:bc043343d753 | 73 | __WFI(); |
Christopher Haster |
79:43a7e8c0d6cc | 74 | } |
Christopher Haster |
79:43a7e8c0d6cc | 75 | } |
Christopher Haster |
79:43a7e8c0d6cc | 76 | |
Christopher Haster |
79:43a7e8c0d6cc | 77 | int TCPSocket::recv(void *data, unsigned size) |
Christopher Haster |
79:43a7e8c0d6cc | 78 | { |
Christopher Haster |
82:97d166c4a193 | 79 | mbed::Timer timer; |
Christopher Haster |
82:97d166c4a193 | 80 | timer.start(); |
Christopher Haster |
118:96627c4b83d5 | 81 | mbed::Timeout timeout; |
Christopher Haster |
118:96627c4b83d5 | 82 | if (_timeout >= 0) { |
Christopher Haster |
118:96627c4b83d5 | 83 | timeout.attach_us(&Socket::wakeup, _timeout * 1000); |
Christopher Haster |
118:96627c4b83d5 | 84 | } |
Christopher Haster |
82:97d166c4a193 | 85 | |
Christopher Haster |
82:97d166c4a193 | 86 | while (true) { |
Christopher Haster |
82:97d166c4a193 | 87 | if (!_socket) { |
Christopher Haster |
82:97d166c4a193 | 88 | return NSAPI_ERROR_NO_SOCKET; |
Christopher Haster |
82:97d166c4a193 | 89 | } |
Christopher Haster |
82:97d166c4a193 | 90 | |
Christopher Haster |
82:97d166c4a193 | 91 | int recv = _iface->socket_recv(_socket, data, size); |
Christopher Haster |
115:950b19eb0f02 | 92 | if (recv != NSAPI_ERROR_WOULD_BLOCK |
Christopher Haster |
118:96627c4b83d5 | 93 | || (_timeout >= 0 && timer.read_ms() >= _timeout)) { |
Christopher Haster |
82:97d166c4a193 | 94 | return recv; |
Christopher Haster |
82:97d166c4a193 | 95 | } |
Christopher Haster |
116:bc043343d753 | 96 | |
Christopher Haster |
116:bc043343d753 | 97 | __WFI(); |
Christopher Haster |
79:43a7e8c0d6cc | 98 | } |
Christopher Haster |
79:43a7e8c0d6cc | 99 | } |