KDDI Fx0 hackathon / Mbed 2 deprecated MurataTypeYD_Websocket_Sample_full

Websocket_Sample for MurataTypeYD

Dependencies:   mbed picojson

SNICInterface_mod/SNIC/SNIC_UartCommandManager.cpp@1:b5ac0f971f43, 2015-03-12 (annotated)

Committer:
komoritan
Date:
Thu Mar 12 12:15:46 2015 +0000
Revision:
1:b5ac0f971f43
Parent:
0:14bd24b5a77f 
Fixed

Who changed what in which revision?

UserRevisionLine numberNew contents of line
komoritan 0:14bd24b5a77f 1 /* Copyright (C) 2014 Murata Manufacturing Co.,Ltd., MIT License
komoritan 0:14bd24b5a77f 2 * muRata, SWITCH SCIENCE Wi-FI module TypeYD SNIC-UART.
komoritan 0:14bd24b5a77f 3 *
komoritan 0:14bd24b5a77f 4 * Permission is hereby granted, free of charge, to any person obtaining a copy of this software
komoritan 0:14bd24b5a77f 5 * and associated documentation files (the "Software"), to deal in the Software without restriction,
komoritan 0:14bd24b5a77f 6 * including without limitation the rights to use, copy, modify, merge, publish, distribute,
komoritan 0:14bd24b5a77f 7 * sublicense, and/or sell copies of the Software, and to permit persons to whom the Software is
komoritan 0:14bd24b5a77f 8 * furnished to do so, subject to the following conditions:
komoritan 0:14bd24b5a77f 9 *
komoritan 0:14bd24b5a77f 10 * The above copyright notice and this permission notice shall be included in all copies or
komoritan 0:14bd24b5a77f 11 * substantial portions of the Software.
komoritan 0:14bd24b5a77f 12 *
komoritan 0:14bd24b5a77f 13 * THE SOFTWARE IS PROVIDED "AS IS", WITHOUT WARRANTY OF ANY KIND, EXPRESS OR IMPLIED, INCLUDING
komoritan 0:14bd24b5a77f 14 * BUT NOT LIMITED TO THE WARRANTIES OF MERCHANTABILITY, FITNESS FOR A PARTICULAR PURPOSE AND
komoritan 0:14bd24b5a77f 15 * NONINFRINGEMENT. IN NO EVENT SHALL THE AUTHORS OR COPYRIGHT HOLDERS BE LIABLE FOR ANY CLAIM,
komoritan 0:14bd24b5a77f 16 * DAMAGES OR OTHER LIABILITY, WHETHER IN AN ACTION OF CONTRACT, TORT OR OTHERWISE, ARISING FROM,
komoritan 0:14bd24b5a77f 17 * OUT OF OR IN CONNECTION WITH THE SOFTWARE OR THE USE OR OTHER DEALINGS IN THE SOFTWARE.
komoritan 0:14bd24b5a77f 18 */
komoritan 0:14bd24b5a77f 19 #include "SNIC_UartCommandManager.h"
komoritan 0:14bd24b5a77f 20 #include "SNIC_Core.h"
komoritan 0:14bd24b5a77f 21
komoritan 0:14bd24b5a77f 22 C_SNIC_UartCommandManager::~C_SNIC_UartCommandManager()
komoritan 0:14bd24b5a77f 23 {
komoritan 0:14bd24b5a77f 24 }
komoritan 0:14bd24b5a77f 25
komoritan 0:14bd24b5a77f 26 void C_SNIC_UartCommandManager::setCommandID( unsigned char cmd_id )
komoritan 0:14bd24b5a77f 27 {
komoritan 0:14bd24b5a77f 28 mCommandID = cmd_id;
komoritan 0:14bd24b5a77f 29 }
komoritan 0:14bd24b5a77f 30
komoritan 0:14bd24b5a77f 31 unsigned char C_SNIC_UartCommandManager::getCommandID()
komoritan 0:14bd24b5a77f 32 {
komoritan 0:14bd24b5a77f 33 return mCommandID;
komoritan 0:14bd24b5a77f 34 }
komoritan 0:14bd24b5a77f 35
komoritan 0:14bd24b5a77f 36 void C_SNIC_UartCommandManager::setCommandSID( unsigned char cmd_sid )
komoritan 0:14bd24b5a77f 37 {
komoritan 0:14bd24b5a77f 38 mCommandSID = cmd_sid;
komoritan 0:14bd24b5a77f 39 }
komoritan 0:14bd24b5a77f 40
komoritan 0:14bd24b5a77f 41 unsigned char C_SNIC_UartCommandManager::getCommandSID()
komoritan 0:14bd24b5a77f 42 {
komoritan 0:14bd24b5a77f 43 return mCommandSID;
komoritan 0:14bd24b5a77f 44 }
komoritan 0:14bd24b5a77f 45
komoritan 0:14bd24b5a77f 46 void C_SNIC_UartCommandManager::setCommandStatus( unsigned char status )
komoritan 0:14bd24b5a77f 47 {
komoritan 0:14bd24b5a77f 48 mCommandStatus = status;
komoritan 0:14bd24b5a77f 49 }
komoritan 0:14bd24b5a77f 50
komoritan 0:14bd24b5a77f 51 unsigned char C_SNIC_UartCommandManager::getCommandStatus()
komoritan 0:14bd24b5a77f 52 {
komoritan 0:14bd24b5a77f 53 return mCommandStatus;
komoritan 0:14bd24b5a77f 54 }
komoritan 0:14bd24b5a77f 55
komoritan 0:14bd24b5a77f 56 void C_SNIC_UartCommandManager::setResponseBuf( unsigned char *buf_p )
komoritan 0:14bd24b5a77f 57 {
komoritan 0:14bd24b5a77f 58 mResponseBuf_p = buf_p;
komoritan 0:14bd24b5a77f 59 }
komoritan 0:14bd24b5a77f 60
komoritan 0:14bd24b5a77f 61 unsigned char *C_SNIC_UartCommandManager::getResponseBuf()
komoritan 0:14bd24b5a77f 62 {
komoritan 0:14bd24b5a77f 63 return mResponseBuf_p;
komoritan 0:14bd24b5a77f 64 }
komoritan 0:14bd24b5a77f 65
komoritan 0:14bd24b5a77f 66 void C_SNIC_UartCommandManager::setScanResultHandler( void (*handler_p)(tagSCAN_RESULT_T *scan_result) )
komoritan 0:14bd24b5a77f 67 {
komoritan 0:14bd24b5a77f 68 mScanResultHandler_p = handler_p;
komoritan 0:14bd24b5a77f 69 }
komoritan 0:14bd24b5a77f 70
komoritan 0:14bd24b5a77f 71
komoritan 0:14bd24b5a77f 72 int C_SNIC_UartCommandManager::wait()
komoritan 0:14bd24b5a77f 73 {
komoritan 0:14bd24b5a77f 74 int ret = 0;
komoritan 0:14bd24b5a77f 75
komoritan 0:14bd24b5a77f 76 // Get thread ID
komoritan 0:14bd24b5a77f 77 mCommandThreadID = osThreadGetId();
komoritan 0:14bd24b5a77f 78
komoritan 0:14bd24b5a77f 79 // Signal flags that are reported as event are automatically cleared.
komoritan 0:14bd24b5a77f 80 osEvent event_ret = osSignalWait( UART_COMMAND_SIGNAL, UART_COMMAND_WAIT_TIMEOUT);
komoritan 0:14bd24b5a77f 81 if( event_ret.status != osEventSignal )
komoritan 0:14bd24b5a77f 82 {
komoritan 0:14bd24b5a77f 83 ret = -1;
komoritan 0:14bd24b5a77f 84 }
komoritan 0:14bd24b5a77f 85
komoritan 0:14bd24b5a77f 86 return ret;
komoritan 0:14bd24b5a77f 87 }
komoritan 0:14bd24b5a77f 88
komoritan 0:14bd24b5a77f 89 int C_SNIC_UartCommandManager::signal()
komoritan 0:14bd24b5a77f 90 {
komoritan 0:14bd24b5a77f 91 // set signal
komoritan 0:14bd24b5a77f 92 return osSignalSet(mCommandThreadID, UART_COMMAND_SIGNAL);
komoritan 0:14bd24b5a77f 93 }
komoritan 0:14bd24b5a77f 94
komoritan 0:14bd24b5a77f 95 bool C_SNIC_UartCommandManager::isWaitingCommand( unsigned int command_id, unsigned char *payload_p )
komoritan 0:14bd24b5a77f 96 {
komoritan 0:14bd24b5a77f 97 bool ret = false;
komoritan 0:14bd24b5a77f 98
komoritan 0:14bd24b5a77f 99 if( (command_id == getCommandID())
komoritan 0:14bd24b5a77f 100 && (payload_p[0] == getCommandSID()) )
komoritan 0:14bd24b5a77f 101 {
komoritan 0:14bd24b5a77f 102 ret = true;
komoritan 0:14bd24b5a77f 103 }
komoritan 0:14bd24b5a77f 104 return ret;
komoritan 0:14bd24b5a77f 105 }
komoritan 0:14bd24b5a77f 106
komoritan 0:14bd24b5a77f 107 void C_SNIC_UartCommandManager::scanResultIndicate( unsigned char *payload_p, int payload_len )
komoritan 0:14bd24b5a77f 108 {
komoritan 0:14bd24b5a77f 109 if( (payload_p == NULL) || (mScanResultHandler_p == NULL) )
komoritan 0:14bd24b5a77f 110 {
komoritan 0:14bd24b5a77f 111 return;
komoritan 0:14bd24b5a77f 112 }
komoritan 0:14bd24b5a77f 113
komoritan 0:14bd24b5a77f 114 tagSCAN_RESULT_T scan_result;
komoritan 0:14bd24b5a77f 115 int ap_count = payload_p[2];
komoritan 0:14bd24b5a77f 116
komoritan 0:14bd24b5a77f 117 if( ap_count == 0 )
komoritan 0:14bd24b5a77f 118 {
komoritan 0:14bd24b5a77f 119 mScanResultHandler_p( NULL );
komoritan 0:14bd24b5a77f 120 }
komoritan 0:14bd24b5a77f 121
komoritan 0:14bd24b5a77f 122 unsigned char *ap_info_p = &payload_p[3];
komoritan 0:14bd24b5a77f 123 int ap_info_idx = 0;
komoritan 0:14bd24b5a77f 124
komoritan 0:14bd24b5a77f 125 for( int i = 0; i < ap_count; i++ )
komoritan 0:14bd24b5a77f 126 {
komoritan 0:14bd24b5a77f 127 scan_result.channel = ap_info_p[ap_info_idx];
komoritan 0:14bd24b5a77f 128 ap_info_idx++;
komoritan 0:14bd24b5a77f 129 scan_result.rssi = (signed)ap_info_p[ap_info_idx];
komoritan 0:14bd24b5a77f 130 ap_info_idx++;
komoritan 0:14bd24b5a77f 131 scan_result.security= ap_info_p[ap_info_idx];
komoritan 0:14bd24b5a77f 132 ap_info_idx++;
komoritan 0:14bd24b5a77f 133 memcpy( scan_result.bssid, &ap_info_p[ap_info_idx], BSSID_MAC_LENTH );
komoritan 0:14bd24b5a77f 134 ap_info_idx += BSSID_MAC_LENTH;
komoritan 0:14bd24b5a77f 135 scan_result.network_type= ap_info_p[ap_info_idx];
komoritan 0:14bd24b5a77f 136 ap_info_idx++;
komoritan 0:14bd24b5a77f 137 scan_result.max_rate= ap_info_p[ap_info_idx];
komoritan 0:14bd24b5a77f 138 ap_info_idx++;
komoritan 0:14bd24b5a77f 139 ap_info_idx++; // reserved
komoritan 0:14bd24b5a77f 140 strcpy( scan_result.ssid, (char *)&ap_info_p[ap_info_idx] );
komoritan 0:14bd24b5a77f 141 ap_info_idx += strlen( (char *)&ap_info_p[ap_info_idx] );
komoritan 0:14bd24b5a77f 142 ap_info_idx++;
komoritan 0:14bd24b5a77f 143
komoritan 0:14bd24b5a77f 144 // Scanresult callback
komoritan 0:14bd24b5a77f 145 mScanResultHandler_p( &scan_result );
komoritan 0:14bd24b5a77f 146 }
komoritan 0:14bd24b5a77f 147 }
komoritan 0:14bd24b5a77f 148
komoritan 0:14bd24b5a77f 149 void C_SNIC_UartCommandManager::bufferredPacket( unsigned char *payload_p, int payload_len )
komoritan 0:14bd24b5a77f 150 {
komoritan 0:14bd24b5a77f 151 if( (payload_p == NULL) || (payload_len == 0) )
komoritan 0:14bd24b5a77f 152 {
komoritan 0:14bd24b5a77f 153 return;
komoritan 0:14bd24b5a77f 154 }
komoritan 0:14bd24b5a77f 155
komoritan 0:14bd24b5a77f 156 C_SNIC_Core *instance_p = C_SNIC_Core::getInstance();
komoritan 0:14bd24b5a77f 157
komoritan 0:14bd24b5a77f 158 int socket_id;
komoritan 0:14bd24b5a77f 159 unsigned short recv_len;
komoritan 0:14bd24b5a77f 160
komoritan 0:14bd24b5a77f 161 // Get socket id from payload
komoritan 0:14bd24b5a77f 162 socket_id = payload_p[2];
komoritan 0:14bd24b5a77f 163
komoritan 0:14bd24b5a77f 164 // DEBUG_PRINT("bufferredPacket socket id:%d\r\n", socket_id);
komoritan 0:14bd24b5a77f 165 // Get Connection information
komoritan 0:14bd24b5a77f 166 C_SNIC_Core::tagCONNECT_INFO_T *con_info_p = instance_p->getConnectInfo( socket_id );
komoritan 0:14bd24b5a77f 167 if( con_info_p == NULL )
komoritan 0:14bd24b5a77f 168 {
komoritan 0:14bd24b5a77f 169 return;
komoritan 0:14bd24b5a77f 170 }
komoritan 0:14bd24b5a77f 171
komoritan 0:14bd24b5a77f 172 if( con_info_p->is_connected == false )
komoritan 0:14bd24b5a77f 173 {
komoritan 0:14bd24b5a77f 174 DEBUG_PRINT(" Socket id \"%d\" is not connected\r\n", socket_id);
komoritan 0:14bd24b5a77f 175 return;
komoritan 0:14bd24b5a77f 176 }
komoritan 0:14bd24b5a77f 177
komoritan 0:14bd24b5a77f 178 // Get receive length from payload
komoritan 0:14bd24b5a77f 179 recv_len= ((payload_p[3]<<8) & 0xFF00) | payload_p[4];
komoritan 0:14bd24b5a77f 180
komoritan 0:14bd24b5a77f 181 while( con_info_p->is_receive_complete == false )
komoritan 0:14bd24b5a77f 182 {
komoritan 0:14bd24b5a77f 183 Thread::yield();
komoritan 0:14bd24b5a77f 184 }
komoritan 0:14bd24b5a77f 185
komoritan 0:14bd24b5a77f 186 // DEBUG_PRINT("bufferredPacket recv_len:%d\r\n", recv_len);
komoritan 0:14bd24b5a77f 187 int i;
komoritan 0:14bd24b5a77f 188 for(i = 0; i < recv_len; i++ )
komoritan 0:14bd24b5a77f 189 {
komoritan 0:14bd24b5a77f 190 if( con_info_p->recvbuf_p->isFull() )
komoritan 0:14bd24b5a77f 191 {
komoritan 0:14bd24b5a77f 192 DEBUG_PRINT("Receive buffer is full.\r\n");
komoritan 0:14bd24b5a77f 193 break;
komoritan 0:14bd24b5a77f 194 }
komoritan 0:14bd24b5a77f 195 // Add to receive buffer
komoritan 0:14bd24b5a77f 196 con_info_p->recvbuf_p->queue( payload_p[5+i] );
komoritan 0:14bd24b5a77f 197 }
komoritan 0:14bd24b5a77f 198 //DEBUG_PRINT("###Receive queue[%d]\r\n", i);
komoritan 0:14bd24b5a77f 199 con_info_p->mutex.lock();
komoritan 0:14bd24b5a77f 200 con_info_p->is_receive_complete = false;
komoritan 0:14bd24b5a77f 201 con_info_p->is_received = true;
komoritan 0:14bd24b5a77f 202 con_info_p->mutex.unlock();
komoritan 0:14bd24b5a77f 203 // Thread::yield();
komoritan 0:14bd24b5a77f 204 }
komoritan 0:14bd24b5a77f 205
komoritan 0:14bd24b5a77f 206 void C_SNIC_UartCommandManager::connectedTCPClient( unsigned char *payload_p, int payload_len )
komoritan 0:14bd24b5a77f 207 {
komoritan 0:14bd24b5a77f 208 if( (payload_p == NULL) || (payload_len == 0) )
komoritan 0:14bd24b5a77f 209 {
komoritan 0:14bd24b5a77f 210 return;
komoritan 0:14bd24b5a77f 211 }
komoritan 0:14bd24b5a77f 212
komoritan 0:14bd24b5a77f 213 C_SNIC_Core *instance_p = C_SNIC_Core::getInstance();
komoritan 0:14bd24b5a77f 214 int socket_id;
komoritan 0:14bd24b5a77f 215
komoritan 0:14bd24b5a77f 216 // Get socket id of client from payload
komoritan 0:14bd24b5a77f 217 socket_id = payload_p[3];
komoritan 0:14bd24b5a77f 218
komoritan 0:14bd24b5a77f 219 DEBUG_PRINT("[connectedTCPClient] socket id:%d\r\n", socket_id);
komoritan 0:14bd24b5a77f 220
komoritan 0:14bd24b5a77f 221 // Get Connection information
komoritan 0:14bd24b5a77f 222 C_SNIC_Core::tagCONNECT_INFO_T *con_info_p = instance_p->getConnectInfo( socket_id );
komoritan 0:14bd24b5a77f 223 if( con_info_p == NULL )
komoritan 0:14bd24b5a77f 224 {
komoritan 0:14bd24b5a77f 225 return;
komoritan 0:14bd24b5a77f 226 }
komoritan 0:14bd24b5a77f 227
komoritan 0:14bd24b5a77f 228 if( con_info_p->recvbuf_p == NULL )
komoritan 0:14bd24b5a77f 229 {
komoritan 0:14bd24b5a77f 230 // DEBUG_PRINT( "create recv buffer[socket:%d]\r\n", socket_id);
komoritan 0:14bd24b5a77f 231 con_info_p->recvbuf_p = new CircBuffer<char>(SNIC_UART_RECVBUF_SIZE);
komoritan 0:14bd24b5a77f 232 }
komoritan 0:14bd24b5a77f 233 con_info_p->is_connected = true;
komoritan 0:14bd24b5a77f 234 con_info_p->is_received = false;
komoritan 0:14bd24b5a77f 235 con_info_p->is_accept = true;
komoritan 0:14bd24b5a77f 236 con_info_p->parent_socket = payload_p[2];
komoritan 0:14bd24b5a77f 237 con_info_p->from_ip = ((payload_p[4] << 24) | (payload_p[5] << 16) | (payload_p[6] << 8) | payload_p[7]);
komoritan 0:14bd24b5a77f 238 con_info_p->from_port = ((payload_p[8] << 8) | payload_p[9]);
komoritan 0:14bd24b5a77f 239 }
komoritan 0:14bd24b5a77f 240
komoritan 0:14bd24b5a77f 241 void C_SNIC_UartCommandManager::bufferredUDPPacket( unsigned char *payload_p, int payload_len )
komoritan 0:14bd24b5a77f 242 {
komoritan 0:14bd24b5a77f 243 if( (payload_p == NULL) || (payload_len == 0) )
komoritan 0:14bd24b5a77f 244 {
komoritan 0:14bd24b5a77f 245 return;
komoritan 0:14bd24b5a77f 246 }
komoritan 0:14bd24b5a77f 247
komoritan 0:14bd24b5a77f 248 C_SNIC_Core *instance_p = C_SNIC_Core::getInstance();
komoritan 0:14bd24b5a77f 249
komoritan 0:14bd24b5a77f 250 // Get Connection information
komoritan 0:14bd24b5a77f 251 C_SNIC_Core::tagUDP_RECVINFO_T *con_info_p = instance_p->getUdpRecvInfo( payload_p[2] );
komoritan 0:14bd24b5a77f 252 if( con_info_p == NULL )
komoritan 0:14bd24b5a77f 253 {
komoritan 0:14bd24b5a77f 254 return;
komoritan 0:14bd24b5a77f 255 }
komoritan 0:14bd24b5a77f 256
komoritan 0:14bd24b5a77f 257 if( con_info_p->recvbuf_p == NULL )
komoritan 0:14bd24b5a77f 258 {
komoritan 0:14bd24b5a77f 259 // DEBUG_PRINT( "create recv buffer[socket:%d]\r\n", payload_p[2]);
komoritan 0:14bd24b5a77f 260 con_info_p->recvbuf_p = new CircBuffer<char>(SNIC_UART_RECVBUF_SIZE);
komoritan 0:14bd24b5a77f 261 }
komoritan 0:14bd24b5a77f 262 con_info_p->mutex.lock();
komoritan 0:14bd24b5a77f 263 con_info_p->is_received = true;
komoritan 0:14bd24b5a77f 264 con_info_p->mutex.unlock();
komoritan 0:14bd24b5a77f 265
komoritan 0:14bd24b5a77f 266 // Set remote IP address and remote port
komoritan 0:14bd24b5a77f 267 con_info_p->from_ip = ((payload_p[3] << 24) | (payload_p[4] << 16) | (payload_p[5] << 8) | payload_p[6]);
komoritan 0:14bd24b5a77f 268 con_info_p->from_port = ((payload_p[7] << 8) | payload_p[8]);
komoritan 0:14bd24b5a77f 269
komoritan 0:14bd24b5a77f 270 unsigned short recv_len;
komoritan 0:14bd24b5a77f 271 // Get receive length from payload
komoritan 0:14bd24b5a77f 272 recv_len= ((payload_p[9]<<8) & 0xFF00) | payload_p[10];
komoritan 0:14bd24b5a77f 273 for( int i = 0; i < recv_len; i++ )
komoritan 0:14bd24b5a77f 274 {
komoritan 0:14bd24b5a77f 275 if( con_info_p->recvbuf_p->isFull() )
komoritan 0:14bd24b5a77f 276 {
komoritan 0:14bd24b5a77f 277 DEBUG_PRINT("Receive buffer is full.\r\n");
komoritan 0:14bd24b5a77f 278 break;
komoritan 0:14bd24b5a77f 279 }
komoritan 0:14bd24b5a77f 280
komoritan 0:14bd24b5a77f 281 // Add to receive buffer
komoritan 0:14bd24b5a77f 282 con_info_p->recvbuf_p->queue( payload_p[11+i] );
komoritan 0:14bd24b5a77f 283 }
komoritan 0:14bd24b5a77f 284 }