Annotation of embedaddon/libpdel/http/http_connection.c, revision 1.1
1.1 ! misho 1:
! 2: /*
! 3: * Copyright (c) 2001-2002 Packet Design, LLC.
! 4: * All rights reserved.
! 5: *
! 6: * Subject to the following obligations and disclaimer of warranty,
! 7: * use and redistribution of this software, in source or object code
! 8: * forms, with or without modifications are expressly permitted by
! 9: * Packet Design; provided, however, that:
! 10: *
! 11: * (i) Any and all reproductions of the source or object code
! 12: * must include the copyright notice above and the following
! 13: * disclaimer of warranties; and
! 14: * (ii) No rights are granted, in any manner or form, to use
! 15: * Packet Design trademarks, including the mark "PACKET DESIGN"
! 16: * on advertising, endorsements, or otherwise except as such
! 17: * appears in the above copyright notice or in the software.
! 18: *
! 19: * THIS SOFTWARE IS BEING PROVIDED BY PACKET DESIGN "AS IS", AND
! 20: * TO THE MAXIMUM EXTENT PERMITTED BY LAW, PACKET DESIGN MAKES NO
! 21: * REPRESENTATIONS OR WARRANTIES, EXPRESS OR IMPLIED, REGARDING
! 22: * THIS SOFTWARE, INCLUDING WITHOUT LIMITATION, ANY AND ALL IMPLIED
! 23: * WARRANTIES OF MERCHANTABILITY, FITNESS FOR A PARTICULAR PURPOSE,
! 24: * OR NON-INFRINGEMENT. PACKET DESIGN DOES NOT WARRANT, GUARANTEE,
! 25: * OR MAKE ANY REPRESENTATIONS REGARDING THE USE OF, OR THE RESULTS
! 26: * OF THE USE OF THIS SOFTWARE IN TERMS OF ITS CORRECTNESS, ACCURACY,
! 27: * RELIABILITY OR OTHERWISE. IN NO EVENT SHALL PACKET DESIGN BE
! 28: * LIABLE FOR ANY DAMAGES RESULTING FROM OR ARISING OUT OF ANY USE
! 29: * OF THIS SOFTWARE, INCLUDING WITHOUT LIMITATION, ANY DIRECT,
! 30: * INDIRECT, INCIDENTAL, SPECIAL, EXEMPLARY, PUNITIVE, OR CONSEQUENTIAL
! 31: * DAMAGES, PROCUREMENT OF SUBSTITUTE GOODS OR SERVICES, LOSS OF
! 32: * USE, DATA OR PROFITS, HOWEVER CAUSED AND UNDER ANY THEORY OF
! 33: * LIABILITY, WHETHER IN CONTRACT, STRICT LIABILITY, OR TORT
! 34: * (INCLUDING NEGLIGENCE OR OTHERWISE) ARISING IN ANY WAY OUT OF
! 35: * THE USE OF THIS SOFTWARE, EVEN IF PACKET DESIGN IS ADVISED OF
! 36: * THE POSSIBILITY OF SUCH DAMAGE.
! 37: *
! 38: * Author: Archie Cobbs <archie@freebsd.org>
! 39: */
! 40:
! 41: #include <sys/types.h>
! 42: #include <sys/socket.h>
! 43: #include <sys/syslog.h>
! 44: #include <sys/queue.h>
! 45:
! 46: #include <netinet/in_systm.h>
! 47: #include <netinet/in.h>
! 48: #include <arpa/inet.h>
! 49:
! 50: #include <stdio.h>
! 51: #include <stdlib.h>
! 52: #include <stdarg.h>
! 53: #include <string.h>
! 54: #include <unistd.h>
! 55: #include <assert.h>
! 56: #include <pthread.h>
! 57:
! 58: #include <openssl/ssl.h>
! 59: #include <openssl/err.h>
! 60:
! 61: #include "structs/structs.h"
! 62: #include "structs/type/array.h"
! 63:
! 64: #include "io/ssl_fp.h"
! 65: #include "io/timeout_fp.h"
! 66: #include "util/typed_mem.h"
! 67:
! 68: #include "http/http_server.h"
! 69: #include "http/http_internal.h"
! 70:
! 71: /* Internal functions */
! 72: static ssl_logger_t http_connection_ssl_logger;
! 73:
! 74: /*
! 75: * Create a new connection from a raw socket/stream.
! 76: *
! 77: * If fp != NULL, we assume the stream already exists and that
! 78: * sock is valid and will be implicitly closed by fclose(fp).
! 79: * Otherwise, we assume sock is valid but has no stream on top of it.
! 80: * Parameter "server" tells whether we are the server or the client.
! 81: */
! 82: struct http_connection *
! 83: _http_connection_create(FILE *fp, int sock, int server,
! 84: struct in_addr ip, u_int16_t port, SSL_CTX *ssl,
! 85: http_logger_t *logger, u_int timeout)
! 86: {
! 87: struct http_connection *conn;
! 88: struct sockaddr_in sin;
! 89: socklen_t slen;
! 90:
! 91: /* Sanity */
! 92: if (sock < 0 || ip.s_addr == 0 || port == 0) {
! 93: errno = EINVAL;
! 94: return (NULL);
! 95: }
! 96:
! 97: /* Get local address */
! 98: slen = sizeof(sin);
! 99: if (getsockname(sock, (struct sockaddr *)&sin, &slen) == -1) {
! 100: (*logger)(LOG_ERR, "%s: %s", "getsockname", strerror(errno));
! 101: return (NULL);
! 102: }
! 103:
! 104: /* Get new connection object */
! 105: if ((conn = MALLOC("http_connection", sizeof(*conn))) == NULL) {
! 106: (*logger)(LOG_ERR, "%s: %s", "malloc", strerror(errno));
! 107: return (NULL);
! 108: }
! 109: memset(conn, 0, sizeof(*conn));
! 110: conn->remote_ip = ip;
! 111: conn->remote_port = port;
! 112: conn->local_ip = sin.sin_addr;
! 113: conn->local_port = ntohs(sin.sin_port);
! 114: conn->logger = logger;
! 115: conn->server = !!server;
! 116: conn->sock = sock;
! 117: conn->ssl = ssl;
! 118:
! 119: /* Create associated request and response */
! 120: if (_http_request_new(conn) == -1)
! 121: goto fail;
! 122: if (_http_response_new(conn) == -1)
! 123: goto fail;
! 124:
! 125: /* Wrap socket descriptor with a stream (if not already supplied) */
! 126: if (fp == NULL) {
! 127: if (ssl != NULL) {
! 128: fp = ssl_fdopen(ssl, sock, server,
! 129: "http_connection.fp", http_connection_ssl_logger,
! 130: conn, timeout);
! 131: } else
! 132: fp = timeout_fdopen(sock, "r+", timeout);
! 133: if (fp == NULL) {
! 134: (*logger)(LOG_ERR, "%s: %s", "fdopen", strerror(errno));
! 135: goto fail;
! 136: }
! 137: }
! 138: conn->fp = fp;
! 139:
! 140: /* Make stream not buffered */
! 141: setbuf(conn->fp, NULL);
! 142:
! 143: /* Done */
! 144: return (conn);
! 145:
! 146: fail:
! 147: _http_connection_free(&conn);
! 148: return (NULL);
! 149: }
! 150:
! 151: /*
! 152: * Free a connection.
! 153: */
! 154: void
! 155: _http_connection_free(struct http_connection **connp)
! 156: {
! 157: struct http_connection *const conn = *connp;
! 158:
! 159: /* Check for NULL */
! 160: if (conn == NULL)
! 161: return;
! 162: DBG(HTTP, "freeing connection %p", conn);
! 163:
! 164: /* Tell the caller that the connection went away */
! 165: *connp = NULL;
! 166:
! 167: /* Close stream and socket */
! 168: if (conn->fp != NULL)
! 169: fclose(conn->fp);
! 170: else if (conn->sock != -1)
! 171: (void)close(conn->sock);
! 172:
! 173: /* Free request and response */
! 174: _http_request_free(&conn->req);
! 175: _http_response_free(&conn->resp);
! 176:
! 177: /* Free structure */
! 178: FREE("http_connection", conn);
! 179: }
! 180:
! 181: /*
! 182: * Logging callback for SSL code.
! 183: */
! 184: static void
! 185: http_connection_ssl_logger(void *arg, int sev, const char *fmt, ...)
! 186: {
! 187: #if 0 /* SSL errors are quite common, so don't log them */
! 188: struct http_connection *const conn = arg;
! 189: va_list args;
! 190: char *s;
! 191:
! 192: /* Prepend remote IP address to error message */
! 193: va_start(args, fmt);
! 194: VASPRINTF(TYPED_MEM_TEMP, &s, fmt, args);
! 195: va_end(args);
! 196: if (s == NULL)
! 197: return;
! 198: (*conn->logger)(sev, "%s: %s", inet_ntoa(conn->remote_ip), s);
! 199: FREE(TYPED_MEM_TEMP, s);
! 200: #endif
! 201: }
! 202:
FreeBSD-CVSweb <freebsd-cvsweb@FreeBSD.org>
![[BACK]](/icons/cvsweb/back.gif){kind=icon}
Return to http_connection.c CVS log ![[TXT]](/icons/cvsweb/text.gif){kind=icon}
![[DIR]](/icons/cvsweb/dir.gif){kind=icon}
Up to [ELWIX - Embedded LightWeight unIX -] / embedaddon / libpdel / http