Changeset 2563

Timestamp:

10/14/07 15:29:12 (1 year ago)

Author:

dgollub

Message:

Initial support for unidirectioanl synchronization.

Example:

Changing the member configuratin (syncmember.conf) from

<write>1</write>

to

<write>0</write>

make the member objtype sink to "read-only". Only for this objtype sink!
No changes will be commited to this object type sink...

This can be changed and checked with:

osync_bool osync_objtype_sink_get_write(OSyncObjTypeSink *sink);
void osync_objtype_sink_set_write(OSyncObjTypeSink *sink, osync_bool write);

To store this settinges changes in the member confguration it's required to call:

osync_bool osync_member_save(OSyncMember *member, OSyncError **error)

<write>1</write> is default if the plugin provides a commit function.

Files:

• trunk/opensync/engine/opensync_obj_engine.c (modified) (5 diffs)

trunk/opensync/engine/opensync_obj_engine.c

@@ -1236 +1236 @@
-        for (p = engine->sink_engines; p; p = p->next) {
-                sinkengine = p->data;
+
+                OSyncMember *member = osync_client_proxy_get_member(sinkengine->proxy);
+                OSyncObjTypeSink *objtype_sink = osync_member_find_objtype_sink(member, engine->objtype);
+
+                /* If the sink engine isn't able/allowed to write we don't care if everything got written ("how dirty is it!?") */ 
+                if (!osync_objtype_sink_get_write(objtype_sink)) 
+                        break;
-                
-                for (e = sinkengine->entries; e; e = e->next) {
@@ -1512 +1519 @@
-                g_free(engine);
-        }
+}
+
+static int _osync_obj_engine_num_write_sinks(OSyncObjEngine *objengine) {
+        osync_trace(TRACE_ENTRY, "%s(%p)", __func__, objengine);
+
+        int num = 0;
+        GList *p = NULL;
+        OSyncSinkEngine *sink;
+
+        for (p = objengine->sink_engines; p; p = p->next) {
+                sink = p->data;
+
+
+        }
+
+        osync_trace(TRACE_EXIT, "%s: %i", __func__, num);
+        return num;
-}
-
@@ -1693 +1717 @@
-                        }
-
+                        int write_sinks = _osync_obj_engine_num_write_sinks(engine);
+
+                        /* Get change entries since last sync. (get_changes) */
-                        for (p = engine->sink_engines; p; p = p->next) {
-                                sinkengine = p->data;
+
+
+                                OSyncMember *member = osync_client_proxy_get_member(sinkengine->proxy);
+                                OSyncObjTypeSink *objtype_sink = osync_member_find_objtype_sink(member, engine->objtype);
+
+                                /* Is there at least one other writeable sink? */
+                                if (osync_objtype_sink_get_write(objtype_sink) && write_sinks) {
+                                        _obj_engine_read_callback(sinkengine->proxy, sinkengine, *error);
+                                        osync_trace(TRACE_INTERNAL, "no other writable sinks .... SKIP");
+                                        continue;
+                                }
+
-                                if (!osync_client_proxy_get_changes(sinkengine->proxy, _obj_engine_read_callback, sinkengine, engine->objtype, engine->slowsync, error))
-                                        goto error;
@@ -1725 +1764 @@
-                                sinkengine = p->data;
-                                
+                                OSyncMember *member = osync_client_proxy_get_member(sinkengine->proxy);
+                                long long int memberid = osync_member_get_id(member);
+
+                                OSyncObjTypeSink *objtype_sink = osync_member_find_objtype_sink(member, engine->objtype);
+
-                                for (e = sinkengine->entries; e; e = e->next) {
-                                        OSyncMappingEntryEngine *entry_engine = e->data;
-                                        osync_assert(entry_engine);
-
-                                        OSyncMember *member = osync_client_proxy_get_member(sinkengine->proxy);
-                                        long long int memberid = osync_member_get_id(member);
-                                        
-
-                                        /* Merger - Save the entire xml and demerge */
@@ -1768 +1808 @@
-                                        }
-
-
+
+
+
-                                                osync_assert(entry_engine->change);
-                                                OSyncChange *change = entry_engine->change;