ap
Dependencies: DnsQuery
Dependents: WizFi310_TCP_Echo_Server_Example
Fork of NetworkSocketAPI by
Socket.cpp@108:2e5eccf30a84, 2016-04-20 (annotated)
- Committer:
- geky
- Date:
- Wed Apr 20 00:46:23 2016 +0000
- Revision:
- 108:2e5eccf30a84
- Parent:
- 105:2fd212f8da61
- Child:
- 109:5d8bd5752386
Fixe race condition in socket close
Who changed what in which revision?
User | Revision | Line number | New contents of line |
---|---|---|---|
Christopher Haster |
89:b1d417383c0d | 1 | /* Socket |
Christopher Haster |
89:b1d417383c0d | 2 | * Copyright (c) 2015 ARM Limited |
Christopher Haster |
89:b1d417383c0d | 3 | * |
Christopher Haster |
89:b1d417383c0d | 4 | * Licensed under the Apache License, Version 2.0 (the "License"); |
Christopher Haster |
89:b1d417383c0d | 5 | * you may not use this file except in compliance with the License. |
Christopher Haster |
89:b1d417383c0d | 6 | * You may obtain a copy of the License at |
Christopher Haster |
89:b1d417383c0d | 7 | * |
Christopher Haster |
89:b1d417383c0d | 8 | * http://www.apache.org/licenses/LICENSE-2.0 |
Christopher Haster |
89:b1d417383c0d | 9 | * |
Christopher Haster |
89:b1d417383c0d | 10 | * Unless required by applicable law or agreed to in writing, software |
Christopher Haster |
89:b1d417383c0d | 11 | * distributed under the License is distributed on an "AS IS" BASIS, |
Christopher Haster |
89:b1d417383c0d | 12 | * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. |
Christopher Haster |
89:b1d417383c0d | 13 | * See the License for the specific language governing permissions and |
Christopher Haster |
89:b1d417383c0d | 14 | * limitations under the License. |
Christopher Haster |
89:b1d417383c0d | 15 | */ |
Christopher Haster |
89:b1d417383c0d | 16 | |
Christopher Haster |
89:b1d417383c0d | 17 | #include "Socket.h" |
Christopher Haster |
89:b1d417383c0d | 18 | |
Christopher Haster |
90:0a988e4abb72 | 19 | Socket::Socket() |
Christopher Haster |
90:0a988e4abb72 | 20 | : _iface(0) |
Christopher Haster |
90:0a988e4abb72 | 21 | , _socket(0) |
Christopher Haster |
89:b1d417383c0d | 22 | , _blocking(true) |
Christopher Haster |
89:b1d417383c0d | 23 | , _timeout(0) |
Christopher Haster |
89:b1d417383c0d | 24 | { |
Christopher Haster |
89:b1d417383c0d | 25 | } |
Christopher Haster |
89:b1d417383c0d | 26 | |
Christopher Haster |
89:b1d417383c0d | 27 | Socket::~Socket() |
Christopher Haster |
89:b1d417383c0d | 28 | { |
Christopher Haster |
89:b1d417383c0d | 29 | if (_socket) { |
Christopher Haster |
91:cad29ce6a01c | 30 | close(); |
Christopher Haster |
89:b1d417383c0d | 31 | } |
Christopher Haster |
89:b1d417383c0d | 32 | } |
Christopher Haster |
89:b1d417383c0d | 33 | |
Christopher Haster |
105:2fd212f8da61 | 34 | int Socket::open(NetworkStack *iface, nsapi_protocol_t proto) |
Christopher Haster |
90:0a988e4abb72 | 35 | { |
Christopher Haster |
90:0a988e4abb72 | 36 | _iface = iface; |
Christopher Haster |
93:65a9f84862f0 | 37 | |
Christopher Haster |
93:65a9f84862f0 | 38 | void *socket; |
Christopher Haster |
93:65a9f84862f0 | 39 | int err = _iface->socket_open(&socket, proto); |
Christopher Haster |
93:65a9f84862f0 | 40 | if (err) { |
Christopher Haster |
93:65a9f84862f0 | 41 | return err; |
Christopher Haster |
93:65a9f84862f0 | 42 | } |
Christopher Haster |
93:65a9f84862f0 | 43 | |
Christopher Haster |
93:65a9f84862f0 | 44 | _socket = socket; |
Christopher Haster |
92:dd5f19874adf | 45 | _iface->socket_attach(_socket, &Socket::thunk, this); |
Christopher Haster |
93:65a9f84862f0 | 46 | |
Christopher Haster |
93:65a9f84862f0 | 47 | return 0; |
Christopher Haster |
90:0a988e4abb72 | 48 | } |
Christopher Haster |
90:0a988e4abb72 | 49 | |
Christopher Haster |
91:cad29ce6a01c | 50 | int Socket::close() |
Christopher Haster |
90:0a988e4abb72 | 51 | { |
Christopher Haster |
90:0a988e4abb72 | 52 | if (!_socket) { |
Christopher Haster |
90:0a988e4abb72 | 53 | return 0; |
Christopher Haster |
90:0a988e4abb72 | 54 | } |
geky | 108:2e5eccf30a84 | 55 | |
geky | 108:2e5eccf30a84 | 56 | _iface->socket_attach(_socket, 0, 0); |
geky | 108:2e5eccf30a84 | 57 | |
geky | 108:2e5eccf30a84 | 58 | void *volatile socket = _socket; |
Christopher Haster |
93:65a9f84862f0 | 59 | _socket = 0; |
Christopher Haster |
93:65a9f84862f0 | 60 | return _iface->socket_close(socket); |
Christopher Haster |
90:0a988e4abb72 | 61 | } |
Christopher Haster |
90:0a988e4abb72 | 62 | |
Christopher Haster |
98:0f614f1d0398 | 63 | int Socket::bind(uint16_t port) |
Christopher Haster |
98:0f614f1d0398 | 64 | { |
Christopher Haster |
98:0f614f1d0398 | 65 | SocketAddress addr(0, port); |
Christopher Haster |
98:0f614f1d0398 | 66 | return bind(addr); |
Christopher Haster |
98:0f614f1d0398 | 67 | } |
Christopher Haster |
98:0f614f1d0398 | 68 | |
Christopher Haster |
98:0f614f1d0398 | 69 | int Socket::bind(const char *address, uint16_t port) |
Christopher Haster |
98:0f614f1d0398 | 70 | { |
Christopher Haster |
98:0f614f1d0398 | 71 | SocketAddress addr(address, port); |
Christopher Haster |
98:0f614f1d0398 | 72 | return bind(addr); |
Christopher Haster |
98:0f614f1d0398 | 73 | } |
Christopher Haster |
98:0f614f1d0398 | 74 | |
Christopher Haster |
98:0f614f1d0398 | 75 | int Socket::bind(const SocketAddress &address) |
Christopher Haster |
98:0f614f1d0398 | 76 | { |
Christopher Haster |
98:0f614f1d0398 | 77 | if (!_socket) { |
Christopher Haster |
98:0f614f1d0398 | 78 | return NSAPI_ERROR_NO_SOCKET; |
Christopher Haster |
98:0f614f1d0398 | 79 | } |
Christopher Haster |
98:0f614f1d0398 | 80 | |
Christopher Haster |
98:0f614f1d0398 | 81 | return _iface->socket_bind(_socket, address); |
Christopher Haster |
98:0f614f1d0398 | 82 | } |
Christopher Haster |
98:0f614f1d0398 | 83 | |
Christopher Haster |
89:b1d417383c0d | 84 | void Socket::set_blocking(bool blocking) |
Christopher Haster |
89:b1d417383c0d | 85 | { |
Christopher Haster |
89:b1d417383c0d | 86 | _blocking = blocking; |
Christopher Haster |
89:b1d417383c0d | 87 | } |
Christopher Haster |
89:b1d417383c0d | 88 | |
Christopher Haster |
89:b1d417383c0d | 89 | void Socket::set_timeout(unsigned timeout) |
Christopher Haster |
89:b1d417383c0d | 90 | { |
Christopher Haster |
89:b1d417383c0d | 91 | _timeout = timeout; |
Christopher Haster |
89:b1d417383c0d | 92 | } |
Christopher Haster |
89:b1d417383c0d | 93 | |
Christopher Haster |
99:f51358e506c1 | 94 | int Socket::setsockopt(int level, int optname, const void *optval, unsigned optlen) |
Christopher Haster |
89:b1d417383c0d | 95 | { |
Christopher Haster |
89:b1d417383c0d | 96 | if (!_socket) { |
Christopher Haster |
89:b1d417383c0d | 97 | return NSAPI_ERROR_NO_SOCKET; |
Christopher Haster |
89:b1d417383c0d | 98 | } |
Christopher Haster |
89:b1d417383c0d | 99 | |
Christopher Haster |
99:f51358e506c1 | 100 | return _iface->setsockopt(_socket, level, optname, optval, optlen); |
Christopher Haster |
89:b1d417383c0d | 101 | } |
Christopher Haster |
89:b1d417383c0d | 102 | |
Christopher Haster |
99:f51358e506c1 | 103 | int Socket::getsockopt(int level, int optname, void *optval, unsigned *optlen) |
Christopher Haster |
89:b1d417383c0d | 104 | { |
Christopher Haster |
89:b1d417383c0d | 105 | if (!_socket) { |
Christopher Haster |
89:b1d417383c0d | 106 | return NSAPI_ERROR_NO_SOCKET; |
Christopher Haster |
89:b1d417383c0d | 107 | } |
Christopher Haster |
89:b1d417383c0d | 108 | |
Christopher Haster |
99:f51358e506c1 | 109 | return _iface->getsockopt(_socket, level, optname, optval, optlen); |
Christopher Haster |
99:f51358e506c1 | 110 | |
Christopher Haster |
89:b1d417383c0d | 111 | } |
Christopher Haster |
89:b1d417383c0d | 112 | |
Christopher Haster |
92:dd5f19874adf | 113 | void Socket::thunk(void *data) |
Christopher Haster |
89:b1d417383c0d | 114 | { |
Christopher Haster |
92:dd5f19874adf | 115 | Socket *self = (Socket *)data; |
Christopher Haster |
92:dd5f19874adf | 116 | if (self->_callback) { |
Christopher Haster |
92:dd5f19874adf | 117 | self->_callback(); |
Christopher Haster |
92:dd5f19874adf | 118 | } |
Christopher Haster |
89:b1d417383c0d | 119 | } |
Christopher Haster |
92:dd5f19874adf | 120 | |
Christopher Haster |
92:dd5f19874adf | 121 | void Socket::attach(FunctionPointer callback) |
Christopher Haster |
92:dd5f19874adf | 122 | { |
Christopher Haster |
92:dd5f19874adf | 123 | _callback = callback; |
Christopher Haster |
92:dd5f19874adf | 124 | } |