http.c revision 355b4669e025ff377602b6fc7caaf30dbc218371
355b4669e025ff377602b6fc7caaf30dbc218371jacobs/*
355b4669e025ff377602b6fc7caaf30dbc218371jacobs * "$Id: http.c 148 2006-04-25 16:54:17Z njacobs $"
355b4669e025ff377602b6fc7caaf30dbc218371jacobs *
355b4669e025ff377602b6fc7caaf30dbc218371jacobs * HTTP routines for the Common UNIX Printing System (CUPS).
355b4669e025ff377602b6fc7caaf30dbc218371jacobs *
355b4669e025ff377602b6fc7caaf30dbc218371jacobs * Copyright 1997-2005 by Easy Software Products, all rights reserved.
355b4669e025ff377602b6fc7caaf30dbc218371jacobs *
355b4669e025ff377602b6fc7caaf30dbc218371jacobs * These coded instructions, statements, and computer programs are the
355b4669e025ff377602b6fc7caaf30dbc218371jacobs * property of Easy Software Products and are protected by Federal
355b4669e025ff377602b6fc7caaf30dbc218371jacobs * copyright law. Distribution and use rights are outlined in the file
355b4669e025ff377602b6fc7caaf30dbc218371jacobs * "LICENSE.txt" which should have been included with this file. If this
355b4669e025ff377602b6fc7caaf30dbc218371jacobs * file is missing or damaged please contact Easy Software Products
355b4669e025ff377602b6fc7caaf30dbc218371jacobs * at:
355b4669e025ff377602b6fc7caaf30dbc218371jacobs *
355b4669e025ff377602b6fc7caaf30dbc218371jacobs * Attn: CUPS Licensing Information
355b4669e025ff377602b6fc7caaf30dbc218371jacobs * Easy Software Products
355b4669e025ff377602b6fc7caaf30dbc218371jacobs * 44141 Airport View Drive, Suite 204
355b4669e025ff377602b6fc7caaf30dbc218371jacobs * Hollywood, Maryland 20636 USA
355b4669e025ff377602b6fc7caaf30dbc218371jacobs *
355b4669e025ff377602b6fc7caaf30dbc218371jacobs * Voice: (301) 373-9600
355b4669e025ff377602b6fc7caaf30dbc218371jacobs * EMail: cups-info@cups.org
355b4669e025ff377602b6fc7caaf30dbc218371jacobs * WWW: http://www.cups.org
355b4669e025ff377602b6fc7caaf30dbc218371jacobs *
355b4669e025ff377602b6fc7caaf30dbc218371jacobs * This file is subject to the Apple OS-Developed Software exception.
355b4669e025ff377602b6fc7caaf30dbc218371jacobs *
355b4669e025ff377602b6fc7caaf30dbc218371jacobs * Contents:
355b4669e025ff377602b6fc7caaf30dbc218371jacobs *
355b4669e025ff377602b6fc7caaf30dbc218371jacobs * httpInitialize() - Initialize the HTTP interface library and set the
355b4669e025ff377602b6fc7caaf30dbc218371jacobs * default HTTP proxy (if any).
355b4669e025ff377602b6fc7caaf30dbc218371jacobs * httpCheck() - Check to see if there is a pending response from
355b4669e025ff377602b6fc7caaf30dbc218371jacobs * the server.
355b4669e025ff377602b6fc7caaf30dbc218371jacobs * httpClearCookie() - Clear the cookie value(s).
355b4669e025ff377602b6fc7caaf30dbc218371jacobs * httpClose() - Close an HTTP connection...
355b4669e025ff377602b6fc7caaf30dbc218371jacobs * httpConnect() - Connect to a HTTP server.
355b4669e025ff377602b6fc7caaf30dbc218371jacobs * httpConnectEncrypt() - Connect to a HTTP server using encryption.
355b4669e025ff377602b6fc7caaf30dbc218371jacobs * httpEncryption() - Set the required encryption on the link.
355b4669e025ff377602b6fc7caaf30dbc218371jacobs * httpReconnect() - Reconnect to a HTTP server...
355b4669e025ff377602b6fc7caaf30dbc218371jacobs * httpGetSubField() - Get a sub-field value.
355b4669e025ff377602b6fc7caaf30dbc218371jacobs * httpSetField() - Set the value of an HTTP header.
355b4669e025ff377602b6fc7caaf30dbc218371jacobs * httpDelete() - Send a DELETE request to the server.
355b4669e025ff377602b6fc7caaf30dbc218371jacobs * httpGet() - Send a GET request to the server.
355b4669e025ff377602b6fc7caaf30dbc218371jacobs * httpHead() - Send a HEAD request to the server.
355b4669e025ff377602b6fc7caaf30dbc218371jacobs * httpOptions() - Send an OPTIONS request to the server.
355b4669e025ff377602b6fc7caaf30dbc218371jacobs * httpPost() - Send a POST request to the server.
355b4669e025ff377602b6fc7caaf30dbc218371jacobs * httpPut() - Send a PUT request to the server.
355b4669e025ff377602b6fc7caaf30dbc218371jacobs * httpTrace() - Send an TRACE request to the server.
355b4669e025ff377602b6fc7caaf30dbc218371jacobs * httpFlush() - Flush data from a HTTP connection.
355b4669e025ff377602b6fc7caaf30dbc218371jacobs * httpRead() - Read data from a HTTP connection.
355b4669e025ff377602b6fc7caaf30dbc218371jacobs * httpSetCookie() - Set the cookie value(s)...
355b4669e025ff377602b6fc7caaf30dbc218371jacobs * httpWait() - Wait for data available on a connection.
355b4669e025ff377602b6fc7caaf30dbc218371jacobs * httpWrite() - Write data to a HTTP connection.
355b4669e025ff377602b6fc7caaf30dbc218371jacobs * httpGets() - Get a line of text from a HTTP connection.
355b4669e025ff377602b6fc7caaf30dbc218371jacobs * httpPrintf() - Print a formatted string to a HTTP connection.
355b4669e025ff377602b6fc7caaf30dbc218371jacobs * httpGetDateString() - Get a formatted date/time string from a time value.
355b4669e025ff377602b6fc7caaf30dbc218371jacobs * httpGetDateTime() - Get a time value from a formatted date/time string.
355b4669e025ff377602b6fc7caaf30dbc218371jacobs * httpUpdate() - Update the current HTTP state for incoming data.
355b4669e025ff377602b6fc7caaf30dbc218371jacobs * httpDecode64() - Base64-decode a string.
355b4669e025ff377602b6fc7caaf30dbc218371jacobs * httpDecode64_2() - Base64-decode a string.
355b4669e025ff377602b6fc7caaf30dbc218371jacobs * httpEncode64() - Base64-encode a string.
355b4669e025ff377602b6fc7caaf30dbc218371jacobs * httpEncode64_2() - Base64-encode a string.
355b4669e025ff377602b6fc7caaf30dbc218371jacobs * httpGetLength() - Get the amount of data remaining from the
355b4669e025ff377602b6fc7caaf30dbc218371jacobs * content-length or transfer-encoding fields.
355b4669e025ff377602b6fc7caaf30dbc218371jacobs * http_field() - Return the field index for a field name.
355b4669e025ff377602b6fc7caaf30dbc218371jacobs * http_send() - Send a request with all fields and the trailing
355b4669e025ff377602b6fc7caaf30dbc218371jacobs * blank line.
355b4669e025ff377602b6fc7caaf30dbc218371jacobs * http_wait() - Wait for data available on a connection.
355b4669e025ff377602b6fc7caaf30dbc218371jacobs * http_upgrade() - Force upgrade to TLS encryption.
355b4669e025ff377602b6fc7caaf30dbc218371jacobs * http_setup_ssl() - Set up SSL/TLS on a connection.
355b4669e025ff377602b6fc7caaf30dbc218371jacobs * http_shutdown_ssl() - Shut down SSL/TLS on a connection.
355b4669e025ff377602b6fc7caaf30dbc218371jacobs * http_read_ssl() - Read from a SSL/TLS connection.
355b4669e025ff377602b6fc7caaf30dbc218371jacobs * http_write_ssl() - Write to a SSL/TLS connection.
355b4669e025ff377602b6fc7caaf30dbc218371jacobs * CDSAReadFunc() - Read function for CDSA decryption code.
355b4669e025ff377602b6fc7caaf30dbc218371jacobs * CDSAWriteFunc() - Write function for CDSA encryption code.
355b4669e025ff377602b6fc7caaf30dbc218371jacobs */
355b4669e025ff377602b6fc7caaf30dbc218371jacobs
355b4669e025ff377602b6fc7caaf30dbc218371jacobs#pragma ident "%Z%%M% %I% %E% SMI"
355b4669e025ff377602b6fc7caaf30dbc218371jacobs
355b4669e025ff377602b6fc7caaf30dbc218371jacobs/*
355b4669e025ff377602b6fc7caaf30dbc218371jacobs * Include necessary headers...
355b4669e025ff377602b6fc7caaf30dbc218371jacobs */
355b4669e025ff377602b6fc7caaf30dbc218371jacobs
355b4669e025ff377602b6fc7caaf30dbc218371jacobs#include "http-private.h"
355b4669e025ff377602b6fc7caaf30dbc218371jacobs
355b4669e025ff377602b6fc7caaf30dbc218371jacobs#include <stdio.h>
355b4669e025ff377602b6fc7caaf30dbc218371jacobs#include <stdlib.h>
355b4669e025ff377602b6fc7caaf30dbc218371jacobs#include <stdarg.h>
355b4669e025ff377602b6fc7caaf30dbc218371jacobs#include <ctype.h>
355b4669e025ff377602b6fc7caaf30dbc218371jacobs#include "string.h"
355b4669e025ff377602b6fc7caaf30dbc218371jacobs#include <fcntl.h>
355b4669e025ff377602b6fc7caaf30dbc218371jacobs#include <errno.h>
355b4669e025ff377602b6fc7caaf30dbc218371jacobs
355b4669e025ff377602b6fc7caaf30dbc218371jacobs#include "http.h"
355b4669e025ff377602b6fc7caaf30dbc218371jacobs#include "debug.h"
355b4669e025ff377602b6fc7caaf30dbc218371jacobs
355b4669e025ff377602b6fc7caaf30dbc218371jacobs#ifndef WIN32
355b4669e025ff377602b6fc7caaf30dbc218371jacobs# include <signal.h>
355b4669e025ff377602b6fc7caaf30dbc218371jacobs# include <sys/time.h>
355b4669e025ff377602b6fc7caaf30dbc218371jacobs# include <sys/resource.h>
355b4669e025ff377602b6fc7caaf30dbc218371jacobs#endif /* !WIN32 */
355b4669e025ff377602b6fc7caaf30dbc218371jacobs
355b4669e025ff377602b6fc7caaf30dbc218371jacobs
355b4669e025ff377602b6fc7caaf30dbc218371jacobs/*
355b4669e025ff377602b6fc7caaf30dbc218371jacobs * Some operating systems have done away with the Fxxxx constants for
355b4669e025ff377602b6fc7caaf30dbc218371jacobs * the fcntl() call; this works around that "feature"...
355b4669e025ff377602b6fc7caaf30dbc218371jacobs */
355b4669e025ff377602b6fc7caaf30dbc218371jacobs
355b4669e025ff377602b6fc7caaf30dbc218371jacobs#ifndef FNONBLK
355b4669e025ff377602b6fc7caaf30dbc218371jacobs# define FNONBLK O_NONBLOCK
355b4669e025ff377602b6fc7caaf30dbc218371jacobs#endif /* !FNONBLK */
355b4669e025ff377602b6fc7caaf30dbc218371jacobs
355b4669e025ff377602b6fc7caaf30dbc218371jacobs
355b4669e025ff377602b6fc7caaf30dbc218371jacobs/*
355b4669e025ff377602b6fc7caaf30dbc218371jacobs * Local functions...
355b4669e025ff377602b6fc7caaf30dbc218371jacobs */
355b4669e025ff377602b6fc7caaf30dbc218371jacobs
355b4669e025ff377602b6fc7caaf30dbc218371jacobsstatic http_field_t http_field(const char *name);
355b4669e025ff377602b6fc7caaf30dbc218371jacobsstatic int http_send(http_t *http, http_state_t request,
355b4669e025ff377602b6fc7caaf30dbc218371jacobs const char *uri);
355b4669e025ff377602b6fc7caaf30dbc218371jacobsstatic int http_wait(http_t *http, int msec);
355b4669e025ff377602b6fc7caaf30dbc218371jacobs#ifdef HAVE_SSL
355b4669e025ff377602b6fc7caaf30dbc218371jacobsstatic int http_upgrade(http_t *http);
355b4669e025ff377602b6fc7caaf30dbc218371jacobsstatic int http_setup_ssl(http_t *http);
355b4669e025ff377602b6fc7caaf30dbc218371jacobsstatic void http_shutdown_ssl(http_t *http);
355b4669e025ff377602b6fc7caaf30dbc218371jacobsstatic int http_read_ssl(http_t *http, char *buf, int len);
355b4669e025ff377602b6fc7caaf30dbc218371jacobsstatic int http_write_ssl(http_t *http, const char *buf, int len);
355b4669e025ff377602b6fc7caaf30dbc218371jacobs# ifdef HAVE_CDSASSL
355b4669e025ff377602b6fc7caaf30dbc218371jacobsstatic OSStatus CDSAReadFunc(SSLConnectionRef connection, void *data, size_t *dataLength);
355b4669e025ff377602b6fc7caaf30dbc218371jacobsstatic OSStatus CDSAWriteFunc(SSLConnectionRef connection, const void *data, size_t *dataLength);
355b4669e025ff377602b6fc7caaf30dbc218371jacobs# endif /* HAVE_CDSASSL */
355b4669e025ff377602b6fc7caaf30dbc218371jacobs#endif /* HAVE_SSL */
355b4669e025ff377602b6fc7caaf30dbc218371jacobs
355b4669e025ff377602b6fc7caaf30dbc218371jacobs
355b4669e025ff377602b6fc7caaf30dbc218371jacobs/*
355b4669e025ff377602b6fc7caaf30dbc218371jacobs * Local globals...
355b4669e025ff377602b6fc7caaf30dbc218371jacobs */
355b4669e025ff377602b6fc7caaf30dbc218371jacobs
355b4669e025ff377602b6fc7caaf30dbc218371jacobsstatic const char * const http_fields[] =
355b4669e025ff377602b6fc7caaf30dbc218371jacobs {
355b4669e025ff377602b6fc7caaf30dbc218371jacobs "Accept-Language",
355b4669e025ff377602b6fc7caaf30dbc218371jacobs "Accept-Ranges",
355b4669e025ff377602b6fc7caaf30dbc218371jacobs "Authorization",
355b4669e025ff377602b6fc7caaf30dbc218371jacobs "Connection",
355b4669e025ff377602b6fc7caaf30dbc218371jacobs "Content-Encoding",
355b4669e025ff377602b6fc7caaf30dbc218371jacobs "Content-Language",
355b4669e025ff377602b6fc7caaf30dbc218371jacobs "Content-Length",
355b4669e025ff377602b6fc7caaf30dbc218371jacobs "Content-Location",
355b4669e025ff377602b6fc7caaf30dbc218371jacobs "Content-MD5",
355b4669e025ff377602b6fc7caaf30dbc218371jacobs "Content-Range",
355b4669e025ff377602b6fc7caaf30dbc218371jacobs "Content-Type",
355b4669e025ff377602b6fc7caaf30dbc218371jacobs "Content-Version",
355b4669e025ff377602b6fc7caaf30dbc218371jacobs "Date",
355b4669e025ff377602b6fc7caaf30dbc218371jacobs "Host",
355b4669e025ff377602b6fc7caaf30dbc218371jacobs "If-Modified-Since",
355b4669e025ff377602b6fc7caaf30dbc218371jacobs "If-Unmodified-since",
355b4669e025ff377602b6fc7caaf30dbc218371jacobs "Keep-Alive",
355b4669e025ff377602b6fc7caaf30dbc218371jacobs "Last-Modified",
355b4669e025ff377602b6fc7caaf30dbc218371jacobs "Link",
355b4669e025ff377602b6fc7caaf30dbc218371jacobs "Location",
355b4669e025ff377602b6fc7caaf30dbc218371jacobs "Range",
355b4669e025ff377602b6fc7caaf30dbc218371jacobs "Referer",
355b4669e025ff377602b6fc7caaf30dbc218371jacobs "Retry-After",
355b4669e025ff377602b6fc7caaf30dbc218371jacobs "Transfer-Encoding",
355b4669e025ff377602b6fc7caaf30dbc218371jacobs "Upgrade",
355b4669e025ff377602b6fc7caaf30dbc218371jacobs "User-Agent",
355b4669e025ff377602b6fc7caaf30dbc218371jacobs "WWW-Authenticate"
355b4669e025ff377602b6fc7caaf30dbc218371jacobs };
355b4669e025ff377602b6fc7caaf30dbc218371jacobsstatic const char * const days[7] =
355b4669e025ff377602b6fc7caaf30dbc218371jacobs {
355b4669e025ff377602b6fc7caaf30dbc218371jacobs "Sun",
355b4669e025ff377602b6fc7caaf30dbc218371jacobs "Mon",
355b4669e025ff377602b6fc7caaf30dbc218371jacobs "Tue",
355b4669e025ff377602b6fc7caaf30dbc218371jacobs "Wed",
355b4669e025ff377602b6fc7caaf30dbc218371jacobs "Thu",
355b4669e025ff377602b6fc7caaf30dbc218371jacobs "Fri",
355b4669e025ff377602b6fc7caaf30dbc218371jacobs "Sat"
355b4669e025ff377602b6fc7caaf30dbc218371jacobs };
355b4669e025ff377602b6fc7caaf30dbc218371jacobsstatic const char * const months[12] =
355b4669e025ff377602b6fc7caaf30dbc218371jacobs {
355b4669e025ff377602b6fc7caaf30dbc218371jacobs "Jan",
355b4669e025ff377602b6fc7caaf30dbc218371jacobs "Feb",
355b4669e025ff377602b6fc7caaf30dbc218371jacobs "Mar",
355b4669e025ff377602b6fc7caaf30dbc218371jacobs "Apr",
355b4669e025ff377602b6fc7caaf30dbc218371jacobs "May",
355b4669e025ff377602b6fc7caaf30dbc218371jacobs "Jun",
355b4669e025ff377602b6fc7caaf30dbc218371jacobs "Jul",
355b4669e025ff377602b6fc7caaf30dbc218371jacobs "Aug",
355b4669e025ff377602b6fc7caaf30dbc218371jacobs "Sep",
355b4669e025ff377602b6fc7caaf30dbc218371jacobs "Oct",
355b4669e025ff377602b6fc7caaf30dbc218371jacobs "Nov",
355b4669e025ff377602b6fc7caaf30dbc218371jacobs "Dec"
355b4669e025ff377602b6fc7caaf30dbc218371jacobs };
355b4669e025ff377602b6fc7caaf30dbc218371jacobs
355b4669e025ff377602b6fc7caaf30dbc218371jacobsvoid
355b4669e025ff377602b6fc7caaf30dbc218371jacobshttpDumpData(FILE *fp, char *tag, char *buffer, int bytes)
355b4669e025ff377602b6fc7caaf30dbc218371jacobs{
355b4669e025ff377602b6fc7caaf30dbc218371jacobs int i, j, ch;
355b4669e025ff377602b6fc7caaf30dbc218371jacobs
355b4669e025ff377602b6fc7caaf30dbc218371jacobs fprintf(fp, "%s %d(0x%x) bytes...\n", tag, bytes, bytes);
355b4669e025ff377602b6fc7caaf30dbc218371jacobs for (i = 0; i < bytes; i += 16) {
355b4669e025ff377602b6fc7caaf30dbc218371jacobs fprintf(fp, "%s ", (tag ? tag : ""));
355b4669e025ff377602b6fc7caaf30dbc218371jacobs
355b4669e025ff377602b6fc7caaf30dbc218371jacobs for (j = 0; j < 16 && (i + j) < bytes; j ++)
355b4669e025ff377602b6fc7caaf30dbc218371jacobs fprintf(fp, " %02X", buffer[i + j] & 255);
355b4669e025ff377602b6fc7caaf30dbc218371jacobs
355b4669e025ff377602b6fc7caaf30dbc218371jacobs while (j < 16) {
355b4669e025ff377602b6fc7caaf30dbc218371jacobs fprintf(fp, " ");
355b4669e025ff377602b6fc7caaf30dbc218371jacobs j++;
355b4669e025ff377602b6fc7caaf30dbc218371jacobs }
355b4669e025ff377602b6fc7caaf30dbc218371jacobs
355b4669e025ff377602b6fc7caaf30dbc218371jacobs fprintf(fp, " ");
355b4669e025ff377602b6fc7caaf30dbc218371jacobs for (j = 0; j < 16 && (i + j) < bytes; j ++) {
355b4669e025ff377602b6fc7caaf30dbc218371jacobs ch = buffer[i + j] & 255;
355b4669e025ff377602b6fc7caaf30dbc218371jacobs if (ch < ' ' || ch == 127)
355b4669e025ff377602b6fc7caaf30dbc218371jacobs ch = '.';
355b4669e025ff377602b6fc7caaf30dbc218371jacobs putc(ch, fp);
355b4669e025ff377602b6fc7caaf30dbc218371jacobs }
355b4669e025ff377602b6fc7caaf30dbc218371jacobs putc('\n', fp);
355b4669e025ff377602b6fc7caaf30dbc218371jacobs }
355b4669e025ff377602b6fc7caaf30dbc218371jacobs}
355b4669e025ff377602b6fc7caaf30dbc218371jacobs
355b4669e025ff377602b6fc7caaf30dbc218371jacobs
355b4669e025ff377602b6fc7caaf30dbc218371jacobs/*
355b4669e025ff377602b6fc7caaf30dbc218371jacobs * 'httpInitialize()' - Initialize the HTTP interface library and set the
355b4669e025ff377602b6fc7caaf30dbc218371jacobs * default HTTP proxy (if any).
355b4669e025ff377602b6fc7caaf30dbc218371jacobs */
355b4669e025ff377602b6fc7caaf30dbc218371jacobs
355b4669e025ff377602b6fc7caaf30dbc218371jacobsvoid
355b4669e025ff377602b6fc7caaf30dbc218371jacobshttpInitialize(void)
355b4669e025ff377602b6fc7caaf30dbc218371jacobs{
355b4669e025ff377602b6fc7caaf30dbc218371jacobs#ifdef HAVE_LIBSSL
355b4669e025ff377602b6fc7caaf30dbc218371jacobs# ifndef WIN32
355b4669e025ff377602b6fc7caaf30dbc218371jacobs struct timeval curtime; /* Current time in microseconds */
355b4669e025ff377602b6fc7caaf30dbc218371jacobs# endif /* !WIN32 */
355b4669e025ff377602b6fc7caaf30dbc218371jacobs int i; /* Looping var */
355b4669e025ff377602b6fc7caaf30dbc218371jacobs unsigned char data[1024]; /* Seed data */
355b4669e025ff377602b6fc7caaf30dbc218371jacobs#endif /* HAVE_LIBSSL */
355b4669e025ff377602b6fc7caaf30dbc218371jacobs
355b4669e025ff377602b6fc7caaf30dbc218371jacobs#ifdef WIN32
355b4669e025ff377602b6fc7caaf30dbc218371jacobs WSADATA winsockdata; /* WinSock data */
355b4669e025ff377602b6fc7caaf30dbc218371jacobs static int initialized = 0; /* Has WinSock been initialized? */
355b4669e025ff377602b6fc7caaf30dbc218371jacobs
355b4669e025ff377602b6fc7caaf30dbc218371jacobs
355b4669e025ff377602b6fc7caaf30dbc218371jacobs if (!initialized)
355b4669e025ff377602b6fc7caaf30dbc218371jacobs WSAStartup(MAKEWORD(1,1), &winsockdata);
355b4669e025ff377602b6fc7caaf30dbc218371jacobs#elif defined(HAVE_SIGSET)
355b4669e025ff377602b6fc7caaf30dbc218371jacobs sigset(SIGPIPE, SIG_IGN);
355b4669e025ff377602b6fc7caaf30dbc218371jacobs#elif defined(HAVE_SIGACTION)
355b4669e025ff377602b6fc7caaf30dbc218371jacobs struct sigaction action; /* POSIX sigaction data */
355b4669e025ff377602b6fc7caaf30dbc218371jacobs
355b4669e025ff377602b6fc7caaf30dbc218371jacobs
355b4669e025ff377602b6fc7caaf30dbc218371jacobs /*
355b4669e025ff377602b6fc7caaf30dbc218371jacobs * Ignore SIGPIPE signals...
355b4669e025ff377602b6fc7caaf30dbc218371jacobs */
355b4669e025ff377602b6fc7caaf30dbc218371jacobs
355b4669e025ff377602b6fc7caaf30dbc218371jacobs memset(&action, 0, sizeof(action));
355b4669e025ff377602b6fc7caaf30dbc218371jacobs action.sa_handler = SIG_IGN;
355b4669e025ff377602b6fc7caaf30dbc218371jacobs sigaction(SIGPIPE, &action, NULL);
355b4669e025ff377602b6fc7caaf30dbc218371jacobs#else
355b4669e025ff377602b6fc7caaf30dbc218371jacobs signal(SIGPIPE, SIG_IGN);
355b4669e025ff377602b6fc7caaf30dbc218371jacobs#endif /* WIN32 */
355b4669e025ff377602b6fc7caaf30dbc218371jacobs
355b4669e025ff377602b6fc7caaf30dbc218371jacobs#ifdef HAVE_GNUTLS
355b4669e025ff377602b6fc7caaf30dbc218371jacobs gnutls_global_init();
355b4669e025ff377602b6fc7caaf30dbc218371jacobs#endif /* HAVE_GNUTLS */
355b4669e025ff377602b6fc7caaf30dbc218371jacobs
355b4669e025ff377602b6fc7caaf30dbc218371jacobs#ifdef HAVE_LIBSSL
355b4669e025ff377602b6fc7caaf30dbc218371jacobs SSL_load_error_strings();
355b4669e025ff377602b6fc7caaf30dbc218371jacobs SSL_library_init();
355b4669e025ff377602b6fc7caaf30dbc218371jacobs
355b4669e025ff377602b6fc7caaf30dbc218371jacobs /*
355b4669e025ff377602b6fc7caaf30dbc218371jacobs * Using the current time is a dubious random seed, but on some systems
355b4669e025ff377602b6fc7caaf30dbc218371jacobs * it is the best we can do (on others, this seed isn't even used...)
355b4669e025ff377602b6fc7caaf30dbc218371jacobs */
355b4669e025ff377602b6fc7caaf30dbc218371jacobs
355b4669e025ff377602b6fc7caaf30dbc218371jacobs#ifdef WIN32
355b4669e025ff377602b6fc7caaf30dbc218371jacobs#else
355b4669e025ff377602b6fc7caaf30dbc218371jacobs gettimeofday(&curtime, NULL);
355b4669e025ff377602b6fc7caaf30dbc218371jacobs srand(curtime.tv_sec + curtime.tv_usec);
355b4669e025ff377602b6fc7caaf30dbc218371jacobs#endif /* WIN32 */
355b4669e025ff377602b6fc7caaf30dbc218371jacobs
355b4669e025ff377602b6fc7caaf30dbc218371jacobs for (i = 0; i < sizeof(data); i ++)
355b4669e025ff377602b6fc7caaf30dbc218371jacobs data[i] = rand(); /* Yes, this is a poor source of random data... */
355b4669e025ff377602b6fc7caaf30dbc218371jacobs
355b4669e025ff377602b6fc7caaf30dbc218371jacobs RAND_seed(&data, sizeof(data));
355b4669e025ff377602b6fc7caaf30dbc218371jacobs#endif /* HAVE_LIBSSL */
355b4669e025ff377602b6fc7caaf30dbc218371jacobs}
355b4669e025ff377602b6fc7caaf30dbc218371jacobs
355b4669e025ff377602b6fc7caaf30dbc218371jacobs
355b4669e025ff377602b6fc7caaf30dbc218371jacobs/*
355b4669e025ff377602b6fc7caaf30dbc218371jacobs * 'httpCheck()' - Check to see if there is a pending response from the server.
355b4669e025ff377602b6fc7caaf30dbc218371jacobs */
355b4669e025ff377602b6fc7caaf30dbc218371jacobs
355b4669e025ff377602b6fc7caaf30dbc218371jacobsint /* O - 0 = no data, 1 = data available */
355b4669e025ff377602b6fc7caaf30dbc218371jacobshttpCheck(http_t *http) /* I - HTTP connection */
355b4669e025ff377602b6fc7caaf30dbc218371jacobs{
355b4669e025ff377602b6fc7caaf30dbc218371jacobs return (httpWait(http, 0));
355b4669e025ff377602b6fc7caaf30dbc218371jacobs}
355b4669e025ff377602b6fc7caaf30dbc218371jacobs
355b4669e025ff377602b6fc7caaf30dbc218371jacobs
355b4669e025ff377602b6fc7caaf30dbc218371jacobs/*
355b4669e025ff377602b6fc7caaf30dbc218371jacobs * 'httpClearCookie()' - Clear the cookie value(s).
355b4669e025ff377602b6fc7caaf30dbc218371jacobs */
355b4669e025ff377602b6fc7caaf30dbc218371jacobs
355b4669e025ff377602b6fc7caaf30dbc218371jacobsvoid
355b4669e025ff377602b6fc7caaf30dbc218371jacobshttpClearCookie(http_t *http) /* I - Connection */
355b4669e025ff377602b6fc7caaf30dbc218371jacobs{
355b4669e025ff377602b6fc7caaf30dbc218371jacobs if (!http)
355b4669e025ff377602b6fc7caaf30dbc218371jacobs return;
355b4669e025ff377602b6fc7caaf30dbc218371jacobs
355b4669e025ff377602b6fc7caaf30dbc218371jacobs if (http->cookie)
355b4669e025ff377602b6fc7caaf30dbc218371jacobs {
355b4669e025ff377602b6fc7caaf30dbc218371jacobs free(http->cookie);
355b4669e025ff377602b6fc7caaf30dbc218371jacobs http->cookie = NULL;
355b4669e025ff377602b6fc7caaf30dbc218371jacobs }
355b4669e025ff377602b6fc7caaf30dbc218371jacobs}
355b4669e025ff377602b6fc7caaf30dbc218371jacobs
355b4669e025ff377602b6fc7caaf30dbc218371jacobs
355b4669e025ff377602b6fc7caaf30dbc218371jacobs/*
355b4669e025ff377602b6fc7caaf30dbc218371jacobs * 'httpClose()' - Close an HTTP connection...
355b4669e025ff377602b6fc7caaf30dbc218371jacobs */
355b4669e025ff377602b6fc7caaf30dbc218371jacobs
355b4669e025ff377602b6fc7caaf30dbc218371jacobsvoid
355b4669e025ff377602b6fc7caaf30dbc218371jacobshttpClose(http_t *http) /* I - Connection to close */
355b4669e025ff377602b6fc7caaf30dbc218371jacobs{
355b4669e025ff377602b6fc7caaf30dbc218371jacobs DEBUG_printf(("httpClose(http=%p)\n", http));
355b4669e025ff377602b6fc7caaf30dbc218371jacobs
355b4669e025ff377602b6fc7caaf30dbc218371jacobs if (!http)
355b4669e025ff377602b6fc7caaf30dbc218371jacobs return;
355b4669e025ff377602b6fc7caaf30dbc218371jacobs
355b4669e025ff377602b6fc7caaf30dbc218371jacobs if (http->input_set)
355b4669e025ff377602b6fc7caaf30dbc218371jacobs free(http->input_set);
355b4669e025ff377602b6fc7caaf30dbc218371jacobs
355b4669e025ff377602b6fc7caaf30dbc218371jacobs if (http->cookie)
355b4669e025ff377602b6fc7caaf30dbc218371jacobs free(http->cookie);
355b4669e025ff377602b6fc7caaf30dbc218371jacobs
355b4669e025ff377602b6fc7caaf30dbc218371jacobs#ifdef HAVE_SSL
355b4669e025ff377602b6fc7caaf30dbc218371jacobs if (http->tls)
355b4669e025ff377602b6fc7caaf30dbc218371jacobs http_shutdown_ssl(http);
355b4669e025ff377602b6fc7caaf30dbc218371jacobs#endif /* HAVE_SSL */
355b4669e025ff377602b6fc7caaf30dbc218371jacobs
355b4669e025ff377602b6fc7caaf30dbc218371jacobs#ifdef WIN32
355b4669e025ff377602b6fc7caaf30dbc218371jacobs closesocket(http->fd);
355b4669e025ff377602b6fc7caaf30dbc218371jacobs#else
355b4669e025ff377602b6fc7caaf30dbc218371jacobs close(http->fd);
355b4669e025ff377602b6fc7caaf30dbc218371jacobs#endif /* WIN32 */
355b4669e025ff377602b6fc7caaf30dbc218371jacobs
355b4669e025ff377602b6fc7caaf30dbc218371jacobs free(http);
355b4669e025ff377602b6fc7caaf30dbc218371jacobs}
355b4669e025ff377602b6fc7caaf30dbc218371jacobs
355b4669e025ff377602b6fc7caaf30dbc218371jacobs
355b4669e025ff377602b6fc7caaf30dbc218371jacobs/*
355b4669e025ff377602b6fc7caaf30dbc218371jacobs * 'httpConnect()' - Connect to a HTTP server.
355b4669e025ff377602b6fc7caaf30dbc218371jacobs */
355b4669e025ff377602b6fc7caaf30dbc218371jacobs
355b4669e025ff377602b6fc7caaf30dbc218371jacobshttp_t * /* O - New HTTP connection */
355b4669e025ff377602b6fc7caaf30dbc218371jacobshttpConnect(const char *host, /* I - Host to connect to */
355b4669e025ff377602b6fc7caaf30dbc218371jacobs int port) /* I - Port number */
355b4669e025ff377602b6fc7caaf30dbc218371jacobs{
355b4669e025ff377602b6fc7caaf30dbc218371jacobs http_encryption_t encrypt; /* Type of encryption to use */
355b4669e025ff377602b6fc7caaf30dbc218371jacobs
355b4669e025ff377602b6fc7caaf30dbc218371jacobs
355b4669e025ff377602b6fc7caaf30dbc218371jacobs /*
355b4669e025ff377602b6fc7caaf30dbc218371jacobs * Set the default encryption status...
355b4669e025ff377602b6fc7caaf30dbc218371jacobs */
355b4669e025ff377602b6fc7caaf30dbc218371jacobs
355b4669e025ff377602b6fc7caaf30dbc218371jacobs if (port == 443)
355b4669e025ff377602b6fc7caaf30dbc218371jacobs encrypt = HTTP_ENCRYPT_ALWAYS;
355b4669e025ff377602b6fc7caaf30dbc218371jacobs else
355b4669e025ff377602b6fc7caaf30dbc218371jacobs encrypt = HTTP_ENCRYPT_IF_REQUESTED;
355b4669e025ff377602b6fc7caaf30dbc218371jacobs
355b4669e025ff377602b6fc7caaf30dbc218371jacobs return (httpConnectEncrypt(host, port, encrypt));
355b4669e025ff377602b6fc7caaf30dbc218371jacobs}
355b4669e025ff377602b6fc7caaf30dbc218371jacobs
355b4669e025ff377602b6fc7caaf30dbc218371jacobs
355b4669e025ff377602b6fc7caaf30dbc218371jacobs/*
355b4669e025ff377602b6fc7caaf30dbc218371jacobs * 'httpConnectEncrypt()' - Connect to a HTTP server using encryption.
355b4669e025ff377602b6fc7caaf30dbc218371jacobs */
355b4669e025ff377602b6fc7caaf30dbc218371jacobs
355b4669e025ff377602b6fc7caaf30dbc218371jacobshttp_t * /* O - New HTTP connection */
355b4669e025ff377602b6fc7caaf30dbc218371jacobshttpConnectEncrypt(const char *host, /* I - Host to connect to */
355b4669e025ff377602b6fc7caaf30dbc218371jacobs int port, /* I - Port number */
355b4669e025ff377602b6fc7caaf30dbc218371jacobs http_encryption_t encrypt)
355b4669e025ff377602b6fc7caaf30dbc218371jacobs /* I - Type of encryption to use */
355b4669e025ff377602b6fc7caaf30dbc218371jacobs{
355b4669e025ff377602b6fc7caaf30dbc218371jacobs int i; /* Looping var */
355b4669e025ff377602b6fc7caaf30dbc218371jacobs http_t *http; /* New HTTP connection */
355b4669e025ff377602b6fc7caaf30dbc218371jacobs struct hostent *hostaddr; /* Host address data */
355b4669e025ff377602b6fc7caaf30dbc218371jacobs
355b4669e025ff377602b6fc7caaf30dbc218371jacobs
355b4669e025ff377602b6fc7caaf30dbc218371jacobs DEBUG_printf(("httpConnectEncrypt(host=\"%s\", port=%d, encrypt=%d)\n",
355b4669e025ff377602b6fc7caaf30dbc218371jacobs host ? host : "(null)", port, encrypt));
355b4669e025ff377602b6fc7caaf30dbc218371jacobs
355b4669e025ff377602b6fc7caaf30dbc218371jacobs if (!host)
355b4669e025ff377602b6fc7caaf30dbc218371jacobs return (NULL);
355b4669e025ff377602b6fc7caaf30dbc218371jacobs
355b4669e025ff377602b6fc7caaf30dbc218371jacobs httpInitialize();
355b4669e025ff377602b6fc7caaf30dbc218371jacobs
355b4669e025ff377602b6fc7caaf30dbc218371jacobs /*
355b4669e025ff377602b6fc7caaf30dbc218371jacobs * Lookup the host...
355b4669e025ff377602b6fc7caaf30dbc218371jacobs */
355b4669e025ff377602b6fc7caaf30dbc218371jacobs
355b4669e025ff377602b6fc7caaf30dbc218371jacobs if ((hostaddr = httpGetHostByName(host)) == NULL)
355b4669e025ff377602b6fc7caaf30dbc218371jacobs {
355b4669e025ff377602b6fc7caaf30dbc218371jacobs /*
355b4669e025ff377602b6fc7caaf30dbc218371jacobs * This hack to make users that don't have a localhost entry in
355b4669e025ff377602b6fc7caaf30dbc218371jacobs * their hosts file or DNS happy...
355b4669e025ff377602b6fc7caaf30dbc218371jacobs */
355b4669e025ff377602b6fc7caaf30dbc218371jacobs
355b4669e025ff377602b6fc7caaf30dbc218371jacobs if (strcasecmp(host, "localhost") != 0)
355b4669e025ff377602b6fc7caaf30dbc218371jacobs return (NULL);
355b4669e025ff377602b6fc7caaf30dbc218371jacobs else if ((hostaddr = httpGetHostByName("127.0.0.1")) == NULL)
355b4669e025ff377602b6fc7caaf30dbc218371jacobs return (NULL);
355b4669e025ff377602b6fc7caaf30dbc218371jacobs }
355b4669e025ff377602b6fc7caaf30dbc218371jacobs
355b4669e025ff377602b6fc7caaf30dbc218371jacobs /*
355b4669e025ff377602b6fc7caaf30dbc218371jacobs * Verify that it is an IPv4, IPv6, or domain address...
355b4669e025ff377602b6fc7caaf30dbc218371jacobs */
355b4669e025ff377602b6fc7caaf30dbc218371jacobs
355b4669e025ff377602b6fc7caaf30dbc218371jacobs if ((hostaddr->h_addrtype != AF_INET || hostaddr->h_length != 4)
355b4669e025ff377602b6fc7caaf30dbc218371jacobs#ifdef AF_INET6
355b4669e025ff377602b6fc7caaf30dbc218371jacobs && (hostaddr->h_addrtype != AF_INET6 || hostaddr->h_length != 16)
355b4669e025ff377602b6fc7caaf30dbc218371jacobs#endif /* AF_INET6 */
355b4669e025ff377602b6fc7caaf30dbc218371jacobs#ifdef AF_LOCAL
355b4669e025ff377602b6fc7caaf30dbc218371jacobs && (hostaddr->h_addrtype != AF_LOCAL)
355b4669e025ff377602b6fc7caaf30dbc218371jacobs#endif /* AF_LOCAL */
355b4669e025ff377602b6fc7caaf30dbc218371jacobs )
355b4669e025ff377602b6fc7caaf30dbc218371jacobs return (NULL);
355b4669e025ff377602b6fc7caaf30dbc218371jacobs
355b4669e025ff377602b6fc7caaf30dbc218371jacobs /*
355b4669e025ff377602b6fc7caaf30dbc218371jacobs * Allocate memory for the structure...
355b4669e025ff377602b6fc7caaf30dbc218371jacobs */
355b4669e025ff377602b6fc7caaf30dbc218371jacobs
355b4669e025ff377602b6fc7caaf30dbc218371jacobs http = calloc(sizeof(http_t), 1);
355b4669e025ff377602b6fc7caaf30dbc218371jacobs if (http == NULL)
355b4669e025ff377602b6fc7caaf30dbc218371jacobs return (NULL);
355b4669e025ff377602b6fc7caaf30dbc218371jacobs
355b4669e025ff377602b6fc7caaf30dbc218371jacobs http->version = HTTP_1_1;
355b4669e025ff377602b6fc7caaf30dbc218371jacobs http->blocking = 1;
355b4669e025ff377602b6fc7caaf30dbc218371jacobs http->activity = time(NULL);
355b4669e025ff377602b6fc7caaf30dbc218371jacobs http->fd = -1;
355b4669e025ff377602b6fc7caaf30dbc218371jacobs
355b4669e025ff377602b6fc7caaf30dbc218371jacobs /*
355b4669e025ff377602b6fc7caaf30dbc218371jacobs * Set the encryption status...
355b4669e025ff377602b6fc7caaf30dbc218371jacobs */
355b4669e025ff377602b6fc7caaf30dbc218371jacobs
355b4669e025ff377602b6fc7caaf30dbc218371jacobs if (port == 443) /* Always use encryption for https */
355b4669e025ff377602b6fc7caaf30dbc218371jacobs http->encryption = HTTP_ENCRYPT_ALWAYS;
355b4669e025ff377602b6fc7caaf30dbc218371jacobs else
355b4669e025ff377602b6fc7caaf30dbc218371jacobs http->encryption = encrypt;
355b4669e025ff377602b6fc7caaf30dbc218371jacobs
355b4669e025ff377602b6fc7caaf30dbc218371jacobs /*
355b4669e025ff377602b6fc7caaf30dbc218371jacobs * Loop through the addresses we have until one of them connects...
355b4669e025ff377602b6fc7caaf30dbc218371jacobs */
355b4669e025ff377602b6fc7caaf30dbc218371jacobs
355b4669e025ff377602b6fc7caaf30dbc218371jacobs strlcpy(http->hostname, host, sizeof(http->hostname));
355b4669e025ff377602b6fc7caaf30dbc218371jacobs
355b4669e025ff377602b6fc7caaf30dbc218371jacobs for (i = 0; hostaddr->h_addr_list[i]; i ++)
355b4669e025ff377602b6fc7caaf30dbc218371jacobs {
355b4669e025ff377602b6fc7caaf30dbc218371jacobs /*
355b4669e025ff377602b6fc7caaf30dbc218371jacobs * Load the address...
355b4669e025ff377602b6fc7caaf30dbc218371jacobs */
355b4669e025ff377602b6fc7caaf30dbc218371jacobs
355b4669e025ff377602b6fc7caaf30dbc218371jacobs httpAddrLoad(hostaddr, port, i, &(http->hostaddr));
355b4669e025ff377602b6fc7caaf30dbc218371jacobs
355b4669e025ff377602b6fc7caaf30dbc218371jacobs /*
355b4669e025ff377602b6fc7caaf30dbc218371jacobs * Connect to the remote system...
355b4669e025ff377602b6fc7caaf30dbc218371jacobs */
355b4669e025ff377602b6fc7caaf30dbc218371jacobs
355b4669e025ff377602b6fc7caaf30dbc218371jacobs if (!httpReconnect(http))
355b4669e025ff377602b6fc7caaf30dbc218371jacobs return (http);
355b4669e025ff377602b6fc7caaf30dbc218371jacobs }
355b4669e025ff377602b6fc7caaf30dbc218371jacobs
355b4669e025ff377602b6fc7caaf30dbc218371jacobs /*
355b4669e025ff377602b6fc7caaf30dbc218371jacobs * Could not connect to any known address - bail out!
355b4669e025ff377602b6fc7caaf30dbc218371jacobs */
355b4669e025ff377602b6fc7caaf30dbc218371jacobs
355b4669e025ff377602b6fc7caaf30dbc218371jacobs free(http);
355b4669e025ff377602b6fc7caaf30dbc218371jacobs return (NULL);
355b4669e025ff377602b6fc7caaf30dbc218371jacobs}
355b4669e025ff377602b6fc7caaf30dbc218371jacobs
355b4669e025ff377602b6fc7caaf30dbc218371jacobs
355b4669e025ff377602b6fc7caaf30dbc218371jacobs/*
355b4669e025ff377602b6fc7caaf30dbc218371jacobs * 'httpEncryption()' - Set the required encryption on the link.
355b4669e025ff377602b6fc7caaf30dbc218371jacobs */
355b4669e025ff377602b6fc7caaf30dbc218371jacobs
355b4669e025ff377602b6fc7caaf30dbc218371jacobsint /* O - -1 on error, 0 on success */
355b4669e025ff377602b6fc7caaf30dbc218371jacobshttpEncryption(http_t *http, /* I - HTTP data */
355b4669e025ff377602b6fc7caaf30dbc218371jacobs http_encryption_t e) /* I - New encryption preference */
355b4669e025ff377602b6fc7caaf30dbc218371jacobs{
355b4669e025ff377602b6fc7caaf30dbc218371jacobs DEBUG_printf(("httpEncryption(http=%p, e=%d)\n", http, e));
355b4669e025ff377602b6fc7caaf30dbc218371jacobs
355b4669e025ff377602b6fc7caaf30dbc218371jacobs#ifdef HAVE_SSL
355b4669e025ff377602b6fc7caaf30dbc218371jacobs if (!http)
355b4669e025ff377602b6fc7caaf30dbc218371jacobs return (0);
355b4669e025ff377602b6fc7caaf30dbc218371jacobs
355b4669e025ff377602b6fc7caaf30dbc218371jacobs http->encryption = e;
355b4669e025ff377602b6fc7caaf30dbc218371jacobs
355b4669e025ff377602b6fc7caaf30dbc218371jacobs if ((http->encryption == HTTP_ENCRYPT_ALWAYS && !http->tls) ||
355b4669e025ff377602b6fc7caaf30dbc218371jacobs (http->encryption == HTTP_ENCRYPT_NEVER && http->tls))
355b4669e025ff377602b6fc7caaf30dbc218371jacobs return (httpReconnect(http));
355b4669e025ff377602b6fc7caaf30dbc218371jacobs else if (http->encryption == HTTP_ENCRYPT_REQUIRED && !http->tls)
355b4669e025ff377602b6fc7caaf30dbc218371jacobs return (http_upgrade(http));
355b4669e025ff377602b6fc7caaf30dbc218371jacobs else
355b4669e025ff377602b6fc7caaf30dbc218371jacobs return (0);
355b4669e025ff377602b6fc7caaf30dbc218371jacobs#else
355b4669e025ff377602b6fc7caaf30dbc218371jacobs if (e == HTTP_ENCRYPT_ALWAYS || e == HTTP_ENCRYPT_REQUIRED)
355b4669e025ff377602b6fc7caaf30dbc218371jacobs return (-1);
355b4669e025ff377602b6fc7caaf30dbc218371jacobs else
355b4669e025ff377602b6fc7caaf30dbc218371jacobs return (0);
355b4669e025ff377602b6fc7caaf30dbc218371jacobs#endif /* HAVE_SSL */
355b4669e025ff377602b6fc7caaf30dbc218371jacobs}
355b4669e025ff377602b6fc7caaf30dbc218371jacobs
355b4669e025ff377602b6fc7caaf30dbc218371jacobs
355b4669e025ff377602b6fc7caaf30dbc218371jacobs/*
355b4669e025ff377602b6fc7caaf30dbc218371jacobs * 'httpReconnect()' - Reconnect to a HTTP server...
355b4669e025ff377602b6fc7caaf30dbc218371jacobs */
355b4669e025ff377602b6fc7caaf30dbc218371jacobs
355b4669e025ff377602b6fc7caaf30dbc218371jacobsint /* O - 0 on success, non-zero on failure */
355b4669e025ff377602b6fc7caaf30dbc218371jacobshttpReconnect(http_t *http) /* I - HTTP data */
355b4669e025ff377602b6fc7caaf30dbc218371jacobs{
355b4669e025ff377602b6fc7caaf30dbc218371jacobs int val; /* Socket option value */
355b4669e025ff377602b6fc7caaf30dbc218371jacobs int status; /* Connect status */
355b4669e025ff377602b6fc7caaf30dbc218371jacobs
355b4669e025ff377602b6fc7caaf30dbc218371jacobs
355b4669e025ff377602b6fc7caaf30dbc218371jacobs DEBUG_printf(("httpReconnect(http=%p)\n", http));
355b4669e025ff377602b6fc7caaf30dbc218371jacobs
355b4669e025ff377602b6fc7caaf30dbc218371jacobs if (!http)
355b4669e025ff377602b6fc7caaf30dbc218371jacobs return (-1);
355b4669e025ff377602b6fc7caaf30dbc218371jacobs
355b4669e025ff377602b6fc7caaf30dbc218371jacobs#ifdef HAVE_SSL
355b4669e025ff377602b6fc7caaf30dbc218371jacobs if (http->tls)
355b4669e025ff377602b6fc7caaf30dbc218371jacobs http_shutdown_ssl(http);
355b4669e025ff377602b6fc7caaf30dbc218371jacobs#endif /* HAVE_SSL */
355b4669e025ff377602b6fc7caaf30dbc218371jacobs
355b4669e025ff377602b6fc7caaf30dbc218371jacobs /*
355b4669e025ff377602b6fc7caaf30dbc218371jacobs * Close any previously open socket...
355b4669e025ff377602b6fc7caaf30dbc218371jacobs */
355b4669e025ff377602b6fc7caaf30dbc218371jacobs
355b4669e025ff377602b6fc7caaf30dbc218371jacobs if (http->fd >= 0)
355b4669e025ff377602b6fc7caaf30dbc218371jacobs#ifdef WIN32
355b4669e025ff377602b6fc7caaf30dbc218371jacobs closesocket(http->fd);
355b4669e025ff377602b6fc7caaf30dbc218371jacobs#else
355b4669e025ff377602b6fc7caaf30dbc218371jacobs close(http->fd);
355b4669e025ff377602b6fc7caaf30dbc218371jacobs#endif /* WIN32 */
355b4669e025ff377602b6fc7caaf30dbc218371jacobs
355b4669e025ff377602b6fc7caaf30dbc218371jacobs /*
355b4669e025ff377602b6fc7caaf30dbc218371jacobs * Create the socket and set options to allow reuse.
355b4669e025ff377602b6fc7caaf30dbc218371jacobs */
355b4669e025ff377602b6fc7caaf30dbc218371jacobs
355b4669e025ff377602b6fc7caaf30dbc218371jacobs if ((http->fd = socket(http->hostaddr.addr.sa_family, SOCK_STREAM, 0)) < 0)
355b4669e025ff377602b6fc7caaf30dbc218371jacobs {
355b4669e025ff377602b6fc7caaf30dbc218371jacobs#ifdef WIN32
355b4669e025ff377602b6fc7caaf30dbc218371jacobs http->error = WSAGetLastError();
355b4669e025ff377602b6fc7caaf30dbc218371jacobs#else
355b4669e025ff377602b6fc7caaf30dbc218371jacobs http->error = errno;
355b4669e025ff377602b6fc7caaf30dbc218371jacobs#endif /* WIN32 */
355b4669e025ff377602b6fc7caaf30dbc218371jacobs http->status = HTTP_ERROR;
355b4669e025ff377602b6fc7caaf30dbc218371jacobs return (-1);
355b4669e025ff377602b6fc7caaf30dbc218371jacobs }
355b4669e025ff377602b6fc7caaf30dbc218371jacobs
355b4669e025ff377602b6fc7caaf30dbc218371jacobs#ifdef FD_CLOEXEC
355b4669e025ff377602b6fc7caaf30dbc218371jacobs fcntl(http->fd, F_SETFD, FD_CLOEXEC); /* Close this socket when starting *
355b4669e025ff377602b6fc7caaf30dbc218371jacobs * other processes... */
355b4669e025ff377602b6fc7caaf30dbc218371jacobs#endif /* FD_CLOEXEC */
355b4669e025ff377602b6fc7caaf30dbc218371jacobs
355b4669e025ff377602b6fc7caaf30dbc218371jacobs val = 1;
355b4669e025ff377602b6fc7caaf30dbc218371jacobs setsockopt(http->fd, SOL_SOCKET, SO_REUSEADDR, (char *)&val, sizeof(val));
355b4669e025ff377602b6fc7caaf30dbc218371jacobs
355b4669e025ff377602b6fc7caaf30dbc218371jacobs#ifdef SO_REUSEPORT
355b4669e025ff377602b6fc7caaf30dbc218371jacobs val = 1;
355b4669e025ff377602b6fc7caaf30dbc218371jacobs setsockopt(http->fd, SOL_SOCKET, SO_REUSEPORT, &val, sizeof(val));
355b4669e025ff377602b6fc7caaf30dbc218371jacobs#endif /* SO_REUSEPORT */
355b4669e025ff377602b6fc7caaf30dbc218371jacobs
355b4669e025ff377602b6fc7caaf30dbc218371jacobs /*
355b4669e025ff377602b6fc7caaf30dbc218371jacobs * Using TCP_NODELAY improves responsiveness, especially on systems
355b4669e025ff377602b6fc7caaf30dbc218371jacobs * with a slow loopback interface... Since we write large buffers
355b4669e025ff377602b6fc7caaf30dbc218371jacobs * when sending print files and requests, there shouldn't be any
355b4669e025ff377602b6fc7caaf30dbc218371jacobs * performance penalty for this...
355b4669e025ff377602b6fc7caaf30dbc218371jacobs */
355b4669e025ff377602b6fc7caaf30dbc218371jacobs
355b4669e025ff377602b6fc7caaf30dbc218371jacobs val = 1;
355b4669e025ff377602b6fc7caaf30dbc218371jacobs#ifdef WIN32
355b4669e025ff377602b6fc7caaf30dbc218371jacobs setsockopt(http->fd, IPPROTO_TCP, TCP_NODELAY, (char *)&val, sizeof(val));
355b4669e025ff377602b6fc7caaf30dbc218371jacobs#else
355b4669e025ff377602b6fc7caaf30dbc218371jacobs setsockopt(http->fd, IPPROTO_TCP, TCP_NODELAY, &val, sizeof(val));
355b4669e025ff377602b6fc7caaf30dbc218371jacobs#endif /* WIN32 */
355b4669e025ff377602b6fc7caaf30dbc218371jacobs
355b4669e025ff377602b6fc7caaf30dbc218371jacobs /*
355b4669e025ff377602b6fc7caaf30dbc218371jacobs * Connect to the server...
355b4669e025ff377602b6fc7caaf30dbc218371jacobs */
355b4669e025ff377602b6fc7caaf30dbc218371jacobs
355b4669e025ff377602b6fc7caaf30dbc218371jacobs#ifdef AF_INET6
355b4669e025ff377602b6fc7caaf30dbc218371jacobs if (http->hostaddr.addr.sa_family == AF_INET6)
355b4669e025ff377602b6fc7caaf30dbc218371jacobs status = connect(http->fd, (struct sockaddr *)&(http->hostaddr),
355b4669e025ff377602b6fc7caaf30dbc218371jacobs sizeof(http->hostaddr.ipv6));
355b4669e025ff377602b6fc7caaf30dbc218371jacobs else
355b4669e025ff377602b6fc7caaf30dbc218371jacobs#endif /* AF_INET6 */
355b4669e025ff377602b6fc7caaf30dbc218371jacobs#ifdef AF_LOCAL
355b4669e025ff377602b6fc7caaf30dbc218371jacobs if (http->hostaddr.addr.sa_family == AF_LOCAL)
355b4669e025ff377602b6fc7caaf30dbc218371jacobs status = connect(http->fd, (struct sockaddr *)&(http->hostaddr),
355b4669e025ff377602b6fc7caaf30dbc218371jacobs SUN_LEN(&(http->hostaddr.un)));
355b4669e025ff377602b6fc7caaf30dbc218371jacobs else
355b4669e025ff377602b6fc7caaf30dbc218371jacobs#endif /* AF_LOCAL */
355b4669e025ff377602b6fc7caaf30dbc218371jacobs status = connect(http->fd, (struct sockaddr *)&(http->hostaddr),
355b4669e025ff377602b6fc7caaf30dbc218371jacobs sizeof(http->hostaddr.ipv4));
355b4669e025ff377602b6fc7caaf30dbc218371jacobs
355b4669e025ff377602b6fc7caaf30dbc218371jacobs if (status < 0)
355b4669e025ff377602b6fc7caaf30dbc218371jacobs {
355b4669e025ff377602b6fc7caaf30dbc218371jacobs#ifdef WIN32
355b4669e025ff377602b6fc7caaf30dbc218371jacobs http->error = WSAGetLastError();
355b4669e025ff377602b6fc7caaf30dbc218371jacobs#else
355b4669e025ff377602b6fc7caaf30dbc218371jacobs http->error = errno;
355b4669e025ff377602b6fc7caaf30dbc218371jacobs#endif /* WIN32 */
355b4669e025ff377602b6fc7caaf30dbc218371jacobs http->status = HTTP_ERROR;
355b4669e025ff377602b6fc7caaf30dbc218371jacobs
355b4669e025ff377602b6fc7caaf30dbc218371jacobs#ifdef WIN32
355b4669e025ff377602b6fc7caaf30dbc218371jacobs closesocket(http->fd);
355b4669e025ff377602b6fc7caaf30dbc218371jacobs#else
355b4669e025ff377602b6fc7caaf30dbc218371jacobs close(http->fd);
355b4669e025ff377602b6fc7caaf30dbc218371jacobs#endif
355b4669e025ff377602b6fc7caaf30dbc218371jacobs
355b4669e025ff377602b6fc7caaf30dbc218371jacobs http->fd = -1;
355b4669e025ff377602b6fc7caaf30dbc218371jacobs
355b4669e025ff377602b6fc7caaf30dbc218371jacobs return (-1);
355b4669e025ff377602b6fc7caaf30dbc218371jacobs }
355b4669e025ff377602b6fc7caaf30dbc218371jacobs
355b4669e025ff377602b6fc7caaf30dbc218371jacobs http->error = 0;
355b4669e025ff377602b6fc7caaf30dbc218371jacobs http->status = HTTP_CONTINUE;
355b4669e025ff377602b6fc7caaf30dbc218371jacobs
355b4669e025ff377602b6fc7caaf30dbc218371jacobs#ifdef HAVE_SSL
355b4669e025ff377602b6fc7caaf30dbc218371jacobs if (http->encryption == HTTP_ENCRYPT_ALWAYS)
355b4669e025ff377602b6fc7caaf30dbc218371jacobs {
355b4669e025ff377602b6fc7caaf30dbc218371jacobs /*
355b4669e025ff377602b6fc7caaf30dbc218371jacobs * Always do encryption via SSL.
355b4669e025ff377602b6fc7caaf30dbc218371jacobs */
355b4669e025ff377602b6fc7caaf30dbc218371jacobs
355b4669e025ff377602b6fc7caaf30dbc218371jacobs if (http_setup_ssl(http) != 0)
355b4669e025ff377602b6fc7caaf30dbc218371jacobs {
355b4669e025ff377602b6fc7caaf30dbc218371jacobs#ifdef WIN32
355b4669e025ff377602b6fc7caaf30dbc218371jacobs closesocket(http->fd);
355b4669e025ff377602b6fc7caaf30dbc218371jacobs#else
355b4669e025ff377602b6fc7caaf30dbc218371jacobs close(http->fd);
355b4669e025ff377602b6fc7caaf30dbc218371jacobs#endif /* WIN32 */
355b4669e025ff377602b6fc7caaf30dbc218371jacobs
355b4669e025ff377602b6fc7caaf30dbc218371jacobs return (-1);
355b4669e025ff377602b6fc7caaf30dbc218371jacobs }
355b4669e025ff377602b6fc7caaf30dbc218371jacobs }
355b4669e025ff377602b6fc7caaf30dbc218371jacobs else if (http->encryption == HTTP_ENCRYPT_REQUIRED)
355b4669e025ff377602b6fc7caaf30dbc218371jacobs return (http_upgrade(http));
355b4669e025ff377602b6fc7caaf30dbc218371jacobs#endif /* HAVE_SSL */
355b4669e025ff377602b6fc7caaf30dbc218371jacobs
355b4669e025ff377602b6fc7caaf30dbc218371jacobs return (0);
355b4669e025ff377602b6fc7caaf30dbc218371jacobs}
355b4669e025ff377602b6fc7caaf30dbc218371jacobs
355b4669e025ff377602b6fc7caaf30dbc218371jacobs
355b4669e025ff377602b6fc7caaf30dbc218371jacobs/*
355b4669e025ff377602b6fc7caaf30dbc218371jacobs * 'httpGetSubField()' - Get a sub-field value.
355b4669e025ff377602b6fc7caaf30dbc218371jacobs */
355b4669e025ff377602b6fc7caaf30dbc218371jacobs
355b4669e025ff377602b6fc7caaf30dbc218371jacobschar * /* O - Value or NULL */
355b4669e025ff377602b6fc7caaf30dbc218371jacobshttpGetSubField(http_t *http, /* I - HTTP data */
355b4669e025ff377602b6fc7caaf30dbc218371jacobs http_field_t field, /* I - Field index */
355b4669e025ff377602b6fc7caaf30dbc218371jacobs const char *name, /* I - Name of sub-field */
355b4669e025ff377602b6fc7caaf30dbc218371jacobs char *value) /* O - Value string */
355b4669e025ff377602b6fc7caaf30dbc218371jacobs{
355b4669e025ff377602b6fc7caaf30dbc218371jacobs const char *fptr; /* Pointer into field */
355b4669e025ff377602b6fc7caaf30dbc218371jacobs char temp[HTTP_MAX_VALUE], /* Temporary buffer for name */
355b4669e025ff377602b6fc7caaf30dbc218371jacobs *ptr; /* Pointer into string buffer */
355b4669e025ff377602b6fc7caaf30dbc218371jacobs
355b4669e025ff377602b6fc7caaf30dbc218371jacobs
355b4669e025ff377602b6fc7caaf30dbc218371jacobs DEBUG_printf(("httpGetSubField(http=%p, field=%d, name=\"%s\", value=%p)\n",
355b4669e025ff377602b6fc7caaf30dbc218371jacobs http, field, name, value));
355b4669e025ff377602b6fc7caaf30dbc218371jacobs
355b4669e025ff377602b6fc7caaf30dbc218371jacobs if (http == NULL ||
355b4669e025ff377602b6fc7caaf30dbc218371jacobs field < HTTP_FIELD_ACCEPT_LANGUAGE ||
355b4669e025ff377602b6fc7caaf30dbc218371jacobs field > HTTP_FIELD_WWW_AUTHENTICATE ||
355b4669e025ff377602b6fc7caaf30dbc218371jacobs name == NULL || value == NULL)
355b4669e025ff377602b6fc7caaf30dbc218371jacobs return (NULL);
355b4669e025ff377602b6fc7caaf30dbc218371jacobs
355b4669e025ff377602b6fc7caaf30dbc218371jacobs for (fptr = http->fields[field]; *fptr;)
355b4669e025ff377602b6fc7caaf30dbc218371jacobs {
355b4669e025ff377602b6fc7caaf30dbc218371jacobs /*
355b4669e025ff377602b6fc7caaf30dbc218371jacobs * Skip leading whitespace...
355b4669e025ff377602b6fc7caaf30dbc218371jacobs */
355b4669e025ff377602b6fc7caaf30dbc218371jacobs
355b4669e025ff377602b6fc7caaf30dbc218371jacobs while (isspace(*fptr & 255))
355b4669e025ff377602b6fc7caaf30dbc218371jacobs fptr ++;
355b4669e025ff377602b6fc7caaf30dbc218371jacobs
355b4669e025ff377602b6fc7caaf30dbc218371jacobs if (*fptr == ',')
355b4669e025ff377602b6fc7caaf30dbc218371jacobs {
355b4669e025ff377602b6fc7caaf30dbc218371jacobs fptr ++;
355b4669e025ff377602b6fc7caaf30dbc218371jacobs continue;
355b4669e025ff377602b6fc7caaf30dbc218371jacobs }
355b4669e025ff377602b6fc7caaf30dbc218371jacobs
355b4669e025ff377602b6fc7caaf30dbc218371jacobs /*
355b4669e025ff377602b6fc7caaf30dbc218371jacobs * Get the sub-field name...
355b4669e025ff377602b6fc7caaf30dbc218371jacobs */
355b4669e025ff377602b6fc7caaf30dbc218371jacobs
355b4669e025ff377602b6fc7caaf30dbc218371jacobs for (ptr = temp;
355b4669e025ff377602b6fc7caaf30dbc218371jacobs *fptr && *fptr != '=' && !isspace(*fptr & 255) && ptr < (temp + sizeof(temp) - 1);
355b4669e025ff377602b6fc7caaf30dbc218371jacobs *ptr++ = *fptr++);
355b4669e025ff377602b6fc7caaf30dbc218371jacobs
355b4669e025ff377602b6fc7caaf30dbc218371jacobs *ptr = '\0';
355b4669e025ff377602b6fc7caaf30dbc218371jacobs
355b4669e025ff377602b6fc7caaf30dbc218371jacobs DEBUG_printf(("httpGetSubField: name=\"%s\"\n", temp));
355b4669e025ff377602b6fc7caaf30dbc218371jacobs
355b4669e025ff377602b6fc7caaf30dbc218371jacobs /*
355b4669e025ff377602b6fc7caaf30dbc218371jacobs * Skip trailing chars up to the '='...
355b4669e025ff377602b6fc7caaf30dbc218371jacobs */
355b4669e025ff377602b6fc7caaf30dbc218371jacobs
355b4669e025ff377602b6fc7caaf30dbc218371jacobs while (isspace(*fptr & 255))
355b4669e025ff377602b6fc7caaf30dbc218371jacobs fptr ++;
355b4669e025ff377602b6fc7caaf30dbc218371jacobs
355b4669e025ff377602b6fc7caaf30dbc218371jacobs if (!*fptr)
355b4669e025ff377602b6fc7caaf30dbc218371jacobs break;
355b4669e025ff377602b6fc7caaf30dbc218371jacobs
355b4669e025ff377602b6fc7caaf30dbc218371jacobs if (*fptr != '=')
355b4669e025ff377602b6fc7caaf30dbc218371jacobs continue;
355b4669e025ff377602b6fc7caaf30dbc218371jacobs
355b4669e025ff377602b6fc7caaf30dbc218371jacobs /*
355b4669e025ff377602b6fc7caaf30dbc218371jacobs * Skip = and leading whitespace...
355b4669e025ff377602b6fc7caaf30dbc218371jacobs */
355b4669e025ff377602b6fc7caaf30dbc218371jacobs
355b4669e025ff377602b6fc7caaf30dbc218371jacobs fptr ++;
355b4669e025ff377602b6fc7caaf30dbc218371jacobs
355b4669e025ff377602b6fc7caaf30dbc218371jacobs while (isspace(*fptr & 255))
355b4669e025ff377602b6fc7caaf30dbc218371jacobs fptr ++;
355b4669e025ff377602b6fc7caaf30dbc218371jacobs
355b4669e025ff377602b6fc7caaf30dbc218371jacobs if (*fptr == '\"')
355b4669e025ff377602b6fc7caaf30dbc218371jacobs {
355b4669e025ff377602b6fc7caaf30dbc218371jacobs /*
355b4669e025ff377602b6fc7caaf30dbc218371jacobs * Read quoted string...
355b4669e025ff377602b6fc7caaf30dbc218371jacobs */
355b4669e025ff377602b6fc7caaf30dbc218371jacobs
355b4669e025ff377602b6fc7caaf30dbc218371jacobs for (ptr = value, fptr ++;
355b4669e025ff377602b6fc7caaf30dbc218371jacobs *fptr && *fptr != '\"' && ptr < (value + HTTP_MAX_VALUE - 1);
355b4669e025ff377602b6fc7caaf30dbc218371jacobs *ptr++ = *fptr++);
355b4669e025ff377602b6fc7caaf30dbc218371jacobs
355b4669e025ff377602b6fc7caaf30dbc218371jacobs *ptr = '\0';
355b4669e025ff377602b6fc7caaf30dbc218371jacobs
355b4669e025ff377602b6fc7caaf30dbc218371jacobs while (*fptr && *fptr != '\"')
355b4669e025ff377602b6fc7caaf30dbc218371jacobs fptr ++;
355b4669e025ff377602b6fc7caaf30dbc218371jacobs
355b4669e025ff377602b6fc7caaf30dbc218371jacobs if (*fptr)
355b4669e025ff377602b6fc7caaf30dbc218371jacobs fptr ++;
355b4669e025ff377602b6fc7caaf30dbc218371jacobs }
355b4669e025ff377602b6fc7caaf30dbc218371jacobs else
355b4669e025ff377602b6fc7caaf30dbc218371jacobs {
355b4669e025ff377602b6fc7caaf30dbc218371jacobs /*
355b4669e025ff377602b6fc7caaf30dbc218371jacobs * Read unquoted string...
355b4669e025ff377602b6fc7caaf30dbc218371jacobs */
355b4669e025ff377602b6fc7caaf30dbc218371jacobs
355b4669e025ff377602b6fc7caaf30dbc218371jacobs for (ptr = value;
355b4669e025ff377602b6fc7caaf30dbc218371jacobs *fptr && !isspace(*fptr & 255) && *fptr != ',' && ptr < (value + HTTP_MAX_VALUE - 1);
355b4669e025ff377602b6fc7caaf30dbc218371jacobs *ptr++ = *fptr++);
355b4669e025ff377602b6fc7caaf30dbc218371jacobs
355b4669e025ff377602b6fc7caaf30dbc218371jacobs *ptr = '\0';
355b4669e025ff377602b6fc7caaf30dbc218371jacobs
355b4669e025ff377602b6fc7caaf30dbc218371jacobs while (*fptr && !isspace(*fptr & 255) && *fptr != ',')
355b4669e025ff377602b6fc7caaf30dbc218371jacobs fptr ++;
355b4669e025ff377602b6fc7caaf30dbc218371jacobs }
355b4669e025ff377602b6fc7caaf30dbc218371jacobs
355b4669e025ff377602b6fc7caaf30dbc218371jacobs DEBUG_printf(("httpGetSubField: value=\"%s\"\n", value));
355b4669e025ff377602b6fc7caaf30dbc218371jacobs
355b4669e025ff377602b6fc7caaf30dbc218371jacobs /*
355b4669e025ff377602b6fc7caaf30dbc218371jacobs * See if this is the one...
355b4669e025ff377602b6fc7caaf30dbc218371jacobs */
355b4669e025ff377602b6fc7caaf30dbc218371jacobs
355b4669e025ff377602b6fc7caaf30dbc218371jacobs if (strcmp(name, temp) == 0)
355b4669e025ff377602b6fc7caaf30dbc218371jacobs return (value);
355b4669e025ff377602b6fc7caaf30dbc218371jacobs }
355b4669e025ff377602b6fc7caaf30dbc218371jacobs
355b4669e025ff377602b6fc7caaf30dbc218371jacobs value[0] = '\0';
355b4669e025ff377602b6fc7caaf30dbc218371jacobs
355b4669e025ff377602b6fc7caaf30dbc218371jacobs return (NULL);
355b4669e025ff377602b6fc7caaf30dbc218371jacobs}
355b4669e025ff377602b6fc7caaf30dbc218371jacobs
355b4669e025ff377602b6fc7caaf30dbc218371jacobs
355b4669e025ff377602b6fc7caaf30dbc218371jacobs/*
355b4669e025ff377602b6fc7caaf30dbc218371jacobs * 'httpSetField()' - Set the value of an HTTP header.
355b4669e025ff377602b6fc7caaf30dbc218371jacobs */
355b4669e025ff377602b6fc7caaf30dbc218371jacobs
355b4669e025ff377602b6fc7caaf30dbc218371jacobsvoid
355b4669e025ff377602b6fc7caaf30dbc218371jacobshttpSetField(http_t *http, /* I - HTTP data */
355b4669e025ff377602b6fc7caaf30dbc218371jacobs http_field_t field, /* I - Field index */
355b4669e025ff377602b6fc7caaf30dbc218371jacobs const char *value) /* I - Value */
355b4669e025ff377602b6fc7caaf30dbc218371jacobs{
355b4669e025ff377602b6fc7caaf30dbc218371jacobs if (http == NULL ||
355b4669e025ff377602b6fc7caaf30dbc218371jacobs field < HTTP_FIELD_ACCEPT_LANGUAGE ||
355b4669e025ff377602b6fc7caaf30dbc218371jacobs field > HTTP_FIELD_WWW_AUTHENTICATE ||
355b4669e025ff377602b6fc7caaf30dbc218371jacobs value == NULL)
355b4669e025ff377602b6fc7caaf30dbc218371jacobs return;
355b4669e025ff377602b6fc7caaf30dbc218371jacobs
355b4669e025ff377602b6fc7caaf30dbc218371jacobs strlcpy(http->fields[field], value, HTTP_MAX_VALUE);
355b4669e025ff377602b6fc7caaf30dbc218371jacobs}
355b4669e025ff377602b6fc7caaf30dbc218371jacobs
355b4669e025ff377602b6fc7caaf30dbc218371jacobs
355b4669e025ff377602b6fc7caaf30dbc218371jacobs/*
355b4669e025ff377602b6fc7caaf30dbc218371jacobs * 'httpDelete()' - Send a DELETE request to the server.
355b4669e025ff377602b6fc7caaf30dbc218371jacobs */
355b4669e025ff377602b6fc7caaf30dbc218371jacobs
355b4669e025ff377602b6fc7caaf30dbc218371jacobsint /* O - Status of call (0 = success) */
355b4669e025ff377602b6fc7caaf30dbc218371jacobshttpDelete(http_t *http, /* I - HTTP data */
355b4669e025ff377602b6fc7caaf30dbc218371jacobs const char *uri) /* I - URI to delete */
355b4669e025ff377602b6fc7caaf30dbc218371jacobs{
355b4669e025ff377602b6fc7caaf30dbc218371jacobs return (http_send(http, HTTP_DELETE, uri));
355b4669e025ff377602b6fc7caaf30dbc218371jacobs}
355b4669e025ff377602b6fc7caaf30dbc218371jacobs
355b4669e025ff377602b6fc7caaf30dbc218371jacobs
355b4669e025ff377602b6fc7caaf30dbc218371jacobs/*
355b4669e025ff377602b6fc7caaf30dbc218371jacobs * 'httpGet()' - Send a GET request to the server.
355b4669e025ff377602b6fc7caaf30dbc218371jacobs */
355b4669e025ff377602b6fc7caaf30dbc218371jacobs
355b4669e025ff377602b6fc7caaf30dbc218371jacobsint /* O - Status of call (0 = success) */
355b4669e025ff377602b6fc7caaf30dbc218371jacobshttpGet(http_t *http, /* I - HTTP data */
355b4669e025ff377602b6fc7caaf30dbc218371jacobs const char *uri) /* I - URI to get */
355b4669e025ff377602b6fc7caaf30dbc218371jacobs{
355b4669e025ff377602b6fc7caaf30dbc218371jacobs return (http_send(http, HTTP_GET, uri));
355b4669e025ff377602b6fc7caaf30dbc218371jacobs}
355b4669e025ff377602b6fc7caaf30dbc218371jacobs
355b4669e025ff377602b6fc7caaf30dbc218371jacobs
355b4669e025ff377602b6fc7caaf30dbc218371jacobs/*
355b4669e025ff377602b6fc7caaf30dbc218371jacobs * 'httpHead()' - Send a HEAD request to the server.
355b4669e025ff377602b6fc7caaf30dbc218371jacobs */
355b4669e025ff377602b6fc7caaf30dbc218371jacobs
355b4669e025ff377602b6fc7caaf30dbc218371jacobsint /* O - Status of call (0 = success) */
355b4669e025ff377602b6fc7caaf30dbc218371jacobshttpHead(http_t *http, /* I - HTTP data */
355b4669e025ff377602b6fc7caaf30dbc218371jacobs const char *uri) /* I - URI for head */
355b4669e025ff377602b6fc7caaf30dbc218371jacobs{
355b4669e025ff377602b6fc7caaf30dbc218371jacobs return (http_send(http, HTTP_HEAD, uri));
355b4669e025ff377602b6fc7caaf30dbc218371jacobs}
355b4669e025ff377602b6fc7caaf30dbc218371jacobs
355b4669e025ff377602b6fc7caaf30dbc218371jacobs
355b4669e025ff377602b6fc7caaf30dbc218371jacobs/*
355b4669e025ff377602b6fc7caaf30dbc218371jacobs * 'httpOptions()' - Send an OPTIONS request to the server.
355b4669e025ff377602b6fc7caaf30dbc218371jacobs */
355b4669e025ff377602b6fc7caaf30dbc218371jacobs
355b4669e025ff377602b6fc7caaf30dbc218371jacobsint /* O - Status of call (0 = success) */
355b4669e025ff377602b6fc7caaf30dbc218371jacobshttpOptions(http_t *http, /* I - HTTP data */
355b4669e025ff377602b6fc7caaf30dbc218371jacobs const char *uri) /* I - URI for options */
355b4669e025ff377602b6fc7caaf30dbc218371jacobs{
355b4669e025ff377602b6fc7caaf30dbc218371jacobs return (http_send(http, HTTP_OPTIONS, uri));
355b4669e025ff377602b6fc7caaf30dbc218371jacobs}
355b4669e025ff377602b6fc7caaf30dbc218371jacobs
355b4669e025ff377602b6fc7caaf30dbc218371jacobs
355b4669e025ff377602b6fc7caaf30dbc218371jacobs/*
355b4669e025ff377602b6fc7caaf30dbc218371jacobs * 'httpPost()' - Send a POST request to the server.
355b4669e025ff377602b6fc7caaf30dbc218371jacobs */
355b4669e025ff377602b6fc7caaf30dbc218371jacobs
355b4669e025ff377602b6fc7caaf30dbc218371jacobsint /* O - Status of call (0 = success) */
355b4669e025ff377602b6fc7caaf30dbc218371jacobshttpPost(http_t *http, /* I - HTTP data */
355b4669e025ff377602b6fc7caaf30dbc218371jacobs const char *uri) /* I - URI for post */
355b4669e025ff377602b6fc7caaf30dbc218371jacobs{
355b4669e025ff377602b6fc7caaf30dbc218371jacobs httpGetLength(http);
355b4669e025ff377602b6fc7caaf30dbc218371jacobs
355b4669e025ff377602b6fc7caaf30dbc218371jacobs return (http_send(http, HTTP_POST, uri));
355b4669e025ff377602b6fc7caaf30dbc218371jacobs}
355b4669e025ff377602b6fc7caaf30dbc218371jacobs
355b4669e025ff377602b6fc7caaf30dbc218371jacobs
355b4669e025ff377602b6fc7caaf30dbc218371jacobs/*
355b4669e025ff377602b6fc7caaf30dbc218371jacobs * 'httpPut()' - Send a PUT request to the server.
355b4669e025ff377602b6fc7caaf30dbc218371jacobs */
355b4669e025ff377602b6fc7caaf30dbc218371jacobs
355b4669e025ff377602b6fc7caaf30dbc218371jacobsint /* O - Status of call (0 = success) */
355b4669e025ff377602b6fc7caaf30dbc218371jacobshttpPut(http_t *http, /* I - HTTP data */
355b4669e025ff377602b6fc7caaf30dbc218371jacobs const char *uri) /* I - URI to put */
355b4669e025ff377602b6fc7caaf30dbc218371jacobs{
355b4669e025ff377602b6fc7caaf30dbc218371jacobs httpGetLength(http);
355b4669e025ff377602b6fc7caaf30dbc218371jacobs
355b4669e025ff377602b6fc7caaf30dbc218371jacobs return (http_send(http, HTTP_PUT, uri));
355b4669e025ff377602b6fc7caaf30dbc218371jacobs}
355b4669e025ff377602b6fc7caaf30dbc218371jacobs
355b4669e025ff377602b6fc7caaf30dbc218371jacobs
355b4669e025ff377602b6fc7caaf30dbc218371jacobs/*
355b4669e025ff377602b6fc7caaf30dbc218371jacobs * 'httpTrace()' - Send an TRACE request to the server.
355b4669e025ff377602b6fc7caaf30dbc218371jacobs */
355b4669e025ff377602b6fc7caaf30dbc218371jacobs
355b4669e025ff377602b6fc7caaf30dbc218371jacobsint /* O - Status of call (0 = success) */
355b4669e025ff377602b6fc7caaf30dbc218371jacobshttpTrace(http_t *http, /* I - HTTP data */
355b4669e025ff377602b6fc7caaf30dbc218371jacobs const char *uri) /* I - URI for trace */
355b4669e025ff377602b6fc7caaf30dbc218371jacobs{
355b4669e025ff377602b6fc7caaf30dbc218371jacobs return (http_send(http, HTTP_TRACE, uri));
355b4669e025ff377602b6fc7caaf30dbc218371jacobs}
355b4669e025ff377602b6fc7caaf30dbc218371jacobs
355b4669e025ff377602b6fc7caaf30dbc218371jacobs
355b4669e025ff377602b6fc7caaf30dbc218371jacobs/*
355b4669e025ff377602b6fc7caaf30dbc218371jacobs * 'httpFlush()' - Flush data from a HTTP connection.
355b4669e025ff377602b6fc7caaf30dbc218371jacobs */
355b4669e025ff377602b6fc7caaf30dbc218371jacobs
355b4669e025ff377602b6fc7caaf30dbc218371jacobsvoid
355b4669e025ff377602b6fc7caaf30dbc218371jacobshttpFlush(http_t *http) /* I - HTTP data */
355b4669e025ff377602b6fc7caaf30dbc218371jacobs{
355b4669e025ff377602b6fc7caaf30dbc218371jacobs char buffer[8192]; /* Junk buffer */
355b4669e025ff377602b6fc7caaf30dbc218371jacobs
355b4669e025ff377602b6fc7caaf30dbc218371jacobs
355b4669e025ff377602b6fc7caaf30dbc218371jacobs DEBUG_printf(("httpFlush(http=%p), state=%d\n", http, http->state));
355b4669e025ff377602b6fc7caaf30dbc218371jacobs
355b4669e025ff377602b6fc7caaf30dbc218371jacobs while (httpRead(http, buffer, sizeof(buffer)) > 0);
355b4669e025ff377602b6fc7caaf30dbc218371jacobs}
355b4669e025ff377602b6fc7caaf30dbc218371jacobs
355b4669e025ff377602b6fc7caaf30dbc218371jacobs
355b4669e025ff377602b6fc7caaf30dbc218371jacobs/*
355b4669e025ff377602b6fc7caaf30dbc218371jacobs * 'httpRead()' - Read data from a HTTP connection.
355b4669e025ff377602b6fc7caaf30dbc218371jacobs */
355b4669e025ff377602b6fc7caaf30dbc218371jacobs
355b4669e025ff377602b6fc7caaf30dbc218371jacobsint /* O - Number of bytes read */
355b4669e025ff377602b6fc7caaf30dbc218371jacobshttpRead(http_t *http, /* I - HTTP data */
355b4669e025ff377602b6fc7caaf30dbc218371jacobs char *buffer, /* I - Buffer for data */
355b4669e025ff377602b6fc7caaf30dbc218371jacobs int length) /* I - Maximum number of bytes */
355b4669e025ff377602b6fc7caaf30dbc218371jacobs{
355b4669e025ff377602b6fc7caaf30dbc218371jacobs int bytes; /* Bytes read */
355b4669e025ff377602b6fc7caaf30dbc218371jacobs char len[32]; /* Length string */
355b4669e025ff377602b6fc7caaf30dbc218371jacobs
355b4669e025ff377602b6fc7caaf30dbc218371jacobs
355b4669e025ff377602b6fc7caaf30dbc218371jacobs DEBUG_printf(("httpRead(http=%p, buffer=%p, length=%d)\n",
355b4669e025ff377602b6fc7caaf30dbc218371jacobs http, buffer, length));
355b4669e025ff377602b6fc7caaf30dbc218371jacobs
355b4669e025ff377602b6fc7caaf30dbc218371jacobs if (http == NULL || buffer == NULL)
355b4669e025ff377602b6fc7caaf30dbc218371jacobs return (-1);
355b4669e025ff377602b6fc7caaf30dbc218371jacobs
355b4669e025ff377602b6fc7caaf30dbc218371jacobs http->activity = time(NULL);
355b4669e025ff377602b6fc7caaf30dbc218371jacobs
355b4669e025ff377602b6fc7caaf30dbc218371jacobs if (length <= 0)
355b4669e025ff377602b6fc7caaf30dbc218371jacobs return (0);
355b4669e025ff377602b6fc7caaf30dbc218371jacobs
355b4669e025ff377602b6fc7caaf30dbc218371jacobs if (http->data_encoding == HTTP_ENCODE_CHUNKED &&
355b4669e025ff377602b6fc7caaf30dbc218371jacobs http->data_remaining <= 0)
355b4669e025ff377602b6fc7caaf30dbc218371jacobs {
355b4669e025ff377602b6fc7caaf30dbc218371jacobs DEBUG_puts("httpRead: Getting chunk length...");
355b4669e025ff377602b6fc7caaf30dbc218371jacobs
355b4669e025ff377602b6fc7caaf30dbc218371jacobs if (httpGets(len, sizeof(len), http) == NULL)
355b4669e025ff377602b6fc7caaf30dbc218371jacobs {
355b4669e025ff377602b6fc7caaf30dbc218371jacobs DEBUG_puts("httpRead: Could not get length!");
355b4669e025ff377602b6fc7caaf30dbc218371jacobs return (0);
355b4669e025ff377602b6fc7caaf30dbc218371jacobs }
355b4669e025ff377602b6fc7caaf30dbc218371jacobs
355b4669e025ff377602b6fc7caaf30dbc218371jacobs http->data_remaining = strtol(len, NULL, 16);
355b4669e025ff377602b6fc7caaf30dbc218371jacobs if (http->data_remaining < 0)
355b4669e025ff377602b6fc7caaf30dbc218371jacobs {
355b4669e025ff377602b6fc7caaf30dbc218371jacobs DEBUG_puts("httpRead: Negative chunk length!");
355b4669e025ff377602b6fc7caaf30dbc218371jacobs return (0);
355b4669e025ff377602b6fc7caaf30dbc218371jacobs }
355b4669e025ff377602b6fc7caaf30dbc218371jacobs }
355b4669e025ff377602b6fc7caaf30dbc218371jacobs
355b4669e025ff377602b6fc7caaf30dbc218371jacobs DEBUG_printf(("httpRead: data_remaining=%d\n", http->data_remaining));
355b4669e025ff377602b6fc7caaf30dbc218371jacobs
355b4669e025ff377602b6fc7caaf30dbc218371jacobs if (http->data_remaining <= 0)
355b4669e025ff377602b6fc7caaf30dbc218371jacobs {
355b4669e025ff377602b6fc7caaf30dbc218371jacobs /*
355b4669e025ff377602b6fc7caaf30dbc218371jacobs * A zero-length chunk ends a transfer; unless we are reading POST
355b4669e025ff377602b6fc7caaf30dbc218371jacobs * data, go idle...
355b4669e025ff377602b6fc7caaf30dbc218371jacobs */
355b4669e025ff377602b6fc7caaf30dbc218371jacobs
355b4669e025ff377602b6fc7caaf30dbc218371jacobs if (http->data_encoding == HTTP_ENCODE_CHUNKED)
355b4669e025ff377602b6fc7caaf30dbc218371jacobs httpGets(len, sizeof(len), http);
355b4669e025ff377602b6fc7caaf30dbc218371jacobs
355b4669e025ff377602b6fc7caaf30dbc218371jacobs if (http->state == HTTP_POST_RECV)
355b4669e025ff377602b6fc7caaf30dbc218371jacobs http->state ++;
355b4669e025ff377602b6fc7caaf30dbc218371jacobs else
355b4669e025ff377602b6fc7caaf30dbc218371jacobs http->state = HTTP_WAITING;
355b4669e025ff377602b6fc7caaf30dbc218371jacobs
355b4669e025ff377602b6fc7caaf30dbc218371jacobs /*
355b4669e025ff377602b6fc7caaf30dbc218371jacobs * Prevent future reads for this request...
355b4669e025ff377602b6fc7caaf30dbc218371jacobs */
355b4669e025ff377602b6fc7caaf30dbc218371jacobs
355b4669e025ff377602b6fc7caaf30dbc218371jacobs http->data_encoding = HTTP_ENCODE_LENGTH;
355b4669e025ff377602b6fc7caaf30dbc218371jacobs
355b4669e025ff377602b6fc7caaf30dbc218371jacobs return (0);
355b4669e025ff377602b6fc7caaf30dbc218371jacobs }
355b4669e025ff377602b6fc7caaf30dbc218371jacobs else if (length > http->data_remaining)
355b4669e025ff377602b6fc7caaf30dbc218371jacobs length = http->data_remaining;
355b4669e025ff377602b6fc7caaf30dbc218371jacobs
355b4669e025ff377602b6fc7caaf30dbc218371jacobs if (http->used == 0 && length <= 256)
355b4669e025ff377602b6fc7caaf30dbc218371jacobs {
355b4669e025ff377602b6fc7caaf30dbc218371jacobs /*
355b4669e025ff377602b6fc7caaf30dbc218371jacobs * Buffer small reads for better performance...
355b4669e025ff377602b6fc7caaf30dbc218371jacobs */
355b4669e025ff377602b6fc7caaf30dbc218371jacobs
355b4669e025ff377602b6fc7caaf30dbc218371jacobs if (!http->blocking && !httpWait(http, 1000))
355b4669e025ff377602b6fc7caaf30dbc218371jacobs return (0);
355b4669e025ff377602b6fc7caaf30dbc218371jacobs
355b4669e025ff377602b6fc7caaf30dbc218371jacobs if (http->data_remaining > sizeof(http->buffer))
355b4669e025ff377602b6fc7caaf30dbc218371jacobs bytes = sizeof(http->buffer);
355b4669e025ff377602b6fc7caaf30dbc218371jacobs else
355b4669e025ff377602b6fc7caaf30dbc218371jacobs bytes = http->data_remaining;
355b4669e025ff377602b6fc7caaf30dbc218371jacobs
355b4669e025ff377602b6fc7caaf30dbc218371jacobs#ifdef HAVE_SSL
355b4669e025ff377602b6fc7caaf30dbc218371jacobs if (http->tls)
355b4669e025ff377602b6fc7caaf30dbc218371jacobs bytes = http_read_ssl(http, http->buffer, bytes);
355b4669e025ff377602b6fc7caaf30dbc218371jacobs else
355b4669e025ff377602b6fc7caaf30dbc218371jacobs#endif /* HAVE_SSL */
355b4669e025ff377602b6fc7caaf30dbc218371jacobs {
355b4669e025ff377602b6fc7caaf30dbc218371jacobs DEBUG_printf(("httpRead: reading %d bytes from socket into buffer...\n",
355b4669e025ff377602b6fc7caaf30dbc218371jacobs bytes));
355b4669e025ff377602b6fc7caaf30dbc218371jacobs
355b4669e025ff377602b6fc7caaf30dbc218371jacobs bytes = recv(http->fd, http->buffer, bytes, 0);
355b4669e025ff377602b6fc7caaf30dbc218371jacobs
355b4669e025ff377602b6fc7caaf30dbc218371jacobs DEBUG_printf(("httpRead: read %d bytes from socket into buffer...\n",
355b4669e025ff377602b6fc7caaf30dbc218371jacobs bytes));
355b4669e025ff377602b6fc7caaf30dbc218371jacobs#ifdef DEBUG_HTTP
355b4669e025ff377602b6fc7caaf30dbc218371jacobs httpDumpData(stdout, "httpRead:", http->buffer, bytes);
355b4669e025ff377602b6fc7caaf30dbc218371jacobs#endif
355b4669e025ff377602b6fc7caaf30dbc218371jacobs }
355b4669e025ff377602b6fc7caaf30dbc218371jacobs
355b4669e025ff377602b6fc7caaf30dbc218371jacobs if (bytes > 0)
355b4669e025ff377602b6fc7caaf30dbc218371jacobs http->used = bytes;
355b4669e025ff377602b6fc7caaf30dbc218371jacobs else if (bytes < 0)
355b4669e025ff377602b6fc7caaf30dbc218371jacobs {
355b4669e025ff377602b6fc7caaf30dbc218371jacobs#ifdef WIN32
355b4669e025ff377602b6fc7caaf30dbc218371jacobs http->error = WSAGetLastError();
355b4669e025ff377602b6fc7caaf30dbc218371jacobs return (-1);
355b4669e025ff377602b6fc7caaf30dbc218371jacobs#else
355b4669e025ff377602b6fc7caaf30dbc218371jacobs if (errno != EINTR)
355b4669e025ff377602b6fc7caaf30dbc218371jacobs {
355b4669e025ff377602b6fc7caaf30dbc218371jacobs http->error = errno;
355b4669e025ff377602b6fc7caaf30dbc218371jacobs return (-1);
355b4669e025ff377602b6fc7caaf30dbc218371jacobs }
355b4669e025ff377602b6fc7caaf30dbc218371jacobs#endif /* WIN32 */
355b4669e025ff377602b6fc7caaf30dbc218371jacobs }
355b4669e025ff377602b6fc7caaf30dbc218371jacobs else
355b4669e025ff377602b6fc7caaf30dbc218371jacobs {
355b4669e025ff377602b6fc7caaf30dbc218371jacobs http->error = EPIPE;
355b4669e025ff377602b6fc7caaf30dbc218371jacobs return (0);
355b4669e025ff377602b6fc7caaf30dbc218371jacobs }
355b4669e025ff377602b6fc7caaf30dbc218371jacobs }
355b4669e025ff377602b6fc7caaf30dbc218371jacobs
355b4669e025ff377602b6fc7caaf30dbc218371jacobs if (http->used > 0)
355b4669e025ff377602b6fc7caaf30dbc218371jacobs {
355b4669e025ff377602b6fc7caaf30dbc218371jacobs if (length > http->used)
355b4669e025ff377602b6fc7caaf30dbc218371jacobs length = http->used;
355b4669e025ff377602b6fc7caaf30dbc218371jacobs
355b4669e025ff377602b6fc7caaf30dbc218371jacobs bytes = length;
355b4669e025ff377602b6fc7caaf30dbc218371jacobs
355b4669e025ff377602b6fc7caaf30dbc218371jacobs DEBUG_printf(("httpRead: grabbing %d bytes from input buffer...\n", bytes));
355b4669e025ff377602b6fc7caaf30dbc218371jacobs
355b4669e025ff377602b6fc7caaf30dbc218371jacobs memcpy(buffer, http->buffer, length);
355b4669e025ff377602b6fc7caaf30dbc218371jacobs http->used -= length;
355b4669e025ff377602b6fc7caaf30dbc218371jacobs
355b4669e025ff377602b6fc7caaf30dbc218371jacobs if (http->used > 0)
355b4669e025ff377602b6fc7caaf30dbc218371jacobs memmove(http->buffer, http->buffer + length, http->used);
355b4669e025ff377602b6fc7caaf30dbc218371jacobs }
355b4669e025ff377602b6fc7caaf30dbc218371jacobs#ifdef HAVE_SSL
355b4669e025ff377602b6fc7caaf30dbc218371jacobs else if (http->tls)
355b4669e025ff377602b6fc7caaf30dbc218371jacobs {
355b4669e025ff377602b6fc7caaf30dbc218371jacobs if (!http->blocking && !httpWait(http, 1000))
355b4669e025ff377602b6fc7caaf30dbc218371jacobs return (0);
355b4669e025ff377602b6fc7caaf30dbc218371jacobs
355b4669e025ff377602b6fc7caaf30dbc218371jacobs bytes = http_read_ssl(http, buffer, length);
355b4669e025ff377602b6fc7caaf30dbc218371jacobs }
355b4669e025ff377602b6fc7caaf30dbc218371jacobs#endif /* HAVE_SSL */
355b4669e025ff377602b6fc7caaf30dbc218371jacobs else
355b4669e025ff377602b6fc7caaf30dbc218371jacobs {
355b4669e025ff377602b6fc7caaf30dbc218371jacobs if (!http->blocking && !httpWait(http, 1000))
355b4669e025ff377602b6fc7caaf30dbc218371jacobs return (0);
355b4669e025ff377602b6fc7caaf30dbc218371jacobs
355b4669e025ff377602b6fc7caaf30dbc218371jacobs DEBUG_printf(("httpRead: reading %d bytes from socket...\n", length));
355b4669e025ff377602b6fc7caaf30dbc218371jacobs
355b4669e025ff377602b6fc7caaf30dbc218371jacobs while ((bytes = recv(http->fd, buffer, length, 0)) < 0)
355b4669e025ff377602b6fc7caaf30dbc218371jacobs if (errno != EINTR)
355b4669e025ff377602b6fc7caaf30dbc218371jacobs break;
355b4669e025ff377602b6fc7caaf30dbc218371jacobs DEBUG_printf(("httpRead: read %d bytes from socket...\n", bytes));
355b4669e025ff377602b6fc7caaf30dbc218371jacobs }
355b4669e025ff377602b6fc7caaf30dbc218371jacobs#ifdef DEBUG_HTTP
355b4669e025ff377602b6fc7caaf30dbc218371jacobs httpDumpData(stdout, "httpRead:", buffer, bytes);
355b4669e025ff377602b6fc7caaf30dbc218371jacobs#endif
355b4669e025ff377602b6fc7caaf30dbc218371jacobs
355b4669e025ff377602b6fc7caaf30dbc218371jacobs if (bytes > 0)
355b4669e025ff377602b6fc7caaf30dbc218371jacobs http->data_remaining -= bytes;
355b4669e025ff377602b6fc7caaf30dbc218371jacobs else if (bytes < 0)
355b4669e025ff377602b6fc7caaf30dbc218371jacobs {
355b4669e025ff377602b6fc7caaf30dbc218371jacobs#ifdef WIN32
355b4669e025ff377602b6fc7caaf30dbc218371jacobs http->error = WSAGetLastError();
355b4669e025ff377602b6fc7caaf30dbc218371jacobs#else
355b4669e025ff377602b6fc7caaf30dbc218371jacobs if (errno == EINTR)
355b4669e025ff377602b6fc7caaf30dbc218371jacobs bytes = 0;
355b4669e025ff377602b6fc7caaf30dbc218371jacobs else
355b4669e025ff377602b6fc7caaf30dbc218371jacobs http->error = errno;
355b4669e025ff377602b6fc7caaf30dbc218371jacobs#endif /* WIN32 */
355b4669e025ff377602b6fc7caaf30dbc218371jacobs }
355b4669e025ff377602b6fc7caaf30dbc218371jacobs else
355b4669e025ff377602b6fc7caaf30dbc218371jacobs {
355b4669e025ff377602b6fc7caaf30dbc218371jacobs http->error = EPIPE;
355b4669e025ff377602b6fc7caaf30dbc218371jacobs return (0);
355b4669e025ff377602b6fc7caaf30dbc218371jacobs }
355b4669e025ff377602b6fc7caaf30dbc218371jacobs
355b4669e025ff377602b6fc7caaf30dbc218371jacobs if (http->data_remaining == 0)
355b4669e025ff377602b6fc7caaf30dbc218371jacobs {
355b4669e025ff377602b6fc7caaf30dbc218371jacobs if (http->data_encoding == HTTP_ENCODE_CHUNKED)
355b4669e025ff377602b6fc7caaf30dbc218371jacobs httpGets(len, sizeof(len), http);
355b4669e025ff377602b6fc7caaf30dbc218371jacobs
355b4669e025ff377602b6fc7caaf30dbc218371jacobs if (http->data_encoding != HTTP_ENCODE_CHUNKED)
355b4669e025ff377602b6fc7caaf30dbc218371jacobs {
355b4669e025ff377602b6fc7caaf30dbc218371jacobs if (http->state == HTTP_POST_RECV)
355b4669e025ff377602b6fc7caaf30dbc218371jacobs http->state ++;
355b4669e025ff377602b6fc7caaf30dbc218371jacobs else
355b4669e025ff377602b6fc7caaf30dbc218371jacobs http->state = HTTP_WAITING;
355b4669e025ff377602b6fc7caaf30dbc218371jacobs }
355b4669e025ff377602b6fc7caaf30dbc218371jacobs }
355b4669e025ff377602b6fc7caaf30dbc218371jacobs
355b4669e025ff377602b6fc7caaf30dbc218371jacobs return (bytes);
355b4669e025ff377602b6fc7caaf30dbc218371jacobs}
355b4669e025ff377602b6fc7caaf30dbc218371jacobs
355b4669e025ff377602b6fc7caaf30dbc218371jacobs
355b4669e025ff377602b6fc7caaf30dbc218371jacobs/*
355b4669e025ff377602b6fc7caaf30dbc218371jacobs * 'httpSetCookie()' - Set the cookie value(s)...
355b4669e025ff377602b6fc7caaf30dbc218371jacobs */
355b4669e025ff377602b6fc7caaf30dbc218371jacobs
355b4669e025ff377602b6fc7caaf30dbc218371jacobsvoid
355b4669e025ff377602b6fc7caaf30dbc218371jacobshttpSetCookie(http_t *http, /* I - Connection */
355b4669e025ff377602b6fc7caaf30dbc218371jacobs const char *cookie) /* I - Cookie string */
355b4669e025ff377602b6fc7caaf30dbc218371jacobs{
355b4669e025ff377602b6fc7caaf30dbc218371jacobs if (!http)
355b4669e025ff377602b6fc7caaf30dbc218371jacobs return;
355b4669e025ff377602b6fc7caaf30dbc218371jacobs
355b4669e025ff377602b6fc7caaf30dbc218371jacobs if (http->cookie)
355b4669e025ff377602b6fc7caaf30dbc218371jacobs free(http->cookie);
355b4669e025ff377602b6fc7caaf30dbc218371jacobs
355b4669e025ff377602b6fc7caaf30dbc218371jacobs if (cookie)
355b4669e025ff377602b6fc7caaf30dbc218371jacobs http->cookie = strdup(cookie);
355b4669e025ff377602b6fc7caaf30dbc218371jacobs else
355b4669e025ff377602b6fc7caaf30dbc218371jacobs http->cookie = NULL;
355b4669e025ff377602b6fc7caaf30dbc218371jacobs}
355b4669e025ff377602b6fc7caaf30dbc218371jacobs
355b4669e025ff377602b6fc7caaf30dbc218371jacobs
355b4669e025ff377602b6fc7caaf30dbc218371jacobs/*
355b4669e025ff377602b6fc7caaf30dbc218371jacobs * 'httpWait()' - Wait for data available on a connection.
355b4669e025ff377602b6fc7caaf30dbc218371jacobs */
355b4669e025ff377602b6fc7caaf30dbc218371jacobs
355b4669e025ff377602b6fc7caaf30dbc218371jacobsint /* O - 1 if data is available, 0 otherwise */
355b4669e025ff377602b6fc7caaf30dbc218371jacobshttpWait(http_t *http, /* I - HTTP data */
355b4669e025ff377602b6fc7caaf30dbc218371jacobs int msec) /* I - Milliseconds to wait */
355b4669e025ff377602b6fc7caaf30dbc218371jacobs{
355b4669e025ff377602b6fc7caaf30dbc218371jacobs /*
355b4669e025ff377602b6fc7caaf30dbc218371jacobs * First see if there is data in the buffer...
355b4669e025ff377602b6fc7caaf30dbc218371jacobs */
355b4669e025ff377602b6fc7caaf30dbc218371jacobs
355b4669e025ff377602b6fc7caaf30dbc218371jacobs if (http == NULL)
355b4669e025ff377602b6fc7caaf30dbc218371jacobs return (0);
355b4669e025ff377602b6fc7caaf30dbc218371jacobs
355b4669e025ff377602b6fc7caaf30dbc218371jacobs if (http->used)
355b4669e025ff377602b6fc7caaf30dbc218371jacobs return (1);
355b4669e025ff377602b6fc7caaf30dbc218371jacobs
355b4669e025ff377602b6fc7caaf30dbc218371jacobs /*
355b4669e025ff377602b6fc7caaf30dbc218371jacobs * If not, check the SSL/TLS buffers and do a select() on the connection...
355b4669e025ff377602b6fc7caaf30dbc218371jacobs */
355b4669e025ff377602b6fc7caaf30dbc218371jacobs
355b4669e025ff377602b6fc7caaf30dbc218371jacobs return (http_wait(http, msec));
355b4669e025ff377602b6fc7caaf30dbc218371jacobs}
355b4669e025ff377602b6fc7caaf30dbc218371jacobs
355b4669e025ff377602b6fc7caaf30dbc218371jacobs
355b4669e025ff377602b6fc7caaf30dbc218371jacobs/*
355b4669e025ff377602b6fc7caaf30dbc218371jacobs * 'httpWrite()' - Write data to a HTTP connection.
355b4669e025ff377602b6fc7caaf30dbc218371jacobs */
355b4669e025ff377602b6fc7caaf30dbc218371jacobs
355b4669e025ff377602b6fc7caaf30dbc218371jacobsint /* O - Number of bytes written */
355b4669e025ff377602b6fc7caaf30dbc218371jacobshttpWrite(http_t *http, /* I - HTTP data */
355b4669e025ff377602b6fc7caaf30dbc218371jacobs const char *buffer, /* I - Buffer for data */
355b4669e025ff377602b6fc7caaf30dbc218371jacobs int length) /* I - Number of bytes to write */
355b4669e025ff377602b6fc7caaf30dbc218371jacobs{
355b4669e025ff377602b6fc7caaf30dbc218371jacobs int tbytes, /* Total bytes sent */
355b4669e025ff377602b6fc7caaf30dbc218371jacobs bytes; /* Bytes sent */
355b4669e025ff377602b6fc7caaf30dbc218371jacobs
355b4669e025ff377602b6fc7caaf30dbc218371jacobs
355b4669e025ff377602b6fc7caaf30dbc218371jacobs if (http == NULL || buffer == NULL)
355b4669e025ff377602b6fc7caaf30dbc218371jacobs return (-1);
355b4669e025ff377602b6fc7caaf30dbc218371jacobs
355b4669e025ff377602b6fc7caaf30dbc218371jacobs http->activity = time(NULL);
355b4669e025ff377602b6fc7caaf30dbc218371jacobs
355b4669e025ff377602b6fc7caaf30dbc218371jacobs if (http->data_encoding == HTTP_ENCODE_CHUNKED)
355b4669e025ff377602b6fc7caaf30dbc218371jacobs {
355b4669e025ff377602b6fc7caaf30dbc218371jacobs if (httpPrintf(http, "%x\r\n", length) < 0)
355b4669e025ff377602b6fc7caaf30dbc218371jacobs return (-1);
355b4669e025ff377602b6fc7caaf30dbc218371jacobs
355b4669e025ff377602b6fc7caaf30dbc218371jacobs if (length == 0)
355b4669e025ff377602b6fc7caaf30dbc218371jacobs {
355b4669e025ff377602b6fc7caaf30dbc218371jacobs /*
355b4669e025ff377602b6fc7caaf30dbc218371jacobs * A zero-length chunk ends a transfer; unless we are sending POST
355b4669e025ff377602b6fc7caaf30dbc218371jacobs * or PUT data, go idle...
355b4669e025ff377602b6fc7caaf30dbc218371jacobs */
355b4669e025ff377602b6fc7caaf30dbc218371jacobs
355b4669e025ff377602b6fc7caaf30dbc218371jacobs DEBUG_printf(("httpWrite: changing states from %d", http->state));
355b4669e025ff377602b6fc7caaf30dbc218371jacobs
355b4669e025ff377602b6fc7caaf30dbc218371jacobs if (http->state == HTTP_POST_RECV)
355b4669e025ff377602b6fc7caaf30dbc218371jacobs http->state ++;
355b4669e025ff377602b6fc7caaf30dbc218371jacobs else if (http->state == HTTP_PUT_RECV)
355b4669e025ff377602b6fc7caaf30dbc218371jacobs http->state = HTTP_STATUS;
355b4669e025ff377602b6fc7caaf30dbc218371jacobs else
355b4669e025ff377602b6fc7caaf30dbc218371jacobs http->state = HTTP_WAITING;
355b4669e025ff377602b6fc7caaf30dbc218371jacobs DEBUG_printf((" to %d\n", http->state));
355b4669e025ff377602b6fc7caaf30dbc218371jacobs
355b4669e025ff377602b6fc7caaf30dbc218371jacobs if (httpPrintf(http, "\r\n") < 0)
355b4669e025ff377602b6fc7caaf30dbc218371jacobs return (-1);
355b4669e025ff377602b6fc7caaf30dbc218371jacobs
355b4669e025ff377602b6fc7caaf30dbc218371jacobs return (0);
355b4669e025ff377602b6fc7caaf30dbc218371jacobs }
355b4669e025ff377602b6fc7caaf30dbc218371jacobs }
355b4669e025ff377602b6fc7caaf30dbc218371jacobs
355b4669e025ff377602b6fc7caaf30dbc218371jacobs tbytes = 0;
355b4669e025ff377602b6fc7caaf30dbc218371jacobs
355b4669e025ff377602b6fc7caaf30dbc218371jacobs while (length > 0)
355b4669e025ff377602b6fc7caaf30dbc218371jacobs {
355b4669e025ff377602b6fc7caaf30dbc218371jacobs#ifdef HAVE_SSL
355b4669e025ff377602b6fc7caaf30dbc218371jacobs if (http->tls)
355b4669e025ff377602b6fc7caaf30dbc218371jacobs bytes = http_write_ssl(http, buffer, length);
355b4669e025ff377602b6fc7caaf30dbc218371jacobs else
355b4669e025ff377602b6fc7caaf30dbc218371jacobs#endif /* HAVE_SSL */
355b4669e025ff377602b6fc7caaf30dbc218371jacobs bytes = send(http->fd, buffer, length, 0);
355b4669e025ff377602b6fc7caaf30dbc218371jacobs
355b4669e025ff377602b6fc7caaf30dbc218371jacobs#ifdef DEBUG_HTTP
355b4669e025ff377602b6fc7caaf30dbc218371jacobs if (bytes >= 0)
355b4669e025ff377602b6fc7caaf30dbc218371jacobs httpDumpData(stdout, "httpWrite:", buffer, bytes);
355b4669e025ff377602b6fc7caaf30dbc218371jacobs#endif /* DEBUG */
355b4669e025ff377602b6fc7caaf30dbc218371jacobs
355b4669e025ff377602b6fc7caaf30dbc218371jacobs
355b4669e025ff377602b6fc7caaf30dbc218371jacobs if (bytes < 0)
355b4669e025ff377602b6fc7caaf30dbc218371jacobs {
355b4669e025ff377602b6fc7caaf30dbc218371jacobs#ifdef WIN32
355b4669e025ff377602b6fc7caaf30dbc218371jacobs if (WSAGetLastError() != http->error)
355b4669e025ff377602b6fc7caaf30dbc218371jacobs {
355b4669e025ff377602b6fc7caaf30dbc218371jacobs http->error = WSAGetLastError();
355b4669e025ff377602b6fc7caaf30dbc218371jacobs continue;
355b4669e025ff377602b6fc7caaf30dbc218371jacobs }
355b4669e025ff377602b6fc7caaf30dbc218371jacobs#else
355b4669e025ff377602b6fc7caaf30dbc218371jacobs if (errno == EINTR)
355b4669e025ff377602b6fc7caaf30dbc218371jacobs continue;
355b4669e025ff377602b6fc7caaf30dbc218371jacobs else if (errno != http->error && errno != ECONNRESET)
355b4669e025ff377602b6fc7caaf30dbc218371jacobs {
355b4669e025ff377602b6fc7caaf30dbc218371jacobs http->error = errno;
355b4669e025ff377602b6fc7caaf30dbc218371jacobs continue;
355b4669e025ff377602b6fc7caaf30dbc218371jacobs }
355b4669e025ff377602b6fc7caaf30dbc218371jacobs#endif /* WIN32 */
355b4669e025ff377602b6fc7caaf30dbc218371jacobs
355b4669e025ff377602b6fc7caaf30dbc218371jacobs DEBUG_puts("httpWrite: error writing data...\n");
355b4669e025ff377602b6fc7caaf30dbc218371jacobs
355b4669e025ff377602b6fc7caaf30dbc218371jacobs return (-1);
355b4669e025ff377602b6fc7caaf30dbc218371jacobs }
355b4669e025ff377602b6fc7caaf30dbc218371jacobs
355b4669e025ff377602b6fc7caaf30dbc218371jacobs buffer += bytes;
355b4669e025ff377602b6fc7caaf30dbc218371jacobs tbytes += bytes;
355b4669e025ff377602b6fc7caaf30dbc218371jacobs length -= bytes;
355b4669e025ff377602b6fc7caaf30dbc218371jacobs if (http->data_encoding == HTTP_ENCODE_LENGTH)
355b4669e025ff377602b6fc7caaf30dbc218371jacobs http->data_remaining -= bytes;
355b4669e025ff377602b6fc7caaf30dbc218371jacobs }
355b4669e025ff377602b6fc7caaf30dbc218371jacobs
355b4669e025ff377602b6fc7caaf30dbc218371jacobs if (http->data_encoding == HTTP_ENCODE_CHUNKED)
355b4669e025ff377602b6fc7caaf30dbc218371jacobs if (httpPrintf(http, "\r\n") < 0)
355b4669e025ff377602b6fc7caaf30dbc218371jacobs return (-1);
355b4669e025ff377602b6fc7caaf30dbc218371jacobs
355b4669e025ff377602b6fc7caaf30dbc218371jacobs if (http->data_remaining == 0 && http->data_encoding == HTTP_ENCODE_LENGTH)
355b4669e025ff377602b6fc7caaf30dbc218371jacobs {
355b4669e025ff377602b6fc7caaf30dbc218371jacobs /*
355b4669e025ff377602b6fc7caaf30dbc218371jacobs * Finished with the transfer; unless we are sending POST or PUT
355b4669e025ff377602b6fc7caaf30dbc218371jacobs * data, go idle...
355b4669e025ff377602b6fc7caaf30dbc218371jacobs */
355b4669e025ff377602b6fc7caaf30dbc218371jacobs
355b4669e025ff377602b6fc7caaf30dbc218371jacobs DEBUG_printf(("httpWrite: changing states from %d", http->state));
355b4669e025ff377602b6fc7caaf30dbc218371jacobs
355b4669e025ff377602b6fc7caaf30dbc218371jacobs if (http->state == HTTP_POST_RECV)
355b4669e025ff377602b6fc7caaf30dbc218371jacobs http->state ++;
355b4669e025ff377602b6fc7caaf30dbc218371jacobs else if (http->state == HTTP_PUT_RECV)
355b4669e025ff377602b6fc7caaf30dbc218371jacobs http->state = HTTP_STATUS;
355b4669e025ff377602b6fc7caaf30dbc218371jacobs else
355b4669e025ff377602b6fc7caaf30dbc218371jacobs http->state = HTTP_WAITING;
355b4669e025ff377602b6fc7caaf30dbc218371jacobs
355b4669e025ff377602b6fc7caaf30dbc218371jacobs DEBUG_printf((" to %d\n", http->state));
355b4669e025ff377602b6fc7caaf30dbc218371jacobs }
355b4669e025ff377602b6fc7caaf30dbc218371jacobs
355b4669e025ff377602b6fc7caaf30dbc218371jacobs return (tbytes);
355b4669e025ff377602b6fc7caaf30dbc218371jacobs}
355b4669e025ff377602b6fc7caaf30dbc218371jacobs
355b4669e025ff377602b6fc7caaf30dbc218371jacobs
355b4669e025ff377602b6fc7caaf30dbc218371jacobs/*
355b4669e025ff377602b6fc7caaf30dbc218371jacobs * 'httpGets()' - Get a line of text from a HTTP connection.
355b4669e025ff377602b6fc7caaf30dbc218371jacobs */
355b4669e025ff377602b6fc7caaf30dbc218371jacobs
355b4669e025ff377602b6fc7caaf30dbc218371jacobschar * /* O - Line or NULL */
355b4669e025ff377602b6fc7caaf30dbc218371jacobshttpGets(char *line, /* I - Line to read into */
355b4669e025ff377602b6fc7caaf30dbc218371jacobs int length, /* I - Max length of buffer */
355b4669e025ff377602b6fc7caaf30dbc218371jacobs http_t *http) /* I - HTTP data */
355b4669e025ff377602b6fc7caaf30dbc218371jacobs{
355b4669e025ff377602b6fc7caaf30dbc218371jacobs char *lineptr, /* Pointer into line */
355b4669e025ff377602b6fc7caaf30dbc218371jacobs *bufptr, /* Pointer into input buffer */
355b4669e025ff377602b6fc7caaf30dbc218371jacobs *bufend; /* Pointer to end of buffer */
355b4669e025ff377602b6fc7caaf30dbc218371jacobs int bytes; /* Number of bytes read */
355b4669e025ff377602b6fc7caaf30dbc218371jacobs
355b4669e025ff377602b6fc7caaf30dbc218371jacobs
355b4669e025ff377602b6fc7caaf30dbc218371jacobs DEBUG_printf(("httpGets(line=%p, length=%d, http=%p)\n", line, length, http));
355b4669e025ff377602b6fc7caaf30dbc218371jacobs
355b4669e025ff377602b6fc7caaf30dbc218371jacobs if (http == NULL || line == NULL)
355b4669e025ff377602b6fc7caaf30dbc218371jacobs return (NULL);
355b4669e025ff377602b6fc7caaf30dbc218371jacobs
355b4669e025ff377602b6fc7caaf30dbc218371jacobs /*
355b4669e025ff377602b6fc7caaf30dbc218371jacobs * Pre-scan the buffer and see if there is a newline in there...
355b4669e025ff377602b6fc7caaf30dbc218371jacobs */
355b4669e025ff377602b6fc7caaf30dbc218371jacobs
355b4669e025ff377602b6fc7caaf30dbc218371jacobs#ifdef WIN32
355b4669e025ff377602b6fc7caaf30dbc218371jacobs WSASetLastError(0);
355b4669e025ff377602b6fc7caaf30dbc218371jacobs#else
355b4669e025ff377602b6fc7caaf30dbc218371jacobs errno = 0;
355b4669e025ff377602b6fc7caaf30dbc218371jacobs#endif /* WIN32 */
355b4669e025ff377602b6fc7caaf30dbc218371jacobs
355b4669e025ff377602b6fc7caaf30dbc218371jacobs do
355b4669e025ff377602b6fc7caaf30dbc218371jacobs {
355b4669e025ff377602b6fc7caaf30dbc218371jacobs bufptr = http->buffer;
355b4669e025ff377602b6fc7caaf30dbc218371jacobs bufend = http->buffer + http->used;
355b4669e025ff377602b6fc7caaf30dbc218371jacobs
355b4669e025ff377602b6fc7caaf30dbc218371jacobs while (bufptr < bufend)
355b4669e025ff377602b6fc7caaf30dbc218371jacobs if (*bufptr == 0x0a)
355b4669e025ff377602b6fc7caaf30dbc218371jacobs break;
355b4669e025ff377602b6fc7caaf30dbc218371jacobs else
355b4669e025ff377602b6fc7caaf30dbc218371jacobs bufptr ++;
355b4669e025ff377602b6fc7caaf30dbc218371jacobs
355b4669e025ff377602b6fc7caaf30dbc218371jacobs if (bufptr >= bufend && http->used < HTTP_MAX_BUFFER)
355b4669e025ff377602b6fc7caaf30dbc218371jacobs {
355b4669e025ff377602b6fc7caaf30dbc218371jacobs /*
355b4669e025ff377602b6fc7caaf30dbc218371jacobs * No newline; see if there is more data to be read...
355b4669e025ff377602b6fc7caaf30dbc218371jacobs */
355b4669e025ff377602b6fc7caaf30dbc218371jacobs
355b4669e025ff377602b6fc7caaf30dbc218371jacobs if (!http->blocking && !http_wait(http, 1000))
355b4669e025ff377602b6fc7caaf30dbc218371jacobs return (NULL);
355b4669e025ff377602b6fc7caaf30dbc218371jacobs
355b4669e025ff377602b6fc7caaf30dbc218371jacobs#ifdef HAVE_SSL
355b4669e025ff377602b6fc7caaf30dbc218371jacobs if (http->tls)
355b4669e025ff377602b6fc7caaf30dbc218371jacobs bytes = http_read_ssl(http, bufend, HTTP_MAX_BUFFER - http->used);
355b4669e025ff377602b6fc7caaf30dbc218371jacobs else
355b4669e025ff377602b6fc7caaf30dbc218371jacobs#endif /* HAVE_SSL */
355b4669e025ff377602b6fc7caaf30dbc218371jacobs bytes = recv(http->fd, bufend, HTTP_MAX_BUFFER - http->used, 0);
355b4669e025ff377602b6fc7caaf30dbc218371jacobs
355b4669e025ff377602b6fc7caaf30dbc218371jacobs DEBUG_printf(("httpGets: read %d bytes...\n", bytes));
355b4669e025ff377602b6fc7caaf30dbc218371jacobs#ifdef DEBUG_HTTP
355b4669e025ff377602b6fc7caaf30dbc218371jacobs httpDumpData(stdout, "httpGets:", bufend, bytes);
355b4669e025ff377602b6fc7caaf30dbc218371jacobs#endif
355b4669e025ff377602b6fc7caaf30dbc218371jacobs
355b4669e025ff377602b6fc7caaf30dbc218371jacobs if (bytes < 0)
355b4669e025ff377602b6fc7caaf30dbc218371jacobs {
355b4669e025ff377602b6fc7caaf30dbc218371jacobs /*
355b4669e025ff377602b6fc7caaf30dbc218371jacobs * Nope, can't get a line this time...
355b4669e025ff377602b6fc7caaf30dbc218371jacobs */
355b4669e025ff377602b6fc7caaf30dbc218371jacobs
355b4669e025ff377602b6fc7caaf30dbc218371jacobs#ifdef WIN32
355b4669e025ff377602b6fc7caaf30dbc218371jacobs if (WSAGetLastError() != http->error)
355b4669e025ff377602b6fc7caaf30dbc218371jacobs {
355b4669e025ff377602b6fc7caaf30dbc218371jacobs http->error = WSAGetLastError();
355b4669e025ff377602b6fc7caaf30dbc218371jacobs continue;
355b4669e025ff377602b6fc7caaf30dbc218371jacobs }
355b4669e025ff377602b6fc7caaf30dbc218371jacobs
355b4669e025ff377602b6fc7caaf30dbc218371jacobs DEBUG_printf(("httpGets: recv() error %d!\n", WSAGetLastError()));
355b4669e025ff377602b6fc7caaf30dbc218371jacobs#else
355b4669e025ff377602b6fc7caaf30dbc218371jacobs DEBUG_printf(("httpGets: recv() error %d!\n", errno));
355b4669e025ff377602b6fc7caaf30dbc218371jacobs
355b4669e025ff377602b6fc7caaf30dbc218371jacobs if (errno == EINTR)
355b4669e025ff377602b6fc7caaf30dbc218371jacobs continue;
355b4669e025ff377602b6fc7caaf30dbc218371jacobs else if (errno != http->error)
355b4669e025ff377602b6fc7caaf30dbc218371jacobs {
355b4669e025ff377602b6fc7caaf30dbc218371jacobs http->error = errno;
355b4669e025ff377602b6fc7caaf30dbc218371jacobs continue;
355b4669e025ff377602b6fc7caaf30dbc218371jacobs }
355b4669e025ff377602b6fc7caaf30dbc218371jacobs#endif /* WIN32 */
355b4669e025ff377602b6fc7caaf30dbc218371jacobs
355b4669e025ff377602b6fc7caaf30dbc218371jacobs return (NULL);
355b4669e025ff377602b6fc7caaf30dbc218371jacobs }
355b4669e025ff377602b6fc7caaf30dbc218371jacobs else if (bytes == 0)
355b4669e025ff377602b6fc7caaf30dbc218371jacobs {
355b4669e025ff377602b6fc7caaf30dbc218371jacobs http->error = EPIPE;
355b4669e025ff377602b6fc7caaf30dbc218371jacobs
355b4669e025ff377602b6fc7caaf30dbc218371jacobs return (NULL);
355b4669e025ff377602b6fc7caaf30dbc218371jacobs }
355b4669e025ff377602b6fc7caaf30dbc218371jacobs
355b4669e025ff377602b6fc7caaf30dbc218371jacobs /*
355b4669e025ff377602b6fc7caaf30dbc218371jacobs * Yup, update the amount used and the end pointer...
355b4669e025ff377602b6fc7caaf30dbc218371jacobs */
355b4669e025ff377602b6fc7caaf30dbc218371jacobs
355b4669e025ff377602b6fc7caaf30dbc218371jacobs http->used += bytes;
355b4669e025ff377602b6fc7caaf30dbc218371jacobs bufend += bytes;
355b4669e025ff377602b6fc7caaf30dbc218371jacobs bufptr = bufend;
355b4669e025ff377602b6fc7caaf30dbc218371jacobs }
355b4669e025ff377602b6fc7caaf30dbc218371jacobs }
355b4669e025ff377602b6fc7caaf30dbc218371jacobs while (bufptr >= bufend && http->used < HTTP_MAX_BUFFER);
355b4669e025ff377602b6fc7caaf30dbc218371jacobs
355b4669e025ff377602b6fc7caaf30dbc218371jacobs http->activity = time(NULL);
355b4669e025ff377602b6fc7caaf30dbc218371jacobs
355b4669e025ff377602b6fc7caaf30dbc218371jacobs /*
355b4669e025ff377602b6fc7caaf30dbc218371jacobs * Read a line from the buffer...
355b4669e025ff377602b6fc7caaf30dbc218371jacobs */
355b4669e025ff377602b6fc7caaf30dbc218371jacobs
355b4669e025ff377602b6fc7caaf30dbc218371jacobs lineptr = line;
355b4669e025ff377602b6fc7caaf30dbc218371jacobs bufptr = http->buffer;
355b4669e025ff377602b6fc7caaf30dbc218371jacobs bytes = 0;
355b4669e025ff377602b6fc7caaf30dbc218371jacobs length --;
355b4669e025ff377602b6fc7caaf30dbc218371jacobs
355b4669e025ff377602b6fc7caaf30dbc218371jacobs while (bufptr < bufend && bytes < length)
355b4669e025ff377602b6fc7caaf30dbc218371jacobs {
355b4669e025ff377602b6fc7caaf30dbc218371jacobs bytes ++;
355b4669e025ff377602b6fc7caaf30dbc218371jacobs
355b4669e025ff377602b6fc7caaf30dbc218371jacobs if (*bufptr == 0x0a)
355b4669e025ff377602b6fc7caaf30dbc218371jacobs {
355b4669e025ff377602b6fc7caaf30dbc218371jacobs bufptr ++;
355b4669e025ff377602b6fc7caaf30dbc218371jacobs break;
355b4669e025ff377602b6fc7caaf30dbc218371jacobs }
355b4669e025ff377602b6fc7caaf30dbc218371jacobs else if (*bufptr == 0x0d)
355b4669e025ff377602b6fc7caaf30dbc218371jacobs bufptr ++;
355b4669e025ff377602b6fc7caaf30dbc218371jacobs else
355b4669e025ff377602b6fc7caaf30dbc218371jacobs *lineptr++ = *bufptr++;
355b4669e025ff377602b6fc7caaf30dbc218371jacobs }
355b4669e025ff377602b6fc7caaf30dbc218371jacobs
355b4669e025ff377602b6fc7caaf30dbc218371jacobs if (bytes > 0)
355b4669e025ff377602b6fc7caaf30dbc218371jacobs {
355b4669e025ff377602b6fc7caaf30dbc218371jacobs *lineptr = '\0';
355b4669e025ff377602b6fc7caaf30dbc218371jacobs
355b4669e025ff377602b6fc7caaf30dbc218371jacobs http->used -= bytes;
355b4669e025ff377602b6fc7caaf30dbc218371jacobs if (http->used > 0)
355b4669e025ff377602b6fc7caaf30dbc218371jacobs memmove(http->buffer, bufptr, http->used);
355b4669e025ff377602b6fc7caaf30dbc218371jacobs
355b4669e025ff377602b6fc7caaf30dbc218371jacobs DEBUG_printf(("httpGets: Returning \"%s\"\n", line));
355b4669e025ff377602b6fc7caaf30dbc218371jacobs return (line);
355b4669e025ff377602b6fc7caaf30dbc218371jacobs }
355b4669e025ff377602b6fc7caaf30dbc218371jacobs
355b4669e025ff377602b6fc7caaf30dbc218371jacobs DEBUG_puts("httpGets: No new line available!");
355b4669e025ff377602b6fc7caaf30dbc218371jacobs
355b4669e025ff377602b6fc7caaf30dbc218371jacobs return (NULL);
355b4669e025ff377602b6fc7caaf30dbc218371jacobs}
355b4669e025ff377602b6fc7caaf30dbc218371jacobs
355b4669e025ff377602b6fc7caaf30dbc218371jacobs
355b4669e025ff377602b6fc7caaf30dbc218371jacobs/*
355b4669e025ff377602b6fc7caaf30dbc218371jacobs * 'httpPrintf()' - Print a formatted string to a HTTP connection.
355b4669e025ff377602b6fc7caaf30dbc218371jacobs */
355b4669e025ff377602b6fc7caaf30dbc218371jacobs
355b4669e025ff377602b6fc7caaf30dbc218371jacobsint /* O - Number of bytes written */
355b4669e025ff377602b6fc7caaf30dbc218371jacobshttpPrintf(http_t *http, /* I - HTTP data */
355b4669e025ff377602b6fc7caaf30dbc218371jacobs const char *format, /* I - printf-style format string */
355b4669e025ff377602b6fc7caaf30dbc218371jacobs ...) /* I - Additional args as needed */
355b4669e025ff377602b6fc7caaf30dbc218371jacobs{
355b4669e025ff377602b6fc7caaf30dbc218371jacobs int bytes, /* Number of bytes to write */
355b4669e025ff377602b6fc7caaf30dbc218371jacobs nbytes, /* Number of bytes written */
355b4669e025ff377602b6fc7caaf30dbc218371jacobs tbytes; /* Number of bytes all together */
355b4669e025ff377602b6fc7caaf30dbc218371jacobs char buf[HTTP_MAX_BUFFER], /* Buffer for formatted string */
355b4669e025ff377602b6fc7caaf30dbc218371jacobs *bufptr; /* Pointer into buffer */
355b4669e025ff377602b6fc7caaf30dbc218371jacobs va_list ap; /* Variable argument pointer */
355b4669e025ff377602b6fc7caaf30dbc218371jacobs
355b4669e025ff377602b6fc7caaf30dbc218371jacobs
355b4669e025ff377602b6fc7caaf30dbc218371jacobs DEBUG_printf(("httpPrintf: httpPrintf(http=%p, format=\"%s\", ...)\n", http, format));
355b4669e025ff377602b6fc7caaf30dbc218371jacobs
355b4669e025ff377602b6fc7caaf30dbc218371jacobs va_start(ap, format);
355b4669e025ff377602b6fc7caaf30dbc218371jacobs bytes = vsnprintf(buf, sizeof(buf), format, ap);
355b4669e025ff377602b6fc7caaf30dbc218371jacobs va_end(ap);
355b4669e025ff377602b6fc7caaf30dbc218371jacobs
355b4669e025ff377602b6fc7caaf30dbc218371jacobs DEBUG_printf(("httpPrintf: %s", buf));
355b4669e025ff377602b6fc7caaf30dbc218371jacobs
355b4669e025ff377602b6fc7caaf30dbc218371jacobs for (tbytes = 0, bufptr = buf; tbytes < bytes; tbytes += nbytes, bufptr += nbytes)
355b4669e025ff377602b6fc7caaf30dbc218371jacobs {
355b4669e025ff377602b6fc7caaf30dbc218371jacobs#ifdef HAVE_SSL
355b4669e025ff377602b6fc7caaf30dbc218371jacobs if (http->tls)
355b4669e025ff377602b6fc7caaf30dbc218371jacobs nbytes = http_write_ssl(http, bufptr, bytes - tbytes);
355b4669e025ff377602b6fc7caaf30dbc218371jacobs else
355b4669e025ff377602b6fc7caaf30dbc218371jacobs#endif /* HAVE_SSL */
355b4669e025ff377602b6fc7caaf30dbc218371jacobs nbytes = send(http->fd, bufptr, bytes - tbytes, 0);
355b4669e025ff377602b6fc7caaf30dbc218371jacobs
355b4669e025ff377602b6fc7caaf30dbc218371jacobs#ifdef DEBUG_HTTP
355b4669e025ff377602b6fc7caaf30dbc218371jacobs if (nbytes >= 0)
355b4669e025ff377602b6fc7caaf30dbc218371jacobs httpDumpData(stdout, "httpPrintf:", bufptr, nbytes);
355b4669e025ff377602b6fc7caaf30dbc218371jacobs#endif
355b4669e025ff377602b6fc7caaf30dbc218371jacobs
355b4669e025ff377602b6fc7caaf30dbc218371jacobs if (nbytes < 0)
355b4669e025ff377602b6fc7caaf30dbc218371jacobs {
355b4669e025ff377602b6fc7caaf30dbc218371jacobs nbytes = 0;
355b4669e025ff377602b6fc7caaf30dbc218371jacobs
355b4669e025ff377602b6fc7caaf30dbc218371jacobs#ifdef WIN32
355b4669e025ff377602b6fc7caaf30dbc218371jacobs if (WSAGetLastError() != http->error)
355b4669e025ff377602b6fc7caaf30dbc218371jacobs {
355b4669e025ff377602b6fc7caaf30dbc218371jacobs http->error = WSAGetLastError();
355b4669e025ff377602b6fc7caaf30dbc218371jacobs continue;
355b4669e025ff377602b6fc7caaf30dbc218371jacobs }
355b4669e025ff377602b6fc7caaf30dbc218371jacobs#else
355b4669e025ff377602b6fc7caaf30dbc218371jacobs if (errno == EINTR)
355b4669e025ff377602b6fc7caaf30dbc218371jacobs continue;
355b4669e025ff377602b6fc7caaf30dbc218371jacobs else if (errno != http->error)
355b4669e025ff377602b6fc7caaf30dbc218371jacobs {
355b4669e025ff377602b6fc7caaf30dbc218371jacobs http->error = errno;
355b4669e025ff377602b6fc7caaf30dbc218371jacobs continue;
355b4669e025ff377602b6fc7caaf30dbc218371jacobs }
355b4669e025ff377602b6fc7caaf30dbc218371jacobs#endif /* WIN32 */
355b4669e025ff377602b6fc7caaf30dbc218371jacobs
355b4669e025ff377602b6fc7caaf30dbc218371jacobs return (-1);
355b4669e025ff377602b6fc7caaf30dbc218371jacobs }
355b4669e025ff377602b6fc7caaf30dbc218371jacobs }
355b4669e025ff377602b6fc7caaf30dbc218371jacobs
355b4669e025ff377602b6fc7caaf30dbc218371jacobs return (bytes);
355b4669e025ff377602b6fc7caaf30dbc218371jacobs}
355b4669e025ff377602b6fc7caaf30dbc218371jacobs
355b4669e025ff377602b6fc7caaf30dbc218371jacobs
355b4669e025ff377602b6fc7caaf30dbc218371jacobs/*
355b4669e025ff377602b6fc7caaf30dbc218371jacobs * 'httpGetDateString()' - Get a formatted date/time string from a time value.
355b4669e025ff377602b6fc7caaf30dbc218371jacobs */
355b4669e025ff377602b6fc7caaf30dbc218371jacobs
355b4669e025ff377602b6fc7caaf30dbc218371jacobsconst char * /* O - Date/time string */
355b4669e025ff377602b6fc7caaf30dbc218371jacobshttpGetDateString(time_t t) /* I - UNIX time */
355b4669e025ff377602b6fc7caaf30dbc218371jacobs{
355b4669e025ff377602b6fc7caaf30dbc218371jacobs struct tm *tdate;
355b4669e025ff377602b6fc7caaf30dbc218371jacobs static char datetime[256];
355b4669e025ff377602b6fc7caaf30dbc218371jacobs
355b4669e025ff377602b6fc7caaf30dbc218371jacobs
355b4669e025ff377602b6fc7caaf30dbc218371jacobs tdate = gmtime(&t);
355b4669e025ff377602b6fc7caaf30dbc218371jacobs snprintf(datetime, sizeof(datetime), "%s, %02d %s %d %02d:%02d:%02d GMT",
355b4669e025ff377602b6fc7caaf30dbc218371jacobs days[tdate->tm_wday], tdate->tm_mday, months[tdate->tm_mon],
355b4669e025ff377602b6fc7caaf30dbc218371jacobs tdate->tm_year + 1900, tdate->tm_hour, tdate->tm_min, tdate->tm_sec);
355b4669e025ff377602b6fc7caaf30dbc218371jacobs
355b4669e025ff377602b6fc7caaf30dbc218371jacobs return (datetime);
355b4669e025ff377602b6fc7caaf30dbc218371jacobs}
355b4669e025ff377602b6fc7caaf30dbc218371jacobs
355b4669e025ff377602b6fc7caaf30dbc218371jacobs
355b4669e025ff377602b6fc7caaf30dbc218371jacobs/*
355b4669e025ff377602b6fc7caaf30dbc218371jacobs * 'httpGetDateTime()' - Get a time value from a formatted date/time string.
355b4669e025ff377602b6fc7caaf30dbc218371jacobs */
355b4669e025ff377602b6fc7caaf30dbc218371jacobs
355b4669e025ff377602b6fc7caaf30dbc218371jacobstime_t /* O - UNIX time */
355b4669e025ff377602b6fc7caaf30dbc218371jacobshttpGetDateTime(const char *s) /* I - Date/time string */
355b4669e025ff377602b6fc7caaf30dbc218371jacobs{
355b4669e025ff377602b6fc7caaf30dbc218371jacobs int i; /* Looping var */
355b4669e025ff377602b6fc7caaf30dbc218371jacobs struct tm tdate; /* Time/date structure */
355b4669e025ff377602b6fc7caaf30dbc218371jacobs char mon[16]; /* Abbreviated month name */
355b4669e025ff377602b6fc7caaf30dbc218371jacobs int day, year; /* Day of month and year */
355b4669e025ff377602b6fc7caaf30dbc218371jacobs int hour, min, sec; /* Time */
355b4669e025ff377602b6fc7caaf30dbc218371jacobs
355b4669e025ff377602b6fc7caaf30dbc218371jacobs
355b4669e025ff377602b6fc7caaf30dbc218371jacobs if (sscanf(s, "%*s%d%15s%d%d:%d:%d", &day, mon, &year, &hour, &min, &sec) < 6)
355b4669e025ff377602b6fc7caaf30dbc218371jacobs return (0);
355b4669e025ff377602b6fc7caaf30dbc218371jacobs
355b4669e025ff377602b6fc7caaf30dbc218371jacobs for (i = 0; i < 12; i ++)
355b4669e025ff377602b6fc7caaf30dbc218371jacobs if (strcasecmp(mon, months[i]) == 0)
355b4669e025ff377602b6fc7caaf30dbc218371jacobs break;
355b4669e025ff377602b6fc7caaf30dbc218371jacobs
355b4669e025ff377602b6fc7caaf30dbc218371jacobs if (i >= 12)
355b4669e025ff377602b6fc7caaf30dbc218371jacobs return (0);
355b4669e025ff377602b6fc7caaf30dbc218371jacobs
355b4669e025ff377602b6fc7caaf30dbc218371jacobs tdate.tm_mon = i;
355b4669e025ff377602b6fc7caaf30dbc218371jacobs tdate.tm_mday = day;
355b4669e025ff377602b6fc7caaf30dbc218371jacobs tdate.tm_year = year - 1900;
355b4669e025ff377602b6fc7caaf30dbc218371jacobs tdate.tm_hour = hour;
355b4669e025ff377602b6fc7caaf30dbc218371jacobs tdate.tm_min = min;
355b4669e025ff377602b6fc7caaf30dbc218371jacobs tdate.tm_sec = sec;
355b4669e025ff377602b6fc7caaf30dbc218371jacobs tdate.tm_isdst = 0;
355b4669e025ff377602b6fc7caaf30dbc218371jacobs
355b4669e025ff377602b6fc7caaf30dbc218371jacobs return (mktime(&tdate));
355b4669e025ff377602b6fc7caaf30dbc218371jacobs}
355b4669e025ff377602b6fc7caaf30dbc218371jacobs
355b4669e025ff377602b6fc7caaf30dbc218371jacobs
355b4669e025ff377602b6fc7caaf30dbc218371jacobs/*
355b4669e025ff377602b6fc7caaf30dbc218371jacobs * 'httpUpdate()' - Update the current HTTP state for incoming data.
355b4669e025ff377602b6fc7caaf30dbc218371jacobs */
355b4669e025ff377602b6fc7caaf30dbc218371jacobs
355b4669e025ff377602b6fc7caaf30dbc218371jacobshttp_status_t /* O - HTTP status */
355b4669e025ff377602b6fc7caaf30dbc218371jacobshttpUpdate(http_t *http) /* I - HTTP data */
355b4669e025ff377602b6fc7caaf30dbc218371jacobs{
355b4669e025ff377602b6fc7caaf30dbc218371jacobs char line[1024], /* Line from connection... */
355b4669e025ff377602b6fc7caaf30dbc218371jacobs *value; /* Pointer to value on line */
355b4669e025ff377602b6fc7caaf30dbc218371jacobs http_field_t field; /* Field index */
355b4669e025ff377602b6fc7caaf30dbc218371jacobs int major, minor, /* HTTP version numbers */
355b4669e025ff377602b6fc7caaf30dbc218371jacobs status; /* Request status */
355b4669e025ff377602b6fc7caaf30dbc218371jacobs
355b4669e025ff377602b6fc7caaf30dbc218371jacobs
355b4669e025ff377602b6fc7caaf30dbc218371jacobs DEBUG_printf(("httpUpdate(http=%p), state=%d\n", http, http->state));
355b4669e025ff377602b6fc7caaf30dbc218371jacobs
355b4669e025ff377602b6fc7caaf30dbc218371jacobs /*
355b4669e025ff377602b6fc7caaf30dbc218371jacobs * If we haven't issued any commands, then there is nothing to "update"...
355b4669e025ff377602b6fc7caaf30dbc218371jacobs */
355b4669e025ff377602b6fc7caaf30dbc218371jacobs
355b4669e025ff377602b6fc7caaf30dbc218371jacobs if (http->state == HTTP_WAITING)
355b4669e025ff377602b6fc7caaf30dbc218371jacobs return (HTTP_CONTINUE);
355b4669e025ff377602b6fc7caaf30dbc218371jacobs
355b4669e025ff377602b6fc7caaf30dbc218371jacobs /*
355b4669e025ff377602b6fc7caaf30dbc218371jacobs * Grab all of the lines we can from the connection...
355b4669e025ff377602b6fc7caaf30dbc218371jacobs */
355b4669e025ff377602b6fc7caaf30dbc218371jacobs
355b4669e025ff377602b6fc7caaf30dbc218371jacobs line[0] = '\0';
355b4669e025ff377602b6fc7caaf30dbc218371jacobs while (httpGets(line, sizeof(line), http) != NULL)
355b4669e025ff377602b6fc7caaf30dbc218371jacobs {
355b4669e025ff377602b6fc7caaf30dbc218371jacobs DEBUG_printf(("httpUpdate: Got \"%s\"\n", line));
355b4669e025ff377602b6fc7caaf30dbc218371jacobs
355b4669e025ff377602b6fc7caaf30dbc218371jacobs if (line[0] == '\0')
355b4669e025ff377602b6fc7caaf30dbc218371jacobs {
355b4669e025ff377602b6fc7caaf30dbc218371jacobs /*
355b4669e025ff377602b6fc7caaf30dbc218371jacobs * Blank line means the start of the data section (if any). Return
355b4669e025ff377602b6fc7caaf30dbc218371jacobs * the result code, too...
355b4669e025ff377602b6fc7caaf30dbc218371jacobs *
355b4669e025ff377602b6fc7caaf30dbc218371jacobs * If we get status 100 (HTTP_CONTINUE), then we *don't* change states.
355b4669e025ff377602b6fc7caaf30dbc218371jacobs * Instead, we just return HTTP_CONTINUE to the caller and keep on
355b4669e025ff377602b6fc7caaf30dbc218371jacobs * tryin'...
355b4669e025ff377602b6fc7caaf30dbc218371jacobs */
355b4669e025ff377602b6fc7caaf30dbc218371jacobs
355b4669e025ff377602b6fc7caaf30dbc218371jacobs if (http->status == HTTP_CONTINUE)
355b4669e025ff377602b6fc7caaf30dbc218371jacobs return (http->status);
355b4669e025ff377602b6fc7caaf30dbc218371jacobs
355b4669e025ff377602b6fc7caaf30dbc218371jacobs if (http->status < HTTP_BAD_REQUEST)
355b4669e025ff377602b6fc7caaf30dbc218371jacobs http->digest_tries = 0;
355b4669e025ff377602b6fc7caaf30dbc218371jacobs
355b4669e025ff377602b6fc7caaf30dbc218371jacobs#ifdef HAVE_SSL
355b4669e025ff377602b6fc7caaf30dbc218371jacobs if (http->status == HTTP_SWITCHING_PROTOCOLS && !http->tls)
355b4669e025ff377602b6fc7caaf30dbc218371jacobs {
355b4669e025ff377602b6fc7caaf30dbc218371jacobs if (http_setup_ssl(http) != 0)
355b4669e025ff377602b6fc7caaf30dbc218371jacobs {
355b4669e025ff377602b6fc7caaf30dbc218371jacobs# ifdef WIN32
355b4669e025ff377602b6fc7caaf30dbc218371jacobs closesocket(http->fd);
355b4669e025ff377602b6fc7caaf30dbc218371jacobs# else
355b4669e025ff377602b6fc7caaf30dbc218371jacobs close(http->fd);
355b4669e025ff377602b6fc7caaf30dbc218371jacobs# endif /* WIN32 */
355b4669e025ff377602b6fc7caaf30dbc218371jacobs
355b4669e025ff377602b6fc7caaf30dbc218371jacobs return (HTTP_ERROR);
355b4669e025ff377602b6fc7caaf30dbc218371jacobs }
355b4669e025ff377602b6fc7caaf30dbc218371jacobs
355b4669e025ff377602b6fc7caaf30dbc218371jacobs return (HTTP_CONTINUE);
355b4669e025ff377602b6fc7caaf30dbc218371jacobs }
355b4669e025ff377602b6fc7caaf30dbc218371jacobs#endif /* HAVE_SSL */
355b4669e025ff377602b6fc7caaf30dbc218371jacobs
355b4669e025ff377602b6fc7caaf30dbc218371jacobs httpGetLength(http);
355b4669e025ff377602b6fc7caaf30dbc218371jacobs
355b4669e025ff377602b6fc7caaf30dbc218371jacobs switch (http->state)
355b4669e025ff377602b6fc7caaf30dbc218371jacobs {
355b4669e025ff377602b6fc7caaf30dbc218371jacobs case HTTP_GET :
355b4669e025ff377602b6fc7caaf30dbc218371jacobs case HTTP_POST :
355b4669e025ff377602b6fc7caaf30dbc218371jacobs case HTTP_POST_RECV :
355b4669e025ff377602b6fc7caaf30dbc218371jacobs case HTTP_PUT :
355b4669e025ff377602b6fc7caaf30dbc218371jacobs http->state ++;
355b4669e025ff377602b6fc7caaf30dbc218371jacobs case HTTP_POST_SEND :
355b4669e025ff377602b6fc7caaf30dbc218371jacobs break;
355b4669e025ff377602b6fc7caaf30dbc218371jacobs
355b4669e025ff377602b6fc7caaf30dbc218371jacobs default :
355b4669e025ff377602b6fc7caaf30dbc218371jacobs http->state = HTTP_WAITING;
355b4669e025ff377602b6fc7caaf30dbc218371jacobs break;
355b4669e025ff377602b6fc7caaf30dbc218371jacobs }
355b4669e025ff377602b6fc7caaf30dbc218371jacobs
355b4669e025ff377602b6fc7caaf30dbc218371jacobs return (http->status);
355b4669e025ff377602b6fc7caaf30dbc218371jacobs }
355b4669e025ff377602b6fc7caaf30dbc218371jacobs else if (strncmp(line, "HTTP/", 5) == 0)
355b4669e025ff377602b6fc7caaf30dbc218371jacobs {
355b4669e025ff377602b6fc7caaf30dbc218371jacobs /*
355b4669e025ff377602b6fc7caaf30dbc218371jacobs * Got the beginning of a response...
355b4669e025ff377602b6fc7caaf30dbc218371jacobs */
355b4669e025ff377602b6fc7caaf30dbc218371jacobs
355b4669e025ff377602b6fc7caaf30dbc218371jacobs if (sscanf(line, "HTTP/%d.%d%d", &major, &minor, &status) != 3)
355b4669e025ff377602b6fc7caaf30dbc218371jacobs return (HTTP_ERROR);
355b4669e025ff377602b6fc7caaf30dbc218371jacobs
355b4669e025ff377602b6fc7caaf30dbc218371jacobs http->version = (http_version_t)(major * 100 + minor);
355b4669e025ff377602b6fc7caaf30dbc218371jacobs http->status = (http_status_t)status;
355b4669e025ff377602b6fc7caaf30dbc218371jacobs }
355b4669e025ff377602b6fc7caaf30dbc218371jacobs else if ((value = strchr(line, ':')) != NULL)
355b4669e025ff377602b6fc7caaf30dbc218371jacobs {
355b4669e025ff377602b6fc7caaf30dbc218371jacobs /*
355b4669e025ff377602b6fc7caaf30dbc218371jacobs * Got a value...
355b4669e025ff377602b6fc7caaf30dbc218371jacobs */
355b4669e025ff377602b6fc7caaf30dbc218371jacobs
355b4669e025ff377602b6fc7caaf30dbc218371jacobs *value++ = '\0';
355b4669e025ff377602b6fc7caaf30dbc218371jacobs while (isspace(*value & 255))
355b4669e025ff377602b6fc7caaf30dbc218371jacobs value ++;
355b4669e025ff377602b6fc7caaf30dbc218371jacobs
355b4669e025ff377602b6fc7caaf30dbc218371jacobs /*
355b4669e025ff377602b6fc7caaf30dbc218371jacobs * Be tolerants of servers that send unknown attribute fields...
355b4669e025ff377602b6fc7caaf30dbc218371jacobs */
355b4669e025ff377602b6fc7caaf30dbc218371jacobs
355b4669e025ff377602b6fc7caaf30dbc218371jacobs if (!strcasecmp(line, "expect"))
355b4669e025ff377602b6fc7caaf30dbc218371jacobs {
355b4669e025ff377602b6fc7caaf30dbc218371jacobs /*
355b4669e025ff377602b6fc7caaf30dbc218371jacobs * "Expect: 100-continue" or similar...
355b4669e025ff377602b6fc7caaf30dbc218371jacobs */
355b4669e025ff377602b6fc7caaf30dbc218371jacobs
355b4669e025ff377602b6fc7caaf30dbc218371jacobs http->expect = (http_status_t)atoi(value);
355b4669e025ff377602b6fc7caaf30dbc218371jacobs }
355b4669e025ff377602b6fc7caaf30dbc218371jacobs else if (!strcasecmp(line, "cookie"))
355b4669e025ff377602b6fc7caaf30dbc218371jacobs {
355b4669e025ff377602b6fc7caaf30dbc218371jacobs /*
355b4669e025ff377602b6fc7caaf30dbc218371jacobs * "Cookie: name=value[; name=value ...]" - replaces previous cookies...
355b4669e025ff377602b6fc7caaf30dbc218371jacobs */
355b4669e025ff377602b6fc7caaf30dbc218371jacobs
355b4669e025ff377602b6fc7caaf30dbc218371jacobs httpSetCookie(http, value);
355b4669e025ff377602b6fc7caaf30dbc218371jacobs }
355b4669e025ff377602b6fc7caaf30dbc218371jacobs else if ((field = http_field(line)) == HTTP_FIELD_UNKNOWN)
355b4669e025ff377602b6fc7caaf30dbc218371jacobs {
355b4669e025ff377602b6fc7caaf30dbc218371jacobs DEBUG_printf(("httpUpdate: unknown field %s seen!\n", line));
355b4669e025ff377602b6fc7caaf30dbc218371jacobs continue;
355b4669e025ff377602b6fc7caaf30dbc218371jacobs }
355b4669e025ff377602b6fc7caaf30dbc218371jacobs else
355b4669e025ff377602b6fc7caaf30dbc218371jacobs httpSetField(http, field, value);
355b4669e025ff377602b6fc7caaf30dbc218371jacobs }
355b4669e025ff377602b6fc7caaf30dbc218371jacobs else
355b4669e025ff377602b6fc7caaf30dbc218371jacobs {
355b4669e025ff377602b6fc7caaf30dbc218371jacobs http->status = HTTP_ERROR;
355b4669e025ff377602b6fc7caaf30dbc218371jacobs return (HTTP_ERROR);
355b4669e025ff377602b6fc7caaf30dbc218371jacobs }
355b4669e025ff377602b6fc7caaf30dbc218371jacobs }
355b4669e025ff377602b6fc7caaf30dbc218371jacobs
355b4669e025ff377602b6fc7caaf30dbc218371jacobs /*
355b4669e025ff377602b6fc7caaf30dbc218371jacobs * See if there was an error...
355b4669e025ff377602b6fc7caaf30dbc218371jacobs */
355b4669e025ff377602b6fc7caaf30dbc218371jacobs
355b4669e025ff377602b6fc7caaf30dbc218371jacobs if (http->error == EPIPE && http->status > HTTP_CONTINUE)
355b4669e025ff377602b6fc7caaf30dbc218371jacobs return (http->status);
355b4669e025ff377602b6fc7caaf30dbc218371jacobs
355b4669e025ff377602b6fc7caaf30dbc218371jacobs if (http->error)
355b4669e025ff377602b6fc7caaf30dbc218371jacobs {
355b4669e025ff377602b6fc7caaf30dbc218371jacobs DEBUG_printf(("httpUpdate: socket error %d - %s\n", http->error,
355b4669e025ff377602b6fc7caaf30dbc218371jacobs strerror(http->error)));
355b4669e025ff377602b6fc7caaf30dbc218371jacobs http->status = HTTP_ERROR;
355b4669e025ff377602b6fc7caaf30dbc218371jacobs return (HTTP_ERROR);
355b4669e025ff377602b6fc7caaf30dbc218371jacobs }
355b4669e025ff377602b6fc7caaf30dbc218371jacobs
355b4669e025ff377602b6fc7caaf30dbc218371jacobs /*
355b4669e025ff377602b6fc7caaf30dbc218371jacobs * If we haven't already returned, then there is nothing new...
355b4669e025ff377602b6fc7caaf30dbc218371jacobs */
355b4669e025ff377602b6fc7caaf30dbc218371jacobs
355b4669e025ff377602b6fc7caaf30dbc218371jacobs return (HTTP_CONTINUE);
355b4669e025ff377602b6fc7caaf30dbc218371jacobs}
355b4669e025ff377602b6fc7caaf30dbc218371jacobs
355b4669e025ff377602b6fc7caaf30dbc218371jacobs
355b4669e025ff377602b6fc7caaf30dbc218371jacobs/*
355b4669e025ff377602b6fc7caaf30dbc218371jacobs * 'httpDecode64()' - Base64-decode a string.
355b4669e025ff377602b6fc7caaf30dbc218371jacobs */
355b4669e025ff377602b6fc7caaf30dbc218371jacobs
355b4669e025ff377602b6fc7caaf30dbc218371jacobschar * /* O - Decoded string */
355b4669e025ff377602b6fc7caaf30dbc218371jacobshttpDecode64(char *out, /* I - String to write to */
355b4669e025ff377602b6fc7caaf30dbc218371jacobs const char *in) /* I - String to read from */
355b4669e025ff377602b6fc7caaf30dbc218371jacobs{
355b4669e025ff377602b6fc7caaf30dbc218371jacobs int outlen; /* Output buffer length */
355b4669e025ff377602b6fc7caaf30dbc218371jacobs
355b4669e025ff377602b6fc7caaf30dbc218371jacobs
355b4669e025ff377602b6fc7caaf30dbc218371jacobs /*
355b4669e025ff377602b6fc7caaf30dbc218371jacobs * Use the old maximum buffer size for binary compatibility...
355b4669e025ff377602b6fc7caaf30dbc218371jacobs */
355b4669e025ff377602b6fc7caaf30dbc218371jacobs
355b4669e025ff377602b6fc7caaf30dbc218371jacobs outlen = 512;
355b4669e025ff377602b6fc7caaf30dbc218371jacobs
355b4669e025ff377602b6fc7caaf30dbc218371jacobs return (httpDecode64_2(out, &outlen, in));
355b4669e025ff377602b6fc7caaf30dbc218371jacobs}
355b4669e025ff377602b6fc7caaf30dbc218371jacobs
355b4669e025ff377602b6fc7caaf30dbc218371jacobs
355b4669e025ff377602b6fc7caaf30dbc218371jacobs/*
355b4669e025ff377602b6fc7caaf30dbc218371jacobs * 'httpDecode64_2()' - Base64-decode a string.
355b4669e025ff377602b6fc7caaf30dbc218371jacobs */
355b4669e025ff377602b6fc7caaf30dbc218371jacobs
355b4669e025ff377602b6fc7caaf30dbc218371jacobschar * /* O - Decoded string */
355b4669e025ff377602b6fc7caaf30dbc218371jacobshttpDecode64_2(char *out, /* I - String to write to */
355b4669e025ff377602b6fc7caaf30dbc218371jacobs int *outlen, /* IO - Size of output string */
355b4669e025ff377602b6fc7caaf30dbc218371jacobs const char *in) /* I - String to read from */
355b4669e025ff377602b6fc7caaf30dbc218371jacobs{
355b4669e025ff377602b6fc7caaf30dbc218371jacobs int pos, /* Bit position */
355b4669e025ff377602b6fc7caaf30dbc218371jacobs base64; /* Value of this character */
355b4669e025ff377602b6fc7caaf30dbc218371jacobs char *outptr, /* Output pointer */
355b4669e025ff377602b6fc7caaf30dbc218371jacobs *outend; /* End of output buffer */
355b4669e025ff377602b6fc7caaf30dbc218371jacobs
355b4669e025ff377602b6fc7caaf30dbc218371jacobs
355b4669e025ff377602b6fc7caaf30dbc218371jacobs /*
355b4669e025ff377602b6fc7caaf30dbc218371jacobs * Range check input...
355b4669e025ff377602b6fc7caaf30dbc218371jacobs */
355b4669e025ff377602b6fc7caaf30dbc218371jacobs
355b4669e025ff377602b6fc7caaf30dbc218371jacobs if (!out || !outlen || *outlen < 1 || !in || !*in)
355b4669e025ff377602b6fc7caaf30dbc218371jacobs return (NULL);
355b4669e025ff377602b6fc7caaf30dbc218371jacobs
355b4669e025ff377602b6fc7caaf30dbc218371jacobs /*
355b4669e025ff377602b6fc7caaf30dbc218371jacobs * Convert from base-64 to bytes...
355b4669e025ff377602b6fc7caaf30dbc218371jacobs */
355b4669e025ff377602b6fc7caaf30dbc218371jacobs
355b4669e025ff377602b6fc7caaf30dbc218371jacobs for (outptr = out, outend = out + *outlen - 1, pos = 0; *in != '\0'; in ++)
355b4669e025ff377602b6fc7caaf30dbc218371jacobs {
355b4669e025ff377602b6fc7caaf30dbc218371jacobs /*
355b4669e025ff377602b6fc7caaf30dbc218371jacobs * Decode this character into a number from 0 to 63...
355b4669e025ff377602b6fc7caaf30dbc218371jacobs */
355b4669e025ff377602b6fc7caaf30dbc218371jacobs
355b4669e025ff377602b6fc7caaf30dbc218371jacobs if (*in >= 'A' && *in <= 'Z')
355b4669e025ff377602b6fc7caaf30dbc218371jacobs base64 = *in - 'A';
355b4669e025ff377602b6fc7caaf30dbc218371jacobs else if (*in >= 'a' && *in <= 'z')
355b4669e025ff377602b6fc7caaf30dbc218371jacobs base64 = *in - 'a' + 26;
355b4669e025ff377602b6fc7caaf30dbc218371jacobs else if (*in >= '0' && *in <= '9')
355b4669e025ff377602b6fc7caaf30dbc218371jacobs base64 = *in - '0' + 52;
355b4669e025ff377602b6fc7caaf30dbc218371jacobs else if (*in == '+')
355b4669e025ff377602b6fc7caaf30dbc218371jacobs base64 = 62;
355b4669e025ff377602b6fc7caaf30dbc218371jacobs else if (*in == '/')
355b4669e025ff377602b6fc7caaf30dbc218371jacobs base64 = 63;
355b4669e025ff377602b6fc7caaf30dbc218371jacobs else if (*in == '=')
355b4669e025ff377602b6fc7caaf30dbc218371jacobs break;
355b4669e025ff377602b6fc7caaf30dbc218371jacobs else
355b4669e025ff377602b6fc7caaf30dbc218371jacobs continue;
355b4669e025ff377602b6fc7caaf30dbc218371jacobs
355b4669e025ff377602b6fc7caaf30dbc218371jacobs /*
355b4669e025ff377602b6fc7caaf30dbc218371jacobs * Store the result in the appropriate chars...
355b4669e025ff377602b6fc7caaf30dbc218371jacobs */
355b4669e025ff377602b6fc7caaf30dbc218371jacobs
355b4669e025ff377602b6fc7caaf30dbc218371jacobs switch (pos)
355b4669e025ff377602b6fc7caaf30dbc218371jacobs {
355b4669e025ff377602b6fc7caaf30dbc218371jacobs case 0 :
355b4669e025ff377602b6fc7caaf30dbc218371jacobs if (outptr < outend)
355b4669e025ff377602b6fc7caaf30dbc218371jacobs *outptr = base64 << 2;
355b4669e025ff377602b6fc7caaf30dbc218371jacobs pos ++;
355b4669e025ff377602b6fc7caaf30dbc218371jacobs break;
355b4669e025ff377602b6fc7caaf30dbc218371jacobs case 1 :
355b4669e025ff377602b6fc7caaf30dbc218371jacobs if (outptr < outend)
355b4669e025ff377602b6fc7caaf30dbc218371jacobs *outptr++ |= (base64 >> 4) & 3;
355b4669e025ff377602b6fc7caaf30dbc218371jacobs if (outptr < outend)
355b4669e025ff377602b6fc7caaf30dbc218371jacobs *outptr = (base64 << 4) & 255;
355b4669e025ff377602b6fc7caaf30dbc218371jacobs pos ++;
355b4669e025ff377602b6fc7caaf30dbc218371jacobs break;
355b4669e025ff377602b6fc7caaf30dbc218371jacobs case 2 :
355b4669e025ff377602b6fc7caaf30dbc218371jacobs if (outptr < outend)
355b4669e025ff377602b6fc7caaf30dbc218371jacobs *outptr++ |= (base64 >> 2) & 15;
355b4669e025ff377602b6fc7caaf30dbc218371jacobs if (outptr < outend)
355b4669e025ff377602b6fc7caaf30dbc218371jacobs *outptr = (base64 << 6) & 255;
355b4669e025ff377602b6fc7caaf30dbc218371jacobs pos ++;
355b4669e025ff377602b6fc7caaf30dbc218371jacobs break;
355b4669e025ff377602b6fc7caaf30dbc218371jacobs case 3 :
355b4669e025ff377602b6fc7caaf30dbc218371jacobs if (outptr < outend)
355b4669e025ff377602b6fc7caaf30dbc218371jacobs *outptr++ |= base64;
355b4669e025ff377602b6fc7caaf30dbc218371jacobs pos = 0;
355b4669e025ff377602b6fc7caaf30dbc218371jacobs break;
355b4669e025ff377602b6fc7caaf30dbc218371jacobs }
355b4669e025ff377602b6fc7caaf30dbc218371jacobs }
355b4669e025ff377602b6fc7caaf30dbc218371jacobs
355b4669e025ff377602b6fc7caaf30dbc218371jacobs *outptr = '\0';
355b4669e025ff377602b6fc7caaf30dbc218371jacobs
355b4669e025ff377602b6fc7caaf30dbc218371jacobs /*
355b4669e025ff377602b6fc7caaf30dbc218371jacobs * Return the decoded string and size...
355b4669e025ff377602b6fc7caaf30dbc218371jacobs */
355b4669e025ff377602b6fc7caaf30dbc218371jacobs
355b4669e025ff377602b6fc7caaf30dbc218371jacobs *outlen = (int)(outptr - out);
355b4669e025ff377602b6fc7caaf30dbc218371jacobs
355b4669e025ff377602b6fc7caaf30dbc218371jacobs return (out);
355b4669e025ff377602b6fc7caaf30dbc218371jacobs}
355b4669e025ff377602b6fc7caaf30dbc218371jacobs
355b4669e025ff377602b6fc7caaf30dbc218371jacobs
355b4669e025ff377602b6fc7caaf30dbc218371jacobs/*
355b4669e025ff377602b6fc7caaf30dbc218371jacobs * 'httpEncode64()' - Base64-encode a string.
355b4669e025ff377602b6fc7caaf30dbc218371jacobs */
355b4669e025ff377602b6fc7caaf30dbc218371jacobs
355b4669e025ff377602b6fc7caaf30dbc218371jacobschar * /* O - Encoded string */
355b4669e025ff377602b6fc7caaf30dbc218371jacobshttpEncode64(char *out, /* I - String to write to */
355b4669e025ff377602b6fc7caaf30dbc218371jacobs const char *in) /* I - String to read from */
355b4669e025ff377602b6fc7caaf30dbc218371jacobs{
355b4669e025ff377602b6fc7caaf30dbc218371jacobs return (httpEncode64_2(out, 512, in, strlen(in)));
355b4669e025ff377602b6fc7caaf30dbc218371jacobs}
355b4669e025ff377602b6fc7caaf30dbc218371jacobs
355b4669e025ff377602b6fc7caaf30dbc218371jacobs
355b4669e025ff377602b6fc7caaf30dbc218371jacobs/*
355b4669e025ff377602b6fc7caaf30dbc218371jacobs * 'httpEncode64_2()' - Base64-encode a string.
355b4669e025ff377602b6fc7caaf30dbc218371jacobs */
355b4669e025ff377602b6fc7caaf30dbc218371jacobs
355b4669e025ff377602b6fc7caaf30dbc218371jacobschar * /* O - Encoded string */
355b4669e025ff377602b6fc7caaf30dbc218371jacobshttpEncode64_2(char *out, /* I - String to write to */
355b4669e025ff377602b6fc7caaf30dbc218371jacobs int outlen, /* I - Size of output string */
355b4669e025ff377602b6fc7caaf30dbc218371jacobs const char *in, /* I - String to read from */
355b4669e025ff377602b6fc7caaf30dbc218371jacobs int inlen) /* I - Size of input string */
355b4669e025ff377602b6fc7caaf30dbc218371jacobs{
355b4669e025ff377602b6fc7caaf30dbc218371jacobs char *outptr, /* Output pointer */
355b4669e025ff377602b6fc7caaf30dbc218371jacobs *outend; /* End of output buffer */
355b4669e025ff377602b6fc7caaf30dbc218371jacobs static const char base64[] = /* Base64 characters... */
355b4669e025ff377602b6fc7caaf30dbc218371jacobs {
355b4669e025ff377602b6fc7caaf30dbc218371jacobs "ABCDEFGHIJKLMNOPQRSTUVWXYZ"
355b4669e025ff377602b6fc7caaf30dbc218371jacobs "abcdefghijklmnopqrstuvwxyz"
355b4669e025ff377602b6fc7caaf30dbc218371jacobs "0123456789"
355b4669e025ff377602b6fc7caaf30dbc218371jacobs "+/"
355b4669e025ff377602b6fc7caaf30dbc218371jacobs };
355b4669e025ff377602b6fc7caaf30dbc218371jacobs
355b4669e025ff377602b6fc7caaf30dbc218371jacobs
355b4669e025ff377602b6fc7caaf30dbc218371jacobs /*
355b4669e025ff377602b6fc7caaf30dbc218371jacobs * Range check input...
355b4669e025ff377602b6fc7caaf30dbc218371jacobs */
355b4669e025ff377602b6fc7caaf30dbc218371jacobs
355b4669e025ff377602b6fc7caaf30dbc218371jacobs if (!out || outlen < 1 || !in || inlen < 1)
355b4669e025ff377602b6fc7caaf30dbc218371jacobs return (NULL);
355b4669e025ff377602b6fc7caaf30dbc218371jacobs
355b4669e025ff377602b6fc7caaf30dbc218371jacobs /*
355b4669e025ff377602b6fc7caaf30dbc218371jacobs * Convert bytes to base-64...
355b4669e025ff377602b6fc7caaf30dbc218371jacobs */
355b4669e025ff377602b6fc7caaf30dbc218371jacobs
355b4669e025ff377602b6fc7caaf30dbc218371jacobs for (outptr = out, outend = out + outlen - 1; inlen > 0; in ++, inlen --)
355b4669e025ff377602b6fc7caaf30dbc218371jacobs {
355b4669e025ff377602b6fc7caaf30dbc218371jacobs /*
355b4669e025ff377602b6fc7caaf30dbc218371jacobs * Encode the up to 3 characters as 4 Base64 numbers...
355b4669e025ff377602b6fc7caaf30dbc218371jacobs */
355b4669e025ff377602b6fc7caaf30dbc218371jacobs
355b4669e025ff377602b6fc7caaf30dbc218371jacobs if (outptr < outend)
355b4669e025ff377602b6fc7caaf30dbc218371jacobs *outptr ++ = base64[(in[0] & 255) >> 2];
355b4669e025ff377602b6fc7caaf30dbc218371jacobs if (outptr < outend)
355b4669e025ff377602b6fc7caaf30dbc218371jacobs *outptr ++ = base64[(((in[0] & 255) << 4) | ((in[1] & 255) >> 4)) & 63];
355b4669e025ff377602b6fc7caaf30dbc218371jacobs
355b4669e025ff377602b6fc7caaf30dbc218371jacobs in ++;
355b4669e025ff377602b6fc7caaf30dbc218371jacobs inlen --;
355b4669e025ff377602b6fc7caaf30dbc218371jacobs if (inlen <= 0)
355b4669e025ff377602b6fc7caaf30dbc218371jacobs {
355b4669e025ff377602b6fc7caaf30dbc218371jacobs if (outptr < outend)
355b4669e025ff377602b6fc7caaf30dbc218371jacobs *outptr ++ = '=';
355b4669e025ff377602b6fc7caaf30dbc218371jacobs if (outptr < outend)
355b4669e025ff377602b6fc7caaf30dbc218371jacobs *outptr ++ = '=';
355b4669e025ff377602b6fc7caaf30dbc218371jacobs break;
355b4669e025ff377602b6fc7caaf30dbc218371jacobs }
355b4669e025ff377602b6fc7caaf30dbc218371jacobs
355b4669e025ff377602b6fc7caaf30dbc218371jacobs if (outptr < outend)
355b4669e025ff377602b6fc7caaf30dbc218371jacobs *outptr ++ = base64[(((in[0] & 255) << 2) | ((in[1] & 255) >> 6)) & 63];
355b4669e025ff377602b6fc7caaf30dbc218371jacobs
355b4669e025ff377602b6fc7caaf30dbc218371jacobs in ++;
355b4669e025ff377602b6fc7caaf30dbc218371jacobs inlen --;
355b4669e025ff377602b6fc7caaf30dbc218371jacobs if (inlen <= 0)
355b4669e025ff377602b6fc7caaf30dbc218371jacobs {
355b4669e025ff377602b6fc7caaf30dbc218371jacobs if (outptr < outend)
355b4669e025ff377602b6fc7caaf30dbc218371jacobs *outptr ++ = '=';
355b4669e025ff377602b6fc7caaf30dbc218371jacobs break;
355b4669e025ff377602b6fc7caaf30dbc218371jacobs }
355b4669e025ff377602b6fc7caaf30dbc218371jacobs
355b4669e025ff377602b6fc7caaf30dbc218371jacobs if (outptr < outend)
355b4669e025ff377602b6fc7caaf30dbc218371jacobs *outptr ++ = base64[in[0] & 63];
355b4669e025ff377602b6fc7caaf30dbc218371jacobs }
355b4669e025ff377602b6fc7caaf30dbc218371jacobs
355b4669e025ff377602b6fc7caaf30dbc218371jacobs *outptr = '\0';
355b4669e025ff377602b6fc7caaf30dbc218371jacobs
355b4669e025ff377602b6fc7caaf30dbc218371jacobs /*
355b4669e025ff377602b6fc7caaf30dbc218371jacobs * Return the encoded string...
355b4669e025ff377602b6fc7caaf30dbc218371jacobs */
355b4669e025ff377602b6fc7caaf30dbc218371jacobs
355b4669e025ff377602b6fc7caaf30dbc218371jacobs return (out);
355b4669e025ff377602b6fc7caaf30dbc218371jacobs}
355b4669e025ff377602b6fc7caaf30dbc218371jacobs
355b4669e025ff377602b6fc7caaf30dbc218371jacobs
355b4669e025ff377602b6fc7caaf30dbc218371jacobs/*
355b4669e025ff377602b6fc7caaf30dbc218371jacobs * 'httpGetLength()' - Get the amount of data remaining from the
355b4669e025ff377602b6fc7caaf30dbc218371jacobs * content-length or transfer-encoding fields.
355b4669e025ff377602b6fc7caaf30dbc218371jacobs */
355b4669e025ff377602b6fc7caaf30dbc218371jacobs
355b4669e025ff377602b6fc7caaf30dbc218371jacobsint /* O - Content length */
355b4669e025ff377602b6fc7caaf30dbc218371jacobshttpGetLength(http_t *http) /* I - HTTP data */
355b4669e025ff377602b6fc7caaf30dbc218371jacobs{
355b4669e025ff377602b6fc7caaf30dbc218371jacobs DEBUG_printf(("httpGetLength(http=%p), state=%d\n", http, http->state));
355b4669e025ff377602b6fc7caaf30dbc218371jacobs
355b4669e025ff377602b6fc7caaf30dbc218371jacobs if (strcasecmp(http->fields[HTTP_FIELD_TRANSFER_ENCODING], "chunked") == 0)
355b4669e025ff377602b6fc7caaf30dbc218371jacobs {
355b4669e025ff377602b6fc7caaf30dbc218371jacobs DEBUG_puts("httpGetLength: chunked request!");
355b4669e025ff377602b6fc7caaf30dbc218371jacobs
355b4669e025ff377602b6fc7caaf30dbc218371jacobs http->data_encoding = HTTP_ENCODE_CHUNKED;
355b4669e025ff377602b6fc7caaf30dbc218371jacobs http->data_remaining = 0;
355b4669e025ff377602b6fc7caaf30dbc218371jacobs }
355b4669e025ff377602b6fc7caaf30dbc218371jacobs else
355b4669e025ff377602b6fc7caaf30dbc218371jacobs {
355b4669e025ff377602b6fc7caaf30dbc218371jacobs http->data_encoding = HTTP_ENCODE_LENGTH;
355b4669e025ff377602b6fc7caaf30dbc218371jacobs
355b4669e025ff377602b6fc7caaf30dbc218371jacobs /*
355b4669e025ff377602b6fc7caaf30dbc218371jacobs * The following is a hack for HTTP servers that don't send a
355b4669e025ff377602b6fc7caaf30dbc218371jacobs * content-length or transfer-encoding field...
355b4669e025ff377602b6fc7caaf30dbc218371jacobs *
355b4669e025ff377602b6fc7caaf30dbc218371jacobs * If there is no content-length then the connection must close
355b4669e025ff377602b6fc7caaf30dbc218371jacobs * after the transfer is complete...
355b4669e025ff377602b6fc7caaf30dbc218371jacobs */
355b4669e025ff377602b6fc7caaf30dbc218371jacobs
355b4669e025ff377602b6fc7caaf30dbc218371jacobs if (http->fields[HTTP_FIELD_CONTENT_LENGTH][0] == '\0')
355b4669e025ff377602b6fc7caaf30dbc218371jacobs http->data_remaining = 2147483647;
355b4669e025ff377602b6fc7caaf30dbc218371jacobs else
355b4669e025ff377602b6fc7caaf30dbc218371jacobs http->data_remaining = atoi(http->fields[HTTP_FIELD_CONTENT_LENGTH]);
355b4669e025ff377602b6fc7caaf30dbc218371jacobs
355b4669e025ff377602b6fc7caaf30dbc218371jacobs DEBUG_printf(("httpGetLength: content_length=%d\n", http->data_remaining));
355b4669e025ff377602b6fc7caaf30dbc218371jacobs }
355b4669e025ff377602b6fc7caaf30dbc218371jacobs
355b4669e025ff377602b6fc7caaf30dbc218371jacobs return (http->data_remaining);
355b4669e025ff377602b6fc7caaf30dbc218371jacobs}
355b4669e025ff377602b6fc7caaf30dbc218371jacobs
355b4669e025ff377602b6fc7caaf30dbc218371jacobs
355b4669e025ff377602b6fc7caaf30dbc218371jacobs/*
355b4669e025ff377602b6fc7caaf30dbc218371jacobs * 'http_field()' - Return the field index for a field name.
355b4669e025ff377602b6fc7caaf30dbc218371jacobs */
355b4669e025ff377602b6fc7caaf30dbc218371jacobs
355b4669e025ff377602b6fc7caaf30dbc218371jacobsstatic http_field_t /* O - Field index */
355b4669e025ff377602b6fc7caaf30dbc218371jacobshttp_field(const char *name) /* I - String name */
355b4669e025ff377602b6fc7caaf30dbc218371jacobs{
355b4669e025ff377602b6fc7caaf30dbc218371jacobs int i; /* Looping var */
355b4669e025ff377602b6fc7caaf30dbc218371jacobs
355b4669e025ff377602b6fc7caaf30dbc218371jacobs
355b4669e025ff377602b6fc7caaf30dbc218371jacobs for (i = 0; i < HTTP_FIELD_MAX; i ++)
355b4669e025ff377602b6fc7caaf30dbc218371jacobs if (strcasecmp(name, http_fields[i]) == 0)
355b4669e025ff377602b6fc7caaf30dbc218371jacobs return ((http_field_t)i);
355b4669e025ff377602b6fc7caaf30dbc218371jacobs
355b4669e025ff377602b6fc7caaf30dbc218371jacobs return (HTTP_FIELD_UNKNOWN);
355b4669e025ff377602b6fc7caaf30dbc218371jacobs}
355b4669e025ff377602b6fc7caaf30dbc218371jacobs
355b4669e025ff377602b6fc7caaf30dbc218371jacobs
355b4669e025ff377602b6fc7caaf30dbc218371jacobs/*
355b4669e025ff377602b6fc7caaf30dbc218371jacobs * 'http_send()' - Send a request with all fields and the trailing blank line.
355b4669e025ff377602b6fc7caaf30dbc218371jacobs */
355b4669e025ff377602b6fc7caaf30dbc218371jacobs
355b4669e025ff377602b6fc7caaf30dbc218371jacobsstatic int /* O - 0 on success, non-zero on error */
355b4669e025ff377602b6fc7caaf30dbc218371jacobshttp_send(http_t *http, /* I - HTTP data */
355b4669e025ff377602b6fc7caaf30dbc218371jacobs http_state_t request, /* I - Request code */
355b4669e025ff377602b6fc7caaf30dbc218371jacobs const char *uri) /* I - URI */
355b4669e025ff377602b6fc7caaf30dbc218371jacobs{
355b4669e025ff377602b6fc7caaf30dbc218371jacobs int i; /* Looping var */
355b4669e025ff377602b6fc7caaf30dbc218371jacobs char *ptr, /* Pointer in buffer */
355b4669e025ff377602b6fc7caaf30dbc218371jacobs buf[1024]; /* Encoded URI buffer */
355b4669e025ff377602b6fc7caaf30dbc218371jacobs static const char * const codes[] =
355b4669e025ff377602b6fc7caaf30dbc218371jacobs { /* Request code strings */
355b4669e025ff377602b6fc7caaf30dbc218371jacobs NULL,
355b4669e025ff377602b6fc7caaf30dbc218371jacobs "OPTIONS",
355b4669e025ff377602b6fc7caaf30dbc218371jacobs "GET",
355b4669e025ff377602b6fc7caaf30dbc218371jacobs NULL,
355b4669e025ff377602b6fc7caaf30dbc218371jacobs "HEAD",
355b4669e025ff377602b6fc7caaf30dbc218371jacobs "POST",
355b4669e025ff377602b6fc7caaf30dbc218371jacobs NULL,
355b4669e025ff377602b6fc7caaf30dbc218371jacobs NULL,
355b4669e025ff377602b6fc7caaf30dbc218371jacobs "PUT",
355b4669e025ff377602b6fc7caaf30dbc218371jacobs NULL,
355b4669e025ff377602b6fc7caaf30dbc218371jacobs "DELETE",
355b4669e025ff377602b6fc7caaf30dbc218371jacobs "TRACE",
355b4669e025ff377602b6fc7caaf30dbc218371jacobs "CLOSE"
355b4669e025ff377602b6fc7caaf30dbc218371jacobs };
355b4669e025ff377602b6fc7caaf30dbc218371jacobs static const char hex[] = "0123456789ABCDEF";
355b4669e025ff377602b6fc7caaf30dbc218371jacobs /* Hex digits */
355b4669e025ff377602b6fc7caaf30dbc218371jacobs
355b4669e025ff377602b6fc7caaf30dbc218371jacobs
355b4669e025ff377602b6fc7caaf30dbc218371jacobs DEBUG_printf(("http_send(http=%p, request=HTTP_%s, uri=\"%s\")\n",
355b4669e025ff377602b6fc7caaf30dbc218371jacobs http, codes[request], uri));
355b4669e025ff377602b6fc7caaf30dbc218371jacobs
355b4669e025ff377602b6fc7caaf30dbc218371jacobs if (http == NULL || uri == NULL)
355b4669e025ff377602b6fc7caaf30dbc218371jacobs return (-1);
355b4669e025ff377602b6fc7caaf30dbc218371jacobs
355b4669e025ff377602b6fc7caaf30dbc218371jacobs /*
355b4669e025ff377602b6fc7caaf30dbc218371jacobs * Encode the URI as needed...
355b4669e025ff377602b6fc7caaf30dbc218371jacobs */
355b4669e025ff377602b6fc7caaf30dbc218371jacobs
355b4669e025ff377602b6fc7caaf30dbc218371jacobs for (ptr = buf; *uri != '\0' && ptr < (buf + sizeof(buf) - 1); uri ++)
355b4669e025ff377602b6fc7caaf30dbc218371jacobs if (*uri <= ' ' || *uri >= 127)
355b4669e025ff377602b6fc7caaf30dbc218371jacobs {
355b4669e025ff377602b6fc7caaf30dbc218371jacobs if (ptr < (buf + sizeof(buf) - 1))
355b4669e025ff377602b6fc7caaf30dbc218371jacobs *ptr ++ = '%';
355b4669e025ff377602b6fc7caaf30dbc218371jacobs if (ptr < (buf + sizeof(buf) - 1))
355b4669e025ff377602b6fc7caaf30dbc218371jacobs *ptr ++ = hex[(*uri >> 4) & 15];
355b4669e025ff377602b6fc7caaf30dbc218371jacobs if (ptr < (buf + sizeof(buf) - 1))
355b4669e025ff377602b6fc7caaf30dbc218371jacobs *ptr ++ = hex[*uri & 15];
355b4669e025ff377602b6fc7caaf30dbc218371jacobs }
355b4669e025ff377602b6fc7caaf30dbc218371jacobs else
355b4669e025ff377602b6fc7caaf30dbc218371jacobs *ptr ++ = *uri;
355b4669e025ff377602b6fc7caaf30dbc218371jacobs
355b4669e025ff377602b6fc7caaf30dbc218371jacobs *ptr = '\0';
355b4669e025ff377602b6fc7caaf30dbc218371jacobs
355b4669e025ff377602b6fc7caaf30dbc218371jacobs /*
355b4669e025ff377602b6fc7caaf30dbc218371jacobs * See if we had an error the last time around; if so, reconnect...
355b4669e025ff377602b6fc7caaf30dbc218371jacobs */
355b4669e025ff377602b6fc7caaf30dbc218371jacobs
355b4669e025ff377602b6fc7caaf30dbc218371jacobs if (http->status == HTTP_ERROR || http->status >= HTTP_BAD_REQUEST)
355b4669e025ff377602b6fc7caaf30dbc218371jacobs httpReconnect(http);
355b4669e025ff377602b6fc7caaf30dbc218371jacobs
355b4669e025ff377602b6fc7caaf30dbc218371jacobs /*
355b4669e025ff377602b6fc7caaf30dbc218371jacobs * Send the request header...
355b4669e025ff377602b6fc7caaf30dbc218371jacobs */
355b4669e025ff377602b6fc7caaf30dbc218371jacobs
355b4669e025ff377602b6fc7caaf30dbc218371jacobs http->state = request;
355b4669e025ff377602b6fc7caaf30dbc218371jacobs if (request == HTTP_POST || request == HTTP_PUT)
355b4669e025ff377602b6fc7caaf30dbc218371jacobs http->state ++;
355b4669e025ff377602b6fc7caaf30dbc218371jacobs
355b4669e025ff377602b6fc7caaf30dbc218371jacobs http->status = HTTP_CONTINUE;
355b4669e025ff377602b6fc7caaf30dbc218371jacobs
355b4669e025ff377602b6fc7caaf30dbc218371jacobs#ifdef HAVE_SSL
355b4669e025ff377602b6fc7caaf30dbc218371jacobs if (http->encryption == HTTP_ENCRYPT_REQUIRED && !http->tls)
355b4669e025ff377602b6fc7caaf30dbc218371jacobs {
355b4669e025ff377602b6fc7caaf30dbc218371jacobs httpSetField(http, HTTP_FIELD_CONNECTION, "Upgrade");
355b4669e025ff377602b6fc7caaf30dbc218371jacobs httpSetField(http, HTTP_FIELD_UPGRADE, "TLS/1.0,SSL/2.0,SSL/3.0");
355b4669e025ff377602b6fc7caaf30dbc218371jacobs }
355b4669e025ff377602b6fc7caaf30dbc218371jacobs#endif /* HAVE_SSL */
355b4669e025ff377602b6fc7caaf30dbc218371jacobs
355b4669e025ff377602b6fc7caaf30dbc218371jacobs if (httpPrintf(http, "%s %s HTTP/1.1\r\n", codes[request], buf) < 1)
355b4669e025ff377602b6fc7caaf30dbc218371jacobs {
355b4669e025ff377602b6fc7caaf30dbc218371jacobs http->status = HTTP_ERROR;
355b4669e025ff377602b6fc7caaf30dbc218371jacobs return (-1);
355b4669e025ff377602b6fc7caaf30dbc218371jacobs }
355b4669e025ff377602b6fc7caaf30dbc218371jacobs
355b4669e025ff377602b6fc7caaf30dbc218371jacobs for (i = 0; i < HTTP_FIELD_MAX; i ++)
355b4669e025ff377602b6fc7caaf30dbc218371jacobs if (http->fields[i][0] != '\0')
355b4669e025ff377602b6fc7caaf30dbc218371jacobs {
355b4669e025ff377602b6fc7caaf30dbc218371jacobs DEBUG_printf(("%s: %s\n", http_fields[i], http->fields[i]));
355b4669e025ff377602b6fc7caaf30dbc218371jacobs
355b4669e025ff377602b6fc7caaf30dbc218371jacobs if (httpPrintf(http, "%s: %s\r\n", http_fields[i], http->fields[i]) < 1)
355b4669e025ff377602b6fc7caaf30dbc218371jacobs {
355b4669e025ff377602b6fc7caaf30dbc218371jacobs http->status = HTTP_ERROR;
355b4669e025ff377602b6fc7caaf30dbc218371jacobs return (-1);
355b4669e025ff377602b6fc7caaf30dbc218371jacobs }
355b4669e025ff377602b6fc7caaf30dbc218371jacobs }
355b4669e025ff377602b6fc7caaf30dbc218371jacobs
355b4669e025ff377602b6fc7caaf30dbc218371jacobs if (httpPrintf(http, "\r\n") < 1)
355b4669e025ff377602b6fc7caaf30dbc218371jacobs {
355b4669e025ff377602b6fc7caaf30dbc218371jacobs http->status = HTTP_ERROR;
355b4669e025ff377602b6fc7caaf30dbc218371jacobs return (-1);
355b4669e025ff377602b6fc7caaf30dbc218371jacobs }
355b4669e025ff377602b6fc7caaf30dbc218371jacobs
355b4669e025ff377602b6fc7caaf30dbc218371jacobs httpClearFields(http);
355b4669e025ff377602b6fc7caaf30dbc218371jacobs
355b4669e025ff377602b6fc7caaf30dbc218371jacobs return (0);
355b4669e025ff377602b6fc7caaf30dbc218371jacobs}
355b4669e025ff377602b6fc7caaf30dbc218371jacobs
355b4669e025ff377602b6fc7caaf30dbc218371jacobs
355b4669e025ff377602b6fc7caaf30dbc218371jacobs/*
355b4669e025ff377602b6fc7caaf30dbc218371jacobs * 'http_wait()' - Wait for data available on a connection.
355b4669e025ff377602b6fc7caaf30dbc218371jacobs */
355b4669e025ff377602b6fc7caaf30dbc218371jacobs
355b4669e025ff377602b6fc7caaf30dbc218371jacobsstatic int /* O - 1 if data is available, 0 otherwise */
355b4669e025ff377602b6fc7caaf30dbc218371jacobshttp_wait(http_t *http, /* I - HTTP data */
355b4669e025ff377602b6fc7caaf30dbc218371jacobs int msec) /* I - Milliseconds to wait */
355b4669e025ff377602b6fc7caaf30dbc218371jacobs{
355b4669e025ff377602b6fc7caaf30dbc218371jacobs#ifndef WIN32
355b4669e025ff377602b6fc7caaf30dbc218371jacobs struct rlimit limit; /* Runtime limit */
355b4669e025ff377602b6fc7caaf30dbc218371jacobs#endif /* !WIN32 */
355b4669e025ff377602b6fc7caaf30dbc218371jacobs struct timeval timeout; /* Timeout */
355b4669e025ff377602b6fc7caaf30dbc218371jacobs int nfds; /* Result from select() */
355b4669e025ff377602b6fc7caaf30dbc218371jacobs int set_size; /* Size of select set */
355b4669e025ff377602b6fc7caaf30dbc218371jacobs
355b4669e025ff377602b6fc7caaf30dbc218371jacobs
355b4669e025ff377602b6fc7caaf30dbc218371jacobs DEBUG_printf(("http_wait(http=%p, msec=%d)\n", http, msec));
355b4669e025ff377602b6fc7caaf30dbc218371jacobs
355b4669e025ff377602b6fc7caaf30dbc218371jacobs /*
355b4669e025ff377602b6fc7caaf30dbc218371jacobs * Check the SSL/TLS buffers for data first...
355b4669e025ff377602b6fc7caaf30dbc218371jacobs */
355b4669e025ff377602b6fc7caaf30dbc218371jacobs
355b4669e025ff377602b6fc7caaf30dbc218371jacobs#ifdef HAVE_SSL
355b4669e025ff377602b6fc7caaf30dbc218371jacobs if (http->tls)
355b4669e025ff377602b6fc7caaf30dbc218371jacobs {
355b4669e025ff377602b6fc7caaf30dbc218371jacobs# ifdef HAVE_LIBSSL
355b4669e025ff377602b6fc7caaf30dbc218371jacobs if (SSL_pending((SSL *)(http->tls)))
355b4669e025ff377602b6fc7caaf30dbc218371jacobs return (1);
355b4669e025ff377602b6fc7caaf30dbc218371jacobs# elif defined(HAVE_GNUTLS)
355b4669e025ff377602b6fc7caaf30dbc218371jacobs if (gnutls_record_check_pending(((http_tls_t *)(http->tls))->session))
355b4669e025ff377602b6fc7caaf30dbc218371jacobs return (1);
355b4669e025ff377602b6fc7caaf30dbc218371jacobs# elif defined(HAVE_CDSASSL)
355b4669e025ff377602b6fc7caaf30dbc218371jacobs size_t bytes; /* Bytes that are available */
355b4669e025ff377602b6fc7caaf30dbc218371jacobs
355b4669e025ff377602b6fc7caaf30dbc218371jacobs if (!SSLGetBufferedReadSize((SSLContextRef)http->tls, &bytes) && bytes > 0)
355b4669e025ff377602b6fc7caaf30dbc218371jacobs return;
355b4669e025ff377602b6fc7caaf30dbc218371jacobs# endif /* HAVE_LIBSSL */
355b4669e025ff377602b6fc7caaf30dbc218371jacobs }
355b4669e025ff377602b6fc7caaf30dbc218371jacobs#endif /* HAVE_SSL */
355b4669e025ff377602b6fc7caaf30dbc218371jacobs
355b4669e025ff377602b6fc7caaf30dbc218371jacobs /*
355b4669e025ff377602b6fc7caaf30dbc218371jacobs * Then try doing a select() to poll the socket...
355b4669e025ff377602b6fc7caaf30dbc218371jacobs */
355b4669e025ff377602b6fc7caaf30dbc218371jacobs
355b4669e025ff377602b6fc7caaf30dbc218371jacobs if (!http->input_set)
355b4669e025ff377602b6fc7caaf30dbc218371jacobs {
355b4669e025ff377602b6fc7caaf30dbc218371jacobs#ifdef WIN32
355b4669e025ff377602b6fc7caaf30dbc218371jacobs /*
355b4669e025ff377602b6fc7caaf30dbc218371jacobs * Windows has a fixed-size select() structure, different (surprise,
355b4669e025ff377602b6fc7caaf30dbc218371jacobs * surprise!) from all UNIX implementations. Just allocate this
355b4669e025ff377602b6fc7caaf30dbc218371jacobs * fixed structure...
355b4669e025ff377602b6fc7caaf30dbc218371jacobs */
355b4669e025ff377602b6fc7caaf30dbc218371jacobs
355b4669e025ff377602b6fc7caaf30dbc218371jacobs http->input_set = calloc(1, sizeof(fd_set));
355b4669e025ff377602b6fc7caaf30dbc218371jacobs#else
355b4669e025ff377602b6fc7caaf30dbc218371jacobs /*
355b4669e025ff377602b6fc7caaf30dbc218371jacobs * Allocate the select() input set based upon the max number of file
355b4669e025ff377602b6fc7caaf30dbc218371jacobs * descriptors available for this process...
355b4669e025ff377602b6fc7caaf30dbc218371jacobs */
355b4669e025ff377602b6fc7caaf30dbc218371jacobs
355b4669e025ff377602b6fc7caaf30dbc218371jacobs getrlimit(RLIMIT_NOFILE, &limit);
355b4669e025ff377602b6fc7caaf30dbc218371jacobs
355b4669e025ff377602b6fc7caaf30dbc218371jacobs set_size = (limit.rlim_cur + 31) / 8 + 4;
355b4669e025ff377602b6fc7caaf30dbc218371jacobs if (set_size < sizeof(fd_set))
355b4669e025ff377602b6fc7caaf30dbc218371jacobs set_size = sizeof(fd_set);
355b4669e025ff377602b6fc7caaf30dbc218371jacobs
355b4669e025ff377602b6fc7caaf30dbc218371jacobs http->input_set = calloc(1, set_size);
355b4669e025ff377602b6fc7caaf30dbc218371jacobs#endif /* WIN32 */
355b4669e025ff377602b6fc7caaf30dbc218371jacobs
355b4669e025ff377602b6fc7caaf30dbc218371jacobs if (!http->input_set)
355b4669e025ff377602b6fc7caaf30dbc218371jacobs return (0);
355b4669e025ff377602b6fc7caaf30dbc218371jacobs }
355b4669e025ff377602b6fc7caaf30dbc218371jacobs
355b4669e025ff377602b6fc7caaf30dbc218371jacobs do
355b4669e025ff377602b6fc7caaf30dbc218371jacobs {
355b4669e025ff377602b6fc7caaf30dbc218371jacobs FD_SET(http->fd, http->input_set);
355b4669e025ff377602b6fc7caaf30dbc218371jacobs
355b4669e025ff377602b6fc7caaf30dbc218371jacobs if (msec >= 0)
355b4669e025ff377602b6fc7caaf30dbc218371jacobs {
355b4669e025ff377602b6fc7caaf30dbc218371jacobs timeout.tv_sec = msec / 1000;
355b4669e025ff377602b6fc7caaf30dbc218371jacobs timeout.tv_usec = (msec % 1000) * 1000;
355b4669e025ff377602b6fc7caaf30dbc218371jacobs
355b4669e025ff377602b6fc7caaf30dbc218371jacobs nfds = select(http->fd + 1, http->input_set, NULL, NULL, &timeout);
355b4669e025ff377602b6fc7caaf30dbc218371jacobs }
355b4669e025ff377602b6fc7caaf30dbc218371jacobs else
355b4669e025ff377602b6fc7caaf30dbc218371jacobs nfds = select(http->fd + 1, http->input_set, NULL, NULL, NULL);
355b4669e025ff377602b6fc7caaf30dbc218371jacobs }
355b4669e025ff377602b6fc7caaf30dbc218371jacobs#ifdef WIN32
355b4669e025ff377602b6fc7caaf30dbc218371jacobs while (nfds < 0 && WSAGetLastError() == WSAEINTR);
355b4669e025ff377602b6fc7caaf30dbc218371jacobs#else
355b4669e025ff377602b6fc7caaf30dbc218371jacobs while (nfds < 0 && errno == EINTR);
355b4669e025ff377602b6fc7caaf30dbc218371jacobs#endif /* WIN32 */
355b4669e025ff377602b6fc7caaf30dbc218371jacobs
355b4669e025ff377602b6fc7caaf30dbc218371jacobs FD_CLR(http->fd, http->input_set);
355b4669e025ff377602b6fc7caaf30dbc218371jacobs
355b4669e025ff377602b6fc7caaf30dbc218371jacobs return (nfds > 0);
355b4669e025ff377602b6fc7caaf30dbc218371jacobs}
355b4669e025ff377602b6fc7caaf30dbc218371jacobs
355b4669e025ff377602b6fc7caaf30dbc218371jacobs
355b4669e025ff377602b6fc7caaf30dbc218371jacobs#ifdef HAVE_SSL
355b4669e025ff377602b6fc7caaf30dbc218371jacobs/*
355b4669e025ff377602b6fc7caaf30dbc218371jacobs * 'http_upgrade()' - Force upgrade to TLS encryption.
355b4669e025ff377602b6fc7caaf30dbc218371jacobs */
355b4669e025ff377602b6fc7caaf30dbc218371jacobs
355b4669e025ff377602b6fc7caaf30dbc218371jacobsstatic int /* O - Status of connection */
355b4669e025ff377602b6fc7caaf30dbc218371jacobshttp_upgrade(http_t *http) /* I - HTTP data */
355b4669e025ff377602b6fc7caaf30dbc218371jacobs{
355b4669e025ff377602b6fc7caaf30dbc218371jacobs int ret; /* Return value */
355b4669e025ff377602b6fc7caaf30dbc218371jacobs http_t myhttp; /* Local copy of HTTP data */
355b4669e025ff377602b6fc7caaf30dbc218371jacobs
355b4669e025ff377602b6fc7caaf30dbc218371jacobs
355b4669e025ff377602b6fc7caaf30dbc218371jacobs DEBUG_printf(("http_upgrade(%p)\n", http));
355b4669e025ff377602b6fc7caaf30dbc218371jacobs
355b4669e025ff377602b6fc7caaf30dbc218371jacobs /*
355b4669e025ff377602b6fc7caaf30dbc218371jacobs * Copy the HTTP data to a local variable so we can do the OPTIONS
355b4669e025ff377602b6fc7caaf30dbc218371jacobs * request without interfering with the existing request data...
355b4669e025ff377602b6fc7caaf30dbc218371jacobs */
355b4669e025ff377602b6fc7caaf30dbc218371jacobs
355b4669e025ff377602b6fc7caaf30dbc218371jacobs memcpy(&myhttp, http, sizeof(myhttp));
355b4669e025ff377602b6fc7caaf30dbc218371jacobs
355b4669e025ff377602b6fc7caaf30dbc218371jacobs /*
355b4669e025ff377602b6fc7caaf30dbc218371jacobs * Send an OPTIONS request to the server, requiring SSL or TLS
355b4669e025ff377602b6fc7caaf30dbc218371jacobs * encryption on the link...
355b4669e025ff377602b6fc7caaf30dbc218371jacobs */
355b4669e025ff377602b6fc7caaf30dbc218371jacobs
355b4669e025ff377602b6fc7caaf30dbc218371jacobs httpClearFields(&myhttp);
355b4669e025ff377602b6fc7caaf30dbc218371jacobs httpSetField(&myhttp, HTTP_FIELD_CONNECTION, "upgrade");
355b4669e025ff377602b6fc7caaf30dbc218371jacobs httpSetField(&myhttp, HTTP_FIELD_UPGRADE, "TLS/1.0, SSL/2.0, SSL/3.0");
355b4669e025ff377602b6fc7caaf30dbc218371jacobs
355b4669e025ff377602b6fc7caaf30dbc218371jacobs if ((ret = httpOptions(&myhttp, "*")) == 0)
355b4669e025ff377602b6fc7caaf30dbc218371jacobs {
355b4669e025ff377602b6fc7caaf30dbc218371jacobs /*
355b4669e025ff377602b6fc7caaf30dbc218371jacobs * Wait for the secure connection...
355b4669e025ff377602b6fc7caaf30dbc218371jacobs */
355b4669e025ff377602b6fc7caaf30dbc218371jacobs
355b4669e025ff377602b6fc7caaf30dbc218371jacobs while (httpUpdate(&myhttp) == HTTP_CONTINUE);
355b4669e025ff377602b6fc7caaf30dbc218371jacobs }
355b4669e025ff377602b6fc7caaf30dbc218371jacobs
355b4669e025ff377602b6fc7caaf30dbc218371jacobs httpFlush(&myhttp);
355b4669e025ff377602b6fc7caaf30dbc218371jacobs
355b4669e025ff377602b6fc7caaf30dbc218371jacobs /*
355b4669e025ff377602b6fc7caaf30dbc218371jacobs * Copy the HTTP data back over, if any...
355b4669e025ff377602b6fc7caaf30dbc218371jacobs */
355b4669e025ff377602b6fc7caaf30dbc218371jacobs
355b4669e025ff377602b6fc7caaf30dbc218371jacobs http->fd = myhttp.fd;
355b4669e025ff377602b6fc7caaf30dbc218371jacobs http->error = myhttp.error;
355b4669e025ff377602b6fc7caaf30dbc218371jacobs http->activity = myhttp.activity;
355b4669e025ff377602b6fc7caaf30dbc218371jacobs http->status = myhttp.status;
355b4669e025ff377602b6fc7caaf30dbc218371jacobs http->version = myhttp.version;
355b4669e025ff377602b6fc7caaf30dbc218371jacobs http->keep_alive = myhttp.keep_alive;
355b4669e025ff377602b6fc7caaf30dbc218371jacobs http->used = myhttp.used;
355b4669e025ff377602b6fc7caaf30dbc218371jacobs
355b4669e025ff377602b6fc7caaf30dbc218371jacobs if (http->used)
355b4669e025ff377602b6fc7caaf30dbc218371jacobs memcpy(http->buffer, myhttp.buffer, http->used);
355b4669e025ff377602b6fc7caaf30dbc218371jacobs
355b4669e025ff377602b6fc7caaf30dbc218371jacobs http->auth_type = myhttp.auth_type;
355b4669e025ff377602b6fc7caaf30dbc218371jacobs http->nonce_count = myhttp.nonce_count;
355b4669e025ff377602b6fc7caaf30dbc218371jacobs
355b4669e025ff377602b6fc7caaf30dbc218371jacobs memcpy(http->nonce, myhttp.nonce, sizeof(http->nonce));
355b4669e025ff377602b6fc7caaf30dbc218371jacobs
355b4669e025ff377602b6fc7caaf30dbc218371jacobs http->tls = myhttp.tls;
355b4669e025ff377602b6fc7caaf30dbc218371jacobs http->encryption = myhttp.encryption;
355b4669e025ff377602b6fc7caaf30dbc218371jacobs
355b4669e025ff377602b6fc7caaf30dbc218371jacobs /*
355b4669e025ff377602b6fc7caaf30dbc218371jacobs * See if we actually went secure...
355b4669e025ff377602b6fc7caaf30dbc218371jacobs */
355b4669e025ff377602b6fc7caaf30dbc218371jacobs
355b4669e025ff377602b6fc7caaf30dbc218371jacobs if (!http->tls)
355b4669e025ff377602b6fc7caaf30dbc218371jacobs {
355b4669e025ff377602b6fc7caaf30dbc218371jacobs /*
355b4669e025ff377602b6fc7caaf30dbc218371jacobs * Server does not support HTTP upgrade...
355b4669e025ff377602b6fc7caaf30dbc218371jacobs */
355b4669e025ff377602b6fc7caaf30dbc218371jacobs
355b4669e025ff377602b6fc7caaf30dbc218371jacobs DEBUG_puts("Server does not support HTTP upgrade!");
355b4669e025ff377602b6fc7caaf30dbc218371jacobs
355b4669e025ff377602b6fc7caaf30dbc218371jacobs# ifdef WIN32
355b4669e025ff377602b6fc7caaf30dbc218371jacobs closesocket(http->fd);
355b4669e025ff377602b6fc7caaf30dbc218371jacobs# else
355b4669e025ff377602b6fc7caaf30dbc218371jacobs close(http->fd);
355b4669e025ff377602b6fc7caaf30dbc218371jacobs# endif
355b4669e025ff377602b6fc7caaf30dbc218371jacobs
355b4669e025ff377602b6fc7caaf30dbc218371jacobs http->fd = -1;
355b4669e025ff377602b6fc7caaf30dbc218371jacobs
355b4669e025ff377602b6fc7caaf30dbc218371jacobs return (-1);
355b4669e025ff377602b6fc7caaf30dbc218371jacobs }
355b4669e025ff377602b6fc7caaf30dbc218371jacobs else
355b4669e025ff377602b6fc7caaf30dbc218371jacobs return (ret);
355b4669e025ff377602b6fc7caaf30dbc218371jacobs}
355b4669e025ff377602b6fc7caaf30dbc218371jacobs
355b4669e025ff377602b6fc7caaf30dbc218371jacobs
355b4669e025ff377602b6fc7caaf30dbc218371jacobs/*
355b4669e025ff377602b6fc7caaf30dbc218371jacobs * 'http_setup_ssl()' - Set up SSL/TLS support on a connection.
355b4669e025ff377602b6fc7caaf30dbc218371jacobs */
355b4669e025ff377602b6fc7caaf30dbc218371jacobs
355b4669e025ff377602b6fc7caaf30dbc218371jacobsstatic int /* O - Status of connection */
355b4669e025ff377602b6fc7caaf30dbc218371jacobshttp_setup_ssl(http_t *http) /* I - HTTP data */
355b4669e025ff377602b6fc7caaf30dbc218371jacobs{
355b4669e025ff377602b6fc7caaf30dbc218371jacobs# ifdef HAVE_LIBSSL
355b4669e025ff377602b6fc7caaf30dbc218371jacobs SSL_CTX *context; /* Context for encryption */
355b4669e025ff377602b6fc7caaf30dbc218371jacobs SSL *conn; /* Connection for encryption */
355b4669e025ff377602b6fc7caaf30dbc218371jacobs# elif defined(HAVE_GNUTLS)
355b4669e025ff377602b6fc7caaf30dbc218371jacobs http_tls_t *conn; /* TLS session object */
355b4669e025ff377602b6fc7caaf30dbc218371jacobs gnutls_certificate_client_credentials *credentials;
355b4669e025ff377602b6fc7caaf30dbc218371jacobs /* TLS credentials */
355b4669e025ff377602b6fc7caaf30dbc218371jacobs# elif defined(HAVE_CDSASSL)
355b4669e025ff377602b6fc7caaf30dbc218371jacobs SSLContextRef conn; /* Context for encryption */
355b4669e025ff377602b6fc7caaf30dbc218371jacobs OSStatus error; /* Error info */
355b4669e025ff377602b6fc7caaf30dbc218371jacobs# endif /* HAVE_LIBSSL */
355b4669e025ff377602b6fc7caaf30dbc218371jacobs
355b4669e025ff377602b6fc7caaf30dbc218371jacobs
355b4669e025ff377602b6fc7caaf30dbc218371jacobs DEBUG_printf(("http_setup_ssl(http=%p)\n", http));
355b4669e025ff377602b6fc7caaf30dbc218371jacobs
355b4669e025ff377602b6fc7caaf30dbc218371jacobs# ifdef HAVE_LIBSSL
355b4669e025ff377602b6fc7caaf30dbc218371jacobs context = SSL_CTX_new(SSLv23_client_method());
355b4669e025ff377602b6fc7caaf30dbc218371jacobs
355b4669e025ff377602b6fc7caaf30dbc218371jacobs SSL_CTX_set_options(context, SSL_OP_NO_SSLv2); /* Only use SSLv3 or TLS */
355b4669e025ff377602b6fc7caaf30dbc218371jacobs
355b4669e025ff377602b6fc7caaf30dbc218371jacobs conn = SSL_new(context);
355b4669e025ff377602b6fc7caaf30dbc218371jacobs
355b4669e025ff377602b6fc7caaf30dbc218371jacobs SSL_set_fd(conn, http->fd);
355b4669e025ff377602b6fc7caaf30dbc218371jacobs if (SSL_connect(conn) != 1)
355b4669e025ff377602b6fc7caaf30dbc218371jacobs {
355b4669e025ff377602b6fc7caaf30dbc218371jacobs# ifdef DEBUG
355b4669e025ff377602b6fc7caaf30dbc218371jacobs unsigned long error; /* Error code */
355b4669e025ff377602b6fc7caaf30dbc218371jacobs
355b4669e025ff377602b6fc7caaf30dbc218371jacobs while ((error = ERR_get_error()) != 0)
355b4669e025ff377602b6fc7caaf30dbc218371jacobs printf("http_setup_ssl: %s\n", ERR_error_string(error, NULL));
355b4669e025ff377602b6fc7caaf30dbc218371jacobs# endif /* DEBUG */
355b4669e025ff377602b6fc7caaf30dbc218371jacobs
355b4669e025ff377602b6fc7caaf30dbc218371jacobs SSL_CTX_free(context);
355b4669e025ff377602b6fc7caaf30dbc218371jacobs SSL_free(conn);
355b4669e025ff377602b6fc7caaf30dbc218371jacobs
355b4669e025ff377602b6fc7caaf30dbc218371jacobs# ifdef WIN32
355b4669e025ff377602b6fc7caaf30dbc218371jacobs http->error = WSAGetLastError();
355b4669e025ff377602b6fc7caaf30dbc218371jacobs# else
355b4669e025ff377602b6fc7caaf30dbc218371jacobs http->error = errno;
355b4669e025ff377602b6fc7caaf30dbc218371jacobs# endif /* WIN32 */
355b4669e025ff377602b6fc7caaf30dbc218371jacobs http->status = HTTP_ERROR;
355b4669e025ff377602b6fc7caaf30dbc218371jacobs
355b4669e025ff377602b6fc7caaf30dbc218371jacobs return (HTTP_ERROR);
355b4669e025ff377602b6fc7caaf30dbc218371jacobs }
355b4669e025ff377602b6fc7caaf30dbc218371jacobs
355b4669e025ff377602b6fc7caaf30dbc218371jacobs# elif defined(HAVE_GNUTLS)
355b4669e025ff377602b6fc7caaf30dbc218371jacobs conn = (http_tls_t *)malloc(sizeof(http_tls_t));
355b4669e025ff377602b6fc7caaf30dbc218371jacobs
355b4669e025ff377602b6fc7caaf30dbc218371jacobs if (conn == NULL)
355b4669e025ff377602b6fc7caaf30dbc218371jacobs {
355b4669e025ff377602b6fc7caaf30dbc218371jacobs http->error = errno;
355b4669e025ff377602b6fc7caaf30dbc218371jacobs http->status = HTTP_ERROR;
355b4669e025ff377602b6fc7caaf30dbc218371jacobs
355b4669e025ff377602b6fc7caaf30dbc218371jacobs return (-1);
355b4669e025ff377602b6fc7caaf30dbc218371jacobs }
355b4669e025ff377602b6fc7caaf30dbc218371jacobs
355b4669e025ff377602b6fc7caaf30dbc218371jacobs credentials = (gnutls_certificate_client_credentials *)
355b4669e025ff377602b6fc7caaf30dbc218371jacobs malloc(sizeof(gnutls_certificate_client_credentials));
355b4669e025ff377602b6fc7caaf30dbc218371jacobs if (credentials == NULL)
355b4669e025ff377602b6fc7caaf30dbc218371jacobs {
355b4669e025ff377602b6fc7caaf30dbc218371jacobs free(conn);
355b4669e025ff377602b6fc7caaf30dbc218371jacobs
355b4669e025ff377602b6fc7caaf30dbc218371jacobs http->error = errno;
355b4669e025ff377602b6fc7caaf30dbc218371jacobs http->status = HTTP_ERROR;
355b4669e025ff377602b6fc7caaf30dbc218371jacobs
355b4669e025ff377602b6fc7caaf30dbc218371jacobs return (-1);
355b4669e025ff377602b6fc7caaf30dbc218371jacobs }
355b4669e025ff377602b6fc7caaf30dbc218371jacobs
355b4669e025ff377602b6fc7caaf30dbc218371jacobs gnutls_certificate_allocate_credentials(credentials);
355b4669e025ff377602b6fc7caaf30dbc218371jacobs
355b4669e025ff377602b6fc7caaf30dbc218371jacobs gnutls_init(&(conn->session), GNUTLS_CLIENT);
355b4669e025ff377602b6fc7caaf30dbc218371jacobs gnutls_set_default_priority(conn->session);
355b4669e025ff377602b6fc7caaf30dbc218371jacobs gnutls_credentials_set(conn->session, GNUTLS_CRD_CERTIFICATE, *credentials);
355b4669e025ff377602b6fc7caaf30dbc218371jacobs gnutls_transport_set_ptr(conn->session, http->fd);
355b4669e025ff377602b6fc7caaf30dbc218371jacobs
355b4669e025ff377602b6fc7caaf30dbc218371jacobs if ((gnutls_handshake(conn->session)) != GNUTLS_E_SUCCESS)
355b4669e025ff377602b6fc7caaf30dbc218371jacobs {
355b4669e025ff377602b6fc7caaf30dbc218371jacobs http->error = errno;
355b4669e025ff377602b6fc7caaf30dbc218371jacobs http->status = HTTP_ERROR;
355b4669e025ff377602b6fc7caaf30dbc218371jacobs
355b4669e025ff377602b6fc7caaf30dbc218371jacobs return (-1);
355b4669e025ff377602b6fc7caaf30dbc218371jacobs }
355b4669e025ff377602b6fc7caaf30dbc218371jacobs
355b4669e025ff377602b6fc7caaf30dbc218371jacobs conn->credentials = credentials;
355b4669e025ff377602b6fc7caaf30dbc218371jacobs
355b4669e025ff377602b6fc7caaf30dbc218371jacobs# elif defined(HAVE_CDSASSL)
355b4669e025ff377602b6fc7caaf30dbc218371jacobs error = SSLNewContext(false, &conn);
355b4669e025ff377602b6fc7caaf30dbc218371jacobs
355b4669e025ff377602b6fc7caaf30dbc218371jacobs if (!error)
355b4669e025ff377602b6fc7caaf30dbc218371jacobs error = SSLSetIOFuncs(conn, CDSAReadFunc, CDSAWriteFunc);
355b4669e025ff377602b6fc7caaf30dbc218371jacobs
355b4669e025ff377602b6fc7caaf30dbc218371jacobs if (!error)
355b4669e025ff377602b6fc7caaf30dbc218371jacobs error = SSLSetConnection(conn, (SSLConnectionRef)http->fd);
355b4669e025ff377602b6fc7caaf30dbc218371jacobs
355b4669e025ff377602b6fc7caaf30dbc218371jacobs if (!error)
355b4669e025ff377602b6fc7caaf30dbc218371jacobs error = SSLSetAllowsExpiredCerts(conn, true);
355b4669e025ff377602b6fc7caaf30dbc218371jacobs
355b4669e025ff377602b6fc7caaf30dbc218371jacobs if (!error)
355b4669e025ff377602b6fc7caaf30dbc218371jacobs error = SSLSetAllowsAnyRoot(conn, true);
355b4669e025ff377602b6fc7caaf30dbc218371jacobs
355b4669e025ff377602b6fc7caaf30dbc218371jacobs if (!error)
355b4669e025ff377602b6fc7caaf30dbc218371jacobs error = SSLHandshake(conn);
355b4669e025ff377602b6fc7caaf30dbc218371jacobs
355b4669e025ff377602b6fc7caaf30dbc218371jacobs if (error != 0)
355b4669e025ff377602b6fc7caaf30dbc218371jacobs {
355b4669e025ff377602b6fc7caaf30dbc218371jacobs http->error = error;
355b4669e025ff377602b6fc7caaf30dbc218371jacobs http->status = HTTP_ERROR;
355b4669e025ff377602b6fc7caaf30dbc218371jacobs
355b4669e025ff377602b6fc7caaf30dbc218371jacobs SSLDisposeContext(conn);
355b4669e025ff377602b6fc7caaf30dbc218371jacobs
355b4669e025ff377602b6fc7caaf30dbc218371jacobs close(http->fd);
355b4669e025ff377602b6fc7caaf30dbc218371jacobs
355b4669e025ff377602b6fc7caaf30dbc218371jacobs return (-1);
355b4669e025ff377602b6fc7caaf30dbc218371jacobs }
355b4669e025ff377602b6fc7caaf30dbc218371jacobs# endif /* HAVE_CDSASSL */
355b4669e025ff377602b6fc7caaf30dbc218371jacobs
355b4669e025ff377602b6fc7caaf30dbc218371jacobs http->tls = conn;
355b4669e025ff377602b6fc7caaf30dbc218371jacobs return (0);
355b4669e025ff377602b6fc7caaf30dbc218371jacobs}
355b4669e025ff377602b6fc7caaf30dbc218371jacobs
355b4669e025ff377602b6fc7caaf30dbc218371jacobs
355b4669e025ff377602b6fc7caaf30dbc218371jacobs/*
355b4669e025ff377602b6fc7caaf30dbc218371jacobs * 'http_shutdown_ssl()' - Shut down SSL/TLS on a connection.
355b4669e025ff377602b6fc7caaf30dbc218371jacobs */
355b4669e025ff377602b6fc7caaf30dbc218371jacobs
355b4669e025ff377602b6fc7caaf30dbc218371jacobsstatic void
355b4669e025ff377602b6fc7caaf30dbc218371jacobshttp_shutdown_ssl(http_t *http) /* I - HTTP data */
355b4669e025ff377602b6fc7caaf30dbc218371jacobs{
355b4669e025ff377602b6fc7caaf30dbc218371jacobs# ifdef HAVE_LIBSSL
355b4669e025ff377602b6fc7caaf30dbc218371jacobs SSL_CTX *context; /* Context for encryption */
355b4669e025ff377602b6fc7caaf30dbc218371jacobs SSL *conn; /* Connection for encryption */
355b4669e025ff377602b6fc7caaf30dbc218371jacobs
355b4669e025ff377602b6fc7caaf30dbc218371jacobs
355b4669e025ff377602b6fc7caaf30dbc218371jacobs conn = (SSL *)(http->tls);
355b4669e025ff377602b6fc7caaf30dbc218371jacobs context = SSL_get_SSL_CTX(conn);
355b4669e025ff377602b6fc7caaf30dbc218371jacobs
355b4669e025ff377602b6fc7caaf30dbc218371jacobs SSL_shutdown(conn);
355b4669e025ff377602b6fc7caaf30dbc218371jacobs SSL_CTX_free(context);
355b4669e025ff377602b6fc7caaf30dbc218371jacobs SSL_free(conn);
355b4669e025ff377602b6fc7caaf30dbc218371jacobs
355b4669e025ff377602b6fc7caaf30dbc218371jacobs# elif defined(HAVE_GNUTLS)
355b4669e025ff377602b6fc7caaf30dbc218371jacobs http_tls_t *conn; /* Encryption session */
355b4669e025ff377602b6fc7caaf30dbc218371jacobs gnutls_certificate_client_credentials *credentials;
355b4669e025ff377602b6fc7caaf30dbc218371jacobs /* TLS credentials */
355b4669e025ff377602b6fc7caaf30dbc218371jacobs
355b4669e025ff377602b6fc7caaf30dbc218371jacobs
355b4669e025ff377602b6fc7caaf30dbc218371jacobs conn = (http_tls_t *)(http->tls);
355b4669e025ff377602b6fc7caaf30dbc218371jacobs credentials = (gnutls_certificate_client_credentials *)(conn->credentials);
355b4669e025ff377602b6fc7caaf30dbc218371jacobs
355b4669e025ff377602b6fc7caaf30dbc218371jacobs gnutls_bye(conn->session, GNUTLS_SHUT_RDWR);
355b4669e025ff377602b6fc7caaf30dbc218371jacobs gnutls_deinit(conn->session);
355b4669e025ff377602b6fc7caaf30dbc218371jacobs gnutls_certificate_free_credentials(*credentials);
355b4669e025ff377602b6fc7caaf30dbc218371jacobs free(credentials);
355b4669e025ff377602b6fc7caaf30dbc218371jacobs free(conn);
355b4669e025ff377602b6fc7caaf30dbc218371jacobs
355b4669e025ff377602b6fc7caaf30dbc218371jacobs# elif defined(HAVE_CDSASSL)
355b4669e025ff377602b6fc7caaf30dbc218371jacobs SSLClose((SSLContextRef)http->tls);
355b4669e025ff377602b6fc7caaf30dbc218371jacobs SSLDisposeContext((SSLContextRef)http->tls);
355b4669e025ff377602b6fc7caaf30dbc218371jacobs# endif /* HAVE_LIBSSL */
355b4669e025ff377602b6fc7caaf30dbc218371jacobs
355b4669e025ff377602b6fc7caaf30dbc218371jacobs http->tls = NULL;
355b4669e025ff377602b6fc7caaf30dbc218371jacobs}
355b4669e025ff377602b6fc7caaf30dbc218371jacobs
355b4669e025ff377602b6fc7caaf30dbc218371jacobs
355b4669e025ff377602b6fc7caaf30dbc218371jacobs/*
355b4669e025ff377602b6fc7caaf30dbc218371jacobs * 'http_read_ssl()' - Read from a SSL/TLS connection.
355b4669e025ff377602b6fc7caaf30dbc218371jacobs */
355b4669e025ff377602b6fc7caaf30dbc218371jacobs
355b4669e025ff377602b6fc7caaf30dbc218371jacobsstatic int /* O - Bytes read */
355b4669e025ff377602b6fc7caaf30dbc218371jacobshttp_read_ssl(http_t *http, /* I - HTTP data */
355b4669e025ff377602b6fc7caaf30dbc218371jacobs char *buf, /* I - Buffer to store data */
355b4669e025ff377602b6fc7caaf30dbc218371jacobs int len) /* I - Length of buffer */
355b4669e025ff377602b6fc7caaf30dbc218371jacobs{
355b4669e025ff377602b6fc7caaf30dbc218371jacobs# if defined(HAVE_LIBSSL)
355b4669e025ff377602b6fc7caaf30dbc218371jacobs return (SSL_read((SSL *)(http->tls), buf, len));
355b4669e025ff377602b6fc7caaf30dbc218371jacobs
355b4669e025ff377602b6fc7caaf30dbc218371jacobs# elif defined(HAVE_GNUTLS)
355b4669e025ff377602b6fc7caaf30dbc218371jacobs return (gnutls_record_recv(((http_tls_t *)(http->tls))->session, buf, len));
355b4669e025ff377602b6fc7caaf30dbc218371jacobs
355b4669e025ff377602b6fc7caaf30dbc218371jacobs# elif defined(HAVE_CDSASSL)
355b4669e025ff377602b6fc7caaf30dbc218371jacobs OSStatus error; /* Error info */
355b4669e025ff377602b6fc7caaf30dbc218371jacobs size_t processed; /* Number of bytes processed */
355b4669e025ff377602b6fc7caaf30dbc218371jacobs
355b4669e025ff377602b6fc7caaf30dbc218371jacobs
355b4669e025ff377602b6fc7caaf30dbc218371jacobs error = SSLRead((SSLContextRef)http->tls, buf, len, &processed);
355b4669e025ff377602b6fc7caaf30dbc218371jacobs
355b4669e025ff377602b6fc7caaf30dbc218371jacobs if (error == 0)
355b4669e025ff377602b6fc7caaf30dbc218371jacobs return (processed);
355b4669e025ff377602b6fc7caaf30dbc218371jacobs else
355b4669e025ff377602b6fc7caaf30dbc218371jacobs {
355b4669e025ff377602b6fc7caaf30dbc218371jacobs http->error = error;
355b4669e025ff377602b6fc7caaf30dbc218371jacobs
355b4669e025ff377602b6fc7caaf30dbc218371jacobs return (-1);
355b4669e025ff377602b6fc7caaf30dbc218371jacobs }
355b4669e025ff377602b6fc7caaf30dbc218371jacobs# endif /* HAVE_LIBSSL */
355b4669e025ff377602b6fc7caaf30dbc218371jacobs}
355b4669e025ff377602b6fc7caaf30dbc218371jacobs
355b4669e025ff377602b6fc7caaf30dbc218371jacobs
355b4669e025ff377602b6fc7caaf30dbc218371jacobs/*
355b4669e025ff377602b6fc7caaf30dbc218371jacobs * 'http_write_ssl()' - Write to a SSL/TLS connection.
355b4669e025ff377602b6fc7caaf30dbc218371jacobs */
355b4669e025ff377602b6fc7caaf30dbc218371jacobs
355b4669e025ff377602b6fc7caaf30dbc218371jacobsstatic int /* O - Bytes written */
355b4669e025ff377602b6fc7caaf30dbc218371jacobshttp_write_ssl(http_t *http, /* I - HTTP data */
355b4669e025ff377602b6fc7caaf30dbc218371jacobs const char *buf, /* I - Buffer holding data */
355b4669e025ff377602b6fc7caaf30dbc218371jacobs int len) /* I - Length of buffer */
355b4669e025ff377602b6fc7caaf30dbc218371jacobs{
355b4669e025ff377602b6fc7caaf30dbc218371jacobs# if defined(HAVE_LIBSSL)
355b4669e025ff377602b6fc7caaf30dbc218371jacobs return (SSL_write((SSL *)(http->tls), buf, len));
355b4669e025ff377602b6fc7caaf30dbc218371jacobs
355b4669e025ff377602b6fc7caaf30dbc218371jacobs# elif defined(HAVE_GNUTLS)
355b4669e025ff377602b6fc7caaf30dbc218371jacobs return (gnutls_record_send(((http_tls_t *)(http->tls))->session, buf, len));
355b4669e025ff377602b6fc7caaf30dbc218371jacobs# elif defined(HAVE_CDSASSL)
355b4669e025ff377602b6fc7caaf30dbc218371jacobs OSStatus error; /* Error info */
355b4669e025ff377602b6fc7caaf30dbc218371jacobs size_t processed; /* Number of bytes processed */
355b4669e025ff377602b6fc7caaf30dbc218371jacobs
355b4669e025ff377602b6fc7caaf30dbc218371jacobs
355b4669e025ff377602b6fc7caaf30dbc218371jacobs error = SSLWrite((SSLContextRef)http->tls, buf, len, &processed);
355b4669e025ff377602b6fc7caaf30dbc218371jacobs
355b4669e025ff377602b6fc7caaf30dbc218371jacobs if (error == 0)
355b4669e025ff377602b6fc7caaf30dbc218371jacobs return (processed);
355b4669e025ff377602b6fc7caaf30dbc218371jacobs else
355b4669e025ff377602b6fc7caaf30dbc218371jacobs {
355b4669e025ff377602b6fc7caaf30dbc218371jacobs http->error = error;
355b4669e025ff377602b6fc7caaf30dbc218371jacobs return (-1);
355b4669e025ff377602b6fc7caaf30dbc218371jacobs }
355b4669e025ff377602b6fc7caaf30dbc218371jacobs# endif /* HAVE_LIBSSL */
355b4669e025ff377602b6fc7caaf30dbc218371jacobs}
355b4669e025ff377602b6fc7caaf30dbc218371jacobs
355b4669e025ff377602b6fc7caaf30dbc218371jacobs
355b4669e025ff377602b6fc7caaf30dbc218371jacobs# if defined(HAVE_CDSASSL)
355b4669e025ff377602b6fc7caaf30dbc218371jacobs/*
355b4669e025ff377602b6fc7caaf30dbc218371jacobs * 'CDSAReadFunc()' - Read function for CDSA decryption code.
355b4669e025ff377602b6fc7caaf30dbc218371jacobs */
355b4669e025ff377602b6fc7caaf30dbc218371jacobs
355b4669e025ff377602b6fc7caaf30dbc218371jacobsstatic OSStatus /* O - -1 on error, 0 on success */
355b4669e025ff377602b6fc7caaf30dbc218371jacobsCDSAReadFunc(SSLConnectionRef connection, /* I - SSL/TLS connection */
355b4669e025ff377602b6fc7caaf30dbc218371jacobs void *data, /* I - Data buffer */
355b4669e025ff377602b6fc7caaf30dbc218371jacobs size_t *dataLength) /* IO - Number of bytes */
355b4669e025ff377602b6fc7caaf30dbc218371jacobs{
355b4669e025ff377602b6fc7caaf30dbc218371jacobs ssize_t bytes; /* Number of bytes read */
355b4669e025ff377602b6fc7caaf30dbc218371jacobs
355b4669e025ff377602b6fc7caaf30dbc218371jacobs#ifdef DEBUG_HTTP
355b4669e025ff377602b6fc7caaf30dbc218371jacobs httpDumpData(stdout, "CDSAReadFunc:", data, *dataLength);
355b4669e025ff377602b6fc7caaf30dbc218371jacobs#endif
355b4669e025ff377602b6fc7caaf30dbc218371jacobs bytes = recv((int)connection, data, *dataLength, 0);
355b4669e025ff377602b6fc7caaf30dbc218371jacobs if (bytes >= 0)
355b4669e025ff377602b6fc7caaf30dbc218371jacobs {
355b4669e025ff377602b6fc7caaf30dbc218371jacobs *dataLength = bytes;
355b4669e025ff377602b6fc7caaf30dbc218371jacobs return (0);
355b4669e025ff377602b6fc7caaf30dbc218371jacobs }
355b4669e025ff377602b6fc7caaf30dbc218371jacobs else
355b4669e025ff377602b6fc7caaf30dbc218371jacobs return (-1);
355b4669e025ff377602b6fc7caaf30dbc218371jacobs}
355b4669e025ff377602b6fc7caaf30dbc218371jacobs
355b4669e025ff377602b6fc7caaf30dbc218371jacobs
355b4669e025ff377602b6fc7caaf30dbc218371jacobs/*
355b4669e025ff377602b6fc7caaf30dbc218371jacobs * 'CDSAWriteFunc()' - Write function for CDSA encryption code.
355b4669e025ff377602b6fc7caaf30dbc218371jacobs */
355b4669e025ff377602b6fc7caaf30dbc218371jacobs
355b4669e025ff377602b6fc7caaf30dbc218371jacobsstatic OSStatus /* O - -1 on error, 0 on success */
355b4669e025ff377602b6fc7caaf30dbc218371jacobsCDSAWriteFunc(SSLConnectionRef connection, /* I - SSL/TLS connection */
355b4669e025ff377602b6fc7caaf30dbc218371jacobs const void *data, /* I - Data buffer */
355b4669e025ff377602b6fc7caaf30dbc218371jacobs size_t *dataLength) /* IO - Number of bytes */
355b4669e025ff377602b6fc7caaf30dbc218371jacobs{
355b4669e025ff377602b6fc7caaf30dbc218371jacobs ssize_t bytes;
355b4669e025ff377602b6fc7caaf30dbc218371jacobs
355b4669e025ff377602b6fc7caaf30dbc218371jacobs
355b4669e025ff377602b6fc7caaf30dbc218371jacobs bytes = write((int)connection, data, *dataLength);
355b4669e025ff377602b6fc7caaf30dbc218371jacobs if (bytes >= 0)
355b4669e025ff377602b6fc7caaf30dbc218371jacobs {
355b4669e025ff377602b6fc7caaf30dbc218371jacobs *dataLength = bytes;
355b4669e025ff377602b6fc7caaf30dbc218371jacobs return (0);
355b4669e025ff377602b6fc7caaf30dbc218371jacobs }
355b4669e025ff377602b6fc7caaf30dbc218371jacobs else
355b4669e025ff377602b6fc7caaf30dbc218371jacobs return (-1);
355b4669e025ff377602b6fc7caaf30dbc218371jacobs}
355b4669e025ff377602b6fc7caaf30dbc218371jacobs# endif /* HAVE_CDSASSL */
355b4669e025ff377602b6fc7caaf30dbc218371jacobs#endif /* HAVE_SSL */
355b4669e025ff377602b6fc7caaf30dbc218371jacobs
355b4669e025ff377602b6fc7caaf30dbc218371jacobs
355b4669e025ff377602b6fc7caaf30dbc218371jacobs/*
355b4669e025ff377602b6fc7caaf30dbc218371jacobs * End of "$Id: http.c 148 2006-04-25 16:54:17Z njacobs $"
355b4669e025ff377602b6fc7caaf30dbc218371jacobs */