From 78e32265532d383c451e34afe46f1139827fb43f Mon Sep 17 00:00:00 2001 From: snowdrop Date: Thu, 11 Dec 2003 14:51:04 +0000 Subject: initial import --- nanohttp/nanohttp-socket.c | 324 +++++++++++++++++++++++++++++++++++++++++++++ 1 file changed, 324 insertions(+) create mode 100644 nanohttp/nanohttp-socket.c (limited to 'nanohttp/nanohttp-socket.c') diff --git a/nanohttp/nanohttp-socket.c b/nanohttp/nanohttp-socket.c new file mode 100644 index 0000000..1a9742b --- /dev/null +++ b/nanohttp/nanohttp-socket.c @@ -0,0 +1,324 @@ +/****************************************************************** + * $Id: nanohttp-socket.c,v 1.1 2003/12/11 14:51:04 snowdrop Exp $ + * + * CSOAP Project: A http client/server library in C + * Copyright (C) 2003 Ferhat Ayaz + * + * This library is free software; you can redistribute it and/or + * modify it under the terms of the GNU Library General Public + * License as published by the Free Software Foundation; either + * version 2 of the License, or (at your option) any later version. + * + * This library 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 + * Library General Public License for more details. + * + * You should have received a copy of the GNU Library General Public + * License along with this library; if not, write to the + * Free Software Foundation, Inc., 59 Temple Place - Suite 330, + * Boston, MA 02111-1307, USA. + * + * Email: ayaz@jprogrammer.net + ******************************************************************/ +#include +#include + +#ifdef HAVE_CONFIG_H +# include "config.h" +#endif + +#ifdef HAVE_SYS_TYPES_H +# include +#endif + +#ifdef HAVE_SYS_SOCKET_H +# include +#endif + +#ifdef HAVE_ARPA_INET_H +# include +#endif + +#ifdef HAVE_NETDB_H +# include +#endif + +#ifdef HAVE_UNISTD_H +# include +#endif + +#include + + +/*-------------------------------------------------- + FUNCTION: hsocket_module_init +----------------------------------------------------*/ +int hsocket_module_init() +{ + /* nothing to init for unix sockets */ + return 0; +} + +/*-------------------------------------------------- + FUNCTION: hsocket_module_destroy +----------------------------------------------------*/ +void hsocket_module_destroy() +{ + /* nothing to destroy for unix sockets */ +} + + +/*-------------------------------------------------- + FUNCTION: hsocket_init +----------------------------------------------------*/ +int hsocket_init(hsocket_t *sock) +{ + /* nothing to init for unix sockets */ + /* just set the descriptor to -1 */ + *sock = -1; + return 0; +} + + +/*-------------------------------------------------- + FUNCTION: hsocket_free +----------------------------------------------------*/ +void hsocket_free(hsocket_t sock) +{ + /* nothing to free for unix sockets */ +} + + +/*-------------------------------------------------- + FUNCTION: hsocket_open +----------------------------------------------------*/ +int hsocket_open(hsocket_t *dsock, const char* hostname, int port) +{ + int sock; + struct sockaddr_in address; + struct hostent* host; + + sock = socket(AF_INET, SOCK_STREAM, 0); + if (sock <= 0) return HSOCKET_CAN_NOT_CREATE_SOCKET; + + /* Get host data */ + host = gethostbyname(hostname); + if (host == NULL) return HSOCKET_CAN_NOT_GET_HOSTNAME; + + /* set server addresss */ + address.sin_family = host->h_addrtype; + address.sin_port = htons(port); + memcpy((char*)&address.sin_addr.s_addr, + host->h_addr_list[0], host->h_length); + + /* connect to the server */ + if (connect(sock, (struct sockaddr*) &address, sizeof(address)) != 0) + return HSOCKET_CAN_NOT_CONNECT; + + *dsock = sock; + return HSOCKET_OK; +} + + +/*-------------------------------------------------- + FUNCTION: hsocket_close +----------------------------------------------------*/ +void hsocket_close(hsocket_t sock) +{ + close(sock); +} + + +/*-------------------------------------------------- + FUNCTION: hsocket_send +----------------------------------------------------*/ +int hsocket_send(hsocket_t sock, const char* buffer) +{ + int size; + + size = send((int)sock, buffer, strlen(buffer), 0); + if (size == -1) + return HSOCKET_CAN_NOT_SEND; + + return HSOCKET_OK; +} + + +/*-------------------------------------------------- + FUNCTION: hsocket_recv_limit (DON'T USE!) +----------------------------------------------------*/ +int hsocket_recv_limit(hsocket_t sock, char** buffer, + const char* delim, char **rest, + int *totalBuffer, int *totalRest) +{ + ssize_t size; + int chunk=1; + char tmp[HSOCKET_MAX_BUFSIZE+1]; + int delimlen; + int fsize; + int i; + + *totalBuffer = 0; + *totalRest = 0; + delimlen = strlen(delim); + + /* calculate first size for realloc */ + if (*buffer) { + fsize = strlen(*buffer); + } else { + fsize = 0; + } + + do { + + size = recv(sock, tmp, HSOCKET_MAX_BUFSIZE, 0); + + if (size == -1) { + log_error1("Error reading from socket\n"); + return HSOCKET_CAN_NOT_RECEIVE; + } + + if (size == 0) { + break; + } + + /* section 1: find delimiter if exist */ + for (i=0;i 0) { + *rest = (char*)realloc(NULL, size - (i+delimlen)+1 + HSOCKET_MAX_BUFSIZE); + strcpy(*rest, &tmp[i+delimlen]); + *totalRest = size - (i+delimlen); + (*rest)[*totalRest] = '\0'; + } else { + *rest = NULL; + } + + return HSOCKET_OK; + } + } + + /* section 2: no delimiter found. so add tmp to buffer */ + *totalBuffer += size; + if (*buffer) { + *buffer = (char*)realloc(*buffer, *totalBuffer+fsize+1); + strcat(*buffer, tmp); + } else { + *buffer = (char*)realloc(NULL, *totalBuffer+1); + strcpy(*buffer, tmp); + } + + (*buffer)[*totalBuffer] = '\0'; + + chunk++; + } while (size > 0); + + return HSOCKET_OK; +} + +/*-------------------------------------------------- + FUNCTION: hsocket_recv +----------------------------------------------------*/ +int hsocket_recv(hsocket_t sock, char** buffer, int *totalSize) +{ + ssize_t size; + int chunk=1; + char tmp[HSOCKET_MAX_BUFSIZE+1]; + int fsize; + + *totalSize = 0; + + /* calculate first size for realloc */ + if (*buffer) { + fsize = strlen(*buffer); + } else { + fsize = 0; + } + + do { + + size = recv(sock, tmp, HSOCKET_MAX_BUFSIZE, 0); + + if (size == -1) { + log_error1("Error reading from socket\n"); + return HSOCKET_CAN_NOT_RECEIVE; + } + + if (size == 0) { + break; + } + + *totalSize += size; + if (*buffer) { + log_debug2("reallocation %d bytes",*totalSize+fsize+1); + *buffer = (char*)realloc((char*)*buffer, (*totalSize)+fsize+HSOCKET_MAX_BUFSIZE); + strcat(*buffer, tmp); + } else { + log_debug1("Allocating"); + *buffer = (char*)realloc(NULL, *totalSize+1); + strcpy(*buffer, tmp); + } + + log_debug1("Assigning"); + (*buffer)[*totalSize+fsize] = '\0'; + chunk++; + } while (size > 0); + + log_debug1("Returning"); + return HSOCKET_OK; +} + + + +/*-------------------------------------------------- + FUNCTION: hsocket_recv +----------------------------------------------------*/ +int hsocket_recv_cb(hsocket_t sock, + hsocket_recv_callback cb, void *userdata) +{ + ssize_t size; + char tmp[HSOCKET_MAX_BUFSIZE+1]; + + do { + + size = recv(sock, tmp, HSOCKET_MAX_BUFSIZE, 0); + + if (size == -1) { + log_error1("Error reading from socket\n"); + return HSOCKET_CAN_NOT_RECEIVE; + } + + if (size == 0) { + break; + } + + tmp[size]='\0'; + if (!cb(sock, tmp, size, userdata)) { + break; + } + + } while (size > 0); + + return HSOCKET_OK; +} + + + -- cgit v1.1-32-gdbae