summaryrefslogtreecommitdiffstats
path: root/nanohttp/nanohttp-socket.c
diff options
context:
space:
mode:
authorGravatar snowdrop2003-12-16 14:12:57 +0000
committerGravatar snowdrop2003-12-16 14:12:57 +0000
commit9cb973e8da746020d364e5fea6eaac7e7556be93 (patch)
treece7d093bf733f6da2b08da1d70bdc704a9c66059 /nanohttp/nanohttp-socket.c
parent15c050ac3a39c9022268aa72770dc94956088615 (diff)
downloadcsoap-9cb973e8da746020d364e5fea6eaac7e7556be93.tar.gz
csoap-9cb973e8da746020d364e5fea6eaac7e7556be93.tar.bz2
develop
Diffstat (limited to 'nanohttp/nanohttp-socket.c')
-rw-r--r--nanohttp/nanohttp-socket.c10
1 files changed, 8 insertions, 2 deletions
diff --git a/nanohttp/nanohttp-socket.c b/nanohttp/nanohttp-socket.c
index d465b8e..9974e76 100644
--- a/nanohttp/nanohttp-socket.c
+++ b/nanohttp/nanohttp-socket.c
@@ -1,5 +1,5 @@
/******************************************************************
- * $Id: nanohttp-socket.c,v 1.2 2003/12/16 13:16:14 snowdrop Exp $
+ * $Id: nanohttp-socket.c,v 1.3 2003/12/16 14:12:58 snowdrop Exp $
*
* CSOAP Project: A http client/server library in C
* Copyright (C) 2003 Ferhat Ayaz
@@ -172,6 +172,7 @@ int hsocket_recv_limit(hsocket_t sock, char** buffer,
do {
+ log_debug1("recv()");
size = recv(sock, tmp, HSOCKET_MAX_BUFSIZE, 0);
if (size == -1) {
@@ -183,10 +184,12 @@ int hsocket_recv_limit(hsocket_t sock, char** buffer,
break;
}
+ puts(tmp);
/* section 1: find delimiter if exist */
for (i=0;i<size-delimlen;i++) {
if (!strncmp(&tmp[i],delim,delimlen)) {
+ log_debug1("Found delimiter");
/* ** split to buffer and rest ** */
/* fill buffer until i */
@@ -234,7 +237,7 @@ int hsocket_recv_limit(hsocket_t sock, char** buffer,
return HSOCKET_OK;
}
-int hsocket_read(hsocket_t sock, char* buffer, int total)
+int hsocket_read(hsocket_t sock, char* buffer, int total, int force)
{
int status;
int totalRead;
@@ -243,6 +246,7 @@ int hsocket_read(hsocket_t sock, char* buffer, int total)
do {
status = recv(sock, &buffer[totalRead], total - totalRead, 0);
+ if (!force) return status;
if (status > 0) {
totalRead += status;
} else {
@@ -381,6 +385,8 @@ int hbufsocket_read(hbufsocket_t *bufsock, char *buffer, int size)
bufsock->bufsize = size;
bufsock->cur = size;
strncpy(&buffer[tmpsize], bufsock->buffer, size);
+ } else {
+ return status;
}
return HSOCKET_OK;