/src/proftpd/src/regexp.c

Source
/*
 * ProFTPD - FTP server daemon
 * Copyright (c) 1997, 1998 Public Flood Software
 * Copyright (c) 1999, 2000 MacGyver aka Habeeb J. Dihu <macgyver@tos.net>
 * Copyright (c) 2001-2021 The ProFTPD Project team
 *
 * This program is free software; you can redistribute it and/or modify
 * it under the terms of the GNU General Public License as published by
 * the Free Software Foundation; either version 2 of the License, or
 * (at your option) any later version.
 *
 * This program is distributed in the hope that it will be useful,
 * but WITHOUT ANY WARRANTY; without even the implied warranty of
 * MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.  See the
 * GNU General Public License for more details.
 *
 * You should have received a copy of the GNU General Public License
 * along with this program; if not, write to the Free Software
 * Foundation, Inc., 51 Franklin Street, Suite 500, Boston, MA 02110-1335, USA.
 *
 * As a special exemption, Public Flood Software/MacGyver aka Habeeb J. Dihu
 * and other respective copyright holders give permission to link this program
 * with OpenSSL, and distribute the resulting executable, without including
 * the source code for OpenSSL in the source distribution.
 */

/* Regex management code. */

#include "conf.h"

#ifdef PR_USE_REGEX

#if defined(PR_USE_PCRE2)
struct regexp_rec {
  pool *regex_pool;

  /* Owning module */
  module *m;

  /* Copy of the original regular expression pattern, flags */
  const char *pattern;
  int flags;

  /* For callers wishing to use POSIX REs */
  regex_t *re;

  /* For callers wishing to use PCRE2 REs */
  pcre2_code *pcre2;
  pcre2_general_context *pcre2_general_ctx;
  pcre2_match_context *pcre2_match_ctx;

  PCRE2_UCHAR *pcre2_errstr;
  PCRE2_SIZE pcre2_errstrsz;
};

static uint32_t pcre2_match_limit = 0;
static uint32_t pcre2_match_limit_recursion = 0;

#elif defined(PR_USE_PCRE)
struct regexp_rec {
  pool *regex_pool;

  /* Owning module */
  module *m;

  /* Copy of the original regular expression pattern, flags */
  const char *pattern;
  int flags;

  /* For callers wishing to use POSIX REs */
  regex_t *re;

  /* For callers wishing to use PCRE REs */
  pcre *pcre;
  pcre_extra *pcre_extra;

  const char *pcre_errstr;
};

static unsigned long pcre_match_limit = 0;
static unsigned long pcre_match_limit_recursion = 0;

#else /* !PR_USE_PCRE2 and !PR_USE_PCRE */
struct regexp_rec {
  pool *regex_pool;

  /* Owning module */
  module *m;

  /* Copy of the original regular expression pattern, flags */
  const char *pattern;
  int flags;

  /* For callers wishing to use POSIX REs */
  regex_t *re;
};
#endif /* PR_USE_PCRE */

static pool *regexp_pool = NULL;
static array_header *regexp_list = NULL;

#if defined(PR_USE_PCRE2) || \
    defined(PR_USE_PCRE)
static int regexp_use_posix = FALSE;
#else
static int regexp_use_posix = TRUE;
#endif /* PR_USE_PCRE */

static const char *trace_channel = "regexp";

static void regexp_free(pr_regex_t *pre) {
#if defined(PR_USE_PCRE2)
  if (pre->pcre2 != NULL) {
    pcre2_code_free(pre->pcre2);
    pre->pcre2 = NULL;
  }

  if (pre->pcre2_general_ctx != NULL) {
    pcre2_general_context_free(pre->pcre2_general_ctx);
    pre->pcre2_general_ctx = NULL;
  }

  if (pre->pcre2_match_ctx != NULL) {
    pcre2_match_context_free(pre->pcre2_match_ctx);
    pre->pcre2_match_ctx = NULL;
  }
#endif /* PR_USE_PCRE2 */

#if defined(PR_USE_PCRE)
  if (pre->pcre != NULL) {
# if defined(HAVE_PCRE_PCRE_FREE_STUDY)
    pcre_free_study(pre->pcre_extra);
# endif /* HAVE_PCRE_PCRE_FREE_STUDY */
    pre->pcre_extra = NULL;
    pcre_free(pre->pcre);
    pre->pcre = NULL;
  }
#endif /* PR_USE_PCRE */

  if (pre->re != NULL) {
    /* This frees memory associated with this pointer by regcomp(3). */
# if defined(HAVE_PCRE2_PCRE2_REGCOMP)
    pcre2_regfree(pre->re);
# else
    regfree(pre->re);
# endif /* HAVE_PCRE2_PCRE2_REGCOMP */
    pre->re = NULL;
  }

  pre->pattern = NULL;
  destroy_pool(pre->regex_pool);
}

static void regexp_cleanup(void) {
  /* Only perform this cleanup if necessary */
  if (regexp_pool) {
    register unsigned int i = 0;
    pr_regex_t **pres = (pr_regex_t **) regexp_list->elts;

    for (i = 0; i < regexp_list->nelts; i++) {
      if (pres[i] != NULL) {
        regexp_free(pres[i]);
        pres[i] = NULL;
      }
    }

    destroy_pool(regexp_pool);
    regexp_pool = NULL;
    regexp_list = NULL;
  }
}

static void regexp_exit_ev(const void *event_data, void *user_data) {
  regexp_cleanup();
}

static void regexp_restart_ev(const void *event_data, void *user_data) {
  regexp_cleanup();
}

pr_regex_t *pr_regexp_alloc(module *m) {
  pr_regex_t *pre = NULL;
  pool *re_pool = NULL;

  /* If no regex-tracking list has been allocated, create one.  Register a
   * cleanup handler for this pool, to free up the data in the list.
   */
  if (regexp_pool == NULL) {
    regexp_pool = make_sub_pool(permanent_pool);
    pr_pool_tag(regexp_pool, "Regexp Pool");
    regexp_list = make_array(regexp_pool, 0, sizeof(pr_regex_t *));
  }

  re_pool = pr_pool_create_sz(regexp_pool, 128);
  pr_pool_tag(re_pool, "regexp pool");

  pre = pcalloc(re_pool, sizeof(pr_regex_t));
  pre->regex_pool = re_pool;
  pre->m = m;

  /* Add this pointer to the array. */
  *((pr_regex_t **) push_array(regexp_list)) = pre;

  return pre;
}

void pr_regexp_free(module *m, pr_regex_t *pre) {
  register unsigned int i = 0;
  pr_regex_t **pres = NULL;

  if (regexp_list == NULL) {
    return;
  }

  pres = (pr_regex_t **) regexp_list->elts;

  for (i = 0; i < regexp_list->nelts; i++) {
    if (pres[i] == NULL) {
      continue;
    }

    if ((pre != NULL && pres[i] == pre) ||
        (m != NULL && pres[i]->m == m)) {
      regexp_free(pres[i]);
      pres[i] = NULL;
    }
  }
}

#if defined(PR_USE_PCRE2)
static int regexp_compile_pcre2(pr_regex_t *pre, const char *pattern,
    int flags) {
  int res;
  PCRE2_SIZE err_offset;

  if (pre == NULL ||
      pattern == NULL) {
    errno = EINVAL;
    return -1;
  }

  pr_trace_msg(trace_channel, 9, "compiling pattern '%s' into PCRE2 regex",
    pattern);
  pre->pattern = pstrdup(pre->regex_pool, pattern);
  pre->flags = flags;

  pre->pcre2 = pcre2_compile((PCRE2_SPTR) pattern, PCRE2_ZERO_TERMINATED,
    flags, &res, &err_offset, NULL);
  if (pre->pcre2 == NULL) {
    if (pre->pcre2_errstr == NULL) {
      pre->pcre2_errstrsz = 128;
      pre->pcre2_errstr = pcalloc(pre->regex_pool, pre->pcre2_errstrsz);
    }

    pcre2_get_error_message(res, pre->pcre2_errstr, pre->pcre2_errstrsz);
    pr_trace_msg(trace_channel, 4,
      "error compiling pattern '%s' into PCRE2 regex: %s", pattern,
      pre->pcre2_errstr);
    return -1;
  }

  /* Prepare the JIT compiler as well. */
  res = pcre2_jit_compile(pre->pcre2, PCRE2_JIT_COMPLETE);
  if (res != 0) {
    if (pre->pcre2_errstr == NULL) {
      pre->pcre2_errstrsz = 128;
      pre->pcre2_errstr = pcalloc(pre->regex_pool, pre->pcre2_errstrsz);
    }

    pcre2_get_error_message(res, pre->pcre2_errstr, pre->pcre2_errstrsz);
    pr_trace_msg(trace_channel, 4,
      "error performing PCRE2 JIT compile for pattern '%s': %s", pattern,
      pre->pcre2_errstr);
  }

  return 0;
}
#endif /* PR_USE_PCRE2 */

#if defined(PR_USE_PCRE)
static int regexp_compile_pcre(pr_regex_t *pre, const char *pattern,
    int flags) {
  int err_offset, study_flags = 0;

  if (pre == NULL ||
      pattern == NULL) {
    errno = EINVAL;
    return -1;
  }

  pr_trace_msg(trace_channel, 9, "compiling pattern '%s' into PCRE regex",
    pattern);
  pre->pattern = pstrdup(pre->regex_pool, pattern);
  pre->flags = flags;

  pre->pcre = pcre_compile(pattern, flags, &(pre->pcre_errstr), &err_offset,
    NULL);
  if (pre->pcre == NULL) {
    pr_trace_msg(trace_channel, 4,
      "error compiling pattern '%s' into PCRE regex: %s", pattern,
      pre->pcre_errstr);
    return -1;
  }

  /* Study the pattern as well, just in case. */
#ifdef PCRE_STUDY_JIT_COMPILE
  study_flags = PCRE_STUDY_JIT_COMPILE;
#endif /* PCRE_STUDY_JIT_COMPILE */
  pr_trace_msg(trace_channel, 9, "studying pattern '%s' for PCRE extra data",
    pattern);
  pre->pcre_extra = pcre_study(pre->pcre, study_flags, &(pre->pcre_errstr));
  if (pre->pcre_extra == NULL) {
    if (pre->pcre_errstr != NULL) {
      pr_trace_msg(trace_channel, 4,
        "error studying pattern '%s' for PCRE regex: %s", pattern,
        pre->pcre_errstr);
    }
  }

  return 0;
}
#endif /* PR_USE_PCRE */

int pr_regexp_compile_posix(pr_regex_t *pre, const char *pattern, int flags) {
  int res;

  if (pre == NULL ||
      pattern == NULL) {
    errno = EINVAL;
    return -1;
  }

  if (pre->re != NULL) {
    regfree(pre->re);
    pre->re = NULL;
  }

  pr_trace_msg(trace_channel, 9, "compiling pattern '%s' into POSIX regex",
    pattern);
  pre->pattern = pstrdup(pre->regex_pool, pattern);

#if defined(REG_EXTENDED)
  /* Enable modern ("extended") POSIX regular expressions by default. */
  flags |= REG_EXTENDED;
#endif /* REG_EXTENDED */

  pre->flags = flags;

  pre->re = pcalloc(pre->regex_pool, sizeof(regex_t));
# if defined(HAVE_PCRE2_PCRE2_REGCOMP)
  res = pcre2_regcomp(pre->re, pattern, flags);
# else
  res = regcomp(pre->re, pattern, flags);
# endif /* HAVE_PCRE2_PCRE2_REGCOMP */

  return res;
}

int pr_regexp_compile(pr_regex_t *pre, const char *pattern, int flags) {
#if defined(PR_USE_PCRE2) || \
    defined(PR_USE_PCRE)
# if defined(PR_USE_PCRE2)
  int pcre2_flags = 0;
# elif defined(PR_USE_PCRE)
  int pcre_flags = 0;
# endif

  if (regexp_use_posix == TRUE) {
    return pr_regexp_compile_posix(pre, pattern, flags);
  }

  /* Provide a simple mapping of POSIX regcomp(3) flags to
   * PCRE pcre_compile() flags.  The ProFTPD code tends not to use many
   * of these flags.
   */
  if (flags & REG_ICASE) {
# if defined(PR_USE_PCRE2)
    pcre2_flags |= PCRE2_CASELESS;
# elif defined(PR_USE_PCRE)
    pcre_flags |= PCRE_CASELESS;
# endif
  }

# if defined(PR_USE_PCRE2)
  return regexp_compile_pcre2(pre, pattern, pcre2_flags);
# else
  return regexp_compile_pcre(pre, pattern, pcre_flags);
# endif /* PR_USE_PCRE2 */
#else
  return pr_regexp_compile_posix(pre, pattern, flags);
#endif /* PR_USE_PCRE */
}

size_t pr_regexp_error(int errcode, const pr_regex_t *pre, char *buf,
    size_t bufsz) {
  size_t res = 0;

  if (pre == NULL ||
      buf == NULL ||
      bufsz == 0) {
    return 0;
  }

#if defined(PR_USE_PCRE2)
  if (pre->pcre2_errstr != NULL) {
    sstrncpy(buf, (const char *) pre->pcre2_errstr, bufsz);
    return strlen((const char *) pre->pcre2_errstr) + 1;
  }
#elif defined(PR_USE_PCRE)
  if (pre->pcre_errstr != NULL) {
    sstrncpy(buf, pre->pcre_errstr, bufsz);
    return strlen(pre->pcre_errstr) + 1;
  }
#endif /* PR_USE_PCRE */

  if (pre->re != NULL) {
    /* Make sure the given buffer is always zeroed out first. */
    memset(buf, '\0', bufsz);
# if defined(HAVE_PCRE2_PCRE2_REGCOMP)
    res = pcre2_regerror(errcode, pre->re, buf, bufsz-1);
# else
    res = regerror(errcode, pre->re, buf, bufsz-1);
# endif /* HAVE_PCRE2_PCRE2_REGCOMP */
  }

  return res;
}

const char *pr_regexp_get_pattern(const pr_regex_t *pre) {
  if (pre == NULL) {
    errno = EINVAL;
    return NULL;
  }

  if (pre->pattern == NULL) {
    errno = ENOENT;
    return NULL;
  }

  return pre->pattern;
}

#if defined(PR_USE_PCRE2)
static int regexp_exec_pcre2(pr_regex_t *pre, const char *text,
    size_t nmatches, regmatch_t *matches, int flags, unsigned long match_limit,
    unsigned long match_limit_recursion) {
  pool *tmp_pool = NULL;
  int res;
  uint32_t ovector_count = 0;
  pcre2_match_data *match_data = NULL;

  if (pre->pcre2 == NULL) {
    errno = EINVAL;
    return -1;
  }

  /* Use the default match limits, if set and if the caller did not
   * explicitly provide limits.
   */
  if (match_limit == 0) {
    match_limit = pcre2_match_limit;
  }

  if (match_limit_recursion == 0) {
    match_limit_recursion = pcre2_match_limit_recursion;
  }

  if (match_limit > 0) {
    if (pre->pcre2_general_ctx == NULL) {
      pre->pcre2_general_ctx = pcre2_general_context_create(NULL, NULL, NULL);
    }

    if (pre->pcre2_match_ctx == NULL) {
      pre->pcre2_match_ctx = pcre2_match_context_create(pre->pcre2_general_ctx);
    }

    pcre2_set_match_limit(pre->pcre2_match_ctx, match_limit);
  }

  if (match_limit_recursion > 0) {
    if (pre->pcre2_general_ctx == NULL) {
      pre->pcre2_general_ctx = pcre2_general_context_create(NULL, NULL, NULL);
    }

    if (pre->pcre2_match_ctx == NULL) {
      pre->pcre2_match_ctx = pcre2_match_context_create(pre->pcre2_general_ctx);
    }

    pcre2_set_depth_limit(pre->pcre2_match_ctx, match_limit_recursion);
  }

  if (nmatches > 0 &&
      matches != NULL) {
    tmp_pool = make_sub_pool(pre->regex_pool);
    pr_pool_tag(tmp_pool, "regexp tmp pool");
  }

  pr_trace_msg(trace_channel, 9,
    "executing PCRE2 regex '%s' against subject '%s'",
    pr_regexp_get_pattern(pre), text);
  match_data = pcre2_match_data_create_from_pattern(pre->pcre2,
    pre->pcre2_general_ctx);
  res = pcre2_match(pre->pcre2, (PCRE2_SPTR) text, PCRE2_ZERO_TERMINATED, 0,
    flags, match_data, pre->pcre2_match_ctx);

  if (res < 0) {
    if (tmp_pool != NULL) {
      destroy_pool(tmp_pool);
    }

    if (pre->pcre2_errstr == NULL) {
      pre->pcre2_errstrsz = 128;
      pre->pcre2_errstr = pcalloc(pre->regex_pool, pre->pcre2_errstrsz);
    }

    pcre2_get_error_message(res, pre->pcre2_errstr, pre->pcre2_errstrsz);
    pr_trace_msg(trace_channel, 9,
      "PCRE2 regex '%s' failed to match subject '%s': %s",
      pr_regexp_get_pattern(pre), text, pre->pcre2_errstr);
    pcre2_match_data_free(match_data);

    return -1;
  }

  pr_trace_msg(trace_channel, 9,
    "PCRE2 regex '%s' successfully matched subject '%s'",
    pr_regexp_get_pattern(pre), text);

  if (nmatches > 0 &&
      matches != NULL) {
    /* If matches/capture groups are requested, do the processing for them. */
    ovector_count = pcre2_get_ovector_count(match_data);
  }

  if (ovector_count > 0) {
    /* Populate the provided POSIX regmatch_t array with the PCRE2 data. */
    register uint32_t i;
    PCRE2_SIZE *ovector = NULL;

    pr_trace_msg(trace_channel, 9,
      "PCRE2 regex '%s' captured %lu groups in subject '%s'",
      pr_regexp_get_pattern(pre), (unsigned long) ovector_count, text);

    ovector = pcre2_get_ovector_pointer(match_data);

    for (i = 0; i < ovector_count; i++) {
      matches[i].rm_so = ovector[i * 2];
      matches[i].rm_eo = ovector[(i * 2) + 1];
    }

    /* Ensure the remaining items are set to proper defaults as well. */
    for (; i < nmatches; i++) {
      matches[i].rm_so = matches[i].rm_eo = -1;
    }
  }

  destroy_pool(tmp_pool);
  pcre2_match_data_free(match_data);

  if (matches != NULL &&
      pr_trace_get_level(trace_channel) >= 20) {
    register unsigned int i;

    for (i = 0; i < nmatches; i++) {
      int match_len;
      const char *match_text;

      if (matches[i].rm_so == -1 ||
          matches[i].rm_eo == -1) {
        break;
      }

      match_text = &(text[matches[i].rm_so]);
      match_len = matches[i].rm_eo - matches[i].rm_so;

      pr_trace_msg(trace_channel, 20,
        "PCRE2 regex '%s' match #%u: %.*s (start %ld, len %d)",
        pr_regexp_get_pattern(pre), i, (int) match_len, match_text,
        (long) matches[i].rm_so, match_len);
    }
  }

  return 0;
}
#endif /* PR_USE_PCRE2 */

#if defined(PR_USE_PCRE)
static int regexp_exec_pcre(pr_regex_t *pre, const char *text,
    size_t nmatches, regmatch_t *matches, int flags, unsigned long match_limit,
    unsigned long match_limit_recursion) {
  int res, ovector_count = 0, *ovector = NULL;
  size_t text_len;
  pool *tmp_pool = NULL;

  if (pre->pcre == NULL) {
    errno = EINVAL;
    return -1;
  }

  text_len = strlen(text);

  /* Use the default match limits, if set and if the caller did not
   * explicitly provide limits.
   */
  if (match_limit == 0) {
    match_limit = pcre_match_limit;
  }

  if (match_limit_recursion == 0) {
    match_limit_recursion = pcre_match_limit_recursion;
  }

  if (match_limit > 0) {
    if (pre->pcre_extra == NULL) {
      pre->pcre_extra = pcalloc(pre->regex_pool, sizeof(pcre_extra));
    }

    pre->pcre_extra->flags |= PCRE_EXTRA_MATCH_LIMIT;
    pre->pcre_extra->match_limit = match_limit;
  }

  if (match_limit_recursion > 0) {
    if (pre->pcre_extra == NULL) {
      pre->pcre_extra = pcalloc(pre->regex_pool, sizeof(pcre_extra));
    }

    pre->pcre_extra->flags |= PCRE_EXTRA_MATCH_LIMIT_RECURSION;
    pre->pcre_extra->match_limit_recursion = match_limit_recursion;
  }

  if (nmatches > 0 &&
      matches != NULL) {
    tmp_pool = make_sub_pool(pre->regex_pool);
    pr_pool_tag(tmp_pool, "regexp tmp pool");

    ovector_count = nmatches;
    ovector = pcalloc(tmp_pool, sizeof(int) * nmatches * 3);
  }

  pr_trace_msg(trace_channel, 9,
    "executing PCRE regex '%s' against subject '%s'",
    pr_regexp_get_pattern(pre), text);
  res = pcre_exec(pre->pcre, pre->pcre_extra, text, text_len, 0, flags,
    ovector, ovector_count);

  if (res < 0) {
    if (tmp_pool != NULL) {
      destroy_pool(tmp_pool);
    }

    if (pr_trace_get_level(trace_channel) >= 9) {
      const char *reason = "unknown";

      switch (res) {
        case PCRE_ERROR_NOMATCH:
          reason = "subject did not match pattern";
          break;

        case PCRE_ERROR_NULL:
          reason = "null regex or subject";
          break;

        case PCRE_ERROR_BADOPTION:
          reason = "unsupported options bit";
          break;

        case PCRE_ERROR_BADMAGIC:
          reason = "bad magic number in regex";
          break;

        case PCRE_ERROR_UNKNOWN_OPCODE:
        case PCRE_ERROR_INTERNAL:
          reason = "internal PCRE error or corrupted regex";
          break;

        case PCRE_ERROR_NOMEMORY:
          reason = "not enough memory for backreferences";
          break;

        case PCRE_ERROR_MATCHLIMIT:
          reason = "match limit reached/exceeded";
          break;

        case PCRE_ERROR_RECURSIONLIMIT:
          reason = "match limit recursion reached/exceeded";
          break;

        case PCRE_ERROR_BADUTF8:
          reason = "invalid UTF8 subject used";
          break;

        case PCRE_ERROR_PARTIAL:
          reason = "subject matched only partially; PCRE_PARTIAL flag not used";
          break;
      }

      pr_trace_msg(trace_channel, 9,
        "PCRE regex '%s' failed to match subject '%s': %s",
        pr_regexp_get_pattern(pre), text, reason);
    }

    return res;
  }

  pr_trace_msg(trace_channel, 9,
    "PCRE regex '%s' successfully matched subject '%s'",
    pr_regexp_get_pattern(pre), text);

  if (ovector_count > 0) {
    /* Populate the provided POSIX regmatch_t array with the PCRE data. */
    register int i;

    for (i = 0; i < res; i++) {
      matches[i].rm_so = ovector[i * 2];
      matches[i].rm_eo = ovector[(i * 2) + 1];
    }

    /* Ensure the remaining items are set to proper defaults as well. */
    for (; i < nmatches; i++) {
      matches[i].rm_so = matches[i].rm_eo = -1;
    }
  }

  destroy_pool(tmp_pool);

  if (matches != NULL &&
      pr_trace_get_level(trace_channel) >= 20) {
    register unsigned int i;

    for (i = 0; i < nmatches; i++) {
      int match_len;
      const char *match_text;

      if (matches[i].rm_so == -1 ||
          matches[i].rm_eo == -1) {
        break;
      }

      match_text = &(text[matches[i].rm_so]);
      match_len = matches[i].rm_eo - matches[i].rm_so;

      pr_trace_msg(trace_channel, 20,
        "PCRE regex '%s' match #%u: %.*s (start %ld, len %d)",
        pr_regexp_get_pattern(pre), i, (int) match_len, match_text,
        (long) matches[i].rm_so, match_len);
    }
  }

  return 0;
}
#endif /* PR_USE_PCRE */

static int regexp_exec_posix(pr_regex_t *pre, const char *text,
    size_t nmatches, regmatch_t *matches, int flags) {
  int res;

  pr_trace_msg(trace_channel, 9,
    "executing POSIX regex '%s' against subject '%s'",
    pr_regexp_get_pattern(pre), text);
# if defined(HAVE_PCRE2_PCRE2_REGCOMP)
  res = pcre2_regexec(pre->re, text, nmatches, matches, flags);
# else
  res = regexec(pre->re, text, nmatches, matches, flags);
# endif /* HAVE_PCRE2_PCRE2_REGCOMP */
  if (res == 0) {
    pr_trace_msg(trace_channel, 9,
      "POSIX regex '%s' successfully matched subject '%s'",
      pr_regexp_get_pattern(pre), text);

     if (matches != NULL &&
         pr_trace_get_level(trace_channel) >= 20) {
       register unsigned int i;

       for (i = 0; i < nmatches; i++) {
         int match_len;
         const char *match_text;

         if (matches[i].rm_so == -1 ||
             matches[i].rm_eo == -1) {
           break;
         }

         match_text = &(text[matches[i].rm_so]);
         match_len = matches[i].rm_eo - matches[i].rm_so;

         pr_trace_msg(trace_channel, 20,
           "POSIX regex '%s' match #%u: %.*s (start %ld, len %d)",
           pr_regexp_get_pattern(pre), i, (int) match_len, match_text,
           (long) matches[i].rm_so, match_len);
       }
     }

  } else {
    if (pr_trace_get_level(trace_channel) >= 9) {
      const char *reason = "subject did not match pattern";

      /* NOTE: Expectation of `res` values here are mixed when PCRE
       * support, and the <pcreposix.h> header, are involved.
       */

      pr_trace_msg(trace_channel, 9,
        "POSIX regex '%s' failed to match subject '%s': %s (%d)",
         pr_regexp_get_pattern(pre), text, reason, res);
    }
  }

  return res;
}

int pr_regexp_exec(pr_regex_t *pre, const char *text, size_t nmatches,
    regmatch_t *matches, int flags, unsigned long match_limit,
    unsigned long match_limit_recursion) {
  int res;

  if (pre == NULL ||
      text == NULL) {
    errno = EINVAL;
    return -1;
  }

#if defined(PR_USE_PCRE2)
  if (pre->pcre2 != NULL) {

    /* What if the given pre was compiled via PCRE2, but we are told to only
     * use POSIX?  In this case, we need to compile+exec on demand.
     */
    if (regexp_use_posix == FALSE) {
      return regexp_exec_pcre2(pre, text, nmatches, matches, flags, match_limit,
        match_limit_recursion);
    }

    res = pr_regexp_compile_posix(pre, pre->pattern, pre->flags);
    if (res < 0) {
      return -1;
    }
  }

#elif defined(PR_USE_PCRE)
  if (pre->pcre != NULL) {

    /* What if the given pre was compiled via PCRE, but we are told to only
     * use POSIX?  In this case, we need to compile+exec on demand.
     */
    if (regexp_use_posix == FALSE) {
      return regexp_exec_pcre(pre, text, nmatches, matches, flags, match_limit,
        match_limit_recursion);
    }

    res = pr_regexp_compile_posix(pre, pre->pattern, pre->flags);
    if (res < 0) {
      return -1;
    }
  }
#endif /* PR_USE_PCRE */
  res = regexp_exec_posix(pre, text, nmatches, matches, flags);

  /* Make sure that we return a negative value to indicate a failed match;
   * PCRE already does this.
   */
  if (res == REG_NOMATCH) {
    res = -1;
  }

  return res;
}

int pr_regexp_set_limits(unsigned long match_limit,
    unsigned long match_limit_recursion) {

#if defined(PR_USE_PCRE2)
  pcre2_match_limit = match_limit;
  pcre2_match_limit_recursion = match_limit_recursion;

#elif defined(PR_USE_PCRE)
  pcre_match_limit = match_limit;
  pcre_match_limit_recursion = match_limit_recursion;
#endif

  return 0;
}

int pr_regexp_set_engine(const char *engine) {
  if (engine == NULL) {
    /* Restore the default. */
#if defined(PR_USE_PCRE2) || \
    defined(PR_USE_PCRE)
    regexp_use_posix = FALSE;
#else
    regexp_use_posix = TRUE;
#endif /* PR_USE_PCRE */
    pr_trace_msg(trace_channel, 19, "%s", "restored default regexp engine");
    return 0;
  }

  if (strcasecmp(engine, "POSIX") != 0 &&
      strcasecmp(engine, "PCRE") != 0 &&
      strcasecmp(engine, "PCRE2") != 0) {
    errno = EINVAL;
    return -1;
  }

#if defined(PR_USE_PCRE2)
  if (strcasecmp(engine, "PCRE") == 0) {
    errno = ENOSYS;
    return -1;
  }

  /* We already use PCRE2 by default, but are being explicitly requested to
   * only use POSIX.
   */
  if (strcasecmp(engine, "POSIX") == 0) {
    if (regexp_use_posix == FALSE) {
      pr_trace_msg(trace_channel, 19, "%s",
        "changed regexp engine from PCRE2 to POSIX");
    }

    regexp_use_posix = TRUE;

  } else {
    if (regexp_use_posix == TRUE) {
      pr_trace_msg(trace_channel, 19, "%s",
        "changed regexp engine from POSIX to PCRE2");
    }

    regexp_use_posix = FALSE;
  }

#elif defined(PR_USE_PCRE)
  if (strcasecmp(engine, "PCRE2") == 0) {
    errno = ENOSYS;
    return -1;
  }

  /* We already use PCRE by default, but are being explicitly requested to
   * only use POSIX.
   */
  if (strcasecmp(engine, "POSIX") == 0) {
    if (regexp_use_posix == FALSE) {
      pr_trace_msg(trace_channel, 19, "%s",
        "changed regexp engine from PCRE to POSIX");
    }

    regexp_use_posix = TRUE;

  } else {
    if (regexp_use_posix == TRUE) {
      pr_trace_msg(trace_channel, 19, "%s",
        "changed regexp engine from POSIX to PCRE");
    }

    regexp_use_posix = FALSE;
  }
#else
  /* We only use POSIX, but are being requested to use PCRE/PCRE2. */
  if (strcasecmp(engine, "PCRE") == 0 ||
      strcasecmp(engine, "PCRE2") == 0) {
    errno = ENOSYS;
    return -1;
  }

  regexp_use_posix = TRUE;
#endif /* PR_USE_PCRE */

  return 0;
}

void init_regexp(void) {

  /* Register a restart handler for the regexp pool, so that when restarting,
   * regfree(3) is called on each of the regex_t pointers in a
   * regex_t-tracking array, thus preventing memory leaks on a long-running
   * daemon.
   *
   * This registration is done here so that it only happens once.
   */
  pr_event_register(NULL, "core.restart", regexp_restart_ev, NULL);
  pr_event_register(NULL, "core.exit", regexp_exit_ev, NULL);

#if defined(PR_USE_PCRE2)
  pr_log_debug(DEBUG2, "using PCRE2 %d.%d", PCRE2_MAJOR, PCRE2_MINOR);
#elif defined(PR_USE_PCRE)
  pr_log_debug(DEBUG2, "using PCRE %s", pcre_version());
#endif /* PR_USE_PCRE */
}

#endif

Coverage Report

Created: 2025-10-12 06:27