netcam.c

/*
 *      netcam.c
 *
 *      Module for handling network cameras.
 *
 *      This code was inspired by the original netcam.c module
 *      written by Jeroen Vreeken and enhanced by several Motion
 *      project contributors, particularly Angel Carpintero and
 *      Christopher Price.
 *
 *      Copyright 2005, William M. Brack
 *      This software is distributed under the GNU Public license
 *      Version 2.  See also the file 'COPYING'.
 *
 *
 *      When a netcam has been configured, instead of using the routines
 *      within video.c (which handle a CCTV-type camera) the routines
 *      within this module are used.  There are only four entry points -
 *      one for "starting up" the camera (netcam_start), for "fetching a
 *      picture" from it (netcam_next), one for cleanup at the end of a
 *      run (netcam_cleanup), and a utility routine for receiving data
 *      from the camera (netcam_recv).
 *
 *      Two quite different types of netcams are handled.  The simplest
 *      one is the type which supplies a single JPEG frame each time it
 *      is accessed.  The other type is one which supplies an mjpeg
 *      stream of data.
 *
 *      For each of these cameras, the routine taking care of the netcam
 *      will start up a completely separate thread (which I call the "camera
 *      handler thread" within subsequent comments).  For a streaming camera,
 *      this handler will receive the mjpeg stream of data from the camera,
 *      and save the latest complete image when it begins to work on the next
 *      one.  For the non-streaming version, this handler will be "triggered"
 *      (signalled) whenever the main motion-loop asks for a new image, and
 *      will start to fetch the next image at that time.  For either type,
 *      the most recent image received from the camera will be returned to
 *      motion.
 */
#include "motion.h"

#include <netdb.h>
#include <netinet/in.h>
#include <regex.h>                  /* For parsing of the URL */
#include <sys/socket.h>

#include "netcam_ftp.h"

#define CONNECT_TIMEOUT        10   /* timeout on remote connection attempt */
#define READ_TIMEOUT            5   /* default timeout on recv requests */
#define POLLING_TIMEOUT  READ_TIMEOUT /* file polling timeout [s] */
#define POLLING_TIME  500*1000*1000 /* file polling time quantum [ns] (500ms) */
#define MAX_HEADER_RETRIES      5   /* Max tries to find a header record */
#define MINVAL(x, y) ((x) < (y) ? (x) : (y))

/*
 * The macro NETCAM_DEBUG is for development testing of this module.
 * The macro SETUP is to assure that "configuration-setup" type messages
 * are also printed when NETCAM_DEBUG is set.  Set the following #if to
 * 1 to enable it, or 0 (normal setting) to disable it.
 */
#define SETUP    ((cnt->conf.setup_mode) || (debug_level >= CAMERA_INFO))


tfile_context *file_new_context(void);
void file_free_context(tfile_context* ctxt);

/* These strings are used for the HTTP connection */
static const char    *connect_req;

static const char    *connect_req_http10 = "GET %s HTTP/1.0\r\n"
                      "Host: %s\r\n"
                      "User-Agent: Motion-netcam/" VERSION "\r\n";

static const char    *connect_req_http11 = "GET %s HTTP/1.1\r\n"
                      "Host: %s\r\n"
                      "User-Agent: Motion-netcam/" VERSION "\r\n";

static const char    *connect_req_close = "Connection: close\r\n";

static const char    *connect_req_keepalive = "Connection: Keep-Alive\r\n";

static const char    *connect_auth_req = "Authorization: Basic %s\r\n";

/*
 * The following three routines (netcam_url_match, netcam_url_parse and
 * netcam_url_free are for 'parsing' (i.e. separating into the relevant
 * components) the URL provided by the user.  They make use of regular
 * expressions (which is outside the scope of this module, so detailed
 * comments are not provided).  netcam_url_parse is called from netcam_start,
 * and puts the "broken-up" components of the URL into the "url" element of
 * the netcam_context structure.
 *
 * Note that the routines are not "very clever", but they work sufficiently
 * well for the limited requirements of this module.  The expression:
 *   (http)://(((.*):(.*))@)?([^/:]|[-.a-z0-9]+)(:([0-9]+))?($|(/[^:]*))
 * requires
 *   1) a string which begins with 'http', followed by '://'
 *   2) optionally a '@' which is preceded by two strings
 *      (with 0 or more characters each) separated by a ':'
 *      [this is for an optional username:password]
 *   3) a string comprising alpha-numerics, '-' and '.' characters
 *      [this is for the hostname]
 *   4) optionally a ':' followed by one or more numeric characters
 *      [this is for an optional port number]
 *   5) finally, either an end of line or a series of segments,
 *      each of which begins with a '/', and contains anything
 *      except a ':'
 */

/**
 * netcam_url_match
 *
 *      Finds the matched part of a regular expression
 *
 * Parameters:
 *
 *      m          A structure containing the regular expression to be used
 *      input      The input string
 *
 * Returns:        The string which was matched
 *
 */
static char *netcam_url_match(regmatch_t m, const char *input)
{
    char *match = NULL;
    int len;

    if (m.rm_so != -1) {
        len = m.rm_eo - m.rm_so;

        if ((match = (char *) malloc(len + 1)) != NULL) {
            strncpy(match, input + m.rm_so, len);
            match[len] = '\0';
        }
    }

    return match;
}

/**
 * netcam_url_parse
 *
 *      parses a string containing a URL into it's components
 *
 * Parameters:
 *      parse_url          A structure which will receive the results
 *                         of the parsing
 *      text_url           The input string containing the URL
 *
 * Returns:                Nothing
 *
 */
static void netcam_url_parse(struct url_t *parse_url, const char *text_url)
{
    char *s;
    int i;
    const char *re = "(http|ftp)://(((.*):(.*))@)?"
                     "([^/:]|[-.a-z0-9]+)(:([0-9]+))?($|(/[^:]*))";
    regex_t pattbuf;
    regmatch_t matches[10];

    if (!strncmp( text_url, "file", 4 ) ) 
        re = "(file)://(((.*):(.*))@)?"
             "([^/:]|[-.a-z0-9]*)(:([0-9]*))?($|(/[^:][/-_.a-z0-9]+))";

    if (debug_level > CAMERA_DEBUG)
        motion_log(-1, 0, "Entry netcam_url_parse data %s", text_url );

    memset(parse_url, 0, sizeof(struct url_t));
    /*
     * regcomp compiles regular expressions into a form that is
     * suitable for regexec searches
     * regexec matches the URL string against the regular expression
     * and returns an array of pointers to strings matching each match
     * within (). The results that we need are finally placed in parse_url
     */
    if (!regcomp(&pattbuf, re, REG_EXTENDED | REG_ICASE)) {
        if (regexec(&pattbuf, text_url, 10, matches, 0) != REG_NOMATCH) {
            for (i = 0; i < 10; i++) {
                if ((s = netcam_url_match(matches[i], text_url)) != NULL) {
                    if (debug_level > CAMERA_DEBUG)
                        motion_log(-1, 0, "Parse case %d data %s", i, s );
                    switch (i) {
                    case 1:
                        parse_url->service = s;
                        break;
                    case 3:
                        parse_url->userpass = s;
                        break;
                    case 6:
                        parse_url->host = s;
                        break;
                    case 8:
                        parse_url->port = atoi(s);
                        free(s);
                        break;
                    case 9:
                        parse_url->path = s;
                        break;
                        /* other components ignored */
                    default:
                        free(s);
                        break;
                    }
                }
            }
        }
    }
    if ((!parse_url->port) && (parse_url->service)){
        if (!strcmp(parse_url->service, "http"))
            parse_url->port = 80;
        else if (!strcmp(parse_url->service, "ftp"))
            parse_url->port = 21;
    }

    regfree(&pattbuf);
}

/**
 * netcam_url_free
 *
 *      General cleanup of the URL structure, called from netcam_cleanup.
 *
 * Parameters:
 *
 *      parse_url       Structure containing the parsed data
 *
 * Returns:             Nothing
 *
 */
static void netcam_url_free(struct url_t *parse_url)
{
    if (parse_url->service) {
        free(parse_url->service);
        parse_url->service = NULL;
    }

    if (parse_url->userpass) {
        free(parse_url->userpass);
        parse_url->userpass = NULL;
    }

    if (parse_url->host) {
        free(parse_url->host);
        parse_url->host = NULL;
    }

    if (parse_url->path) {
        free(parse_url->path);
        parse_url->path = NULL;
    }
}

/**
 * check_quote
 *
 *      Checks a string to see if it's quoted, and if so removes the
 *      quotes.
 *
 * Parameters:
 *
 *      str             Pointer to a string
 *
 * Returns:             Nothing, but updates the target if necessary
 *
 */
static void check_quote(char *str)
{
    int len;
    char ch;

    ch = *str;

    if ((ch == '"') || (ch == '\'')) {
        len = strlen(str) - 1;
        if (str[len] == ch) {
            memmove(str, str+1, len-1);
            str[len-1] = 0;
        }
    }
}

/**
 * netcam_check_content_length
 *
 *     Analyse an HTTP-header line to see if it is a Content-length
 *
 * Parameters:
 *
 *      header          Pointer to a string containing the header line
 *
 * Returns:
 *      -1              Not a Content-length line
 *      >=0             Value of Content-length field
 *
 */
static long netcam_check_content_length(char *header)
{
    long length = -1;    /* note this is a long, not an int */

    if (!header_process(header, "Content-Length", header_extract_number, &length)) {
        /*
         * Some netcams deliver some bad-format data, but if
         * we were able to recognize the header section and the
         * number we might as well try to use it.
         */
        if (length > 0)
            return length;
        return -1;
    }

    return length;
}

/**
 * netcam_check_keepalive
 *
 *     Analyse an HTTP-header line to see if it is a Keep-Alive.
 *
 * Parameters:
 *
 *      header          Pointer to a string containing the header line
 *
 * Returns:
 *      -1              Not a Keep-Alive line
 *      1               Is a Keep-Alive line
 *
 */
static int netcam_check_keepalive(char *header)
{
    char *content_type = NULL;

    if (!header_process(header, "Keep-Alive", http_process_type, &content_type))
        return -1;

    /* We do not detect the second field or other case mixes at present. */

    if (content_type) 
        free(content_type);

    return 1;
}

/**
 * netcam_check_close
 *
 *     Analyse an HTTP-header line to see if it is a Connection: close
 *
 * Parameters:
 *
 *      header          Pointer to a string containing the header line
 *
 * Returns:
 *      -1              Not a Connection: close
 *      1               Is a Connection: close
 *
 */
static int netcam_check_close(char *header)
{
    char *type = NULL;
    int ret = -1;

    if (!header_process(header, "Connection", http_process_type, &type))
        return -1;
    
    if (!strcmp(type, "close")) /* strcmp returns 0 for match */
        ret = 1;
    
    if (type) 
        free(type);

    return ret;
}

/**
 * netcam_check_content_type
 *
 *     Analyse an HTTP-header line to see if it is a Content-type
 *
 * Parameters:
 *
 *      header          Pointer to a string containing the header line
 *
 * Returns:
 *      -1              Not a Content-type line
 *      0               Content-type not recognized
 *      1               image/jpeg
 *      2               multipart/x-mixed-replace or multipart/mixed
 *
 */
static int netcam_check_content_type(char *header)
{
    char *content_type = NULL;
    int ret;

    if (!header_process(header, "Content-type", http_process_type, &content_type))
        return -1;

    if (!strcmp(content_type, "image/jpeg")) {
        ret = 1;
    } else if (!strcmp(content_type, "multipart/x-mixed-replace") ||
               !strcmp(content_type, "multipart/mixed")) {
        ret = 2;
    } else {
        ret = 0;
    }
            
    if (content_type)
        free(content_type);

    return ret;
}


/**
 * netcam_read_next_header
 *
 *      Read the next header record from the camera.
 *
 * Parameters
 *
 *      netcam          pointer to a netcam_context
 *
 * Returns:             0 for success, -1 if any error
 *
 */
static int netcam_read_next_header(netcam_context_ptr netcam)
{
    int retval;
    char *header;

    /*
     * return if not connected
     */
    if (netcam->sock == -1) 
        return -1;
    /*
     * We are expecting a header which *must* contain a mime-type of
     * image/jpeg, and *might* contain a Content-Length.
     *
     * If this is a "streaming" camera, the header *must* be preceded
     * by a "boundary" string.
     *
     */
    netcam->caps.content_length = 0;
    /*
     * If this is a "streaming" camera, the stream header must be
     * preceded by a "boundary" string
     */
    if (netcam->caps.streaming) {
        while (1) {
            retval = header_get(netcam, &header, HG_NONE);

            if (retval != HG_OK) {
                /* Header reported as not-OK, check to see if it's null */
                if (strlen(header) == 0) {
                    if (debug_level > CAMERA_INFO)
                        motion_log(LOG_DEBUG, 0, "Error reading image header, streaming mode (1). Null header.");
                } else {
                    /* Header is not null. Output it in case it's a new camera with unknown headers. */
                    if (debug_level > CAMERA_INFO)
                        motion_log(LOG_ERR, 0, "Error reading image header, streaming mode (1). "
                                               "Unknown header '%s'", header );
                }

                free(header);
                return -1;
            }

            retval = (strstr(header, netcam->boundary) == NULL);
            free(header);

            if (!retval)
                break;
        }
    }

    while (1) {
        retval = header_get(netcam, &header, HG_NONE);

        if (retval != HG_OK) {
            motion_log(LOG_ERR, 0, "Error reading image header (2)");
            free(header);
            return -1;
        }

        if (*header == 0)
            break;

        if ((retval = netcam_check_content_type(header)) >= 0) {
            if (retval != 1) {
                motion_log(LOG_ERR, 0, "Header not JPEG");
                free(header);
                return -1;
            }
        }

        if ((retval = (int) netcam_check_content_length(header)) > 0) {
            netcam->caps.content_length = 1;       /* set flag */
            netcam->receiving->content_length = (int) retval;
        }

        free(header);
    }

    if (debug_level > CAMERA_INFO)
        motion_log(-1, 0, "Found image header record");

    free(header);
    return 0;
}

/**
 * netcam_read_first_header
 *
 * This routine attempts to read a header record from the netcam.  If
 * successful, it analyses the header to determine whether the camera is
 * a "streaming" type.  If it is, the routine looks for the Boundary-string;
 * if found, it positions just past the string so that the image header can
 * be read.  It then reads the image header and continues processing that
 * header as well.
 *
 * If the camera does not appear to be a streaming type, it is assumed that the
 * header just read was the image header.  It is processed to determine whether
 * a Content-length is present.
 *
 * After this processing, the routine returns to the caller.
 *
 * Parameters:
 *      netcam            Pointer to the netcam_context structure
 *
 * Returns:               Content-type code if successful, -1 if not
 *
 */
static int netcam_read_first_header(netcam_context_ptr netcam)
{
    int retval = -2;                         /* "Unknown err" */
    int ret;
    int firstflag = 1;
    int aliveflag = 0;    /* If we have seen a Keep-Alive header from cam */
    int closeflag = 0;    /* If we have seen a Connection: close header from cam */
    char *header;
    char *boundary;
    struct context *cnt = netcam->cnt;       /* for conf debug_level */

    /* Send the initial command to the camera */
    if (send(netcam->sock, netcam->connect_request,
             strlen(netcam->connect_request), 0) < 0) {
        motion_log(LOG_ERR, 1, "Error sending 'connect' request");
        return -1;
    }

    /*
     * We expect to get back an HTTP header from the camera.
     * Successive calls to header_get will return each line
     * of the header received.  We will continue reading until
     * a blank line is received.
     *
     * As we process the header, we are looking for either of
     * header lines Content-type or Content-length.  Content-type
     * is used to determine whether the camera is "streaming" or
     * "non-streaming", and Content-length will be used to determine
     * whether future reads of images will be controlled by the
     * length specified before the image, or by a boundary string.
     *
     * The Content-length will only be present "just before" an
     * image is sent (if it is present at all).  That means that, if
     * this is a "streaming" camera, it will not be present in the
     * "first header", but will occur later (after a boundary-string).
     * For a non-streaming camera, however, there is no boundary-string,
     * and the first header is, in fact, the only header.  In this case,
     * there may be a Content-length.
     *
     */
    while (1) {                                 /* 'Do forever' */
        ret = header_get(netcam, &header, HG_NONE);

        if (debug_level > CAMERA_INFO)    /* Changed criterion and moved up from below to catch headers that cause returns */
            motion_log(LOG_DEBUG, 0, "Received first header ('%s')", header);

        if (ret != HG_OK) {
            if (debug_level > CAMERA_INFO)
                motion_log(LOG_ERR, 0, "Error reading first header (%s)", header);
            free(header);
            return -1;
        }

        if (firstflag) {
            if ((ret = http_result_code(header)) != 200) {
                if (debug_level > CAMERA_INFO)
                    motion_log(-1, 0, "HTTP Result code %d", ret);

                free(header);

                if (netcam->connect_keepalive) {
                    /* Cannot unset netcam->cnt->conf.netcam_http as it is assigned const */
                    /* But we do unset the netcam keepalive flag which was set in netcam_start */
                    /* This message is logged as Information as it would be useful to know */
                    /* if your netcam often returns bad HTTP result codes */
                    netcam->connect_keepalive = 0;
                    motion_log(LOG_INFO, 0, "Removed netcam Keep-Alive flag"
                                            "due to apparent closed HTTP connection.");
                }
                return ret;
            }

            firstflag = 0;
            free(header);
            continue;
        }

        if (*header == 0)                  /* blank line received */
            break;

        /* Check if this line is the content type */
        if ((ret = netcam_check_content_type(header)) >= 0) {
            retval = ret;
            /*
             * We are expecting to find one of three types:
             * 'multipart/x-mixed-replace', 'multipart/mixed'
             * or 'image/jpeg'.  The first two will be received
             * from a streaming camera, and the third from a
             * camera which provides a single frame only.
             */
            switch (ret) {
            case 1:         /* not streaming */
                if (SETUP) {
                    if (netcam->connect_keepalive) 
                        motion_log(LOG_DEBUG, 0, "Non-streaming camera (keep-alive set)");
                    else
                        motion_log(LOG_DEBUG, 0, "Non-streaming camera (keep-alive not set)");
                }
                netcam->caps.streaming = 0;
                break;

            case 2:         /* streaming */
                if (SETUP)
                    motion_log(LOG_DEBUG, 0, "Streaming camera");

                netcam->caps.streaming = 1;

                if ((boundary = strstr(header, "boundary="))) {
                    /*
                     * on error recovery this
                     * may already be set
                     * */
                    if (netcam->boundary)
                        free(netcam->boundary);

                    netcam->boundary = strdup(boundary + 9);
                    /*
                     * HTTP protocol apparently permits the boundary string
                     * to be quoted (the Lumenera does this, which caused
                     * trouble) so we need to get rid of any surrounding
                     * quotes
                     */
                    check_quote(netcam->boundary);
                    netcam->boundary_length = strlen(netcam->boundary);

                    if (SETUP) 
                        motion_log(LOG_DEBUG, 0, "Boundary string [%s]",
                                   netcam->boundary);
                        
                }                    
                break;

            default:       /* error */
                motion_log(LOG_ERR, 0, "Unrecognized content type");
                free(header);
                return -1;
                
            }
        } else if ((ret = (int) netcam_check_content_length(header)) >= 0) {
            if (SETUP)
                motion_log(LOG_DEBUG, 0, "Content-length present");

            netcam->caps.content_length = 1;     /* set flag */
            netcam->receiving->content_length = ret;
        } else if (netcam_check_keepalive(header) == TRUE) {
            /* Note that we have received a Keep-Alive header, and thus the socket can be left open */
            aliveflag=TRUE;
            netcam->keepalive_thisconn = TRUE;
            /* This flag will not be set when a Streaming cam is in use, but that */
            /* does not matter as the test below looks at Streaming state also.   */
        } else if (netcam_check_close(header) == TRUE) {
            /* Note that we have received a Connection: close header */
            closeflag=TRUE;
            /* This flag is acted upon below */
            if (debug_level > CAMERA_INFO) /* Changed criterion and moved up from below to catch headers that cause returns */
                motion_log(LOG_DEBUG, 0, "Found Conn:close header ('%s')", header);
        }
        free(header);
    }
    free(header);

    if (!netcam->caps.streaming && netcam->connect_keepalive) {
        
        /*
         * If we are a non-streaming (ie. Jpeg) netcam and keepalive is configured 
         */

        if (aliveflag) {
            if (closeflag) {
                   /*
                    * If not a streaming cam, and keepalive is set, and the flag shows we 
                    * did not see a Keep-Alive field returned from netcam and a Close field.
                    * Not quite sure what the correct course of action is here. In for testing.
                    */ 
                motion_log(LOG_INFO, 0, "Info: Both 'Connection: Keep-Alive' and 'Connection: close' "
                                        "header received. Motion continues unchanged.");
            } else {
                    /* aliveflag && !closeflag 
                     *
                     * If not a streaming cam, and keepalive is set, and the flag shows we 
                     * just got a Keep-Alive field returned from netcam and no Close field.
                     * No action, as this is the normal case. In debug we print a notification.
                     */
        
                if (debug_level > CAMERA_INFO)
                    motion_log(LOG_INFO, 0, "Info: Received a Keep-Alive field in this set of headers.");
            }
        } else { /* !aliveflag */
            if (!closeflag) {
                   /*
                    * If not a streaming cam, and keepalive is set, and the flag shows we 
                    * did not see a Keep-Alive field returned from netcam nor a Close field.
                    * Not quite sure what the correct course of action is here. In for testing.
                    */                                                                                                     
                motion_log(LOG_INFO, 0, "Info: No 'Connection: Keep-Alive' nor 'Connection: close' "
                                        "header received. Motion continues unchanged.");
            } else {  
                /* !aliveflag & closeflag 
                 * If not a streaming cam, and keepalive is set, and the flag shows we 
                 * received a 'Connection: close' field returned from netcam. It is not likely
                 * we will get a Keep-Alive and Close header together - this is picked up by
                 * the test code above.
                 * If we receive a Close header, then we want to cease keep-alive for this cam.
                 * This situation will occur in 2 situations:
                 *    (a) in HTTP 1.1 when the client wants to stop the keep-alive
                 *          (and in this case it would be correct to close connection and then
                 *          make a new one, with keep-alive set again).
                 *    (b) in HTTP 1.0 with keepalive, when the client does not support it.
                 *          In this case we should not attempt to re-start Keep-Alive.
                 * Due to that, we accept a Connection: close header in HTTP 1.0 & 1.1 modes
                 *
                 * To tell between the sitation where a camera has been in Keep-Alive mode and
                 * is now finishing (and will want to be re-started in Keep-Alive) and the other
                 * case when a cam does not support it, we have a flag which says if the netcam
                 * has returned a Keep-Alive flag during this connection. If that's set, we
                 * set ourselves up to re-connect with Keep-Alive after the socket is closed.
                 * If it's not set, then we will not try again to use Keep-Alive.
                 */
                if (!netcam->keepalive_thisconn) {
                    netcam->connect_keepalive = FALSE;    /* No further attempts at keep-alive */
                    motion_log(LOG_INFO, 0, "Removed netcam Keep-Alive flag because 'Connection: close' "
                                            "header received. Netcam does not support Keep-Alive. Motion "
                                            "continues in non-Keep-Alive.");
                } else {
                    netcam->keepalive_timeup = TRUE;    /* We will close and re-open keep-alive */
                    motion_log(LOG_INFO, 0, "Keep-Alive has reached end of valid period. Motion will close " 
                                            "netcam, then resume Keep-Alive with a new socket.");
                }
            }
        }
    }

    return retval;
}

/**
 * netcam_disconnect
 *
 *      Disconnect from the network camera.
 *
 * Parameters:
 *
 *      netcam  pointer to netcam context
 *
 * Returns:     Nothing
 *
 */
static void netcam_disconnect(netcam_context_ptr netcam)
{
    if (netcam->sock > 0) {
        if (close(netcam->sock) < 0)
            motion_log(LOG_ERR, 1, "netcam_disconnect");

        netcam->sock = -1;
    }
}

/**
 * netcam_connect
 *
 *      Attempt to open the network camera as a stream device.
 *      Keep-alive is supported, ie. if netcam->connect_keepalive is TRUE, we
 *      re-use netcam->sock unless it has value -1, meaning it is invalid.
 *
 * Parameters:
 *
 *      netcam    pointer to netcam_context structure
 *      err_flag  flag to suppress error printout (1 => suppress)
 *                Note that errors which indicate something other than
 *                a network connection problem are not suppressed.
 *
 * Returns:     0 for success, -1 for error
 *
 */
static int netcam_connect(netcam_context_ptr netcam, int err_flag)
{
    struct sockaddr_in server;      /* for connect */
    struct addrinfo *res;           /* for getaddrinfo */
    int ret;
    int saveflags;
    int back_err;
    int optval;
    socklen_t optlen=sizeof(optval);
    socklen_t len;
    fd_set fd_w;
    struct timeval selecttime;

    /* Assure any previous connection has been closed - IF we are not in keepalive */
    if (!netcam->connect_keepalive) {
        if (debug_level > CAMERA_INFO)
            motion_log(LOG_DEBUG, 0, "netcam_connect, disconnecting netcam since keep-alive not set." );
        
        netcam_disconnect(netcam);

        /* create a new socket */
        if ((netcam->sock = socket(PF_INET, SOCK_STREAM, 0)) < 0) {
            motion_log(LOG_ERR, 1, "netcam_connect with no keepalive, attempt to create socket failed.");
            return -1;
        }

        if (debug_level > CAMERA_INFO )
            motion_log(LOG_DEBUG, 0, "netcam_connect with no keepalive, new socket created fd %d", netcam->sock);

    } else {       /* We are in keepalive mode, check for invalid socket */
        if (netcam->sock == -1) {
            /* Must be first time, or closed, create a new socket */
            if ((netcam->sock = socket(PF_INET, SOCK_STREAM, 0)) < 0) {
                motion_log(LOG_ERR, 1, "netcam_connect with keepalive set, invalid socket." 
                                       "This could be the first time. Creating a new one failed.");
                return -1;
            }

            if (debug_level > CAMERA_INFO)
                motion_log(LOG_DEBUG, 0, "netcam_connect with keepalive set, invalid socket."
                                         "This could be first time, created a new one with fd %d", netcam->sock);

            /* Record that this connection has not yet received a Keep-Alive header */
            netcam->keepalive_thisconn = FALSE;

            /* Check the socket status for the keepalive option */
            if (getsockopt(netcam->sock, SOL_SOCKET, SO_KEEPALIVE, &optval, &optlen) < 0) {
                motion_log(LOG_ERR, 1, "netcam_connect : getsockopt()");
                return -1;
            }

            if (debug_level > CAMERA_INFO) {
                if (optval == 1)    
                    motion_log(LOG_DEBUG, 0, "netcam_connect: SO_KEEPALIVE is ON");
                else
                    motion_log(LOG_DEBUG, 0, "netcam_connect: SO_KEEPALIVE is OFF");
            }
    
            /* Set the option active */
            optval = 1;
            optlen = sizeof(optval);

            if (setsockopt(netcam->sock, SOL_SOCKET, SO_KEEPALIVE, &optval, optlen) < 0) {
                motion_log(LOG_ERR, 1, "netcam_connect : setsockopt()");
                return -1;
            }

            if (debug_level > CAMERA_INFO )
                motion_log(LOG_DEBUG, 0, "netcam_connect: SO_KEEPALIVE set on socket.");

        } else if (debug_level > CAMERA_INFO) {
            motion_log(LOG_DEBUG, 0, "netcam_connect re-using socket %d since keepalive is set.", netcam->sock);
        }
    }

    /* lookup the hostname given in the netcam URL */
    if ((ret = getaddrinfo(netcam->connect_host, NULL, NULL, &res)) != 0) {
        if (!err_flag)
            motion_log(LOG_ERR, 0, "getaddrinfo() failed (%s): %s",
                       netcam->connect_host, gai_strerror(ret));
        if (debug_level > CAMERA_INFO)
            motion_log(LOG_DEBUG, 0, "netcam_connect disconnecting netcam (1)");
        netcam_disconnect(netcam);
        return -1;
    }

    /*
     * Fill the hostname details into the 'server' structure and
     * attempt to connect to the remote server
     */
    memset(&server, 0, sizeof(server));
    memcpy(&server, res->ai_addr, sizeof(server));
    freeaddrinfo(res);

    server.sin_family = AF_INET;
    server.sin_port = htons(netcam->connect_port);

    /*
     * We set the socket non-blocking and then use a 'select'
     * system call to control the timeout.
     */

    if ((saveflags = fcntl(netcam->sock, F_GETFL, 0)) < 0) {
        motion_log(LOG_ERR, 1, "fcntl(1) on socket");
        netcam_disconnect(netcam);
        return -1;
    }

    /* Set the socket non-blocking */
    if (fcntl(netcam->sock, F_SETFL, saveflags | O_NONBLOCK) < 0) {
        motion_log(LOG_ERR, 1, "fcntl(2) on socket");
        netcam_disconnect(netcam);
        return -1;
    }

    /* Now the connect call will return immediately */
    ret = connect(netcam->sock, (struct sockaddr *) &server,
                  sizeof(server));
    back_err = errno;           /* save the errno from connect */

    /* If the connect failed with anything except EINPROGRESS, error */
    if ((ret < 0) && (back_err != EINPROGRESS)) {
        if (!err_flag)
            motion_log(LOG_ERR, 1, "connect() failed (%d)", back_err);

        if (debug_level > CAMERA_INFO)    
            motion_log(LOG_DEBUG, 0, "netcam_connect disconnecting netcam (4)");

        netcam_disconnect(netcam);
        return -1;
    }

    /* Now we do a 'select' with timeout to wait for the connect */
    FD_ZERO(&fd_w);
    FD_SET(netcam->sock, &fd_w);
    selecttime.tv_sec = CONNECT_TIMEOUT;
    selecttime.tv_usec = 0;
    ret = select(FD_SETSIZE, NULL, &fd_w, NULL, &selecttime);

    if (ret == 0) {            /* 0 means timeout */
        if (!err_flag)
            motion_log(LOG_ERR, 0, "timeout on connect()");

        if (debug_level > CAMERA_INFO)
            motion_log(LOG_DEBUG, 0, "netcam_connect disconnecting netcam (2)");

        netcam_disconnect(netcam);
        return -1;
    }

    /*
     * A +ve value returned from the select (actually, it must be a
     * '1' showing 1 fd's changed) shows the select has completed.
     * Now we must check the return code from the select.
     */
    len = sizeof(ret);

    if (getsockopt(netcam->sock, SOL_SOCKET, SO_ERROR, &ret, &len) < 0) {
        motion_log(LOG_ERR, 0, "getsockopt after connect");
        netcam_disconnect(netcam);
        return -1;
    }

    /* If the return code is anything except 0, error on connect */
    if (ret) {
        if (!err_flag)
            motion_log(LOG_ERR, 1, "connect returned error");
        if (debug_level > CAMERA_INFO)
            motion_log(LOG_DEBUG, 0, "netcam_connect disconnecting netcam (3)");
        netcam_disconnect(netcam);
        return -1;
    }

    /* The socket info is stored in the rbuf structure of our context */
    rbuf_initialize(netcam);

    return 0;            /* success */
}


/**
 * netcam_check_buffsize
 *
 * This routine checks whether there is enough room in a buffer to copy
 * some additional data.  If there is not enough room, it will re-allocate
 * the buffer and adjust it's size.
 *
 * Parameters:
 *      buff            Pointer to a netcam_image_buffer structure
 *      numbytes        The number of bytes to be copied
 *
 * Returns:             Nothing
 */
static void netcam_check_buffsize(netcam_buff_ptr buff, size_t numbytes)
{
    if ((buff->size - buff->used) >= numbytes)
        return;

    if (debug_level > CAMERA_INFO)
        motion_log(-1, 0, "expanding buffer from %d to %d bytes",
                   (int) buff->size, (int) buff->size + NETCAM_BUFFSIZE);

    buff->ptr = myrealloc(buff->ptr, buff->size + NETCAM_BUFFSIZE,
                          "netcam_check_buf_size");
    buff->size += NETCAM_BUFFSIZE;
}

/**
 * netcam_read_html_jpeg
 *
 * This routine reads a jpeg image from the netcam.  When it is called,
 * the stream is already positioned just after the image header.
 *
 * This routine is called under the four variations of two different
 * conditions:
 *     1) Streaming or non-streaming camera
 *           Note: Keep-Alive is supported for non-streaming cameras,
 *           if enabled in the netcam's config structure.
 *     2) Header does or does not include Content-Length
 * Additionally, if it is a streaming camera, there must always be a
 * boundary-string.
 *
 * The routine will (attempt to) read the JPEG image.  If a Content-Length
 * is present, it will be used (this will result in more efficient code, and
 * also code which should be better at detecting and recovering from possible
 * error conditions).
 *
 * If a boundary-string is present (and, if the camera is streaming, this
 * *must* be the case), the routine will assure that it is recognized and
 * acted upon.
 *
 * Our algorithm for this will be as follows:
 *     1) If a Content-Length is present, set the variable "remaining"
 *        to be equal to that value, else set it to a "very large"
 *        number.
 *     2) While there is more data available from the camera:
 *        a) If there is a "boundary string" specified (from the initial
 *           header):
 *           i)   If the amount of data in the input buffer is less than
 *                the length of the boundary string, get more data into
 *                the input buffer (error if failure).
 *           ii)  If the boundary string is found, check how many
 *                characters remain in the input buffer before the start
 *                of the boundary string.  If that is less than the
 *                variable "remaining", reset "remaining" to be equal
 *                to that number.
 *        b) Try to copy up to "remaining" characters from the input
 *           buffer into our destination buffer.
 *        c) If there are no more characters available from the camera,
 *           exit this loop, else subtract the number of characters
 *           actually copied from the variable "remaining".
 *     3) If Content-Length was present, and "remaining" is not equal
 *        to zero, generate a warning message for logging.
 *
 *
 * Parameters:
 *      netcam          Pointer to netcam context
 *
 *
 * Returns:             0 for success, -1 for error
 *
 */
static int netcam_read_html_jpeg(netcam_context_ptr netcam)
{
    netcam_buff_ptr buffer;
    size_t remaining;       /* # characters to read */
    size_t maxflush;        /* # chars before boundary */
    size_t rem, rlen, ix;   /* working vars */
    int retval;
    char *ptr, *bptr, *rptr;
    netcam_buff *xchg;
    struct timeval curtime;
    /*
     * Initialisation - set our local pointers to the context
     * information
     */
    buffer = netcam->receiving;
    /* Assure the target buffer is empty */
    buffer->used = 0;
    /* Prepare for read loop */
    if (buffer->content_length != 0)
        remaining = buffer->content_length;
    else
        remaining = 999999;

    /* Now read in the data */
    while (remaining) {
        /* Assure data in input buffer */
        if (netcam->response->buffer_left <= 0) {
            retval = rbuf_read_bufferful(netcam);

            if (retval <= 0)
                break;

            netcam->response->buffer_left = retval;
            netcam->response->buffer_pos = netcam->response->buffer;
        }

        /* If a boundary string is present, take it into account */
        bptr = netcam->boundary;

        if (bptr) {
            rptr = netcam->response->buffer_pos;
            rlen = netcam->response->buffer_left;

            /* Loop through buffer looking for start of boundary */
            while (1) {
                /*
                 * Logic gets a little complicated here.  The
                 * problem is that we are reading in input
                 * data in packets, and there is a (small)
                 * chance that the boundary string could be
                 * split across successive packets.
                 * First a quick check if the string *might*
                 * be in the current buffer.
                 */
                if (rlen > remaining)
                    rlen = remaining;

                if (remaining < netcam->boundary_length)
                    break;

                if ((ptr = memchr(rptr, *bptr, rlen)) == NULL)
                    /* boundary not here (normal path) */
                    break;
                /*
                 * At least the first char was found in the
                 * buffer - check for the rest
                 */
                rem = rlen - (ptr - rptr);
                for (ix = 1; (ix < rem) && (ix < netcam->boundary_length); ix++) {
                    if (ptr[ix] != bptr[ix])
                        break;
                }

                if ((ix != netcam->boundary_length) && (ix != rem)) {
                    /*
                     * Not pointing at a boundary string -
                     * step along input
                     */
                    ix = ptr - rptr + 1;
                    rptr += ix;
                    rlen -= ix;

                    if (rlen <= 0)
                        /* boundary not in buffer - go copy out
                         */
                        break;
                    /*
                     * not yet decided - continue
                     * through input
                     */
                    continue;
                }
                /*
                 * If we finish the 'for' with
                 * ix == boundary_length, that means we found
                 * the string, and should copy any data which
                 * precedes it into the target buffer, then
                 * exit the main loop.
                 */
                if (ix == netcam->boundary_length) {
                    if ((ptr - netcam->response->buffer) < (int) remaining)
                        remaining = ptr - netcam->response->buffer;

                    /* go copy everything up to boundary */
                    break;
                }

                /*
                 * If not, and ix == rem, that means we reached
                 * the end of the input buffer in the middle of
                 * our check, which is the (somewhat messy)
                 * problem mentioned above.
                 *
                 * Assure there is data before potential
                 * boundary string
                 */
                if (ptr != netcam->response->buffer) {
                    /*
                     * We have a boundary string crossing
                     * packets :-(. We will copy all the
                     * data up to the beginning of the
                     * potential boundary, then re-position
                     * the (partial) string to the
                     * beginning and get some more input
                     * data.  First we flush the input
                     * buffer up to the beginning of the
                     * (potential) boundary string
                     */
                    ix = ptr - netcam->response->buffer_pos;
                    netcam_check_buffsize(buffer, ix);
                    retval = rbuf_flush(netcam, buffer->ptr + buffer->used, ix);
                    buffer->used += retval;
                    remaining -= retval;

                    /*
                     * Now move the boundary fragment to
                     * the head of the input buffer.
                     * This is really a "hack" - ideally,
                     * we should have a function within the
                     * module netcam_wget.c to do this job!
                     */

                    if (debug_level > CAMERA_INFO) {
                        motion_log(-1, 0,
                                   "Potential split boundary - "
                                   "%d chars flushed, %d "
                                   "re-positioned", ix,
                                   (int) netcam->response->buffer_left);
                    }

                    memmove(netcam->response->buffer, ptr,
                            netcam->response->buffer_left);
                }       /* end of boundary split over buffer */

                retval = netcam_recv(netcam, netcam->response->buffer +
                                     netcam->response->buffer_left,
                                     sizeof(netcam->response->buffer) -
                                     netcam->response->buffer_left);

                if (retval <= 0) { /* this is a fatal error */
                    motion_log(LOG_ERR, 1, "recv() fail after boundary string");
                    return -1;
                }

                /* Reset the input buffer pointers */
                netcam->response->buffer_left = retval + netcam->response->buffer_left;
                netcam->response->buffer_pos = netcam->response->buffer;

                /* This will cause a 'continue' of the main loop */
                bptr = NULL;

                /* Return to do the boundary compare from the start */
                break;
            }             /* end of while(1) input buffer search */

            /* !bptr shows we're processing split boundary */
            if (!bptr)
                continue;
        }             /* end of if (bptr) */

        /* boundary string not present, so just write out as much data as possible */
        if (remaining) {
            maxflush = MINVAL(netcam->response->buffer_left, remaining);
            netcam_check_buffsize(buffer, maxflush);
            retval = rbuf_flush(netcam, buffer->ptr + buffer->used, maxflush);
            buffer->used += retval;
            remaining -= retval;
        }
    }

    /*
     * read is complete - set the current 'receiving' buffer atomically
     * as 'latest', and make the buffer previously in 'latest' become
     * the new 'receiving'
     */
    if (gettimeofday(&curtime, NULL) < 0) 
        motion_log(LOG_ERR, 1, "gettimeofday in netcam_read_jpeg");
    

    netcam->receiving->image_time = curtime;

    /*
     * Calculate our "running average" time for this netcam's
     * frame transmissions (except for the first time).
     * Note that the average frame time is held in microseconds.
     */
    if (netcam->last_image.tv_sec) {
        netcam->av_frame_time = (9.0 * netcam->av_frame_time +
                                 1000000.0 * (curtime.tv_sec - netcam->last_image.tv_sec) +
                                 (curtime.tv_usec- netcam->last_image.tv_usec)) / 10.0;

        if (debug_level > CAMERA_INFO) 
            motion_log(-1, 0, "Calculated frame time %f", netcam->av_frame_time);
    }
    netcam->last_image = curtime;

    pthread_mutex_lock(&netcam->mutex);

    xchg = netcam->latest;
    netcam->latest = netcam->receiving;
    netcam->receiving = xchg;
    netcam->imgcnt++;
    /*
     * We have a new frame ready.  We send a signal so that
     * any thread (e.g. the motion main loop) waiting for the
     * next frame to become available may proceed.
     */
    pthread_cond_signal(&netcam->pic_ready);

    pthread_mutex_unlock(&netcam->mutex);

    if (!netcam->caps.streaming) {
        if (!netcam->connect_keepalive) {
            if (debug_level > CAMERA_INFO)
                 motion_log(LOG_DEBUG, 0, "netcam_read_html_jpeg disconnecting netcam since keep-alive not set." );
            netcam_disconnect(netcam);
        } else if (debug_level > CAMERA_INFO) {
            motion_log(LOG_DEBUG, 0, "netcam_read_html_jpeg leaving netcam connected." );
        }
    }

    return 0;
}

/**
 * netcam_read_ftp_jpeg
 *
 *      This routine reads from a netcam using the FTP protocol.
 *      The current implementation is still a little experimental,
 *      and needs some additional code for error detection and
 *      recovery.
 */
static int netcam_read_ftp_jpeg(netcam_context_ptr netcam)
{
    netcam_buff_ptr buffer;
    int len;
    netcam_buff *xchg;
    struct timeval curtime;

    /* Point to our working buffer */
    buffer = netcam->receiving;
    buffer->used = 0;

    /* Request the image from the remote server */
    if (ftp_get_socket(netcam->ftp) <= 0) {
        motion_log(LOG_ERR, 0, "ftp_get_socket failed in netcam_read_jpeg");
        return -1;
    }

    /* Now fetch the image using ftp_read.  Note this is a blocking call */
    do {
        /* Assure there's enough room in the buffer */
        netcam_check_buffsize(buffer, FTP_BUF_SIZE);

        /* Do the read */
        if ((len = ftp_read(netcam->ftp, buffer->ptr + buffer->used, FTP_BUF_SIZE)) < 0)
            return -1;

        buffer->used += len;
    } while (len > 0);

    if (gettimeofday(&curtime, NULL) < 0) 
        motion_log(LOG_ERR, 1, "gettimeofday in netcam_read_jpeg");
    

    netcam->receiving->image_time = curtime;
    /*
     * Calculate our "running average" time for this netcam's
     * frame transmissions (except for the first time).
     * Note that the average frame time is held in microseconds.
     */
    if (netcam->last_image.tv_sec) {
        netcam->av_frame_time =
          ((9.0 * netcam->av_frame_time) + 1000000.0 *
          (curtime.tv_sec - netcam->last_image.tv_sec) +
          (curtime.tv_usec- netcam->last_image.tv_usec)) / 10.0;

        if (debug_level > CAMERA_INFO)
            motion_log(-1, 0, "Calculated frame time %f", netcam->av_frame_time);
    }

    netcam->last_image = curtime;

    /*
     * read is complete - set the current 'receiving' buffer atomically
     * as 'latest', and make the buffer previously in 'latest' become
     * the new 'receiving'
     */
    pthread_mutex_lock(&netcam->mutex);

    xchg = netcam->latest;
    netcam->latest = netcam->receiving;
    netcam->receiving = xchg;
    netcam->imgcnt++;

    /*
     * We have a new frame ready.  We send a signal so that
     * any thread (e.g. the motion main loop) waiting for the
     * next frame to become available may proceed.
     */
    pthread_cond_signal(&netcam->pic_ready);
    pthread_mutex_unlock(&netcam->mutex);

    return 0;
}


/**
 * netcam_read_file_jpeg
 *
 *      This routine reads local image file. ( netcam_url file:///path/image.jpg )
 *      The current implementation is still a little experimental,
 *      and needs some additional code for error detection and
 *      recovery.
 */
static int netcam_read_file_jpeg(netcam_context_ptr netcam)
{
    int loop_counter=0;

    if (debug_level > CAMERA_VERBOSE) 
        motion_log(-1,0,"Begin %s", __FUNCTION__);
    
    netcam_buff_ptr buffer;
    int len;
    netcam_buff *xchg;
    struct timeval curtime;
    struct stat statbuf;

    /* Point to our working buffer */
    buffer = netcam->receiving;
    buffer->used = 0;

    /*int fstat(int filedes, struct stat *buf);*/
    do {

        if (stat( netcam->file->path, &statbuf)) {
            motion_log(-1, 0, "stat(%s) error", netcam->file->path );
            return -1;
        }
    
        if (debug_level > CAMERA_VERBOSE) 
            motion_log(-1, 0, "statbuf.st_mtime[%d] != last_st_mtime[%d]", statbuf.st_mtime,  netcam->file->last_st_mtime);
        
        if (loop_counter>((POLLING_TIMEOUT*1000*1000)/(POLLING_TIME/1000))) { //its waits POLLING_TIMEOUT
            motion_log(-1, 0, "waiting new file image timeout" );
            return -1;
        }

        if (debug_level > CAMERA_VERBOSE)
            motion_log(-1, 0, "delay waiting new file image ");
        
        //SLEEP(netcam->timeout.tv_sec, netcam->timeout.tv_usec*1000 ); //its waits 5seconds - READ_TIMEOUT
        SLEEP( 0, POLLING_TIME ); // its waits 500ms
        /*return -1;*/
        loop_counter++;

    } while (statbuf.st_mtime==netcam->file->last_st_mtime);

    netcam->file->last_st_mtime = statbuf.st_mtime;
    if (debug_level > CAMERA_INFO) 
        motion_log(LOG_INFO, 0, "processing new file image - st_mtime "
                                "%d", netcam->file->last_st_mtime );
    

    /* Assure there's enough room in the buffer */
    while (buffer->size < (size_t)statbuf.st_size) 
        netcam_check_buffsize(buffer, statbuf.st_size); 
    

    /* Do the read */
    netcam->file->control_file_desc = open( netcam->file->path, O_RDONLY);

    if (netcam->file->control_file_desc < 0) {
        motion_log(-1, 0, "open(%s) error:%d", netcam->file->path, netcam->file->control_file_desc);
        return -1;
    }

    if ((len = read(netcam->file->control_file_desc, buffer->ptr + buffer->used, statbuf.st_size)) < 0) {
        motion_log(-1, 0, "read(%s) error:%d", netcam->file->control_file_desc, len );
        return -1;
    }

    buffer->used += len;

    close( netcam->file->control_file_desc );

    if (gettimeofday(&curtime, NULL) < 0) 
        motion_log(LOG_ERR, 1, "gettimeofday in netcam_read_jpeg");
    
    netcam->receiving->image_time = curtime;
    /*
     * Calculate our "running average" time for this netcam's
     * frame transmissions (except for the first time).
     * Note that the average frame time is held in microseconds.
     */
    if (netcam->last_image.tv_sec) {
        netcam->av_frame_time =
          ((9.0 * netcam->av_frame_time) + 1000000.0 *
          (curtime.tv_sec - netcam->last_image.tv_sec) +
          (curtime.tv_usec- netcam->last_image.tv_usec)) / 10.0;
    
        if (debug_level > CAMERA_INFO)
            motion_log(-1, 0, "Calculated frame time %f", netcam->av_frame_time);
    }

    netcam->last_image = curtime;

    /*
     * read is complete - set the current 'receiving' buffer atomically
     * as 'latest', and make the buffer previously in 'latest' become
     * the new 'receiving'
     */
    pthread_mutex_lock(&netcam->mutex);

    xchg = netcam->latest;
    netcam->latest = netcam->receiving;
    netcam->receiving = xchg;
    netcam->imgcnt++;

    /*
     * We have a new frame ready.  We send a signal so that
     * any thread (e.g. the motion main loop) waiting for the
     * next frame to become available may proceed.
     */
    pthread_cond_signal(&netcam->pic_ready);

    pthread_mutex_unlock(&netcam->mutex);

    if (debug_level > CAMERA_VERBOSE) 
        motion_log(-1,0,"End %s", __FUNCTION__);
    
    return 0;
}


tfile_context *file_new_context(void) 
{
    tfile_context *ret;

    /* note that mymalloc will exit on any problem */
    ret = mymalloc(sizeof(tfile_context));
    if (!ret)
        return ret;

    memset(ret, 0, sizeof(tfile_context));
    return ret;
}

void file_free_context(tfile_context* ctxt) {
    if (ctxt == NULL)
        return;

    if (ctxt->path != NULL)
        free(ctxt->path);

    free(ctxt);
}

static int netcam_setup_file(netcam_context_ptr netcam, struct url_t *url) 
{

    if ((netcam->file = file_new_context()) == NULL)
        return -1;

    /*
     * We copy the strings out of the url structure into the ftp_context
     * structure.  By setting url->{string} to NULL we effectively "take
     * ownership" of the string away from the URL (i.e. it won't be freed
     * when we cleanup the url structure later).
     */
    netcam->file->path = url->path;
    url->path = NULL;

    if (debug_level > CAMERA_INFO)
        motion_log(LOG_INFO, 0, "netcam_setup_file: netcam->file->path %s",netcam->file->path);

    netcam_url_free(url);

    netcam->get_image = netcam_read_file_jpeg;

    return 0;
}

/**
 * netcam_handler_loop
 *      This is the "main loop" for the handler thread.  It is created
 *      in netcam_start when a streaming camera is detected.
 *
 * Parameters
 *
 *      arg     Pointer to the motion context for this camera
 *
 * Returns:     NULL pointer
 *
 */
static void *netcam_handler_loop(void *arg)
{
    int retval;
    int open_error = 0;
    netcam_context_ptr netcam = arg;
    struct context *cnt = netcam->cnt; /* needed for the SETUP macro :-( */

    /* Store the corresponding motion thread number in TLS also for this
     * thread (necessary for 'motion_log' to function properly).
     */
    pthread_setspecific(tls_key_threadnr, (void *)((unsigned long)cnt->threadnr));

    if (SETUP)
        motion_log(LOG_INFO, 0, "Camera handler thread [%d]  started", netcam->threadnr);

    /*
     * The logic of our loop is very simple.  If this is a non-
     * streaming camera, we re-establish connection with the camera
     * and read the header record.  If it's a streaming camera, we
     * position to the next "boundary string" in the input stream.
     * In either case, we then read the following JPEG image into the
     * next available buffer, updating the "next" and "latest" indices
     * in our netcam * structure.  The loop continues until netcam->finish
     * or cnt->finish is set.
     */

    while (!netcam->finish) {
        if (netcam->response) {    /* if html input */
            if (!netcam->caps.streaming) {
                /* Non-streaming ie. jpeg */
                if (!netcam->connect_keepalive || (netcam->connect_keepalive && netcam->keepalive_timeup)) {
                    /* If keepalive flag set but time up, time to close this socket */
                    if (netcam->connect_keepalive && netcam->keepalive_timeup) {
                        motion_log(LOG_INFO, 0, "Closing netcam socket as Keep-Alive time is up "
                                                "(camera sent Close field). A reconnect should happen.");
                        netcam_disconnect(netcam);
                        netcam->keepalive_timeup = FALSE;
                    }

                    /* And the netcam_connect call below will open a new one */
                    if (netcam_connect(netcam, open_error) < 0) {
                        if (!open_error) { /* log first error */
                            motion_log(LOG_ERR, 0,
                                       "re-opening camera (non-streaming)");
                            open_error = 1;
                        }
                        /* need to have a dynamic delay here */
                        SLEEP(5,0);
                        continue;
                    }

                    if (open_error) {          /* log re-connection */
                        motion_log(LOG_ERR, 0, "camera re-connected");
                        open_error = 0;
                    }
                }
                /* Send our request and look at the response */
                if ((retval = netcam_read_first_header(netcam)) != 1) {
                    if (retval > 0) {
                        motion_log(LOG_ERR, 0, "Unrecognized image header (%d)", retval);
                    } else if (retval != -1) {
                        motion_log(LOG_ERR, 0, "Error in header (%d)", retval);
                    }
                    /* need to have a dynamic delay here */
                    continue;
                }
            } else {    /* Streaming */
                if (netcam_read_next_header(netcam) < 0) {
                    if (netcam_connect(netcam, open_error) < 0) {
                        if (!open_error) { /* log first error */
                            motion_log(LOG_ERR, 0, "re-opening camera (streaming)");
                            open_error = 1;
                        }
                        SLEEP(5,0);
                        continue;
                    }

                    if ((retval = netcam_read_first_header(netcam) != 2)) {
                        if (retval > 0) {
                            motion_log(LOG_ERR, 0, "Unrecognized image header (%d)", retval);
                        } else if (retval != -1) {
                            motion_log(LOG_ERR, 0, "Error in header (%d)", retval);
                        }
                        /* FIXME need some limit */
                        continue;
                    }
                }
                if (open_error) {          /* log re-connection */
                    motion_log(LOG_ERR, 0, "camera re-connected");
                    open_error = 0;
                }
            }
        }
        if (netcam->get_image(netcam) < 0) {
            motion_log(LOG_ERR, 0, "Error getting jpeg image");
            /* if FTP connection, attempt to re-connect to server */
            if (netcam->ftp) {
                close(netcam->ftp->control_file_desc);
                if (ftp_connect(netcam) < 0) 
                    motion_log(LOG_ERR, 0, "Trying to re-connect");
                
            }
            continue;
        }
        /*
         * FIXME
         * Need to check whether the image was received / decoded
         * satisfactorily
         */

        /*
         * If non-streaming, want to synchronize our thread with the
         * motion main-loop.
         */
        if (!netcam->caps.streaming) {
            pthread_mutex_lock(&netcam->mutex);

            /* before anything else, check for system shutdown */
            if (netcam->finish) {
                pthread_mutex_unlock(&netcam->mutex);
                break;
            }

            /*
             * If our current loop has finished before the next
             * request from the motion main-loop, we do a
             * conditional wait (wait for signal).  On the other
             * hand, if the motion main-loop has already signalled
             * us, we just continue.  In either event, we clear
             * the start_capture flag set by the main loop.
             */
            if (!netcam->start_capture)
                pthread_cond_wait(&netcam->cap_cond, &netcam->mutex);

            netcam->start_capture = 0;

            pthread_mutex_unlock(&netcam->mutex);
        }
    /* the loop continues forever, or until motion shutdown */
    }

    /* our thread is finished - decrement motion's thread count */
    pthread_mutex_lock(&global_lock);
    threads_running--;
    pthread_mutex_unlock(&global_lock);

    /* log out a termination message */
    motion_log(LOG_INFO, 0, "netcam camera handler: finish set, exiting");

    /* setting netcam->thread_id to zero shows netcam_cleanup we're done */
    netcam->thread_id = 0;

    /* signal netcam_cleanup that we're all done */
    pthread_mutex_lock(&netcam->mutex);
    pthread_cond_signal(&netcam->exiting);
    pthread_mutex_unlock(&netcam->mutex);

    /* Goodbye..... */
    pthread_exit(NULL);
}

static int netcam_setup_html(netcam_context_ptr netcam, struct url_t *url) {
    struct context *cnt = netcam->cnt;
    const char *ptr;                  /* working var */
    char *userpass;                   /* temp pointer to config value */
    char *encuserpass;                /* temp storage for encoded ver */
    char *request_pass = NULL;        /* temp storage for base64 conv */
    int ix;

    /* First the http context structure */
    netcam->response = (struct rbuf *) mymalloc(sizeof(struct rbuf));
    memset(netcam->response, 0, sizeof(struct rbuf));

    if (debug_level > CAMERA_INFO)
        motion_log(LOG_INFO, 0, "netcam_setup_html: Netcam has flags: HTTP1.0: %s HTTP1.1: %s Keep-Alive %s.", 
                                netcam->connect_http_10 ? "1":"0", netcam->connect_http_11 ? "1":"0", 
                                netcam->connect_keepalive ? "ON":"OFF");

    /*
     * The network camera may require a username and password.  If
     * so, the information can come from two different places in the
     * motion configuration file.  Either it can be present in
     * the netcam_userpass, or it can be present as a part of the URL
     * for the camera.  We assume the first of these has a higher
     * relevance.
     */
    if (cnt->conf.netcam_userpass)
        ptr = cnt->conf.netcam_userpass;
    else
        ptr = url->userpass;

    /* base64_encode needs up to 3 additional chars */
    if (ptr) {
        userpass = mymalloc(strlen(ptr) + 3);
        strcpy(userpass, ptr);
    } else {
        userpass = NULL;
    }

    /*
     * Now we want to create the actual string which will be used to
     * connect to the camera.  It may or may not contain a username /
     * password.  We first compose a basic connect message, then check
     * if a Keep-Alive header is to be included (or just 'close'), then
     * whether a username / password is required and, if so, just
     * concatenate it with the request.
     *
     */
    /* space for final \r\n plus string terminator */
    ix = 3;

    /* See if username / password is required */
    if (userpass) {         /* if either of the above are non-NULL */
        /* Allocate space for the base64-encoded string */
        encuserpass = mymalloc(BASE64_LENGTH(strlen(userpass)) + 1);
        /* Fill in the value */
        base64_encode(userpass, encuserpass, strlen(userpass));
        /* Now create the last part (authorization) of the request */
        request_pass = mymalloc(strlen(connect_auth_req) +
                                strlen(encuserpass) + 1);
        ix += sprintf(request_pass, connect_auth_req, encuserpass);
        /* free the working variables */
        free(encuserpass);
    }

    /*
     * We are now ready to set up the netcam's "connect request".  Most of
     * this comes from the (preset) string 'connect_req', but additional
     * characters are required if there is a proxy server, or if there is
     * a Keep-Alive connection rather than a close connection, or
     * a username / password for the camera.  The variable 'ix' currently
     * has the number of characters required for username/password (which
     * could be zero) and for the \r\n and string terminator.  We will also
     * always need space for the netcam path, and if a proxy is being used
     * we also need space for a preceding  'http://{hostname}' for the
     * netcam path.
     * Note: Keep-Alive (but not HTTP 1.1) is disabled if a proxy URL
     * is set, since HTTP 1.0 Keep-alive cannot be transferred through.
     */
    if (cnt->conf.netcam_proxy) {
        /*
         * Allocate space for a working string to contain the path.
         * The extra 4 is for "://" and string terminator.
         */
        ptr = mymalloc(strlen(url->service) + strlen(url->host)
                       + strlen(url->path) + 4);
        sprintf((char *)ptr, "http://%s%s", url->host, url->path);
        netcam->connect_keepalive=0; /* Disable Keepalive if proxy */

        if (debug_level > CAMERA_INFO)
            motion_log(LOG_DEBUG, 0, "Removed netcam_keepalive flag due to proxy set." 
                                     "Proxy is incompatible with Keep-Alive.");
    } else {
        /* if no proxy, set as netcam_url path */
        ptr = url->path;
        /*
         * after generating the connect message the string
         * will be freed, so we don't want netcam_url_free
         * to free it as well.
         */
        url->path = NULL;
    }

    ix += strlen(ptr);

       /* Now add the required number of characters for the close header
        * or Keep-Alive header.  We test the flag which can be unset if
    * there is a problem (rather than the flag in the conf structure
    * which is read-only.
    */
 
    if (netcam->connect_keepalive)
        ix += strlen(connect_req_keepalive);
    else
        ix += strlen(connect_req_close);
    
    /* Point to either the HTTP 1.0 or 1.1 request header set     */
    /* If the configuration is anything other than 1.1, use 1.0   */
    /* as a default. This avoids a chance of being left with none */
    if (netcam->connect_http_11==TRUE)
        connect_req = connect_req_http11;
    else
        connect_req = connect_req_http10;

    /*
     * Now that we know how much space we need, we can allocate space
     * for the connect-request string.
     */
    netcam->connect_request = mymalloc(strlen(connect_req) + ix +
                              strlen(netcam->connect_host));

    /* Now create the request string with an sprintf */
    sprintf(netcam->connect_request, connect_req, ptr,
            netcam->connect_host); 

    if (netcam->connect_keepalive)  
        strcat(netcam->connect_request, connect_req_keepalive);
    else 
        strcat(netcam->connect_request, connect_req_close);
    

    if (userpass) {
        strcat(netcam->connect_request, request_pass);
        free(request_pass);
        free(userpass);
    }

    /* put on the final CRLF onto the request */
    strcat(netcam->connect_request, "\r\n");
    free((void *)ptr);
    netcam_url_free(url);         /* Cleanup the url data */

    if (debug_level > CAMERA_INFO) {
        motion_log(-1, 0, "Camera connect string is ''%s''", netcam->connect_request);
        motion_log(-1, 0, "End of camera connect string.");
    }

    /*
     * Our basic initialisation has been completed.  Now we will attempt
     * to connect with the camera so that we can then get a "header"
     * in order to find out what kind of camera we are dealing with,
     * as well as what are the picture dimensions.  Note that for
     * this initial connection, any failure will cause an error
     * return from netcam_start (unlike later possible attempts at
     * re-connecting, if the network connection is later interrupted).
     */
    for (ix = 0; ix < MAX_HEADER_RETRIES; ix++) {
        /*
         * netcam_connect does an automatic netcam_close, so it's
         * safe to include it as part of this loop
         * (Not always true now Keep-Alive is implemented)
         */
        if (debug_level > CAMERA_INFO)
            motion_log(-1, 0, "netcam_setup_html: about to try to connect, time #%d", ix);

        if (netcam_connect(netcam, 0) != 0) {
            motion_log(LOG_ERR, 0,"Failed to open camera - check your config and that netcamera is online");

            /* Fatal error on startup */
            ix = MAX_HEADER_RETRIES;
            break;;
        }

        if (netcam_read_first_header(netcam) >= 0)
            break;

        motion_log(LOG_ERR, 0, "Error reading first header - re-trying");
    }

    if (ix == MAX_HEADER_RETRIES) {
        motion_log(LOG_ERR, 0, "Failed to read first camera header - giving up for now");
        return -1;
    }

    /*
     * If this is a streaming camera, we need to position just
     * past the boundary string and read the image header
     */
    if (netcam->caps.streaming) {
        if (netcam_read_next_header(netcam) < 0) {
            motion_log(LOG_ERR, 0,
                       "Failed to read first stream header - giving up for now");
            return -1;
        }
    }

    if (debug_level > CAMERA_INFO)
        motion_log(-1, 0, "netcam_setup_html: connected, going on to read image.", ix );

    netcam->get_image = netcam_read_html_jpeg;
    return 0;
}

static int netcam_setup_ftp(netcam_context_ptr netcam, struct url_t *url) {
    struct context *cnt = netcam->cnt;
    const char *ptr;

    if ((netcam->ftp = ftp_new_context()) == NULL)
        return -1;
    /*
     * We copy the strings out of the url structure into the ftp_context
     * structure.  By setting url->{string} to NULL we effectively "take
     * ownership" of the string away from the URL (i.e. it won't be freed
     * when we cleanup the url structure later).
     */
    netcam->ftp->path = url->path;
    url->path = NULL;

    if (cnt->conf.netcam_userpass != NULL)
        ptr = cnt->conf.netcam_userpass;
    else 
        ptr = url->userpass;  /* don't set this one NULL, gets freed */
    

    if (ptr != NULL) {
        char *cptr;

        if ((cptr = strchr(ptr, ':')) == NULL) {
            netcam->ftp->user = strdup(ptr);
        } else {
            netcam->ftp->user = mymalloc((cptr - ptr));
            memcpy(netcam->ftp->user,ptr,(cptr - ptr));
            netcam->ftp->passwd = strdup(cptr + 1);
        }
    }

    netcam_url_free(url);

    /*
     * The ftp context should be all ready to attempt a connection with
     * the server, so we try ....
     */
    if (ftp_connect(netcam) < 0) {
        ftp_free_context(netcam->ftp);
        return -1;
    }

    if (ftp_send_type(netcam->ftp, 'I') < 0) {
        motion_log(LOG_ERR, 0, "Error sending TYPE I to ftp server");
        return -1;
    }

    netcam->get_image = netcam_read_ftp_jpeg;
    return 0;
}

/**
 * netcam_recv
 *
 *      This routine receives the next block from the netcam.  It takes care
 *      of the potential timeouts and interrupt which may occur because of
 *      the settings from setsockopt.
 *
 * Parameters:
 *
 *      netcam          Pointer to a netcam context
 *      buffptr         Pointer to the receive buffer
 *      buffsize        Length of the buffer
 *
 * Returns:
 *      If successful, the length of the message received, otherwise the
 *      error reply from the system call.
 *
 */
ssize_t netcam_recv(netcam_context_ptr netcam, void *buffptr, size_t buffsize) {
    ssize_t retval;
    fd_set fd_r;
    struct timeval selecttime;

    FD_ZERO(&fd_r);
    FD_SET(netcam->sock, &fd_r);
    selecttime = netcam->timeout;

    retval = select(FD_SETSIZE, &fd_r, NULL, NULL, &selecttime);
    if (retval == 0)  /* 0 means timeout */
        return -1;
    
    return recv(netcam->sock, buffptr, buffsize, 0);
}

/**
 * netcam_cleanup
 *
 *      This routine releases any allocated data within the netcam context,
 *      then frees the context itself.  Extreme care must be taken to assure
 *      that the multi-threading nature of the program is correctly
 *      handled.
 *      This function is also called from motion_init if first time connection
 *      fails and we start retrying until we get a valid first frame from the
 *      camera. 
 *
 * Parameters:
 *
 *      netcam           Pointer to a netcam context
 *      init_retry_flag  1 when the function is called because we are retrying
 *                         making the initial connection with a netcam and we know
 *                         we do not need to kill a netcam handler thread
 *                       0 in any other case.
 *
 * Returns:              Nothing.
 *
 */
void netcam_cleanup(netcam_context_ptr netcam, int init_retry_flag)
{
    struct timespec waittime;

    if (!netcam)
        return;

    /*
     * This 'lock' is just a bit of "defensive" programming.  It should
     * only be necessary if the routine is being called from different
     * threads, but in our Motion design, it should only be called from
     * the motion main-loop.
     */
    pthread_mutex_lock(&netcam->mutex);

    if (netcam->cnt->netcam == NULL) 
        return;
    
    /*
     * We set the netcam_context pointer in the motion main-loop context
     * to be NULL, so that this routine won't be called a second time
     */
    netcam->cnt->netcam = NULL;

    /*
     * Next we set 'finish' in order to get the camera-handler thread
     * to stop.
     */
    netcam->finish = 1;

    /*
     * If the camera is non-streaming, the handler thread could be waiting
     * for a signal, so we send it one.  If it's actually waiting on the
     * condition, it won't actually start yet because we still have
     * netcam->mutex locked.
     */

    if (!netcam->caps.streaming) 
        pthread_cond_signal(&netcam->cap_cond);
    
    /*
     * Once the camera-handler gets to the end of it's loop (probably as
     * soon as we release netcam->mutex), because netcam->finish has been
     * set it will exit it's loop, do anything it needs to do with the
     * netcam context, and then send *us* as signal (netcam->exiting).
     * Note that when we start our wait on netcam->exiting, our lock on
     * netcam->mutex is automatically released, which will allow the
     * handler to complete it's loop, notice that 'finish' is set and exit.
     * This should always work, but again (defensive programming) we
     * use pthread_cond_timedwait and, if our timeout (8 seconds) expires
     * we just do the cleanup the handler would normally have done.  This
     * assures that (even if there is a bug in our code) motion will still
     * be able to exit.
     * If the init_retry_flag is not set the netcam_cleanup code was
     * called while retrying the initial connection to a netcam and then
     * there is no camera-handler started yet and thread_running must
     * not be decremented.
     */
    waittime.tv_sec = time(NULL) + 8;   /* Seems that 3 is too small */
    waittime.tv_nsec = 0;

    if (!init_retry_flag &&
        pthread_cond_timedwait(&netcam->exiting, &netcam->mutex, &waittime) != 0) {
        /*
         * Although this shouldn't happen, if it *does* happen we will
         * log it (just for the programmer's information)
         */
        motion_log(-1, 0, "No response from camera "
                          "handler - it must have already died");
        pthread_mutex_lock(&global_lock);
        threads_running--;
        pthread_mutex_unlock(&global_lock);
    }

    /* we don't need any lock anymore, so release it */
    pthread_mutex_unlock(&netcam->mutex);

    /* and cleanup the rest of the netcam_context structure */
    if (netcam->connect_host != NULL) 
        free(netcam->connect_host);
    
    if (netcam->connect_request != NULL) 
        free(netcam->connect_request);
    
    if (netcam->boundary != NULL) 
        free(netcam->boundary);
    
    if (netcam->latest != NULL) {
        if (netcam->latest->ptr != NULL) 
            free(netcam->latest->ptr);
        
        free(netcam->latest);
    }

    if (netcam->receiving != NULL) {
        if (netcam->receiving->ptr != NULL) 
            free(netcam->receiving->ptr);
        
        free(netcam->receiving);
    }

    if (netcam->jpegbuf != NULL) {
        if (netcam->jpegbuf->ptr != NULL) 
            free(netcam->jpegbuf->ptr);
        
        free(netcam->jpegbuf);
    }

    if (netcam->ftp != NULL) 
        ftp_free_context(netcam->ftp);
    else 
        netcam_disconnect(netcam);
    
    if (netcam->response != NULL) 
        free(netcam->response);
    
    pthread_mutex_destroy(&netcam->mutex);
    pthread_cond_destroy(&netcam->cap_cond);
    pthread_cond_destroy(&netcam->pic_ready);
    pthread_cond_destroy(&netcam->exiting);
    free(netcam);
}

/**
 * netcam_next
 *
 *      This routine is called when the main 'motion' thread wants a new
 *      frame of video.  It fetches the most recent frame available from
 *      the netcam, converts it to YUV420P, and returns it to motion.
 *
 * Parameters:
 *      cnt             Pointer to the context for this thread
 *      image           Pointer to a buffer for the returned image
 *
 * Returns:             Error code
 */
int netcam_next(struct context *cnt, unsigned char *image)
{
    netcam_context_ptr netcam;

    /*
     * Here we have some more "defensive programming".  This check should
     * never be true, but if it is just return with a "fatal error".
     */
    if ((!cnt) || (!cnt->netcam))
        return NETCAM_FATAL_ERROR;

    netcam = cnt->netcam;

    if (!netcam->latest->used) {
        if (debug_level) 
            motion_log(LOG_INFO, 0, "netcam_next called with no data in buffer");
        
        return NETCAM_NOTHING_NEW_ERROR;
    }

    /*
     * If we are controlling a non-streaming camera, we synchronize the
     * motion main-loop with the camera-handling thread through a signal,
     * together with a flag to say "start your next capture".
     */
    if (!netcam->caps.streaming) {
        pthread_mutex_lock(&netcam->mutex);
        netcam->start_capture = 1;
        pthread_cond_signal(&netcam->cap_cond);
        pthread_mutex_unlock(&netcam->mutex);
    }

    /*
     * If an error occurs in the JPEG decompression which follows this,
     * jpeglib will return to the code within this 'if'.  Basically, our
     * approach is to just return a NULL (failed) to the caller (an
     * error message has already been produced by the libjpeg routines)
     */
    if (setjmp(netcam->setjmp_buffer)) 
        return NETCAM_GENERAL_ERROR | NETCAM_JPEG_CONV_ERROR;
    
    /* If there was no error, process the latest image buffer */
    return netcam_proc_jpeg(netcam, image);
}

/**
 * netcam_start
 *
 *      This routine is called from the main motion thread.  It's job is
 *      to open up the requested camera device and do any required
 *      initialisation.  If the camera is a streaming type, then this
 *      routine must also start up the camera-handling thread to take
 *      care of it.
 *
 * Parameters:
 *
 *      cnt     Pointer to the motion context structure for this device
 *
 * Returns:     0 on success, -1 on any failure
 */

int netcam_start(struct context *cnt)
{
    netcam_context_ptr netcam;        /* local pointer to our context */
    pthread_attr_t handler_attribute; /* attributes of our handler thread */
    int retval;                       /* working var */
    struct url_t url;                 /* for parsing netcam URL */

    if (debug_level > CAMERA_INFO)
        motion_log(-1, 0, "entered netcam_start()");

    memset(&url, 0, sizeof(url));
    if (SETUP)
        motion_log(LOG_INFO, 0, "Camera thread starting...");

    /*
     * Create a new netcam_context for this camera
     * and clear all the entries.
     */
    cnt->netcam = (struct netcam_context *)
                   mymalloc(sizeof(struct netcam_context));
    memset(cnt->netcam, 0, sizeof(struct netcam_context));
    netcam = cnt->netcam;           /* Just for clarity in remaining code */
    netcam->cnt = cnt;              /* Fill in the "parent" info */

    /*
     * Fill in our new netcam context with all known initial
     * values.
     */

    /* Our image buffers */
    netcam->receiving = mymalloc(sizeof(netcam_buff));
    memset(netcam->receiving, 0, sizeof(netcam_buff));
    netcam->receiving->ptr = mymalloc(NETCAM_BUFFSIZE);

    netcam->jpegbuf = mymalloc(sizeof(netcam_buff));
    memset(netcam->jpegbuf, 0, sizeof(netcam_buff));
    netcam->jpegbuf->ptr = mymalloc(NETCAM_BUFFSIZE);

    netcam->latest = mymalloc(sizeof(netcam_buff));
    memset(netcam->latest, 0, sizeof(netcam_buff));
    netcam->latest->ptr = mymalloc(NETCAM_BUFFSIZE);
    netcam->timeout.tv_sec = READ_TIMEOUT;

    /* Thread control structures */
    pthread_mutex_init(&netcam->mutex, NULL);
    pthread_cond_init(&netcam->cap_cond, NULL);
    pthread_cond_init(&netcam->pic_ready, NULL);
    pthread_cond_init(&netcam->exiting, NULL);
    
    /* Initialise the average frame time to the user's value */
    netcam->av_frame_time = 1000000.0 / cnt->conf.frame_limit;

    /*
     * If a proxy has been specified, parse that URL.
     */
    if (cnt->conf.netcam_proxy) {
        netcam_url_parse(&url, cnt->conf.netcam_proxy);

        if (!url.host) {
            motion_log(LOG_ERR, 0, "Invalid netcam_proxy (%s)",
                       cnt->conf.netcam_proxy);
            netcam_url_free(&url);
            return -1;
        }

        if (url.userpass) {
            motion_log(LOG_ERR, 0, "Username/password not allowed on a proxy URL");
            netcam_url_free(&url);
            return -1;
        }

        /*
         * A 'proxy' means that our eventual 'connect' to our
         * camera must be sent to the proxy, and that our 'GET' must
         * include the full path to the camera host.
         */
        netcam->connect_host = url.host;
        url.host = NULL;
        netcam->connect_port = url.port;
        netcam_url_free(&url);  /* Finished with proxy */
    }

    /*
     * Parse the URL from the configuration data
     */
    netcam_url_parse(&url, cnt->conf.netcam_url);

    if (!url.host) {
        motion_log(LOG_ERR, 0, "Invalid netcam_url (%s)", cnt->conf.netcam_url);
        netcam_url_free(&url);
        return -1;
    }

    if (cnt->conf.netcam_proxy == NULL) {
        netcam->connect_host = url.host;
        url.host = NULL;
        netcam->connect_port = url.port;
    }

        /* Get HTTP Mode (1.0 default, 1.0 Keep-Alive, 1.1) flag from config
     * and report its stata for debug reasons.
     * The flags in the conf structure is read only and cannot be 
     * unset if the Keep-Alive needs to be switched off (ie. netcam does
     * not turn out to support it. That is handled by unsetting the flags
     * in the context structures (cnt->...) only.
     */

    if (!strcmp(cnt->conf.netcam_http,"keep_alive")) {
            netcam->connect_http_10   = TRUE;
            netcam->connect_http_11   = FALSE;
            netcam->connect_keepalive = TRUE;
    } else if (!strcmp(cnt->conf.netcam_http,"1.0") || !strcmp(cnt->conf.netcam_http,"1.0")) {
            netcam->connect_http_10   = TRUE;
            netcam->connect_http_11   = FALSE;
            netcam->connect_keepalive = FALSE;
    } else if (!strcmp(cnt->conf.netcam_http,"1.1")) {
            netcam->connect_http_10   = FALSE;
            netcam->connect_http_11   = TRUE;
            netcam->connect_keepalive = TRUE; /* HTTP 1.1 has keepalive by default */
    }
    if (debug_level > CAMERA_INFO)
        motion_log(LOG_INFO, 0, "netcam_start: Netcam_http parameter '%s' converts to flags: HTTP1.0:" 
                                "%s HTTP1.1: %s Keep-Alive %s.", cnt->conf.netcam_http, 
                                netcam->connect_http_10 ? "1":"0", netcam->connect_http_11 ? "1":"0", 
                                netcam->connect_keepalive ? "ON":"OFF");

    /* Initialise the netcam socket to -1 to trigger a connection by the keep-alive logic */
    netcam->sock = -1;

    if ((url.service) && (!strcmp(url.service, "http")) ){
        if (debug_level > CAMERA_INFO)
            motion_log(-1, 0, "netcam_start: now calling netcam_setup_html()");
        retval = netcam_setup_html(netcam, &url);
    } else if ((url.service) && (!strcmp(url.service, "ftp")) ){
        if (debug_level > CAMERA_INFO)
            motion_log(-1, 0, "netcam_start: now calling netcam_setup_ftp");
        retval = netcam_setup_ftp(netcam, &url);
    } else if ((url.service) && (!strcmp(url.service, "file")) ){
        if (debug_level > CAMERA_INFO)
            motion_log(-1, 0, "netcam_start: now calling netcam_setup_file()");
        retval = netcam_setup_file(netcam, &url);
    } else {
        motion_log(LOG_ERR, 0, "Invalid netcam service  '%s' - "
                               "must be http or ftp", url.service);
        netcam_url_free(&url);
        return -1;
    }

    if (retval < 0)
        return -1;

    /*
     * We expect that, at this point, we should be positioned to read
     * the first image available from the camera (directly after the
     * applicable header).  We want to decode the image in order to get
     * the dimensions (width and height).  If successful, we will use
     * these to set the required image buffer(s) in our netcam_struct.
     */
    if ((retval = netcam->get_image(netcam)) != 0) {
        motion_log(LOG_ERR, 0, "Failed trying to read first image - retval:%d", retval );
        return -1;
    }

    /*
     * If an error occurs in the JPEG decompression which follows this,
     * jpeglib will return to the code within this 'if'.  If such an error
     * occurs during startup, we will just abandon this attempt.
     */
    if (setjmp(netcam->setjmp_buffer)) {
        motion_log(LOG_ERR, 0, "libjpeg decompression failure "
                               "on first frame - giving up!");
        return -1;
    }

    netcam->netcam_tolerant_check = cnt->conf.netcam_tolerant_check;
    netcam->JFIF_marker = 0;
    netcam_get_dimensions(netcam);

    /* Motion currently requires that image height and width is a
     * multiple of 16. So we check for this.
     */
    if (netcam->width % 16) {
        motion_log(LOG_ERR, 0, "netcam image width (%d) is not modulo 16",
                   netcam->width);
        return -1;
    }

    if (netcam->height % 16) {
        motion_log(LOG_ERR, 0, "netcam image height (%d) is not modulo 16",
                   netcam->height);
        return -1;
    }

    /* Fill in camera details into context structure */
    cnt->imgs.width = netcam->width;
    cnt->imgs.height = netcam->height;
    cnt->imgs.size = (netcam->width * netcam->height * 3) / 2;
    cnt->imgs.motionsize = netcam->width * netcam->height;
    cnt->imgs.type = VIDEO_PALETTE_YUV420P;

    /*
     * Everything is now ready - start up the
     * "handler thread".
     */
    pthread_attr_init(&handler_attribute);
    pthread_attr_setdetachstate(&handler_attribute, PTHREAD_CREATE_DETACHED);
    pthread_mutex_lock(&global_lock);
    netcam->threadnr = ++threads_running;
    pthread_mutex_unlock(&global_lock);

    if ((retval = pthread_create(&netcam->thread_id, &handler_attribute,
                                 &netcam_handler_loop, netcam)) < 0) {
        motion_log(LOG_ERR, 1, "Starting camera handler thread [%d]", netcam->threadnr);
        return -1;
    }

    return 0;
}