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.
TCPSocket.cpp@9:1600369a29dd, 2016-04-05 (annotated)
- Committer:
- Christopher Haster
- Date:
- Tue Apr 05 12:52:07 2016 -0500
- Revision:
- 9:1600369a29dd
- Parent:
- 8:9c6673c93082
- Child:
- 10:97d166c4a193
Added proper forwarding for interrupt driven callbacks
Who changed what in which revision?
User | Revision | Line number | New contents of line |
---|---|---|---|
Christopher Haster |
7:43a7e8c0d6cc | 1 | /* Socket |
Christopher Haster |
7:43a7e8c0d6cc | 2 | * Copyright (c) 2015 ARM Limited |
Christopher Haster |
7:43a7e8c0d6cc | 3 | * |
Christopher Haster |
7:43a7e8c0d6cc | 4 | * Licensed under the Apache License, Version 2.0 (the "License"); |
Christopher Haster |
7:43a7e8c0d6cc | 5 | * you may not use this file except in compliance with the License. |
Christopher Haster |
7:43a7e8c0d6cc | 6 | * You may obtain a copy of the License at |
Christopher Haster |
7:43a7e8c0d6cc | 7 | * |
Christopher Haster |
7:43a7e8c0d6cc | 8 | * http://www.apache.org/licenses/LICENSE-2.0 |
Christopher Haster |
7:43a7e8c0d6cc | 9 | * |
Christopher Haster |
7:43a7e8c0d6cc | 10 | * Unless required by applicable law or agreed to in writing, software |
Christopher Haster |
7:43a7e8c0d6cc | 11 | * distributed under the License is distributed on an "AS IS" BASIS, |
Christopher Haster |
7:43a7e8c0d6cc | 12 | * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. |
Christopher Haster |
7:43a7e8c0d6cc | 13 | * See the License for the specific language governing permissions and |
Christopher Haster |
7:43a7e8c0d6cc | 14 | * limitations under the License. |
Christopher Haster |
7:43a7e8c0d6cc | 15 | */ |
Christopher Haster |
7:43a7e8c0d6cc | 16 | |
Christopher Haster |
7:43a7e8c0d6cc | 17 | #include "TCPSocket.h" |
Christopher Haster |
7:43a7e8c0d6cc | 18 | |
Christopher Haster |
7:43a7e8c0d6cc | 19 | TCPSocket::TCPSocket(NetworkInterface *iface) |
Christopher Haster |
7:43a7e8c0d6cc | 20 | : Socket(iface, NetworkInterface::TCP) |
Christopher Haster |
7:43a7e8c0d6cc | 21 | { |
Christopher Haster |
7:43a7e8c0d6cc | 22 | } |
Christopher Haster |
7:43a7e8c0d6cc | 23 | |
Christopher Haster |
8:9c6673c93082 | 24 | int TCPSocket::connect(const SocketAddress &addr) |
Christopher Haster |
7:43a7e8c0d6cc | 25 | { |
Christopher Haster |
7:43a7e8c0d6cc | 26 | if (!_socket) { |
Christopher Haster |
7:43a7e8c0d6cc | 27 | return NSAPI_ERROR_NO_SOCKET; |
Christopher Haster |
7:43a7e8c0d6cc | 28 | } |
Christopher Haster |
7:43a7e8c0d6cc | 29 | |
Christopher Haster |
7:43a7e8c0d6cc | 30 | return _iface->socket_connect(_socket, addr); |
Christopher Haster |
7:43a7e8c0d6cc | 31 | } |
Christopher Haster |
7:43a7e8c0d6cc | 32 | |
Christopher Haster |
7:43a7e8c0d6cc | 33 | int TCPSocket::connect(const char *host, uint16_t port) |
Christopher Haster |
7:43a7e8c0d6cc | 34 | { |
Christopher Haster |
8:9c6673c93082 | 35 | SocketAddress addr(_iface, host, port); |
Christopher Haster |
7:43a7e8c0d6cc | 36 | if (!addr.get_ip_address()) { |
Christopher Haster |
7:43a7e8c0d6cc | 37 | return NSAPI_ERROR_DNS_FAILURE; |
Christopher Haster |
7:43a7e8c0d6cc | 38 | } |
Christopher Haster |
7:43a7e8c0d6cc | 39 | |
Christopher Haster |
7:43a7e8c0d6cc | 40 | return connect(addr); |
Christopher Haster |
7:43a7e8c0d6cc | 41 | } |
Christopher Haster |
7:43a7e8c0d6cc | 42 | |
Christopher Haster |
7:43a7e8c0d6cc | 43 | bool TCPSocket::is_connected() |
Christopher Haster |
7:43a7e8c0d6cc | 44 | { |
Christopher Haster |
7:43a7e8c0d6cc | 45 | return _socket && _iface->socket_is_connected(_socket); |
Christopher Haster |
7:43a7e8c0d6cc | 46 | } |
Christopher Haster |
7:43a7e8c0d6cc | 47 | |
Christopher Haster |
7:43a7e8c0d6cc | 48 | int TCPSocket::send(const void *data, unsigned size) |
Christopher Haster |
7:43a7e8c0d6cc | 49 | { |
Christopher Haster |
7:43a7e8c0d6cc | 50 | if (!_socket) { |
Christopher Haster |
7:43a7e8c0d6cc | 51 | return NSAPI_ERROR_NO_SOCKET; |
Christopher Haster |
7:43a7e8c0d6cc | 52 | } |
Christopher Haster |
7:43a7e8c0d6cc | 53 | |
Christopher Haster |
7:43a7e8c0d6cc | 54 | return _iface->socket_send(_socket, data, size); |
Christopher Haster |
7:43a7e8c0d6cc | 55 | } |
Christopher Haster |
7:43a7e8c0d6cc | 56 | |
Christopher Haster |
7:43a7e8c0d6cc | 57 | int TCPSocket::recv(void *data, unsigned size) |
Christopher Haster |
7:43a7e8c0d6cc | 58 | { |
Christopher Haster |
7:43a7e8c0d6cc | 59 | if (!_socket) { |
Christopher Haster |
7:43a7e8c0d6cc | 60 | return NSAPI_ERROR_NO_SOCKET; |
Christopher Haster |
7:43a7e8c0d6cc | 61 | } |
Christopher Haster |
7:43a7e8c0d6cc | 62 | |
Christopher Haster |
7:43a7e8c0d6cc | 63 | return _iface->socket_recv(_socket, data, size); |
Christopher Haster |
7:43a7e8c0d6cc | 64 | } |
Christopher Haster |
9:1600369a29dd | 65 | |
Christopher Haster |
9:1600369a29dd | 66 | |
Christopher Haster |
9:1600369a29dd | 67 | void TCPSocket::attach_send(mbed::FuncPtr<void()> callback) |
Christopher Haster |
9:1600369a29dd | 68 | { |
Christopher Haster |
9:1600369a29dd | 69 | _send_cb = callback; |
Christopher Haster |
9:1600369a29dd | 70 | |
Christopher Haster |
9:1600369a29dd | 71 | if (_socket && _send_cb) { |
Christopher Haster |
9:1600369a29dd | 72 | return _iface->socket_attach_send(_socket, Socket::thunk, &_send_cb); |
Christopher Haster |
9:1600369a29dd | 73 | } else if (_socket) { |
Christopher Haster |
9:1600369a29dd | 74 | return _iface->socket_attach_send(_socket, 0, 0); |
Christopher Haster |
9:1600369a29dd | 75 | } |
Christopher Haster |
9:1600369a29dd | 76 | } |
Christopher Haster |
9:1600369a29dd | 77 | |
Christopher Haster |
9:1600369a29dd | 78 | void TCPSocket::attach_recv(mbed::FuncPtr<void()> callback) |
Christopher Haster |
9:1600369a29dd | 79 | { |
Christopher Haster |
9:1600369a29dd | 80 | _recv_cb = callback; |
Christopher Haster |
9:1600369a29dd | 81 | |
Christopher Haster |
9:1600369a29dd | 82 | if (_socket && _recv_cb) { |
Christopher Haster |
9:1600369a29dd | 83 | return _iface->socket_attach_recv(_socket, Socket::thunk, &_recv_cb); |
Christopher Haster |
9:1600369a29dd | 84 | } else if (_socket) { |
Christopher Haster |
9:1600369a29dd | 85 | return _iface->socket_attach_recv(_socket, 0, 0); |
Christopher Haster |
9:1600369a29dd | 86 | } |
Christopher Haster |
9:1600369a29dd | 87 | } |
Christopher Haster |
9:1600369a29dd | 88 | |
Christopher Haster |
9:1600369a29dd | 89 | TCPSocket::~TCPSocket() |
Christopher Haster |
9:1600369a29dd | 90 | { |
Christopher Haster |
9:1600369a29dd | 91 | if (_socket && _send_cb) { |
Christopher Haster |
9:1600369a29dd | 92 | _iface->socket_attach_send(_socket, 0, 0); |
Christopher Haster |
9:1600369a29dd | 93 | } |
Christopher Haster |
9:1600369a29dd | 94 | |
Christopher Haster |
9:1600369a29dd | 95 | if (_socket && _recv_cb) { |
Christopher Haster |
9:1600369a29dd | 96 | _iface->socket_attach_recv(_socket, 0, 0); |
Christopher Haster |
9:1600369a29dd | 97 | } |
Christopher Haster |
9:1600369a29dd | 98 | } |