Matthew Furseman / cc3000_hostdriver_mbedsocket_hacked

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.

Fork of cc3000_hostdriver_mbedsocket by Martin Kojtal

Socket/UDPSocket.cpp@28:8c7cc1c76ff8, 2013-10-05 (annotated)

Committer:
Kojto
Date:
Sat Oct 05 20:29:39 2013 +0200
Revision:
28:8c7cc1c76ff8
Parent:
16:f3676ae62f96 
Commented select on UDP write (send),  return in TCP receive

Who changed what in which revision?

UserRevisionLine numberNew contents of line
Kojto 5:245ac5b73132 1 /* Copyright (C) 2013 mbed.org, MIT License
Kojto 0:615c697c33b0 2 *
Kojto 0:615c697c33b0 3 * Permission is hereby granted, free of charge, to any person obtaining a copy of this software
Kojto 0:615c697c33b0 4 * and associated documentation files (the "Software"), to deal in the Software without restriction,
Kojto 0:615c697c33b0 5 * including without limitation the rights to use, copy, modify, merge, publish, distribute,
Kojto 0:615c697c33b0 6 * sublicense, and/or sell copies of the Software, and to permit persons to whom the Software is
Kojto 0:615c697c33b0 7 * furnished to do so, subject to the following conditions:
Kojto 0:615c697c33b0 8 *
Kojto 0:615c697c33b0 9 * The above copyright notice and this permission notice shall be included in all copies or
Kojto 0:615c697c33b0 10 * substantial portions of the Software.
Kojto 0:615c697c33b0 11 *
Kojto 0:615c697c33b0 12 * THE SOFTWARE IS PROVIDED "AS IS", WITHOUT WARRANTY OF ANY KIND, EXPRESS OR IMPLIED, INCLUDING
Kojto 0:615c697c33b0 13 * BUT NOT LIMITED TO THE WARRANTIES OF MERCHANTABILITY, FITNESS FOR A PARTICULAR PURPOSE AND
Kojto 0:615c697c33b0 14 * NONINFRINGEMENT. IN NO EVENT SHALL THE AUTHORS OR COPYRIGHT HOLDERS BE LIABLE FOR ANY CLAIM,
Kojto 0:615c697c33b0 15 * DAMAGES OR OTHER LIABILITY, WHETHER IN AN ACTION OF CONTRACT, TORT OR OTHERWISE, ARISING FROM,
Kojto 0:615c697c33b0 16 * OUT OF OR IN CONNECTION WITH THE SOFTWARE OR THE USE OR OTHER DEALINGS IN THE SOFTWARE.
Kojto 0:615c697c33b0 17 */
Kojto 0:615c697c33b0 18
Kojto 0:615c697c33b0 19 #include "UDPSocket.h"
Kojto 0:615c697c33b0 20
Kojto 0:615c697c33b0 21 #include <string>
Kojto 0:615c697c33b0 22 #include <algorithm>
Kojto 0:615c697c33b0 23
Kojto 0:615c697c33b0 24 UDPSocket::UDPSocket() {
Kojto 0:615c697c33b0 25
Kojto 0:615c697c33b0 26 }
Kojto 0:615c697c33b0 27
Kojto 0:615c697c33b0 28 int UDPSocket::init(void) {
Kojto 4:15b58c119a0a 29 return init_socket(SOCK_DGRAM, IPPROTO_UDP);
Kojto 0:615c697c33b0 30 }
Kojto 0:615c697c33b0 31
Kojto 0:615c697c33b0 32 int UDPSocket::bind(int port) {
Kojto 4:15b58c119a0a 33 if (init_socket(SOCK_DGRAM, IPPROTO_UDP) < 0) {
Kojto 4:15b58c119a0a 34 return -1;
Kojto 4:15b58c119a0a 35 }
Kojto 0:615c697c33b0 36
Kojto 0:615c697c33b0 37 sockaddr_in localHost;
Kojto 4:15b58c119a0a 38 std::memset(&localHost, 0, sizeof(sockaddr_in));
Kojto 0:615c697c33b0 39
Kojto 0:615c697c33b0 40 localHost.sin_family = AF_INET;
Kojto 0:615c697c33b0 41 localHost.sin_port = htons(port);
Kojto 4:15b58c119a0a 42 localHost.sin_addr.s_addr = 0;
Kojto 0:615c697c33b0 43
Kojto 4:15b58c119a0a 44 if (_cc3000_module->_socket.bind(_sock_fd, (sockaddr *)&localHost, sizeof(sockaddr_in)) != 0) {
SolderSplashLabs 13:5e36c267e62f 45 DBG_SOCKET("Failed to bind a socket (udp). Closing socket");
Kojto 0:615c697c33b0 46 _cc3000_module->_socket.closesocket(_sock_fd);
Kojto 4:15b58c119a0a 47 _sock_fd = -1;
Kojto 0:615c697c33b0 48 return -1;
Kojto 0:615c697c33b0 49 }
Kojto 5:245ac5b73132 50
Kojto 0:615c697c33b0 51 return 0;
Kojto 0:615c697c33b0 52 }
Kojto 0:615c697c33b0 53
Kojto 0:615c697c33b0 54 int UDPSocket::sendTo(Endpoint &remote, char *packet, int length)
Kojto 0:615c697c33b0 55 {
Kojto 0:615c697c33b0 56 if (_sock_fd < 0) {
Kojto 0:615c697c33b0 57 return -1;
Kojto 0:615c697c33b0 58 }
Kojto 28:8c7cc1c76ff8 59 // TODO - seems to be a bug, waiting for TI to respond
Kojto 28:8c7cc1c76ff8 60 // if (!_blocking) {
Kojto 28:8c7cc1c76ff8 61 // TimeInterval timeout(_timeout);
Kojto 28:8c7cc1c76ff8 62 // if (wait_writable(timeout) != 0) {
Kojto 28:8c7cc1c76ff8 63 // DBG_SOCKET("The socket is not writeable. _sock_fd: %d", _sock_fd);
Kojto 28:8c7cc1c76ff8 64 // return 0;
Kojto 28:8c7cc1c76ff8 65 // }
Kojto 28:8c7cc1c76ff8 66 // }
Kojto 0:615c697c33b0 67
Kojto 4:15b58c119a0a 68 return _cc3000_module->_socket.sendto(_sock_fd, packet, length, 0, (sockaddr *)&remote._remote_host, sizeof(sockaddr));
Kojto 0:615c697c33b0 69 }
Kojto 0:615c697c33b0 70
Kojto 0:615c697c33b0 71 int UDPSocket::receiveFrom(Endpoint &remote, char *buffer, int length)
Kojto 0:615c697c33b0 72 {
Kojto 0:615c697c33b0 73 if (_sock_fd < 0) {
Kojto 0:615c697c33b0 74 return -1;
Kojto 0:615c697c33b0 75 }
Kojto 0:615c697c33b0 76
Kojto 0:615c697c33b0 77 if (!_blocking) {
Kojto 0:615c697c33b0 78 TimeInterval timeout(_timeout);
Kojto 0:615c697c33b0 79 if (wait_readable(timeout) != 0) {
SolderSplashLabs 13:5e36c267e62f 80 DBG_SOCKET("The socket is not readable. _sock_fd: %d", _sock_fd);
Kojto 0:615c697c33b0 81 return 0;
Kojto 0:615c697c33b0 82 }
Kojto 0:615c697c33b0 83 }
Kojto 0:615c697c33b0 84
Kojto 0:615c697c33b0 85 remote.reset_address();
Kojto 0:615c697c33b0 86 socklen_t remote_host_length = sizeof(remote._remote_host);
Kojto 0:615c697c33b0 87
Kojto 0:615c697c33b0 88 return _cc3000_module->_socket.recvfrom(_sock_fd, buffer, length, 0, (sockaddr *)&remote._remote_host, &remote_host_length);
Kojto 0:615c697c33b0 89 }
Kojto 0:615c697c33b0 90
Kojto 0:615c697c33b0 91