Daniele Lacamera / PicoTCP-Experimental_CDC_ECM_Branch

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 PicoTCP by Daniele Lacamera

Socket/TCPSocketConnection.cpp@29:1a47b7151851, 2013-06-16 (annotated)

Committer:
daniele
Date:
Sun Jun 16 20:19:44 2013 +0000
Revision:
29:1a47b7151851
Child:
35:6078073547bb
Updated from masterbranch;

Who changed what in which revision?

UserRevisionLine numberNew contents of line
daniele 29:1a47b7151851 1 /*
daniele 29:1a47b7151851 2 *
daniele 29:1a47b7151851 3 * PicoTCP Socket interface for mbed.
daniele 29:1a47b7151851 4 * Copyright (C) 2013 TASS Belgium NV
daniele 29:1a47b7151851 5 *
daniele 29:1a47b7151851 6 * Released under GPL v2
daniele 29:1a47b7151851 7 *
daniele 29:1a47b7151851 8 * Other licensing models might apply at the sole discretion of the copyright holders.
daniele 29:1a47b7151851 9 *
daniele 29:1a47b7151851 10 *
daniele 29:1a47b7151851 11 * This software is based on the mbed.org EthernetInterface implementation:
daniele 29:1a47b7151851 12 * Copyright (C) 2012 mbed.org, MIT License
daniele 29:1a47b7151851 13 *
daniele 29:1a47b7151851 14 * Permission is hereby granted, free of charge, to any person obtaining a copy of this software
daniele 29:1a47b7151851 15 * and associated documentation files (the "Software"), to deal in the Software without restriction,
daniele 29:1a47b7151851 16 * including without limitation the rights to use, copy, modify, merge, publish, distribute,
daniele 29:1a47b7151851 17 * sublicense, and/or sell copies of the Software, and to permit persons to whom the Software is
daniele 29:1a47b7151851 18 * furnished to do so, subject to the following conditions:
daniele 29:1a47b7151851 19 *
daniele 29:1a47b7151851 20 * The above copyright notice and this permission notice shall be included in all copies or
daniele 29:1a47b7151851 21 * substantial portions of the Software.
daniele 29:1a47b7151851 22 *
daniele 29:1a47b7151851 23 * THE SOFTWARE IS PROVIDED "AS IS", WITHOUT WARRANTY OF ANY KIND, EXPRESS OR IMPLIED, INCLUDING
daniele 29:1a47b7151851 24 * BUT NOT LIMITED TO THE WARRANTIES OF MERCHANTABILITY, FITNESS FOR A PARTICULAR PURPOSE AND
daniele 29:1a47b7151851 25 * NONINFRINGEMENT. IN NO EVENT SHALL THE AUTHORS OR COPYRIGHT HOLDERS BE LIABLE FOR ANY CLAIM,
daniele 29:1a47b7151851 26 * DAMAGES OR OTHER LIABILITY, WHETHER IN AN ACTION OF CONTRACT, TORT OR OTHERWISE, ARISING FROM,
daniele 29:1a47b7151851 27 * OUT OF OR IN CONNECTION WITH THE SOFTWARE OR THE USE OR OTHER DEALINGS IN THE SOFTWARE.
daniele 29:1a47b7151851 28 */
daniele 29:1a47b7151851 29 #include "TCPSocketConnection.h"
daniele 29:1a47b7151851 30 #include "wrapper.h"
daniele 29:1a47b7151851 31 #include <cstring>
daniele 29:1a47b7151851 32
daniele 29:1a47b7151851 33 using std::memset;
daniele 29:1a47b7151851 34 using std::memcpy;
daniele 29:1a47b7151851 35
daniele 29:1a47b7151851 36 TCPSocketConnection::TCPSocketConnection() :
daniele 29:1a47b7151851 37 _is_connected(false) {
daniele 29:1a47b7151851 38 }
daniele 29:1a47b7151851 39
daniele 29:1a47b7151851 40 int TCPSocketConnection::connect(const char* host, const int port) {
daniele 29:1a47b7151851 41 if (init_socket(SOCK_STREAM) < 0)
daniele 29:1a47b7151851 42 {
daniele 29:1a47b7151851 43 printf("init_socket\n");
daniele 29:1a47b7151851 44 return -1;
daniele 29:1a47b7151851 45 }
daniele 29:1a47b7151851 46
daniele 29:1a47b7151851 47 if (set_address(host, port) != 0)
daniele 29:1a47b7151851 48 {
daniele 29:1a47b7151851 49 printf("set_address\n");
daniele 29:1a47b7151851 50 return -1;
daniele 29:1a47b7151851 51 }
daniele 29:1a47b7151851 52
daniele 29:1a47b7151851 53 if (picotcp_connect(_ep, (struct sockaddr *) &_remoteHost, sizeof(_remoteHost)) < 0) {
daniele 29:1a47b7151851 54 close();
daniele 29:1a47b7151851 55 return -1;
daniele 29:1a47b7151851 56 }
daniele 29:1a47b7151851 57 _is_connected = true;
daniele 29:1a47b7151851 58
daniele 29:1a47b7151851 59 return 0;
daniele 29:1a47b7151851 60 }
daniele 29:1a47b7151851 61
daniele 29:1a47b7151851 62 bool TCPSocketConnection::is_connected(void) {
daniele 29:1a47b7151851 63 return _is_connected;
daniele 29:1a47b7151851 64 }
daniele 29:1a47b7151851 65
daniele 29:1a47b7151851 66 int TCPSocketConnection::send(char* data, int length) {
daniele 29:1a47b7151851 67 int ret;
daniele 29:1a47b7151851 68 if ((_ep < 0) || !_is_connected)
daniele 29:1a47b7151851 69 return -1;
daniele 29:1a47b7151851 70
daniele 29:1a47b7151851 71 if (!_blocking) {
daniele 29:1a47b7151851 72 TimeInterval timeout(_timeout);
daniele 29:1a47b7151851 73 if (wait_writable(timeout) != 0)
daniele 29:1a47b7151851 74 {
daniele 29:1a47b7151851 75 printf("Failed\n");
daniele 29:1a47b7151851 76 return -1;
daniele 29:1a47b7151851 77 }
daniele 29:1a47b7151851 78 }
daniele 29:1a47b7151851 79 ret = picotcp_write(_ep, data, length);
daniele 29:1a47b7151851 80 if (ret < length) {
daniele 29:1a47b7151851 81 _ep->revents &= (~PICO_SOCK_EV_WR);
daniele 29:1a47b7151851 82 printf("Short write\n");
daniele 29:1a47b7151851 83 }
daniele 29:1a47b7151851 84 return ret;
daniele 29:1a47b7151851 85 }
daniele 29:1a47b7151851 86
daniele 29:1a47b7151851 87 // -1 if unsuccessful, else number of bytes written
daniele 29:1a47b7151851 88 int TCPSocketConnection::send_all(char* data, int length) {
daniele 29:1a47b7151851 89 int ret;
daniele 29:1a47b7151851 90 if ((_ep < 0) || !_is_connected)
daniele 29:1a47b7151851 91 return -1;
daniele 29:1a47b7151851 92
daniele 29:1a47b7151851 93 if (!_blocking) {
daniele 29:1a47b7151851 94 TimeInterval timeout(_timeout);
daniele 29:1a47b7151851 95 // Wait for socket to be writeable
daniele 29:1a47b7151851 96 if (wait_writable(timeout) != 0) {
daniele 29:1a47b7151851 97 return 0;
daniele 29:1a47b7151851 98 }
daniele 29:1a47b7151851 99 }
daniele 29:1a47b7151851 100 ret = picotcp_write(_ep, data, length);
daniele 29:1a47b7151851 101 if (ret < length) {
daniele 29:1a47b7151851 102 _ep->revents &= (~PICO_SOCK_EV_WR);
daniele 29:1a47b7151851 103 //printf("Short write\n");
daniele 29:1a47b7151851 104 }
daniele 29:1a47b7151851 105 return ret;
daniele 29:1a47b7151851 106 }
daniele 29:1a47b7151851 107
daniele 29:1a47b7151851 108 int TCPSocketConnection::receive(char* data, int length) {
daniele 29:1a47b7151851 109 int ret;
daniele 29:1a47b7151851 110 if ((_ep < 0) || !_is_connected)
daniele 29:1a47b7151851 111 return -1;
daniele 29:1a47b7151851 112
daniele 29:1a47b7151851 113 if (!_blocking) {
daniele 29:1a47b7151851 114 TimeInterval timeout(_timeout);
daniele 29:1a47b7151851 115 if (wait_readable(timeout) != 0)
daniele 29:1a47b7151851 116 {
daniele 29:1a47b7151851 117 printf("Failed receiving\n");
daniele 29:1a47b7151851 118 return -1;
daniele 29:1a47b7151851 119 }
daniele 29:1a47b7151851 120 }
daniele 29:1a47b7151851 121 ret = picotcp_read(_ep, data, length);
daniele 29:1a47b7151851 122 if (ret < length) {
daniele 29:1a47b7151851 123 _ep->revents &= (~PICO_SOCK_EV_RD);
daniele 29:1a47b7151851 124 //printf("Short read\n");
daniele 29:1a47b7151851 125 }
daniele 29:1a47b7151851 126 return ret;
daniele 29:1a47b7151851 127 }
daniele 29:1a47b7151851 128
daniele 29:1a47b7151851 129 // -1 if unsuccessful, else number of bytes received
daniele 29:1a47b7151851 130 int TCPSocketConnection::receive_all(char* data, int length) {
daniele 29:1a47b7151851 131 return receive(data, length);
daniele 29:1a47b7151851 132 }