Nigel Rantor / azure_c_shared_utility

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 azure_c_shared_utility by Azure IoT

tcpsocketconnection_c.cpp@34:651c23af382c, 2017-08-24 (annotated)

Committer:
wiggly
Date:
Thu Aug 24 14:14:15 2017 +0100
Revision:
34:651c23af382c
Parent:
33:5f2a48fc7e5b 
Pass in network stack to platform initialisation

Remove NTP setup from azure platform code

Who changed what in which revision?

UserRevisionLine numberNew contents of line
Azure.IoT Build 0:fa2de1b79154 1 // Copyright (c) Microsoft. All rights reserved.
Azure.IoT Build 0:fa2de1b79154 2 // Licensed under the MIT license. See LICENSE file in the project root for full license information.
Azure.IoT Build 0:fa2de1b79154 3
Azure.IoT Build 0:fa2de1b79154 4 #include "mbed.h"
Azure.IoT Build 0:fa2de1b79154 5 #include <stddef.h>
Azure.IoT Build 0:fa2de1b79154 6 #include "azure_c_shared_utility/tcpsocketconnection_c.h"
wiggly 34:651c23af382c 7 #include "azure_c_shared_utility/platform.h"
Azure.IoT Build 0:fa2de1b79154 8
wiggly 33:5f2a48fc7e5b 9 typedef struct {
wiggly 33:5f2a48fc7e5b 10 TCPSocket* socket;
wiggly 33:5f2a48fc7e5b 11 bool connected;
wiggly 33:5f2a48fc7e5b 12 } TCPSOCKETCONNECTION_HANDLE_T;
Azure.IoT Build 0:fa2de1b79154 13
Azure.IoT Build 0:fa2de1b79154 14 TCPSOCKETCONNECTION_HANDLE tcpsocketconnection_create(void)
Azure.IoT Build 0:fa2de1b79154 15 {
wiggly 33:5f2a48fc7e5b 16 TCPSOCKETCONNECTION_HANDLE_T* conn = new TCPSOCKETCONNECTION_HANDLE_T;
wiggly 34:651c23af382c 17 conn->socket = new TCPSocket(platform_get_network_stack());
wiggly 33:5f2a48fc7e5b 18 conn->connected = false;
wiggly 33:5f2a48fc7e5b 19 return conn;
Azure.IoT Build 0:fa2de1b79154 20 }
Azure.IoT Build 0:fa2de1b79154 21
Azure.IoT Build 0:fa2de1b79154 22 void tcpsocketconnection_set_blocking(TCPSOCKETCONNECTION_HANDLE tcpSocketConnectionHandle, bool blocking, unsigned int timeout)
Azure.IoT Build 0:fa2de1b79154 23 {
wiggly 33:5f2a48fc7e5b 24 TCPSOCKETCONNECTION_HANDLE_T* tsc = (TCPSOCKETCONNECTION_HANDLE_T*)tcpSocketConnectionHandle;
wiggly 33:5f2a48fc7e5b 25 tsc->socket->set_blocking(blocking);
wiggly 33:5f2a48fc7e5b 26 tsc->socket->set_timeout(timeout);
Azure.IoT Build 0:fa2de1b79154 27 }
Azure.IoT Build 0:fa2de1b79154 28
Azure.IoT Build 0:fa2de1b79154 29 void tcpsocketconnection_destroy(TCPSOCKETCONNECTION_HANDLE tcpSocketConnectionHandle)
Azure.IoT Build 0:fa2de1b79154 30 {
wiggly 33:5f2a48fc7e5b 31 delete (TCPSOCKETCONNECTION_HANDLE_T*)tcpSocketConnectionHandle;
Azure.IoT Build 0:fa2de1b79154 32 }
Azure.IoT Build 0:fa2de1b79154 33
Azure.IoT Build 0:fa2de1b79154 34 int tcpsocketconnection_connect(TCPSOCKETCONNECTION_HANDLE tcpSocketConnectionHandle, const char* host, const int port)
Azure.IoT Build 0:fa2de1b79154 35 {
wiggly 33:5f2a48fc7e5b 36 TCPSOCKETCONNECTION_HANDLE_T* tsc = (TCPSOCKETCONNECTION_HANDLE_T*)tcpSocketConnectionHandle;
wiggly 33:5f2a48fc7e5b 37 // TODO: so, we set this but we really need to kill it if we get an error later too.....
wiggly 33:5f2a48fc7e5b 38 auto rv = tsc->socket->connect(host, port);
wiggly 33:5f2a48fc7e5b 39 if(rv == 0) { tsc->connected = true; }
wiggly 33:5f2a48fc7e5b 40 return rv;
Azure.IoT Build 0:fa2de1b79154 41 }
Azure.IoT Build 0:fa2de1b79154 42
Azure.IoT Build 0:fa2de1b79154 43 bool tcpsocketconnection_is_connected(TCPSOCKETCONNECTION_HANDLE tcpSocketConnectionHandle)
Azure.IoT Build 0:fa2de1b79154 44 {
wiggly 33:5f2a48fc7e5b 45 TCPSOCKETCONNECTION_HANDLE_T* tsc = (TCPSOCKETCONNECTION_HANDLE_T*)tcpSocketConnectionHandle;
wiggly 33:5f2a48fc7e5b 46 return tsc->connected;
Azure.IoT Build 0:fa2de1b79154 47 }
Azure.IoT Build 0:fa2de1b79154 48
Azure.IoT Build 0:fa2de1b79154 49 void tcpsocketconnection_close(TCPSOCKETCONNECTION_HANDLE tcpSocketConnectionHandle)
Azure.IoT Build 0:fa2de1b79154 50 {
wiggly 33:5f2a48fc7e5b 51 TCPSOCKETCONNECTION_HANDLE_T* tsc = (TCPSOCKETCONNECTION_HANDLE_T*)tcpSocketConnectionHandle;
wiggly 33:5f2a48fc7e5b 52 tsc->socket->close();
Azure.IoT Build 0:fa2de1b79154 53 }
Azure.IoT Build 0:fa2de1b79154 54
Azure.IoT Build 0:fa2de1b79154 55 int tcpsocketconnection_send(TCPSOCKETCONNECTION_HANDLE tcpSocketConnectionHandle, const char* data, int length)
Azure.IoT Build 0:fa2de1b79154 56 {
wiggly 33:5f2a48fc7e5b 57 TCPSOCKETCONNECTION_HANDLE_T* tsc = (TCPSOCKETCONNECTION_HANDLE_T*)tcpSocketConnectionHandle;
wiggly 33:5f2a48fc7e5b 58 return tsc->socket->send((char*)data, length);
Azure.IoT Build 0:fa2de1b79154 59 }
Azure.IoT Build 0:fa2de1b79154 60
Azure.IoT Build 0:fa2de1b79154 61 int tcpsocketconnection_send_all(TCPSOCKETCONNECTION_HANDLE tcpSocketConnectionHandle, const char* data, int length)
Azure.IoT Build 0:fa2de1b79154 62 {
wiggly 33:5f2a48fc7e5b 63 TCPSOCKETCONNECTION_HANDLE_T* tsc = (TCPSOCKETCONNECTION_HANDLE_T*)tcpSocketConnectionHandle;
wiggly 33:5f2a48fc7e5b 64 // TODO: this is shonky and quickly done....
wiggly 33:5f2a48fc7e5b 65
wiggly 33:5f2a48fc7e5b 66 auto rv = tsc->socket->send((char*)data, length);
wiggly 33:5f2a48fc7e5b 67
wiggly 33:5f2a48fc7e5b 68 if(rv < 0 || rv == length) {
wiggly 33:5f2a48fc7e5b 69 return rv;
wiggly 33:5f2a48fc7e5b 70 }
wiggly 33:5f2a48fc7e5b 71
wiggly 33:5f2a48fc7e5b 72 auto remain = length - rv;
wiggly 33:5f2a48fc7e5b 73
wiggly 33:5f2a48fc7e5b 74 while(rv > 0 && remain > 0) {
wiggly 33:5f2a48fc7e5b 75 data = data + rv;
wiggly 33:5f2a48fc7e5b 76 rv = tsc->socket->send((char*)data, length);
wiggly 33:5f2a48fc7e5b 77 remain = length - rv;
wiggly 33:5f2a48fc7e5b 78 }
wiggly 33:5f2a48fc7e5b 79
wiggly 33:5f2a48fc7e5b 80 return rv;
Azure.IoT Build 0:fa2de1b79154 81 }
Azure.IoT Build 0:fa2de1b79154 82
Azure.IoT Build 0:fa2de1b79154 83 int tcpsocketconnection_receive(TCPSOCKETCONNECTION_HANDLE tcpSocketConnectionHandle, char* data, int length)
Azure.IoT Build 0:fa2de1b79154 84 {
wiggly 33:5f2a48fc7e5b 85 TCPSOCKETCONNECTION_HANDLE_T* tsc = (TCPSOCKETCONNECTION_HANDLE_T*)tcpSocketConnectionHandle;
wiggly 33:5f2a48fc7e5b 86 return tsc->socket->recv(data, length);
Azure.IoT Build 0:fa2de1b79154 87 }
Azure.IoT Build 0:fa2de1b79154 88
Azure.IoT Build 0:fa2de1b79154 89 int tcpsocketconnection_receive_all(TCPSOCKETCONNECTION_HANDLE tcpSocketConnectionHandle, char* data, int length)
Azure.IoT Build 0:fa2de1b79154 90 {
wiggly 33:5f2a48fc7e5b 91 TCPSOCKETCONNECTION_HANDLE_T* tsc = (TCPSOCKETCONNECTION_HANDLE_T*)tcpSocketConnectionHandle;
wiggly 33:5f2a48fc7e5b 92 // TODO: this is shonky and quickly done....
wiggly 33:5f2a48fc7e5b 93
wiggly 33:5f2a48fc7e5b 94 auto rv = tsc->socket->recv((char*)data, length);
wiggly 33:5f2a48fc7e5b 95
wiggly 33:5f2a48fc7e5b 96 if(rv < 0 || rv == length) {
wiggly 33:5f2a48fc7e5b 97 return rv;
wiggly 33:5f2a48fc7e5b 98 }
wiggly 33:5f2a48fc7e5b 99
wiggly 33:5f2a48fc7e5b 100 auto remain = length - rv;
wiggly 33:5f2a48fc7e5b 101
wiggly 33:5f2a48fc7e5b 102 while(rv > 0 && remain > 0) {
wiggly 33:5f2a48fc7e5b 103 data = data + rv;
wiggly 33:5f2a48fc7e5b 104 rv = tsc->socket->recv((char*)data, length);
wiggly 33:5f2a48fc7e5b 105 remain = length - rv;
wiggly 33:5f2a48fc7e5b 106 }
wiggly 33:5f2a48fc7e5b 107
wiggly 33:5f2a48fc7e5b 108 return rv;
Azure.IoT Build 0:fa2de1b79154 109 }