Sarah Marsh / C027Interface(bu)

C027 Interface

Dependencies:   C027_Support

Fork of C027Interface by NetworkSocketAPI

C027Interface.cpp@17:9d5e8c64d82e, 2016-10-04 (annotated)

Committer:
sarahmarshy
Date:
Tue Oct 04 20:24:50 2016 +0000
Revision:
17:9d5e8c64d82e
Parent:
16:4015243c506d 
Support added.

Who changed what in which revision?

UserRevisionLine numberNew contents of line
geky 12:181a9415736b 1 /* C027 implementation of NetworkInterfaceAPI
geky 12:181a9415736b 2 * Copyright (c) 2015 ARM Limited
geky 12:181a9415736b 3 *
geky 12:181a9415736b 4 * Licensed under the Apache License, Version 2.0 (the "License");
geky 12:181a9415736b 5 * you may not use this file except in compliance with the License.
geky 12:181a9415736b 6 * You may obtain a copy of the License at
geky 12:181a9415736b 7 *
geky 12:181a9415736b 8 * http://www.apache.org/licenses/LICENSE-2.0
geky 12:181a9415736b 9 *
geky 12:181a9415736b 10 * Unless required by applicable law or agreed to in writing, software
geky 12:181a9415736b 11 * distributed under the License is distributed on an "AS IS" BASIS,
geky 12:181a9415736b 12 * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
geky 12:181a9415736b 13 * See the License for the specific language governing permissions and
geky 12:181a9415736b 14 * limitations under the License.
geky 12:181a9415736b 15 */
geky 12:181a9415736b 16
geky 12:181a9415736b 17 #include "C027Interface.h"
geky 12:181a9415736b 18 #include "mbed.h"
geky 12:181a9415736b 19
geky 12:181a9415736b 20
geky 12:181a9415736b 21 // C027Interface implementation
geky 12:181a9415736b 22 C027Interface::C027Interface(const char *simpin, bool debug)
geky 12:181a9415736b 23 : _debug(debug)
geky 12:181a9415736b 24 {
geky 12:181a9415736b 25 strcpy(_pin, simpin);
geky 12:181a9415736b 26 }
geky 12:181a9415736b 27
Christopher Haster 14:3d1845f5cd81 28 int C027Interface::connect(const char *apn, const char *username, const char *password)
geky 12:181a9415736b 29 {
geky 12:181a9415736b 30 // create the modem
geky 12:181a9415736b 31 _mdm = new MDMSerial;
geky 12:181a9415736b 32 if (_debug) {
geky 12:181a9415736b 33 _mdm->setDebug(4);
geky 12:181a9415736b 34 } else {
geky 12:181a9415736b 35 _mdm->setDebug(0);
geky 12:181a9415736b 36 }
geky 12:181a9415736b 37
geky 12:181a9415736b 38 // initialize the modem
geky 12:181a9415736b 39 MDMParser::DevStatus devStatus = {};
geky 12:181a9415736b 40 MDMParser::NetStatus netStatus = {};
geky 12:181a9415736b 41 bool mdmOk = _mdm->init(_pin, &devStatus);
geky 12:181a9415736b 42 if (_debug) {
geky 12:181a9415736b 43 _mdm->dumpDevStatus(&devStatus);
geky 12:181a9415736b 44 }
geky 12:181a9415736b 45
geky 12:181a9415736b 46 if (mdmOk) {
geky 12:181a9415736b 47 // wait until we are connected
geky 12:181a9415736b 48 mdmOk = _mdm->registerNet(&netStatus);
geky 12:181a9415736b 49 if (_debug) {
geky 12:181a9415736b 50 _mdm->dumpNetStatus(&netStatus);
geky 12:181a9415736b 51 }
geky 12:181a9415736b 52 }
geky 12:181a9415736b 53
Christopher Haster 14:3d1845f5cd81 54 if (mdmOk) {
geky 12:181a9415736b 55 // join the internet connection
geky 12:181a9415736b 56 MDMParser::IP ip = _mdm->join(apn, username, password);
geky 15:21d4f56eb172 57 _ip_address.set_ip_bytes(&ip, NSAPI_IPv4);
geky 12:181a9415736b 58 mdmOk = (ip != NOIP);
geky 12:181a9415736b 59 }
geky 12:181a9415736b 60
Christopher Haster 14:3d1845f5cd81 61 return mdmOk ? 0 : NSAPI_ERROR_DEVICE_ERROR;
geky 12:181a9415736b 62 }
geky 12:181a9415736b 63
Christopher Haster 14:3d1845f5cd81 64 int C027Interface::disconnect()
geky 12:181a9415736b 65 {
geky 12:181a9415736b 66 if (!_mdm->disconnect()) {
Christopher Haster 14:3d1845f5cd81 67 return NSAPI_ERROR_DEVICE_ERROR;
geky 12:181a9415736b 68 }
geky 12:181a9415736b 69
geky 12:181a9415736b 70 return 0;
geky 12:181a9415736b 71 }
geky 12:181a9415736b 72
Christopher Haster 14:3d1845f5cd81 73 const char *C027Interface::get_ip_address()
geky 12:181a9415736b 74 {
geky 15:21d4f56eb172 75 return _ip_address.get_ip_address();
geky 12:181a9415736b 76 }
geky 12:181a9415736b 77
Christopher Haster 14:3d1845f5cd81 78 const char *C027Interface::get_mac_address()
geky 12:181a9415736b 79 {
geky 12:181a9415736b 80 return 0;
geky 12:181a9415736b 81 }
geky 12:181a9415736b 82
Christopher Haster 14:3d1845f5cd81 83 struct c027_socket {
Christopher Haster 14:3d1845f5cd81 84 int socket;
Christopher Haster 14:3d1845f5cd81 85 MDMParser::IpProtocol proto;
Christopher Haster 14:3d1845f5cd81 86 MDMParser::IP ip;
Christopher Haster 14:3d1845f5cd81 87 int port;
Christopher Haster 14:3d1845f5cd81 88 };
Christopher Haster 14:3d1845f5cd81 89
Christopher Haster 14:3d1845f5cd81 90 int C027Interface::socket_open(void **handle, nsapi_protocol_t proto)
geky 12:181a9415736b 91 {
Christopher Haster 14:3d1845f5cd81 92 MDMParser::IpProtocol mdmproto = (proto == NSAPI_UDP) ? MDMParser::IPPROTO_UDP : MDMParser::IPPROTO_TCP;
Christopher Haster 14:3d1845f5cd81 93 int fd = _mdm->socketSocket(mdmproto);
Christopher Haster 14:3d1845f5cd81 94 if (fd < 0) {
Christopher Haster 14:3d1845f5cd81 95 return NSAPI_ERROR_NO_SOCKET;
geky 12:181a9415736b 96 }
geky 12:181a9415736b 97
Christopher Haster 14:3d1845f5cd81 98 _mdm->socketSetBlocking(fd, 10000);
Christopher Haster 14:3d1845f5cd81 99 struct c027_socket *socket = new struct c027_socket;
Christopher Haster 14:3d1845f5cd81 100 if (!socket) {
Christopher Haster 14:3d1845f5cd81 101 return NSAPI_ERROR_NO_SOCKET;
Christopher Haster 14:3d1845f5cd81 102 }
geky 12:181a9415736b 103
Christopher Haster 14:3d1845f5cd81 104 socket->socket = fd;
Christopher Haster 14:3d1845f5cd81 105 socket->proto = mdmproto;
Christopher Haster 14:3d1845f5cd81 106 *handle = socket;
Christopher Haster 14:3d1845f5cd81 107 return 0;
geky 12:181a9415736b 108 }
geky 12:181a9415736b 109
Christopher Haster 14:3d1845f5cd81 110 int C027Interface::socket_close(void *handle)
geky 12:181a9415736b 111 {
Christopher Haster 14:3d1845f5cd81 112 struct c027_socket *socket = (struct c027_socket *)handle;
Christopher Haster 14:3d1845f5cd81 113 _mdm->socketFree(socket->socket);
geky 12:181a9415736b 114
geky 12:181a9415736b 115 delete socket;
Christopher Haster 14:3d1845f5cd81 116 return 0;
geky 12:181a9415736b 117 }
geky 12:181a9415736b 118
Christopher Haster 14:3d1845f5cd81 119 int C027Interface::socket_bind(void *handle, const SocketAddress &address)
Christopher Haster 14:3d1845f5cd81 120 {
Christopher Haster 14:3d1845f5cd81 121 return NSAPI_ERROR_UNSUPPORTED;
Christopher Haster 14:3d1845f5cd81 122 }
geky 12:181a9415736b 123
Christopher Haster 14:3d1845f5cd81 124 int C027Interface::socket_listen(void *handle, int backlog)
geky 12:181a9415736b 125 {
Christopher Haster 14:3d1845f5cd81 126 return NSAPI_ERROR_UNSUPPORTED;
Christopher Haster 14:3d1845f5cd81 127 }
Christopher Haster 14:3d1845f5cd81 128
Christopher Haster 14:3d1845f5cd81 129 int C027Interface::socket_connect(void *handle, const SocketAddress &addr)
Christopher Haster 14:3d1845f5cd81 130 {
Christopher Haster 14:3d1845f5cd81 131 struct c027_socket *socket = (struct c027_socket *)handle;
geky 12:181a9415736b 132
Christopher Haster 14:3d1845f5cd81 133 if (!_mdm->socketConnect(socket->socket, addr.get_ip_address(), addr.get_port())) {
Christopher Haster 14:3d1845f5cd81 134 return NSAPI_ERROR_DEVICE_ERROR;
geky 12:181a9415736b 135 }
geky 12:181a9415736b 136
geky 12:181a9415736b 137 return 0;
geky 12:181a9415736b 138 }
geky 12:181a9415736b 139
Christopher Haster 14:3d1845f5cd81 140 int C027Interface::socket_accept(void **handle, void *server)
geky 12:181a9415736b 141 {
Christopher Haster 14:3d1845f5cd81 142 return NSAPI_ERROR_UNSUPPORTED;
geky 12:181a9415736b 143 }
geky 12:181a9415736b 144
Christopher Haster 14:3d1845f5cd81 145 int C027Interface::socket_send(void *handle, const void *data, unsigned size)
geky 12:181a9415736b 146 {
Christopher Haster 14:3d1845f5cd81 147 struct c027_socket *socket = (struct c027_socket *)handle;
Christopher Haster 14:3d1845f5cd81 148
Christopher Haster 14:3d1845f5cd81 149 int sent = _mdm->socketSend(socket->socket, (const char *)data, size);
Christopher Haster 14:3d1845f5cd81 150 if (sent == SOCKET_ERROR) {
Christopher Haster 14:3d1845f5cd81 151 return NSAPI_ERROR_DEVICE_ERROR;
geky 12:181a9415736b 152 }
geky 12:181a9415736b 153
Christopher Haster 14:3d1845f5cd81 154 return sent;
geky 12:181a9415736b 155 }
geky 12:181a9415736b 156
Christopher Haster 14:3d1845f5cd81 157 int C027Interface::socket_recv(void *handle, void *data, unsigned size)
geky 12:181a9415736b 158 {
Christopher Haster 14:3d1845f5cd81 159 struct c027_socket *socket = (struct c027_socket *)handle;
Christopher Haster 14:3d1845f5cd81 160 if (!_mdm->socketReadable(socket->socket)) {
Christopher Haster 14:3d1845f5cd81 161 return NSAPI_ERROR_WOULD_BLOCK;
geky 12:181a9415736b 162 }
geky 12:181a9415736b 163
Christopher Haster 14:3d1845f5cd81 164 int recv = _mdm->socketRecv(socket->socket, (char *)data, size);
geky 12:181a9415736b 165 if (recv == SOCKET_ERROR) {
Christopher Haster 14:3d1845f5cd81 166 return NSAPI_ERROR_DEVICE_ERROR;
geky 12:181a9415736b 167 }
geky 12:181a9415736b 168
geky 12:181a9415736b 169 return recv;
geky 12:181a9415736b 170 }
geky 12:181a9415736b 171
Christopher Haster 14:3d1845f5cd81 172 int C027Interface::socket_sendto(void *handle, const SocketAddress &addr, const void *data, unsigned size)
Christopher Haster 14:3d1845f5cd81 173 {
Christopher Haster 14:3d1845f5cd81 174 struct c027_socket *socket = (struct c027_socket *)handle;
geky 12:181a9415736b 175
geky 15:21d4f56eb172 176 int sent = _mdm->socketSendTo(socket->socket,
geky 15:21d4f56eb172 177 *(MDMParser::IP *)addr.get_ip_bytes(), addr.get_port(),
geky 15:21d4f56eb172 178 (const char *)data, size);
geky 15:21d4f56eb172 179
Christopher Haster 14:3d1845f5cd81 180 if (sent == SOCKET_ERROR) {
Christopher Haster 14:3d1845f5cd81 181 return NSAPI_ERROR_DEVICE_ERROR;
Christopher Haster 14:3d1845f5cd81 182 }
Christopher Haster 14:3d1845f5cd81 183
Christopher Haster 14:3d1845f5cd81 184 return sent;
Christopher Haster 14:3d1845f5cd81 185 }
Christopher Haster 14:3d1845f5cd81 186
Christopher Haster 14:3d1845f5cd81 187 int C027Interface::socket_recvfrom(void *handle, SocketAddress *addr, void *data, unsigned size)
Christopher Haster 14:3d1845f5cd81 188 {
Christopher Haster 14:3d1845f5cd81 189 struct c027_socket *socket = (struct c027_socket *)handle;
Christopher Haster 14:3d1845f5cd81 190 if (!_mdm->socketReadable(socket->socket)) {
Christopher Haster 14:3d1845f5cd81 191 return NSAPI_ERROR_WOULD_BLOCK;
Christopher Haster 14:3d1845f5cd81 192 }
Christopher Haster 14:3d1845f5cd81 193
Christopher Haster 14:3d1845f5cd81 194 MDMParser::IP ip;
Christopher Haster 14:3d1845f5cd81 195 int port;
Christopher Haster 14:3d1845f5cd81 196
Christopher Haster 14:3d1845f5cd81 197 int recv = _mdm->socketRecvFrom(socket->socket, &ip, &port, (char *)data, size);
Christopher Haster 14:3d1845f5cd81 198 if (recv == SOCKET_ERROR) {
Christopher Haster 14:3d1845f5cd81 199 return NSAPI_ERROR_DEVICE_ERROR;
Christopher Haster 14:3d1845f5cd81 200 }
Christopher Haster 14:3d1845f5cd81 201
Christopher Haster 14:3d1845f5cd81 202 if (addr) {
geky 15:21d4f56eb172 203 addr->set_ip_bytes(&ip, NSAPI_IPv4);
Christopher Haster 14:3d1845f5cd81 204 addr->set_port(port);
Christopher Haster 14:3d1845f5cd81 205 }
Christopher Haster 14:3d1845f5cd81 206
Christopher Haster 14:3d1845f5cd81 207 return recv;
Christopher Haster 14:3d1845f5cd81 208 }
Christopher Haster 14:3d1845f5cd81 209
sarahmarshy 16:4015243c506d 210 void C027Interface::_run()
sarahmarshy 16:4015243c506d 211 {
sarahmarshy 16:4015243c506d 212 while (true) {
sarahmarshy 16:4015243c506d 213 _callback(_data);
sarahmarshy 16:4015243c506d 214 wait(0.25f);
sarahmarshy 16:4015243c506d 215 }
sarahmarshy 16:4015243c506d 216 }
sarahmarshy 16:4015243c506d 217
Christopher Haster 14:3d1845f5cd81 218 void C027Interface::socket_attach(void *handle, void (*callback)(void *), void *data)
Christopher Haster 14:3d1845f5cd81 219 {
sarahmarshy 16:4015243c506d 220 _callback = callback;
sarahmarshy 16:4015243c506d 221 _data = data;
sarahmarshy 16:4015243c506d 222 _thread.start(this, &C027Interface::_run);
Christopher Haster 14:3d1845f5cd81 223 }