3 files changed, 101 insertions, 62 deletions

diff --git a/configure.ac b/configure.ac
index 2fa32f6..f21fcfb 100644
--- a/configure.ac
+++ b/configure.ac
@@ -105,30 +105,12 @@ AC_ARG_WITH([vmoddir],
 
 
 if test -z "$VMODDIR"; then
        VMODDIR='$(libdir)/varnish/mods'
 fi
 
-###########
-# Check for db.h and libdb
-#
-AC_CHECK_HEADER([db.h],,[AC_MSG_ERROR([Required header file db.h not found])])
-
-AC_CHECK_LIB(db, db_create,
-  [LIBS="$LIBS -ldb"
-   AC_RUN_IFELSE(
-     [AC_LANG_PROGRAM([#include "db.h"],
-        [int v_major, v_minor, v_patch;
-         db_version(&v_major, &v_minor, &v_patch);
-         return !(v_major == DB_VERSION_MAJOR
-                  && v_minor == DB_VERSION_MINOR
-                  && v_patch == DB_VERSION_PATCH);
-        ])],
-     [],
-     [AC_MSG_ERROR([header file db.h is not the same version as libdb])])])
-
 AC_CONFIG_COMMANDS([status],[
 delim="-------------------------------------------------------------------"
 echo ""
 echo $delim
 echo "Building for Varnish version $VARNISHVERSION"
 echo $delim
diff --git a/src/variable.c b/src/variable.c
index 6403c1a..9442b6b 100644
--- a/src/variable.c
+++ b/src/variable.c
@@ -497,13 +497,14 @@ log_error(const char *fmt, ...)
 
 #define S(s) ((s) ? (s) : "NULL")
 
 struct vardef {
         struct vardef *next;
         enum variable_type type;
-        char name[1];
+        char *name;
+        char *repl;
 };
 
 static void
 vardef_free(struct vardef *v)
 {
         while (v) {
@@ -567,12 +568,57 @@ str2duration(const char *str)
         }
         while (*p && isspace(*p))
                 p++;
         return *p ? 0 : r;
 }       
 
+char *
+bref_expand(const char *str, const char *input, pcre *re,
+            int ovsize, int *ovector)
+{
+        size_t rlen = 0;
+        char *rbase = NULL;
+        char *rptr;
+        int nm = 2*ovsize/3;
+        const char *p;
+        
+        for (p = str; *p; ) {
+                if (*p == '\\' && strchr("123456789", p[1])) {
+                        int n = 2*(p[1] - '0');
+                        if (n < nm) {
+                                rlen += ovector[n+1] - ovector[n];
+                                p += 2;
+                                continue;
+                        }
+                }
+                ++p;
+                ++rlen;
+        }
+        rbase = malloc(rlen + 1);
+        AN(rbase);
+        p = str;
+        rptr = rbase;
+        while (*p) {
+                if (*p == '\\' && strchr("123456789", p[1])) {
+                        int n = 2*(p[1] - '0');
+                        if (n < nm) {
+                                memcpy(rptr, input + ovector[n],
+                                       ovector[n+1] - ovector[n]);
+                                rptr += ovector[n+1] - ovector[n];
+                                p += 2;
+                                continue;
+                        } 
+                } 
+
+                *rptr++ = *p++;
+        }
+        *rptr = 0;
+
+        return rbase;
+}
+
 VCL_VOID
 vmod_batchset(VARIABLE_CTX ctx,
               VCL_STRING vars, VCL_STRING rxs, VCL_STRING input)
 {
         struct symtab *vt = get_symtab(ctx);
         struct vardef *head = NULL, *tail = NULL, *def;
@@ -595,56 +641,69 @@ vmod_batchset(VARIABLE_CTX ctx,
                 log_error("variable.batchset: bad arguments: vars=%s, rxs=%s, input=%s",
                       S(vars), S(rxs), S(input));
                 return;
         }
 
         while (*v) {
-                size_t n = strcspn(v, "=");
+                char const *nameptr = v;
+                size_t n = strcspn(v, ":=,");
+                size_t namelen;
+                char const *replptr;
+                size_t repllen;
+                char rbuf[3];
+                enum variable_type type;
+                int delim;
+                
+                namelen = n;
                 
-                if (!v[n]) {
-                        log_error("variable.batchset: vars argument invalid near %s",
-                              v);
-                        vardef_free(head);
-                        return;
+                v += n;
+                delim = *v ? *v++ : 0;
+
+                if (delim == ':') {
+                        n = strcspn(v, "=,");
+                        type = str2type(v, n);
+                        v += n;
+                        delim = *v ? *v++ : 0;
+                } else
+                        type = variable_string;
+
+                if (delim == '=') {
+                        n = strcspn(v, ",");
+                        replptr = v;
+                        repllen = n;
+                        v += n;
+                        delim = *v ? *v++ : 0;
+                } else {
+                        rbuf[0] = '\\';
+                        rbuf[1] = count + '1';
+                        rbuf[2] = 0;
+                        replptr = rbuf;
+                        repllen = 2;
                 }
-                def = malloc(sizeof(def[0]) + n);
+
+                def = malloc(sizeof(def[0]) + namelen + repllen + 2);
                 def->next = NULL;
-                memcpy(def->name, v, n);
-                def->name[n] = 0;
                 if (tail)
                         tail->next = def;
                 else
                         head = def;
                 tail = def;
                 ++count;
-                
-                v += n + 1;
-                if (!*v) {
-                        log_error("variable.batchset: no type for %s", def->name);
-                        vardef_free(head);
-                        return;
-                }
-                
-                n = strcspn(v, ",");
-                def->type = str2type(v, n);
-                if (def->type == variable_unset) {
-                        log_error("variable.batchset: invalid type for %s",
-                              def->name);
-                        vardef_free(head);
-                        return;
-                }
-
-                v += n;
-                if (*v)
-                        ++v;
+                def->type = type;
+                def->name = (char*)(def + 1);
+                memcpy(def->name, nameptr, namelen);
+                def->name[namelen] = 0;
+                def->repl = def->name + namelen + 1;
+                memcpy(def->repl, replptr, repllen);
+                def->repl[repllen] = 0;
         }
 
         re = pcre_compile(rxs, cflags, &error_ptr, &error_offset, NULL);
         if (!re) {
                 log_error("variable.batchset: %s: compilation failed near %s: %s",
-                      rxs, rxs + error_offset, error_ptr);
+                          rxs, rxs + error_offset, error_ptr);
                 vardef_free(head);
                 return;
         }
 
         rc = pcre_fullinfo(re, NULL, PCRE_INFO_CAPTURECOUNT, &n);
         if (rc) {
@@ -670,22 +729,14 @@ vmod_batchset(VARIABLE_CTX ctx,
                 else