url.c

Go to the documentation of this file.

/************************************************************************
 * Copyright (C) 2006-2009 Philipp Marek.
 *
 * This program is free software;  you can redistribute it and/or modify
 * it under the terms of the GNU General Public License version 3 as
 * published by the Free Software Foundation.
 ************************************************************************/

#include <stdlib.h>
#include <fcntl.h>
#include <unistd.h>
#include <ctype.h>
#include <sys/select.h>


#include "url.h"
#include "waa.h"
#include "cache.h"
#include "helper.h"
#include "est_ops.h"
#include "checksum.h"
#include "racallback.h"


char **url__parm_list=NULL;
int url__parm_list_len=0,
        url__parm_list_used=0;

int url__must_write_defs=0;


int url__find_by_name(const char *name, struct url_t **storage)
{
    int status;
    int i;

    /* Normalize */
    if (name && !*name) name=NULL;

    status=EADDRNOTAVAIL;
    for(i=0; i<urllist_count; i++)
    {
        /* Check for NULL name, and allow NULL === "", too. */
        if (!urllist[i]->name ?
                (!name || !*name) :
                (strcmp(urllist[i]->name, name) == 0) )
        {
            if (storage) *storage=urllist[i];
            status=0;
            break;
        }
    }

    if (status)
        DEBUGP("url with name %s not found!", name);

    return status;
}


int url__find_by_url_in_list(char *url, 
        struct url_t **list, int count,
        struct url_t **storage)
{
    int status;
    int i;


    status=EADDRNOTAVAIL;
    for(i=0; i<count; i++)
    {
        if (strcmp(list[i]->url, url) == 0)
        {
            if (storage) *storage=list[i];
            status=0;
            break;
        }
    }

    if (status)
        DEBUGP("url with url %s not found!", url);

    return status;
}


int url__find_by_url(char *url, struct url_t **storage)
{
    return url__find_by_url_in_list(url, urllist, urllist_count, storage);
}

int url__find_by_intnum(int intnum, struct url_t **storage)
{
    int status;
    int i;

    /* We must not return ENOENT. Because this is called below input_tree,
     * returning ENOENT could be interpreted as "no dirlist found" - which
     * has to be allowed in some cases. */
    status=EADDRNOTAVAIL;
    for(i=0; i<urllist_count; i++)
    {
        if (urllist[i]->internal_number == intnum)
        {
            if (storage) *storage=urllist[i];
            status=0;
            break;
        }
    }

    if (status)
        DEBUGP("url with intnum %d not found!", intnum);
    else
        DEBUGP("url with intnum %d is %s", intnum, (*storage)->url);

    return status;
}


#define HAVE_NAME (1)
#define HAVE_PRIO (2)
#define HAVE_URL (4)
#define HAVE_TARGET (8)
#define HAVE_READONLY (16)

int url__parse(char *input, struct url_t *storage, int *def_parms)
{
    int status;
    char *cp, *value, *end, *cur;
    struct url_t eurl;
    int nlen, vlen, have_seen;


    status=0;

    have_seen=0;
    memset(&eurl, 0, sizeof(eurl));
    /* The internal number is initially unknown; we must not set one here,
     * as a later read URL may have the number we've chosen.
     * We have to give internal numbers in a second pass. */
    eurl.internal_number=INVALID_INTERNAL_NUMBER;
    eurl.current_rev=0;
    eurl.target_rev=SVN_INVALID_REVNUM;
    eurl.current_target_override=0;
    eurl.head_rev=SVN_INVALID_REVNUM;
    cur=input;

    DEBUGP("input: %s", input);
    while (! (have_seen & HAVE_URL))
    {
        /* Find first ':'.
         * Variables are as follows:
         *          nlen=5    vlen=3
         *             [---][-]
         *    name:xxx,prio:123,svn://xxxxxx 
         *             ^    ^  ^
         *             |    |  end
         *             |    value
         *             cur
         *    */
        end=cur;
        value=NULL;
        while (*end)
        {
            /* There may be multiple ':' in a single value, eg. in the URL:
             *   http://user:pass@host:port/.
             * Set value to the first occurrence. */
            if (*end == ':' && !value)
                value = end+1;

            if (*end == ',') break;

            end++;
        }   

        /* Don't count the ':'. */
        nlen = (value ? value-1 : end) - cur;
        vlen =  value ? end - value : 0;

        DEBUGP("cur=%s value=%s end=%s vlen=%d nlen=%d",
                cur, value, end, vlen, nlen);

        if (strncmp("name", cur, nlen) == 0 ||
                strncmp("N", cur, nlen) == 0)
        {
            STOPIF_CODE_ERR( have_seen & HAVE_NAME, EINVAL, 
                    "!Found two names in URL '%s'; only one may be given.",
                    input);
            if (!value) goto need_value;

            /* "" == NULL == empty name? */
            if (vlen==0)
                DEBUGP("NULL name");
            else if (storage) 
            {
                /* If we need that name again, make a copy.
                 * We cannot simply use strdup(), because this is not 
                 * \0-terminated. */
                STOPIF( hlp__strnalloc(vlen, &eurl.name, value), NULL);

                DEBUGP("got a name '%s' (%d bytes), going on with '%s'",
                        eurl.name, vlen, end);
                have_seen |= HAVE_NAME;
            }
        }
        else if (strncmp("target", cur, nlen) == 0 ||
                strncmp("T", cur, nlen) == 0)
        {
            STOPIF_CODE_ERR( have_seen & HAVE_TARGET, EINVAL, 
                    "!Already got a target revision in URL '%s'.",
                    input);
            if (!value) goto need_value;
            STOPIF( hlp__parse_rev( value, &cp, & eurl.target_rev), NULL);
            STOPIF_CODE_ERR( cp == value || cp != end, EINVAL,
                    "The given target revision in '%s' is invalid.",
                    input);
            DEBUGP("got target %s", hlp__rev_to_string(eurl.target_rev));
            have_seen |= HAVE_TARGET;
        }
        else if (strncmp("prio", cur, nlen) == 0 ||
                strncmp("P", cur, nlen) == 0)
        {
            STOPIF_CODE_ERR( have_seen & HAVE_PRIO, EINVAL, 
                    "!Found two priorities in URL '%s'; only one allowed.",
                    input);
            if (!value) goto need_value;
            eurl.priority=strtol(value, &cp, 0);
            STOPIF_CODE_ERR( cp == value || cp != end, EINVAL,
                    "!The given url \"%s\" is invalid; cannot parse the priority.",
                    input);
            DEBUGP("got priority %d", eurl.priority);
            have_seen |= HAVE_PRIO;
        }
        else if (strncmp("readonly", cur, nlen) == 0 ||
                strncmp("ro", cur, nlen) == 0)
        {
            STOPIF_CODE_ERR( have_seen & HAVE_READONLY, EINVAL, 
                    "!Found two readonly flags in URL \"%s\"; only one allowed.",
                    input);
            if (value) 
            {
                eurl.is_readonly=strtol(value, &cp, 0);
                STOPIF_CODE_ERR( cp == value || cp != end, EINVAL,
                        "!Cannot parse the readonly flag in \"%s\".", input);
            }
            else
                eurl.is_readonly=1;

            have_seen |= HAVE_READONLY;
        }
        else
        {
            /* For URLs no abbreviation is allowed, so we check the length extra.  
             * An exception is "svn+", which can have arbitrary tunnels after it; 
             * see ~/.subversion/config for details.
             *
             * We cannot use strcmp(), as the URL has no '\0' at the given 
             * position.
             * We test for the ":", too, so that "http\0" isn't valid.
             * */
            nlen++;
            if (strncmp("svn+", cur, 4) == 0)
            {
                    /* At least a single character after the '+'; but nlen is already 
                     * incremented.  */
                    STOPIF_CODE_ERR(nlen <= 5, EINVAL,
                            "!No tunnel given after \"svn+\" in \"%s\".", cur);
            }
            else if (
                    (nlen == 4 && strncmp("svn:", cur, nlen) == 0) ||
                    (nlen == 5 &&
                     (strncmp("http:", cur, nlen) == 0 ||
                        strncmp("file:", cur, nlen) == 0) ) ||
                    (nlen == 6 && strncmp("https:", cur, nlen) == 0))
                DEBUGP("known protocol found");
            else
                STOPIF_CODE_ERR(1, EINVAL, 
                        "!The protocol given in \"%s\" is unknown!", cur);

            /* The shortest URL is name="http:" and value="//a", or something 
             * like that ;-) */
            if (!value || vlen<3 || strncmp(value, "//", 2)!=0)
                STOPIF_CODE_ERR(1, EINVAL, "!The URL in \"%s\" is invalid.", cur);

            /* Must be an URL */
            /* We remove any / at the end of the URL (which may have resulted from
             * bash-completion), otherwise we'll get an error:
             *   subversion/libsvn_subr/path.c:114: 
             *     svn_path_join: Assertion `is_canonical (base, blen)' failed.
             * That's not necessary. */
            /* Please note that URLs are defined to use a '/', not 
             * (platform-dependent) PATH_SEPARATOR! */
            while (vlen>3 && value[vlen-1] == '/')
                value[--vlen] = 0;

            /* We need the ':' and the "name" (protocol) too, but don't count the 
             * '\0' at the end.
             * The ':' is already counted by the nlen++ above. */
            eurl.urllen=nlen + 0 + 1 + vlen - 1;
            STOPIF( hlp__strdup( &eurl.url, cur), NULL);

            have_seen |= HAVE_URL;
        }

        while (*end == ',') end++;
        if (!*end) break;
        cur=end;
    }


    if (def_parms) 
        *def_parms=have_seen;
    else
        STOPIF_CODE_ERR( !(have_seen & HAVE_URL), EINVAL,
                "!No URL found in %s", input);

    if (storage) *storage=eurl;

    /* Maybe not entirely correct here, because URLs might not be stored in 
     * the URL list. */
    url__must_write_defs=1;

ex:
    return status;

need_value:
    STOPIF(EINVAL,
            "!Specification '%s' is not a valid URL - ':' missing.", input);
    goto ex;
}


int url__insert_or_replace(char *eurl, 
        struct url_t **storage, 
        int *existed)
{
    int status;
    int seen;
    struct url_t target, *dupl, *dest, *by_name;


    status=0;
    STOPIF( url__parse(eurl, &target, &seen), NULL);


    by_name=NULL;
    /* No error checks necessary, pointer stays NULL if not found. */
    if (seen & HAVE_NAME)
        url__find_by_name(target.name, &by_name);

    dupl=NULL;
    /* If an URL is given, this is what is used for replacement. */
    if (seen & HAVE_URL)
        url__find_by_url(target.url, &dupl);
    else
    {
        /* If no URL, then try to find the name. */ 
        dupl=by_name;
    }


    if (!dupl)
    {
        if (!(seen & HAVE_URL))
        {
            STOPIF( EINVAL,
                    !(seen & HAVE_NAME) ? 
                    "!No URL was given in \"%s\"." :
                    "!Cannot find the name given in \"%s\", so cannot modify an URL.",
                    eurl);
        }
        if (seen & HAVE_NAME)
        {
            /* The names must be unique. */
            STOPIF_CODE_ERR( by_name, EADDRINUSE, 
                    "!There's already an url named \"%s\"", target.name);

            /* If we didn't find it, it's ok. */
            status=0;
        }

        /* Copy to destination */
        dest=urllist[urllist_count];
        *dest = target;
        urllist_count++;
    }
    else
    {
        /* \todo Currently it is not defined whether the strings are 
         * heap-allocated or not, so it's not easy to free them.
         *
         * This should not happen so often, so we ignore that. */
        /* When it gets overwritten, we take care to not simply copy - 
         * we just change the given values. */
        if (seen & HAVE_TARGET)
            dupl->target_rev = target.target_rev;
        if (seen & HAVE_PRIO)
            dupl->priority = target.priority;
        if (seen & HAVE_READONLY)
            dupl->is_readonly = target.is_readonly;
        if (seen & HAVE_NAME)
            dupl->name = target.name;
        /* The URL is the same, so the length is the same, and the internal 
         * number is generated or already present. */
        dest=dupl;
    }

    if (existed)
        *existed = dupl ? EEXIST : 0;

    if (storage) 
        *storage=dest;

ex:
    return status;
}


int find_next_zero_bit(fd_set *fd, int from)
{
    while (FD_ISSET(from, fd)) from++;
    return from;
}


int url___set_internal_nums(void)
{
    int status;
    int i, j, bit;
    fd_set bitmap;


    /* We need to store only so many bits as we have URLs. 
     * If URLs have higher inums there will be free lower inums. */

    STOPIF_CODE_ERR( sizeof(bitmap)*8 < urllist_count, EMFILE,
            "Your fd_set is too small for the number of urls.\n"
            "Please contact dev@fsvs.tigris.org for help.");

    status=0;
    FD_ZERO(&bitmap);
    /* Step 1: look which numbers are used. */
    for(i=0; i<urllist_count; i++)
    {
        if (urllist[i]->internal_number > urllist_count)
        {
            /* Note: For such values we still have to check whether two 
             * internal numbers collide. */
            for(j=i+1; j<urllist_count; j++)
                STOPIF_CODE_ERR( 
                        urllist[i]->internal_number == urllist[j]->internal_number,
                        EINVAL, "The URLs %s and %s have identical internal numbers!",
                        urllist[i]->url, urllist[j]->url);
        }
        else if (urllist[i]->internal_number != INVALID_INTERNAL_NUMBER)
        {
            STOPIF_CODE_ERR( FD_ISSET(urllist[i]->internal_number, &bitmap),
                    EINVAL, 
                    "The URL %s has a duplicate internal number!",
                    urllist[i]->url);

            FD_SET(urllist[i]->internal_number, &bitmap);
        }
    }

    /* Step 2: Fill invalid. Start with internal number 1. */
    bit=1;
    for(i=0; i<urllist_count; i++)
    {
        DEBUGP("inum for %s is %d",
                urllist[i]->url, urllist[i]->internal_number);
        if (urllist[i]->internal_number == INVALID_INTERNAL_NUMBER)
        {
            /* Find a free bit */
            bit= find_next_zero_bit(&bitmap, bit);
            DEBUGP("found a free bit for %s: %d",
                    urllist[i]->url, bit);

            urllist[i]->internal_number=bit;

            /* No need to set that bit here, just skip to the next. */
            bit++;
        }
    }

ex:
    return status;
}


int url__allocate(int reserve_space)
{
    int status;
    struct url_t *url_mem;
    int i;


    status=0;
    /* We put a terminating NULL pointer at the end. */
    STOPIF( hlp__realloc( &urllist, 
            sizeof(*urllist) * (urllist_count+1+reserve_space)), NULL);
    STOPIF( hlp__calloc( &url_mem, sizeof(*url_mem), reserve_space), NULL);

    /* store url pointers */
    for(i=0; i<reserve_space; i++)
    {
        urllist[urllist_count+i]=url_mem+i;
    }
    urllist[urllist_count+i]=NULL;

ex:
    return status;
}


int url__indir_sorter(const void *a, const void *b)
{
    struct url_t *u1=*(struct url_t **)a,
                             *u2=*(struct url_t **)b;

    return url__sorter(u1, u2);
}


int url__load_list(char *dir, int reserve_space)
{
    int status, fh, l, i;
    struct stat64 st;
    char *urllist_mem;
    int inum, cnt, new_count;
    svn_revnum_t rev;
    int intnum;
    struct url_t *target;
    FILE *rev_in;
    char *buffer;


    fh=-1;
    urllist_mem=NULL;

    /* ENOENT must be possible without an error message. 
     * The space must always be allocated. */
    status=waa__open_byext(dir, WAA__URLLIST_EXT, WAA__READ, &fh);
    if (status==ENOENT)
    {
        STOPIF( url__allocate(reserve_space), NULL);
        status=ENOENT;
        goto ex;
    }

    STOPIF_CODE_ERR(status, status, "Cannot read URL list");

    STOPIF_CODE_ERR( fstat64(fh, &st) == -1, errno,
            "fstat() of url-list");

    /* add 1 byte to ensure \0 */
    STOPIF( hlp__alloc( &urllist_mem, st.st_size+1), NULL);

    status=read(fh, urllist_mem, st.st_size);
    STOPIF_CODE_ERR( status != st.st_size, errno, 
            "error reading url-list");

    urllist_mem[st.st_size]=0;

    /* count urls */
    new_count=0;
    for(l=0; l<st.st_size; )
    {
        while (isspace(urllist_mem[l])) l++;

        if (urllist_mem[l]) new_count++;
        l += strlen(urllist_mem+l)+1;
    }

    DEBUGP("found %d urls", new_count);
    STOPIF( url__allocate(reserve_space+new_count), NULL);

    /* store urls */
    for(l=i=0; i<new_count; )
    {
        /* Skip over \n and similar, mostly for the debug output. sscanf() 
         * would ignore that anyway. */
        while (isspace(urllist_mem[l])) l++;

        DEBUGP("url %d of %d: %s",i, new_count, urllist_mem+l);
        if (urllist_mem[l]) 
        {
            STOPIF_CODE_ERR( 
                    sscanf(urllist_mem+l, "%d %ld %n", 
                    &inum, &rev, &cnt) != 2, 
                    EINVAL,
                    "Cannot parse urllist line '%s'", urllist_mem+l);

            STOPIF( url__insert_or_replace(urllist_mem+l+cnt, &target, NULL), NULL);
            target->internal_number=inum;
            target->current_rev=rev;

            i++;
            l += strlen(urllist_mem+l);
        }

        /* Skip over \0 */
        l++;
    }

    STOPIF_CODE_ERR( close(fh) == -1, errno, "closing the url-list");
    fh=-1;


    /* Read the current revisions from the WAA definition.
     * If we got data before, we need this here too. */
    /* Exception for 1.1.18: Upgrade from 1.1.17. A non-existing file is 
     * allowed, but will convert the data next time. */
    status=waa__open_byext(dir, WAA__URL_REVS, WAA__READ, &fh);
    if (status==ENOENT)
    {
        DEBUGP("No file; upgrading?");
        status=0;
    }
    else
    {
        /* Read the associated revisions. */
        rev_in=fdopen(fh, "r");
        while (1)
        {
            status=hlp__string_from_filep(rev_in, &buffer, NULL, 0);
            if (status == EOF) 
            {
                status=0;
                break;
            }
            STOPIF( status, "Failed to read copyfrom source");

            STOPIF_CODE_ERR( sscanf(buffer, "%d %lu 0 0 0 0\n", 
                        &intnum, &rev) != 2, EINVAL,
                    "Error parsing line \"%s\" from %s", buffer, WAA__URL_REVS);

            STOPIF( url__find_by_intnum(intnum, &target), 
                    "URL number %d read from %s not found",
                    intnum, WAA__URL_REVS);

            target->current_rev=rev;
        }
        STOPIF_CODE_ERR( fclose(rev_in)==-1, errno, 
            "error closing %s", WAA__URL_REVS);
        fh=-1;
    }


    /* Sort list by priority */
    qsort(urllist, urllist_count, sizeof(*urllist), url__indir_sorter);

    /* No writing would be necessary if nothing gets changed. */
    url__must_write_defs=0;

ex:
    /* urllist_mem must not be freed - our url-strings still live there! */
    if (fh!=-1) 
    {
        l=close(fh);
        STOPIF_CODE_ERR(l == -1 && !status, errno, "closing the url-list");
    }

    return status;
}


int url__load_nonempty_list(char *dir, int reserve_space)
{
    int status, load_st;

    status=0;
    if (!dir) dir=wc_path;

    load_st=url__load_list(dir, reserve_space);
    STOPIF_CODE_ERR( load_st==ENOENT || 
            urllist_count==0, ENOENT,
            "!No URLs have been defined for %s.", dir);

ex:
    return status;
}

    
int url__output_list(void)
{
    int status, i, fh, l, fh_revs;
    char buffer[1024];
    struct url_t *url;


    fh=-1;
    fh_revs=-1;

    STOPIF( url___set_internal_nums(), 
            "Setting the internal numbers failed.");

    if (url__must_write_defs)
        STOPIF( waa__open_byext(NULL, WAA__URLLIST_EXT, WAA__WRITE, &fh), NULL);

    STOPIF( waa__open_byext(NULL, WAA__URL_REVS, WAA__WRITE, &fh_revs), NULL);
    for(i=0; i<urllist_count; i++)
    {
        url=urllist[i];

        if (url->target_rev == 0 && url->current_rev == 0)
            continue;

        if (fh != -1)
        {
            l=snprintf(buffer, sizeof(buffer),
                    "%d %d T:%ld,N:%s,P:%d,ro:%u,%s",
                    url->internal_number,
                    0, /* Previously the the current revision. */
                    url->target_rev,
                    url->name ? url->name : "",
                    url->priority,
                    url->is_readonly,
                    url->url);

            STOPIF_CODE_ERR( l > sizeof(buffer)-4, E2BIG, 
                    "You've got too long URLs; I'd need %d bytes. Sorry.", l);

            /* include the \0 */
            l++;
            STOPIF_CODE_ERR( write(fh, buffer, l) != l, errno,
                    "Error writing the URL list");
            STOPIF_CODE_ERR( write(fh, "\n", 1) != 1, errno,
                    "Error writing the URL list delimiter");
            DEBUGP("writing line %s", buffer);
        }


        /* A few extra fields, to store some information later. */
        l=snprintf(buffer, sizeof(buffer),
                "%d %ld 0 0 0 0\n",
                url->internal_number,
                url->current_rev);
        /* This can never happen, apart from being caused by radiation. */
        BUG_ON( l > sizeof(buffer)-4);
        STOPIF_CODE_ERR( write(fh_revs, buffer, l) != l, errno,
                "Error writing the URL list");
    }

    url__must_write_defs=0;

ex:
    if (fh != -1)
    {
        i=waa__close(fh, status);
        fh=-1;
        STOPIF(i, "Error closing the URL list");
    }

    if (fh_revs != -1)
    {
        i=waa__close(fh_revs, status);
        fh_revs=-1;
        STOPIF(i, "Error closing the revisions list");
    }

    return status;
}


int url__open_session(svn_ra_session_t **session, char **missing_dirs)
{
    int status;
    svn_error_t *status_svn;
    apr_hash_t *cfg;
    char *buffer, *cp;
    int exists;
    svn_revnum_t head;


    status=0;
    if (!current_url->pool)
    {
        STOPIF( apr_pool_create_ex(& current_url->pool, global_pool, 
                    NULL, NULL), 
                "no pool");
    }

    STOPIF( hlp__get_svn_config(&cfg), NULL);


    if (current_url->session) goto ex;


    /* We wouldn't need to allocate this memory if the URL was ok; but we 
     * don't know that here, and it doesn't hurt that much. */
    STOPIF( hlp__strnalloc(current_url->urllen, 
                &buffer, current_url->url), NULL);
    cp=buffer+current_url->urllen;
    BUG_ON(*cp);

    STOPIF_SVNERR_TEXT( svn_ra_open,
                (& current_url->session, buffer,
                 &cb__cb_table, NULL,  /* cbtable, cbbaton, */
                 cfg,   /* config hash */
                 current_url->pool),
                "svn_ra_open(\"%s\")", current_url->url);
    head=SVN_INVALID_REVNUM;
  STOPIF( url__canonical_rev( current_url, &head), NULL);

    DEBUGP("Trying url %s@%ld", buffer, head);
    while (1)
    {
        /* Is the caller interested in this check? If not, then just return. */
        if (!missing_dirs) break;


        /* Test whether the base directory exists; we need some lightweight 
         * mechanism to detect that.
         * Sadly we don't get a result when we open the session. */
        /* That's not entirely correct.
         * In the time between this test and the commit running someone could 
         * create or remove the base path; then we would have tested against 
         * the wrong revision, and might fail nonetheless. */
        STOPIF( cb__does_path_exist(current_url->session, "", head, 
                    &exists, current_url->pool), NULL);
        if (exists) break;


        /* Doesn't exist. Try with the last part removed. */
        /* We don't do URLs with less than a few characters. */
        while (cp > buffer+4 && *cp != '/') cp--;

        /* If we're before the hostname, signified by a "//", we abort. */
        STOPIF_CODE_EPIPE(cp[-1] == '/', EINVAL,
                "!Unsuccessfull svn_ra_stat() on every try for URL \"%s\".",
                current_url->url);

        /* We're at a slash, and try with a shortened URL. */
        *cp=0;

        DEBUGP("Reparent to %s", buffer);
        STOPIF_SVNERR( svn_ra_reparent,
                (current_url->session, buffer, current_url->pool));
    }


    /* See whether the original URL is valid. */
    if (missing_dirs) 
    {
        if (buffer + current_url->urllen == cp)
        {
            *missing_dirs=NULL;
            IF_FREE(buffer);
        }
        else
        {
            /* Return just the missing parts:
             *
             *   url:    http://aaa/11/22/33/44
             *   buffer: http://aaa/11/22
             *   return: 33/44
             *
             * We return the characters that were cut off, without the '/'. */
            strcpy(buffer, current_url->url + 1 + (cp - buffer));

            DEBUGP("returning missing=%s", buffer);
            *missing_dirs=buffer;
        }
    }
    else IF_FREE(buffer);


    if (session) 
        *session = current_url->session;

ex:
    return status;
}


int url__close_session(struct url_t *cur)
{
    /* There's no svn_ra_close() or suchlike.
     * I hope it gets closed by freeing it's pool. */
    if (cur->pool)
    {
        DEBUGP("closing session and pool for %s", cur->url);

        BUG_ON(cur->pool == NULL && cur->session != NULL);
        apr_pool_destroy(cur->pool);
        cur->session=NULL;
        cur->pool=NULL;
    }

    return 0;
}


int url__close_sessions(void)
{
  int status;
    int i;

    status=0;

    IF_FREE(url__parm_list);
    url__parm_list_len=url__parm_list_used=0;

    for(i=0; i<urllist_count; i++)
        STOPIF( url__close_session( urllist[i] ), NULL);

ex:
    return status;
}


int url__current_has_precedence(struct url_t *to_compare)
{
    return to_compare==NULL ||
        (current_url->priority <= to_compare->priority);
}


int url___dump(char *format)
{
    int status;
    int i;
    char *cp;
    FILE *output=stdout;
    struct url_t *url;


    if (!format) 
        format= opt__is_verbose()>0 ? 
            "%u\\n\tname: \"%n\"; priority: %p; current revision: %r; "
            "target: %t; readonly:%R\\n" :
            "name:%n,prio:%p,target:%t,ro:%R,%u\\n";

    status=0;
    for(i=0; i < urllist_count; i++)
    {
        url = urllist[i];
        cp=format;

        while (*cp)
        {
            switch (cp[0])
            {
                case '\\':
                    switch (cp[1])
                    {
                        case '\\':
                            STOPIF_CODE_EPIPE( fputc('\\', output), NULL);
                            break;
                        case 'n':
                            STOPIF_CODE_EPIPE( fputc('\n', output), NULL);
                            break;
                        case 'r':
                            STOPIF_CODE_EPIPE( fputc('\r', output), NULL);
                            break;
                        case 't':
                            STOPIF_CODE_EPIPE( fputc('\t', output), NULL);
                            break;
                        case 'f':
                            STOPIF_CODE_EPIPE( fputc('\f', output), NULL);
                            break;
                        case 'x':
                            status= cp[2] && cp[3] ? cs__two_ch2bin(cp+2) : -1;
                            STOPIF_CODE_ERR(status <0, EINVAL, 
                                    "A \"\\x\" sequence must have 2 hex digits.");
                            STOPIF_CODE_EPIPE( fputc(status, output), NULL);
                            /* There's a +2 below. */
                            cp+=2;
                            break;
                        default:
                            STOPIF_CODE_ERR(1, EINVAL, 
                                    "Unknown escape sequence '\\%c' in format.",
                                    cp[1]);
                            break;
                    }
                    cp+=2;
                    break;

                case '%':
                    switch (cp[1])
                    {
                        /* Allow internal number, too? */
                        case 'n':
                            STOPIF_CODE_EPIPE( fputs(url->name ?: "", output), NULL);
                            break;
                        case 't':
                            STOPIF_CODE_EPIPE( fputs(
                                        hlp__rev_to_string(url->target_rev), 
                                        output), NULL);
                            break;
                        case 'r':
                            STOPIF_CODE_EPIPE( fputs(
                                        hlp__rev_to_string(url->current_rev), 
                                        output), NULL);
                            break;
                        case 'R':
                            STOPIF_CODE_EPIPE( fprintf(output, "%u", 
                                        url->is_readonly), NULL);
                            break;
                        case 'I':
                            STOPIF_CODE_EPIPE( fprintf(output, "%u", 
                                        url->internal_number), NULL);
                            break;
                        case 'p':
                            STOPIF_CODE_EPIPE( fprintf(output, "%u", 
                                        url->priority), NULL);
                            break;
                        case 'u':
                            STOPIF_CODE_EPIPE( fputs(url->url, output), NULL);
                            break;
                        case '%':
                            STOPIF_CODE_EPIPE( fputc('%', output), NULL);
                            break;
                        default:
                            STOPIF_CODE_ERR(1, EINVAL, 
                                    "Invalid placeholder '%%%c' in format.",
                                    cp[1]);
                            break;
                    }
                    cp+=2;
                    break;

                default:
                    STOPIF_CODE_EPIPE( fputc(*cp, output), NULL);
                    cp++;
            }
        }
    }

    status=0;

ex:
    return status;
}


int url__other_full_url(struct estat *sts, struct url_t *url, char **output)
{   
    static const char none[]="(none)";
    static struct cache_t *cache=NULL;
    int status, len;
    char *data, *path;

    status=0;

    if (url)
    {
        STOPIF( ops__build_path( &path, sts), NULL);
        len=url->urllen + 1 + sts->path_len+1;
        STOPIF( cch__new_cache(&cache, 4), NULL);

        STOPIF( cch__add(cache, 0, NULL, len, &data), NULL);
    strcpy( data, url->url);

        if (path[0]=='.' && path[1]==0) 
        {
            /* Nothing to be done; just the base URL. */
        }
        else
        {
            /* Remove ./ at start. */
            if (path[0]=='.' && path[1]==PATH_SEPARATOR) path += 2;

            data[url->urllen]='/';
            strcpy( data+url->urllen+1, path);
        }

        *output=data;
    }
    else
        *output=(char*)none;

ex:
    return status;
}


int url__full_url(struct estat *sts, char **url)
{   
    int status;

    STOPIF( url__other_full_url(sts, sts->url, url), NULL);

ex:
    return status;
}



int url__find(char *url, struct url_t **output)
{
    int i;
    struct url_t *cur;

    /* The URLs are in sorted order (by priority!), so just do a linear 
     * search.  */
    for(i=0; i<urllist_count; i++)
    {
        cur=urllist[i];
        if (strncmp(cur->url, url, cur->urllen) == 0)
        {
            *output = cur;
            return 0;
        }
    }

    return ENOENT;
}


int url__work(struct estat *root UNUSED, int argc, char *argv[])
{
    int status, fh, l, i, had_it;
    char *dir;
    char *cp;
    int have_space;
    struct url_t *target;
    struct url_t *tmp;
    struct url_t **old_urllist;
    int old_urllist_count;


    dir=NULL;
    fh=-1;

    STOPIF( waa__given_or_current_wd(NULL, &dir), NULL );
    /* The current directory is the WC root. */
    STOPIF( waa__set_working_copy(dir), NULL);

    /* If there's \b no parameter given, we default to dump.
     * - Use goto?
     * - Set argv[0] to parm_dump? 
     * - Test for argc? That's what we'll do. */
    if (argc>0 && strcmp(argv[0], parm_load) == 0)
    {
        /* In case the user had some URLs already defined and "load"s another 
         * list, he would loose all URL internal numbers, so that a 
         * "sync-repos" would be necessary.
         *
         * To avoid that we read the existing URLs (but ignore any errors, in 
         * case the URLs are loaded again because the file is damaged). */
        status=url__load_list(NULL, argc+1);
        if (!status || status == ENOENT)
        {
            /* all right, just ignore that. */
        }
        else
        {
            /* Other errors are at least shown. */
            STOPIF_CODE_ERR_GOTO( 1, status, ignore_err,
                    "!Got an error reading the old URL list, so the internal URL mappings\n"
                    "cannot be kept; a \"sync-repos\" might be necessary.");
ignore_err:
            ;
        }

        /* Don't remember the old values. */
        old_urllist_count=urllist_count;
        old_urllist=urllist;
        urllist=NULL;
        urllist_count=0;

        /* Surely write the list again. */
        url__must_write_defs=1;

        status=0;

        /* Load URLs. We do not know how many we'll get, possibly we'll have
         * to allocate more memory. */
        i=0;
        have_space=0;
        while (1)
        {
            if (have_space < 1)
            {
                have_space=32;
                STOPIF( url__allocate(have_space), NULL);
            }

            status=hlp__string_from_filep(stdin, &cp, NULL, SFF_WHITESPACE);
            if (status == EOF) break;

            DEBUGP("parsing %s into %d", cp, urllist_count);
            STOPIF( url__insert_or_replace(cp, &target, &had_it), NULL);
            DEBUGP("had=%d", had_it);
            if (!had_it) 
            {
                have_space--;
                i++;
            }
            target->current_rev=0;

            /* Try to restore the internal number. */
            if (url__find_by_url_in_list(target->url, 
                        old_urllist, old_urllist_count, &tmp) == 0)
                target->internal_number = tmp->internal_number;
        }

        IF_FREE(old_urllist);

        if (opt__is_verbose() >= 0)
            printf("%d URL%s loaded.\n", i, i==1 ? "" : "s");
    }
    else
    {
        /* Read URLs, reserving space. */
        status=url__load_list(NULL, argc+1);
        /* But ignore ENOENT */
        if (status == ENOENT)
            urllist_count=0;
        else
            STOPIF_CODE_ERR( status, status, NULL);

        /* Needs status still set from url__load_list()! */
        if (argc == 0 || strcmp(argv[0], parm_dump) == 0)
        {
            STOPIF_CODE_ERR( status==ENOENT, ENOENT,
                 "!No URLs defined for \"%s\".", dir);

            /* Dump */
            STOPIF( url___dump(argc ? argv[1] : NULL), NULL);
            goto ex;
        }


        /* Append/insert. */
        DEBUGP("%d to parse", argc);
        /* Parse URLs */
        for(l=0; l<argc; l++)
        {
            DEBUGP("parsing %s into %d", argv[l], urllist_count);
            STOPIF( url__insert_or_replace(argv[l], &target, &had_it), NULL);
            if (!had_it)
                target->current_rev=0;
        }
    } /* if load_from_stdin */

    STOPIF( waa__create_working_copy(dir), NULL);

    /* Write the URL list */
    STOPIF( url__output_list(), NULL);

ex:
    return status;
}


int url__mark_todo(void)
{
    int status;
    char *parm, *url_string, *rev_str, **list;
    static const char delim[]=",; \t\r\n\f";
    struct url_t *url;


    status=0;
    if (!url__parm_list_used) goto ex;

    /* Terminate the list */
    url__parm_list[url__parm_list_used] = NULL;
    list=url__parm_list;
    while (*list)
    {
        parm=*(list++);

        url_string=strtok(parm, delim);
        while (url_string && *url_string)
        {
            DEBUGP("marking URL %s", url_string);

            rev_str=strchr(url_string, '@');
            if (rev_str) *(rev_str++)=0;

            STOPIF( url__find_by_name(url_string, &url), 
                    "!No URL with name \"%s\" found", url_string);

            if (url->to_be_handled)
                DEBUGP("URL %s mentioned multiple times", url->url);
            url->to_be_handled=1;

            if (rev_str) 
            {
                STOPIF( hlp__parse_rev(rev_str, NULL, 
                            & url->current_target_rev), NULL);
                url->current_target_override=1;
            }

            url_string=strtok(NULL, delim);
        }   
    }

ex:
    return status;
}


int url__store_url_name(char *parm)
{
    int status;

    status=0;
    /* The terminating NULL must be applied later, too. */
    if (url__parm_list_used+2 >= url__parm_list_len)
    {
        url__parm_list_len= url__parm_list_len ? url__parm_list_len*2 : 8;
        STOPIF( hlp__realloc( &url__parm_list, 
                url__parm_list_len*sizeof(*url__parm_list)), NULL);
    }

    url__parm_list[url__parm_list_used++] = parm;

ex:
    return status;
}


int url__canonical_rev( struct url_t *url, svn_revnum_t *rev)
{
    int status;
    svn_error_t *status_svn;


    status=0;
    status_svn=NULL;
    if (*rev == SVN_INVALID_REVNUM)
    {
        if (url->head_rev == SVN_INVALID_REVNUM)
        {
            BUG_ON( !url->session );
            /* As we ask at most once we just use the connection's pool - that 
             * has to exist if there's a session. */
            STOPIF_SVNERR( svn_ra_get_latest_revnum,
                    (url->session, & url->head_rev, url->pool));

            DEBUGP("HEAD of %s is at %ld", url->url, url->head_rev);
        }

        *rev=url->head_rev;
    }


ex:
    return status;
}


int url__iterator2(svn_revnum_t *target_rev, int only_if_count,
        char **missing)
{
    int status;
    static int last_index=-1;
    svn_revnum_t rev;


    status=0;
    if (!target_rev) 
    {
        last_index=-1;
        goto ex;
    }


    while (1)
    {
        last_index++;
        if (last_index >= urllist_count) 
        {
            DEBUGP("no more URLs.");
            /* No more data. */
            status=EOF;
            goto ex;
        }

        current_url=urllist[last_index];

        if (only_if_count)
        {
            if (!current_url->entry_list_count)
            {
                DEBUGP("No changes for url %s.", current_url->url);
                continue;
            }
            DEBUGP("%d changes for url %s.", 
                    current_url->entry_list_count, current_url->url);
        }

        if (url__to_be_handled(current_url)) break;
    }

    STOPIF( url__open_session(NULL, missing), NULL);


    if (current_url->current_target_override)
        rev=current_url->current_target_rev;
    else if (opt_target_revisions_given)
        rev=opt_target_revision;
    else
        rev=current_url->target_rev;
    DEBUGP("doing URL %s @ %s", current_url->url, 
            hlp__rev_to_string(rev));

    STOPIF( url__canonical_rev(current_url, &rev), NULL);
    *target_rev = rev;

ex:
    return status;
}

---