+/**
+ * libsortnetwork - src/sn_stage.c
+ * Copyright (C) 2008-2010 Florian octo Forster
+ *
+ * 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; only version 2 of the License is applicable.
+ *
+ * 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 St, Fifth Floor, Boston, MA 02110-1301 USA
+ *
+ * Authors:
+ * Florian octo Forster <ff at octo.it>
+ **/
+
+#ifndef _ISOC99_SOURCE
+# define _ISOC99_SOURCE
+#endif
+#ifndef _POSIX_C_SOURCE
+# define _POSIX_C_SOURCE 200112L
+#endif
+
#include <stdlib.h>
#include <string.h>
#include <assert.h>
+#include <errno.h>
#include "sn_comparator.h"
#include "sn_stage.h"
free (s);
} /* void sn_stage_destroy */
+int sn_stage_sort (sn_stage_t *s, int *values)
+{
+ sn_comparator_t *c;
+ int i;
+
+ for (i = 0; i < s->comparators_num; i++)
+ {
+ c = s->comparators + i;
+ if (values[c->min] > values[c->max])
+ {
+ int temp;
+
+ temp = values[c->min];
+ values[c->min] = values[c->max];
+ values[c->max] = temp;
+ }
+ }
+
+ return (0);
+} /* int sn_stage_sort */
+
int sn_stage_comparator_add (sn_stage_t *s, const sn_comparator_t *c)
{
sn_comparator_t *temp;
int i;
+ if ((s == NULL) || (c == NULL))
+ return (EINVAL);
+
+ i = sn_stage_comparator_check_conflict (s, c);
+ if (i != 0)
+ return (i);
+
temp = (sn_comparator_t *) realloc (s->comparators,
(s->comparators_num + 1) * sizeof (sn_comparator_t));
if (temp == NULL)
- return (-1);
+ return (ENOMEM);
s->comparators = temp;
temp = NULL;
int nmemb = s->comparators_num - (c_num + 1);
sn_comparator_t *temp;
+ if ((s == NULL) || (s->comparators_num <= c_num))
+ return (EINVAL);
+
assert (c_num < s->comparators_num);
+ assert (c_num >= 0);
if (nmemb > 0)
memmove (s->comparators + c_num, s->comparators + (c_num + 1),
s->comparators_num--;
/* Free the unused memory */
- temp = (sn_comparator_t *) realloc (s->comparators,
- s->comparators_num * sizeof (sn_comparator_t));
- if (temp == NULL)
- return (-1);
- s->comparators = temp;
+ if (s->comparators_num == 0)
+ {
+ free (s->comparators);
+ s->comparators = NULL;
+ }
+ else
+ {
+ temp = (sn_comparator_t *) realloc (s->comparators,
+ s->comparators_num * sizeof (sn_comparator_t));
+ if (temp == NULL)
+ return (-1);
+ s->comparators = temp;
+ }
return (0);
} /* int sn_stage_comparator_remove */
+sn_stage_t *sn_stage_clone (const sn_stage_t *s)
+{
+ sn_stage_t *s_copy;
+
+ s_copy = sn_stage_create (s->depth);
+ if (s_copy == NULL)
+ return (NULL);
+
+ s_copy->comparators = (sn_comparator_t *) malloc (s->comparators_num
+ * sizeof (sn_comparator_t));
+ if (s_copy->comparators == NULL)
+ {
+ free (s_copy);
+ return (NULL);
+ }
+
+ memcpy (s_copy->comparators, s->comparators,
+ s->comparators_num * sizeof (sn_comparator_t));
+ s_copy->comparators_num = s->comparators_num;
+
+ return (s_copy);
+} /* sn_stage_t *sn_stage_clone */
+
int sn_stage_comparator_check_conflict (sn_stage_t *s, const sn_comparator_t *c0)
{
int i;
int j;
int k;
-
for (i = 0; i < s->comparators_num; i++)
{
lines[i] = -1;
{
int i;
+ if (s == NULL)
+ return (EINVAL);
+
for (i = 0; i < s->comparators_num; i++)
sn_comparator_invert (s->comparators + i);
return (0);
} /* int sn_stage_invert */
+int sn_stage_shift (sn_stage_t *s, int sw, int inputs_num)
+{
+ int i;
+
+ if ((s == NULL) || (inputs_num < 2))
+ return (EINVAL);
+
+ sw %= inputs_num;
+ if (sw == 0)
+ return (0);
+
+ for (i = 0; i < s->comparators_num; i++)
+ sn_comparator_shift (s->comparators + i, sw, inputs_num);
+
+ return (0);
+} /* int sn_stage_shift */
+
int sn_stage_swap (sn_stage_t *s, int con0, int con1)
{
int i;
+ if (s == NULL)
+ return (EINVAL);
+
for (i = 0; i < s->comparators_num; i++)
sn_comparator_swap (s->comparators + i, con0, con1);
int new_position = input;
int i;
+ if ((s == NULL) || (input < 0))
+ return (-EINVAL);
+
for (i = 0; i < s->comparators_num; i++)
{
sn_comparator_t *c = s->comparators + i;
return (0);
} /* int sn_stage_write */
-/* vim: set shiftwidth=2 softtabstop=2 : */
+int sn_stage_serialize (sn_stage_t *s,
+ char **ret_buffer, size_t *ret_buffer_size)
+{
+ char *buffer;
+ size_t buffer_size;
+ int status;
+ int i;
+
+ if (s->comparators_num <= 0)
+ return (0);
+
+ buffer = *ret_buffer;
+ buffer_size = *ret_buffer_size;
+
+#define SNPRINTF_OR_FAIL(...) \
+ status = snprintf (buffer, buffer_size, __VA_ARGS__); \
+ if ((status < 1) || (((size_t) status) >= buffer_size)) \
+ return (-1); \
+ buffer += status; \
+ buffer_size -= status;
+
+ for (i = 0; i < s->comparators_num; i++)
+ {
+ SNPRINTF_OR_FAIL ("%i %i\r\n",
+ SN_COMP_MIN (s->comparators + i),
+ SN_COMP_MAX (s->comparators + i));
+ }
+
+ SNPRINTF_OR_FAIL ("\r\n");
+
+ *ret_buffer = buffer;
+ *ret_buffer_size = buffer_size;
+ return (0);
+} /* int sn_stage_serialize */
+
+sn_stage_t *sn_stage_unserialize (char **ret_buffer, size_t *ret_buffer_size)
+{
+ sn_stage_t *s;
+ char *buffer;
+ size_t buffer_size;
+ int status;
+
+ buffer = *ret_buffer;
+ buffer_size = *ret_buffer_size;
+
+ if (buffer_size == 0)
+ return (NULL);
+
+ s = sn_stage_create (0);
+ if (s == NULL)
+ return (NULL);
+
+ status = 0;
+ while (buffer_size > 0)
+ {
+ sn_comparator_t c;
+ char *endptr;
+ char *substr;
+ size_t substr_length;
+
+ endptr = strchr (buffer, '\n');
+ if (endptr == NULL)
+ {
+ status = -1;
+ break;
+ }
+
+ *endptr = 0;
+ endptr++;
+
+ substr = buffer;
+ substr_length = strlen (buffer);
+ buffer = endptr;
+ buffer_size -= (substr_length + 1);
+
+ if ((substr_length > 0) && (substr[substr_length - 1] == '\r'))
+ {
+ substr[substr_length - 1] = 0;
+ substr_length--;
+ }
+
+ if (substr_length == 0)
+ {
+ status = 0;
+ break;
+ }
+
+ endptr = NULL;
+ c.min = (int) strtol (substr, &endptr, 0);
+ if (substr == endptr)
+ {
+ status = -1;
+ break;
+ }
+
+ substr = endptr;
+ endptr = NULL;
+ c.max = (int) strtol (substr, &endptr, 0);
+ if (substr == endptr)
+ {
+ status = -1;
+ break;
+ }
+
+ sn_stage_comparator_add (s, &c);
+ } /* while (buffer_size > 0) */
+
+ if ((status != 0) || (s->comparators_num == 0))
+ {
+ sn_stage_destroy (s);
+ return (NULL);
+ }
+
+ *ret_buffer = buffer;
+ *ret_buffer_size = buffer_size;
+ return (s);
+} /* sn_stage_t *sn_stage_unserialize */
+
+/* vim: set shiftwidth=2 softtabstop=2 expandtab : */
projects / sort-networks.git / blobdiff