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

[http] Profile receive datapath 

Signed-off-by: Michael Brown <mcb30@ipxe.org>
pull/17/head
Michael Brown 2014-04-28 12:31:23 +01:00
parent 767f2acb98
commit e825a96a25
1 changed files with 13 additions and 0 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

13
src/net/tcp/httpcore.c
View File

@ -53,6 +53,7 @@ FILE_LICENCE ( GPL2_OR_LATER );
#include <ipxe/acpi.h> #include <ipxe/acpi.h>
#include <ipxe/version.h> #include <ipxe/version.h>
#include <ipxe/params.h> #include <ipxe/params.h>
#include <ipxe/profile.h>
#include <ipxe/http.h> #include <ipxe/http.h>
/* Disambiguate the various error causes */ /* Disambiguate the various error causes */
@ -93,6 +94,12 @@ FILE_LICENCE ( GPL2_OR_LATER );
/** Retry delay used when we cannot understand the Retry-After header */ /** Retry delay used when we cannot understand the Retry-After header */
#define HTTP_RETRY_SECONDS 5 #define HTTP_RETRY_SECONDS 5
/** Receive profiler */
static struct profiler http_rx_profiler __profiler = { .name = "http.rx" };
/** Data transfer profiler */
static struct profiler http_xfer_profiler __profiler = { .name = "http.xfer" };
/** HTTP flags */ /** HTTP flags */
enum http_flags { enum http_flags {
/** Request is waiting to be transmitted */ /** Request is waiting to be transmitted */
@ -892,6 +899,7 @@ static int http_socket_deliver ( struct http_request *http,
ssize_t line_len; ssize_t line_len;
int rc = 0; int rc = 0;
profile_start ( &http_rx_profiler );
while ( iobuf && iob_len ( iobuf ) ) { while ( iobuf && iob_len ( iobuf ) ) {
switch ( http->rx_state ) { switch ( http->rx_state ) {
@ -927,16 +935,20 @@ static int http_socket_deliver ( struct http_request *http,
iob_pull ( iobuf, data_len ); iob_pull ( iobuf, data_len );
} else if ( data_len < iob_len ( iobuf ) ) { } else if ( data_len < iob_len ( iobuf ) ) {
/* Deliver partial buffer as raw data */ /* Deliver partial buffer as raw data */
profile_start ( &http_xfer_profiler );
rc = xfer_deliver_raw ( &http->xfer, rc = xfer_deliver_raw ( &http->xfer,
iobuf->data, data_len ); iobuf->data, data_len );
iob_pull ( iobuf, data_len ); iob_pull ( iobuf, data_len );
if ( rc != 0 ) if ( rc != 0 )
goto done; goto done;
profile_stop ( &http_xfer_profiler );
} else { } else {
/* Deliver whole I/O buffer */ /* Deliver whole I/O buffer */
profile_start ( &http_xfer_profiler );
if ( ( rc = xfer_deliver_iob ( &http->xfer, if ( ( rc = xfer_deliver_iob ( &http->xfer,
iob_disown ( iobuf ) ) ) != 0 ) iob_disown ( iobuf ) ) ) != 0 )
goto done; goto done;
profile_stop ( &http_xfer_profiler );
} }
http->rx_len += data_len; http->rx_len += data_len;
if ( http->chunk_remaining ) { if ( http->chunk_remaining ) {
@ -985,6 +997,7 @@ static int http_socket_deliver ( struct http_request *http,
if ( rc ) if ( rc )
http_close ( http, rc ); http_close ( http, rc );
free_iob ( iobuf ); free_iob ( iobuf );
profile_stop ( &http_rx_profiler );
return rc; return rc;
} }