ExternalVendorCode/serval-dna
1
0
Fork 0
mirror of https://github.com/servalproject/serval-dna.git synced 2025-01-31 00:23:50 +00:00
Code Issues Actions Packages Projects Releases Wiki Activity

rhizome direct http transport sends request, and receives http

Browse Source 
reply (including if error).  Doesn't capture the reply body yet. #9
This commit is contained in:
gardners 2012-09-11 09:04:38 +09:30
parent e4896cd028
commit e8009ac94a
1 changed files with 27 additions and 0 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

27
rhizome_direct_http.c
View File

@ -512,6 +512,9 @@ void rhizome_direct_http_dispatch(rhizome_direct_sync_request *r)
char boundary[1024]; char boundary[1024];
snprintf(boundary,1024,"----%08lx%08lx",random(),random()); snprintf(boundary,1024,"----%08lx%08lx",random(),random());
/* TODO: Refactor this code so that it uses our asynchronous framework.
*/
int content_length= int content_length=
strlen("--")+strlen(boundary)+strlen("\r\n")+ strlen("--")+strlen(boundary)+strlen("\r\n")+
strlen("Content-Disposition: form-data; name=\"IHAVEs\"; filename=\"IHAVEs\"\r\n" strlen("Content-Disposition: form-data; name=\"IHAVEs\"; filename=\"IHAVEs\"\r\n"
@ -539,6 +542,7 @@ void rhizome_direct_http_dispatch(rhizome_direct_sync_request *r)
int count=write(sock,&buffer[sent],len-sent); int count=write(sock,&buffer[sent],len-sent);
if (count<1) { if (count<1) {
DEBUGF("errno=%d, count=%d",errno,count); DEBUGF("errno=%d, count=%d",errno,count);
if (errno==EPIPE) goto rx;
close(sock); close(sock);
goto end; goto end;
} }
@ -552,6 +556,7 @@ void rhizome_direct_http_dispatch(rhizome_direct_sync_request *r)
int count=write(sock,&r->cursor->buffer[sent],len-sent); int count=write(sock,&r->cursor->buffer[sent],len-sent);
if (count<1) { if (count<1) {
DEBUGF("errno=%d, count=%d",errno,count); DEBUGF("errno=%d, count=%d",errno,count);
if (errno==EPIPE) goto rx;
close(sock); close(sock);
goto end; goto end;
} }
@ -566,12 +571,34 @@ void rhizome_direct_http_dispatch(rhizome_direct_sync_request *r)
int count=write(sock,&buffer[sent],len-sent); int count=write(sock,&buffer[sent],len-sent);
if (count<1) { if (count<1) {
DEBUGF("errno=%d, count=%d",errno,count); DEBUGF("errno=%d, count=%d",errno,count);
if (errno==EPIPE) goto rx;
close(sock); close(sock);
goto end; goto end;
} }
sent+=count; sent+=count;
} }
rx:
/* request sent, now get response back. */
buffer[0]=0; len=0;
while(!http_header_complete(buffer,len,len)&&(len<8192))
{
int count=read(sock,&buffer[len],8192-len);
if (count<1) {
DEBUGF("errno=%d, count=%d",errno,count);
close(sock);
goto end;
}
len+=count;
if (len>=8000) {
DEBUGF("reply header too long");
close(sock);
goto end;
}
}
DEBUGF("Got HTTP header");
dump("reply",(unsigned char *)buffer,len);
end: end:
/* Warning: tail recursion when done this way. /* Warning: tail recursion when done this way.