pg_regress_ecpg.c File Reference

#include "postgres_fe.h"
#include "common/string.h"
#include "lib/stringinfo.h"
#include "pg_regress.h"

Include dependency graph for pg_regress_ecpg.c:

Go to the source code of this file.

Functions
static void	ecpg_filter_source (const char *sourcefile, const char *outfile)
static void	ecpg_filter_stderr (const char *resultfile, const char *tmpfile)
static PID_TYPE	ecpg_start_test (const char *testname, _stringlist **resultfiles, _stringlist **expectfiles, _stringlist **tags)
static void	ecpg_postprocess_result (const char *filename)
static void	ecpg_init (int argc, char *argv[])
int	main (int argc, char *argv[])

Function Documentation

ecpg_filter_source()

static void ecpg_filter_source ( const char *  sourcefile, const char *  outfile  )

static

Definition at line 34 of file pg_regress_ecpg.c.

{
    FILE       *s,
               *t;
    StringInfoData linebuf;
 
    s = fopen(sourcefile, "r");
    if (!s)
    {
        fprintf(stderr, "Could not open file %s for reading\n", sourcefile);
        exit(2);
    }
    t = fopen(outfile, "w");
    if (!t)
    {
        fprintf(stderr, "Could not open file %s for writing\n", outfile);
        exit(2);
    }
 
    initStringInfo(&linebuf);
 
    while (pg_get_line_buf(s, &linebuf))
    {
        /* check for "#line " in the beginning */
        if (strstr(linebuf.data, "#line ") == linebuf.data)
        {
            char       *p = strchr(linebuf.data, '"');
            int         plen = 1;
 
            while (*p && (*(p + plen) == '.' || strchr(p + plen, '/') != NULL))
            {
                plen++;
            }
            /* plen is one more than the number of . and / characters */
            if (plen > 1)
            {
                memmove(p + 1, p + plen, strlen(p + plen) + 1);
                /* we don't bother to fix up linebuf.len */
            }
        }
        fputs(linebuf.data, t);
    }
 
    pfree(linebuf.data);
    fclose(s);
    fclose(t);
}

References StringInfoData::data, exit(), fprintf, initStringInfo(), outfile, pfree(), and pg_get_line_buf().

Referenced by ecpg_start_test().

ecpg_filter_stderr()

static void ecpg_filter_stderr ( const char *  resultfile, const char *  tmpfile  )

static

Definition at line 93 of file pg_regress_ecpg.c.

{
    FILE       *s,
               *t;
    StringInfoData linebuf;
 
    s = fopen(resultfile, "r");
    if (!s)
    {
        fprintf(stderr, "Could not open file %s for reading\n", resultfile);
        exit(2);
    }
    t = fopen(tmpfile, "w");
    if (!t)
    {
        fprintf(stderr, "Could not open file %s for writing\n", tmpfile);
        exit(2);
    }
 
    initStringInfo(&linebuf);
 
    while (pg_get_line_buf(s, &linebuf))
    {
        char       *p1 = strstr(linebuf.data, "connection to server ");
 
        if (p1)
        {
            char       *p2 = strstr(p1, "failed: ");
 
            if (p2)
            {
                memmove(p1 + 21, p2, strlen(p2) + 1);
                /* we don't bother to fix up linebuf.len */
            }
        }
        fputs(linebuf.data, t);
    }
 
    pfree(linebuf.data);
    fclose(s);
    fclose(t);
    if (rename(tmpfile, resultfile) != 0)
    {
        fprintf(stderr, "Could not overwrite file %s with %s\n",
                resultfile, tmpfile);
        exit(2);
    }
}

References StringInfoData::data, exit(), fprintf, initStringInfo(), p2, pfree(), and pg_get_line_buf().

Referenced by ecpg_postprocess_result().

ecpg_init()

static void ecpg_init ( int  argc, char *  argv[]  )

static

Definition at line 254 of file pg_regress_ecpg.c.

{
    /* nothing to do here at the moment */
}

Referenced by main().

ecpg_postprocess_result()

static void ecpg_postprocess_result ( const char *  filename )

static

Definition at line 239 of file pg_regress_ecpg.c.

{
    int         nlen = strlen(filename);
 
    /* Only stderr files require filtering, at the moment */
    if (nlen > 7 && strcmp(filename + nlen - 7, ".stderr") == 0)
    {
        char       *tmpfile = psprintf("%s.tmp", filename);
 
        ecpg_filter_stderr(filename, tmpfile);
        pfree(tmpfile);
    }
}

References ecpg_filter_stderr(), filename, pfree(), and psprintf().

Referenced by main().

ecpg_start_test()

static PID_TYPE ecpg_start_test ( const char *  testname, _stringlist **  resultfiles, _stringlist **  expectfiles, _stringlist **  tags  )

static

Definition at line 148 of file pg_regress_ecpg.c.

{
    PID_TYPE    pid;
    char        inprg[MAXPGPATH];
    char        insource[MAXPGPATH];
    StringInfoData testname_dash;
    char        outfile_stdout[MAXPGPATH],
                expectfile_stdout[MAXPGPATH];
    char        outfile_stderr[MAXPGPATH],
                expectfile_stderr[MAXPGPATH];
    char        outfile_source[MAXPGPATH],
                expectfile_source[MAXPGPATH];
    char        cmd[MAXPGPATH * 3];
    char       *appnameenv;
 
    snprintf(inprg, sizeof(inprg), "%s/%s", inputdir, testname);
    snprintf(insource, sizeof(insource), "%s/%s.c", inputdir, testname);
 
    /* make a version of the test name that has dashes in place of slashes */
    initStringInfo(&testname_dash);
    appendStringInfoString(&testname_dash, testname);
    for (char *c = testname_dash.data; *c != '\0'; c++)
    {
        if (*c == '/')
            *c = '-';
    }
 
    snprintf(expectfile_stdout, sizeof(expectfile_stdout),
             "%s/expected/%s.stdout",
             expecteddir, testname_dash.data);
    snprintf(expectfile_stderr, sizeof(expectfile_stderr),
             "%s/expected/%s.stderr",
             expecteddir, testname_dash.data);
    snprintf(expectfile_source, sizeof(expectfile_source),
             "%s/expected/%s.c",
             expecteddir, testname_dash.data);
 
    snprintf(outfile_stdout, sizeof(outfile_stdout),
             "%s/results/%s.stdout",
             outputdir, testname_dash.data);
    snprintf(outfile_stderr, sizeof(outfile_stderr),
             "%s/results/%s.stderr",
             outputdir, testname_dash.data);
    snprintf(outfile_source, sizeof(outfile_source),
             "%s/results/%s.c",
             outputdir, testname_dash.data);
 
    add_stringlist_item(resultfiles, outfile_stdout);
    add_stringlist_item(expectfiles, expectfile_stdout);
    add_stringlist_item(tags, "stdout");
 
    add_stringlist_item(resultfiles, outfile_stderr);
    add_stringlist_item(expectfiles, expectfile_stderr);
    add_stringlist_item(tags, "stderr");
 
    add_stringlist_item(resultfiles, outfile_source);
    add_stringlist_item(expectfiles, expectfile_source);
    add_stringlist_item(tags, "source");
 
    ecpg_filter_source(insource, outfile_source);
 
    snprintf(cmd, sizeof(cmd),
             "\"%s\" >\"%s\" 2>\"%s\"",
             inprg,
             outfile_stdout,
             outfile_stderr);
 
    appnameenv = psprintf("ecpg/%s", testname_dash.data);
    setenv("PGAPPNAME", appnameenv, 1);
    free(appnameenv);
 
    pid = spawn_process(cmd);
 
    if (pid == INVALID_PID)
    {
        fprintf(stderr, _("could not start process for test %s\n"),
                testname);
        exit(2);
    }
 
    unsetenv("PGAPPNAME");
 
    free(testname_dash.data);
 
    return pid;
}

References _, add_stringlist_item(), appendStringInfoString(), StringInfoData::data, ecpg_filter_source(), exit(), expecteddir, fprintf, free, initStringInfo(), inputdir, INVALID_PID, MAXPGPATH, outputdir, PID_TYPE, psprintf(), setenv, snprintf, spawn_process(), and unsetenv.

Referenced by main().

main()

int main	(	int	argc,
		char *	argv[]
	)

Definition at line 260 of file pg_regress_ecpg.c.

{
    return regression_main(argc, argv,
                           ecpg_init,
                           ecpg_start_test,
                           ecpg_postprocess_result);
}

References ecpg_init(), ecpg_postprocess_result(), ecpg_start_test(), and regression_main().