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.
Dependencies: C12832 EthernetInterface LM75B MMA7660 MQTT mbed-rtos mbed
Fork of IBMIoTClientEthernetExample by
Diff: EthernetInterface/Socket/TCPSocketConnection.cpp
- Revision:
- 9:58eb378727d9
- Parent:
- 8:80d49dd91542
- Child:
- 10:0b5e0dfee08e
--- a/EthernetInterface/Socket/TCPSocketConnection.cpp Wed Oct 01 13:27:35 2014 +0000
+++ /dev/null Thu Jan 01 00:00:00 1970 +0000
@@ -1,133 +0,0 @@
-/* Copyright (C) 2012 mbed.org, MIT License
- *
- * Permission is hereby granted, free of charge, to any person obtaining a copy of this software
- * and associated documentation files (the "Software"), to deal in the Software without restriction,
- * including without limitation the rights to use, copy, modify, merge, publish, distribute,
- * sublicense, and/or sell copies of the Software, and to permit persons to whom the Software is
- * furnished to do so, subject to the following conditions:
- *
- * The above copyright notice and this permission notice shall be included in all copies or
- * substantial portions of the Software.
- *
- * THE SOFTWARE IS PROVIDED "AS IS", WITHOUT WARRANTY OF ANY KIND, EXPRESS OR IMPLIED, INCLUDING
- * BUT NOT LIMITED TO THE WARRANTIES OF MERCHANTABILITY, FITNESS FOR A PARTICULAR PURPOSE AND
- * NONINFRINGEMENT. IN NO EVENT SHALL THE AUTHORS OR COPYRIGHT HOLDERS BE LIABLE FOR ANY CLAIM,
- * DAMAGES OR OTHER LIABILITY, WHETHER IN AN ACTION OF CONTRACT, TORT OR OTHERWISE, ARISING FROM,
- * OUT OF OR IN CONNECTION WITH THE SOFTWARE OR THE USE OR OTHER DEALINGS IN THE SOFTWARE.
- */
-#include "TCPSocketConnection.h"
-#include <cstring>
-
-using std::memset;
-using std::memcpy;
-
-TCPSocketConnection::TCPSocketConnection() :
- _is_connected(false) {
-}
-
-int TCPSocketConnection::connect(const char* host, const int port) {
- if (init_socket(SOCK_STREAM) < 0)
- return -1;
-
- if (set_address(host, port) != 0)
- return -1;
-
- if (lwip_connect(_sock_fd, (const struct sockaddr *) &_remoteHost, sizeof(_remoteHost)) < 0) {
- close();
- return -1;
- }
- _is_connected = true;
-
- return 0;
-}
-
-bool TCPSocketConnection::is_connected(void) {
- return _is_connected;
-}
-
-int TCPSocketConnection::send(char* data, int length) {
- if ((_sock_fd < 0) || !_is_connected)
- return -1;
-
- if (!_blocking) {
- TimeInterval timeout(_timeout);
- if (wait_writable(timeout) != 0)
- return -1;
- }
-
- int n = lwip_send(_sock_fd, data, length, 0);
- _is_connected = (n != 0);
-
- return n;
-}
-
-// -1 if unsuccessful, else number of bytes written
-int TCPSocketConnection::send_all(char* data, int length) {
- if ((_sock_fd < 0) || !_is_connected)
- return -1;
-
- int writtenLen = 0;
- TimeInterval timeout(_timeout);
- while (writtenLen < length) {
- if (!_blocking) {
- // Wait for socket to be writeable
- if (wait_writable(timeout) != 0)
- return writtenLen;
- }
-
- int ret = lwip_send(_sock_fd, data + writtenLen, length - writtenLen, 0);
- if (ret > 0) {
- writtenLen += ret;
- continue;
- } else if (ret == 0) {
- _is_connected = false;
- return writtenLen;
- } else {
- return -1; //Connnection error
- }
- }
- return writtenLen;
-}
-
-int TCPSocketConnection::receive(char* data, int length) {
- if ((_sock_fd < 0) || !_is_connected)
- return -1;
-
- if (!_blocking) {
- TimeInterval timeout(_timeout);
- if (wait_readable(timeout) != 0)
- return -1;
- }
-
- int n = lwip_recv(_sock_fd, data, length, 0);
- _is_connected = (n != 0);
-
- return n;
-}
-
-// -1 if unsuccessful, else number of bytes received
-int TCPSocketConnection::receive_all(char* data, int length) {
- if ((_sock_fd < 0) || !_is_connected)
- return -1;
-
- int readLen = 0;
- TimeInterval timeout(_timeout);
- while (readLen < length) {
- if (!_blocking) {
- //Wait for socket to be readable
- if (wait_readable(timeout) != 0)
- return readLen;
- }
-
- int ret = lwip_recv(_sock_fd, data + readLen, length - readLen, 0);
- if (ret > 0) {
- readLen += ret;
- } else if (ret == 0) {
- _is_connected = false;
- return readLen;
- } else {
- return -1; //Connnection error
- }
- }
- return readLen;
-}
