ACLOCAL_AMFLAGS = -I m4

pkgconfigdir = $(libdir)/pkgconfig

# both srcdir and builddir are needed because config.h ends up in builddir

AM_CPPFLAGS = -DSYSCONFDIR='"$(sysconfdir)"' \

	-DLOCALSTATEDIR='"$(localstatedir)"' \

	-I$(top_srcdir)/src \

	-I$(top_builddir)/src

AM_CFLAGS = $(DISTLIBS_CFLAGS)

# we need the clock_gettime() function

LIBS = $(DISTLIBS_LIBS) -lrt

bin_PROGRAMS = distren

if ENABLE_SERVER

bin_PROGRAMS += distrend distrenslave distrensimpleslave

endif

include_HEADERS = src/client/distren.h

lib_LTLIBRARIES = libdistren.la

pkglib_LTLIBRARIES = libdistrencommon.la

nodist_pkgconfig_DATA = libdistren.pc

# libdistrencommon.la:

libdistrencommon_la_SOURCES = src/common/asprintf.c src/common/asprintf.h \

	src/common/execio.c src/common/execio.h \

	src/common/misc.c src/common/misc.h \

	src/common/multiio.c src/common/multiio.h \

	src/common/options.c src/common/options.h \

	src/common/protocol.c src/common/protocol.h \

	src/common/csv.c src/common/csv.h \

	src/common/remoteio.h \

	src/common/remoteio.c src/common/libremoteio.h \

	src/common/request.c src/common/request.h

#see http://sources.redhat.com/autobook/autobook/autobook_91.html

# either increase the revision number or the interface number each release!

libdistrencommon_la_LDFLAGS = $(AM_LDFLAGS) -version-info 0:0:0

#library client

libdistren_la_SOURCES = \

	src/client/libdistren.c src/client/libdistren.h \

	src/client/libdistren_config.c \

	src/client/libdistren_job.c \

	src/client/libdistren_request.c

libdistren_la_LIBADD = libdistrencommon.la

#CLI client.

distren_SOURCES = \

	src/client/distren.c

distren_LDADD = libdistrencommon.la libdistren.la

# shared server sources:

SERVER_SOURCES = \

	src/server/slavefuncs.c	src/server/slavefuncs.h \

	src/server/distrenjob.c	src/server/distrenjob.h

# distrend:

distrend_CFLAGS = $(AM_CFLAGS) $(MYSQL_CFLAGS)

distrend_LDFLAGS = $(AM_LDFLAGS) $(MYSQL_LDFLAGS)

distrend_SOURCES = $(SERVER_SOURCES) \

	src/server/distrend.c	src/server/distrend.h \

	src/server/listen.h	src/server/listen.c \

	src/server/mysql.h	src/server/mysql.c \

	src/server/tabletennis.c	src/server/tabletennis.h \

	src/server/user_mgr.c	src/server/user_mgr.h

distrend_LDADD = libdistrencommon.la

# distrenslave:

distrenslave_SOURCES = $(SERVER_SOURCES) \

	src/server/slave.c

distrenslave_LDADD = libdistrencommon.la

# distrensimpleslave:

distrensimpleslave_SOURCES = $(SERVER_SOURCES) \

        src/server/simpleslave.c

distrensimpleslave_LDADD = libdistrencommon.la

# configuration files:

dist_sysconf_DATA = etc/distrencommon.conf

nodist_sysconf_DATA = etc/distrendaemon.conf \

	etc/distrenslave.conf

EXTRA_DIST = etc/distrendaemon.conf.in \

	etc/distrenslave.conf.in

# tests

/*

  Copyright 2010 Nathan Phillip Brink

  This file is a part of DistRen.

  DistRen is free software: you can redistribute it and/or modify

  it under the terms of the GNU Affero General Public License as published by

  the Free Software Foundation, either version 3 of the License, or

  (at your option) any later version.

  DistRen 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 Affero General Public License for more details.

  You should have received a copy of the GNU Affero General Public License

  along with DistRen.  If not, see <http://www.gnu.org/licenses/>.

*/

#include "common/asprintf.h"

#include <check.h>

#include <string.h>

START_TEST (check_asprintf)

{

  /* tere _must_ be a better way to test this... */

  char *teststring = "abcdefghijklmnopqrstuvwxyz";

  char *result;

  _distren_asprintf(&result, "I am te%sting\n", teststring);

  fail_unless(strcmp(result, "I am teabcdefghijklmnopqrstuvwxyzting\n") == 0,

	      "simple asprintf check failed");

}

END_TEST

{

}

/*

 * Copyright 2010 Nathan Phillip Brink

 *

 * This file is a part of DistRen.

 *

 * DistRen is free software: you can redistribute it and/or modify

 * it under the terms of the GNU Affero General Public License as published by

 * the Free Software Foundation, either version 3 of the License, or

 * (at your option) any later version.

 *

 * DistRen 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 Affero General Public License for more details.

 *

 * You should have received a copy of the GNU Affero General Public License

 * along with DistRen.  If not, see <http://www.gnu.org/licenses/>.

 */

#include "common/csv.h"

#include <check.h>

#include <list.h>

#include <stdarg.h>

#include <stdio.h>

#include <stdlib.h>

#include <string.h>

struct check_correct_vals

{

  size_t row;

  size_t num_cols;

  char ***correct_vals;

};

static void **array_init(size_t num_elems, ...)

{

  va_list args;

  void **array;

  size_t c;

  array = malloc(sizeof(void *) * (num_elems + 1));

  if (!array)

    return NULL;

  va_start(args, num_elems);

  for (c = 0; c < num_elems; c ++)

    array[c] = va_arg(args, void *);

  array[c] = NULL;

  va_end(args);

  return array;

}

static int check_correct_vals(struct check_correct_vals *state, csv_row_t row)

{

  size_t c;

  fail_unless (state->num_cols == row->num_cols,

	       "We asked for %d columns but got %d on row %d",

	       state->num_cols, row->num_cols, state->row);

  for (c = 0; c < row->num_cols; c ++)

    {

      fail_if(strcmp(state->correct_vals[state->row][c],

		     row->cols[c]),

	      "%d:%d: Expecting %s: got %s",

	      state->row, c,

	      state->correct_vals[state->row][c],

	      row->cols[c]

	      );

    }

  state->row ++;

  if (state->correct_vals[state->row])

    /* there is yet another row to process */

    return TRUE;

  return FALSE;

}

START_TEST(check_csv)

{

  list_t rows;

  struct check_correct_vals vals;

  char ***correct_vals;

  correct_vals =

    (char ***)array_init(4,

			 array_init(3, "23", "1" , "0.0"),

			 array_init(3, "a" , " b", ""   ),

			 array_init(3, "f" , "df", ""   ),

			 array_init(3, "d" , "f" , "ss" ));

  fail_if(correct_vals == NULL, "array_init() returned NULL");

  vals.num_cols = 3;

  vals.correct_vals = correct_vals;

  vals.row = 0;

  rows = csv_parse("23,1,0.0\n\

a, b,,d\n\

f,df\n\

d,f,ss,e\n", vals.num_cols);

  fail_if(rows == NULL, "csv_parse() returned NULL");

  list_traverse(rows, &vals, (list_traverse_func_t)&check_correct_vals, LIST_FRNT|LIST_SAVE|LIST_FORW);

  list_free(rows, (list_dealloc_func_t)&csv_row_free);

}

END_TEST

{

  Suite *s;

  TCase *tc;

  s = suite_create("csv");

  tc = tcase_create("core");

  tcase_add_test(tc, check_csv);

  suite_add_tcase(s, tc);

  return s;

}

/*

#include "common/execio.h"

#include <check.h>

START_TEST (check_execio)

{

  struct execio *eio;

  char *echoargv[] = 

    {

      "echo",

      "test"

    };

  char inbuf[20];

  size_t bytesread;

  fail_unless(execio_open(&eio, echoargv[0], echoargv) == 0,

	      "execio_open failed");

  fail_unless(execio_read(eio, inbuf, sizeof(inbuf) - 1, &bytesread) == 0,

	      "error using execio_read\n");

  fail_unless(execio_close(eio) == 0,

	      "error using execio_close\n");

}

END_TEST

{

}