KDDI Fx0 hackathon / NySNICInterface

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 NySNICInterface by Ryo Iizuka

Socket/TCPSocketConnection.cpp@24:987e412ae879, 2014-03-28 (annotated)

Committer:
kishino
Date:
Fri Mar 28 00:45:15 2014 +0000
Revision:
24:987e412ae879
Parent:
22:a9ec0cad4f84
Child:
26:f2e1030964e4
Changed to that any classes do not have instance of C_SNIC_Core class.

Who changed what in which revision?

UserRevisionLine numberNew contents of line
kishino 20:dd736d328de6 1 /* Copyright (C) 2012 mbed.org, MIT License
kishino 20:dd736d328de6 2 *
kishino 20:dd736d328de6 3 * Permission is hereby granted, free of charge, to any person obtaining a copy of this software
kishino 20:dd736d328de6 4 * and associated documentation files (the "Software"), to deal in the Software without restriction,
kishino 20:dd736d328de6 5 * including without limitation the rights to use, copy, modify, merge, publish, distribute,
kishino 20:dd736d328de6 6 * sublicense, and/or sell copies of the Software, and to permit persons to whom the Software is
kishino 20:dd736d328de6 7 * furnished to do so, subject to the following conditions:
kishino 20:dd736d328de6 8 *
kishino 20:dd736d328de6 9 * The above copyright notice and this permission notice shall be included in all copies or
kishino 20:dd736d328de6 10 * substantial portions of the Software.
kishino 20:dd736d328de6 11 *
kishino 20:dd736d328de6 12 * THE SOFTWARE IS PROVIDED "AS IS", WITHOUT WARRANTY OF ANY KIND, EXPRESS OR IMPLIED, INCLUDING
kishino 20:dd736d328de6 13 * BUT NOT LIMITED TO THE WARRANTIES OF MERCHANTABILITY, FITNESS FOR A PARTICULAR PURPOSE AND
kishino 20:dd736d328de6 14 * NONINFRINGEMENT. IN NO EVENT SHALL THE AUTHORS OR COPYRIGHT HOLDERS BE LIABLE FOR ANY CLAIM,
kishino 20:dd736d328de6 15 * DAMAGES OR OTHER LIABILITY, WHETHER IN AN ACTION OF CONTRACT, TORT OR OTHERWISE, ARISING FROM,
kishino 20:dd736d328de6 16 * OUT OF OR IN CONNECTION WITH THE SOFTWARE OR THE USE OR OTHER DEALINGS IN THE SOFTWARE.
kishino 20:dd736d328de6 17 */
kishino 20:dd736d328de6 18 /******************* Murata Manufacturing Co.,Ltd. 2014 *****************
kishino 20:dd736d328de6 19 *
kishino 20:dd736d328de6 20 * Filename: TCPSocketConnection.cpp
kishino 20:dd736d328de6 21 *
kishino 20:dd736d328de6 22 * Purpose: This module has implementation of TCP connection.
kishino 20:dd736d328de6 23 *
kishino 20:dd736d328de6 24 * $Author: kishino $
kishino 20:dd736d328de6 25 *
kishino 20:dd736d328de6 26 * $Date: 2014/03/26 $
kishino 20:dd736d328de6 27 *
kishino 20:dd736d328de6 28 * $Revision: 0.0.0.1 $
kishino 20:dd736d328de6 29 * ***********************************************************************/
kishino 20:dd736d328de6 30 #include "TCPSocketConnection.h"
kishino 20:dd736d328de6 31 #include <cstring>
kishino 20:dd736d328de6 32
kishino 20:dd736d328de6 33 using namespace murata_wifi;
kishino 20:dd736d328de6 34
kishino 20:dd736d328de6 35 TCPSocketConnection::TCPSocketConnection()
kishino 20:dd736d328de6 36 {
kishino 20:dd736d328de6 37 }
kishino 20:dd736d328de6 38
kishino 20:dd736d328de6 39 int TCPSocketConnection::connect( unsigned int ip_addr, unsigned short port)
kishino 20:dd736d328de6 40 {
kishino 20:dd736d328de6 41 int ret;
kishino 24:987e412ae879 42 C_SNIC_Core *snic_core_p = C_SNIC_Core::getInstance();
kishino 24:987e412ae879 43 C_SNIC_UartCommandManager *uartCmdMgr_p = snic_core_p->getUartCommand();
kishino 20:dd736d328de6 44
kishino 20:dd736d328de6 45 // Socket create
kishino 20:dd736d328de6 46 ret = createSocket();
kishino 20:dd736d328de6 47 if( ret != 0 )
kishino 20:dd736d328de6 48 {
kishino 20:dd736d328de6 49 printf("createSocket error : %d\r\n", ret);
kishino 20:dd736d328de6 50 return -1;
kishino 20:dd736d328de6 51 }
kishino 20:dd736d328de6 52
kishino 20:dd736d328de6 53 // Get buffer for response payload from MemoryPool
kishino 24:987e412ae879 54 C_SNIC_Core::tagMEMPOOL_BLOCK_T *payload_buf = snic_core_p->allocCmdBuf();
kishino 20:dd736d328de6 55 if( payload_buf == NULL )
kishino 20:dd736d328de6 56 {
kishino 20:dd736d328de6 57 printf("connect payload_buf NULL\r\n");
kishino 20:dd736d328de6 58 return -1;
kishino 20:dd736d328de6 59 }
kishino 20:dd736d328de6 60
kishino 22:a9ec0cad4f84 61 C_SNIC_Core::tagSNIC_TCP_CONNECT_TO_SERVER_REQ_T req;
kishino 20:dd736d328de6 62 // Make request
kishino 20:dd736d328de6 63 req.cmd_sid = UART_CMD_SID_SNIC_TCP_CONNECT_TO_SERVER_REQ;
kishino 20:dd736d328de6 64 req.seq = mUartRequestSeq++;
kishino 20:dd736d328de6 65 req.socket_id = mSocketID;
kishino 20:dd736d328de6 66
kishino 20:dd736d328de6 67 // set ip addr ( byte order )
kishino 20:dd736d328de6 68 req.remote_addr[0] = ( (ip_addr & 0xFF000000) >> 24 );
kishino 20:dd736d328de6 69 req.remote_addr[1] = ( (ip_addr & 0xFF0000) >> 16 );
kishino 20:dd736d328de6 70 req.remote_addr[2] = ( (ip_addr & 0xFF00) >> 8 );
kishino 20:dd736d328de6 71 req.remote_addr[3] = (ip_addr & 0xFF);
kishino 20:dd736d328de6 72 req.remote_port[0] = ( (port & 0xFF00) >> 8 );
kishino 20:dd736d328de6 73 req.remote_port[1] = (port & 0xFF);
kishino 20:dd736d328de6 74 req.recv_bufsize[0] = ( (SNIC_UART_RECVBUF_SIZE & 0xFF00) >> 8 );
kishino 20:dd736d328de6 75 req.recv_bufsize[1] = (SNIC_UART_RECVBUF_SIZE & 0xFF);
kishino 20:dd736d328de6 76 req.timeout = 60;
kishino 20:dd736d328de6 77
kishino 20:dd736d328de6 78 unsigned char command_array[UART_REQUEST_PAYLOAD_MAX];
kishino 20:dd736d328de6 79 unsigned int command_len;
kishino 20:dd736d328de6 80 // Preparation of command
kishino 24:987e412ae879 81 command_len = snic_core_p->preparationSendCommand( UART_CMD_ID_SNIC, req.cmd_sid, (unsigned char *)&req
kishino 22:a9ec0cad4f84 82 , sizeof(C_SNIC_Core::tagSNIC_TCP_CONNECT_TO_SERVER_REQ_T), payload_buf->buf, command_array );
kishino 20:dd736d328de6 83
kishino 20:dd736d328de6 84 // Send uart command request
kishino 24:987e412ae879 85 snic_core_p->sendUart( command_len, command_array );
kishino 20:dd736d328de6 86
kishino 20:dd736d328de6 87 uartCmdMgr_p->setCommandSID( UART_CMD_SID_SNIC_TCP_CONNECTION_STATUS_IND );
kishino 20:dd736d328de6 88
kishino 20:dd736d328de6 89 // Wait UART response
kishino 20:dd736d328de6 90 ret = uartCmdMgr_p->wait();
kishino 20:dd736d328de6 91 if( ret != 0 )
kishino 20:dd736d328de6 92 {
kishino 20:dd736d328de6 93 printf( "connect failed\r\n" );
kishino 24:987e412ae879 94 snic_core_p->freeCmdBuf( payload_buf );
kishino 20:dd736d328de6 95 return -1;
kishino 20:dd736d328de6 96 }
kishino 20:dd736d328de6 97
kishino 20:dd736d328de6 98 if( uartCmdMgr_p->getCommandStatus() != UART_CMD_RES_SNIC_CONNECTION_UP )
kishino 20:dd736d328de6 99 {
kishino 20:dd736d328de6 100 printf("connect status:%02x\r\n", uartCmdMgr_p->getCommandStatus());
kishino 24:987e412ae879 101 snic_core_p->freeCmdBuf( payload_buf );
kishino 20:dd736d328de6 102 return -1;
kishino 20:dd736d328de6 103 }
kishino 24:987e412ae879 104 snic_core_p->freeCmdBuf( payload_buf );
kishino 20:dd736d328de6 105
kishino 20:dd736d328de6 106 // Initialize connection information
kishino 24:987e412ae879 107 C_SNIC_Core::tagCONNECT_INFO_T *con_info_p = snic_core_p->getConnectInfo( mSocketID );
kishino 20:dd736d328de6 108 if( con_info_p->recvbuf_p == NULL )
kishino 20:dd736d328de6 109 {
kishino 20:dd736d328de6 110 printf( "create recv buffer[socket:%d]\r\n", mSocketID);
kishino 20:dd736d328de6 111 con_info_p->recvbuf_p = new CircBuffer<unsigned char>(SNIC_UART_RECVBUF_SIZE);
kishino 20:dd736d328de6 112 }
kishino 20:dd736d328de6 113 con_info_p->is_connected = true;
kishino 20:dd736d328de6 114 con_info_p->is_received = false;
kishino 20:dd736d328de6 115
kishino 20:dd736d328de6 116 return 0;
kishino 20:dd736d328de6 117 }
kishino 20:dd736d328de6 118
kishino 20:dd736d328de6 119 bool TCPSocketConnection::is_connected(void)
kishino 20:dd736d328de6 120 {
kishino 24:987e412ae879 121 C_SNIC_Core *snic_core_p = C_SNIC_Core::getInstance();
kishino 24:987e412ae879 122 C_SNIC_Core::tagCONNECT_INFO_T *con_info_p = snic_core_p->getConnectInfo( mSocketID );
kishino 20:dd736d328de6 123 return con_info_p->is_connected;
kishino 20:dd736d328de6 124 }
kishino 20:dd736d328de6 125
kishino 20:dd736d328de6 126 unsigned char gTCP_SEND_BUF[2048];
kishino 20:dd736d328de6 127 int TCPSocketConnection::send(unsigned char* data_p, int length)
kishino 20:dd736d328de6 128 {
kishino 24:987e412ae879 129 C_SNIC_Core *snic_core_p = C_SNIC_Core::getInstance();
kishino 24:987e412ae879 130 C_SNIC_UartCommandManager *uartCmdMgr_p = snic_core_p->getUartCommand();
kishino 20:dd736d328de6 131
kishino 20:dd736d328de6 132 // Get buffer for response payload from MemoryPool
kishino 24:987e412ae879 133 C_SNIC_Core::tagMEMPOOL_BLOCK_T *payload_buf = snic_core_p->allocCmdBuf();
kishino 20:dd736d328de6 134 if( payload_buf == NULL )
kishino 20:dd736d328de6 135 {
kishino 20:dd736d328de6 136 printf("connect payload_buf NULL\r\n");
kishino 20:dd736d328de6 137 return -1;
kishino 20:dd736d328de6 138 }
kishino 20:dd736d328de6 139
kishino 22:a9ec0cad4f84 140 C_SNIC_Core::tagSNIC_TCP_SEND_FROM_SOCKET_REQ_T req;
kishino 20:dd736d328de6 141 // Make request
kishino 20:dd736d328de6 142 req.cmd_sid = UART_CMD_SID_SNIC_SEND_FROM_SOCKET_REQ;
kishino 20:dd736d328de6 143 req.seq = mUartRequestSeq++;
kishino 20:dd736d328de6 144 req.socket_id = mSocketID;
kishino 20:dd736d328de6 145 req.option = 0;
kishino 20:dd736d328de6 146 req.payload_len[0]= ( (length & 0xFF00) >> 8 );
kishino 20:dd736d328de6 147 req.payload_len[1]= (length & 0xFF);
kishino 20:dd736d328de6 148
kishino 22:a9ec0cad4f84 149 int req_size = sizeof(C_SNIC_Core::tagSNIC_TCP_SEND_FROM_SOCKET_REQ_T);
kishino 20:dd736d328de6 150 memcpy( gTCP_SEND_BUF, &req, req_size );
kishino 20:dd736d328de6 151 memcpy( &gTCP_SEND_BUF[req_size], data_p, length );
kishino 20:dd736d328de6 152
kishino 20:dd736d328de6 153 unsigned char command_array[UART_REQUEST_PAYLOAD_MAX];
kishino 20:dd736d328de6 154 unsigned int command_len;
kishino 20:dd736d328de6 155 // Preparation of command
kishino 24:987e412ae879 156 command_len = snic_core_p->preparationSendCommand( UART_CMD_ID_SNIC, req.cmd_sid, gTCP_SEND_BUF
kishino 20:dd736d328de6 157 , req_size + length, payload_buf->buf, command_array );
kishino 20:dd736d328de6 158
kishino 20:dd736d328de6 159 // Send uart command request
kishino 24:987e412ae879 160 snic_core_p->sendUart( command_len, command_array );
kishino 20:dd736d328de6 161
kishino 20:dd736d328de6 162 // Wait UART response
kishino 20:dd736d328de6 163 int ret = uartCmdMgr_p->wait();
kishino 20:dd736d328de6 164 if( ret != 0 )
kishino 20:dd736d328de6 165 {
kishino 20:dd736d328de6 166 printf( "send failed\r\n" );
kishino 24:987e412ae879 167 snic_core_p->freeCmdBuf( payload_buf );
kishino 20:dd736d328de6 168 return -1;
kishino 20:dd736d328de6 169 }
kishino 20:dd736d328de6 170
kishino 20:dd736d328de6 171 if( uartCmdMgr_p->getCommandStatus() != UART_CMD_RES_SNIC_SUCCESS )
kishino 20:dd736d328de6 172 {
kishino 20:dd736d328de6 173 printf("send status:%02x\r\n", uartCmdMgr_p->getCommandStatus());
kishino 24:987e412ae879 174 snic_core_p->freeCmdBuf( payload_buf );
kishino 20:dd736d328de6 175 return -1;
kishino 20:dd736d328de6 176 }
kishino 24:987e412ae879 177 snic_core_p->freeCmdBuf( payload_buf );
kishino 20:dd736d328de6 178
kishino 20:dd736d328de6 179 // SNIC_SEND_FROM_SOCKET_REQ
kishino 20:dd736d328de6 180 return 0;
kishino 20:dd736d328de6 181 }
kishino 20:dd736d328de6 182
kishino 20:dd736d328de6 183 int TCPSocketConnection::receive(unsigned char* data_p, int length)
kishino 20:dd736d328de6 184 {
kishino 20:dd736d328de6 185 int i = 0;
kishino 20:dd736d328de6 186
kishino 20:dd736d328de6 187 if( (data_p == NULL) || (length < 1) )
kishino 20:dd736d328de6 188 {
kishino 20:dd736d328de6 189 printf("TCPSocketConnection::receive parameter error\r\n");
kishino 20:dd736d328de6 190 return -1;
kishino 20:dd736d328de6 191 }
kishino 20:dd736d328de6 192
kishino 24:987e412ae879 193 C_SNIC_Core *snic_core_p = C_SNIC_Core::getInstance();
kishino 20:dd736d328de6 194 // Initialize connection information
kishino 24:987e412ae879 195 C_SNIC_Core::tagCONNECT_INFO_T *con_info_p = snic_core_p->getConnectInfo( mSocketID );
kishino 20:dd736d328de6 196 if( con_info_p->recvbuf_p == NULL )
kishino 20:dd736d328de6 197 {
kishino 20:dd736d328de6 198 printf("TCPSocketConnection::receive Conncection info error\r\n");
kishino 20:dd736d328de6 199 return -1;
kishino 20:dd736d328de6 200 }
kishino 20:dd736d328de6 201
kishino 20:dd736d328de6 202 // Check connection
kishino 20:dd736d328de6 203 if( con_info_p->is_connected == false )
kishino 20:dd736d328de6 204 {
kishino 20:dd736d328de6 205 printf(" Socket id \"%d\" is not connected\r\n", mSocketID);
kishino 20:dd736d328de6 206 return -1;
kishino 20:dd736d328de6 207 }
kishino 20:dd736d328de6 208
kishino 20:dd736d328de6 209 if( con_info_p->is_received == false )
kishino 20:dd736d328de6 210 {
kishino 20:dd736d328de6 211 // printf(" Socket id \"%d\" is not received\r\n", mSocketID);
kishino 20:dd736d328de6 212 return 0;
kishino 20:dd736d328de6 213 }
kishino 20:dd736d328de6 214
kishino 20:dd736d328de6 215 // Get packet data from buffer for receive.
kishino 20:dd736d328de6 216 for (i = 0; i < length; i ++)
kishino 20:dd736d328de6 217 {
kishino 20:dd736d328de6 218 if (con_info_p->recvbuf_p->dequeue(&data_p[i]) == false)
kishino 20:dd736d328de6 219 {
kishino 20:dd736d328de6 220 break;
kishino 20:dd736d328de6 221 }
kishino 20:dd736d328de6 222 }
kishino 20:dd736d328de6 223
kishino 20:dd736d328de6 224 if( con_info_p->recvbuf_p->isEmpty() )
kishino 20:dd736d328de6 225 {
kishino 20:dd736d328de6 226 con_info_p->is_received = false;
kishino 20:dd736d328de6 227 }
kishino 20:dd736d328de6 228
kishino 20:dd736d328de6 229 return i;
kishino 20:dd736d328de6 230 }