diff options
Diffstat (limited to 'debian/opensync/opensync-0.22/formats/file.c')
| -rw-r--r-- | debian/opensync/opensync-0.22/formats/file.c | 303 |
1 files changed, 0 insertions, 303 deletions
diff --git a/debian/opensync/opensync-0.22/formats/file.c b/debian/opensync/opensync-0.22/formats/file.c deleted file mode 100644 index 5742eb2d..00000000 --- a/debian/opensync/opensync-0.22/formats/file.c +++ /dev/null @@ -1,303 +0,0 @@ -/* - * opensync - A plugin for file objects for the opensync framework - * Copyright (C) 2004-2005 Armin Bauer <armin.bauer@opensync.org> - * - * This library is free software; you can redistribute it and/or - * modify it under the terms of the GNU Lesser General Public - * License as published by the Free Software Foundation; either - * version 2.1 of the License, or (at your option) any later version. - * - * This library 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 - * Lesser General Public License for more details. - * - * You should have received a copy of the GNU Lesser General Public - * License along with this library; if not, write to the Free Software - * Foundation, Inc., 59 Temple Place, Suite 330, Boston, MA 02111-1307 USA - * - */ - -#include <opensync/opensync.h> - -#include "file.h" -#include <string.h> -#include <glib.h> - -static OSyncConvCmpResult compare_file(OSyncChange *leftchange, OSyncChange *rightchange) -{ - osync_trace(TRACE_ENTRY, "%s(%p, %p)", __func__, leftchange, rightchange); - - fileFormat *leftfile = (fileFormat *)osync_change_get_data(leftchange); - fileFormat *rightfile = (fileFormat *)osync_change_get_data(rightchange); - - osync_bool data_same = FALSE; - osync_bool path_same = FALSE; - - if (!strcmp(osync_change_get_uid(leftchange), osync_change_get_uid(rightchange))) - path_same = TRUE; - - osync_trace(TRACE_INTERNAL, "%i %i", leftfile->size, rightfile->size); - - if (leftfile->size == rightfile->size) { - if (leftfile->data == rightfile->data) { - data_same = TRUE; - } else { - if (!memcmp(leftfile->data, rightfile->data, leftfile->size)) - data_same = TRUE; - } - } - - if (data_same && path_same) { - osync_trace(TRACE_EXIT, "%s: Same", __func__); - return CONV_DATA_SAME; - } - if (path_same) { - osync_trace(TRACE_EXIT, "%s: Similar", __func__); - return CONV_DATA_SIMILAR; - } - - osync_trace(TRACE_EXIT, "%s: Mismatch", __func__); - return CONV_DATA_MISMATCH; -} - -#ifdef STRESS_TEST -static void create_file(OSyncChange *change) -{ - osync_debug("FILE", 4, "start: %s", __func__); - fileFormat *file_info = g_malloc0(sizeof(fileFormat)); - int file_size = g_random_int_range(0, 1000); - osync_change_set_data(change, (char *)file_info, sizeof(fileFormat), TRUE); - - file_info->data = g_malloc0(file_size * 105 * sizeof(char)); - file_info->size = file_size * 100 * sizeof(char); - - char *datap = file_info->data; - FILE *fd = fopen("/dev/urandom", "r"); - if (fd) { - for (; file_size > 5; file_size--) { - fread(datap, 100, 1, fd); - datap += 100 * sizeof(char); - } - } - fclose(fd); - osync_change_set_uid(change, osync_rand_str(6)); -} -#endif - -static osync_bool conv_file_to_plain(void *user_data, char *input, int inpsize, char **output, int *outpsize, osync_bool *free_input, OSyncError **error) -{ - osync_trace(TRACE_ENTRY, "%s(%p, %p, %i, %p, %p, %p, %p)", __func__, user_data, input, inpsize, output, outpsize, free_input, error); - g_assert(inpsize == sizeof(fileFormat)); - fileFormat *file = (fileFormat *)input; - - *free_input = FALSE; - *output = file->data; - *outpsize = file->size; - - osync_trace(TRACE_EXIT, "%s", __func__); - return TRUE; -} - -static osync_bool conv_plain_to_file(void *user_data, char *input, int inpsize, char **output, int *outpsize, osync_bool *free_input, OSyncError **error) -{ - osync_trace(TRACE_ENTRY, "%s(%p, %p, %i, %p, %p, %p, %p)", __func__, user_data, input, inpsize, output, outpsize, free_input, error); - fileFormat *file = osync_try_malloc0(sizeof(fileFormat), error); - if (!file) - goto error; - - file->data = input; - file->size = inpsize; - - *free_input = FALSE; - *output = (char *)file; - *outpsize = sizeof(*file); - - osync_trace(TRACE_EXIT, "%s", __func__); - return TRUE; - -error: - osync_trace(TRACE_EXIT_ERROR, "%s: %s", __func__, osync_error_print(error)); - return FALSE; -} - -static osync_bool marshall_file(const char *input, int inpsize, char **output, int *outpsize, OSyncError **error) -{ - /* The marshall block will be a fileFormat struct, followed by the file data - * - * the 'data' field on fileFormat will be set to NULL - */ - - /* Get our input file struct */ - g_assert(inpsize == sizeof(fileFormat)); - fileFormat *file = (fileFormat*)input; - - /* Allocate our block */ - int osize = sizeof(fileFormat) + file->size; - char *out = osync_try_malloc0(osize, error); - if (!out) - goto error; - - - /* Get the pointers to the output data: */ - /* fileFormat struct in the beginning */ - fileFormat *outfile = (fileFormat*)out; - /* file data immediately after outfile */ - char *outdata = ((char*)outfile) + sizeof(fileFormat); - - /* Copy the data: */ - /* file struct */ - memcpy(outfile, file, sizeof(fileFormat)); - outfile->data = NULL; - - /* file data */ - if (file->size > 0) - memcpy(outdata, file->data, file->size); - - *output = out; - *outpsize = osize; - return TRUE; - -error: - return FALSE; -} - -static osync_bool demarshall_file(const char *input, int inpsize, char **output, int *outpsize, OSyncError **error) -{ - /* Get file struct */ - g_assert(inpsize >= sizeof(fileFormat)); - fileFormat *file = (fileFormat*)input; - - /* get file data */ - g_assert(inpsize == sizeof(fileFormat) + file->size); - const char *filedata = input + sizeof(fileFormat); - - fileFormat *newfile = osync_try_malloc0(sizeof(fileFormat), error); - if (!newfile) - goto error; - - memcpy(newfile, file, sizeof(fileFormat)); - - if (file->size > 0) { - newfile->data = osync_try_malloc0(file->size, error); - if (!newfile->data) - goto error_free_file; - - memcpy(newfile->data, filedata, file->size); - } else - newfile->data = NULL; - - *output = (char*)newfile; - *outpsize = sizeof(fileFormat); - return TRUE; - -error_free_file: - g_free(newfile); -error: - return FALSE; -} - -static void destroy_file(char *input, size_t inpsize) -{ - osync_trace(TRACE_ENTRY, "%s(%p, %i)", __func__, input, inpsize); - g_assert(inpsize == sizeof(fileFormat)); - fileFormat *file = (fileFormat *)input; - - g_free(file->data); - g_free(file); - - osync_trace(TRACE_EXIT, "%s", __func__); -} - -static void duplicate_file(OSyncChange *change) -{ - osync_trace(TRACE_ENTRY, "%s(%p)", __func__, change); - - char *newuid = g_strdup_printf ("%s-dupe", osync_change_get_uid(change)); - osync_change_set_uid(change, newuid); - g_free(newuid); - - osync_trace(TRACE_EXIT, "%s", __func__); -} - -static osync_bool copy_file(const char *input, int inpsize, char **output, int *outpsize) -{ - osync_trace(TRACE_ENTRY, "%s(%p, %i, %p, %p)", __func__, input, inpsize, output, outpsize); - - fileFormat *oldfile = (fileFormat *)input; - fileFormat *newfile = g_malloc0(sizeof(fileFormat)); - - newfile->groupid = oldfile->groupid; - newfile->mode = oldfile->mode; - newfile->userid = oldfile->userid; - newfile->size = oldfile->size; - newfile->last_mod = oldfile->last_mod; - - if (oldfile->size) { - newfile->data = g_malloc0(oldfile->size); - memcpy(newfile->data, oldfile->data, oldfile->size); - } - - *output = (char *)newfile; - *outpsize = inpsize; - - osync_trace(TRACE_EXIT, "%s", __func__); - return TRUE; -} - -static void create_file(OSyncChange *change) -{ - osync_debug("FILE", 4, "start: %s", __func__); - - fileFormat *newfile = g_malloc0(sizeof(fileFormat)); - - char *data = osync_rand_str(g_random_int_range(1, 100)); - newfile->data = data; - newfile->size = strlen(data) + 1; - - osync_change_set_data(change, (char *)newfile, sizeof(newfile), TRUE); - if (!osync_change_get_uid(change)) - osync_change_set_uid(change, osync_rand_str(6)); -} - -static time_t revision_file(OSyncChange *change, OSyncError **error) -{ - osync_trace(TRACE_ENTRY, "%s(%p, %p)", __func__, change, error); - - fileFormat *filechange = (fileFormat *)osync_change_get_data(change); - time_t lastmod = filechange->last_mod; - - osync_trace(TRACE_EXIT, "%s: %i", __func__, lastmod); - return lastmod; -} - -static char *print_file(OSyncChange *change) -{ - osync_debug("FILE", 4, "start: %s", __func__); - fileFormat *file = (fileFormat *)osync_change_get_data(change); - - char *printable = g_strdup_printf ("File: %s\nSize: %i", osync_change_get_uid(change), file ? file->size : 0); - return printable; -} - -void get_info(OSyncEnv *env) -{ - osync_env_register_objtype(env, "data"); - osync_env_register_objformat(env, "data", "file"); - osync_env_format_set_compare_func(env, "file", compare_file); - osync_env_format_set_duplicate_func(env, "file", duplicate_file); - osync_env_format_set_destroy_func(env, "file", destroy_file); - osync_env_format_set_print_func(env, "file", print_file); - osync_env_format_set_copy_func(env, "file", copy_file); - osync_env_format_set_create_func(env, "file", create_file); - osync_env_format_set_revision_func(env, "file", revision_file); - - osync_env_format_set_marshall_func(env, "file", marshall_file); - osync_env_format_set_demarshall_func(env, "file", demarshall_file); - -#ifdef STRESS_TEST - osync_env_format_set_create_func(env, "file", create_file); -#endif - osync_env_register_converter(env, CONVERTER_DECAP, "file", "plain", conv_file_to_plain); - osync_env_register_converter(env, CONVERTER_ENCAP, "plain", "file", conv_plain_to_file); -} |