//========================================================================== // // net/http_client.c // // Stand-alone HTTP support for RedBoot // //========================================================================== //####ECOSGPLCOPYRIGHTBEGIN#### // ------------------------------------------- // This file is part of eCos, the Embedded Configurable Operating System. // Copyright (C) 1998, 1999, 2000, 2001, 2002 Red Hat, Inc. // Copyright (C) 2002 Gary Thomas // // eCos 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 or (at your option) any later version. // // eCos 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 eCos; if not, write to the Free Software Foundation, Inc., // 59 Temple Place, Suite 330, Boston, MA 02111-1307 USA. // // As a special exception, if other files instantiate templates or use macros // or inline functions from this file, or you compile this file and link it // with other works to produce a work based on this file, this file does not // by itself cause the resulting work to be covered by the GNU General Public // License. However the source code for this file must still be made available // in accordance with section (3) of the GNU General Public License. // // This exception does not invalidate any other reasons why a work based on // this file might be covered by the GNU General Public License. // // Alternative licenses for eCos may be arranged by contacting Red Hat, Inc. // at http://sources.redhat.com/ecos/ecos-license/ // ------------------------------------------- //####ECOSGPLCOPYRIGHTEND#### //========================================================================== //#####DESCRIPTIONBEGIN#### // // Author(s): gthomas // Contributors: gthomas // Date: 2002-05-22 // Purpose: // Description: // // This code is part of RedBoot (tm). // //####DESCRIPTIONEND#### // //========================================================================== // HTTP client support #include // have_net #include #include // So we remember which ports have been used static int get_port = 7800; static struct _stream{ bool open; int avail, actual_len, pos, filelen; char data[4096]; char *bufp; tcp_socket_t sock; } http_stream; static __inline__ int min(int a, int b) { if (a < b) return a; else return b; } int http_stream_open(connection_info_t *info, int *err) { int res; struct _stream *s = &http_stream; info->server->sin_port = 80; // HTTP port if ((res = __tcp_open(&s->sock, info->server, get_port++, 5000, err)) < 0) { *err = HTTP_OPEN; return -1; } diag_sprintf(s->data, "GET %s HTTP/1.0\r\n\r\n", info->filename); __tcp_write_block(&s->sock, s->data, strlen(s->data)); s->avail = 0; s->open = true; s->pos = 0; return 0; } void http_stream_close(int *err) { struct _stream *s = &http_stream; if (s->open) { __tcp_close(&s->sock); s->open = false; } } int http_stream_read(char *buf, int len, int *err) { struct _stream *s = &http_stream; int total = 0; int cnt, code; if (!s->open) { return -1; // Shouldn't happen, but... } while (len) { while (s->avail == 0) { // Need to wait for some data to arrive __tcp_poll(); if (s->sock.state != _ESTABLISHED) { if (s->sock.state == _CLOSE_WAIT) { // This connection is breaking if (s->sock.data_bytes == 0 && s->sock.rxcnt == 0) { __tcp_close(&s->sock); return total; } } else if (s->sock.state == _CLOSED) { // The connection is gone s->open = false; return -1; } else { *err = HTTP_IO; return -1; } } s->actual_len = __tcp_read(&s->sock, s->data, sizeof(s->data)); if (s->actual_len > 0) { s->bufp = s->data; s->avail = s->actual_len; if (s->pos == 0) { // First data - need to scan HTTP response header if (strncmp(s->bufp, "HTTP/", 5) == 0) { // Should look like "HTTP/1.1 200 OK" s->bufp += 5; s->avail -= 5; // Find first space while ((s->avail > 0) && (*s->bufp != ' ')) { s->bufp++; s->avail--; } // Now the integer response code = 0; while ((s->avail > 0) && (*s->bufp == ' ')) { s->bufp++; s->avail--; } while ((s->avail > 0) && isdigit(*s->bufp)) { code = (code * 10) + (*s->bufp - '0'); s->bufp++; s->avail--; } // Make sure it says OK while ((s->avail > 0) && (*s->bufp == ' ')) { s->bufp++; s->avail--; } if (strncmp(s->bufp, "OK", 2)) { *err = HTTP_BADHDR; return -1; } // Find \r\n\r\n - end of HTTP preamble while (s->avail > 4) { // This could be done faster, but not simpler if (strncmp(s->bufp, "\r\n\r\n", 4) == 0) { s->bufp += 4; s->avail -= 4; #if 0 // DEBUG - show header *(s->bufp-2) = '\0'; diag_printf(s->data); #endif break; } s->avail--; s->bufp++; } s->pos++; } else { // Unrecognized response *err = HTTP_BADHDR; return -1; } } } else if (s->actual_len < 0) { *err = HTTP_IO; return -1; } } cnt = min(len, s->avail); memcpy(buf, s->bufp, cnt); s->avail -= cnt; s->bufp += cnt; buf += cnt; total += cnt; len -= cnt; } return total; } char * http_error(int err) { char *errmsg = "Unknown error"; switch (err) { case HTTP_NOERR: return ""; case HTTP_BADHDR: return "Unrecognized HTTP response"; case HTTP_OPEN: return "Can't connect to host"; case HTTP_IO: return "I/O error"; } return errmsg; } // // RedBoot interface // GETC_IO_FUNCS(http_io, http_stream_open, http_stream_close, 0, http_stream_read, http_error); RedBoot_load(http, http_io, true, true, 0);
