narenas
/
opengnsys_ipxe
mirror of https://github.com/ipxe/ipxe.git
1
0
Fork 0
Code Issues Packages Projects Releases Wiki Activity

Updated to use new URL parser and new protocol API. 

Sort of works; the HTTP stuff is fine but the TCP code seems to be
broken; it doesn't ACK the packets and just hands us the retransmitted
packets instead.
pull/1/head
Michael Brown 2005-05-02 12:10:14 +00:00
parent a918abc036
commit 4ed412f1c2
1 changed files with 70 additions and 75 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

139
src/proto/http.c
View File

@ -1,7 +1,7 @@
#include "proto.h"
#include "tcp.h"
#include "url.h"
#include "etherboot.h" #include "etherboot.h"
#include "http.h"
#ifdef DOWNLOAD_PROTO_HTTP
/* The block size is currently chosen to be 512 bytes. This means, we can /* The block size is currently chosen to be 512 bytes. This means, we can
allocate the receive buffer on the stack, but it results in a noticeable allocate the receive buffer on the stack, but it results in a noticeable
@ -17,7 +17,9 @@
SEND_TCP_CALLBACK - Send data using TCP SEND_TCP_CALLBACK - Send data using TCP
**************************************************************************/ **************************************************************************/
struct send_recv_state { struct send_recv_state {
int (*fnc)(unsigned char *data, int block, int len, int eof); int ( * process ) ( unsigned char *data,
unsigned int blocknum,
unsigned int len, int eof );
char *send_buffer; char *send_buffer;
char *recv_buffer; char *recv_buffer;
int send_length; int send_length;
@ -27,7 +29,7 @@ struct send_recv_state {
int bytes_received; int bytes_received;
enum { RESULT_CODE, HEADER, DATA, ERROR, MOVED } recv_state; enum { RESULT_CODE, HEADER, DATA, ERROR, MOVED } recv_state;
int rc; int rc;
char location[MAX_URL+1]; char *url;
}; };
static int send_tcp_request(int length, void *buffer, void *ptr) { static int send_tcp_request(int length, void *buffer, void *ptr) {
@ -56,16 +58,19 @@ static int recv_tcp_request(int length, const void *buffer, void *ptr) {
int rc = strtoul(ptr, &ptr, 10); int rc = strtoul(ptr, &ptr, 10);
if (ptr >= (const char *)buffer + length) { if (ptr >= (const char *)buffer + length) {
state->recv_state = ERROR; state->recv_state = ERROR;
DBG ( "HTTP got bad result code\n" );
return 0; return 0;
} }
state->rc = rc; state->rc = rc;
state->recv_state = HEADER; state->recv_state = HEADER;
DBG ( "HTTP got result code %d\n", rc );
goto header; goto header;
} }
++(const char *)buffer; ++(const char *)buffer;
length--; length--;
} }
state->recv_state = ERROR; state->recv_state = ERROR;
DBG ( "HTTP got no result code\n" );
return 0; return 0;
} }
if (state->recv_state == HEADER) { if (state->recv_state == HEADER) {
@ -73,13 +78,16 @@ static int recv_tcp_request(int length, const void *buffer, void *ptr) {
/* Check for HTTP redirect */ /* Check for HTTP redirect */
if (state->rc >= 300 && state->rc < 400 && if (state->rc >= 300 && state->rc < 400 &&
!memcmp(buffer, "Location: ", 10)) { !memcmp(buffer, "Location: ", 10)) {
char *ptr = state->location; char *p;
int i;
memcpy(ptr, buffer + 10, MAX_URL); state->url = p = ( char * ) buffer + 10;
for (i = 0; i < MAX_URL && *ptr > ' '; while ( *p > ' ' ) {
i++, ptr++); p++;
*ptr = '\000'; }
*p = '\0';
state->recv_state = MOVED; state->recv_state = MOVED;
DBG ( "HTTP got redirect to %s\n",
state->url );
return 1; return 1;
} }
/* Find beginning of line */ /* Find beginning of line */
@ -99,6 +107,7 @@ static int recv_tcp_request(int length, const void *buffer, void *ptr) {
} }
if (state->recv_state == DATA) { if (state->recv_state == DATA) {
state->bytes_received += length; state->bytes_received += length;
DBG2 ( "HTTP received %d bytes\n", length );
while (length > 0) { while (length > 0) {
int copy_length = BLOCKSIZE - state->recv_length; int copy_length = BLOCKSIZE - state->recv_length;
if (copy_length > length) if (copy_length > length)
@ -106,9 +115,11 @@ static int recv_tcp_request(int length, const void *buffer, void *ptr) {
memcpy(state->recv_buffer + state->recv_length, memcpy(state->recv_buffer + state->recv_length,
buffer, copy_length); buffer, copy_length);
if ((state->recv_length += copy_length) == BLOCKSIZE) { if ((state->recv_length += copy_length) == BLOCKSIZE) {
if (!state->fnc(state->recv_buffer, DBG2 ( "HTTP processing %d bytes\n",
++state->block, BLOCKSIZE, 0)) BLOCKSIZE );
return 0; if (!state->process(state->recv_buffer,
++state->block,
BLOCKSIZE, 0))
state->recv_length = 0; state->recv_length = 0;
} }
length -= copy_length; length -= copy_length;
@ -121,86 +132,70 @@ static int recv_tcp_request(int length, const void *buffer, void *ptr) {
/************************************************************************** /**************************************************************************
HTTP_GET - Get data using HTTP HTTP_GET - Get data using HTTP
**************************************************************************/ **************************************************************************/
int http(const char *url, static int http ( char *url,
int (*fnc)(unsigned char *, unsigned int, unsigned int, int)) { struct sockaddr_in *server __unused,
char *file __unused,
int ( * process ) ( unsigned char *data,
unsigned int blocknum,
unsigned int len, int eof ) ) {
struct protocol *proto;
struct sockaddr_in http_server = *server;
char *filename;
static const char GET[] = "GET /%s HTTP/1.0\r\n\r\n"; static const char GET[] = "GET /%s HTTP/1.0\r\n\r\n";
static char recv_buffer[BLOCKSIZE]; static char recv_buffer[BLOCKSIZE];
in_addr destip;
int port;
int length;
struct send_recv_state state; struct send_recv_state state;
int length;
state.fnc = fnc;
state.rc = -1; state.rc = -1;
state.block = 0; state.block = 0;
state.recv_buffer = recv_buffer; state.recv_buffer = recv_buffer;
length = strlen(url); state.url = url;
if (length <= MAX_URL) { state.process = process;
memcpy(state.location, url, length+1); while ( 1 ) {
destip = arptable[ARP_SERVER].ipaddr; length = strlen ( filename ) + strlen ( GET );
port = url_port; {
if (port == -1) char send_buf[length];
port = 80;
goto first_time;
do { sprintf ( send_buf, GET, filename );
state.rc = -1; state.send_buffer = send_buf;
state.block = 0; state.send_length = strlen ( send_buf );
url = state.location;
if (memcmp("http://", url, 7))
break;
url += 7;
length = inet_aton(url, &destip);
if (!length) {
/* As we do not have support for DNS, assume*/
/* that HTTP redirects always point to the */
/* same machine */
if (state.recv_state == MOVED) {
while (*url &&
*url != ':' && *url != '/') url++;
} else {
break;
}
}
if (*(url += length) == ':') {
port = strtoul(url, &url, 10);
} else {
port = 80;
}
if (!*url)
url = "/";
if (*url != '/')
break;
url++;
first_time:
length = strlen(url);
state.send_length = sizeof(GET) - 3 + length;
{ char buf[state.send_length + 1];
sprintf(state.send_buffer = buf, GET, url);
state.bytes_sent = 0; state.bytes_sent = 0;
state.bytes_received = 0; state.bytes_received = 0;
state.recv_state = RESULT_CODE; state.recv_state = RESULT_CODE;
state.recv_length = 0; state.recv_length = 0;
tcp_transaction(destip.s_addr, 80, &state, tcp_transaction ( server->sin_addr.s_addr,
server->sin_port, &state,
send_tcp_request, recv_tcp_request ); send_tcp_request, recv_tcp_request );
} }
} while (state.recv_state == MOVED);
} else { if ( state.recv_state == MOVED ) {
memcpy(state.location, url, MAX_URL); if ( ! parse_url ( state.url, &proto,
state.location[MAX_URL] = '\000'; &http_server, &filename ) ) {
printf ( "Invalid redirect URL %s\n",
state.url );
return 0;
}
continue;
}
break;
} }
if ( state.rc == 200 ) { if ( state.rc == 200 ) {
return fnc(recv_buffer, ++state.block, state.recv_length, 1); DBG2 ( "HTTP processing %d bytes\n", state.recv_length );
return process ( recv_buffer, ++state.block,
state.recv_length, 1 );
} else { } else {
printf ( "Failed to download %s (rc = %d)\n", printf ( "Failed to download %s (rc = %d)\n",
state.location, state.rc); state.url, state.rc );
return 0; return 0;
} }
} }
#endif /* DOWNLOAD_PROTO_HTTP */ static struct protocol http_protocol __protocol = {
.name = "http",
.default_port = 80,
.load = http,
};