Diff: socket/socket_lwip.c

Revision:

0:35aa5be3b78d

--- /dev/null	Thu Jan 01 00:00:00 1970 +0000
+++ b/socket/socket_lwip.c	Fri Jun 06 10:49:02 2014 +0000
@@ -0,0 +1,108 @@
+/*
+MuTLS - A super trimmed down TLS/SSL Library for embedded devices
+Author: Donatien Garnier
+Copyright (C) 2013-2014 AppNearMe Ltd
+
+This program is free software; you can redistribute it and/or
+modify it under the terms of the GNU General Public License
+as published by the Free Software Foundation; either version 2
+of the License, or (at your option) any later version.
+
+This program is distributed in the hope that it will be useful,
+but WITHOUT ANY WARRANTY; without even the implied warranty of
+MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.  See the
+GNU General Public License for more details.
+
+You should have received a copy of the GNU General Public License
+along with this program; if not, write to the Free Software
+Foundation, Inc., 51 Franklin Street, Fifth Floor, Boston, MA  02110-1301, USA.
+*//**
+ * \file socket_lwip.c
+ * \copyright Copyright (c) AppNearMe Ltd 2013
+ * \author Donatien Garnier
+ */
+
+#include "core/fwk.h"
+
+#include "socket.h"
+
+#include "lwip/sockets.h"
+#include "lwip/inet.h"
+#include "lwip/netdb.h"
+
+int socket_socket()
+{
+  return lwip_socket(AF_INET, SOCK_STREAM, 0);
+}
+
+
+int socket_connect(int fd, const char* hostname, uint16_t port)
+{
+  /*struct hostent* hostent = gethostbyname(hostname);
+  if(hostent == NULL)
+  {
+    return MUTLS_ERR_SOCKET_ERROR;
+  }*/
+  struct sockaddr_in server;
+  server.sin_family = AF_INET;
+  //memcpy(&server.sin_addr.s_addr, &hostent->h_addr_list[0], hostent->h_length);
+  server.sin_addr.s_addr = inet_addr(hostname);
+  server.sin_port = htons(port);
+
+  DBG("Trying to connect to %s:%d", hostname, port);
+
+  return lwip_connect(fd, (struct sockaddr*)&server, sizeof(struct sockaddr_in));
+}
+
+int socket_wait_readable(int fd, int timeout_ms)
+{
+  //Wait for record to be readable
+  fd_set set;
+  FD_ZERO(&set);
+  FD_SET(fd, &set);
+
+  struct timeval timeout;
+  timeout.tv_sec = timeout_ms / 1000;
+  timeout.tv_usec = (timeout_ms - (timeout.tv_sec * 1000)) * 1000;
+
+  int r = lwip_select(fd + 1, &set, NULL, NULL, &timeout);
+  if( (r <= 0) || !FD_ISSET(fd, &set) )
+  {
+    return -1;
+  }
+  return 0;
+}
+
+int socket_wait_writeable(int fd, int timeout_ms)
+{
+  //Wait for record to be writeable
+  fd_set set;
+  FD_ZERO(&set);
+  FD_SET(fd, &set);
+
+  struct timeval timeout;
+  timeout.tv_sec = timeout_ms / 1000;
+  timeout.tv_usec = (timeout_ms - (timeout.tv_sec * 1000)) * 1000;
+
+  int r = lwip_select(fd + 1, NULL, &set, NULL, &timeout);
+  if( (r <= 0) || !FD_ISSET(fd, &set) )
+  {
+    return -1;
+  }
+  return 0;
+}
+
+int socket_recv(int fd, void* buf, size_t size)
+{
+  return lwip_recv(fd, buf, size, 0);
+}
+
+int socket_send(int fd, void* buf, size_t size)
+{
+  return lwip_send(fd, buf, size, 0);
+}
+
+int socket_close(int fd)
+{
+  return lwip_close(fd);
+}