Diff: http/server/HttpSocket.cpp

Revision:

0:50cedd586816

Child:

6:37fb696395d7

--- /dev/null	Thu Jan 01 00:00:00 1970 +0000
+++ b/http/server/HttpSocket.cpp	Wed Jun 24 09:54:16 2015 +0000
@@ -0,0 +1,251 @@
+//*****************************************************************************
+// Copyright (C) 2014 Texas Instruments Incorporated
+//
+// All rights reserved. Property of Texas Instruments Incorporated.
+// Restricted rights to use, duplicate or disclose this code are
+// granted through contract.
+// The program may not be used without the written permission of
+// Texas Instruments Incorporated or against the terms and conditions
+// stipulated in the agreement under which this program has been supplied,
+// and under no circumstances can it be used with non-TI connectivity device.
+//
+//*****************************************************************************
+
+
+/**
+ * @defgroup HttpSocket
+ * This module performs all HTTP socket operations
+ *
+ * @{
+ */
+
+#include <string.h>
+#include "HttpDebug.h"
+#include "HttpSocket.h"
+#include "cc3100_simplelink.h"
+#include "cc3100_socket.h"
+
+#include "osi.h"
+
+using namespace mbed_cc3100;
+
+//cc3100 _cc3100_Module(NC, NC, PE_5, PE_4, PE_6, SPI(PB_5, PB_4, PB_3));//Seeed_Arch_Max  irq, nHib, cs, mosi, miso, sck
+cc3100 _cc3100_Module(NC, NC, PD_12, PD_13, PD_11, SPI(PB_5, PB_4, PB_3));//Seeed_Arch_Max  irq, nHib, cs, mosi, miso, sck
+
+#define OSI_DELAY(x)    osi_Sleep(x); //os idle
+
+int OpenTCPServerSocket(unsigned int uiPortNum)
+{
+  int iSockDesc, iRetVal;
+  sockaddr_in sServerAddress;
+  SlSockNonblocking_t enableOption;
+  enableOption.NonblockingEnabled = 1;
+
+  //
+  // opens a secure socket
+  //
+  if(443 == uiPortNum)
+  {
+  	iSockDesc = _cc3100_Module._socket.sl_Socket(SL_AF_INET,SL_SOCK_STREAM, SL_SEC_SOCKET);
+	}
+	else //non secure
+	{
+		iSockDesc = _cc3100_Module._socket.sl_Socket(SL_AF_INET, SL_SOCK_STREAM, SL_IPPROTO_TCP);
+	}
+
+  if( iSockDesc < 0 )
+  {
+     return -1;
+  }
+  //non blocking socket - Enable nonblocking mode
+  iRetVal = _cc3100_Module._socket.sl_SetSockOpt(iSockDesc,SOL_SOCKET,SL_SO_NONBLOCKING, &enableOption,sizeof(enableOption));
+  if(iRetVal < 0)
+  {
+    CloseTCPServerSocket(iSockDesc);
+    return -1;
+  }
+
+  if(443 == uiPortNum)
+  {
+		iRetVal = _cc3100_Module._socket.sl_SetSockOpt(iSockDesc, SL_SOL_SOCKET, SL_SO_SECURE_FILES_PRIVATE_KEY_FILE_NAME,SL_SSL_SRV_KEY, strlen(SL_SSL_SRV_KEY));
+		if( iRetVal < 0 )
+		{
+				CloseTCPServerSocket(iSockDesc);
+				return -1;
+		}
+		iRetVal = _cc3100_Module._socket.sl_SetSockOpt(iSockDesc, SL_SOL_SOCKET, SL_SO_SECURE_FILES_CERTIFICATE_FILE_NAME,SL_SSL_SRV_CERT, strlen(SL_SSL_SRV_CERT));
+		if( iRetVal < 0 )
+		{
+				CloseTCPServerSocket(iSockDesc);
+				return -1;
+		}
+	}
+
+  //
+  // Bind - Assign a port to the socket
+  //
+  sServerAddress.sin_family = AF_INET;
+  sServerAddress.sin_addr.s_addr = _cc3100_Module._socket.htonl(INADDR_ANY);
+  sServerAddress.sin_port = _cc3100_Module._socket.htons(uiPortNum);
+  if ( _cc3100_Module._socket.bind(iSockDesc, (sockaddr*)&sServerAddress, sizeof(sServerAddress)) != 0 )
+  {
+    CloseTCPServerSocket(iSockDesc);
+    return -1;
+  }
+
+  return iSockDesc;
+}
+
+int CreateTCPServerSocket(unsigned int uiPortNum)
+{
+  int iSockDesc = -1;
+  unsigned char connectRetries = 0;
+
+  while (connectRetries++ < SERVER_MAX_SETUP_RETRY_COUNT)
+  {
+    iSockDesc = OpenTCPServerSocket(uiPortNum);
+
+    if (iSockDesc < 0)
+    {
+      continue;
+    }
+
+    if(_cc3100_Module._socket.listen(iSockDesc, HTTP_CORE_MAX_CONNECTIONS) != 0)
+    {
+      CloseTCPServerSocket(iSockDesc);
+      iSockDesc = -1;
+      continue;
+    }
+    else
+    {
+      connectRetries = 0;
+      break;
+    }
+  }
+
+  return iSockDesc;
+}
+
+int CloseTCPServerSocket(int iSockDesc)
+{
+  int ittr = 0;
+
+  if(iSockDesc < 0)
+  {
+    return 0 ;
+  }
+
+  do
+  {
+    if(_cc3100_Module._socket.sl_Close(iSockDesc) >= 0)
+    {
+      iSockDesc = -1;
+      HttpDebug("Http server socket closed\n\r");
+      return 0;
+    }
+    else
+    {
+    	HttpDebug("\n Http client socket close error\n\r");
+      OSI_DELAY(500);//wait 500ms
+    }
+    ittr++;
+  }while(ittr < 3);
+
+  return -1;
+}
+
+int CreateTCPClientSocket(int iSockDesc)
+{
+  sockaddr sClientAddr;
+  SlSocklen_t uiClientAddrLen = sizeof(sClientAddr);
+  int sock = -1;
+  SlTimeval_t timeVal;
+  SlSockNonblocking_t enableOption;
+
+  sock = _cc3100_Module._socket.accept(iSockDesc, &sClientAddr, &uiClientAddrLen);
+  if(sock >= 0)
+  {
+    enableOption.NonblockingEnabled = 0;
+
+    //Blocking socket - Enable blocking mode
+    if(_cc3100_Module._socket.sl_SetSockOpt(sock,SOL_SOCKET,SL_SO_NONBLOCKING, &enableOption,sizeof(enableOption)) < 0)
+    {
+      CloseTCPClientSocket(sock);
+      return -1;
+    }
+
+    timeVal.tv_sec =  1;             // 1 Seconds
+    timeVal.tv_usec = 0;             // Microseconds. 10000 microseconds resoultion
+    if((_cc3100_Module._socket.sl_SetSockOpt(sock,SOL_SOCKET,SL_SO_RCVTIMEO, &timeVal, sizeof(timeVal))) < 0)
+    {
+      CloseTCPClientSocket(sock);
+      return -1;
+    }// Enable receive timeout
+  }
+  return sock;
+}
+
+int CloseTCPClientSocket(int iSockDesc)
+{
+  int ittr = 0;
+
+  if(iSockDesc < 0)
+  {
+    return 0;
+  }
+
+  do
+  {
+    if(_cc3100_Module._socket.sl_Close(iSockDesc) >= 0)
+    {
+      iSockDesc = -1;
+//      HttpDebug("\n Http client socket closed\n\r");
+
+	    return 0;
+    }
+    else
+    {
+    	HttpDebug("\n client socket close error\n\r");
+      OSI_DELAY(500);//wait 500ms
+    }
+    ittr++;
+  }while(ittr < 3);
+
+  return -1;
+}
+
+int ClientSocketSend(long socket, char * buffer, unsigned int len)
+{
+  int send_len = 0, Ittr = 0;
+
+  do
+  {
+    send_len = (int)_cc3100_Module._socket.send((int)socket, buffer, (int)len, 0);
+
+    if(send_len > 0)
+    {
+      if(len != send_len)
+      {
+    	  HttpDebug("client Send length is not matching %d \n\r", send_len);
+        send_len = -1;
+      }
+      return send_len;
+    }
+    else if(send_len != SL_EAGAIN)
+    {
+    	HttpDebug("\n client socket send error %d\n\r", send_len);
+    	return -1;
+    }
+
+    Ittr++;
+
+  }  while((SL_EAGAIN == send_len));
+
+  HttpDebug("\n client send time out %d\n\r", send_len);
+
+  return -1;
+}
+
+
+/// @}
+