summaryrefslogtreecommitdiffstats
path: root/qemu/roms/ipxe/src/net/tcp/httpconn.c
diff options
context:
space:
mode:
authorRajithaY <rajithax.yerrumsetty@intel.com>2017-04-25 03:31:15 -0700
committerRajitha Yerrumchetty <rajithax.yerrumsetty@intel.com>2017-05-22 06:48:08 +0000
commitbb756eebdac6fd24e8919e2c43f7d2c8c4091f59 (patch)
treeca11e03542edf2d8f631efeca5e1626d211107e3 /qemu/roms/ipxe/src/net/tcp/httpconn.c
parenta14b48d18a9ed03ec191cf16b162206998a895ce (diff)
Adding qemu as a submodule of KVMFORNFV
This Patch includes the changes to add qemu as a submodule to kvmfornfv repo and make use of the updated latest qemu for the execution of all testcase Change-Id: I1280af507a857675c7f81d30c95255635667bdd7 Signed-off-by:RajithaY<rajithax.yerrumsetty@intel.com>
Diffstat (limited to 'qemu/roms/ipxe/src/net/tcp/httpconn.c')
-rw-r--r--qemu/roms/ipxe/src/net/tcp/httpconn.c309
1 files changed, 0 insertions, 309 deletions
diff --git a/qemu/roms/ipxe/src/net/tcp/httpconn.c b/qemu/roms/ipxe/src/net/tcp/httpconn.c
deleted file mode 100644
index 7e4877b7b..000000000
--- a/qemu/roms/ipxe/src/net/tcp/httpconn.c
+++ /dev/null
@@ -1,309 +0,0 @@
-/*
- * Copyright (C) 2015 Michael Brown <mbrown@fensystems.co.uk>.
- *
- * This program 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 of the
- * License, or any later version.
- *
- * This program 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 this program; if not, write to the Free Software
- * Foundation, Inc., 51 Franklin Street, Fifth Floor, Boston, MA
- * 02110-1301, USA.
- *
- * You can also choose to distribute this program under the terms of
- * the Unmodified Binary Distribution Licence (as given in the file
- * COPYING.UBDL), provided that you have satisfied its requirements.
- */
-
-FILE_LICENCE ( GPL2_OR_LATER_OR_UBDL );
-
-/**
- * @file
- *
- * Hyper Text Transfer Protocol (HTTP) connection management
- *
- */
-
-#include <stdlib.h>
-#include <string.h>
-#include <errno.h>
-#include <byteswap.h>
-#include <ipxe/tcpip.h>
-#include <ipxe/uri.h>
-#include <ipxe/timer.h>
-#include <ipxe/xfer.h>
-#include <ipxe/open.h>
-#include <ipxe/pool.h>
-#include <ipxe/http.h>
-
-/** HTTP pooled connection expiry time */
-#define HTTP_CONN_EXPIRY ( 10 * TICKS_PER_SEC )
-
-/** HTTP connection pool */
-static LIST_HEAD ( http_connection_pool );
-
-/**
- * Identify HTTP scheme
- *
- * @v uri URI
- * @ret scheme HTTP scheme, or NULL
- */
-static struct http_scheme * http_scheme ( struct uri *uri ) {
- struct http_scheme *scheme;
-
- /* Sanity check */
- if ( ! uri->scheme )
- return NULL;
-
- /* Identify scheme */
- for_each_table_entry ( scheme, HTTP_SCHEMES ) {
- if ( strcmp ( uri->scheme, scheme->name ) == 0 )
- return scheme;
- }
-
- return NULL;
-}
-
-/**
- * Free HTTP connection
- *
- * @v refcnt Reference count
- */
-static void http_conn_free ( struct refcnt *refcnt ) {
- struct http_connection *conn =
- container_of ( refcnt, struct http_connection, refcnt );
-
- /* Free connection */
- uri_put ( conn->uri );
- free ( conn );
-}
-
-/**
- * Close HTTP connection
- *
- * @v conn HTTP connection
- * @v rc Reason for close
- */
-static void http_conn_close ( struct http_connection *conn, int rc ) {
-
- /* Remove from connection pool, if applicable */
- pool_del ( &conn->pool );
-
- /* Shut down interfaces */
- intf_shutdown ( &conn->socket, rc );
- intf_shutdown ( &conn->xfer, rc );
- if ( rc == 0 ) {
- DBGC2 ( conn, "HTTPCONN %p closed %s://%s\n",
- conn, conn->scheme->name, conn->uri->host );
- } else {
- DBGC ( conn, "HTTPCONN %p closed %s://%s: %s\n",
- conn, conn->scheme->name, conn->uri->host,
- strerror ( rc ) );
- }
-}
-
-/**
- * Disconnect idle HTTP connection
- *
- * @v pool Pooled connection
- */
-static void http_conn_expired ( struct pooled_connection *pool ) {
- struct http_connection *conn =
- container_of ( pool, struct http_connection, pool );
-
- /* Close connection */
- http_conn_close ( conn, 0 /* Not an error to close idle connection */ );
-}
-
-/**
- * Receive data from transport layer interface
- *
- * @v http HTTP connection
- * @v iobuf I/O buffer
- * @v meta Transfer metadata
- * @ret rc Return status code
- */
-static int http_conn_socket_deliver ( struct http_connection *conn,
- struct io_buffer *iobuf,
- struct xfer_metadata *meta ) {
-
- /* Mark connection as alive */
- pool_alive ( &conn->pool );
-
- /* Pass on to data transfer interface */
- return xfer_deliver ( &conn->xfer, iobuf, meta );
-}
-
-/**
- * Close HTTP connection transport layer interface
- *
- * @v http HTTP connection
- * @v rc Reason for close
- */
-static void http_conn_socket_close ( struct http_connection *conn, int rc ) {
-
- /* If we are reopenable (i.e. we are a recycled connection
- * from the connection pool, and we have received no data from
- * the underlying socket since we were pooled), then suggest
- * that the client should reopen the connection.
- */
- if ( pool_is_reopenable ( &conn->pool ) )
- pool_reopen ( &conn->xfer );
-
- /* Close the connection */
- http_conn_close ( conn, rc );
-}
-
-/**
- * Recycle this connection after closing
- *
- * @v http HTTP connection
- */
-static void http_conn_xfer_recycle ( struct http_connection *conn ) {
-
- /* Mark connection as recyclable */
- pool_recyclable ( &conn->pool );
- DBGC2 ( conn, "HTTPCONN %p keepalive enabled\n", conn );
-}
-
-/**
- * Close HTTP connection data transfer interface
- *
- * @v conn HTTP connection
- * @v rc Reason for close
- */
-static void http_conn_xfer_close ( struct http_connection *conn, int rc ) {
-
- /* Add to the connection pool if keepalive is enabled and no
- * error occurred.
- */
- if ( ( rc == 0 ) && pool_is_recyclable ( &conn->pool ) ) {
- intf_restart ( &conn->xfer, rc );
- pool_add ( &conn->pool, &http_connection_pool,
- HTTP_CONN_EXPIRY );
- DBGC2 ( conn, "HTTPCONN %p pooled %s://%s\n",
- conn, conn->scheme->name, conn->uri->host );
- return;
- }
-
- /* Otherwise, close the connection */
- http_conn_close ( conn, rc );
-}
-
-/** HTTP connection socket interface operations */
-static struct interface_operation http_conn_socket_operations[] = {
- INTF_OP ( xfer_deliver, struct http_connection *,
- http_conn_socket_deliver ),
- INTF_OP ( intf_close, struct http_connection *,
- http_conn_socket_close ),
-};
-
-/** HTTP connection socket interface descriptor */
-static struct interface_descriptor http_conn_socket_desc =
- INTF_DESC_PASSTHRU ( struct http_connection, socket,
- http_conn_socket_operations, xfer );
-
-/** HTTP connection data transfer interface operations */
-static struct interface_operation http_conn_xfer_operations[] = {
- INTF_OP ( pool_recycle, struct http_connection *,
- http_conn_xfer_recycle ),
- INTF_OP ( intf_close, struct http_connection *,
- http_conn_xfer_close ),
-};
-
-/** HTTP connection data transfer interface descriptor */
-static struct interface_descriptor http_conn_xfer_desc =
- INTF_DESC_PASSTHRU ( struct http_connection, xfer,
- http_conn_xfer_operations, socket );
-
-/**
- * Connect to an HTTP server
- *
- * @v xfer Data transfer interface
- * @v uri Connection URI
- * @ret rc Return status code
- *
- * HTTP connections are pooled. The caller should be prepared to
- * receive a pool_reopen() message.
- */
-int http_connect ( struct interface *xfer, struct uri *uri ) {
- struct http_connection *conn;
- struct http_scheme *scheme;
- struct sockaddr_tcpip server;
- struct interface *socket;
- int rc;
-
- /* Identify scheme */
- scheme = http_scheme ( uri );
- if ( ! scheme )
- return -ENOTSUP;
-
- /* Sanity check */
- if ( ! uri->host )
- return -EINVAL;
-
- /* Look for a reusable connection in the pool */
- list_for_each_entry ( conn, &http_connection_pool, pool.list ) {
-
- /* Sanity checks */
- assert ( conn->uri != NULL );
- assert ( conn->uri->host != NULL );
-
- /* Reuse connection, if possible */
- if ( ( scheme == conn->scheme ) &&
- ( strcmp ( uri->host, conn->uri->host ) == 0 ) ) {
-
- /* Remove from connection pool, stop timer,
- * attach to parent interface, and return.
- */
- pool_del ( &conn->pool );
- intf_plug_plug ( &conn->xfer, xfer );
- DBGC2 ( conn, "HTTPCONN %p reused %s://%s\n",
- conn, conn->scheme->name, conn->uri->host );
- return 0;
- }
- }
-
- /* Allocate and initialise structure */
- conn = zalloc ( sizeof ( *conn ) );
- ref_init ( &conn->refcnt, http_conn_free );
- conn->uri = uri_get ( uri );
- conn->scheme = scheme;
- intf_init ( &conn->socket, &http_conn_socket_desc, &conn->refcnt );
- intf_init ( &conn->xfer, &http_conn_xfer_desc, &conn->refcnt );
- pool_init ( &conn->pool, http_conn_expired, &conn->refcnt );
-
- /* Open socket */
- memset ( &server, 0, sizeof ( server ) );
- server.st_port = htons ( uri_port ( uri, scheme->port ) );
- socket = &conn->socket;
- if ( scheme->filter &&
- ( ( rc = scheme->filter ( socket, uri->host, &socket ) ) != 0 ) )
- goto err_filter;
- if ( ( rc = xfer_open_named_socket ( socket, SOCK_STREAM,
- ( struct sockaddr * ) &server,
- uri->host, NULL ) ) != 0 )
- goto err_open;
-
- /* Attach to parent interface, mortalise self, and return */
- intf_plug_plug ( &conn->xfer, xfer );
- ref_put ( &conn->refcnt );
-
- DBGC2 ( conn, "HTTPCONN %p created %s://%s:%d\n", conn,
- conn->scheme->name, conn->uri->host, ntohs ( server.st_port ) );
- return 0;
-
- err_open:
- err_filter:
- DBGC2 ( conn, "HTTPCONN %p could not create %s://%s: %s\n",
- conn, conn->scheme->name, conn->uri->host, strerror ( rc ) );
- http_conn_close ( conn, rc );
- ref_put ( &conn->refcnt );
- return rc;
-}