/var/data/www/opensync/code/opensync/plugin/opensync_objtype_sink_private.h

/*
 * libopensync - A synchronization 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
 * 
 */

#ifndef OPENSYNC_OBJTYPE_SINK_PRIVATE_H_
#define OPENSYNC_OBJTYPE_SINK_PRIVATE_H_


#define OSYNC_SINK_TIMEOUT_TRANSPORT    30
#define OSYNC_SINK_TIMEOUT_SINGLEIO     30
#define OSYNC_SINK_TIMEOUT_BATCHIO      1800

/* FIXME: OSYNC_SINK_TIMEOUT_COMMIT, OSYNC_SINK_TIMEOUT_READ,
   OSYNC_SINK_TIMEOUT_WRITE are set to OSYNC_SINK_TIMEOUT_BATCHIO
   to workaround a timeout issue with the async client/proxy
   communication and the current timeout handling.

   All async i/o call (message) recieved by the client get processed in
   a sequence. Each event gets appended at the end of the queue
   and sits there; timeout handlers keeps already ticking!

   Commits which got added at the end of a long queue of events,
   doesn't get processed in time and get killed by the timeout handler.

   TODO: Fix timeout handler and start ticking when SINGLEIO get processed.
   Reset  OSYNC_SINK_TIMEOUT_COMMIT, OSYNC_SINK_TIMEOUT_READ and other SINGLEIO
   actions to SINGLEIO timeout values by default.
 
 */

#define OSYNC_SINK_TIMEOUT_CONNECT      OSYNC_SINK_TIMEOUT_TRANSPORT 
#define OSYNC_SINK_TIMEOUT_CONNECTDONE  OSYNC_SINK_TIMEOUT_SINGLEIO
#define OSYNC_SINK_TIMEOUT_DISCONNECT   OSYNC_SINK_TIMEOUT_TRANSPORT 
#define OSYNC_SINK_TIMEOUT_GETCHANGES   OSYNC_SINK_TIMEOUT_BATCHIO
#define OSYNC_SINK_TIMEOUT_COMMIT       OSYNC_SINK_TIMEOUT_BATCHIO /* FIXME */
#define OSYNC_SINK_TIMEOUT_BATCHCOMMIT  OSYNC_SINK_TIMEOUT_BATCHIO
#define OSYNC_SINK_TIMEOUT_COMMITTEDALL OSYNC_SINK_TIMEOUT_SINGLEIO
#define OSYNC_SINK_TIMEOUT_SYNCDONE     OSYNC_SINK_TIMEOUT_SINGLEIO
#define OSYNC_SINK_TIMEOUT_READ         OSYNC_SINK_TIMEOUT_BATCHIO /* FIXME */
#define OSYNC_SINK_TIMEOUT_WRITE        OSYNC_SINK_TIMEOUT_BATCHIO /* FIXME */

typedef struct OSyncObjTypeSinkFunctionTimeouts {
        unsigned int connect;
        unsigned int connect_done;
        unsigned int disconnect;
        unsigned int get_changes;
        unsigned int commit;
        unsigned int batch_commit;
        unsigned int committed_all;
        unsigned int sync_done;
        unsigned int read;
        unsigned int write;
} OSyncObjTypeSinkFunctionTimeouts;

struct OSyncObjTypeSink {
        OSyncAnchor *anchor;

        osync_bool anchor_requested;

        char *preferred_format;
        OSyncList *objformatsinks;

        OSyncObjTypeSinkFunctions functions;
        void *userdata;

        OSyncObjTypeSinkFunctionTimeouts timeout;
        
        char *objtype;

        osync_bool write;
        osync_bool func_write;

        osync_bool read;
        osync_bool func_read;

        osync_bool getchanges; 
        osync_bool func_getchanges; 

        osync_bool enabled;

        osync_bool slowsync;

        int ref_count;

        OSyncList *commit_changes;
        OSyncList *commit_contexts;
        osync_bool available;
};

#endif /* OPENSYNC_OBJTYPE_SINK_PRIVATE_H_ */

---